Move 'samples' into 'tests' folder

Some of the samples are more like pure integratiuon tests (I wouldn't
use them to copy code into a real app). So I put them with the other
"test" projects.

tests/samples-messaging-spring/src/main/java/com/example/BookDeleted.java

@@ -0,0 +1,31 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example;
+
+import java.io.Serializable;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+
+@SuppressWarnings("serial")
+public class BookDeleted implements Serializable {
+	public final String bookName;
+
+	@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
+	public BookDeleted(String bookName) {
+		this.bookName = bookName;
+	}
+}

tests/samples-messaging-spring/src/main/java/com/example/BookListener.java

@@ -0,0 +1,83 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example;
+
+import java.io.IOException;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.Session;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.core.MessageCreator;
+import org.springframework.stereotype.Service;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+@Service
+public class BookListener {
+	
+	
+	private static final Logger log = LoggerFactory.getLogger(BookListener.class);
+
+
+	private @Autowired JmsTemplate jmsTemplate;
+	private ObjectMapper objectMapper = new ObjectMapper();
+
+	/**
+	 * Scenario for "should generate tests triggered by a message": client side: if sends
+	 * a message to input.messageFrom then message will be sent to output.messageFrom
+	 * server side: will send a message to input, verify the message contents and await
+	 * upon receiving message on the output messageFrom
+	 */
+	@JmsListener(destination = "input")
+	public void returnBook(String messageAsString) throws Exception {
+		final BookReturned bookReturned = objectMapper.readerFor(BookReturned.class).readValue(messageAsString);
+		log.info("Returning book [$bookReturned]");
+		MessageCreator messageCreator = new MessageCreator() {
+			@Override
+			public Message createMessage(Session session) throws JMSException {
+				Message message = session.createObjectMessage(bookReturned);
+				message.setStringProperty("BOOK-NAME", bookReturned.bookName);
+				return message;
+			}
+		};
+		jmsTemplate.send("output", messageCreator);
+	}
+
+	/**
+	   Scenario for "should generate tests triggered by a message":
+	     client side: if sends a message to input.messageFrom then message will be sent to output.messageFrom
+	     server side: will send a message to input, verify the message contents and await upon receiving message on the output messageFrom
+	 * @throws IOException 
+	 * @throws JsonProcessingException 
+	 */
+	@JmsListener(destination = "delete")
+	public void bookDeleted(String bookDeletedAsString) throws Exception {
+		BookDeleted bookDeleted = objectMapper.readerFor(BookDeleted.class).readValue(bookDeletedAsString);
+		log.info("Deleting book " + bookDeleted);
+		bookSuccessfulyDeleted.set(true);
+	}
+
+	AtomicBoolean bookSuccessfulyDeleted = new AtomicBoolean(false);
+}

tests/samples-messaging-spring/src/main/java/com/example/BookReturned.java

@@ -0,0 +1,31 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example;
+
+import java.io.Serializable;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+
+@SuppressWarnings("serial")
+public class BookReturned implements Serializable {
+	public final String bookName;
+
+	@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
+	BookReturned(String bookName) {
+		this.bookName = bookName;
+	}
+}

tests/samples-messaging-spring/src/main/java/com/example/BookService.java

@@ -0,0 +1,57 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example;
+
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.Session;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.core.MessageCreator;
+import org.springframework.stereotype.Service;
+
+@Service
+public class BookService {
+
+	private static final Logger log = LoggerFactory.getLogger(BookService.class);
+
+	private @Autowired JmsTemplate jmsTemplate;
+
+	/**
+	 * Scenario for "should generate tests triggered by a method": client side: must have
+	 * a possibility to "trigger" sending of a message to the given messageFrom server
+	 * side: will run the method and await upon receiving message on the output
+	 * messageFrom
+	 * 
+	 * Method triggers sending a message to a source
+	 */
+	public void returnBook(final BookReturned bookReturned) {
+		log.info("Returning book " + bookReturned);
+		MessageCreator messageCreator = new MessageCreator() {
+			@Override
+			public Message createMessage(Session session) throws JMSException {
+				Message message = session.createObjectMessage(bookReturned);
+				message.setStringProperty("BOOK-NAME", bookReturned.bookName);
+				return message;
+			}
+		};
+		jmsTemplate.send("output", messageCreator);
+	}
+}

tests/samples-messaging-spring/src/main/java/com/example/SpringMessagingApplication.java

@@ -0,0 +1,30 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.jms.annotation.EnableJms;
+
+@SpringBootApplication
+@EnableJms
+class SpringMessagingApplication {
+
+	static void main(String[] args) {
+		SpringApplication.run(SpringMessagingApplication.class, args);
+	}
+}

tests/samples-messaging-spring/src/test/groovy/com/example/SpringApplicationSpec.groovy

