Function processEvent

plugin-server/tests/main/process-event.test.ts:108–132

(
    distinctId: string,
    ip: string | null,
    _siteUrl: string,
    data: Partial<PluginEvent>,
    teamId: number,
    timestamp: DateTime,
    eventUuid: string
)

}

async function processEvent(
    distinctId: string,
    ip: string | null,
    _siteUrl: string,
    data: Partial<PluginEvent>,
    teamId: number,
    timestamp: DateTime,
    eventUuid: string
): Promise<void> {
    const pluginEvent: PluginEvent = {
        distinct_id: distinctId,
        site_url: _siteUrl,
        team_id: teamId,
        timestamp: timestamp.toUTC().toISO(),
        now: timestamp.toUTC().toISO(),
        ip: ip,
        uuid: eventUuid,
        ...data,
    } as any as PluginEvent

    const runner = new EventPipelineRunner(hub, pluginEvent)
    await runner.runEventPipeline(pluginEvent)

    await delayUntilEventIngested(() => hub.db.fetchEvents(), ++processEventCounter)
}

// Simple client used to simulate sending events
// Use state object to simulate stateful clients that keep track of old