subs endpoint first pass

Author: Nikhilvedi

app/uk/gov/hmrc/senioraccountingofficer/config/AppConfig.scala

@@ -17,11 +17,12 @@
 package uk.gov.hmrc.senioraccountingofficer.config
 
 import play.api.Configuration
+import uk.gov.hmrc.play.bootstrap.config.ServicesConfig
 
-import javax.inject.{Inject, Singleton}
+import javax.inject.Inject
 
-@Singleton
-class AppConfig @Inject() (config: Configuration) {
+class AppConfig @Inject() (servicesConfig: ServicesConfig, config: Configuration) {
 
   val appName: String = config.get[String]("appName")
+  val stubsBaseUrl: String = servicesConfig.baseUrl("senior-accounting-officer-stubs")
 }

app/uk/gov/hmrc/senioraccountingofficer/config/Module.scala

@@ -17,11 +17,13 @@
 package uk.gov.hmrc.senioraccountingofficer.config
 
 import com.google.inject.AbstractModule
+import uk.gov.hmrc.senioraccountingofficer.connectors.{DefaultSubscriptionsConnector, SubscriptionsConnector}
 
 class Module extends AbstractModule {
 
   override def configure(): Unit = {
 
     bind(classOf[AppConfig]).asEagerSingleton()
+    bind(classOf[SubscriptionsConnector]).to(classOf[DefaultSubscriptionsConnector])
   }
 }

app/uk/gov/hmrc/senioraccountingofficer/connectors/SubscriptionsConnector.scala

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2026 HM Revenue & Customs
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package uk.gov.hmrc.senioraccountingofficer.connectors
+
+import play.api.http.MimeTypes
+import play.api.libs.ws.writeableOf_String
+import uk.gov.hmrc.http.HttpReads.Implicits.*
+import uk.gov.hmrc.http.client.HttpClientV2
+import uk.gov.hmrc.http.{HeaderCarrier, HttpResponse, StringContextOps}
+import uk.gov.hmrc.senioraccountingofficer.config.AppConfig
+
+import scala.concurrent.{ExecutionContext, Future}
+
+import javax.inject.Inject
+
+trait SubscriptionsConnector {
+  def putSubscription(body: String)(using HeaderCarrier): Future[HttpResponse]
+}
+
+class DefaultSubscriptionsConnector @Inject() (httpClient: HttpClientV2, appConfig: AppConfig)(using
+    ExecutionContext
+) extends SubscriptionsConnector {
+
+  override def putSubscription(body: String)(using HeaderCarrier): Future[HttpResponse] =
+    httpClient
+      .put(url"${appConfig.stubsBaseUrl}/subscriptions")
+      .setHeader("Content-Type" -> MimeTypes.JSON)
+      .withBody(body)
+      .execute[HttpResponse]
+}

app/uk/gov/hmrc/senioraccountingofficer/controllers/SubscriptionsController.scala

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2026 HM Revenue & Customs
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package uk.gov.hmrc.senioraccountingofficer.controllers
+
+import play.api.http.MimeTypes
+import play.api.mvc.{Action, ControllerComponents}
+import uk.gov.hmrc.http.HeaderCarrier
+import uk.gov.hmrc.play.bootstrap.backend.controller.BackendController
+import uk.gov.hmrc.play.http.HeaderCarrierConverter
+import uk.gov.hmrc.senioraccountingofficer.connectors.SubscriptionsConnector
+
+import scala.concurrent.ExecutionContext
+
+import javax.inject.Inject
+
+class SubscriptionsController @Inject() (
+    cc: ControllerComponents,
+    subscriptionsConnector: SubscriptionsConnector
+)(using ec: ExecutionContext)
+    extends BackendController(cc) {
+
+  def putSubscription: Action[String] = Action.async(parse.tolerantText) { implicit request =>
+    given HeaderCarrier = HeaderCarrierConverter.fromRequest(request)
+
+    subscriptionsConnector.putSubscription(request.body).map { response =>
+      if response.body.isBlank then Status(response.status)
+      else Status(response.status)(response.body).as(MimeTypes.JSON)
+    }
+  }
+}

conf/app.routes

@@ -1,3 +1,4 @@
 # microservice specific routes
 
 GET        /hello-world             uk.gov.hmrc.senioraccountingofficer.controllers.MicroserviceHelloWorldController.hello()
+PUT        /subscriptions           uk.gov.hmrc.senioraccountingofficer.controllers.SubscriptionsController.putSubscription

conf/application.conf

@@ -65,6 +65,9 @@ microservice {
       host = localhost
       port = 8500
     }
+    senior-accounting-officer-stubs {
+      host = localhost
+      port = 10061
+    }
   }
 }
