posthog attribution adjustment

This commit is contained in:
Vladyslav Matsiiako
2023-05-27 19:12:32 -07:00
parent c730280eff
commit a6f6711c9a
3 changed files with 27 additions and 10 deletions
@@ -144,7 +144,8 @@ export const batchSecrets = async (req: Request, res: Response) => {
workspaceId, workspaceId,
channel, channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: req.user.email
} }
}); });
} }
@@ -232,7 +233,8 @@ export const batchSecrets = async (req: Request, res: Response) => {
workspaceId, workspaceId,
channel, channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: req.user.email
} }
}); });
} }
@@ -268,7 +270,8 @@ export const batchSecrets = async (req: Request, res: Response) => {
workspaceId, workspaceId,
channel: channel, channel: channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: req.user.email
} }
}); });
} }
@@ -545,7 +548,10 @@ export const createSecrets = async (req: Request, res: Response) => {
workspaceId, workspaceId,
channel: channel, channel: channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: await TelemetryService.getDistinctId({
authData: req.authData
})
} }
}); });
} }
@@ -748,7 +754,10 @@ export const getSecrets = async (req: Request, res: Response) => {
workspaceId, workspaceId,
channel, channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: await TelemetryService.getDistinctId({
authData: req.authData
})
} }
}); });
} }
@@ -978,7 +987,10 @@ export const updateSecrets = async (req: Request, res: Response) => {
workspaceId: key, workspaceId: key,
channel: channel, channel: channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: await TelemetryService.getDistinctId({
authData: req.authData
})
} }
}); });
} }
@@ -1119,7 +1131,10 @@ export const deleteSecrets = async (req: Request, res: Response) => {
workspaceId: key, workspaceId: key,
channel: channel, channel: channel,
userAgent: req.headers?.['user-agent'], userAgent: req.headers?.['user-agent'],
isPaid isPaid,
email: await TelemetryService.getDistinctId({
authData: req.authData
})
} }
}); });
} }
@@ -120,7 +120,7 @@ const attemptLogin = async (
} }
if (email) { if (email) {
telemetry.identify(email); telemetry.identify(email, email);
telemetry.capture('User Logged In'); telemetry.capture('User Logged In');
} }
@@ -22,10 +22,12 @@ class Capturer {
} }
} }
identify(id: string) { identify(id: string, email?: string) {
if (ENV === 'production' && TELEMETRY_CAPTURING_ENABLED) { if (ENV === 'production' && TELEMETRY_CAPTURING_ENABLED) {
try { try {
this.api.identify(id); this.api.identify(id, {
email: email
});
} catch (error) { } catch (error) {
console.error('PostHog', error); console.error('PostHog', error);
} }