API Documentation

const fetch = require("node-fetch");
const fs = require("fs");
const FormData = require("form-data");
const Database = require("better-sqlite3");

const API_BASE = 'https://invoicesengine.com/invoice-api/v3.0';
const API_KEY  = process.env.INVOICE_API_KEY || "YOUR_API_KEY";

const db = new Database("requests.db");
db.exec("CREATE TABLE IF NOT EXISTS requests (id TEXT PRIMARY KEY, path TEXT, status TEXT, created_at INTEGER)");

async function upload(filePath) {
  const form = new FormData();
  form.append("file", fs.createReadStream(filePath));
  const res = await fetch(`${API_BASE}/extract`, {
    method: "POST",
    headers: { Authorization: `Bearer ${API_KEY}` },
    body: form
  });
  const j = await res.json();
  if (j.status === "error") throw new Error(`${j.error.code}: ${j.error.message}`);
  const id = j.request_id || j.request_id;
  db.prepare("INSERT OR REPLACE INTO requests (id, path, status, created_at) VALUES (?, ?, ?, strftime('%s','now'))")
    .run(id, filePath, "pending");
}

async function checkPending() {
  const rows = db.prepare("SELECT id FROM requests WHERE status='pending'").all();
  for (const r of rows) {
    const res = await fetch(`${API_BASE}/result/${encodeURIComponent(r.id)}`, {
      headers: { Authorization: `Bearer ${API_KEY}` }
    });
    const json = await res.json();
    const s = json.status;
    if (s === "queued" || s === "processing") continue;
    db.prepare("UPDATE requests SET status=? WHERE id=?").run("done", r.id);
    fs.writeFileSync(`result_${r.id}.json`, JSON.stringify(json, null, 2));
    console.log("Saved:", r.id);
  }
}

// CRON #1: upload new files periodically (e.g., */5 * * * *)
// upload("/abs/path/invoice.pdf").catch(console.error);

// CRON #2: poll for completed requests (e.g., */2 * * * *)
// checkPending().catch(console.error);

import os, time, requests

API_BASE = 'https://invoicesengine.com/invoice-api/v3.0'
API_KEY  = os.getenv("INVOICE_API_KEY", "YOUR_API_KEY")
HEADERS  = { "Authorization": f"Bearer {API_KEY}" }

def upload(path):
    with open(path, "rb") as f:
        r = requests.post(f"{API_BASE}/extract", headers=HEADERS, files={"file": f})
    j = r.json()
    if j.get("status") == "error":
        raise SystemExit(f"{j["error"]["code"]}: {j["error"]["message"]}")
    return j.get("request_id") or j.get("request_id")

def poll(request_id, interval=1.5):
    while True:
        j = requests.get(f"{API_BASE}/result/{request_id}", headers=HEADERS).json()
        s = j.get("status")
        if s in ("queued", "processing"):
            time.sleep(interval)
            continue
        return j  # success (with data/warnings/errors) or error envelope

if __name__ == "__main__":
    jid = upload("invoice.pdf")
    print("Queued:", jid)
    final = poll(jid)
    print("Final:", final)

import os, json, time, sqlite3, requests

API_BASE = 'https://invoicesengine.com/invoice-api/v3.0'
API_KEY  = os.getenv("INVOICE_API_KEY", "YOUR_API_KEY")
HEADERS  = { "Authorization": f"Bearer {API_KEY}" }

db = sqlite3.connect("requests.db")
db.execute("CREATE TABLE IF NOT EXISTS requests (id TEXT PRIMARY KEY, path TEXT, status TEXT, created_at INTEGER)")
db.commit()

def upload(path):
    with open(path, "rb") as f:
        j = requests.post(f"{API_BASE}/extract", headers=HEADERS, files={"file": f}).json()
    if j.get("status") == "error":
        raise SystemExit(f"{j["error"]["code"]}: {j["error"]["message"]}")
    jid = j.get("request_id") or j.get("request_id")
    db.execute("INSERT OR REPLACE INTO requests (id, path, status, created_at) VALUES (?, ?, 'pending', strftime('%s','now'))", (jid, path))
    db.commit()

def check_pending():
    for (jid,) in db.execute("SELECT id FROM requests WHERE status='pending'"):
        j = requests.get(f"{API_BASE}/result/{jid}", headers=HEADERS).json()
        s = j.get("status")
        if s in ("queued", "processing"):
            continue
        db.execute("UPDATE requests SET status='done' WHERE id=?", (jid,))
        db.commit()
        with open(f"result_{jid}.json", "w") as f:
            json.dump(j, f, indent=2)

# CRON 1: upload("/abs/path/invoice.pdf")
# CRON 2: check_pending()

<?php
$API_BASE = 'https://invoicesengine.com/invoice-api/v3.0';
$API_KEY  = getenv("INVOICE_API_KEY") ?: "YOUR_API_KEY";

function upload($path) {
  global $API_BASE, $API_KEY;
  $ch = curl_init($API_BASE . "/extract");
  curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER     => ["Authorization: Bearer " . $API_KEY],
    CURLOPT_POST           => true,
    CURLOPT_POSTFIELDS     => ["file" => new CURLFile($path)],
    CURLOPT_RETURNTRANSFER => true,
  ]);
  $resp = curl_exec($ch);
  curl_close($ch);
  $j = json_decode($resp, true);
  if (($j["status"] ?? null) === "error") {
    throw new RuntimeException(($j["error"]["code"] ?? "ERR") . ": " . ($j["error"]["message"] ?? "Unknown"));
  }
  return $j["request_id"] ?? ($j["request_id"] ?? null);
}

