mirror of
https://github.com/eclipse-sailing-analytics/sailing-analytics.git
synced 2026-10-11 06:40:53 +00:00
renaming all trackedEvent occurrences to trackedRegatta
This commit is contained in:
1 parent
28ad1dbad2
commit
2799b7c287
39 files changed
+154
-154
No files matched your search
+1
-1
@@ -22,7 +22,7 @@ public interface MongoObjectFactory {
|
||||
* update received will be appended to the MongoDB and can later be retrieved. The key used to identify the race is
|
||||
* the {@link RaceDefinition#getName() race name} and the {@link Regatta#getName() event name}.
|
||||
*/
|
||||
void addWindTrackDumper(TrackedRegatta trackedEvent, TrackedRace trackedRace, WindSource windSource);
|
||||
void addWindTrackDumper(TrackedRegatta trackedRegatta, TrackedRace trackedRace, WindSource windSource);
|
||||
|
||||
/**
|
||||
* Stores the configuration data of <code>leaderboard</code> in the Mongo DB associated with this
|
||||
|
||||
+2
-2
@@ -73,9 +73,9 @@ public class MongoObjectFactoryImpl implements MongoObjectFactory {
|
||||
}
|
||||
|
||||
@Override
|
||||
public void addWindTrackDumper(TrackedRegatta trackedEvent, TrackedRace trackedRace, WindSource windSource) {
|
||||
public void addWindTrackDumper(TrackedRegatta trackedRegatta, TrackedRace trackedRace, WindSource windSource) {
|
||||
WindTrack windTrack = trackedRace.getOrCreateWindTrack(windSource);
|
||||
windTrack.addListener(new MongoWindListener(trackedEvent, trackedRace, windSource, this, database));
|
||||
windTrack.addListener(new MongoWindListener(trackedRegatta, trackedRace, windSource, this, database));
|
||||
}
|
||||
|
||||
public DBCollection getWindTrackCollection() {
|
||||
|
||||
+5
-5
@@ -10,16 +10,16 @@ import com.sap.sailing.domain.tracking.TrackedRace;
|
||||
import com.sap.sailing.domain.tracking.Wind;
|
||||
|
||||
public class MongoWindListener implements com.sap.sailing.domain.tracking.WindListener {
|
||||
private final TrackedRegatta trackedEvent;
|
||||
private final TrackedRegatta trackedRegatta;
|
||||
private final TrackedRace trackedRace;
|
||||
private final WindSource windSource;
|
||||
private final MongoObjectFactoryImpl mongoObjectFactory;
|
||||
private final DBCollection windTracksCollection;
|
||||
|
||||
public MongoWindListener(TrackedRegatta trackedEvent, TrackedRace trackedRace, WindSource windSource,
|
||||
public MongoWindListener(TrackedRegatta trackedRegatta, TrackedRace trackedRace, WindSource windSource,
|
||||
MongoObjectFactory mongoObjectFactory, DB database) {
|
||||
super();
|
||||
this.trackedEvent = trackedEvent;
|
||||
this.trackedRegatta = trackedRegatta;
|
||||
this.trackedRace = trackedRace;
|
||||
this.windSource = windSource;
|
||||
this.mongoObjectFactory = (MongoObjectFactoryImpl) mongoObjectFactory;
|
||||
@@ -28,13 +28,13 @@ public class MongoWindListener implements com.sap.sailing.domain.tracking.WindLi
|
||||
|
||||
@Override
|
||||
public void windDataReceived(Wind wind) {
|
||||
DBObject windTrackEntry = mongoObjectFactory.storeWindTrackEntry(trackedEvent.getRegatta(), trackedRace.getRace(), windSource, wind);
|
||||
DBObject windTrackEntry = mongoObjectFactory.storeWindTrackEntry(trackedRegatta.getRegatta(), trackedRace.getRace(), windSource, wind);
|
||||
windTracksCollection.insert(windTrackEntry);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void windDataRemoved(Wind wind) {
|
||||
DBObject windTrackEntry = mongoObjectFactory.storeWindTrackEntry(trackedEvent.getRegatta(), trackedRace.getRace(), windSource, wind);
|
||||
DBObject windTrackEntry = mongoObjectFactory.storeWindTrackEntry(trackedRegatta.getRegatta(), trackedRace.getRace(), windSource, wind);
|
||||
windTracksCollection.remove(windTrackEntry);
|
||||
}
|
||||
|
||||
|
||||
+7
-7
@@ -48,26 +48,26 @@ public class MongoWindStoreImpl extends EmptyWindStore implements MongoWindStore
|
||||
* additions to the wind track will be written to the MongoDB.
|
||||
*/
|
||||
@Override
|
||||
public WindTrack getWindTrack(TrackedRegatta trackedEvent, TrackedRace trackedRace, WindSource windSource,
|
||||
public WindTrack getWindTrack(TrackedRegatta trackedRegatta, TrackedRace trackedRace, WindSource windSource,
|
||||
long millisecondsOverWhichToAverage, long delayForWindEstimationCacheInvalidation) {
|
||||
WindTrack result;
|
||||
if (windSource.canBeStored()) {
|
||||
result = domainObjectFactory.loadWindTrack(trackedEvent.getRegatta(), trackedRace.getRace(), windSource,
|
||||
result = domainObjectFactory.loadWindTrack(trackedRegatta.getRegatta(), trackedRace.getRace(), windSource,
|
||||
millisecondsOverWhichToAverage);
|
||||
result.addListener(new MongoWindListener(trackedEvent, trackedRace, windSource, mongoObjectFactory, db));
|
||||
result.addListener(new MongoWindListener(trackedRegatta, trackedRace, windSource, mongoObjectFactory, db));
|
||||
} else {
|
||||
result = super.getWindTrack(trackedEvent, trackedRace, windSource, millisecondsOverWhichToAverage, delayForWindEstimationCacheInvalidation);
|
||||
result = super.getWindTrack(trackedRegatta, trackedRace, windSource, millisecondsOverWhichToAverage, delayForWindEstimationCacheInvalidation);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Map<? extends WindSource, ? extends WindTrack> loadWindTracks(TrackedRegatta trackedEvent,
|
||||
public Map<? extends WindSource, ? extends WindTrack> loadWindTracks(TrackedRegatta trackedRegatta,
|
||||
TrackedRace trackedRace, long millisecondsOverWhichToAverageWind) {
|
||||
Map<? extends WindSource, ? extends WindTrack> result = domainObjectFactory.loadWindTracks(
|
||||
trackedEvent.getRegatta(), trackedRace.getRace(), millisecondsOverWhichToAverageWind);
|
||||
trackedRegatta.getRegatta(), trackedRace.getRace(), millisecondsOverWhichToAverageWind);
|
||||
for (Entry<? extends WindSource, ? extends WindTrack> e : result.entrySet()) {
|
||||
e.getValue().addListener(new MongoWindListener(trackedEvent, trackedRace, e.getKey(), mongoObjectFactory, db));
|
||||
e.getValue().addListener(new MongoWindListener(trackedRegatta, trackedRace, e.getKey(), mongoObjectFactory, db));
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user