Copy some test utilities to the integration test module

Copy some test utilities to the integration test module

#755

integrationtests/src/test/java/org/axonframework/AssertUtils.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright (c) 2010-2018. Axon Framework
+ *
+ * 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 org.axonframework;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Utility class for special assertions
+ */
+public class AssertUtils {
+
+    private AssertUtils() {
+
+    }
+
+    /**
+     * Assert that the given {@code assertion} succeeds with the given {@code time} and {@code unit}.
+     * @param time The time in which the assertion must pass
+     * @param unit The unit in which time is expressed
+     * @param assertion the assertion to succeed within the deadline
+     */
+    public static void assertWithin(int time, TimeUnit unit, Runnable assertion) {
+        long now = System.currentTimeMillis();
+        long deadline = now + unit.toMillis(time);
+        do {
+            try {
+                assertion.run();
+                break;
+            } catch (AssertionError e) {
+                if (now >= deadline) {
+                    throw e;
+                }
+            }
+            now = System.currentTimeMillis();
+        } while (true);
+    }
+
+}

integrationtests/src/test/java/org/axonframework/EventTestUtils.java

@@ -0,0 +1,107 @@
+/*
+ * Copyright (c) 2010-2018. Axon Framework
+ *
+ * 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 org.axonframework;
+
+import org.axonframework.common.IdentifierFactory;
+import org.axonframework.eventhandling.DomainEventMessage;
+import org.axonframework.eventhandling.GenericDomainEventMessage;
+import org.axonframework.messaging.MetaData;
+
+import java.time.Instant;
+import java.util.List;
+import java.util.UUID;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+
+// TODO copied from EventStoreTestUtils - consolidate
+public abstract class EventTestUtils {
+
+    public static final String PAYLOAD = "payload";
+    public static final String AGGREGATE = "aggregate";
+    private static final String TYPE = "type";
+    private static final MetaData METADATA = MetaData.emptyInstance();
+
+    public static List<DomainEventMessage<?>> createEvents(int numberOfEvents) {
+        return IntStream.range(0, numberOfEvents)
+                        .mapToObj(sequenceNumber -> createEvent(TYPE,
+                                                                IdentifierFactory.getInstance().generateIdentifier(),
+                                                                AGGREGATE,
+                                                                sequenceNumber,
+                                                                PAYLOAD + sequenceNumber,
+                                                                METADATA))
+                        .collect(Collectors.toList());
+    }
+
+    public static List<DomainEventMessage<?>> createUUIDEvents(int numberOfEvents) {
+        return IntStream.range(0, numberOfEvents).mapToObj(
+                sequenceNumber -> createEvent(TYPE,
+                                              IdentifierFactory.getInstance().generateIdentifier(),
+                                              UUID.randomUUID().toString(),
+                                              sequenceNumber,
+                                              PAYLOAD + sequenceNumber,
+                                              METADATA))
+                        .collect(Collectors.toList());
+    }
+
+    public static DomainEventMessage<String> createEvent() {
+        return createEvent(0);
+    }
+
+    public static DomainEventMessage<String> createEvent(long sequenceNumber) {
+        return createEvent(AGGREGATE, sequenceNumber);
+    }
+
+    public static DomainEventMessage<String> createEvent(long sequenceNumber, Instant timestamp) {
+        return new GenericDomainEventMessage<>(TYPE, AGGREGATE, sequenceNumber, PAYLOAD, METADATA,
+                                               IdentifierFactory.getInstance().generateIdentifier(), timestamp);
+    }
+
+    public static DomainEventMessage<String> createEvent(String aggregateId, long sequenceNumber) {
+        return createEvent(aggregateId, sequenceNumber, PAYLOAD);
+    }
+
+    public static DomainEventMessage<String> createEvent(String aggregateId, long sequenceNumber, String payload) {
+        return createEvent(TYPE,
+                           IdentifierFactory.getInstance().generateIdentifier(),
+                           aggregateId,
+                           sequenceNumber,
+                           payload,
+                           METADATA);
+    }
+
+    public static DomainEventMessage<String> createEvent(String eventId, String aggregateId, long sequenceNumber) {
+        return createEvent(TYPE, eventId, aggregateId, sequenceNumber, PAYLOAD, METADATA);
+    }
+
+    public static DomainEventMessage<String> createEvent(String type,
+                                                         String eventId,
+                                                         String aggregateId,
+                                                         long sequenceNumber,
+                                                         String payload,
+                                                         MetaData metaData) {
+        return new GenericDomainEventMessage<>(type,
+                                               aggregateId,
+                                               sequenceNumber,
+                                               payload,
+                                               metaData,
+                                               eventId,
+                                               GenericDomainEventMessage.clock.instant());
+    }
+
+    private EventTestUtils() {
+    }
+}

integrationtests/src/test/java/org/axonframework/MockException.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright (c) 2010-2018. Axon Framework
+ *
+ * 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 org.axonframework;
+
+/**
+ * Mock exception that provides no stack trace.
+ * TODO check whether to move this to a test-utils package or something like that
+ * @author Allard Buijze
+ * @since 2.0
+ */
+public class MockException extends RuntimeException {
+
+    public MockException(String message) {
+        super(message);
+    }
+
+    public MockException() {
+        super("Mock");
+    }
+
+    @Override
+    public synchronized Throwable fillInStackTrace() {
+        return this;
+    }
+
+    @Override
+    public StackTraceElement[] getStackTrace() {
+        return new StackTraceElement[]{};
+    }
+}