Adds upload_time and enables filter flags for incorrect time closes #117

lambda/ham_put_api/__init__.py

@@ -63,6 +63,7 @@ def upload(event, context):
     payloads = json.loads(event["body"])
     to_sns = []
     errors = []
+    warnings = []
 
 
 
@@ -72,8 +73,36 @@ def upload(event, context):
             payload["user-agent"] = event["headers"]["user-agent"]
         payload["position"] = f'{payload["lat"]},{payload["lon"]}'
 
+        payload["upload_time"] = datetime.datetime.now().isoformat()
+
         valid, error_message = telemetry_filter(payload)
 
+        try:
+            _delta_time = (
+                datetime.datetime.now() - datetime.datetime.fromisoformat(payload["datetime"].replace("Z",""))
+            ).total_seconds()
+        except:
+            errors.append({
+                "error_message": "Unable to parse datetime",
+                "payload": payload
+            })
+
+        future_time_threshold_seconds = 60
+        time_threshold_hours = 24
+        if _delta_time < -future_time_threshold_seconds:
+            payload["telemetry_hidden"] = True
+            warnings.append({
+                "warning_message": f"Payload reported time too far in the future. Either sonde time or system time is invalid. (Threshold: {future_time_threshold_seconds} seconds)",
+                "payload": payload
+            })
+        if "historical" not in payload or payload['historical'] == False:
+            if abs(_delta_time) > (3600 * time_threshold_hours):
+                payload["telemetry_hidden"] = True
+                warnings.append({
+                    "warning_message": f"Payload reported time too far from current UTC time. Either payload time or system time is invalid. (Threshold: {time_threshold_hours} hours)",
+                    "payload": payload
+                })
+
         if not valid:
             errors.append({
                 "error_message": error_message,
@@ -98,19 +127,20 @@ def upload(event, context):
 
 
     post(to_sns)
-    return errors
+    return errors, warnings
 def lambda_handler(event, context):
     try:
-        errors = upload(event, context)
+        errors, warnings = upload(event, context)
     except zlib.error:
         return {"statusCode": 400, "body": "Could not decompress"}
     except json.decoder.JSONDecodeError:
         return {"statusCode": 400, "body": "Not valid json"}
     error_message = {
-        "message": "some or all payloads could not be processed",
-        "errors": errors
+        "message": "some or all payloads could not be processed or have warnings",
+        "errors": errors,
+        "warnings": warnings
     }
-    if errors:
+    if errors or warnings:
         output = {
             "statusCode": 202, 
             "body": json.dumps(error_message),

lambda/ham_put_api/__main__.py

@@ -12,7 +12,7 @@ body = [
     "payload_callsign": "4FSKTEST",
     "uploader_antenna": "1/4 wave monopole",
     "time_received": "2021-12-30T03:55:05.510688Z",
-    "datetime": "2021-12-30T03:55:05.510688Z",
+    "datetime": "2022-08-02T04:10:05.510688Z",
     "manufacturer": "Graw",
     "type": "DFM",
     "subtype": "DFM09",
@@ -32,6 +32,8 @@ body = [
     "position": "47.8319,10.89474",
     "uploader_alt": 545,
     "uploader_position": [None,None,None],
+    "historical": True,
+    "dev": True
   }]
 
 compressed = BytesIO()