test: fix some tests

Lukinhasssss · Jun 1, 2024 · 091eab6 · 091eab6
1 parent 653e65f
commit 091eab6
Show file tree

Hide file tree

Showing 8 changed files with 28 additions and 26 deletions.
diff --git a/infrastructure/src/test/kotlin/com/lukinhasssss/catalogo/AbstractEmbeddedKafkaTest.kt b/infrastructure/src/test/kotlin/com/lukinhasssss/catalogo/AbstractEmbeddedKafkaTest.kt
@@ -2,6 +2,7 @@ package com.lukinhasssss.catalogo
 
 import com.lukinhasssss.catalogo.infrastructure.configuration.WebServerConfig
 import com.lukinhasssss.catalogo.infrastructure.kafka.models.connect.Source
+import io.mockk.clearAllMocks
 import org.apache.kafka.clients.admin.AdminClient
 import org.apache.kafka.clients.admin.AdminClientConfig
 import org.apache.kafka.clients.producer.Producer
@@ -40,16 +41,17 @@ abstract class AbstractEmbeddedKafkaTest {
 
  @BeforeAll
  fun init() {
+ clearAllMocks()
  admin = AdminClient.create(mapOf(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG to kafkaBroker.brokersAsString))
  producer = DefaultKafkaProducerFactory(KafkaTestUtils.producerProps(kafkaBroker), StringSerializer(), StringSerializer()).createProducer()
  }
 
  @AfterAll
  fun shutdown() = producer.close()
 
- protected val source = Source(
+ protected fun source(tableName: String) = Source(
  name = "adm_videos_postgresql",
  database = "adm_videos",
- table = "categories"
+ table = tableName
  )
 }
diff --git a/...otlin/com/lukinhasssss/catalogo/infrastructure/graphql/CastMemberGraphQLControllerTest.kt b/...otlin/com/lukinhasssss/catalogo/infrastructure/graphql/CastMemberGraphQLControllerTest.kt
@@ -157,9 +157,9 @@ class CastMemberGraphQLControllerTest {
  val input = mapOf(
  "id" to expectedId,
  "name" to expectedName,
- "type" to expectedType,
- "createdAt" to expectedCreatedAt,
- "updatedAt" to expectedUpdatedAt
+ "type" to expectedType.name,
+ "createdAt" to expectedCreatedAt.toString(),
+ "updatedAt" to expectedUpdatedAt.toString()
  )
 
  val query = """

diff --git a/.../kotlin/com/lukinhasssss/catalogo/infrastructure/graphql/CategoryGraphQLControllerTest.kt b/.../kotlin/com/lukinhasssss/catalogo/infrastructure/graphql/CategoryGraphQLControllerTest.kt
@@ -155,9 +155,9 @@ class CategoryGraphQLControllerTest {
  "name" to expectedName,
  "description" to expectedDescription,
  "active" to expectedIsActive,
- "createdAt" to expectedCreatedAt,
- "updatedAt" to expectedUpdatedAt,
- "deletedAt" to expectedDeletedAt
+ "createdAt" to expectedCreatedAt.toString(),
+ "updatedAt" to expectedUpdatedAt.toString(),
+ "deletedAt" to expectedDeletedAt.toString()
  )
 
  val query = """

diff --git a/...est/kotlin/com/lukinhasssss/catalogo/infrastructure/graphql/GenreGraphQLControllerTest.kt b/...est/kotlin/com/lukinhasssss/catalogo/infrastructure/graphql/GenreGraphQLControllerTest.kt
@@ -166,7 +166,7 @@ class GenreGraphQLControllerTest {
  val input = mapOf(
  "id" to expectedId,
  "name" to expectedName,
- "active" to expectedIsActive.toString(),
+ "active" to expectedIsActive,
  "categories" to expectedCategories,
  "createdAt" to expectedCreatedAt.toString(),
  "updatedAt" to expectedUpdatedAt.toString(),
@@ -219,7 +219,7 @@ class GenreGraphQLControllerTest {
  val input = mapOf(
  "id" to expectedId,
  "name" to expectedName,
- "active" to expectedIsActive.toString(),
+ "active" to expectedIsActive,
  "categories" to expectedCategories,
  "createdAt" to expectedCreatedAt.toString(),
  "updatedAt" to expectedUpdatedAt.toString()

diff --git a/.../src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/CastMemberListenerTest.kt b/.../src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/CastMemberListenerTest.kt
@@ -72,7 +72,7 @@ class CastMemberListenerTest : AbstractEmbeddedKafkaTest() {
  val nami = Fixture.CastMembers.nami()
  val namiEvent = CastMemberEvent.from(nami)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, namiEvent, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, namiEvent, source("cast_members"), Operation.DELETE)))
 
  val latch = CountDownLatch(5)
 
@@ -112,7 +112,7 @@ class CastMemberListenerTest : AbstractEmbeddedKafkaTest() {
  val nami = Fixture.CastMembers.nami()
  val namiEvent = CastMemberEvent.from(nami)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(null, namiEvent, source, Operation.CREATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(null, namiEvent, source("cast_members"), Operation.CREATE)))
 
  val latch = CountDownLatch(1)
 
@@ -134,7 +134,7 @@ class CastMemberListenerTest : AbstractEmbeddedKafkaTest() {
  val nami = Fixture.CastMembers.nami()
  val namiEvent = CastMemberEvent.from(nami)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, namiEvent, source, Operation.UPDATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, namiEvent, source("cast_members"), Operation.UPDATE)))
 
  val latch = CountDownLatch(1)
 
@@ -156,7 +156,7 @@ class CastMemberListenerTest : AbstractEmbeddedKafkaTest() {
  val nami = Fixture.CastMembers.nami()
  val namiEvent = CastMemberEvent.from(nami)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, null, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(namiEvent, null, source("cast_members"), Operation.DELETE)))
 
  val latch = CountDownLatch(1)
 

diff --git a/...re/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/CategoryListenerTest.kt b/...re/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/CategoryListenerTest.kt
@@ -76,7 +76,7 @@ class CategoryListenerTest : AbstractEmbeddedKafkaTest() {
  val aulas = Fixture.Categories.aulas
  val aulasEvent = CategoryEvent(aulas.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, aulasEvent, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, aulasEvent, source("categories"), Operation.DELETE)))
 
  val latch = CountDownLatch(5)
 
