Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

enable test #465

Open
wants to merge 5 commits into
base: main
Choose a base branch
from
Open

enable test #465

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
ec58174
enable test
mkrzywanski Aug 11, 2024
64b5fee
enable test
mkrzywanski Aug 12, 2024
13c5962
enable test
mkrzywanski Aug 12, 2024
953fa58
enable test
mkrzywanski Aug 12, 2024
7f29839
enable test
mkrzywanski Aug 12, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
348 changes: 195 additions & 153 deletions ...io/mkrzywanski/pn/matching/matchedoffers/PostsConsumerToNotificationProductionSpec.groovy
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,49 +1,46 @@
//package io.mkrzywanski.pn.matching.matchedoffers
//
//import com.github.tomakehurst.wiremock.WireMockServer
//import dasniko.testcontainers.keycloak.KeycloakContainer
//import io.mkrzywanski.pn.matching.MatchingServiceApp
//
//import io.mkrzywanski.pn.matching.user.config.MongoConfig
//
//import io.mkrzywanski.shared.keycloak.KeyCloakProperties
//import io.mkrzywanski.shared.keycloak.spring.KeycloakContainerConfiguration
//import org.slf4j.Logger
//import org.slf4j.LoggerFactory
//import org.springframework.amqp.rabbit.annotation.RabbitListener
//import org.springframework.amqp.rabbit.core.RabbitTemplate
//import org.springframework.beans.factory.annotation.Autowired
//import org.springframework.beans.factory.annotation.Value
//import org.springframework.boot.test.context.SpringBootTest
//import org.springframework.cloud.contract.wiremock.AutoConfigureWireMock
//import org.springframework.context.annotation.Bean
//import org.springframework.context.annotation.Configuration
//import org.springframework.context.annotation.Import
//import org.springframework.security.oauth2.client.registration.ClientRegistration
//import org.springframework.security.oauth2.client.registration.ClientRegistrationRepository
//import org.springframework.security.oauth2.client.registration.InMemoryClientRegistrationRepository
//import org.springframework.security.oauth2.core.AuthorizationGrantType
//import org.springframework.stereotype.Component
//import org.springframework.test.context.ContextConfiguration
//import org.springframework.test.context.DynamicPropertyRegistry
//import org.springframework.test.context.DynamicPropertySource
//import org.testcontainers.containers.RabbitMQContainer
//import org.testcontainers.utility.DockerImageName
//import spock.lang.Shared
//import spock.lang.Specification
//
//import java.util.concurrent.CopyOnWriteArrayList
//
//import static com.github.tomakehurst.wiremock.client.WireMock.*
//import static org.assertj.core.api.Assertions.assertThat
//import static org.awaitility.Awaitility.await
//
//@SpringBootTest
//@AutoConfigureWireMock(port = 0)
//@ContextConfiguration(classes = [MongoConfig, TestConfig, TestNotificationConsumer, MatchingServiceApp])
//class PostsConsumerToNotificationProductionSpec extends Specification {
//
// private static final Logger LOG = LoggerFactory.getLogger(PostsConsumerToNotificationProductionSpec.class)
package io.mkrzywanski.pn.matching.matchedoffers

import com.github.tomakehurst.wiremock.WireMockServer
import dasniko.testcontainers.keycloak.KeycloakContainer
import io.mkrzywanski.pn.matching.MatchingServiceApp
import io.mkrzywanski.pn.matching.user.config.MongoConfig
import io.mkrzywanski.shared.keycloak.KeyCloakProperties
import io.mkrzywanski.shared.keycloak.spring.KeycloakContainerConfiguration
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.amqp.rabbit.annotation.RabbitListener
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory
import org.springframework.amqp.rabbit.core.RabbitTemplate
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.beans.factory.annotation.Value
import org.springframework.boot.test.context.SpringBootTest
import org.springframework.cloud.contract.wiremock.AutoConfigureWireMock
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.context.annotation.Import
import org.springframework.security.oauth2.client.registration.ClientRegistration
import org.springframework.security.oauth2.client.registration.ClientRegistrationRepository
import org.springframework.security.oauth2.client.registration.InMemoryClientRegistrationRepository
import org.springframework.security.oauth2.core.AuthorizationGrantType
import org.springframework.stereotype.Component
import org.springframework.test.context.ContextConfiguration
import org.testcontainers.containers.RabbitMQContainer
import org.testcontainers.utility.DockerImageName
import spock.lang.Specification

import java.util.concurrent.CopyOnWriteArrayList
import java.util.concurrent.TimeUnit

import static com.github.tomakehurst.wiremock.client.WireMock.*
import static org.assertj.core.api.Assertions.assertThat
import static org.awaitility.Awaitility.await

