mirror of
https://github.com/Mintplex-Labs/anything-llm.git
synced 2024-09-11 23:03:25 +02:00
a126b5f5aa
* WIP converted all sqlite models into prisma calls * modify db setup and fix ApiKey model calls in admin.js * renaming function params to be consistent * converted adminEndpoints to utilize prisma orm * converted chatEndpoints to utilize prisma orm * converted inviteEndpoints to utilize prisma orm * converted systemEndpoints to utilize prisma orm * converted workspaceEndpoints to utilize prisma orm * converting sql queries to prisma calls * fixed default param bug for orderBy and limit * fixed typo for workspace chats * fixed order of deletion to account for sql relations * fix invite CRUD and workspace management CRUD * fixed CRUD for api keys * created prisma setup scripts/docs for understanding how to use prisma * prisma dependency change * removing unneeded console.logs * removing unneeded sql escape function * linting and creating migration script * migration from depreciated sqlite script update * removing unneeded migrations in prisma folder * create backup of old sqlite db and use transactions to ensure all operations complete successfully * adding migrations to gitignore * updated PRISMA.md docs for info on how to use sqlite migration script * comment changes * adding back migrations folder to repo * Reviewing SQL and prisma integraiton on fresh repo * update inline key replacement * ensure migration script executes and maps foreign_keys regardless of db ordering * run migration endpoint * support new prisma backend * bump version * change migration call --------- Co-authored-by: timothycarambat <rambat1010@gmail.com>
71 lines
1.8 KiB
JavaScript
71 lines
1.8 KiB
JavaScript
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_9qu7QLpV8L84P3vFmEiZxL020t2EqIubP7HHHxrSsqS",
|
|
stubDevelopmentEvents: true, // [DO NOT TOUCH] Core team only.
|
|
label: "telemetry_id",
|
|
|
|
id: async function () {
|
|
const result = await SystemSettings.get({ label: this.label });
|
|
return result?.value || null;
|
|
},
|
|
|
|
connect: async function () {
|
|
const client = this.client();
|
|
const distinctId = await this.findOrCreateId();
|
|
return { client, distinctId };
|
|
},
|
|
|
|
isDev: function () {
|
|
return process.env.NODE_ENV === "development" && this.stubDevelopmentEvents;
|
|
},
|
|
|
|
client: function () {
|
|
if (process.env.DISABLE_TELEMETRY === "true" || this.isDev()) return null;
|
|
const { PostHog } = require("posthog-node");
|
|
return new PostHog(this.pubkey);
|
|
},
|
|
|
|
sendTelemetry: async function (event, properties = {}) {
|
|
try {
|
|
const { client, distinctId } = await this.connect();
|
|
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();
|
|
},
|
|
|
|
setUid: async function () {
|
|
const newId = v4();
|
|
await SystemSettings.updateSettings({ [this.label]: newId });
|
|
return newId;
|
|
},
|
|
|
|
findOrCreateId: async function () {
|
|
let currentId = await this.id();
|
|
if (currentId) return currentId;
|
|
|
|
currentId = await this.setUid();
|
|
return currentId;
|
|
},
|
|
};
|
|
|
|
module.exports = { Telemetry };
|