Purple Flea + Inngest:
Event-Driven Agent Finance

import { inngest, pfApi } from "../client";

export const tradeOnPriceAlert = inngest.createFunction(
  {
    id: "trade-on-price-alert",
    retries: 3,
    concurrency: { limit: 1 }, // one trade at a time
  },
  { event: "purple-flea/price.alert" },

  async ({ event, step }) => {
    const { asset, price, direction } = event.data;

    // Step 1: Check wallet balance before trading
    const wallet = await step.run("check-balance", async () =>
      pfApi("/wallet/balance")
    );

    if (wallet.usdc_balance < 10) {
      return { skipped: true, reason: "insufficient balance" };
    }

    // Step 2: Place the trade
    const order = await step.run("place-order", async () =>
      pfApi("/trading/order", "POST", {
        asset,
        side: direction,
        size_usdc: 10,
        order_type: "market",
      })
    );

    // Step 3: Log result (retried independently if it fails)
    await step.run("log-trade", async () => {
      await fetch("https://your-slack-webhook.com", {
        method: "POST",
        body: JSON.stringify({
          text: `Trade placed: ${direction} ${asset} @ $${price} — order ${order.id}`,
        }),
      });
    });

    return { order_id: order.id, asset, direction, price };
  }
);

// In your price feed listener or API handler:
await inngest.send({
  name: "purple-flea/price.alert",
  data: {
    asset: "ETH",
    price: 2840.50,
    direction: "long",
    triggered_by: "rsi_oversold",
  },
});

import { serve } from "inngest/next";
import { inngest } from "@/inngest/client";
import { tradeOnPriceAlert } from "@/inngest/functions/tradeOnPriceAlert";
import { dailyFaucetClaim } from "@/inngest/functions/dailyFaucetClaim";
import { escrowWebhookHandler } from "@/inngest/functions/escrowWebhookHandler";

export const { GET, POST, PUT } = serve({
  client: inngest,
  functions: [tradeOnPriceAlert, dailyFaucetClaim, escrowWebhookHandler],
});

import { inngest, pfApi } from "../client";

export const escrowWebhookHandler = inngest.createFunction(
  {
    id: "escrow-lifecycle",
    retries: 3,
    timeouts: { finish: "7d" }, // wait up to 7 days for confirm
  },
  { event: "purple-flea/escrow.created" },

  async ({ event, step }) => {
    const { escrow_id, amount_usdc, counterparty } = event.data;

    // Step 1: Create the escrow on Purple Flea
    const escrow = await step.run("create-escrow", async () =>
      pfApi("/escrow/create", "POST", {
        amount_usdc,
        counterparty_address: counterparty,
        description: "Agent service payment",
        timeout_hours: 168, // 7 days
      })
    );

    // Step 2: Pause until the counterparty confirms
    // This suspends the function with zero resource usage
    const confirmEvent = await step.waitForEvent(
      "wait-for-counterparty",
      {
        event: "purple-flea/escrow.confirmed",
        timeout: "7d",
        match: "data.escrow_id",
      }
    );

    if (!confirmEvent) {
      // Timed out — cancel and refund
      await step.run("cancel-escrow", async () =>
        pfApi(`/escrow/${escrow.id}/cancel`, "POST")
      );
      return { status: "cancelled", escrow_id: escrow.id };
    }

    // Step 3: Release funds to counterparty
    const release = await step.run("release-escrow", async () =>
      pfApi(`/escrow/${escrow.id}/release`, "POST")
    );

    return {
      status: "released",
      escrow_id: escrow.id,
      tx_hash: release.tx_hash,
      fee_usdc: release.fee_usdc,       // 1% Purple Flea fee
      referral_earned: release.referral, // 15% of fee if referred
    };
  }
);

// Buyer initiates the escrow
await inngest.send({
  name: "purple-flea/escrow.created",
  data: {
    escrow_id: "esc_001",
    amount_usdc: 50.00,
    counterparty: "0xSellerAgentAddress",
  },
});

// Purple Flea webhook hits your /api/webhooks/escrow endpoint.
// Forward the confirmation to Inngest to resume the paused function:
await inngest.send({
  name: "purple-flea/escrow.confirmed",
  data: {
    escrow_id: "esc_001",  // matches the paused function
    confirmed_by: "0xSellerAgentAddress",
    confirmed_at: new Date().toISOString(),
  },
});