@SpringBootTest
@AutoConfigureWireMock(port = 0)
@ContextConfiguration(classes = [MongoConfig, TestConfig, TestNotificationConsumer, RabbitMQIntegConfig, MatchingServiceApp])
class PostsConsumerToNotificationProductionSpec extends Specification {

private static final Logger LOG = LoggerFactory.getLogger(PostsConsumerToNotificationProductionSpec.class)
//
// private static final String RABBIT_USERNAME = "test"
// private static final String RABBIT_PASSWORD = "test"
Expand All @@ -63,114 +60,159 @@
// registry.add("spring.rabbitmq.username", { -> RABBIT_USERNAME })
// registry.add("spring.rabbitmq.password", { -> RABBIT_PASSWORD })
// }
//
// @Value('${gpn.queue.name}')
// private String newPostsQueue
//
// @Autowired
// RabbitTemplate rabbitTemplate
//
// @Autowired
// TestNotificationConsumer testNotificationConsumer
//
// @Autowired
// WireMockServer wireMockServer
//
// def postId = UUID.fromString("cb53e434-0dc0-4f66-b796-7b7beadbad3d")
// def offerId = UUID.fromString("b0e05d9c-fdfe-458e-9aaa-2a251e026205")
// def userId = UUID.fromString("8e3a885f-0708-4b84-903f-e383ebc2ee40")
// def offerName = "offerName"
// def postLink = "link"
// def offers = List.of(new Offer(offerId, offerName, Map.of(Currency.getInstance("PLN"), BigDecimal.ONE), "link"))
// def post = new Post(postId, postLink, offers)
//
// void setup() {
// def subscriptionMatchingRequestBody = """
// {
// "postsToMatch" : [
// {
// "postId" : "${postId}",
// "offers" : [
// {
// "id" : "${offerId}",
// "text" : "${offerName}"
// }
// ]
// }
// ]
// }
// """.trim()
// wireMockServer.addStubMapping(post(urlEqualTo("/v1/subscriptions/match")).withRequestBody(equalToJson(subscriptionMatchingRequestBody)).withHeader("Content-Type", equalTo("application/json"))
// .willReturn(aResponse()
// .withHeader("Content-Type", "application/json")
// .withBody("""
// {
// "matches" : [
// {
// "userId" : "${userId}",
// "postId" : "${postId}",
// "offerId" : "${offerId}"
// }
// ]
// }
// """)).build())
//
// wireMockServer.addStubMapping(
// get(urlEqualTo("/v1/users/${userId}"))
// .withHeader("Content-Type", equalTo("application/json"))
// .willReturn(aResponse().withBody("""
//
// {
// "userId" : "${userId}",
// "username" : "test",
// "firstName" : "test",
// "email" : "[email protected]"
// }
// """).withHeader("Content-Type", "application/json")).build())
// }
//
// def 'should publish notifications when new post arrives'() {
// when:
// newPostAppearsOnQueue()
//
// then:
// await()

@Value('${gpn.queue.name}')
private String newPostsQueue

@Autowired
RabbitTemplate rabbitTemplate

@Autowired
TestNotificationConsumer testNotificationConsumer

@Autowired
WireMockServer wireMockServer

def postId = UUID.fromString("cb53e434-0dc0-4f66-b796-7b7beadbad3d")
def offerId = UUID.fromString("b0e05d9c-fdfe-458e-9aaa-2a251e026205")
def userId = UUID.fromString("8e3a885f-0708-4b84-903f-e383ebc2ee40")
def offerName = "offerName"
def postLink = "link"
def offers = List.of(new Offer(offerId, offerName, Map.of(Currency.getInstance("PLN"), BigDecimal.ONE), "link"))
def post = new Post(postId, postLink, offers)

void setup() {
def subscriptionMatchingRequestBody = """
{
"postsToMatch" : [
{
"postId" : "${postId}",
"offers" : [
{
"id" : "${offerId}",
"text" : "${offerName}"
}
]
}
]
}
""".trim()
wireMockServer.addStubMapping(post(urlEqualTo("/v1/subscriptions/match")).withRequestBody(equalToJson(subscriptionMatchingRequestBody)).withHeader("Content-Type", equalTo("application/json"))
.willReturn(aResponse()
.withHeader("Content-Type", "application/json")
.withBody("""
{
"matches" : [
{
"userId" : "${userId}",
"postId" : "${postId}",
"offerId" : "${offerId}"
}
]
}
""")).build())

wireMockServer.addStubMapping(
get(urlEqualTo("/v1/users/${userId}"))
.withHeader("Content-Type", equalTo("application/json"))
.willReturn(aResponse().withBody("""

{
"userId" : "${userId}",
"username" : "test",
"firstName" : "test",
"email" : "[email protected]"
}
""").withHeader("Content-Type", "application/json")).build())
}

def 'should publish notifications when new post arrives'() {
when:
newPostAppearsOnQueue()

then:
await()
// .forever()
//// .atMost(20, TimeUnit.SECONDS)
// .untilAsserted({
// assertThat(testNotificationConsumer.notifications).hasSize(1)
// })
// }
//
// private newPostAppearsOnQueue() {
// LOG.info("Sending new post to queue")
// rabbitTemplate.convertAndSend(newPostsQueue, post)
// }
//}
//
//@Configuration
//@Import(KeycloakContainerConfiguration)
//class TestConfig {
.atMost(20, TimeUnit.SECONDS)
.untilAsserted({
assertThat(testNotificationConsumer.notifications).hasSize(1)
})
}

private newPostAppearsOnQueue() {
LOG.info("Sending new post to queue")
rabbitTemplate.convertAndSend(newPostsQueue, post)
}
}

