Poll for new form submissions

curl -X POST https://sutrena.com/api/forms \
  -H "Authorization: Bearer $SUTRENA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Feedback Queue",
    "fields": [
      {"name": "email", "label": "Email", "type": "email", "required": true},
      {"name": "feedback", "label": "Feedback", "type": "textarea", "required": true},
      {"name": "priority", "label": "Priority", "type": "select", "options": ["Low", "Medium", "High"]}
    ]
  }'

import requests, time, os
from datetime import datetime, timezone

API_KEY = os.environ["SUTRENA_API_KEY"]
FORM_ID = os.environ["FORM_ID"]
BASE = "https://sutrena.com"
POLL_INTERVAL = 30  # seconds

last_seen = datetime.now(timezone.utc).isoformat()

def process_submission(sub):
    """Your agent logic here."""
    print(f"New: {sub['payload']['email']} — {sub['payload']['priority']}")
    # Update a page, send a notification, log to a dashboard, etc.

while True:
    res = requests.get(
        f"{BASE}/api/forms/{FORM_ID}/submissions",
        headers={"Authorization": f"Bearer {API_KEY}"},
        params={"from": last_seen, "limit": 100},
    )
    data = res.json().get("data", res.json())
    submissions = data.get("submissions", [])

    for sub in submissions:
        process_submission(sub)
        last_seen = sub["createdAt"]

    if submissions:
        print(f"Processed {len(submissions)} new submissions")

    time.sleep(POLL_INTERVAL)

const API_KEY = process.env.SUTRENA_API_KEY;
const FORM_ID = process.env.FORM_ID;
const BASE = "https://sutrena.com";

let lastSeen = new Date().toISOString();

async function poll() {
  const url = new URL(`${BASE}/api/forms/${FORM_ID}/submissions`);
  url.searchParams.set("from", lastSeen);
  url.searchParams.set("limit", "100");

  const res = await fetch(url, {
    headers: { Authorization: `Bearer ${API_KEY}` },
  });
  const json = await res.json();
  const submissions = json.data?.submissions ?? json.submissions ?? [];

  for (const sub of submissions) {
    console.log("New:", sub.payload.email, "—", sub.payload.priority);
    // Your agent logic here
    lastSeen = sub.createdAt;
  }

  if (submissions.length > 0) {
    console.log(`Processed ${submissions.length} new submissions`);
  }
}

// Poll every 30 seconds
setInterval(poll, 30_000);
poll(); // Run immediately on start

async function pollAll() {
  let cursor = undefined;
  let total = 0;

  do {
    const url = new URL(`${BASE}/api/forms/${FORM_ID}/submissions`);
    url.searchParams.set("from", lastSeen);
    url.searchParams.set("limit", "100");
    if (cursor) url.searchParams.set("cursor", cursor);

    const res = await fetch(url, {
      headers: { Authorization: `Bearer ${API_KEY}` },
    });
    const json = await res.json();
    const data = json.data ?? json;
    const submissions = data.submissions ?? [];

    for (const sub of submissions) {
      // Process each submission
      lastSeen = sub.createdAt;
      total++;
    }

    cursor = data.cursor; // undefined when no more pages
  } while (cursor);

  if (total > 0) console.log(`Processed ${total} submissions`);
}