From 153faab8786bddbba495f5bd85bd903af95fecde Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Sat, 5 Oct 2024 22:36:02 +0200
Subject: [PATCH] fix(worker): minor improvements for incoming events

---
 apps/worker/src/jobs/events.incoming-event.ts | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/apps/worker/src/jobs/events.incoming-event.ts b/apps/worker/src/jobs/events.incoming-event.ts
index 32adf6fa..b5320ee4 100644
--- a/apps/worker/src/jobs/events.incoming-event.ts
+++ b/apps/worker/src/jobs/events.incoming-event.ts
@@ -63,10 +63,12 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
   const uaInfo = parseUserAgent(userAgent);
 
   if (uaInfo.isServer) {
-    const event = await getLastScreenViewFromProfileId({
-      profileId,
-      projectId,
-    });
+    const event = profileId
+      ? await getLastScreenViewFromProfileId({
+          profileId,
+          projectId,
+        })
+      : null;
 
     const payload: IServiceCreateEventPayload = {
       name: body.name,
@@ -82,8 +84,8 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
       country: event?.country || geo.country || '',
       city: event?.city || geo.city || '',
       region: event?.region || geo.region || '',
-      longitude: geo.longitude,
-      latitude: geo.latitude,
+      longitude: event?.longitude || geo.longitude || null,
+      latitude: event?.latitude || geo.latitude || null,
       os: event?.os ?? '',
       osVersion: event?.osVersion ?? '',
       browser: event?.browser ?? '',
@@ -128,6 +130,7 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
     profileId,
     projectId,
     properties: Object.assign({}, omit(GLOBAL_PROPERTIES, properties), {
+      user_agent: userAgent,
       __hash: hash,
       __query: query,
     }),