Implemented migration of COMPETITORS collection to COMPETITORS_WITH_BOAT_REFERENCES and BOATS collections (old COMPETITORS collection is not deleted for easier development and debugging)

TracTrac connector uses now boat metadata AND leaderboardGroup to create boatIds and lookup boats from the boat store.
This commit is contained in:
Frank Mittag
2017-09-29 16:09:30 +02:00
parent ce42ab2c0c
commit 85f3ec4723
31 changed files with 463 additions and 119 deletions
@@ -180,6 +180,11 @@ public class TestStoringAndLoadingEventsAndRegattas extends AbstractMongoDBTest
public LeaderboardGroup getLeaderboardGroupByID(UUID leaderboardGroupID) {
return leaderboardGroupID.equals(lg1.getId()) ? lg1 : leaderboardGroupID.equals(lg2.getId()) ? lg2 : null;
}
@Override
public LeaderboardGroup resolveLeaderboardGroupByRegattaName(String regattaName) {
return null;
}
});
assertNotNull(loadedEvent);
assertEquals(eventName, loadedEvent.getName());
@@ -30,6 +30,7 @@ import com.sap.sailing.domain.common.impl.DegreePosition;
import com.sap.sailing.domain.common.impl.KnotSpeedWithBearingImpl;
import com.sap.sailing.domain.common.impl.WindImpl;
import com.sap.sailing.domain.common.impl.WindSourceImpl;
import com.sap.sailing.domain.leaderboard.LeaderboardGroupResolver;
import com.sap.sailing.domain.persistence.impl.DomainObjectFactoryImpl;
import com.sap.sailing.domain.persistence.impl.MongoObjectFactoryImpl;
import com.sap.sailing.domain.racelog.impl.EmptyRaceLogStore;
@@ -90,7 +91,7 @@ public class TestStoringAndRetrievingWindTracksTest extends AbstractTracTracLive
@Override
public void addRaceDefinition(RaceDefinition race, DynamicTrackedRace trackedRace) {
}
}, /* trackedRegattaRegistry */ null, mock(RaceLogResolver.class),
}, /* trackedRegattaRegistry */ null, mock(RaceLogResolver.class), mock(LeaderboardGroupResolver.class),
/*courseDesignUpdateURI*/ null, /*tracTracUsername*/ null, /*tracTracPassword*/ null, getEventSubscriber(), getRaceSubscriber(), /*ignoreTracTracMarkPassings*/ false, RaceTracker.TIMEOUT_FOR_RECEIVING_RACE_DEFINITION_IN_MILLISECONDS, ReceiverType.RACECOURSE);
addListenersForStoredDataAndStartController(typeControllers);
for (final Receiver receiver : typeControllers) {