@Configuration
@Import(KeycloakContainerConfiguration)
class TestConfig {
@Bean
ClientRegistrationRepository clientRegistrationRepository(KeyCloakProperties keyCloakProperties, KeycloakContainer keyCloakContainer) {
ClientRegistration clientRegistration = ClientRegistration.withRegistrationId("pn-matching-service")
.authorizationGrantType(AuthorizationGrantType.CLIENT_CREDENTIALS)
.clientId(keyCloakProperties.client.clientId)
.clientSecret(keyCloakProperties.client.clientSecret)
.tokenUri("http://localhost:${keyCloakContainer.firstMappedPort}/realms/${keyCloakProperties.testRealm}/protocol/openid-connect/token")
.build()
new InMemoryClientRegistrationRepository(clientRegistration)
}
}

@Component
class TestNotificationConsumer {

final List<NewOffersNotification> notifications = new CopyOnWriteArrayList<>()

@RabbitListener(queues = '${gpn.matching-service.publishing.queue.name}')
void capture(NewOffersNotification notification) {
notifications.add(notification)
}

}

@Configuration
class RabbitMQIntegConfig {

private static final String RABBIT_USERNAME = "test"
private static final String RABBIT_PASSWORD = "test"

private static final RABBIT_MQ_IMAGE = "bitnami/rabbitmq:3.8.18"
public static final DockerImageName RABBIT_IMAGE = DockerImageName.parse(RABBIT_MQ_IMAGE)
.asCompatibleSubstituteFor("rabbitmq")


@Bean(destroyMethod = "")
RabbitMQContainer rabbitMQContainer() {
RabbitMQContainer rabbitMQContainer = new RabbitMQContainer(RABBIT_IMAGE)
.withEnv("RABBITMQ_USERNAME", RABBIT_USERNAME)
.withEnv("RABBITMQ_PASSWORD", RABBIT_PASSWORD)
rabbitMQContainer.start()
rabbitMQContainer
}

// @Bean
// ClientRegistrationRepository clientRegistrationRepository(KeyCloakProperties keyCloakProperties, KeycloakContainer keyCloakContainer) {
// ClientRegistration clientRegistration = ClientRegistration.withRegistrationId("pn-matching-service")
// .authorizationGrantType(AuthorizationGrantType.CLIENT_CREDENTIALS)
// .clientId(keyCloakProperties.client.clientId)
// .clientSecret(keyCloakProperties.client.clientSecret)
// .tokenUri("http://localhost:${keyCloakContainer.firstMappedPort}/realms/${keyCloakProperties.testRealm}/protocol/openid-connect/token")
// .build()
// new InMemoryClientRegistrationRepository(clientRegistration)
// }
//}
//
//@Component
//class TestNotificationConsumer {
//
// final List<NewOffersNotification> notifications = new CopyOnWriteArrayList<>()
// CachingConnectionFactoryConfigurer connectionFactoryCustomizer(RabbitMQContainer container) {
// (factory) -> {
// factory.setUsername(RABBIT_USERNAME)
// factory.setPassword(RABBIT_PASSWORD)
// factory.setPort(container.getAmqpPort())
// factory.setHost("localhost")
// }
//
// @RabbitListener(queues = '${gpn.matching-service.publishing.queue.name}')
// void capture(NewOffersNotification notification) {
// notifications.add(notification)
// }
//
//}

@Bean
CachingConnectionFactory connectionFactory() {

def factory = new CachingConnectionFactory("localhost", rabbitMQContainer().firstMappedPort)
factory.setUsername(RABBIT_USERNAME)
factory.setPassword(RABBIT_PASSWORD)

factory

}

}

2 changes: 1 addition & 1 deletion promotion-notifier-backend/pn-matching-service/src/integTest/resources/logback-test.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
</encoder>
</appender>

<root level="info">
<root level="debug">
<appender-ref ref="STDOUT"/>
</root>

Expand Down
Loading
Loading