Moved scenario tests into separate subpackage under src/test

dddsample/src/test/java/se/citerus/dddsample/scenario/CargoHandlingScenarioTest.java

@@ -0,0 +1,192 @@
+package se.citerus.dddsample.scenario;
+
+import junit.framework.TestCase;
+import se.citerus.dddsample.application.HandlingEventService;
+import se.citerus.dddsample.application.TrackingService;
+import se.citerus.dddsample.application.impl.HandlingEventServiceImpl;
+import se.citerus.dddsample.application.impl.TrackingServiceImpl;
+import se.citerus.dddsample.application.messaging.HandlingEventRegistrationAttempt;
+import se.citerus.dddsample.domain.model.cargo.*;
+import static se.citerus.dddsample.domain.model.carrier.SampleVoyages.*;
+import se.citerus.dddsample.domain.model.carrier.Voyage;
+import se.citerus.dddsample.domain.model.carrier.VoyageRepository;
+import se.citerus.dddsample.domain.model.handling.CannotCreateHandlingEventException;
+import se.citerus.dddsample.domain.model.handling.HandlingEvent;
+import se.citerus.dddsample.domain.model.handling.HandlingEventFactory;
+import se.citerus.dddsample.domain.model.handling.HandlingEventRepository;
+import se.citerus.dddsample.domain.model.location.Location;
+import se.citerus.dddsample.domain.model.location.LocationRepository;
+import static se.citerus.dddsample.domain.model.location.SampleLocations.*;
+import se.citerus.dddsample.domain.service.DomainEventNotifier;
+import se.citerus.dddsample.domain.service.RoutingService;
+import se.citerus.dddsample.infrastructure.persistence.inmemory.LocationRepositoryInMem;
+import se.citerus.dddsample.infrastructure.persistence.inmemory.VoyageRepositoryInMem;
+
+import java.util.*;
+
+/**
+ * Cargo scenarios.
+ */
+public class CargoHandlingScenarioTest extends TestCase {
+
+  HandlingEventFactory handlingEventFactory;
+
+  DomainEventNotifier domainEventNotifier;
+
+  HandlingEventService handlingEventService;
+  TrackingService trackingService;
+  RoutingService routingService;
+
+  HandlingEventRepository handlingEventRepository;
+  CargoRepository cargoRepository;
+  LocationRepository locationRepository;
+  VoyageRepository voyageRepository;
+
+  Cargo cargo;
+
+
+  public void testCargoFromHongkongToStockholm() throws Exception {
+
+    // Cargo from Hongkong to Stockholm (skipping the booking procedure here)
+    TrackingId trackingId = generateTrackingId();
+    Location origin = HONGKONG;
+    Location destination = STOCKHOLM;
+    cargo = new Cargo(trackingId, origin, destination);
+
+
+    assertEquals(RoutingStatus.NOT_ROUTED, cargo.routingStatus());
+
+    // Route cargo
+    RouteSpecification routeSpecification = new RouteSpecification(cargo.origin(), cargo.destination(), inTwoWeeks());
+    List<Itinerary> itineraries = routingService.fetchRoutesForSpecification(routeSpecification);
+    Itinerary itinerary = selectPreferedItinerary(itineraries);
+    cargo.assignToRoute(itinerary);
+
+    // Handling begins: cargo is received in Hongkong
+    handlingEventService.register(new HandlingEventRegistrationAttempt(
+      new Date(), new Date(), trackingId, null, HandlingEvent.Type.RECEIVE, HONGKONG.unLocode()
+    ));
+
+
+    // Loaded onto carrier movement CM003 in Hongkong
+    handlingEventService.register(new HandlingEventRegistrationAttempt(
+      new Date(), new Date(), trackingId, CM003.voyageNumber(), HandlingEvent.Type.LOAD, HONGKONG.unLocode()
+    ));
+
+    // Check current state - should be ok
+    assertEquals(CM003, cargo.delivery().currentVoyage());
+    assertEquals(HONGKONG, cargo.delivery().lastKnownLocation());
+    assertEquals(TransportStatus.ONBOARD_CARRIER, cargo.delivery().transportStatus());
+    assertFalse(cargo.isMisdirected());
+
+
+    // Cargo is now (incorrectly) unloaded in Tokyo
+    handlingEventService.register(new HandlingEventRegistrationAttempt(
+      new Date(), new Date(), trackingId, CM003.voyageNumber(), HandlingEvent.Type.UNLOAD, TOKYO.unLocode()
+    ));
+
+    // Check current state - cargo is misdirected!
+    assertEquals(Voyage.NONE, cargo.delivery().currentVoyage());
+    assertEquals(TOKYO, cargo.delivery().lastKnownLocation());
+    assertEquals(TransportStatus.IN_PORT, cargo.delivery().transportStatus());
+    assertTrue(cargo.isMisdirected());
+
+    // Then: Reroute!
+  }
+
+  
+
+  /*
+   * Utility stubs below.
+   */
+
+  private Date dateReceived() {
+    return new Date(100);
+  }
+
+  private Date dateLoadingCompleted() {
+    return new Date(200);
+  }
+
+  private Date dateUnloadingCompleted() {
+    return new Date(300);
+  }
+
+  private TrackingId generateTrackingId() {
+    return new TrackingId("TI1");
+  }
+
+  private Date inTwoWeeks() {
+    return new Date(new Date().getTime() + 1000*60*60*24*14);
+  }
+
+  private Itinerary selectPreferedItinerary(List<Itinerary> itineraries) {
+    return itineraries.get(0);
+  }
+
+  protected void setUp() throws Exception {
+
+    // Stub
+    routingService = new RoutingService() {
+      public List<Itinerary> fetchRoutesForSpecification(RouteSpecification routeSpecification) {
+        return Arrays.asList(
+          new Itinerary(Arrays.asList(
+                new Leg(CM003, HONGKONG, NEWYORK, new Date(), new Date()),
+                new Leg(CM004, NEWYORK, CHICAGO, new Date(), new Date()),
+                new Leg(CM005, CHICAGO, STOCKHOLM, new Date(), new Date())
+          ))
+        );
+      }
+    };
+
+    // Synchronous stub
+    domainEventNotifier = new DomainEventNotifier() {
+      public void cargoWasHandled(HandlingEvent event) {
+        trackingService.onCargoHandled(event.cargo().trackingId());
+      }
+      public void cargoWasMisdirected(Cargo cargo) {}
+      public void cargoHasArrived(Cargo cargo) {}
+      public void rejectHandlingEventRegistrationAttempt(CannotCreateHandlingEventException e) {}
+    };
+
+    // Stub
+    cargoRepository = new CargoRepository() {
+      public Cargo find(TrackingId trackingId) {
+        return cargo;
+      }
+
+      public List<Cargo> findAll() {
+        return null;
+      }
+
+      public void save(Cargo cargo) {
+      }
+
+      public TrackingId nextTrackingId() {
+        return null;
+      }
+    };
+
+    // Stub
+    handlingEventRepository = new HandlingEventRepository() {
+      public void save(HandlingEvent event) {
+        Set<HandlingEvent> events = new HashSet<HandlingEvent>(cargo.delivery().history());
+        events.add(event);
+        CargoTestHelper.setDeliveryHistory(cargo, events);
+      }
+
+      public List<HandlingEvent> findEventsForCargo(TrackingId trackingId) {
+        return null;
+      }
+    };
+
+    // In-memory implementations
+    locationRepository = new LocationRepositoryInMem();
+    voyageRepository = new VoyageRepositoryInMem();
+
+    // Domain services and factories that are implemented in the domain layer - not stubbed
+    trackingService = new TrackingServiceImpl(domainEventNotifier, cargoRepository);
+    handlingEventFactory = new HandlingEventFactory(cargoRepository, this.voyageRepository, this.locationRepository);
+    handlingEventService = new HandlingEventServiceImpl(handlingEventRepository, domainEventNotifier, handlingEventFactory);
+  }
+}

