BizPipeline — La couche RevOps des petites équipes B2B

1// Logique partagée — appelée par la fonction Inngest ET par le repli synchrone
2async function processLead(input: LeadInput, workspaceId: string): Promise<Deal> {
3  const scored = scoreLead(input) // même logique, quel que soit le chemin d'exécution
4  const route = routeToOwner(scored, await getWorkspaceMembers(workspaceId))
5
6  return db.deals.create({
7    workspaceId, // scope RLS — jamais de fuite cross-tenant
8    leadId: input.id,
9    score: scored.value,
10    ownerId: route.ownerId,
11    stage: 'new',
12  })
13}

1// Queue durable — repli synchrone si Inngest n'est pas configuré (jamais bloquant)
2export const processLeadEvent = inngest.createFunction(
3  { id: 'process-lead', retries: 3 },
4  { event: 'lead/created' },
5  async ({ event }) => processLead(event.data.lead, event.data.workspaceId)
6)
7
8async function submitLead(input: LeadInput, workspaceId: string): Promise<Deal> {
9  const sent = await inngest.send({ name: 'lead/created', data: { lead: input, workspaceId } })
10  if (sent) return { status: 'queued' } as Deal
11
12  // INNGEST_EVENT_KEY absent → même logique exécutée en ligne, pas d'échec visible
13  return processLead(input, workspaceId)
14}