u

src/api/delivery.js

@@ -0,0 +1,151 @@
+import { http, clientIdHeaders } from './http.js';
+
+/**
+ * Company-scoped goods receipts (manifest type = delivery).
+ * DeliverySummary = { id, number, externalNumber, type: 'delivery', supplierId, date }
+ *   - number: server-allocated, read-only manifest number (from nextNumber('delivery')).
+ *   - externalNumber: user-entered reference (nullable).
+ * DeliveryLine = { id, articleId, sku, amount, net, transactedAmount, rebate, tax, comment }
+ * Delivery = DeliverySummary & { lines: DeliveryLine[] }
+ * DeliveryLineInput = { sku, amount, net, tax, rebate?, transactedAmount?, comment? }
+ */
+export const delivery = {
+  /** GET /api/delivery → { deliveries: DeliverySummary[] } */
+  list() {
+    return http('/api/delivery');
+  },
+
+  /** GET /api/delivery/:id → { delivery: Delivery } */
+  get(id) {
+    return http(`/api/delivery/${id}`);
+  },
+
+  /**
+   * POST /api/delivery
+   * Body: { externalNumber?, date, supplierId?, lines: DeliveryLineInput[] }
+   * number is NOT sent — the server allocates it automatically. The
+   * caller-supplied reference goes in externalNumber (nullable).
+   * Line requires sku, amount, net, tax. rebate→0, transactedAmount→amount.
+   * → 201 { delivery: Delivery }
+   */
+  create(body) {
+    return http('/api/delivery', { method: 'POST', body });
+  },
+
+  /**
+   * PATCH /api/delivery/:id
+   * Body: partial { externalNumber?, date?, supplierId?, lines? }.
+   * number is read-only and cannot be edited. externalNumber is editable and
+   * can be cleared by sending null or an empty string.
+   * If lines present, replaces all lines; if omitted, lines unchanged.
+   * → 200 { delivery: Delivery }
+   */
+  update(id, body) {
+    return http(`/api/delivery/${id}`, { method: 'PATCH', body });
+  },
+
+  /** DELETE /api/delivery/:id → 204 */
+  delete(id) {
+    return http(`/api/delivery/${id}`, { method: 'DELETE' });
+  },
+
+  /**
+   * GET /api/delivery/:id/file/:fileId → Blob
+   * Full binary content of attached file (PDF, text, etc.)
+   */
+  async getFile(id, fileId, { download = false } = {}) {
+    const query = download ? '?download=true' : '';
+    const res = await fetch(`/api/delivery/${encodeURIComponent(id)}/file/${encodeURIComponent(fileId)}${query}`, {
+      method: 'GET',
+      credentials: 'include',
+    });
+    if (!res.ok) {
+      let message = res.statusText;
+      try {
+        const data = await res.json();
+        message = data.error || data.message || message;
+      } catch { /* ignore */ }
+      const err = new Error(message || `Request failed (${res.status})`);
+      err.status = res.status;
+      throw err;
+    }
+    return res.blob();
+  },
+
+  /**
+   * POST /api/delivery/parse — multipart/form-data, field "file"
+   * Accepts PDF, TXT or CSV document (max 50 MB)
+   * Streams SSE events: status, llm_call, tool_call, usage, progress, result, error
+   */
+  async *parseSse(file, { signal } = {}) {
+    const formData = new FormData();
+    formData.append('file', file, file.name);
+    const res = await fetch('/api/delivery/parse', {
+      method: 'POST',
+      headers: { ...clientIdHeaders() },
+      credentials: 'include',
+      body: formData,
+      signal,
+    });
+    if (!res.ok) {
+      let message = res.statusText;
+      try {
+        const data = await res.json();
+        message = data.error || data.message || message;
+      } catch { /* ignore */ }
+      const err = new Error(message || `Request failed (${res.status})`);
+      err.status = res.status;
+      throw err;
+    }
+    const reader = res.body.getReader();
+    const decoder = new TextDecoder();
+    let buf = '';
+    let currentEvent = 'message';
+
+    const onAbort = () => {
+      try {
+        reader.cancel();
+      } catch { /* ignore */ }
+    };
+    if (signal) {
+      if (signal.aborted) {
+        onAbort();
+        return;
+      }
+      signal.addEventListener('abort', onAbort, { once: true });
+    }
+
+    try {
+      while (true) {
+        const { done, value } = await reader.read();
+        if (done) break;
+        buf += decoder.decode(value, { stream: true });
+        const lines = buf.split('\n');
+        buf = lines.pop();
+        for (const line of lines) {
+          if (line.startsWith('event:')) {
+            currentEvent = line.slice(6).trim();
+          } else if (line.startsWith('data:')) {
+            const raw = line.slice(5).trim();
+            let data;
+            try { data = JSON.parse(raw); } catch { data = raw; }
+            yield { event: currentEvent, data };
+            currentEvent = 'message';
+          }
+        }
+      }
+    } catch (err) {
+      if (signal?.aborted || err.name === 'AbortError') {
+        return;
+      }
+      throw err;
+    } finally {
+      if (signal) {
+        signal.removeEventListener('abort', onAbort);
+      }
+      try {
+        reader.releaseLock();
+      } catch { /* ignore */ }
+    }
+  },
+};