⚡ Add userId to BE PH identify call

packages/cli/src/Interfaces.ts

@@ -380,6 +380,7 @@ export interface IInternalHooksClass {
 	onServerStarted(
 		diagnosticInfo: IDiagnosticInfo,
 		firstWorkflowCreatedAt?: Date,
+		userId?: string,
 	): Promise<unknown[]>;
 	onPersonalizationSurveySubmitted(userId: string, answers: Record<string, string>): Promise<void>;
 	onWorkflowCreated(userId: string, workflow: IWorkflowBase, publicApi: boolean): Promise<void>;

packages/cli/src/InternalHooks.ts

@@ -32,6 +32,7 @@ export class InternalHooksClass implements IInternalHooksClass {
 	async onServerStarted(
 		diagnosticInfo: IDiagnosticInfo,
 		earliestWorkflowCreatedAt?: Date,
+		userId?: string,
 	): Promise<unknown[]> {
 		const info = {
 			version_cli: diagnosticInfo.versionCli,
@@ -45,9 +46,11 @@ export class InternalHooksClass implements IInternalHooksClass {
 			n8n_binary_data_mode: diagnosticInfo.binaryDataMode,
 			n8n_multi_user_allowed: diagnosticInfo.n8n_multi_user_allowed,
 			smtp_set_up: diagnosticInfo.smtp_set_up,
+			user_id: userId,
 		};
 
 		return Promise.all([
+			this.telemetry.identify(info),
 			this.telemetry.track('Instance started', {
 				...info,
 				earliest_workflow_created: earliestWorkflowCreatedAt,

packages/cli/src/Server.ts

@@ -1986,14 +1986,21 @@ export async function start(): Promise<void> {
 			smtp_set_up: config.getEnv('userManagement.emails.mode') === 'smtp',
 		};
 
-		void Db.collections
+		const earliestWorkflow = await Db.collections.Workflow.findOne({
-			.Workflow!.findOne({
+			select: ['createdAt', 'id'],
-				select: ['createdAt'],
+			order: { createdAt: 'ASC' },
-				order: { createdAt: 'ASC' },
+		});
-			})
+
-			.then(async (workflow) =>
+		const sharing = await Db.collections.SharedWorkflow.findOne({
-				InternalHooksManager.getInstance().onServerStarted(diagnosticInfo, workflow?.createdAt),
+			where: { workflow: { id: earliestWorkflow?.id } },
-			);
+			relations: ['workflow'],
+		});
+
+		void InternalHooksManager.getInstance().onServerStarted(
+			diagnosticInfo,
+			earliestWorkflow?.createdAt,
+			sharing?.userId,
+		);
 	});
 
 	server.on('error', (error: Error & { code: string }) => {

packages/cli/src/telemetry/index.ts

@@ -138,6 +138,38 @@ export class Telemetry {
 		});
 	}
 
+	async identify(traits?: {
+		[key: string]: string | number | boolean | object | undefined | null;
+	}): Promise<void> {
+		return new Promise<void>((resolve) => {
+			if (this.postHog && traits?.user_id) {
+				this.postHog.identify({
+					distinctId: [this.instanceId, traits.user_id].join('#'),
+					properties: {
+						...traits,
+						instanceId: this.instanceId,
+					},
+				});
+			}
+
+			if (this.rudderStack) {
+				this.rudderStack.identify(
+					{
+						userId: this.instanceId,
+						anonymousId: '000000000000',
+						traits: {
+							...traits,
+							instanceId: this.instanceId,
+						},
+					},
+					resolve,
+				);
+			} else {
+				resolve();
+			}
+		});
+	}
+
 	async track(
 		eventName: string,
 		properties: ITelemetryTrackProperties = {},