Replay time ordering

RadarSDK/RadarAPIClient.m

@@ -212,6 +212,7 @@ - (void)trackWithLocation:(CLLocation *_Nonnull)location
         return completionHandler(RadarStatusErrorPublishableKey, nil, nil, nil, nil, nil, nil);
     }
     NSMutableDictionary *params = [NSMutableDictionary new];
+    RadarSdkConfiguration *sdkConfiguration = [RadarSettings sdkConfiguration];
     BOOL anonymous = [RadarSettings anonymousTrackingEnabled];
     params[@"anonymous"] = @(anonymous);
     if (anonymous) {
@@ -251,10 +252,11 @@ - (void)trackWithLocation:(CLLocation *_Nonnull)location
         params[@"floorLevel"] = @(location.floor.level);
     }
     long nowMs = (long)([NSDate date].timeIntervalSince1970 * 1000);
-    if (!foreground) {
-        long timeInMs = (long)(location.timestamp.timeIntervalSince1970 * 1000);
-        params[@"updatedAtMsDiff"] = @(nowMs - timeInMs);
+    long locationMs = (long)(location.timestamp.timeIntervalSince1970 * 1000);
+    if (sdkConfiguration.useForegroundLocationUpdatedAtMsDiff || !foreground) {
+        params[@"updatedAtMsDiff"] = @(nowMs - locationMs);
     }
+    params[@"locationMs"] = @(locationMs);
     params[@"foreground"] = @(foreground);
     params[@"stopped"] = @(stopped);
     params[@"replayed"] = @(replayed);
@@ -298,7 +300,6 @@ - (void)trackWithLocation:(CLLocation *_Nonnull)location
         [tripParams setValue:[Radar stringForMode:tripOptions.mode] forKey:@"mode"];
         params[@"tripOptions"] = tripParams;
     }
-
     RadarTrackingOptions *options = [Radar getTrackingOptions];
     if (options.syncGeofences) {
         params[@"nearbyGeofences"] = @(YES);
@@ -340,7 +341,6 @@ - (void)trackWithLocation:(CLLocation *_Nonnull)location
         }
     }
     params[@"appId"] = [[NSBundle mainBundle] bundleIdentifier];
-    RadarSdkConfiguration *sdkConfiguration = [RadarSettings sdkConfiguration];
     if (sdkConfiguration.useLocationMetadata) { 
         NSMutableDictionary *locationMetadata = [NSMutableDictionary new];
         locationMetadata[@"motionActivityData"] = [RadarState lastMotionActivityData];
@@ -415,9 +415,6 @@ - (void)trackWithLocation:(CLLocation *_Nonnull)location
                                     // create a copy of params that we can use to write to the buffer in case of request failure
                                     NSMutableDictionary *bufferParams = [params mutableCopy];
                                     bufferParams[@"replayed"] = @(YES);
-                                    bufferParams[@"updatedAtMs"] = @(nowMs);
-                                    // remove the updatedAtMsDiff key because for replays we want to rely on the updatedAtMs key for the time instead
-                                    [bufferParams removeObjectForKey:@"updatedAtMsDiff"];
 
                                     [[RadarReplayBuffer sharedInstance] writeNewReplayToBuffer:bufferParams];
                                 } else if (options.replay == RadarTrackingOptionsReplayStops && stopped &&

RadarSDK/RadarAPIHelper.m

@@ -67,9 +67,39 @@ - (void)requestWithMethod:(NSString *)method
             }
 
             if (params) {
-                [req setHTTPBody:[NSJSONSerialization dataWithJSONObject:params options:0 error:NULL]];
+                NSNumber *prevUpdatedAtMsDiff = params[@"updatedAtMsDiff"];
+                NSArray *replays = params[@"replays"];
+                if (prevUpdatedAtMsDiff || replays) {
+                    NSMutableDictionary *requestParams = [params mutableCopy];
+                    long nowMs = (long)([NSDate date].timeIntervalSince1970 * 1000);
+                    NSNumber *locationMs = params[@"locationMs"];
+
+                    if (locationMs != nil && prevUpdatedAtMsDiff != nil) {
+                        long updatedAtMsDiff = nowMs - [locationMs longValue];
+                        requestParams[@"updatedAtMsDiff"] = @(updatedAtMsDiff);
+                    }
+
+                    if (replays) {
+                        NSMutableArray *updatedReplays = [NSMutableArray arrayWithCapacity:replays.count];
+                        for (NSDictionary *replay in replays) {
+                            NSMutableDictionary *updatedReplay = [replay mutableCopy];
+                            NSNumber *replayLocationMs = replay[@"locationMs"];
+                            if (replayLocationMs != nil) {
+                                long replayUpdatedAtMsDiff = nowMs - [replayLocationMs longValue];
+                                updatedReplay[@"updatedAtMsDiff"] = @(replayUpdatedAtMsDiff);
+                            }
+                            [updatedReplays addObject:updatedReplay];
+                        }
+                        requestParams[@"replays"] = updatedReplays;
+                    }
+
+                    [req setHTTPBody:[NSJSONSerialization dataWithJSONObject:requestParams options:0 error:NULL]];
+                } else {
+                    [req setHTTPBody:[NSJSONSerialization dataWithJSONObject:params options:0 error:NULL]];
+                }
             }
 
