SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added tests for messaging

Browse Source
This commit is contained in:
Marcin Grzejszczak
2016-06-21 10:37:15 +02:00
parent db1ae1c93b
commit 33a57dd147
7 changed files with 205 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-camel/src/main/groovy/org/springframework/cloud/contract/stubrunner/messaging/camel/StubRunnerCamelProcessor.groovy
View File

@@ -41,11 +41,14 @@ class StubRunnerCamelProcessor implements Processor {
@Override
void process(Exchange exchange) throws Exception {
Message input = exchange.in
input.body = BodyAsStringUtil.extractClientValueFrom(groovyDsl.outputMessage.body)
groovyDsl.input.messageHeaders.entries.each {
groovyDsl.input.messageHeaders?.entries?.each {
input.removeHeader(it.name)
}
groovyDsl.outputMessage.headers.entries.each {
if (!groovyDsl.outputMessage) {
return
}
input.body = BodyAsStringUtil.extractStubValueFrom(groovyDsl.outputMessage.body)
groovyDsl.outputMessage.headers?.entries?.each {
input.setHeader(it.name, it.clientValue)
}
}

67
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-camel/src/test/groovy/org/springframework/cloud/contract/stubrunner/messaging/camel/StubRunnerCamelProcessorSpec.groovy Normal file
View File

@@ -0,0 +1,67 @@
package org.springframework.cloud.contract.stubrunner.messaging.camel
import org.apache.camel.CamelContext
import org.apache.camel.Exchange
import org.apache.camel.builder.ExchangeBuilder
import org.apache.camel.spring.SpringCamelContext
import org.springframework.cloud.contract.verifier.dsl.Contract
import spock.lang.Specification
class StubRunnerCamelProcessorSpec extends Specification {
CamelContext camelContext = new SpringCamelContext()
Exchange message = ExchangeBuilder.anExchange(camelContext).build()
def noOutputMessageContract = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
}
def 'should not process the message if there is no output message'() {
given:
StubRunnerCamelProcessor processor = new StubRunnerCamelProcessor(noOutputMessageContract)
when:
processor.process(message)
then:
noExceptionThrown()
}
def dsl = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
outputMessage {
sentTo('returnBook')
body([
responseId: $(producer(regex('[0-9]+')), consumer('123'))
])
headers {
header('BOOK-NAME', 'foo')
}
}
}
def 'should process message when it has an output message section'() {
given:
StubRunnerCamelProcessor processor = new StubRunnerCamelProcessor(dsl)
when:
processor.process(message)
then:
message.getIn().getBody(String) == '{"responseId":"123"}'
}
}

2
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-integration/src/main/groovy/org/springframework/cloud/contract/stubrunner/messaging/integration/StubRunnerIntegrationTransformer.groovy
View File

@@ -41,7 +41,7 @@ class StubRunnerIntegrationTransformer implements GenericTransformer<Message<?>,
if (!groovyDsl.outputMessage) {
return source
}
String payload = BodyAsStringUtil.extractClientValueFrom(groovyDsl.outputMessage.body)
String payload = BodyAsStringUtil.extractStubValueFrom(groovyDsl.outputMessage.body)
Map<String, Object> headers = groovyDsl.outputMessage.headers.asStubSideMap()
return MessageBuilder.createMessage(payload, new MessageHeaders(headers))
}

64
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-integration/src/test/groovy/org/springframework/cloud/contract/stubrunner/messaging/integration/StubRunnerIntegrationTransformerSpec.groovy Normal file
View File

