u

src/api/index.js

@@ -589,6 +589,27 @@ export const brand = {
   delete(id) {
     return http(`/api/brand/${encodeURIComponent(id)}`, { method: 'DELETE' });
   },
+
+  /**
+   * POST /api/brand/:id/image
+   * Accepts full-size AVIF body (Content-Type: image/avif).
+   * → 201 { brand: { id, fullHash, thumbW, thumbH, thumbHash, pics } }
+   */
+  addImage(brandId, file) {
+    return httpBinary(`/api/brand/${brandId}/image`, {
+      method: 'POST',
+      contentType: 'image/avif',
+      body: file,
+    });
+  },
+
+  /**
+   * DELETE /api/brand/:id/image
+   * → 200 { brand: { id, thumbW: null, thumbH: null, thumbHash: null, pics: [] } }
+   */
+  deleteImage(brandId) {
+    return http(`/api/brand/${brandId}/image`, { method: 'DELETE' });
+  },
 };
 
 /**
@@ -842,6 +863,111 @@ export const delivery = {
   },
 };
 
+/**
+ * Serper Google Images search and WebP thumbnail streaming.
+ */
+export const serper = {
+  /**
+   * POST /api/serper/images
+   * Body: { q, gl, hl, num, preferSource }
+   * Streams SSE events: images, thumb, done, error
+   *
+   * @param {object} params
+   * @param {string} params.q - Search query
+   * @param {string} [params.gl='de'] - Country code
+   * @param {string} [params.hl='de'] - Language code
+   * @param {number} [params.num=100] - Result count (1-100)
+   * @param {boolean} [params.preferSource=false] - Prefer high-res source image
+   * @param {object} [options]
+   * @param {AbortSignal} [options.signal] - Abort controller signal
+   * @returns {AsyncGenerator<{event: string, data: any}>}
+   */
+  async *searchImages(
+    { q, gl = 'de', hl = 'de', num = 100, preferSource = false } = {},
+    { signal } = {},
+  ) {
+    const res = await fetch('/api/serper/images', {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      credentials: 'include',
+      body: JSON.stringify({ q, gl, hl, num, preferSource }),
+      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 */
+      }
+    }
+  },
+};
+
 /**
  * Append-only stock and payment ledger.
  * Entry = { id, manifestarticle_id, sku, transaction_type, amount, transaction_text, hash_version, prev_hash, created_at }