1
// Note: This endpoint uses Server-Sent Events (SSE)
2
const eventSource = new EventSource('/v1/ai/entity_12345/suggest-categories-vector');
3
4
fetch('/v1/ai/entity_12345/suggest-categories-vector', {
5
  method: 'POST',
6
  headers: {
7
    'Content-Type': 'application/json',
8
    'Authorization': 'Bearer your_token_here'
9
  },
10
  body: JSON.stringify({
11
    transactions: [
12
      {
13
        id: "txn_123",
14
        description: "AWS Monthly Subscription",
15
        amount: 125.99,
16
        direction: "DEBIT",
17
        counterparty_name: "Amazon Web Services",
18
        date: "2023-04-15",
19
        bank_transaction_id: "tx_12345abcdef"
20
      },
21
      {
22
        id: "txn_124",
23
        description: "Office supplies",
24
        amount: 45.0,
25
        direction: "DEBIT",
26
        counterparty_name: "Staples",
27
        date: "2023-04-16",
28
        bank_transaction_id: "tx_67890ghijkl"
29
      }
30
    ]
31
  })
32
})

1
// Immediate response for transactions already categorized
2
data: {
3
  "transaction_id": "txn_123",
4
  "suggested_type": "EXPENSE",
5
  "suggested_category_code": 5001,
6
  "account_code": 5001,
7
  "category_id": 12,
8
  "confidence": 1.0
9
}

1
// Progress updates during categorization
2
data: {
3
  "transaction_id": "txn_124",
4
  "status": "in_progress",
5
  "suggested_type": "EXPENSE",
6
  "suggested_category_code": 5002,
7
  "account_code": 5002,
8
  "category_id": 13,
9
  "confidence": 0.88
10
}
11
12
// Final result
13
data: {
14
  "transaction_id": "txn_124",
15
  "suggested_type": "EXPENSE",
16
  "suggested_category_code": 5002,
17
  "account_code": 5002,
18
  "category_id": 13,
19
  "confidence": 0.88,
20
  "status": "complete",
21
  "enrichment": {
22
    "counterparty_info": "Staples is an office supply retail chain",
23
    "transaction_context": "Purchase of office supplies",
24
    "likely_business_category": "Office Expenses"
25
  }
26
}
27
28
// End of stream
29
data: [DONE]

1
data: {
2
  "error": "Internal server error",
3
  "message": "Detailed error message"
4
}

1
data: {
2
  "transaction_id": "txn_125",
3
  "status": "retrying", 
4
  "retry_count": 1,
5
  "message": "Retrying categorization (attempt 2/3)"
6
}

1
async function categorizeTransactions(entityId, transactions, token) {
2
  const response = await fetch(`/v1/ai/${entityId}/suggest-categories-vector`, {
3
    method: 'POST',
4
    headers: {
5
      'Content-Type': 'application/json',
6
      'Authorization': `Bearer ${token}`
7
    },
8
    body: JSON.stringify({ transactions })
9
  });
10
11
  const reader = response.body?.getReader();
12
  const decoder = new TextDecoder();
13
  const results = [];
14
15
  while (true) {
16
    const { done, value } = await reader.read();
17
    if (done) break;
18
19
    const chunk = decoder.decode(value);
20
    const lines = chunk.split('\n');
21
22
    for (const line of lines) {
23
      if (line.startsWith('data: ')) {
24
        const data = line.slice(6);
25
        if (data === '[DONE]') {
26
          return results;
27
        }
28
        
29
        try {
30
          const result = JSON.parse(data);
31
          if (result.status === 'complete' || result.confidence) {
32
            results.push(result);
33
          }
34
        } catch (e) {
35
          console.error('Error parsing SSE data:', e);
36
        }
37
      }
38
    }
39
  }
40
41
  return results;
42
}
43
44
// Example usage
45
const transactions = [
46
  {
47
    id: "txn_123",
48
    description: "AWS Monthly Subscription",
49
    amount: 125.99,
50
    direction: "DEBIT",
51
    counterparty_name: "Amazon Web Services",
52
    date: "2023-04-15",
53
    bank_transaction_id: "tx_12345abcdef"
54
  }
55
];
56
57
const suggestions = await categorizeTransactions("entity_123456", transactions, "your_token");
58
console.log(suggestions);

1
// Network or authentication errors
2
data: {
3
  "error": "Instance not found for this entity"
4
}
5
6
// Processing errors with retry
7
data: {
8
  "transaction_id": "txn_123",
9
  "status": "retrying",
10
  "retry_count": 2,
11
  "message": "Retrying categorization (attempt 3/3)"
12
}