# Convert document to base64
base64_doc=$(base64 -i invoice.pdf)

curl -X POST https://api.adteco.com/v1/documents \
  -H "Authorization: Bearer sk_live_your_api_key" \
  -H "Content-Type: application/json" \
  -d '{
    "extractor_id": "ext_abc123...",
    "document": "'$base64_doc'",
    "mime_type": "application/pdf",
    "metadata": {
      "source": "email_attachment",
      "user_id": "user_123"
    }
  }'

import fs from 'fs';

// Read and convert document to base64
const documentBuffer = fs.readFileSync('./invoice.pdf');
const base64Document = documentBuffer.toString('base64');

const response = await fetch('https://api.adteco.com/v1/documents', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer sk_live_your_api_key',
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    extractor_id: 'ext_abc123...',
    document: base64Document,
    mime_type: 'application/pdf',
    metadata: {
      source: 'email_attachment',
      user_id: 'user_123',
    },
  }),
});

const job = await response.json();
console.log('Job ID:', job.id);
console.log('Status:', job.status);

import requests
import base64

# Read and convert document to base64
with open('invoice.pdf', 'rb') as f:
    document_bytes = f.read()
    base64_document = base64.b64encode(document_bytes).decode('utf-8')

response = requests.post(
    'https://api.adteco.com/v1/documents',
    headers={
        'Authorization': 'Bearer sk_live_your_api_key',
        'Content-Type': 'application/json',
    },
    json={
        'extractor_id': 'ext_abc123...',
        'document': base64_document,
        'mime_type': 'application/pdf',
        'metadata': {
            'source': 'email_attachment',
            'user_id': 'user_123',
        },
    },
)

job = response.json()
print('Job ID:', job['id'])
print('Status:', job['status'])

curl -X GET https://api.adteco.com/v1/documents/job_abc123... \
  -H "Authorization: Bearer sk_live_your_api_key"

const jobId = 'job_abc123...';

const response = await fetch(
  `https://api.adteco.com/v1/documents/${jobId}`,
  {
    headers: {
      'Authorization': 'Bearer sk_live_your_api_key',
    },
  }
);

const job = await response.json();

if (job.status === 'completed') {
  console.log('Extracted data:', job.extracted_data);
  console.log('Confidence scores:', job.confidence);
} else if (job.status === 'failed') {
  console.error('Job failed:', job.error_details);
} else {
  console.log('Job is still processing...');
}

job_id = 'job_abc123...'

response = requests.get(
    f'https://api.adteco.com/v1/documents/{job_id}',
    headers={'Authorization': 'Bearer sk_live_your_api_key'},
)

job = response.json()

if job['status'] == 'completed':
    print('Extracted data:', job['extracted_data'])
    print('Confidence scores:', job['confidence'])
elif job['status'] == 'failed':
    print('Job failed:', job['error_details'])
else:
    print('Job is still processing...')

async function waitForResults(jobId: string): Promise<any> {
  const maxAttempts = 30; // 60 seconds total
  const pollInterval = 2000; // 2 seconds

  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    const response = await fetch(
      `https://api.adteco.com/v1/documents/${jobId}`,
      {
        headers: {
          'Authorization': 'Bearer sk_live_your_api_key',
        },
      }
    );

    const job = await response.json();

    if (job.status === 'completed') {
      return job.extracted_data;
    } else if (job.status === 'failed') {
      throw new Error(`Job failed: ${job.error_details?.message}`);
    }

    // Wait before next poll
    await new Promise(resolve => setTimeout(resolve, pollInterval));
  }

  throw new Error('Job processing timeout');
}

// Usage
try {
  const extractedData = await waitForResults('job_abc123...');
  console.log(extractedData);
} catch (error) {
  console.error('Error:', error.message);
}

import time

def wait_for_results(job_id: str, max_attempts: int = 30):
    """Poll for job results with exponential backoff."""
    poll_interval = 2  # seconds

    for attempt in range(max_attempts):
        response = requests.get(
            f'https://api.adteco.com/v1/documents/{job_id}',
            headers={'Authorization': 'Bearer sk_live_your_api_key'},
        )

        job = response.json()

        if job['status'] == 'completed':
            return job['extracted_data']
        elif job['status'] == 'failed':
            raise Exception(f"Job failed: {job['error_details']['message']}")

        # Wait before next poll
        time.sleep(poll_interval)

    raise Exception('Job processing timeout')

# Usage
try:
    extracted_data = wait_for_results('job_abc123...')
    print(extracted_data)
except Exception as e:
    print(f'Error: {e}')

curl -X GET "https://api.adteco.com/v1/documents?status=completed&limit=20" \
  -H "Authorization: Bearer sk_live_your_api_key"

const params = new URLSearchParams({
  status: 'completed',
  limit: '20',
  offset: '0',
});

const response = await fetch(
  `https://api.adteco.com/v1/documents?${params}`,
  {
    headers: {
      'Authorization': 'Bearer sk_live_your_api_key',
    },
  }
);

const data = await response.json();
console.log(`Found ${data.jobs.length} jobs`);

params = {
    'status': 'completed',
    'limit': 20,
    'offset': 0,
}

response = requests.get(
    'https://api.adteco.com/v1/documents',
    headers={'Authorization': 'Bearer sk_live_your_api_key'},
    params=params,
)

data = response.json()
print(f"Found {len(data['jobs'])} jobs")