dddsample/src/test/java/se/citerus/dddsample/scenario/TrackingScenarioTest.java

@@ -0,0 +1,68 @@
+package se.citerus.dddsample.scenario;
+
+import junit.framework.TestCase;
+import se.citerus.dddsample.domain.model.cargo.Cargo;
+import se.citerus.dddsample.domain.model.cargo.CargoTestHelper;
+import se.citerus.dddsample.domain.model.cargo.Delivery;
+import se.citerus.dddsample.domain.model.cargo.TrackingId;
+import static se.citerus.dddsample.domain.model.carrier.SampleVoyages.CM001;
+import static se.citerus.dddsample.domain.model.carrier.SampleVoyages.CM002;
+import se.citerus.dddsample.domain.model.handling.HandlingEvent;
+import static se.citerus.dddsample.domain.model.handling.HandlingEvent.Type.LOAD;
+import static se.citerus.dddsample.domain.model.handling.HandlingEvent.Type.UNLOAD;
+import static se.citerus.dddsample.domain.model.location.SampleLocations.*;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+public class TrackingScenarioTest extends TestCase {
+
+  public void testTrackingScenarioStage1() throws Exception {
+
+    Cargo cargo = populateCargo();
+
+    Delivery delivery = cargo.delivery();
+
+    List<HandlingEvent> handlingEvents = delivery.history();
+
+    assertEquals(4, handlingEvents.size());
+    final HandlingEvent event = delivery.lastEvent();
+
+    assertEquals(UNLOAD, event.type());
+
+//    assertFalse(cargo.atFinalDestiation());
+//    assertEquals("CNHKG", cargo.currentLocation().unlocode());
+
+  }
+
+  private Cargo populateCargo() throws Exception {
+    final Cargo cargo = new Cargo(new TrackingId("XYZ"), STOCKHOLM, MELBOURNE);
+
+    final List<HandlingEvent> handlingEventList = Arrays.asList(
+      new HandlingEvent(cargo, getDate("2007-12-01"), new Date(), LOAD, STOCKHOLM, CM001),
+      new HandlingEvent(cargo, getDate("2007-12-02"), new Date(), UNLOAD, HAMBURG, CM001),
+      new HandlingEvent(cargo, getDate("2007-12-03"), new Date(), LOAD, HAMBURG, CM002),
+      new HandlingEvent(cargo, getDate("2007-12-05"), new Date(), UNLOAD, HONGKONG, CM002)
+    );
+    CargoTestHelper.setDeliveryHistory(cargo, handlingEventList);
+
+    return cargo;
+  }
+
+  /**
+   * Parse an ISO 8601 (YYYY-MM-DD) String to Date
+   *
+   * @param isoFormat String to parse.
+   * @return Created date instance.
+   * @throws ParseException Thrown if parsing fails.
+   */
+  private Date getDate(String isoFormat) throws ParseException {
+    final DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+    return dateFormat.parse(isoFormat);
+  }
+
+}