in src/main/scala/payment_failure_comms/SalesforceConnector.scala [152:181]
private def logReadRequest(query: String, logger: LambdaLogger, request: Request): Unit =
Log.request(logger)(
service = Log.Service.Salesforce,
description = Some("Read outstanding payment failure records"),
url = request.url().toString,
method = request.method(),
query = Some(query)
)
def responseToQueryRequest(
url: String,
bearerToken: String,
query: String,
logger: LambdaLogger
): Either[Throwable, Response] = {
val urlWithParam = HttpUrl
.parse(url)
.newBuilder()
.addQueryParameter("q", query)
.build()
val request: Request = new Request.Builder()
.header("Authorization", s"Bearer $bearerToken")
.url(urlWithParam)
.get()
.build()
logReadRequest(query, logger, request)
Try(
HttpClient().newCall(request).execute()
).toEither
}