|
1 | 1 | import Mixpanel from 'mixpanel';
|
2 |
| -import { getJobs } from '../storage/jobStorage.js'; |
3 |
| -import { getUniqueId } from './uniqueId.js'; |
4 |
| -import { config, inDevMode } from '../../utils.js'; |
| 2 | +import {getJobs} from '../storage/jobStorage.js'; |
| 3 | +import {getUniqueId} from './uniqueId.js'; |
| 4 | +import {config, inDevMode} from '../../utils.js'; |
5 | 5 | import os from 'os';
|
| 6 | +import {readFileSync} from 'fs'; |
| 7 | +import {packageUp} from 'package-up'; |
6 | 8 |
|
7 | 9 | const mixpanelTracker = Mixpanel.init('718670ef1c58c0208256c1e408a3d75e');
|
8 |
| - |
9 | 10 | const distinct_id = getUniqueId() || 'N/A';
|
| 11 | +const version = await getPackageVersion(); |
10 | 12 |
|
11 | 13 | export const track = function () {
|
12 |
| - //only send tracking information if the user allowed to do so. |
13 |
| - if (config.analyticsEnabled && !inDevMode()) { |
14 |
| - const activeProvider = new Set(); |
15 |
| - const activeAdapter = new Set(); |
| 14 | + //only send tracking information if the user allowed to do so. |
| 15 | + if (config.analyticsEnabled && !inDevMode()) { |
| 16 | + const activeProvider = new Set(); |
| 17 | + const activeAdapter = new Set(); |
16 | 18 |
|
17 |
| - const jobs = getJobs(); |
| 19 | + const jobs = getJobs(); |
18 | 20 |
|
19 |
| - if (jobs != null && jobs.length > 0) { |
20 |
| - jobs.forEach((job) => { |
21 |
| - job.provider.forEach((provider) => { |
22 |
| - activeProvider.add(provider.id); |
23 |
| - }); |
24 |
| - job.notificationAdapter.forEach((adapter) => { |
25 |
| - activeAdapter.add(adapter.id); |
26 |
| - }); |
27 |
| - }); |
| 21 | + if (jobs != null && jobs.length > 0) { |
| 22 | + jobs.forEach((job) => { |
| 23 | + job.provider.forEach((provider) => { |
| 24 | + activeProvider.add(provider.id); |
| 25 | + }); |
| 26 | + job.notificationAdapter.forEach((adapter) => { |
| 27 | + activeAdapter.add(adapter.id); |
| 28 | + }); |
| 29 | + }); |
28 | 30 |
|
29 |
| - mixpanelTracker.track( |
30 |
| - 'fredy_tracking', |
31 |
| - enrichTrackingObject({ |
32 |
| - adapter: Array.from(activeAdapter), |
33 |
| - provider: Array.from(activeProvider), |
34 |
| - }), |
35 |
| - ); |
| 31 | + mixpanelTracker.track( |
| 32 | + 'fredy_tracking', |
| 33 | + enrichTrackingObject({ |
| 34 | + adapter: Array.from(activeAdapter), |
| 35 | + provider: Array.from(activeProvider), |
| 36 | + }), |
| 37 | + ); |
| 38 | + } |
36 | 39 | }
|
37 |
| - } |
38 | 40 | };
|
39 | 41 |
|
40 | 42 | /**
|
41 | 43 | * Note, this will only be used when Fredy runs in demo mode
|
42 | 44 | */
|
43 | 45 | export function trackDemoJobCreated(jobData) {
|
44 |
| - if (config.analyticsEnabled && !inDevMode() && config.demoMode) { |
45 |
| - mixpanelTracker.track('demoJobCreated', enrichTrackingObject(jobData)); |
46 |
| - } |
| 46 | + if (config.analyticsEnabled && !inDevMode() && config.demoMode) { |
| 47 | + mixpanelTracker.track('demoJobCreated', enrichTrackingObject(jobData)); |
| 48 | + } |
47 | 49 | }
|
48 | 50 |
|
49 | 51 | /**
|
50 | 52 | * Note, this will only be used when Fredy runs in demo mode
|
51 | 53 | */
|
52 | 54 | export function trackDemoAccessed() {
|
53 |
| - if (config.analyticsEnabled && !inDevMode() && config.demoMode) { |
54 |
| - mixpanelTracker.track('demoAccessed', enrichTrackingObject({})); |
55 |
| - } |
| 55 | + if (config.analyticsEnabled && !inDevMode() && config.demoMode) { |
| 56 | + mixpanelTracker.track('demoAccessed', enrichTrackingObject({})); |
| 57 | + } |
56 | 58 | }
|
57 | 59 |
|
58 | 60 | function enrichTrackingObject(trackingObject) {
|
59 |
| - const operating_system = os.platform(); |
60 |
| - const os_version = os.release(); |
61 |
| - const arch = process.arch; |
62 |
| - const language = process.env.LANG || 'en'; |
63 |
| - const nodeVersion = process.version || 'N/A'; |
| 61 | + const operating_system = os.platform(); |
| 62 | + const os_version = os.release(); |
| 63 | + const arch = process.arch; |
| 64 | + const language = process.env.LANG || 'en'; |
| 65 | + const nodeVersion = process.version || 'N/A'; |
64 | 66 |
|
65 |
| - return { |
66 |
| - ...trackingObject, |
67 |
| - isDemo: config.demoMode, |
68 |
| - operating_system, |
69 |
| - os_version, |
70 |
| - arch, |
71 |
| - nodeVersion, |
72 |
| - language, |
73 |
| - distinct_id, |
74 |
| - }; |
| 67 | + return { |
| 68 | + ...trackingObject, |
| 69 | + isDemo: config.demoMode, |
| 70 | + operating_system, |
| 71 | + os_version, |
| 72 | + arch, |
| 73 | + nodeVersion, |
| 74 | + language, |
| 75 | + distinct_id, |
| 76 | + fredy_version: version |
| 77 | + }; |
| 78 | +} |
| 79 | + |
| 80 | +async function getPackageVersion() { |
| 81 | + try { |
| 82 | + const packagePath = await packageUp(); |
| 83 | + const packageJson = readFileSync(packagePath, 'utf8'); |
| 84 | + const json = JSON.parse(packageJson); |
| 85 | + return json.version; |
| 86 | + } catch (error) { |
| 87 | + console.error('Error reading version from package.json', error); |
| 88 | + } |
| 89 | + return 'N/A'; |
75 | 90 | }
|
0 commit comments