@@ -112,7 +112,7 @@ class CategoryListenerTest : AbstractEmbeddedKafkaTest() {
  val aulas = Fixture.Categories.aulas
  val aulasEvent = CategoryEvent(aulas.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(null, aulasEvent, source, Operation.CREATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(null, aulasEvent, source("categories"), Operation.CREATE)))
 
  val latch = CountDownLatch(1)
 
@@ -135,7 +135,7 @@ class CategoryListenerTest : AbstractEmbeddedKafkaTest() {
  val aulas = Fixture.Categories.aulas
  val aulasEvent = CategoryEvent(aulas.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, aulasEvent, source, Operation.UPDATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, aulasEvent, source("categories"), Operation.UPDATE)))
 
  val latch = CountDownLatch(1)
 
@@ -158,7 +158,7 @@ class CategoryListenerTest : AbstractEmbeddedKafkaTest() {
  val aulas = Fixture.Categories.aulas
  val aulasEvent = CategoryEvent(aulas.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, null, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(aulasEvent, null, source("categories"), Operation.DELETE)))
 
  val latch = CountDownLatch(1)
 

diff --git a/...cture/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/GenreListenerTest.kt b/...cture/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/GenreListenerTest.kt
@@ -77,7 +77,7 @@ class GenreListenerTest : AbstractEmbeddedKafkaTest() {
  val tech = tech()
  val techEvent = GenreEvent(tech.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, techEvent, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, techEvent, source("genres"), Operation.DELETE)))
 
  val latch = CountDownLatch(5)
 
@@ -117,7 +117,7 @@ class GenreListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val techEvent = GenreEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(null, techEvent, source, Operation.CREATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(null, techEvent, source("genres"), Operation.CREATE)))
 
  val latch = CountDownLatch(1)
 
@@ -141,7 +141,7 @@ class GenreListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val techEvent = GenreEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, techEvent, source, Operation.UPDATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, techEvent, source("genres"), Operation.UPDATE)))
 
  val latch = CountDownLatch(1)
 
@@ -165,7 +165,7 @@ class GenreListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val techEvent = GenreEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, null, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(techEvent, null, source("genres"), Operation.DELETE)))
 
  val latch = CountDownLatch(1)
 

diff --git a/...cture/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/VideoListenerTest.kt b/...cture/src/test/kotlin/com/lukinhasssss/catalogo/infrastructure/kafka/VideoListenerTest.kt
@@ -81,7 +81,7 @@ class VideoListenerTest : AbstractEmbeddedKafkaTest() {
  val cleanCode = cleanCode()
  val cleanCodeEvent = VideoEvent(cleanCode.id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, cleanCodeEvent, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, cleanCodeEvent, source("videos"), Operation.DELETE)))
 
  val latch = CountDownLatch(5)
 
@@ -121,7 +121,7 @@ class VideoListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val cleanCodeEvent = VideoEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(null, cleanCodeEvent, source, Operation.CREATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(null, cleanCodeEvent, source("videos"), Operation.CREATE)))
 
  val latch = CountDownLatch(1)
 
@@ -168,7 +168,7 @@ class VideoListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val cleanCodeEvent = VideoEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, cleanCodeEvent, source, Operation.UPDATE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, cleanCodeEvent, source("videos"), Operation.UPDATE)))
 
  val latch = CountDownLatch(1)
 
@@ -215,7 +215,7 @@ class VideoListenerTest : AbstractEmbeddedKafkaTest() {
  // given
  val cleanCodeEvent = VideoEvent(id)
 
- val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, null, source, Operation.DELETE)))
+ val message = Json.writeValueAsString(MessageValue(ValuePayload(cleanCodeEvent, null, source("videos"), Operation.DELETE)))
 
  val latch = CountDownLatch(1)