imp(): update worker task types

Author: e11sy

lib/event-worker.ts

@@ -26,6 +26,7 @@ export abstract class EventWorker extends Worker {
       projectId: event.projectId,
       catcherType: this.type,
       event: event.payload,
+      timestamp: event.timestamp
     } as GroupWorkerTask);
   }
 
@@ -35,7 +36,7 @@ export abstract class EventWorker extends Worker {
    * @param {EventWorkerTask} event - event to be validated
    */
   protected validate(event: EventWorkerTask): void {
-    if (!event.projectId || !event.payload) {
+    if (!event.projectId || !event.payload || !event.timestamp) {
       throw new Error('Bad data was given');
     }
   }

lib/types/event-worker-task.d.ts

@@ -19,4 +19,9 @@ export interface EventWorkerTask extends WorkerTask {
    * All information about the event
    */
   payload: DecodedEventData<EventAddons>;
+
+  /**
+   * Unix timestamp of the event
+   */
+  timestamp: number;
 }

workers/default/types/default-event-worker-task.d.ts

@@ -14,4 +14,9 @@ export interface DefaultEventWorkerTask extends EventWorkerTask {
    * Language-specific payload
    */
   payload: DefaultEventPayload;
+
+  /**
+   * Unix timestamp of the event
+   */
+  timestamp: number;
 }

workers/grouper/types/group-worker-task.d.ts

@@ -1,4 +1,4 @@
-import type { EventDataAccepted, EventAddons } from '@hawk.so/types';
+import type { EventAddons, EventData } from '@hawk.so/types';
 import type { WorkerTask } from '../../../lib/types/worker-task';
 import type { Delta } from '@n1ru4l/json-patch-plus';
 
@@ -20,7 +20,12 @@ export interface GroupWorkerTask extends WorkerTask {
   /**
    * Event that should be grouped
    */
-  event: EventDataAccepted<EventAddons>;
+  event: EventData<EventAddons>;
+
+  /**
+   * Unix timestamp of the event
+   */
+  timestamp: number;
 }
 
 /**

workers/javascript/types/javascript-event-worker-task.d.ts

@@ -14,4 +14,9 @@ export interface JavaScriptEventWorkerTask extends EventWorkerTask {
    * Language-specific payload
    */
   payload: JavaScriptEventPayload;
+
+  /**
+   * Unix timestamp of the event
+   */
+  timestamp: number;
 }