Customer Support Integrations | blade47/dub Wiki | doc0

Public

Customer Support Integrations | blade47/dub Wiki | doc0

export const syncUserPlanToPlain = async (user: PlainUser) => {
  if (!user.email) {
    console.log(`User ${user.id} has no email, skipping sync...`);
    return;
  }
 
  const { data } = await upsertPlainCustomer({
    id: user.id,
    name: user.name,
    email: user.email,
  });
 
  if (!data) {
    console.log(
      `Failed to upsert plain customer for user ${user.id}, skipping sync...`,
    );
    return;
  }
  const plainCustomer = data.customer;
 
  let companyDomainName: string | undefined;
  if (!isGenericEmail(user.email)) {
    companyDomainName = user.email.split("@")[1];
  }
...

  const partnerProfile = await prisma.partner.findFirst({
    where: {
      users: {
        some: {
          userId: customer.externalId,
        },
      },
    },
    include: {
      programs: {
        select: {
          program: {
            select: {
              name: true,
            },
          },
          createdAt: true,
          totalCommissions: true,
        },
        where: {
          totalCommissions: {
            gt: 0,
          },
        },
        orderBy: {
          totalCommissions: "desc",
        },
        take: 5,
      },
    },
  });

Account Type / Tier	Condition	Priority Level	Metadata Fields Assigned
Workspace (Enterprise / Advanced)	`workspace.plan` is `"enterprise"` or `"advanced"`	`0`	Workspace Name, Slug, Plan
Workspace (Business)	`workspace.plan` is `"business"`	`1`	Workspace Name, Slug, Plan
Workspace (Pro)	`workspace.plan` is `"pro"`	`2`	Workspace Name, Slug, Plan
Workspace (Default)	Other plans or unlinked workspace	`3`	None
Partner (Top Tier)	`partnerLifetimePayouts > 10_000_00`	`0`	Program Name, Slug, Support Email, Holding Period, Min Payout, Lifetime Payouts
Partner (Mid Tier)	`partnerLifetimePayouts > 1_000_00`	`1`	Program Name, Slug, Support Email, Holding Period, Min Payout, Lifetime Payouts
Partner (Standard Tier)	`partnerLifetimePayouts > 100_00`	`2`	Program Name, Slug, Support Email, Holding Period, Min Payout, Lifetime Payouts
Partner (Default)	Lifetime payouts $\le$ 100.00 or unlinked	`3`	None

const SLACK_TOOL_LABELS: Record<string, string> = {
  requestSupportTicket: "Showed support ticket form",
  createSupportTicket: "Created support ticket",
  findRelevantDocs: "Searched documentation",
  getWorkspaceDetails: "Looked up workspace details",
  getProgramPerformance: "Looked up program performance",
  getPlanComparison: "Compared plans",
};

Credential Field	Transformation / Source	Purpose
`accessToken`	`encrypt(token.access_token)`	Securely encrypts the OAuth access token before database storage
`appId`	`admin.app?.id_code`	Stores the validated Intercom workspace identifier

Endpoint Route	Verification Method	Action / Purpose
`POST /api/intercom/webhook`	`verifyIntercomWebhookSignature(req)`	Ingests raw webhooks, checks topics, and enqueues batch jobs via QStash.
`POST /api/intercom/webhook/process`	`verifyQstashSignature(...)`	Verifies QStash signature, looks up project installations, checks program status, and dispatches `conversation.admin.replied` handlers.
`POST /api/intercom/webhook/health-check`	`verifyIntercomWebhookSignature(req)`	Validates installation existence and credential schema validity, returning `OK` or `UNHEALTHY` states.
`POST /api/intercom/webhook/uninstall`	`verifyIntercomWebhookSignature(req)`	Parses uninstallation webhooks and deletes the matching `InstalledIntegration` record from Prisma.

if (result?.partnersFound) {
  await captureWebhookLog({
    workspaceId,
    method: "POST",
    path: "/intercom/webhook",
    statusCode: 200,
    duration: Date.now() - startTime,
    requestBody: body,
    responseBody: result.message,
    userAgent: req.headers.get("user-agent"),
  });
}

Condition	Attachment Processing Action	Delivery Method
All attachments are images (`allImages === true`)	Retrieves signed download URLs expiring in 30 minutes (`expiresIn: 30 * 60`).	Pushed to `attachmentUrls` for Intercom to fetch directly.
Mixed attachments or non-images	Fetches signed URL content, converts to buffer, and encodes to base64.	Pushed to `attachmentFiles` containing `content_type`, `data`, and `name`.

export function sharedSupportChannelName({
  workspaceSlug,
}: {
  workspaceSlug: string;
}): string {
  const base = workspaceSlug
    .toLowerCase()
    .replace(/[^a-z0-9-]/g, "-")
    .replace(/-+/g, "-")
    .replace(/^-|-$/g, "");
  const safeBase = base.length > 0 ? base : "workspace";
  const prefixed = `shared-${safeBase}`;
  return prefixed.length <= 80 ? prefixed : prefixed.slice(0, 80);
}

Parameter / Constant	Value / Behavior	Purpose
`INTERNAL_SUPPORT_USERGROUP_ID`	`"S0AJUBR8Y1Y"`	Slack user group identifier for internal support team members.
Max user invite slice	`100`	Slices the usergroup list to a maximum of 100 members per invite call.
Max channel name length	`80` characters	Truncates prefixed channel names that exceed 80 characters.
Default fallback base	`"workspace"`	Used when a workspace slug results in an empty base after sanitization.

const slackSupportInviteBodySchema = z.object({
  emails: z.array(z.email()).min(1).max(SLACK_SUPPORT_INVITE_MAX_EMAILS),
});
 
function dedupeEmails(emails: string[]): string[] {
  const seen = new Set<string>();
  return emails.filter((e) => {
    if (seen.has(e)) return false;
    seen.add(e);
    return true;
  });
}

Rate Limit Policy Key	Identifier Scope	Target
`RATELIMIT_POLICIES.slackSupportInviteWorkspace`	Workspace ID (`workspace.id`)	Prevents excessive invites generated per workspace.
`RATELIMIT_POLICIES.slackSupportInviteUser`	Combined Workspace and User ID (`[workspace.id, session.user.id]`)	Limits requests per user within a given workspace.

  const permissionsError = clientAccessCheck({
    action: "workspaces.write",
    role,
  }).error;
 
  if (
    loading ||
    !slug ||
    dismissed ||
    permissionsError ||
    !getPlanCapabilities(plan).canRequestSlackSupportInvite ||
    isWorkspaceBillingTrialActive(trialEndsAt)
  ) {
    return null;
  }

export function SlackSupportInvite() {
  const [needsChannelId, setNeedsChannelId] = useState(false);
 
  return (
    <div className="flex flex-col space-y-5">
      <form
        action={async (data) => {
          try {
            const res = await fetch("/api/admin/slack-support-invite", {
              method: "POST",
              body: JSON.stringify({
                email: data.get("email"),
                workspaceSlug: data.get("workspaceSlug"),
                channelId: data.get("channelId") || undefined,
              }),
            });
 
            const json = await res.json().catch(() => ({}));
 
            if (!res.ok) {
              if (json.nameTaken) {
                setNeedsChannelId(true);
              }
              toast.error(
                json.error ?? "Something went wrong. Please try again.",
              );
              return;
            }
 
            setNeedsChannelId(false);
            toast.success(`Slack invite sent (ID: ${json.inviteId})`);
          } catch {
            toast.error(
              "Network error. Please check your connection and try again.",
            );
          }
        }}
      >
        <Form needsChannelId={needsChannelId} />
      </form>
    </div>
  );
}

Input Field Name	Element Type	Validation / Pattern	Purpose
`email`	`email`	`required`, `autoComplete="off"`	Recipient email address for the support invite.
`workspaceSlug`	`text`	`required`, `autoComplete="off"`	Target workspace slug prefix (`app.dub.co` domain context).
`channelId`	`text`	`pattern="^[CG][A-Z0-9]{8,}$"`	Optional explicit Slack channel ID requested when `nameTaken` returns true.