eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-30 09:26:44 +00:00
Code Activity

Added first End-To-End Test for StoreForward -> SwissTimingConnector driven by a script of messages

Browse Source
This commit is contained in:
fmittag
2011-11-16 18:06:01 +01:00
parent 4e314c61c7
commit 653e825560
5 changed files with 214 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.swisstimingadapter.persistence/src/com/sap/sailing/domain/swisstimingadapter/persistence/impl/SwissTimingAdapterPersistenceImpl.java
+21 -2
View File
@@ -148,9 +148,10 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
query.append(FieldNames.RACE_ID.name(), raceID);
DBObject o = races.findOne(query);
if (o != null) {
Long startTimeAsMillis = (Long) o.get(FieldNames.RACE_STARTTIME.name());
Race race = swissTimingFactory.createRace((String) o.get(FieldNames.RACE_ID.name()),
(String) o.get(FieldNames.RACE_DESCRIPTION.name()),
new MillisecondsTimePoint((Long) o.get(FieldNames.RACE_STARTTIME.name())));
startTimeAsMillis == null ? null : new MillisecondsTimePoint(startTimeAsMillis));
return race;
}
return null;
@@ -208,7 +209,15 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
messageCollection = database.getCollection(CollectionNames.COMMAND_MESSAGES.name());
}
messageCollection.insert(objToInsert);
if(message.getRaceID() != null && cachedRaces.containsKey(message.getRaceID()) == false) {
if(message.getType() == MessageType.RAC) {
// store the new race in the master data collection
List<Race> availableRaces = parseAvailableRacesMessage(message);
for (Race newRace : availableRaces) {
storeRace(newRace);
}
} else if(message.getRaceID() != null && cachedRaces.containsKey(message.getRaceID()) == false) {
// ah, we found a new raceID which is not in the list of known races
// in order to have a more intelligent conflict resolver mechanism we will forward the resolution to a special thread later on
boolean simpleResolution = true;
@@ -226,6 +235,16 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
}
}
private List<Race> parseAvailableRacesMessage(SailMasterMessage availableRacesMessage) {
int count = Integer.valueOf(availableRacesMessage.getSections()[1]);
List<Race> result = new ArrayList<Race>();
for (int i=0; i<count; i++) {
String[] idAndDescription = availableRacesMessage.getSections()[2+i].split(";");
result.add(SwissTimingFactory.INSTANCE.createRace(idAndDescription[0], idAndDescription[1], null));
}
return result;
}
@Override
public void storeRace(Race race) {
DBCollection racesCollection = database.getCollection(CollectionNames.RACES_MASTERDATA.name());