API externa

curl -H "x-api-key: YOUR_API_KEY" \
  https://workflow.aurora-ai.co/api/v1/logs?workspaceId=YOUR_WORKSPACE_ID

"limits": {
  "workflowExecutionRateLimit": {
    "sync": {
      "limit": 60,        // Max sync workflow executions per minute
      "remaining": 58,    // Remaining sync workflow executions
      "resetAt": "..."    // When the window resets
    },
    "async": {
      "limit": 60,        // Max async workflow executions per minute
      "remaining": 59,    // Remaining async workflow executions
      "resetAt": "..."    // When the window resets
    }
  },
  "usage": {
    "currentPeriodCost": 1.234,  // Current billing period usage in USD
    "limit": 10,                  // Usage limit in USD
    "plan": "pro",                // Current subscription plan
    "isExceeded": false           // Whether limit is exceeded
  }
}

{
  "id": "evt_123",
  "type": "workflow.execution.completed",
  "timestamp": 1735925767890,
  "data": {
    "workflowId": "wf_xyz789",
    "executionId": "exec_def456",
    "status": "success",
    "level": "info",
    "trigger": "api",
    "startedAt": "2025-01-01T12:34:56.789Z",
    "endedAt": "2025-01-01T12:34:57.123Z",
    "totalDurationMs": 334,
    "cost": {
      "total": 0.00234,
      "tokens": {
        "prompt": 123,
        "completion": 456,
        "total": 579
      },
      "models": {
        "gpt-4o": {
          "input": 0.001,
          "output": 0.00134,
          "total": 0.00234,
          "tokens": {
            "prompt": 123,
            "completion": 456,
            "total": 579
          }
        }
      }
    },
    "files": null,
    "finalOutput": {...},  // Only if includeFinalOutput=true
    "traceSpans": [...],   // Only if includeTraceSpans=true
    "rateLimits": {...},   // Only if includeRateLimits=true
    "usage": {...}         // Only if includeUsageData=true
  },
  "links": {
    "log": "/v1/logs/log_abc123",
    "execution": "/v1/logs/workflow/pt-BR/executions/exec_def456"
  }
}

let cursor = null;
const workspaceId = "YOUR_WORKSPACE_ID";
const startDate = new Date().toISOString();

async function pollLogs() {
  const params = new URLSearchParams({
    workspaceId,
    startDate,
    order: "asc",
    limit: "100",
  });

  if (cursor) {
    params.append("cursor", cursor);
  }

  const response = await fetch(
    `https://workflow.aurora-ai.co/api/v1/logs?${params}`,
    {
      headers: {
        "x-api-key": "YOUR_API_KEY",
      },
    }
  );

  if (response.ok) {
    const data = await response.json();

    // Process new logs
    for (const log of data.data) {
      console.log(`New execution: ${log.executionId}`);
    }

    // Update cursor for next poll
    if (data.nextCursor) {
      cursor = data.nextCursor;
    }
  }
}

// Poll every 30 seconds
setInterval(pollLogs, 30000);

import express from "express";
import crypto from "crypto";

const app = express();
app.use(express.json());

app.post("/sim-webhook", (req, res) => {
  // Verify signature
  const signature = req.headers["sim-signature"];
  const body = JSON.stringify(req.body);

  if (!verifyWebhookSignature(body, signature, process.env.WEBHOOK_SECRET)) {
    return res.status(401).send("Invalid signature");
  }

  // Check timestamp to prevent replay attacks
  const timestamp = parseInt(req.headers["sim-timestamp"]);
  const fiveMinutesAgo = Date.now() - 5 * 60 * 1000;

  if (timestamp < fiveMinutesAgo) {
    return res.status(401).send("Timestamp too old");
  }

  // Process the webhook
  const event = req.body;

  switch (event.type) {
    case "workflow.execution.completed":
      const { workflowId, executionId, status, cost } = event.data;

      if (status === "error") {
        console.error(`Workflow ${workflowId} failed: ${executionId}`);
        // Handle error...
      } else {
        console.log(`Workflow ${workflowId} completed: ${executionId}`);
        console.log(`Cost: $${cost.total}`);
        // Process successful execution...
      }
      break;
  }

  // Return 200 to acknowledge receipt
  res.status(200).send("OK");
});

app.listen(3000, () => {
  console.log("Webhook server listening on port 3000");
});