@@ -0,0 +1,64 @@
package org.springframework.cloud.contract.stubrunner.messaging.integration
import org.springframework.cloud.contract.verifier.dsl.Contract
import org.springframework.messaging.Message
import org.springframework.messaging.support.MessageBuilder
import spock.lang.Specification
class StubRunnerIntegrationTransformerSpec extends Specification {
Message message = MessageBuilder.withPayload("hello").build()
def noOutputMessageContract = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
}
def 'should not transform the message if there is no output message'() {
given:
StubRunnerIntegrationTransformer transformer = new StubRunnerIntegrationTransformer(noOutputMessageContract)
when:
def result = transformer.transform(message)
then:
result.is(message)
}
def dsl = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
outputMessage {
sentTo('returnBook')
body([
responseId: $(producer(regex('[0-9]+')), consumer('123'))
])
headers {
header('BOOK-NAME', 'foo')
}
}
}
def 'should convert dsl into message'() {
given:
StubRunnerIntegrationTransformer transformer = new StubRunnerIntegrationTransformer(dsl)
when:
def result = transformer.transform(message)
then:
result.payload == '{"responseId":"123"}'
}
}

2
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-stream/src/main/groovy/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamTransformer.groovy
View File

@@ -41,7 +41,7 @@ class StubRunnerStreamTransformer implements GenericTransformer<Message<?>, Mess
if (!groovyDsl.outputMessage) {
return source
}
String payload = BodyAsStringUtil.extractClientValueFrom(groovyDsl.outputMessage.body)
String payload = BodyAsStringUtil.extractStubValueFrom(groovyDsl.outputMessage.body)
Map<String, Object> headers = groovyDsl.outputMessage.headers.asStubSideMap()
return MessageBuilder.createMessage(payload, new MessageHeaders(headers))
}

64
spring-cloud-contract-stub-runner/spring-cloud-contract-stub-runner-messaging/spring-cloud-contract-stub-runner-stream/src/test/groovy/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamTransformerSpec.groovy Normal file
View File

@@ -0,0 +1,64 @@
package org.springframework.cloud.contract.stubrunner.messaging.stream
import org.springframework.cloud.contract.verifier.dsl.Contract
import org.springframework.messaging.Message
import org.springframework.messaging.support.MessageBuilder
import spock.lang.Specification
class StubRunnerStreamTransformerSpec extends Specification {
Message message = MessageBuilder.withPayload("hello").build()
def noOutputMessageContract = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
}
def 'should not transform the message if there is no output message'() {
given:
StubRunnerStreamTransformer streamTransformer = new StubRunnerStreamTransformer(noOutputMessageContract)
when:
def result = streamTransformer.transform(message)
then:
result.is(message)
}
def dsl = Contract.make {
label 'return_book_2'
input {
messageFrom('bookStorage')
messageBody([
bookId: $(consumer(regex('[0-9]+')), producer('123'))
])
messageHeaders {
header('sample', 'header')
}
}
outputMessage {
sentTo('returnBook')
body([
responseId: $(producer(regex('[0-9]+')), consumer('123'))
])
headers {
header('BOOK-NAME', 'foo')
}
}
}
def 'should convert dsl into message'() {
given:
StubRunnerStreamTransformer streamTransformer = new StubRunnerStreamTransformer(dsl)
when:
def result = streamTransformer.transform(message)
then:
result.payload == '{"responseId":"123"}'
}
}

4
spring-cloud-contract-verifier/spring-cloud-contract-verifier-core/src/main/groovy/org/springframework/cloud/contract/verifier/util/BodyAsStringUtil.groovy
View File

@@ -40,7 +40,7 @@ class BodyAsStringUtil {
* That means that all the interpolations etc. will be resolved for the
* server side.
*/
static String extractServerValueFrom(Object body) {
static String extractTestValueFrom(Object body) {
Object bodyValue = extractServerValueFromBody(body)
String json = new JsonOutput().toJson(bodyValue)
json = StringEscapeUtils.unescapeJavaScript(json)
@@ -52,7 +52,7 @@ class BodyAsStringUtil {
* That means that all the interpolations etc. will be resolved for the
* client side.
*/
static String extractClientValueFrom(Object body) {
static String extractStubValueFrom(Object body) {
Object bodyValue = extractClientValueFromBody(body);
String json = new JsonOutput().toJson(bodyValue)
json = StringEscapeUtils.unescapeJavaScript(json)