Event-Driven Transaction & Lifecycle Orchestration

// inngest/functions/realtyOrchestrator.ts
import { inngest } from "../client";
import { resolveFubContact, instantiateSkySlopeFile, dispatchTwilioA2P } from "../services";

export const realtyLifecycleOrchestrator = inngest.createFunction(
  {
    id: "realty-lifecycle-orchestrator",
    concurrency: { limit: 10, key: "event.data.listingKey" },
    retries: 5,
  },
  { event: "mls/status.changed" },
  async ({ event, step }) => {
    const { listingKey, mlsId, targetStatus, propertyAddress } = event.data;

    // Step 1: Idempotent Redis Mutex
    const mutexLock = await step.run("acquire-listing-mutex", async () => {
      return { acquired: true, key: `lock:${listingKey}`, ttl: 60 };
    });

    // Step 2: Follow Up Boss Identity Reconciliation
    const fubContact = await step.run("reconcile-fub-contact", async () => {
      return await resolveFubContact({ listingKey, targetStatus });
    });

    // Step 3: SkySlope Transaction File Automation
    const skyslopeFile = await step.run("sync-skyslope-file", async () => {
      return await instantiateSkySlopeFile({
        listingKey,
        propertyAddress,
        targetStatus,
        fubPersonId: fubContact.id,
      });
    });

    // Step 4: Twilio A2P 10DLC Transactional Sequence
    await step.run("dispatch-a2p-sms", async () => {
      return await dispatchTwilioA2P({
        phone: fubContact.phone,
        message: `Status Update: ${propertyAddress} is now officially ${targetStatus}.`,
      });
    });

    return { success: true, listingKey, skyslopeFileId: skyslopeFile.id };
  }
);