override def getSubscriptionByName()

in lambda/src/main/scala/pricemigrationengine/services/SalesforceClientLive.scala [88:127]
37 lines of code
1 McCabe index (conditional complexity)

        override def getSubscriptionByName(
            subscriptionName: String
        ): IO[SalesforceClientFailure, SalesforceSubscription] =
          sendRequestAndParseResponse[SalesforceSubscription](
            Http(
              s"${auth.instance_url}/${salesforceApiPathPrefixToVersion}/sobjects/SF_Subscription__c/Name/$subscriptionName"
            )
              .header("Authorization", s"Bearer ${auth.access_token}")
              .method("GET")
          ).tap(subscription => logging.info(s"Successfully loaded: ${subscription.Name}"))

        override def getContact(contactId: String): IO[SalesforceClientFailure, SalesforceContact] =
          sendRequestAndParseResponse[SalesforceContact](
            Http(s"${auth.instance_url}/${salesforceApiPathPrefixToVersion}/sobjects/Contact/$contactId")
              .header("Authorization", s"Bearer ${auth.access_token}")
              .method("GET")
          ).tap(contact => logging.info(s"Successfully loaded contact: ${contact.Id}"))

        override def createPriceRise(
            priceRise: SalesforcePriceRise
        ): IO[SalesforceClientFailure, SalesforcePriceRiseCreationResponse] =
          sendRequestAndParseResponse[SalesforcePriceRiseCreationResponse](
            Http(s"${auth.instance_url}/${salesforceApiPathPrefixToVersion}/sobjects/Price_Rise__c/")
              .postData(serialisePriceRise(priceRise))
              .header("Authorization", s"Bearer ${auth.access_token}")
              .header("Content-Type", "application/json")
          ).tap(priceRiseId => logging.info(s"Successfully created Price_Rise__c object: ${priceRiseId.id}"))

        override def updatePriceRise(
            priceRiseId: String,
            priceRise: SalesforcePriceRise
        ): IO[SalesforceClientFailure, Unit] = {
          sendRequest(
            Http(s"${auth.instance_url}/${salesforceApiPathPrefixToVersion}/sobjects/Price_Rise__c/$priceRiseId")
              .postData(serialisePriceRise(priceRise))
              .method("PATCH")
              .header("Authorization", s"Bearer ${auth.access_token}")
              .header("Content-Type", "application/json")
          ).unit
        } <* logging.info(s"Successfully updated Price_Rise__c object: $priceRiseId")