chore: normalize json result

app.py

@@ -23,7 +23,7 @@ for webhook in client.webhooks:
 async def record_events(record: rg.Record, type: str, timestamp: datetime):
     print(f"Received event type {type} at {timestamp}: ", record)
 
-    incoming_events.put(record)
+    incoming_events.put({"event": type,  "data": record})
 
 
 # Create a webhook for dataset events
@@ -31,7 +31,7 @@ async def record_events(record: rg.Record, type: str, timestamp: datetime):
 async def dataset_events(dataset: rg.Dataset, type: str, timestamp: datetime):
     print(f"Received event type {type} at {timestamp}: ", dataset)
 
-    incoming_events.put((type, dataset))
+    incoming_events.put({"event": type,  "data": dataset})
 
 
 # Create a webhook for response events
@@ -39,7 +39,7 @@ async def dataset_events(dataset: rg.Dataset, type: str, timestamp: datetime):
 async def response_events(response: rg.UserResponse, type: str, timestamp: datetime):
     print(f"Received event type {type} at {timestamp}: ", response)
 
-    incoming_events.put(response)
+    incoming_events.put({"event": type,  "data": response})
 
 
 def read_next_event():