LetsPing

import { LetsPing } from "@letsping/sdk";
import { z } from "zod";

const lp = new LetsPing();

// Pass a Zod schema and the dashboard renders a type-safe edit form.
// The operator can change values before approving.
const decision = await lp.ask({
  service: "outreach-bot",
  action:  "send_email",
  payload: { to: "ceo@acme.com", subject: "Q1 recap", body: "..." },
  schema: z.object({
    to:      z.string().email(),
    subject: z.string(),
    body:    z.string().describe("Plain text or Markdown"),
  })
});

// Check if the operator edited the subject.
const final = decision.status === "APPROVED_WITH_MODIFICATIONS" 
  ? decision.patched_payload 
  : decision.payload;

# Start the MCP server (reads LETSPING_API_KEY from env)
npx @letsping/mcp

# Claude Desktop — add to claude_desktop_config.json:
{
  "mcpServers": {
    "letsping": {
      "command": "npx",
      "args": ["@letsping/mcp"],
      "env": { "LETSPING_API_KEY": "lp_live_..." }
    }
  }
}

# Cursor — add to .cursor/mcp.json with the same structure.
# The agent now has access to the "ask_human" tool.

// LetsPing sends a POST to your endpoint on every status change.
// Payload shape:
{
  "event":      "request.approved",  // or "request.rejected" | "request.created"
  "request_id": "req_abc123",
  "status":     "APPROVED",
  "service":    "billing-agent",
  "action":     "refund_user",
  "payload":    { "user_id": "u_123", "amount": 550 },
  "patched_payload": { "user_id": "u_123", "amount": 220 }, // if operator edited
  "resolved_at": "2026-02-20T19:30:00Z",
  "state_download_url": "https://[project].supabase.co/storage/v1/object/sign/agent_states/states/req_abc123.enc?token=..."
}

// app/api/webhook/letsping/route.ts
import { NextResponse } from "next/server";
import { LetsPing } from "@letsping/sdk";

const lp = new LetsPing(); // Automatically loads LETSPING_ENCRYPTION_KEY if set

export async function POST(req: Request) {
  const body = await req.json();
  
  if (body.status === "APPROVED" || body.status === "APPROVED_WITH_MODIFICATIONS") {
      const finalPayload = body.patched_payload || body.payload;
      
      let hydratedState = null;
      if (body.state_download_url) {
          // 1. Fetch the frozen Cryo-Sleep state
          const res = await fetch(body.state_download_url);
          const encryptedState = await res.json();
          
          // 2. Decrypt locally
          hydratedState = (lp as any)._decrypt(encryptedState);
      }
      
      // 3. Manually resume your specific framework (e.g. LangGraph)
      // await resumeAgent(hydratedState, finalPayload);
  }
  
  return NextResponse.json({ success: true });
}