function poll($request_id, $interval = 1.5) {
  global $API_BASE, $API_KEY;
  while (true) {
    $ch = curl_init($API_BASE . "/result/" . rawurlencode($request_id));
    curl_setopt_array($ch, [
      CURLOPT_HTTPHEADER     => ["Authorization: Bearer " . $API_KEY],
      CURLOPT_RETURNTRANSFER => true,
    ]);
    $resp = curl_exec($ch);
    curl_close($ch);
    $j = json_decode($resp, true);
    $s = $j["status"] ?? null;
    if ($s === "queued" || $s === "processing") {
      usleep((int)($interval * 1_000_000));
      continue;
    }
    return $j;
  }
}

$jid  = upload(__DIR__ . "/invoice.pdf");
$final = poll($jid);
print_r($final);

<?php
$API_BASE = 'https://invoicesengine.com/invoice-api/v3.0';
$API_KEY  = getenv("INVOICE_API_KEY") ?: "YOUR_API_KEY";
$pdo = new PDO("sqlite:" . __DIR__ . "/requests.db");
$pdo->exec("CREATE TABLE IF NOT EXISTS requests (id TEXT PRIMARY KEY, path TEXT, status TEXT, created_at INTEGER)");

function upload($path) {
  global $API_BASE, $API_KEY, $pdo;
  $ch = curl_init($API_BASE . "/extract");
  curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER     => ["Authorization: Bearer " . $API_KEY],
    CURLOPT_POST           => true,
    CURLOPT_POSTFIELDS     => ["file" => new CURLFile($path)],
    CURLOPT_RETURNTRANSFER => true,
  ]);
  $j = json_decode(curl_exec($ch), true);
  curl_close($ch);
  if (($j["status"] ?? null) === "error") {
    fwrite(STDERR, json_encode($j) . PHP_EOL);
    return;
  }
  $id = $j["request_id"] ?? ($j["request_id"] ?? null);
  $stmt = $pdo->prepare("INSERT OR REPLACE INTO requests (id, path, status, created_at) VALUES (?, ?, 'pending', strftime('%s','now'))");
  $stmt->execute([$id, $path]);
}

function checkPending() {
  global $API_BASE, $API_KEY, $pdo;
  foreach ($pdo->query("SELECT id FROM requests WHERE status='pending'") as $row) {
    $id = $row["id"];
    $ch = curl_init($API_BASE . "/result/" . rawurlencode($id));
    curl_setopt_array($ch, [
      CURLOPT_HTTPHEADER     => ["Authorization: Bearer " . $API_KEY],
      CURLOPT_RETURNTRANSFER => true,
    ]);
    $j = json_decode(curl_exec($ch), true);
    curl_close($ch);
    $s = $j["status"] ?? null;
    if ($s === "queued" || $s === "processing") continue;
    $pdo->prepare("UPDATE requests SET status='done' WHERE id=?")->execute([$id]);
    file_put_contents(__DIR__ . "/result_{$id}.json", json_encode($j, JSON_PRETTY_PRINT));
  }
}

// CRON 1: */5 * * * * php -r 'require "this.php"; upload("/abs/path/invoice.pdf");'
// CRON 2: */2 * * * * php -r 'require "this.php"; checkPending();'

API_BASE='https://invoicesengine.com/invoice-api/v3.0'
API_KEY="${INVOICE_API_KEY:-YOUR_API_KEY}"

# Upload (multipart/form-data)
UPLOAD_JSON=$(curl -s -X POST "$API_BASE/extract" \
  -H "Authorization: Bearer $API_KEY" \
  -F "file=@invoice.pdf")

# Extract id (request_id or request_id)
REQUEST_ID=$(printf "%s" "$UPLOAD_JSON" | jq -r '.request_id // .request_id // empty')
[ -z "$REQUEST_ID" ] && { echo "Upload failed:"; echo "$UPLOAD_JSON"; exit 1; }
echo "Queued: $REQUEST_ID"

# Poll
while :; do
  RESP=$(curl -s -H "Authorization: Bearer $API_KEY" "$API_BASE/result/$REQUEST_ID")
  STATUS=$(printf "%s" "$RESP" | jq -r .status)
  if [ "$STATUS" = "queued" ] || [ "$STATUS" = "processing" ]; then
    sleep 2
  else
    echo "$RESP" | jq .
    break
  fi
done

# CRON 1: upload and store request IDs
API_BASE='https://invoicesengine.com/invoice-api/v3.0'
API_KEY="${INVOICE_API_KEY:-YOUR_API_KEY}"
DB="requests.txt"

UPLOAD_JSON=$(curl -s -X POST "$API_BASE/extract" -H "Authorization: Bearer $API_KEY" -F "file=@invoice.pdf")
REQUEST_ID=$(printf "%s" "$UPLOAD_JSON" | jq -r '.request_id // .request_id // empty')
[ -n "$REQUEST_ID" ] && echo "$REQUEST_ID" >> "$DB"

# CRON 2: poll pending IDs
TMP="requests.tmp"
: > "$TMP"
while read -r ID; do
  RESP=$(curl -s -H "Authorization: Bearer $API_KEY" "$API_BASE/result/$ID")
  STATUS=$(printf "%s" "$RESP" | jq -r .status)
  if [ "$STATUS" = "queued" ] || [ "$STATUS" = "processing" ]; then
    echo "$ID" >> "$TMP"
  else
    printf "%s\n" "$RESP" > "result_${ID}.json"
  fi
done < "$DB"
mv "$TMP" "$DB"