feature(root): add vitest and some basic tests

Author: lindesvard

apps/worker/package.json

@@ -2,6 +2,7 @@
   "name": "@openpanel/worker",
   "version": "0.0.1",
   "scripts": {
+    "test": "vitest",
     "dev": "dotenv -e ../../.env -c -v WATCH=1 tsup",
     "testing": "WORKER_PORT=9999 pnpm dev",
     "start": "node dist/index.js",

apps/worker/src/jobs/events.incoming-event.ts

@@ -96,14 +96,36 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
 
   // if timestamp is from the past we dont want to create a new session
   if (uaInfo.isServer || isTimestampFromThePast) {
-    const event = profileId
+    const screenView = profileId
       ? await getLastScreenViewFromProfileId({
           profileId,
           projectId,
         })
       : null;
 
-    const payload = merge(omit(['properties'], event ?? {}), baseEvent);
+    const payload = {
+      ...baseEvent,
+      deviceId: screenView?.deviceId ?? '',
+      sessionId: screenView?.sessionId ?? '',
+      referrer: screenView?.referrer ?? undefined,
+      referrerName: screenView?.referrerName ?? undefined,
+      referrerType: screenView?.referrerType ?? undefined,
+      path: screenView?.path ?? baseEvent.path,
+      os: screenView?.os ?? baseEvent.os,
+      osVersion: screenView?.osVersion ?? baseEvent.osVersion,
+      browserVersion: screenView?.browserVersion ?? baseEvent.browserVersion,
+      browser: screenView?.browser ?? baseEvent.browser,
+      device: screenView?.device ?? baseEvent.device,
+      brand: screenView?.brand ?? baseEvent.brand,
+      model: screenView?.model ?? baseEvent.model,
+      city: screenView?.city ?? baseEvent.city,
+      country: screenView?.country ?? baseEvent.country,
+      region: screenView?.region ?? baseEvent.region,
+      longitude: screenView?.longitude ?? baseEvent.longitude,
+      latitude: screenView?.latitude ?? baseEvent.latitude,
+      origin: screenView?.origin ?? baseEvent.origin,
+    };
+
     return createEventAndNotify(payload as IServiceEvent);
   }
 
@@ -121,7 +143,7 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
     referrer: sessionEnd.payload?.referrer,
     referrerName: sessionEnd.payload?.referrerName,
     referrerType: sessionEnd.payload?.referrerType,
-  }) as IServiceCreateEventPayload
+  }) as IServiceCreateEventPayload;
 
   if (sessionEnd.notFound) {
     await createSessionEnd({ payload });