Function handleTrack

apps/api/src/controllers/track.controller.ts:206–256

(
  payload: ITrackPayload,
  context: TrackContext
)

}

async function handleTrack(
  payload: ITrackPayload,
  context: TrackContext
): Promise<void> {
  const { projectId, deviceId, geo, headers, timestamp, sessionId } = context;

  const uaInfo = parseUserAgent(headers['user-agent'], payload.properties);
  const groupId = uaInfo.isServer
    ? payload.profileId
      ? `${projectId}:${payload.profileId}`
      : undefined
    : deviceId;
  const promises: Promise<unknown>[] = [];

  // If we have more than one property in the identity object, we should identify the user
  // Otherwise its only a profileId and we should not identify the user
  if (context.identity && Object.keys(context.identity).length > 1) {
    promises.push(handleIdentify(context.identity, context));
  }

  const queueData: EventsQueuePayloadIncomingEvent['payload'] = {
    projectId,
    headers,
    event: {
      ...payload,
      groups: payload.groups ?? [],
      timestamp: timestamp.value,
      isTimestampFromThePast: timestamp.isFromPast,
    },
    uaInfo,
    geo,
    deviceId,
    sessionId,
  };

  const partitionKey = groupId || generateId();

  if (shouldUseKafka()) {
    promises.push(produceIncomingEvent(queueData, partitionKey));
  } else {
    promises.push(
      getEventsGroupQueueShard(partitionKey).add({
        orderMs: timestamp.value,
        data: queueData,
        groupId,
      })
    );
  }

  await Promise.all(promises);
}

async function handleIdentify(
  payload: IIdentifyPayload,