-

test/uk/gov/hmrc/senioraccountingofficer/controllers/SubscriptionsControllerSpec.scala

@@ -0,0 +1,94 @@
+/*
+ * Copyright 2026 HM Revenue & Customs
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package uk.gov.hmrc.senioraccountingofficer.controllers
+
+import org.scalatest.matchers.should.Matchers
+import org.scalatest.wordspec.AnyWordSpec
+import org.scalatestplus.play.guice.GuiceOneAppPerSuite
+import org.apache.pekko.stream.Materializer
+import play.api.http.HeaderNames.CONTENT_TYPE
+import play.api.http.Status
+import play.api.test.Helpers.{contentAsString, defaultAwaitTimeout, status, stubControllerComponents}
+import play.api.test.FakeRequest
+import uk.gov.hmrc.http.{HeaderCarrier, HttpResponse}
+import uk.gov.hmrc.senioraccountingofficer.connectors.SubscriptionsConnector
+
+import scala.concurrent.{ExecutionContext, Future}
+
+class SubscriptionsControllerSpec extends AnyWordSpec with Matchers with GuiceOneAppPerSuite {
+
+  given ExecutionContext = ExecutionContext.global
+  given Materializer     = app.materializer
+
+  private val validPayload =
+    """{
+      |  "safeId": "XE000123456789",
+      |  "company": {
+      |    "companyName": "Acme Manufacturing Ltd",
+      |    "uniqueTaxReference": "1234567890",
+      |    "companyRegistrationNumber": "OC123456"
+      |  },
+      |  "contacts": [
+      |    {
+      |      "name": "Jane Doe",
+      |      "email": "jane.doe@example.com"
+      |    }
+      |  ]
+      |}""".stripMargin
+
+  "SubscriptionsController" should {
+    "return the downstream status when the stub responds without a body" in {
+      val controller = new SubscriptionsController(
+        stubControllerComponents(),
+        new StubSubscriptionsConnector(Future.successful(HttpResponse(status = Status.NO_CONTENT)))
+      )
+
+      val result = controller.putSubscription(
+        FakeRequest("PUT", "/subscriptions")
+          .withHeaders(CONTENT_TYPE -> "application/json")
+          .withTextBody(validPayload)
+      )
+
+      status(result) shouldBe Status.NO_CONTENT
+    }
+
+    "return the downstream JSON body for validation errors" in {
+      val downstreamBody = """[{"path":"safeId","reason":"INVALID_FORMAT"}]"""
+      val controller     = new SubscriptionsController(
+        stubControllerComponents(),
+        new StubSubscriptionsConnector(Future.successful(HttpResponse(status = Status.BAD_REQUEST, body = downstreamBody)))
+      )
+
+      val result = controller.putSubscription(
+        FakeRequest("PUT", "/subscriptions")
+          .withHeaders(CONTENT_TYPE -> "application/json")
+          .withTextBody(validPayload)
+      )
+
+      status(result) shouldBe Status.BAD_REQUEST
+      contentAsString(result) shouldBe downstreamBody
+    }
+
+  }
+
+  private class StubSubscriptionsConnector(
+      result: Future[HttpResponse]
+  ) extends SubscriptionsConnector {
+    override def putSubscription(body: String)(using HeaderCarrier): Future[HttpResponse] =
+      result
+  }
+}