| import { strict as assert } from "node:assert"; |
| import { test } from "node:test"; |
|
|
| process.env.DATABASE_URL ??= "postgres://postgres:postgres@localhost:5434/superlog"; |
|
|
| const { |
| DEFAULT_LOOPS_WELCOME_EVENT, |
| buildLoopsContactPayload, |
| buildLoopsWelcomeEventPayload, |
| sendLoopsWelcomeFlow, |
| } = await import("@superlog/db"); |
|
|
| const input = { |
| user: { id: "user_123", email: "founder@acme.test" }, |
| org: { id: "org_123", name: "Acme Observability", slug: "acme-observability" }, |
| project: { id: "project_123", name: "Default", slug: "default" }, |
| signupSource: "skill", |
| clerkOrgId: "org_clerk_123", |
| appUrl: "https://superlog.sh", |
| }; |
|
|
| test("buildLoopsWelcomeEventPayload includes welcome context for Loops", () => { |
| const payload = buildLoopsWelcomeEventPayload(input); |
|
|
| assert.equal(payload.email, "founder@acme.test"); |
| assert.equal(payload.userId, "user_123"); |
| assert.equal(payload.eventName, DEFAULT_LOOPS_WELCOME_EVENT); |
| assert.equal(payload.source, "Superlog signup"); |
| assert.deepEqual(payload.eventProperties, { |
| userId: "user_123", |
| orgId: "org_123", |
| orgName: "Acme Observability", |
| orgSlug: "acme-observability", |
| projectId: "project_123", |
| projectName: "Default", |
| projectSlug: "default", |
| signupSource: "skill", |
| clerkOrgId: "org_clerk_123", |
| appUrl: "https://superlog.sh", |
| }); |
| }); |
|
|
| test("buildLoopsContactPayload mirrors lifecycle flags onto the contact", () => { |
| const payload = buildLoopsContactPayload(input, { |
| telemetrySet: true, |
| telemetrySetAt: "2026-05-11T20:00:00.000Z", |
| githubAdded: true, |
| githubAddedAt: "2026-05-11T20:01:00.000Z", |
| slackAdded: false, |
| slackAddedAt: null, |
| mcpInstalled: true, |
| mcpInstalledAt: "2026-05-11T20:02:00.000Z", |
| }); |
|
|
| assert.equal(payload.email, "founder@acme.test"); |
| assert.equal(payload.userId, "user_123"); |
| assert.equal(payload.orgName, "Acme Observability"); |
| assert.equal(payload.telemetrySet, true); |
| assert.equal(payload.githubAdded, true); |
| assert.equal(payload.slackAdded, false); |
| assert.equal(payload.mcpInstalledAt, "2026-05-11T20:02:00.000Z"); |
| }); |
|
|
| test("sendLoopsWelcomeFlow skips cleanly without an API key", async () => { |
| const result = await sendLoopsWelcomeFlow(input, { |
| apiKey: "", |
| fetch: async () => { |
| throw new Error("fetch should not be called"); |
| }, |
| }); |
|
|
| assert.deepEqual(result, { sent: false, reason: "not_configured" }); |
| }); |
|
|
| test("sendLoopsWelcomeFlow sends the welcome event to Loops", async () => { |
| let capturedUrl = ""; |
| let capturedInit: RequestInit | undefined; |
|
|
| const result = await sendLoopsWelcomeFlow(input, { |
| apiKey: "loops_secret", |
| apiBase: "https://loops.test/api/v1/", |
| eventName: "welcomeSignup", |
| fetch: async (url, init) => { |
| capturedUrl = String(url); |
| capturedInit = init; |
| return new Response(JSON.stringify({ success: true }), { status: 200 }); |
| }, |
| }); |
|
|
| assert.deepEqual(result, { sent: true }); |
| assert.equal(capturedUrl, "https://loops.test/api/v1/events/send"); |
| assert.equal(capturedInit?.method, "POST"); |
| assert.equal( |
| (capturedInit?.headers as Record<string, string>).authorization, |
| "Bearer loops_secret", |
| ); |
|
|
| const body = JSON.parse(String(capturedInit?.body)); |
| assert.equal(body.eventName, "welcomeSignup"); |
| assert.equal(body.email, "founder@acme.test"); |
| assert.equal(body.eventProperties.signupSource, "skill"); |
| }); |
|
|
| test("sendLoopsWelcomeFlow surfaces Loops API errors", async () => { |
| await assert.rejects( |
| () => |
| sendLoopsWelcomeFlow(input, { |
| apiKey: "loops_secret", |
| fetch: async () => new Response("bad key", { status: 401 }), |
| }), |
| /Loops request failed: 401 bad key/, |
| ); |
| }); |
|
|