@@ -0,0 +1,170 @@
+/*
+ *  Copyright 2013-2016 the original author or authors.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.example
+
+import javax.inject.Inject
+
+import org.junit.BeforeClass
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootContextLoader
+import org.springframework.cloud.contract.spec.Contract
+import org.springframework.cloud.contract.verifier.messaging.MessageVerifier
+import org.springframework.cloud.contract.verifier.messaging.boot.AutoConfigureMessageVerifier
+import org.springframework.cloud.contract.verifier.messaging.internal.ContractVerifierObjectMapper;
+import org.springframework.messaging.Message;
+import org.springframework.test.annotation.DirtiesContext
+import org.springframework.test.context.ContextConfiguration
+
+import spock.lang.Specification
+import spock.util.concurrent.PollingConditions
+
+import com.jayway.jsonpath.DocumentContext
+import com.jayway.jsonpath.JsonPath
+import com.toomuchcoding.jsonassert.JsonAssertion
+/**
+ * SPIKE ON TESTS FROM NOTES IN MessagingSpec
+ */
+// Context configuration would end up in base class
+@ContextConfiguration(classes = [SpringMessagingApplication], loader = SpringBootContextLoader)
+@DirtiesContext
+@AutoConfigureMessageVerifier
+public class SpringApplicationSpec extends Specification {
+
+	// ALL CASES
+	@Inject MessageVerifier<Message<?>> contractVerifierMessaging
+	ContractVerifierObjectMapper contractVerifierObjectMapper = new ContractVerifierObjectMapper()
+
+	@BeforeClass
+	void init() {
+		System.setProperty("org.apache.activemq.SERIALIZABLE_PACKAGES", "*")
+	}
+
+	def "should work for triggered based messaging"() {
+		given:
+			def dsl = Contract.make {
+				label 'some_label'
+				input {
+					triggeredBy('bookReturnedTriggered()')
+				}
+				outputMessage {
+					sentTo('output')
+					body('''{ "bookName" : "foo" }''')
+					headers {
+						header('BOOK-NAME', 'foo')
+					}
+				}
+			}
+		// generated test should look like this:
+		when:
+			bookReturnedTriggered()
+		then:
+			def response = contractVerifierMessaging.receive('output')
+			response.headers.get('BOOK-NAME')  == 'foo'
+		and:
+			DocumentContext parsedJson = JsonPath.parse(contractVerifierObjectMapper.writeValueAsString(response.payload))
+			JsonAssertion.assertThat(parsedJson).field('bookName').isEqualTo('foo')
+	}
+
+	def "should generate tests triggered by a message"() {
+		given:
+			def dsl = Contract.make {
+				label 'some_label'
+				input {
+					messageFrom('input')
+					messageBody([
+					        bookName: 'foo'
+					])
+					messageHeaders {
+						header('sample', 'header')
+					}
+				}
+				outputMessage {
+					sentTo('output')
+					body([
+					        bookName: 'foo'
+					])
+					headers {
+						header('BOOK-NAME', 'foo')
+					}
+				}
+			}
+
+		// generated test should look like this:
+
+		//given:
+		Message<?> inputMessage = contractVerifierMessaging.create(
+				contractVerifierObjectMapper.writeValueAsString([bookName: 'foo']),
+				[sample: 'header']
+		)
+		when:
+			contractVerifierMessaging.send(inputMessage, 'input')
+		then:
+			def response = contractVerifierMessaging.receive('output')
+			response.headers.get('BOOK-NAME')  == 'foo'
+		and:
+			DocumentContext parsedJson = JsonPath.parse(contractVerifierObjectMapper.writeValueAsString(response.payload))
+			JsonAssertion.assertThat(parsedJson).field('bookName').isEqualTo('foo')
+	}
+
+	def "should generate tests without destination, triggered by a message"() {
+		given:
+			def dsl = Contract.make {
+				label 'some_label'
+				input {
+					messageFrom('delete')
+					messageBody([
+					        bookName: 'foo'
+					])
+					messageHeaders {
+						header('sample', 'header')
+					}
+					assertThat('bookWasDeleted()')
+				}
+			}
+
+		// generated test should look like this:
+
+		//given:
+		Message<?> inputMessage = contractVerifierMessaging.create(
+				contractVerifierObjectMapper.writeValueAsString([bookName: 'foo']),
+				[sample: 'header']
+		)
+		when:
+			contractVerifierMessaging.send(inputMessage, 'delete')
+		then:
+			noExceptionThrown()
+			bookWasDeleted()
+	}
+
+	// BASE CLASS WOULD HAVE THIS:
+
+	@Autowired BookService bookService
+	@Autowired BookListener bookListener
+
+	void bookReturnedTriggered() {
+		bookService.returnBook(new BookReturned("foo"))
+	}
+
+	PollingConditions pollingConditions = new PollingConditions()
+
+	void bookWasDeleted() {
+		pollingConditions.eventually {
+			assert bookListener.bookSuccessfulyDeleted.get()
+		}
+	}
+
+}