📦 EqualifyEverything / equalify-v2-api

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26import { cm, db, event, getAnalytics, isStaging } from '#src/utils';

export const trackUser = async () => {
    await db.connect();
    const { sub, email, name } = event.claims;
    const analytics = getAnalytics();
    await db.query({
        text: `UPDATE "users" SET "analytics"=$1 WHERE "id"=$2`,
        values: [JSON.stringify(analytics), sub],
    });

    if (!event.claims.email.includes('+')) {
        await fetch(process.env.SLACK_WEBHOOK, {
            method: 'POST',
            body: JSON.stringify({
                text: `${isStaging ? '[STAGING] ' : ''}*${event.claims.email}* just signed up from *${analytics?.city}, ${analytics?.state}* on *${analytics?.device}*`
            })
        })
    }

    await cm.addSubscriber({ email, name });
    await cm.removeSubscriber({ email, listId: process.env.CM_LEADS });

    await db.clean();
    return;
}