diff --git a/packages/db/src/buffers/profile-buffer-psql.ts b/packages/db/src/buffers/profile-buffer-psql.ts index 3580f6f1..0f7649d0 100644 --- a/packages/db/src/buffers/profile-buffer-psql.ts +++ b/packages/db/src/buffers/profile-buffer-psql.ts @@ -81,6 +81,7 @@ export class ProfileBuffer extends BaseBuffer { ['created_at'], ['properties', 'brand'], ['properties', 'browser_version'], + ['properties', 'browserVersion'], ['properties', 'browser'], ['properties', 'city'], ['properties', 'country'], @@ -89,10 +90,13 @@ export class ProfileBuffer extends BaseBuffer { ['properties', 'longitude'], ['properties', 'model'], ['properties', 'os_version'], + ['properties', 'osVersion'], ['properties', 'os'], ['properties', 'path'], ['properties', 'referrer_name'], + ['properties', 'referrerName'], ['properties', 'referrer_type'], + ['properties', 'referrerType'], ['properties', 'referrer'], ['properties', 'region'], ]; diff --git a/packages/db/src/services/event.service.ts b/packages/db/src/services/event.service.ts index 4a14b0ec..0a4ced6d 100644 --- a/packages/db/src/services/event.service.ts +++ b/packages/db/src/services/event.service.ts @@ -278,7 +278,7 @@ export async function createEvent(payload: IServiceCreateEventPayload) { } if (payload.profileId) { - await upsertProfile({ + const profile = { id: String(payload.profileId), isExternal: payload.profileId !== payload.deviceId, projectId: payload.projectId, @@ -300,7 +300,14 @@ export async function createEvent(payload: IServiceCreateEventPayload) { referrer_name: payload.referrerName, referrer_type: payload.referrerType, }, - }); + }; + + if ( + profile.isExternal || + (profile.isExternal === false && payload.name === 'session_start') + ) { + await upsertProfile(profile); + } } const event: IClickhouseEvent = {