+
             NSURLSessionConfiguration *configuration;
             if (extendedTimeout) {
                 configuration = [NSURLSessionConfiguration defaultSessionConfiguration];

RadarSDK/RadarLocationManager.m

@@ -1131,6 +1131,10 @@ - (void)locationManager:(CLLocationManager *)manager didVisit:(CLVisit *)visit {
         return;
     }
 
+    [[RadarLogger sharedInstance] logWithLevel:RadarLogLevelDebug
+                                   message:[NSString stringWithFormat:@"Visit detected | arrival = %@; departure = %@; horizontalAccuracy = %f; visit.coordinate = (%f, %f); manager.location = %@",
+                                                                      visit.arrivalDate, visit.departureDate, visit.horizontalAccuracy, visit.coordinate.latitude, visit.coordinate.longitude, manager.location]];
+
     BOOL tracking = [RadarSettings tracking];
     if (!tracking) {
         [[RadarLogger sharedInstance] logWithLevel:RadarLogLevelDebug message:@"Ignoring visit: not tracking"];

RadarSDK/RadarSdkConfiguration.h

@@ -34,6 +34,9 @@ NS_ASSUME_NONNULL_BEGIN
 @property (nonatomic, assign) BOOL useLocationMetadata;
 
 @property (nonatomic, assign) BOOL useOpenedAppConversion;
+
+@property (nonatomic, assign) BOOL useForegroundLocationUpdatedAtMsDiff;
+
 /**
  Initializes a new RadarSdkConfiguration object with given value.
  */

RadarSDK/RadarSdkConfiguration.m

@@ -69,10 +69,16 @@ - (instancetype)initWithDict:(NSDictionary *)dict {
         _useLocationMetadata = [(NSNumber *)useLocationMetadataObj boolValue];
     }
 
-    NSObject *useOpenedAppConversion = dict[@"useOpenedAppConversion"];
+    NSObject *useOpenedAppConversionObj = dict[@"useOpenedAppConversion"];
     _useOpenedAppConversion = NO;
-    if (useOpenedAppConversion && [useOpenedAppConversion isKindOfClass:[NSNumber class]]) {
-        _useOpenedAppConversion = [(NSNumber *)useOpenedAppConversion boolValue];
+    if (useOpenedAppConversionObj && [useOpenedAppConversionObj isKindOfClass:[NSNumber class]]) {
+        _useOpenedAppConversion = [(NSNumber *)useOpenedAppConversionObj boolValue];
+    }
+
+    NSObject *useForegroundLocationUpdatedAtMsDiffObj = dict[@"foregroundLocationUseUpdatedAtMsDiff"];
+    _useForegroundLocationUpdatedAtMsDiff = NO;
+    if (useForegroundLocationUpdatedAtMsDiffObj && [useForegroundLocationUpdatedAtMsDiffObj isKindOfClass:[NSNumber class]]) {
+        _useForegroundLocationUpdatedAtMsDiff = [(NSNumber *)useForegroundLocationUpdatedAtMsDiffObj boolValue];
     }
 
     return self;
@@ -90,6 +96,7 @@ - (NSDictionary *)dictionaryValue {
     dict[@"useRadarModifiedBeacon"] = @(_useRadarModifiedBeacon);
     dict[@"useLocationMetadata"] = @(_useLocationMetadata);
     dict[@"useOpenedAppConversion"] = @(_useOpenedAppConversion);
+    dict[@"useForegroundLocationUpdatedAtMsDiff"] = @(_useForegroundLocationUpdatedAtMsDiff);
 
     return dict;
 }