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) { 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) { 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) { profileId, projectId, properties: Object.assign({}, omit(GLOBAL_PROPERTIES, properties), { + user_agent: userAgent, __hash: hash, __query: query, }),