iainporter

@Configuration
public class FilePollingConfiguration {

    @Bean(name="inboundReadDirectory")
    public File inboundReadDirectory(@Value("${inbound.read.path}") String path) {
        return makeDirectory(path);
    }

    @Bean(name="inboundProcessedDirectory")
    public File inboundProcessedDirectory(@Value("${inbound.processed.path}") String path) {

iainporter

<profile>
    <id>native</id>
    <activation>
        <property>
            <name>native</name>
        </property>
    </activation>
    <build>
        <plugins>
            <plugin>

iainporter

private fun getAccessToken(): String {
    val clientId = "backend-service"
    val clientSecret = "8155b2ad-cd9d-48ae-a5e1-ea11d5cfcb79"
    val response = RestAssured.given()
            .auth().preemptive().basic(clientId, clientSecret)
            .contentType("application/x-www-form-urlencoded")
            .formParam("grant_type", "client_credentials")
            .post("http://localhost:$authServerPort/auth/realms/porterhead/protocol/openid-connect/token")
            .then()
            .extract()

iainporter

var keycloakContainer = KGenericContainer("quay.io/keycloak/keycloak:11.0.0")
       .withNetwork(network)
       .withNetworkAliases("keycloak")
       .withExposedPorts(8080)
       .withEnv("KEYCLOAK_USER", "admin")
       .withEnv("KEYCLOAK_PASSWORD", "admin")
       .withEnv("KEYCLOAK_IMPORT", "/tmp/realm.json")
       .withEnv("JAVA_OPTS", "-Dkeycloak.profile.feature.scripts=enabled -Dkeycloak.profile.feature.upload_scripts=enabled")
       .withClasspathResourceMapping("config/porterhead-realm.json", "/tmp/realm.json", BindMode.READ_ONLY)
       .waitingFor(Wait.forHttp("/auth"))

iainporter

    @Test
    @DisplayName("POST /v1/sms with valid request returns 202")
    fun testSuccessfulSend() {
        whenever(smsService.createMessage(any(), any())).thenReturn(testDouble())
        given()
                .`when`()
                .contentType(ContentType.JSON)
                .auth().oauth2(generateJWT(keyPair))
                .body("""{"text":"Hello World", "fromNumber":"+1234567890", "toNumber":"+1234567899"}""")
                .post("/v1/sms")

iainporter

 fun generateJWT(keyPair: RSAKey): String {
     val signer: JWSSigner = RSASSASigner(keyPair.toRSAKey())
     // Prepare JWT with claims set
     val claimsSet = JWTClaimsSet.Builder()
             .subject("backend-service")
             .issuer("https://example.com")
             .expirationTime(Date(Date().time + 60 * 1000))
             .build()
     val signedJWT = SignedJWT(
             JWSHeader.Builder(JWSAlgorithm.RS256).keyID(keyPair.keyID).type(JOSEObjectType.JWT).build(),

iainporter

postStubMapping(publicKeysStub(keyPair.toPublicJWK().toJSONString()))

private fun publicKeysStub(keys: String): String {
    return """
        {
        "name": "public_keys_stub",
        "request": {
             "method": "GET",
             "url": "/v1/keys"
        },

iainporter

private fun oidcConfigurationStub(): String {
    return """
    {
       "name": "oidc_configuration",
       "request": {
            "method": "GET",
            "url": "/mock-server/.well-known/openid-configuration"
       },
       "response": {
            "status": 200,

iainporter

  fun generatePrivateKey() :RSAKey {
      return  RSAKeyGenerator(2048)
              .keyID("123").keyUse(KeyUse.SIGNATURE)
              .generate()
  }

iainporter

open class WiremockTestResource : QuarkusTestResourceLifecycleManager {

    lateinit var wireMockServer: WireMockServer
    lateinit var keyPair: RSAKey

    override fun start(): MutableMap<String, String> {
        wireMockServer = WireMockServer(WireMockConfiguration().dynamicPort())
        wireMockServer.start()
        keyPair = generatePrivateKey()
        postStubMapping(oidcConfigurationStub())