vector-admin/backend/models/telemetry.js

const { v4 } = require("uuid");
const { SystemSettings } = require("./systemSettings");

const Telemetry = {
  // Write-only key. It can't read events or any of your other data, so it's safe to use in public apps.
  pubkey: "phc_6ZCKNjcWaIJoLWXfdkrFgvAcy4J14iOqa6RBeXGJOCs",
  stubDevelopmentEvents: true, // [DO NOT TOUCH] Core team only.
  label: "telemetry_id",
  id: async function () {
    const result = await SystemSettings.get({ label: this.label });
    if (!!result?.value) return result.value;
    return result?.value;
  },
  connect: async function (force = false) {
    const client = this.client(force);
    const distinctId = await this.findOrCreateId();
    return { client, distinctId };
  },
  isDev: function () {
    if (process.env.NODE_ENV === "development")
      return this.stubDevelopmentEvents;
    return false;
  },
  client: function (force = false) {
    if (process.env.DISABLE_TELEMETRY === "true") return null;
    if (!force && this.isDev()) return null;

    const { PostHog } = require("posthog-node");
    return new PostHog(this.pubkey);
  },
  sendTelemetry: async function (event, properties = {}, force = false) {
    try {
      if (!force && this.isDev() && process.env.DISABLE_TELEMETRY !== "true") {
        console.log(`\x1b[33m[DEVELOPER MODE: TELEMETRY STUBBED]\x1b[0m`, {
          event,
          properties,
        });
      }

      const { client, distinctId } = await this.connect(force);
      if (!client) return;
      console.log(`\x1b[32m[TELEMETRY SENT]\x1b[0m`, {
        event,
        properties,
      });
      client.capture({
        event,
        distinctId,
        properties,
      });
    } catch {
      return;
    }
  },
  flush: async function () {
    const { client } = this.client();
    if (!client) return;
    await client.shutdownAsync();
    return;
  },
  setUid: async function () {
    const newId = v4();
    await SystemSettings.updateSettings({ [this.label]: newId });
    return newId;
  },
  findOrCreateId: async function () {
    const currentId = await this.id();
    if (!!currentId) return currentId;
    const newId = await this.setUid();
    return newId;
  },
};

module.exports = { Telemetry };