vertx-unit-tests.kt

  @Test
  fun `send http request success`() = runBlocking {
    mockHttpCall(
      statusCode = 200,
      jsonResponse = json {
        obj(
          "ip" to "1.1.1.1"
        )
      }
    )

    val responseFuture = vertx.eventBus().request<JsonObject>("${HttpWorkerVerticle.SERVICE_ADDRESS}.request.send", sampleHttpRequest.toJson())

    responseFuture.onComplete { handler ->
      assertTrue(handler.succeeded())
      val responseBody = handler.result().body()
      assertEquals("1.1.1.1", responseBody.getString("ip"))
    }

    responseFuture.await()
    return@runBlocking
  }

  @Test
  fun `send http request 500`() = runBlocking {
    mockHttpCall(
      statusCode = 500,
      jsonResponse = json {
        obj(
          "ip" to "1.1.1.1"
        )
      }
    )

    val responseFuture = vertx.eventBus().request<JsonObject>("${HttpWorkerVerticle.SERVICE_ADDRESS}.request.send", sampleHttpRequest.toJson())
    responseFuture.onComplete { handler ->
      assertTrue(handler.failed())
    }
    responseFuture.await()
    return@runBlocking
  }