Importing order flow

const BASE = "https://monitoring.seqlense.com/api/v1/orderbook";
const KEY = process.env.SEQLENSE_API_KEY;

// Rows already mapped to canonical names. In real use, build these from your CSV.
const rows = [
  { client_id: "POSTG0000114", order_id: "1776678242178", venue: "WHITEBIT",
    base: "BTC", quote: "USDC", side: "SELL", order_type: "LIMIT",
    price: "75235.92", quantity: "0.0001", status: "FILLED",
    ts_submitted: "2026-04-20 09:44:02", ts_finished: "2026-04-20 09:44:17" },
  { client_id: "POSTG0000113", order_id: "1767011739000", venue: "BYBIT",
    base: "ETH", quote: "USDC", side: "SELL", order_type: "LIMIT",
    price: "3000", quantity: "0.003", status: "CANCELED", cancel_origin: "EXCHANGE",
    ts_submitted: "2025-12-29 12:35:39", ts_finished: "2025-12-29 12:51:00" },
];
const options = { record_shape: "ORDER_SNAPSHOT", timezone: "UTC", decimal_separator: "." };
const BATCH = 1000;

async function call(path, body) {
  const res = await fetch(`${BASE}${path}`, {
    method: "POST",
    headers: { Authorization: `Bearer ${KEY}`, "Content-Type": "application/json" },
    body: JSON.stringify(body),
  });
  const json = await res.json();
  if (!res.ok) throw new Error(`${path}: ${res.status} ${json.error}`);
  return json;
}

// 1. Dry run on a sample (at most 500 rows). first_row 2 = line after the CSV header.
const check = await call("/validate", { ...options, first_row: 2, rows: rows.slice(0, 500) });
console.log("dry run:", check.rows_accepted, "ok,", check.rows_rejected, "rejected", check.errors);
if (check.rows_rejected > 0) process.exit(1);

// 2. Open the import.
const { import_id } = await call("/import/start", { record_shape: options.record_shape, filename: "demo.csv" });

// 3. Send the batches, then 4. close the import (FAILED if anything went wrong).
let status = "DONE";
try {
  for (let i = 0; i < rows.length; i += BATCH) {
    const r = await call("/import/batch", {
      ...options, import_id, first_row: 2 + i, rows: rows.slice(i, i + BATCH),
    });
    console.log(`batch at row ${2 + i}:`, r.events_written, "events,", r.rows_rejected, "rejected", r.errors);
  }
} catch (e) {
  status = "FAILED";
  console.error(e.message);
}
const done = await call("/import/finish", { import_id, status });
console.log(done.status, done.events_written, "events stored, import", done.id);

curl -X POST -H "Authorization: Bearer sq_YOUR_API_KEY" \
    -H "Content-Type: application/json" \
    "https://monitoring.seqlense.com/api/v1/orderbook/profiles" \
    -d '{
      "name": "Whitebit export",
      "venue": "WHITEBIT",
      "profile": {
        "record_shape": "ORDER_SNAPSHOT",
        "timezone": "Europe/Paris",
        "decimal_separator": ",",
        "columns": { "ord_id": "order_id", "ord_amount": "quantity" }
      }
    }'

{ "id": "5d7c1a3e-2f4b-4c6d-8e9f-0a1b2c3d4e5f", "name": "Whitebit export" }

curl -X POST -H "Authorization: Bearer sq_YOUR_API_KEY" \
    -H "Content-Type: application/json" \
    "https://monitoring.seqlense.com/api/v1/orderbook/imports/rollback" \
    -d '{"import_id": "0b8f7a52-6a0e-4a8f-9d5e-3c1f0e2b7a41"}'

{ "rolled_back": true, "import_id": "0b8f7a52-6a0e-4a8f-9d5e-3c1f0e2b7a41", "events_removed": 1994 }