Display referral and group moves changelog

Author: steven-tey

apps/web/app/(ee)/api/stripe/integration/webhook/checkout-session-completed.ts

@@ -479,6 +479,7 @@ export async function checkoutSessionCompleted(
           trigger: "partnerMetricsUpdated",
           reason: "sale",
           identity: {
+            workspaceId: workspace.id,
             programId: link.programId,
             partnerId: link.partnerId,
           },
@@ -664,6 +665,7 @@ async function attributeViaPromoCode({
             trigger: "partnerMetricsUpdated",
             reason: "lead",
             identity: {
+              workspaceId: workspace.id,
               programId: link.programId,
               partnerId: link.partnerId,
             },

apps/web/app/(ee)/api/stripe/integration/webhook/invoice-paid.ts

@@ -248,6 +248,7 @@ export async function invoicePaid(event: Stripe.Event, mode: StripeMode) {
           trigger: "partnerMetricsUpdated",
           reason: "sale",
           identity: {
+            workspaceId: workspace.id,
             programId: link.programId,
             partnerId: link.partnerId,
           },

apps/web/app/(ee)/api/stripe/integration/webhook/utils/create-new-customer.ts

@@ -109,6 +109,7 @@ export async function createNewCustomer(event: Stripe.Event) {
           trigger: "partnerMetricsUpdated",
           reason: "lead",
           identity: {
+            workspaceId: workspace.id,
             programId: link.programId,
             partnerId: link.partnerId,
           },

apps/web/app/(ee)/api/workflows/partner-approved/route.ts

@@ -390,6 +390,7 @@ export const { POST } = serve<Payload>(
       await executeWorkflows({
         trigger: "partnerEnrolled",
         identity: {
+          workspaceId: program.workspaceId,
           programId,
           partnerId,
         },

apps/web/app/api/activity-logs/route.ts

@@ -1,3 +1,4 @@
+import { getDefaultProgramIdOrThrow } from "@/lib/api/programs/get-default-program-id-or-throw";
 import { withWorkspace } from "@/lib/auth";
 import {
   activityLogSchema,
@@ -7,16 +8,19 @@ import { prisma } from "@dub/prisma";
 import { NextResponse } from "next/server";
 import * as z from "zod/v4";
 
-// GET /api/activity-logs - get activity logs for a resource
+// GET /api/activity-logs – get activity logs for a resource
 export const GET = withWorkspace(async ({ workspace, searchParams }) => {
-  const { resourceType, resourceId } =
+  const { resourceType, resourceId, action } =
     getActivityLogsQuerySchema.parse(searchParams);
 
+  const programId = getDefaultProgramIdOrThrow(workspace);
   const activityLogs = await prisma.activityLog.findMany({
     where: {
       workspaceId: workspace.id,
+      programId,
       resourceType,
       resourceId,
+      ...(action && { action }),
     },
     orderBy: {
       createdAt: "desc",

apps/web/lib/actions/partners/create-manual-commission.ts

@@ -575,6 +575,7 @@ export const createManualCommissionAction = authActionClient
               trigger: "partnerMetricsUpdated",
               reason: "commission",
               identity: {
+                workspaceId: workspace.id,
                 programId,
                 partnerId,
               },

apps/web/lib/actions/referrals/update-referral-status.ts

@@ -7,7 +7,10 @@ import { getReferralOrThrow } from "@/lib/api/referrals/get-referral-or-throw";
 import { markReferralClosedWon } from "@/lib/api/referrals/mark-referral-closed-won";
 import { markReferralQualified } from "@/lib/api/referrals/mark-referral-qualified";
 import { notifyReferralStatusUpdate } from "@/lib/api/referrals/notify-referral-status-update";
-import { REFERRAL_STATUS_TRANSITIONS } from "@/lib/referrals/constants";
+import {
+  REFERRAL_STATUS_TO_ACTIVITY_ACTION,
+  REFERRAL_STATUS_TRANSITIONS,
+} from "@/lib/referrals/constants";
 import { ReferralWithCustomer } from "@/lib/types";
 import { updateReferralStatusSchema } from "@/lib/zod/schemas/referrals";
 import { prisma } from "@dub/prisma";
@@ -16,16 +19,6 @@ import { waitUntil } from "@vercel/functions";
 import { authActionClient } from "../safe-action";
 import { throwIfNoPermission } from "../throw-if-no-permission";
 
-const REFERRAL_EVENT_TYPES = {
-  [ReferralStatus.pending]: "referral.created",
-  [ReferralStatus.qualified]: "referral.qualified",
-  [ReferralStatus.meeting]: "referral.meeting",
-  [ReferralStatus.negotiation]: "referral.negotiation",
-  [ReferralStatus.unqualified]: "referral.unqualified",
-  [ReferralStatus.closedWon]: "referral.closedWon",
-  [ReferralStatus.closedLost]: "referral.closedLost",
-} as const;
-
 export const updateReferralStatusAction = authActionClient
   .inputSchema(updateReferralStatusSchema)
   .action(async ({ parsedInput, ctx }) => {
@@ -92,7 +85,7 @@ export const updateReferralStatusAction = authActionClient
             resourceType: "referral",
             resourceId: referral.id,
             userId: user.id,
-            action: REFERRAL_EVENT_TYPES[status],
+            action: REFERRAL_STATUS_TO_ACTIVITY_ACTION[status],
             description: notes,
             changeSet: {
               status: {

apps/web/lib/api/activity-log/build-change-set.ts

@@ -1,12 +1,6 @@
+import type { ChangeSet } from "@/lib/types";
 import { PartnerGroup } from "@dub/prisma/client";
 
-export type FieldDiff<T = unknown> = {
-  old: T | null;
-  new: T | null;
-};
-
-export type ChangeSet = Record<string, FieldDiff>;
-
 interface BuildProgramEnrollmentChangeSetInput {
   oldEnrollment:
     | { partnerGroup: Pick<PartnerGroup, "id" | "name"> | null | undefined }

apps/web/lib/api/activity-log/track-activity-log.ts

@@ -1,20 +1,21 @@
 import { logger } from "@/lib/axiom/server";
+import type { ChangeSet } from "@/lib/types";
 import {
   ActivityLogAction,
   ActivityLogResourceType,
 } from "@/lib/zod/schemas/activity-log";
 import { prisma } from "@dub/prisma";
 import { Prisma } from "@dub/prisma/client";
 import { prettyPrint } from "@dub/utils";
-import { ChangeSet } from "./build-change-set";
 
 export interface TrackActivityLogInput
   extends Pick<
     Prisma.ActivityLogUncheckedCreateInput,
-    "workspaceId" | "programId" | "resourceId" | "userId" | "description"
+    "workspaceId" | "programId" | "resourceId" | "description"
   > {
   resourceType: ActivityLogResourceType;
   action: ActivityLogAction;
+  userId?: string | null;
   changeSet?: ChangeSet;
 }
 
@@ -24,7 +25,9 @@ export const trackActivityLog = async (
   let inputs = Array.isArray(input) ? input : [input];
 
   inputs = inputs.filter(
-    (i) => i.changeSet && Object.keys(i.changeSet).length > 0,
+    (i) =>
+      i.action === "referral.created" ||
+      (i.changeSet && Object.keys(i.changeSet).length > 0),
   );
 
   if (inputs.length === 0) {

apps/web/lib/api/conversions/track-lead.ts

@@ -327,6 +327,7 @@ export const trackLead = async ({
                 trigger: "partnerMetricsUpdated",
                 reason: "lead",
                 identity: {
+                  workspaceId: workspace.id,
                   programId: link.programId,
                   partnerId: link.partnerId,
                 },