vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: gsheet integration analytics

Browse Source
This commit is contained in:
karishmas6
2024-10-28 04:12:21 +05:30
parent 8bf86af7de
commit e076734e55
1 changed files with 44 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
server/src/routes/auth.ts
View File

@@ -33,7 +33,7 @@ router.post('/register', async (req, res) => {
httpOnly: true httpOnly: true
}) })
captureServerAnalytics.capture({ captureServerAnalytics.capture({
distinctId: user.id, distinctId: user.id.toString(),
event: 'maxun-oss-user-registered', event: 'maxun-oss-user-registered',
properties: { properties: {
email: user.email, email: user.email,
@@ -123,6 +123,15 @@ router.post('/generate-api-key', requireSignIn, async (req: AuthenticatedRequest
await user.update({ api_key: apiKey }); await user.update({ api_key: apiKey });
captureServerAnalytics.capture({
distinctId: user.id.toString(),
event: 'maxun-oss-api-key-created',
properties: {
user_id: user.id,
created_at: new Date().toISOString()
}
})
return res.status(200).json({ return res.status(200).json({
message: 'API key generated successfully', message: 'API key generated successfully',
api_key: apiKey, api_key: apiKey,
@@ -175,6 +184,15 @@ router.delete('/delete-api-key', requireSignIn, async (req: AuthenticatedRequest
await User.update({ api_key: null }, { where: { id: req.user.id } }); await User.update({ api_key: null }, { where: { id: req.user.id } });
captureServerAnalytics.capture({
distinctId: user.id.toString(),
event: 'maxun-oss-api-key-deleted',
properties: {
user_id: user.id,
deleted_at: new Date().toISOString()
}
})
return res.status(200).json({ message: 'API Key deleted successfully' }); return res.status(200).json({ message: 'API Key deleted successfully' });
} catch (error: any) { } catch (error: any) {
return res.status(500).json({ message: 'Error deleting API key', error: error.message }); return res.status(500).json({ message: 'Error deleting API key', error: error.message });
@@ -255,6 +273,16 @@ router.get('/google/callback', requireSignIn, async (req: AuthenticatedRequest,
google_refresh_token: tokens.refresh_token, google_refresh_token: tokens.refresh_token,
}); });
captureServerAnalytics.capture({
distinctId: user.id.toString(),
event: 'maxun-oss-google-sheet-integration-created',
properties: {
user_id: user.id,
robot_id: robot.recording_meta.id,
created_at: new Date().toISOString()
}
})
// List user's Google Sheets from their Google Drive // List user's Google Sheets from their Google Drive
const drive = google.drive({ version: 'v3', auth: oauth2Client }); const drive = google.drive({ version: 'v3', auth: oauth2Client });
const response = await drive.files.list({ const response = await drive.files.list({
@@ -377,12 +405,16 @@ router.post('/gsheets/update', requireSignIn, async (req, res) => {
} }
}); });
router.post('/gsheets/remove', requireSignIn, async (req, res) => { router.post('/gsheets/remove', requireSignIn, async (req: AuthenticatedRequest, res) => {
const { robotId } = req.body; const { robotId } = req.body;
if (!robotId) { if (!robotId) {
return res.status(400).json({ message: 'Robot ID is required' }); return res.status(400).json({ message: 'Robot ID is required' });
} }
if (!req.user) {
return res.status(401).send({ error: 'Unauthorized' });
}
try { try {
let robot = await Robot.findOne({ where: { 'recording_meta.id': robotId } }); let robot = await Robot.findOne({ where: { 'recording_meta.id': robotId } });
@@ -398,6 +430,16 @@ router.post('/gsheets/remove', requireSignIn, async (req, res) => {
google_refresh_token: null google_refresh_token: null
}); });
captureServerAnalytics.capture({
distinctId: req.user.id.toString(),
event: 'maxun-oss-google-sheet-integration-removed',
properties: {
user_id: req.user.id,
robot_id: robotId,
deleted_at: new Date().toISOString()
}
})
res.json({ message: 'Google Sheets integration removed successfully' }); res.json({ message: 'Google Sheets integration removed successfully' });
} catch (error: any) { } catch (error: any) {
res.status(500).json({ message: `Error removing Google Sheets integration: ${error.message}` }); res.status(500).json({ message: `Error removing Google Sheets integration: ${error.message}` });