From 97b7c20e513890e2edcb6529b5e407ebf5cbb614 Mon Sep 17 00:00:00 2001
From: Hackall <36754621+hackall360@users.noreply.github.com>
Date: Sat, 13 Sep 2025 11:09:15 -0700
Subject: [PATCH 1/2] Organize PolliLib assets under js folder

---
 index.html                             |   2 +-
 js/polliLib/polliLib-web.global.js     | 294 ++++++++++++++++++++++++
 js/polliLib/polliLib-web.global.js.bak | 298 +++++++++++++++++++++++++
 js/polliLib/src/audio.js               |  47 ++++
 js/polliLib/src/client.js              |  64 ++++++
 js/polliLib/src/feeds.js               |  29 +++
 js/polliLib/src/image.js               |  31 +++
 js/polliLib/src/mcp.js                 |  61 +++++
 js/polliLib/src/pipeline.js            |  36 +++
 js/polliLib/src/sse.js                 |  37 +++
 js/polliLib/src/text.js                |  77 +++++++
 js/polliLib/src/tools.js               |  35 +++
 js/polliLib/src/vision.js              |  40 ++++
 tests/pollilib-smoke.mjs               |   2 +-
 14 files changed, 1051 insertions(+), 2 deletions(-)
 create mode 100644 js/polliLib/polliLib-web.global.js
 create mode 100644 js/polliLib/polliLib-web.global.js.bak
 create mode 100644 js/polliLib/src/audio.js
 create mode 100644 js/polliLib/src/client.js
 create mode 100644 js/polliLib/src/feeds.js
 create mode 100644 js/polliLib/src/image.js
 create mode 100644 js/polliLib/src/mcp.js
 create mode 100644 js/polliLib/src/pipeline.js
 create mode 100644 js/polliLib/src/sse.js
 create mode 100644 js/polliLib/src/text.js
 create mode 100644 js/polliLib/src/tools.js
 create mode 100644 js/polliLib/src/vision.js

diff --git a/index.html b/index.html
index ed88036..e7fcdd7 100644
--- a/index.html
+++ b/index.html
@@ -10,7 +10,7 @@
     <link rel="stylesheet" href="js/ui/styles.css">
     <link rel="stylesheet" href="js/ui/stylesScreensaver.css">
     <script src="https://cdn.jsdelivr.net/npm/marked/marked.min.js"></script>
-    <script defer src="polliLib/polliLib-web.global.js"></script>
+    <script defer src="js/polliLib/polliLib-web.global.js"></script>
     <script defer>
       // Configure polliLib default client and expose an explicit client for MCP helpers
       (function(){
diff --git a/js/polliLib/polliLib-web.global.js b/js/polliLib/polliLib-web.global.js
new file mode 100644
index 0000000..916e32e
--- /dev/null
+++ b/js/polliLib/polliLib-web.global.js
@@ -0,0 +1,294 @@
+(function (g) {
+  'use strict';
+
+  // --- client.js (web) ---
+  class PolliClientWeb {
+    constructor({ referrer = inferReferrer(), imageBase = 'https://image.pollinations.ai', textBase = 'https://text.pollinations.ai', timeoutMs = 60_000 } = {}) {
+      this.referrer = referrer;
+      this.imageBase = stripTrail(imageBase);
+      this.textBase = stripTrail(textBase);
+      this.timeoutMs = timeoutMs;
+    }
+    _addReferrer(u, params) {
+      const hasRefParam = params && Object.prototype.hasOwnProperty.call(params, 'referrer');
+      if (!hasRefParam && this.referrer) u.searchParams.set('referrer', this.referrer);
+      else if (hasRefParam && params.referrer) u.searchParams.set('referrer', params.referrer);
+    }
+    async get(url, { params = {}, headers = {}, stream = false } = {}) {
+      const u = new URL(url);
+      for (const [k, v] of Object.entries(params)) if (v != null && k !== 'referrer') u.searchParams.set(k, String(v));
+      this._addReferrer(u, params);
+      const controller = new AbortController();
+      const id = setTimeout(() => controller.abort(), this.timeoutMs);
+      try { return await fetch(u.toString(), { method: 'GET', headers, signal: controller.signal }); }
+      finally { clearTimeout(id); }
+    }
+    async postJson(url, body, { headers = {}, stream = false } = {}) {
+      const controller = new AbortController();
+      const id = setTimeout(() => controller.abort(), this.timeoutMs);
+      const hdrs = { 'Content-Type': 'application/json' };
+      Object.assign(hdrs, headers);
+      const payload = { ...(body || {}) };
+      if (this.referrer && payload.referrer == null) payload.referrer = this.referrer;
+      try { return await fetch(url, { method: 'POST', headers: hdrs, body: JSON.stringify(payload), signal: controller.signal }); }
+      finally { clearTimeout(id); }
+    }
+  }
+  function inferReferrer() { try { if (typeof window !== 'undefined' && window.location && window.location.origin) return window.location.origin; } catch {} return null; }
+  function stripTrail(s) { return s && s.endsWith('/') ? s.slice(0, -1) : s; }
+  let defaultClient = null;
+  function getDefaultClient() { return defaultClient ?? (defaultClient = new PolliClientWeb()); }
+  function setDefaultClient(c) { defaultClient = c; }
+
+  // --- sse.js ---
+  async function* sseEvents(response) {
+    const reader = response.body.getReader();
+    const decoder = new TextDecoder();
+    let buffer = '';
+    let eventLines = [];
+    while (true) {
+      const { value, done } = await reader.read();
+      if (done) break;
+      buffer += decoder.decode(value, { stream: true });
+      let idx;
+      while ((idx = buffer.indexOf('\n')) >= 0) {
+        const line = buffer.slice(0, idx).replace(/\r$/, '');
+        buffer = buffer.slice(idx + 1);
+        if (line === '') {
+          if (eventLines.length) {
+            const data = eventLines.filter(l => l.startsWith('data:')).map(l => l.slice(5).trimStart()).join('\n');
+            eventLines = [];
+            if (data) yield data;
+          }
+        } else eventLines.push(line);
+      }
+    }
+    if (eventLines.length) {
+      const data = eventLines.filter(l => l.startsWith('data:')).map(l => l.slice(5).trimStart()).join('\n');
+      if (data) yield data;
+    }
+  }
+
+  // --- helpers ---
+  const bool = v => (v == null ? undefined : (v ? 'true' : 'false'));
+  function base64FromArrayBuffer(ab) {
+    const bytes = new Uint8Array(ab);
+    let binary = '';
+    const chunk = 0x8000;
+    for (let i = 0; i < bytes.length; i += chunk) {
+      const sub = bytes.subarray(i, i + chunk);
+      binary += String.fromCharCode.apply(null, sub);
+    }
+    return btoa(binary);
+  }
+
+  // --- image.js ---
+  async function image(prompt, { model, seed, width, height, image: imgUrl, nologo, private: priv, enhance, safe, referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.imageBase}/prompt/${encodeURIComponent(prompt)}`;
+    const params = {};
+    if (model) params.model = model;
+    if (seed != null) params.seed = seed;
+    if (width != null) params.width = width;
+    if (height != null) params.height = height;
+    if (imgUrl) params.image = imgUrl;
+    if (nologo != null) params.nologo = bool(nologo);
+    if (priv != null) params.private = bool(priv);
+    if (enhance != null) params.enhance = bool(enhance);
+    if (safe != null) params.safe = bool(safe);
+    if (referrer) params.referrer = referrer;
+    const r = await client.get(url, { params });
+    if (!r.ok) throw new Error(`image error ${r.status}`);
+    return await r.blob();
+  }
+  async function imageModels(client = getDefaultClient()) {
+    const r = await client.get(`${client.imageBase}/models`);
+    if (!r.ok) throw new Error(`imageModels error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- text.js ---
+  async function text(prompt, { model, seed, temperature, top_p, presence_penalty, frequency_penalty, json, system, stream, private: priv, referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.textBase}/${encodeURIComponent(prompt)}`;
+    const params = {};
+    if (model) params.model = model;
+    if (seed != null) params.seed = seed;
+    if (temperature != null) params.temperature = temperature;
+    if (top_p != null) params.top_p = top_p;
+    if (presence_penalty != null) params.presence_penalty = presence_penalty;
+    if (frequency_penalty != null) params.frequency_penalty = frequency_penalty;
+    if (json) params.json = 'true';
+    if (system) params.system = system;
+    if (priv != null) params.private = !!priv;
+    if (referrer) params.referrer = referrer;
+    if (stream) {
+      params.stream = 'true';
+      const r = await client.get(url, { params, headers: { 'Accept': 'text/event-stream' } });
+      if (!r.ok) throw new Error(`text(stream) error ${r.status}`);
+      return (async function* () { for await (const data of sseEvents(r)) { if (String(data).trim() === '[DONE]') break; yield data; } })();
+    } else {
+      const r = await client.get(url, { params });
+      if (!r.ok) throw new Error(`text error ${r.status}`);
+      return await r.text();
+    }
+  }
+  async function chat({ model, messages, seed, temperature, top_p, presence_penalty, frequency_penalty, max_tokens, stream, private: priv, tools, tool_choice, referrer }, client = getDefaultClient()) {
+    const url = `${client.textBase}/openai`;
+    const body = { model, messages };
+    if (seed != null) body.seed = seed;
+    if (temperature != null) body.temperature = temperature;
+    if (top_p != null) body.top_p = top_p;
+    if (presence_penalty != null) body.presence_penalty = presence_penalty;
+    if (frequency_penalty != null) body.frequency_penalty = frequency_penalty;
+    if (max_tokens != null) body.max_tokens = max_tokens;
+    if (priv != null) body.private = !!priv;
+    if (tools) body.tools = tools;
+    if (tool_choice) body.tool_choice = tool_choice;
+    if (referrer) body.referrer = referrer;
+    if (stream) {
+      body.stream = true;
+      const r = await client.postJson(url, body, { headers: { 'Accept': 'text/event-stream' } });
+      if (!r.ok) throw new Error(`chat(stream) error ${r.status}`);
+      return (async function* () { for await (const data of sseEvents(r)) { if (String(data).trim() === '[DONE]') break; yield JSON.parse(data); } })();
+    } else {
+      const r = await client.postJson(url, body);
+      if (!r.ok) throw new Error(`chat error ${r.status}`);
+      return await r.json();
+    }
+  }
+  async function textModels(client = getDefaultClient()) {
+    const r = await client.get(`${client.textBase}/models`);
+    if (!r.ok) throw new Error(`textModels error ${r.status}`);
+    return await r.json();
+  }
+  async function search(query, model = 'searchgpt', client = getDefaultClient()) { return await text(query, { model }, client); }
+
+  // --- audio.js ---
+  async function tts(t, { voice, model = 'openai-audio', referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.textBase}/${encodeURIComponent(t)}`;
+    const params = { model };
+    if (voice) params.voice = voice;
+    if (referrer) params.referrer = referrer;
+    const r = await client.get(url, { params });
+    if (!r.ok) throw new Error(`tts error ${r.status}`);
+    return await r.blob();
+  }
+  async function stt({ file, data, format, question }, client = getDefaultClient()) {
+    if (!file && !data) throw new Error("Provide either 'file' or 'data'");
+    if (!format && file) {
+      if (file.type && file.type.startsWith('audio/')) format = file.type.split('/')[1];
+      else if (file.name && file.name.includes('.')) format = file.name.split('.').pop().toLowerCase();
+    }
+    if (!format) throw new Error("Audio 'format' is required (e.g., 'mp3' or 'wav')");
+    const bytes = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+    const b64 = base64FromArrayBuffer(bytes);
+    const body = { model: 'openai-audio', messages: [{ role: 'user', content: [{ type: 'text', text: question ?? 'Transcribe this audio' }, { type: 'input_audio', input_audio: { data: b64, format } }] }] };
+    const r = await client.postJson(`${client.textBase}/openai`, body);
+    if (!r.ok) throw new Error(`stt error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- vision.js ---
+  async function vision({ imageUrl, file, data, imageFormat, question, model = 'openai', max_tokens } = {}, client = getDefaultClient()) {
+    if (!imageUrl && !file && !data) throw new Error('Provide imageUrl or file/data');
+    if (!imageUrl) {
+      const ab = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+      if (!imageFormat) { if (file?.type?.startsWith('image/')) imageFormat = file.type.split('/')[1]; else throw new Error('imageFormat is required when providing raw bytes'); }
+      const b64 = base64FromArrayBuffer(ab);
+      imageUrl = `data:image/${imageFormat};base64,${b64}`;
+    }
+    const payload = { model, messages: [{ role: 'user', content: [{ type: 'text', text: question ?? 'Describe this image:' }, { type: 'image_url', image_url: { url: imageUrl } }] }] };
+    if (max_tokens != null) payload.max_tokens = max_tokens;
+    const r = await client.postJson(`${client.textBase}/openai`, payload);
+    if (!r.ok) throw new Error(`vision error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- feeds.js ---
+  async function* imageFeed({ limit } = {}, client = getDefaultClient()) {
+    const r = await client.get(`${client.imageBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`imageFeed error ${r.status}`);
+    let count = 0;
+    for await (const data of sseEvents(r)) { try { const obj = JSON.parse(data); yield obj; if (limit != null && ++count >= limit) break; } catch {} }
+  }
+  async function* textFeed({ limit } = {}, client = getDefaultClient()) {
+    const r = await client.get(`${client.textBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`textFeed error ${r.status}`);
+    let count = 0;
+    for await (const data of sseEvents(r)) { try { const obj = JSON.parse(data); yield obj; if (limit != null && ++count >= limit) break; } catch {} }
+  }
+
+  // --- tools.js ---
+  function functionTool(name, description, parameters) { return { type: 'function', function: { name, description, parameters } }; }
+  class ToolBox { constructor() { this.map = new Map(); } register(n, fn) { this.map.set(n, fn); return this; } get(n) { return this.map.get(n); } }
+  async function chatWithTools({ client, model, messages, tools, toolbox, maxRounds = 3, tool_choice }) {
+    const history = [...messages];
+    for (let round = 0; round <= maxRounds; round++) {
+      const resp = await chat({ model, messages: history, tools, tool_choice }, client);
+      const choice = (resp.choices?.[0]?.message) ?? {}; const toolCalls = choice.tool_calls ?? [];
+      if (!toolCalls.length) return resp;
+      history.push({ role: 'assistant', tool_calls: toolCalls });
+      for (const tc of toolCalls) {
+        const fname = tc.function?.name; let args = {}; try { args = JSON.parse(tc.function?.arguments ?? '{}'); } catch {}
+        const fn = toolbox.get(fname); if (!fn) return resp; const out = await fn(args);
+        history.push({ role: 'tool', tool_call_id: tc.id, name: fname, content: typeof out === 'string' ? out : JSON.stringify(out) });
+      }
+    }
+    return await chat({ model, messages: history }, client);
+  }
+
+  // --- mcp.js (web) ---
+  function serverName() { return 'pollinations-multimodal-api'; }
+  function toolDefinitions() {
+    return { name: serverName(), tools: [
+      { name: 'generateImageUrl', description: 'Generate an image and return its URL', parameters: { type: 'object', properties: { prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' }, nologo: { type: 'boolean' }, private: { type: 'boolean' } }, required: ['prompt'] } },
+      { name: 'generateImage', description: 'Generate an image and return base64', parameters: { type: 'object', properties: { prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' } }, required: ['prompt'] } },
+      { name: 'listImageModels', description: 'List available image models', parameters: { type: 'object', properties: {} } },
+      { name: 'respondAudio', description: 'Generate TTS audio (voice) from text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'sayText', description: 'Speak the provided text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'listAudioVoices', description: 'List available voices', parameters: { type: 'object', properties: {} } },
+      { name: 'listTextModels', description: 'List text & multimodal models', parameters: { type: 'object', properties: {} } },
+      { name: 'listModels', description: 'List models by kind', parameters: { type: 'object', properties: { kind: { type: 'string', enum: ['image','text','audio'] } } } },
+    ] };
+  }
+  function generateImageUrl(client, params) {
+    const { prompt, ...rest } = params; const u = new URL(`${client.imageBase}/prompt/${encodeURIComponent(prompt)}`);
+    for (const [k, v] of Object.entries(rest)) if (v != null) u.searchParams.set(k, String(v));
+    if (client.referrer && !u.searchParams.has('referrer')) u.searchParams.set('referrer', client.referrer);
+    return u.toString();
+  }
+  async function generateImageBase64(client, params) {
+    const blob = await image(params.prompt, params, client);
+    const ab = await blob.arrayBuffer(); const bytes = new Uint8Array(ab);
+    let binary = ''; const chunk = 0x8000; for (let i = 0; i < bytes.length; i += chunk) { const sub = bytes.subarray(i, i + chunk); binary += String.fromCharCode.apply(null, sub); }
+    return btoa(binary);
+  }
+  async function listImageModels(client) { return await imageModels(client); }
+  async function listTextModels(client) { return await textModels(client); }
+  async function listAudioVoices(client) { const models = await textModels(client); return models?.['openai-audio']?.voices ?? []; }
+
+  // --- pipeline.js ---
+  class Context extends Map {}
+  class Pipeline { constructor() { this.steps = []; } step(s) { this.steps.push(s); return this; } async execute({ client, context = new Context() } = {}) { for (const s of this.steps) await s.run({ client, context }); return context; } }
+  class TextGetStep { constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; } async run({ client, context }) { const v = await text(this.prompt, this.params, client); context.set(this.outKey, v); } }
+  class ImageStep { constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; } async run({ client, context }) { const blob = await image(this.prompt, this.params, client); context.set(this.outKey, { blob }); } }
+  class TtsStep { constructor({ text: t, outKey, params = {} }) { this.text = t; this.outKey = outKey; this.params = params; } async run({ client, context }) { const blob = await tts(this.text, this.params, client); context.set(this.outKey, { blob }); } }
+  class VisionUrlStep { constructor({ imageUrl, outKey, question, params = {} }) { this.imageUrl = imageUrl; this.outKey = outKey; this.params = { question, ...params }; } async run({ client, context }) { const v = await vision({ imageUrl: this.imageUrl, ...this.params }, client); context.set(this.outKey, v); } }
+
+  // --- top-level API ---
+  function configure({ referrer = undefined, imageBase = 'https://image.pollinations.ai', textBase = 'https://text.pollinations.ai', timeoutMs = 60_000 } = {}) {
+    setDefaultClient(new PolliClientWeb({ referrer, imageBase, textBase, timeoutMs }));
+  }
+
+  const api = {
+    configure,
+    image, text, chat, search, tts, stt, vision,
+    imageModels, textModels, imageFeed, textFeed,
+    tools: { functionTool, ToolBox, chatWithTools },
+    mcp: { serverName, toolDefinitions, generateImageUrl, generateImageBase64, listImageModels, listTextModels, listAudioVoices },
+    pipeline: { Context, Pipeline, TextGetStep, ImageStep, TtsStep, VisionUrlStep },
+    PolliClientWeb,
+  };
+
+  g.polliLib = api;
+
+})(typeof globalThis !== 'undefined' ? globalThis : (typeof self !== 'undefined' ? self : this));
diff --git a/js/polliLib/polliLib-web.global.js.bak b/js/polliLib/polliLib-web.global.js.bak
new file mode 100644
index 0000000..024cab2
--- /dev/null
+++ b/js/polliLib/polliLib-web.global.js.bak
@@ -0,0 +1,298 @@
+(function (g) {
+  'use strict';
+
+  // --- client.js (web) ---
+  class PolliClientWeb {
+    constructor({ referrer = inferReferrer(), imageBase = 'https://image.pollinations.ai', textBase = 'https://text.pollinations.ai', timeoutMs = 60_000 } = {}) {
+      this.referrer = referrer;
+      this.imageBase = stripTrail(imageBase);
+      this.textBase = stripTrail(textBase);
+      this.timeoutMs = timeoutMs;
+    }
+    _addReferrer(u, params) {
+      const hasRefParam = params && Object.prototype.hasOwnProperty.call(params, 'referrer');
+      if (!hasRefParam && this.referrer) u.searchParams.set('referrer', this.referrer);
+      else if (hasRefParam && params.referrer) u.searchParams.set('referrer', params.referrer);
+    }
+    async get(url, { params = {}, headers = {}, stream = false } = {}) {
+      const u = new URL(url);
+      for (const [k, v] of Object.entries(params)) if (v != null && k !== 'referrer') u.searchParams.set(k, String(v));
+      this._addReferrer(u, params);
+      const controller = new AbortController();
+      const id = setTimeout(() => controller.abort(), this.timeoutMs);
+      try { return await fetch(u.toString(), { method: 'GET', headers, signal: controller.signal }); }
+      finally { clearTimeout(id); }
+    }
+    async postJson(url, body, { headers = {}, stream = false } = {}) {
+      const controller = new AbortController();
+      const id = setTimeout(() => controller.abort(), this.timeoutMs);
+      const hdrs = { 'Content-Type': 'application/json' };
+      Object.assign(hdrs, headers);
+      const payload = { ...(body || {}) };
+      if (this.referrer && payload.referrer == null) payload.referrer = this.referrer;
+      try { return await fetch(url, { method: 'POST', headers: hdrs, body: JSON.stringify(payload), signal: controller.signal }); }
+      finally { clearTimeout(id); }
+    }
+  }
+  function inferReferrer() { try { if (typeof window !== 'undefined' && window.location && window.location.origin) return window.location.origin; } catch {} return null; }
+  function stripTrail(s) { return s && s.endsWith('/') ? s.slice(0, -1) : s; }
+  let defaultClient = null;
+  function getDefaultClient() { return defaultClient ?? (defaultClient = new PolliClientWeb()); }
+  function setDefaultClient(c) { defaultClient = c; }
+
+  // --- sse.js ---
+  async function* sseEvents(response) {
+    const reader = response.body.getReader();
+    const decoder = new TextDecoder();
+    let buffer = '';
+    let eventLines = [];
+    while (true) {
+      const { value, done } = await reader.read();
+      if (done) break;
+      buffer += decoder.decode(value, { stream: true });
+      let idx;
+      while ((idx = buffer.indexOf('\n')) >= 0) {
+        const line = buffer.slice(0, idx).replace(/\r$/, '');
+        buffer = buffer.slice(idx + 1);
+        if (line === '') {
+          if (eventLines.length) {
+            const data = eventLines.filter(l => l.startsWith('data:')).map(l => l.slice(5).trimStart()).join('\n');
+            eventLines = [];
+            if (data) yield data;
+          }
+        } else eventLines.push(line);
+      }
+    }
+    if (eventLines.length) {
+      const data = eventLines.filter(l => l.startsWith('data:')).map(l => l.slice(5).trimStart()).join('\n');
+      if (data) yield data;
+    }
+  }
+
+  // --- helpers ---
+  const bool = v => (v == null ? undefined : (v ? 'true' : 'false'));
+  function base64FromArrayBuffer(ab) {
+    const bytes = new Uint8Array(ab);
+    let binary = '';
+    const chunk = 0x8000;
+    for (let i = 0; i < bytes.length; i += chunk) {
+      const sub = bytes.subarray(i, i + chunk);
+      binary += String.fromCharCode.apply(null, sub);
+    }
+    return btoa(binary);
+  }
+
+  // --- image.js ---
+  async function image(prompt, { model, seed, width, height, image: imgUrl, nologo, private: priv, enhance, safe, referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.imageBase}/prompt/${encodeURIComponent(prompt)}`;
+    const params = {};
+    if (model) params.model = model;
+    if (seed != null) params.seed = seed;
+    if (width != null) params.width = width;
+    if (height != null) params.height = height;
+    if (imgUrl) params.image = imgUrl;
+    if (nologo != null) params.nologo = bool(nologo);
+    if (priv != null) params.private = bool(priv);
+    if (enhance != null) params.enhance = bool(enhance);
+    if (safe != null) params.safe = bool(safe);
+    if (referrer) params.referrer = referrer;
+    const r = await client.get(url, { params });
+    if (!r.ok) throw new Error(`image error ${r.status}`);
+    return await r.blob();
+  }
+  async function imageModels(client = getDefaultClient()) {
+    const r = await client.get(`${client.imageBase}/models`);
+    if (!r.ok) throw new Error(`imageModels error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- text.js ---
+  async function text(prompt, { model, seed, temperature, top_p, presence_penalty, frequency_penalty, json, system, stream, private: priv, referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.textBase}/${encodeURIComponent(prompt)}`;
+    const params = {};
+    if (model) params.model = model;
+    if (seed != null) params.seed = seed;
+    if (temperature != null) params.temperature = temperature;
+    if (top_p != null) params.top_p = top_p;
+    if (presence_penalty != null) params.presence_penalty = presence_penalty;
+    if (frequency_penalty != null) params.frequency_penalty = frequency_penalty;
+    if (json) params.json = 'true';
+    if (system) params.system = system;
+    if (priv != null) params.private = !!priv;
+    if (referrer) params.referrer = referrer;
+    if (stream) {
+      params.stream = 'true';
+      const r = await client.get(url, { params, headers: { 'Accept': 'text/event-stream' } });
+      if (!r.ok) throw new Error(`text(stream) error ${r.status}`);
+      return (async function* () { for await (const data of sseEvents(r)) { if (String(data).trim() === '[DONE]') break; yield data; } })();
+    } else {
+      const r = await client.get(url, { params });
+      if (!r.ok) throw new Error(`text error ${r.status}`);
+      return await r.text();
+    }
+  }
+  async function chat({ model, messages, seed, temperature, top_p, presence_penalty, frequency_penalty, max_tokens, stream, private: priv, tools, tool_choice, referrer }, client = getDefaultClient()) {
+    const url = `${client.textBase}/openai`;
+    const body = { model, messages };
+    if (seed != null) body.seed = seed;
+    if (temperature != null) body.temperature = temperature;
+    if (top_p != null) body.top_p = top_p;
+    if (presence_penalty != null) body.presence_penalty = presence_penalty;
+    if (frequency_penalty != null) body.frequency_penalty = frequency_penalty;
+    if (max_tokens != null) body.max_tokens = max_tokens;
+    if (priv != null) body.private = !!priv;
+    if (tools) body.tools = tools;
+    if (tool_choice) body.tool_choice = tool_choice;
+    if (referrer) body.referrer = referrer;
+    if (stream) {
+      body.stream = true;
+      const r = await client.postJson(url, body, { headers: { 'Accept': 'text/event-stream' } });
+      if (!r.ok) throw new Error(`chat(stream) error ${r.status}`);
+      return (async function* () { for await (const data of sseEvents(r)) { if (String(data).trim() === '[DONE]') break; yield JSON.parse(data); } })();
+    } else {
+      const r = await client.postJson(url, body);
+      if (!r.ok) throw new Error(`chat error ${r.status}`);
+      return await r.json();
+    }
+  }
+  async function textModels(client = getDefaultClient()) {
+    const r = await client.get(`${client.textBase}/models`);
+    if (!r.ok) throw new Error(`textModels error ${r.status}`);
+    return await r.json();
+  }
+  async function search(query, model = 'searchgpt', client = getDefaultClient()) { return await text(query, { model }, client); }
+
+  // --- audio.js ---
+  async function tts(t, { voice, model = 'openai-audio', referrer } = {}, client = getDefaultClient()) {
+    const url = `${client.textBase}/${encodeURIComponent(t)}`;
+    const params = { model };
+    if (voice) params.voice = voice;
+    if (referrer) params.referrer = referrer;
+    const r = await client.get(url, { params });
+    if (!r.ok) throw new Error(`tts error ${r.status}`);
+    return await r.blob();
+  }
+  async function stt({ file, data, format, question }, client = getDefaultClient()) {
+    if (!file && !data) throw new Error("Provide either 'file' or 'data'");
+    if (!format && file) {
+      if (file.type && file.type.startsWith('audio/')) format = file.type.split('/')[1];
+      else if (file.name && file.name.includes('.')) format = file.name.split('.').pop().toLowerCase();
+    }
+    if (!format) throw new Error("Audio 'format' is required (e.g., 'mp3' or 'wav')");
+    const bytes = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+    const b64 = base64FromArrayBuffer(bytes);
+    const body = { model: 'openai-audio', messages: [{ role: 'user', content: [{ type: 'text', text: question ?? 'Transcribe this audio' }, { type: 'input_audio', input_audio: { data: b64, format } }] }] };
+    const r = await client.postJson(`${client.textBase}/openai`, body);
+    if (!r.ok) throw new Error(`stt error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- vision.js ---
+  async function vision({ imageUrl, file, data, imageFormat, question, model = 'openai', max_tokens } = {}, client = getDefaultClient()) {
+    if (!imageUrl && !file && !data) throw new Error('Provide imageUrl or file/data');
+    if (!imageUrl) {
+      const ab = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+      if (!imageFormat) { if (file?.type?.startsWith('image/')) imageFormat = file.type.split('/')[1]; else throw new Error('imageFormat is required when providing raw bytes'); }
+      const b64 = base64FromArrayBuffer(ab);
+      imageUrl = `data:image/${imageFormat};base64,${b64}`;
+    }
+    const payload = { model, messages: [{ role: 'user', content: [{ type: 'text', text: question ?? 'Describe this image:' }, { type: 'image_url', image_url: { url: imageUrl } }] }] };
+    if (max_tokens != null) payload.max_tokens = max_tokens;
+    const r = await client.postJson(`${client.textBase}/openai`, payload);
+    if (!r.ok) throw new Error(`vision error ${r.status}`);
+    return await r.json();
+  }
+
+  // --- feeds.js ---
+  async function* imageFeed({ limit } = {}, client = getDefaultClient()) {
+    const r = await client.get(`${client.imageBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`imageFeed error ${r.status}`);
+    let count = 0;
+    for await (const data of sseEvents(r)) { try { const obj = JSON.parse(data); yield obj; if (limit != null && ++count >= limit) break; } catch {} }
+  }
+  async function* textFeed({ limit } = {}, client = getDefaultClient()) {
+    const r = await client.get(`${client.textBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`textFeed error ${r.status}`);
+    let count = 0;
+    for await (const data of sseEvents(r)) { try { const obj = JSON.parse(data); yield obj; if (limit != null && ++count >= limit) break; } catch {} }
+  }
+
+  // --- tools.js ---
+  function functionTool(name, description, parameters) { return { type: 'function', function: { name, description, parameters } }; }
+  class ToolBox { constructor() { this.map = new Map(); } register(n, fn) { this.map.set(n, fn); return this; } get(n) { return this.map.get(n); } }
+  async function chatWithTools({ client, model, messages, tools, toolbox, maxRounds = 3, tool_choice }) {
+    const history = [...messages];
+    for (let round = 0; round <= maxRounds; round++) {
+      const resp = await chat({ model, messages: history, tools, tool_choice }, client);
+      const choice = (resp.choices?.[0]?.message) ?? {}; const toolCalls = choice.tool_calls ?? [];
+      if (!toolCalls.length) return resp;
+      history.push({ role: 'assistant', tool_calls: toolCalls });
+      for (const tc of toolCalls) {
+        const fname = tc.function?.name; let args = {}; try { args = JSON.parse(tc.function?.arguments ?? '{}'); } catch {}
+        const fn = toolbox.get(fname); if (!fn) return resp; const out = await fn(args);
+        history.push({ role: 'tool', tool_call_id: tc.id, name: fname, content: typeof out === 'string' ? out : JSON.stringify(out) });
+      }
+    }
+    return await chat({ model, messages: history }, client);
+  }
+
+  // --- mcp.js (web) ---
+  function serverName() { return 'pollinations-multimodal-api'; }
+  function toolDefinitions() {
+    return { name: serverName(), tools: [
+      { name: 'generateImageUrl', description: 'Generate an image and return its URL', parameters: { type: 'object', properties: { prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' }, nologo: { type: 'boolean' }, private: { type: 'boolean' } }, required: ['prompt'] } },
+      { name: 'generateImage', description: 'Generate an image and return base64', parameters: { type: 'object', properties: { prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' } }, required: ['prompt'] } },
+      { name: 'listImageModels', description: 'List available image models', parameters: { type: 'object', properties: {} } },
+      { name: 'respondAudio', description: 'Generate TTS audio (voice) from text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'sayText', description: 'Speak the provided text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'listAudioVoices', description: 'List available voices', parameters: { type: 'object', properties: {} } },
+      { name: 'listTextModels', description: 'List text & multimodal models', parameters: { type: 'object', properties: {} } },
+      { name: 'listModels', description: 'List models by kind', parameters: { type: 'object', properties: { kind: { type: 'string', enum: ['image','text','audio'] } } } },
+    ] };
+  }
+  function generateImageUrl(client, params) {
+    const { prompt, ...rest } = params; const u = new URL(`${client.imageBase}/prompt/${encodeURIComponent(prompt)}`);
+    for (const [k, v] of Object.entries(rest)) if (v != null) u.searchParams.set(k, String(v));
+    if (client.referrer && !u.searchParams.has('referrer')) u.searchParams.set('referrer', client.referrer);
+    return u.toString();
+  }
+  async function generateImageBase64(client, params) {
+    const blob = await image(params.prompt, params, client);
+    const ab = await blob.arrayBuffer(); const bytes = new Uint8Array(ab);
+    let binary = ''; const chunk = 0x8000; for (let i = 0; i < bytes.length; i += chunk) { const sub = bytes.subarray(i, i + chunk); binary += String.fromCharCode.apply(null, sub); }
+    return btoa(binary);
+  }
+  async function listImageModels(client) { return await imageModels(client); }
+  async function listTextModels(client) { return await textModels(client); }
+  async function listAudioVoices(client) { const models = await textModels(client); return models?.['openai-audio']?.voices ?? []; }
+
+  // --- pipeline.js ---
+  class Context extends Map {}
+  class Pipeline { constructor() { this.steps = []; } step(s) { this.steps.push(s); return this; } async execute({ client, context = new Context() } = {}) { for (const s of this.steps) await s.run({ client, context }); return context; } }
+  class TextGetStep { constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; } async run({ client, context }) { const v = await text(prompt, this.params, client); context.set(this.outKey, v); } }
+  // Fix: use this.prompt inside run
+  TextGetStep.prototype.run = async function ({ client, context }) { const v = await text(this.prompt, this.params, client); context.set(this.outKey, v); };
+  class ImageStep { constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; } async run({ client, context }) { const blob = await image(this.prompt, this.params, client); context.set(this.outKey, { blob }); } }
+  class TtsStep { constructor({ text: t, outKey, params = {} }) { this.text = t; this.outKey = outKey; this.params = params; } async run({ client, context }) { const blob = await tts(this.text, this.params, client); context.set(this.outKey, { blob }); } }
+  class VisionUrlStep { constructor({ imageUrl, outKey, question, params = {} }) { this.imageUrl = imageUrl; this.outKey = outKey; this.params = { question, ...params }; } async run({ client, context }) { const v = await vision({ imageUrl: this.imageUrl, ...this.params }, client); context.set(this.outKey, v); } }
+
+  // --- top-level API ---
+  function configure({ referrer = undefined, imageBase = 'https://image.pollinations.ai', textBase = 'https://text.pollinations.ai', timeoutMs = 60_000 } = {}) {
+    setDefaultClient(new PolliClientWeb({ referrer, imageBase, textBase, timeoutMs }));
+  }
+
+  const api = {
+    configure,
+    image, text, chat, search, tts, stt, vision,
+    imageModels, textModels, imageFeed, textFeed,
+    tools: { functionTool, ToolBox, chatWithTools },
+    mcp: { serverName, toolDefinitions, generateImageUrl, generateImageBase64, listImageModels, listTextModels, listAudioVoices },
+    pipeline: { Context, Pipeline, TextGetStep, ImageStep, TtsStep, VisionUrlStep },
+    PolliClientWeb,
+  };
+
+  g.polliLib = api;
+
+})(typeof globalThis !== 'undefined' ? globalThis : (typeof self !== 'undefined' ? self : this));
+
+
diff --git a/js/polliLib/src/audio.js b/js/polliLib/src/audio.js
new file mode 100644
index 0000000..dfb0a96
--- /dev/null
+++ b/js/polliLib/src/audio.js
@@ -0,0 +1,47 @@
+import { getDefaultClient } from './client.js';
+
+export async function tts(text, { voice, model = 'openai-audio', referrer } = {}, client = getDefaultClient()) {
+  const url = `${client.textBase}/${encodeURIComponent(text)}`;
+  const params = { model };
+  if (voice) params.voice = voice;
+  if (referrer) params.referrer = referrer;
+  const r = await client.get(url, { params });
+  if (!r.ok) throw new Error(`tts error ${r.status}`);
+  return await r.blob();
+}
+
+export async function stt({ file, data, format, question }, client = getDefaultClient()) {
+  if (!file && !data) throw new Error("Provide either 'file' or 'data'");
+  if (!format && file) {
+    if (file.type && file.type.startsWith('audio/')) format = file.type.split('/')[1];
+    else if (file.name && file.name.includes('.')) format = file.name.split('.').pop().toLowerCase();
+  }
+  if (!format) throw new Error("Audio 'format' is required (e.g., 'mp3' or 'wav')");
+  const bytes = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+  const b64 = base64FromArrayBuffer(bytes);
+  const body = {
+    model: 'openai-audio',
+    messages: [{
+      role: 'user',
+      content: [
+        { type: 'text', text: question ?? 'Transcribe this audio' },
+        { type: 'input_audio', input_audio: { data: b64, format } },
+      ],
+    }],
+  };
+  const r = await client.postJson(`${client.textBase}/openai`, body);
+  if (!r.ok) throw new Error(`stt error ${r.status}`);
+  return await r.json();
+}
+
+function base64FromArrayBuffer(ab) {
+  const bytes = new Uint8Array(ab);
+  let binary = '';
+  const chunk = 0x8000;
+  for (let i = 0; i < bytes.length; i += chunk) {
+    const sub = bytes.subarray(i, i + chunk);
+    binary += String.fromCharCode.apply(null, sub);
+  }
+  return btoa(binary);
+}
+
diff --git a/js/polliLib/src/client.js b/js/polliLib/src/client.js
new file mode 100644
index 0000000..e3cd9e2
--- /dev/null
+++ b/js/polliLib/src/client.js
@@ -0,0 +1,64 @@
+// Browsers do not allow setting a custom `User-Agent` header, so
+// PolliClientWeb relies on the default browser user agent.
+export class PolliClientWeb {
+  constructor({
+    referrer = inferReferrer(),
+    imageBase = 'https://image.pollinations.ai',
+    textBase = 'https://text.pollinations.ai',
+    timeoutMs = 60_000,
+  } = {}) {
+    this.referrer = referrer;
+    this.imageBase = stripTrail(imageBase);
+    this.textBase = stripTrail(textBase);
+    this.timeoutMs = timeoutMs;
+  }
+
+  _addReferrer(u, params) {
+    const hasRefParam = params && Object.prototype.hasOwnProperty.call(params, 'referrer');
+    if (!hasRefParam && this.referrer) {
+      u.searchParams.set('referrer', this.referrer);
+    } else if (hasRefParam && params.referrer) {
+      u.searchParams.set('referrer', params.referrer);
+    }
+  }
+
+  async get(url, { params = {}, headers = {}, stream = false } = {}) {
+    const u = new URL(url);
+    for (const [k, v] of Object.entries(params)) {
+      if (v != null && k !== 'referrer') u.searchParams.set(k, String(v));
+    }
+    this._addReferrer(u, params);
+    const final = u.toString();
+    const controller = new AbortController();
+    const id = setTimeout(() => controller.abort(), this.timeoutMs);
+    try {
+      return await fetch(final, { method: 'GET', headers, signal: controller.signal });
+    } finally { clearTimeout(id); }
+  }
+
+  async postJson(url, body, { headers = {}, stream = false } = {}) {
+    const controller = new AbortController();
+    const id = setTimeout(() => controller.abort(), this.timeoutMs);
+    const hdrs = { 'Content-Type': 'application/json' };
+    Object.assign(hdrs, headers);
+    const payload = { ...(body || {}) };
+    if (this.referrer && payload.referrer == null) payload.referrer = this.referrer;
+    try {
+      return await fetch(url, { method: 'POST', headers: hdrs, body: JSON.stringify(payload), signal: controller.signal });
+    } finally { clearTimeout(id); }
+  }
+}
+
+function inferReferrer() {
+  try {
+    if (typeof window !== 'undefined' && window.location && window.location.origin) return window.location.origin;
+  } catch {}
+  return null;
+}
+
+function stripTrail(s) { return s.endsWith('/') ? s.slice(0, -1) : s; }
+
+export let defaultClient = null;
+export function getDefaultClient() { return defaultClient ??= new PolliClientWeb(); }
+export function setDefaultClient(c) { defaultClient = c; }
+
diff --git a/js/polliLib/src/feeds.js b/js/polliLib/src/feeds.js
new file mode 100644
index 0000000..150d4fa
--- /dev/null
+++ b/js/polliLib/src/feeds.js
@@ -0,0 +1,29 @@
+import { getDefaultClient } from './client.js';
+import { sseEvents } from './sse.js';
+
+export async function* imageFeed({ limit } = {}, client = getDefaultClient()) {
+  const r = await client.get(`${client.imageBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+  if (!r.ok) throw new Error(`imageFeed error ${r.status}`);
+  let count = 0;
+  for await (const data of sseEvents(r)) {
+    try {
+      const obj = JSON.parse(data);
+      yield obj;
+      if (limit != null && ++count >= limit) break;
+    } catch { /* ignore */ }
+  }
+}
+
+export async function* textFeed({ limit } = {}, client = getDefaultClient()) {
+  const r = await client.get(`${client.textBase}/feed`, { headers: { 'Accept': 'text/event-stream' } });
+  if (!r.ok) throw new Error(`textFeed error ${r.status}`);
+  let count = 0;
+  for await (const data of sseEvents(r)) {
+    try {
+      const obj = JSON.parse(data);
+      yield obj;
+      if (limit != null && ++count >= limit) break;
+    } catch { /* ignore */ }
+  }
+}
+
diff --git a/js/polliLib/src/image.js b/js/polliLib/src/image.js
new file mode 100644
index 0000000..adae2e0
--- /dev/null
+++ b/js/polliLib/src/image.js
@@ -0,0 +1,31 @@
+import { getDefaultClient } from './client.js';
+
+const bool = v => (v == null ? undefined : (v ? 'true' : 'false'));
+
+export async function image(prompt, {
+  model, seed, width, height, image, nologo, private: priv, enhance, safe, referrer,
+} = {}, client = getDefaultClient()) {
+  const url = `${client.imageBase}/prompt/${encodeURIComponent(prompt)}`;
+  const params = {};
+  if (model) params.model = model;
+  if (seed != null) params.seed = seed;
+  if (width != null) params.width = width;
+  if (height != null) params.height = height;
+  if (image) params.image = image;
+  if (nologo != null) params.nologo = bool(nologo);
+  if (priv != null) params.private = bool(priv);
+  if (enhance != null) params.enhance = bool(enhance);
+  if (safe != null) params.safe = bool(safe);
+  if (referrer) params.referrer = referrer;
+
+  const r = await client.get(url, { params });
+  if (!r.ok) throw new Error(`image error ${r.status}`);
+  return await r.blob();
+}
+
+export async function imageModels(client = getDefaultClient()) {
+  const r = await client.get(`${client.imageBase}/models`);
+  if (!r.ok) throw new Error(`imageModels error ${r.status}`);
+  return await r.json();
+}
+
diff --git a/js/polliLib/src/mcp.js b/js/polliLib/src/mcp.js
new file mode 100644
index 0000000..ce1b8ff
--- /dev/null
+++ b/js/polliLib/src/mcp.js
@@ -0,0 +1,61 @@
+import { image as imageGen } from './image.js';
+import { imageModels as listImage } from './image.js';
+import { textModels as listText } from './text.js';
+
+export function serverName() { return 'pollinations-multimodal-api'; }
+
+export function toolDefinitions() {
+  return {
+    name: serverName(),
+    tools: [
+      { name: 'generateImageUrl', description: 'Generate an image and return its URL', parameters: {
+        type: 'object', properties: {
+          prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' }, nologo: { type: 'boolean' }, private: { type: 'boolean' }
+        }, required: ['prompt'] } },
+      { name: 'generateImage', description: 'Generate an image and return base64', parameters: {
+        type: 'object', properties: { prompt: { type: 'string' }, model: { type: 'string' }, seed: { type: 'integer' }, width: { type: 'integer' }, height: { type: 'integer' } }, required: ['prompt'] } },
+      { name: 'listImageModels', description: 'List available image models', parameters: { type: 'object', properties: {} } },
+      { name: 'respondAudio', description: 'Generate TTS audio (voice) from text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'sayText', description: 'Speak the provided text', parameters: { type: 'object', properties: { text: { type: 'string' }, voice: { type: 'string' } }, required: ['text'] } },
+      { name: 'listAudioVoices', description: 'List available voices', parameters: { type: 'object', properties: {} } },
+      { name: 'listTextModels', description: 'List text & multimodal models', parameters: { type: 'object', properties: {} } },
+      { name: 'listModels', description: 'List models by kind', parameters: { type: 'object', properties: { kind: { type: 'string', enum: ['image','text','audio'] } } } },
+    ]
+  };
+}
+
+export function generateImageUrl(client, params) {
+  const { prompt, ...rest } = params;
+  const u = new URL(`${client.imageBase}/prompt/${encodeURIComponent(prompt)}`);
+  for (const [k, v] of Object.entries(rest)) if (v != null) u.searchParams.set(k, String(v));
+  if (client.referrer && !u.searchParams.has('referrer')) u.searchParams.set('referrer', client.referrer);
+  return u.toString();
+}
+
+export async function generateImageBase64(client, params) {
+  const blob = await imageGen(params.prompt, params, client);
+  const base64 = await blobToBase64(blob);
+  return base64;
+}
+
+export async function listImageModels(client) { return await listImage(client); }
+export async function listTextModels(client) { return await listText(client); }
+
+export async function listAudioVoices(client) {
+  const models = await listText(client);
+  const voices = models?.['openai-audio']?.voices ?? [];
+  return voices;
+}
+
+async function blobToBase64(blob) {
+  const ab = await blob.arrayBuffer();
+  const bytes = new Uint8Array(ab);
+  let binary = '';
+  const chunk = 0x8000;
+  for (let i = 0; i < bytes.length; i += chunk) {
+    const sub = bytes.subarray(i, i + chunk);
+    binary += String.fromCharCode.apply(null, sub);
+  }
+  return btoa(binary);
+}
+
diff --git a/js/polliLib/src/pipeline.js b/js/polliLib/src/pipeline.js
new file mode 100644
index 0000000..ba9d1d7
--- /dev/null
+++ b/js/polliLib/src/pipeline.js
@@ -0,0 +1,36 @@
+import { text as textGet } from './text.js';
+import { image as imageGen } from './image.js';
+import { tts as ttsGen } from './audio.js';
+import { vision as visionAnalyze } from './vision.js';
+
+export class Context extends Map {}
+
+export class Pipeline {
+  constructor() { this.steps = []; }
+  step(s) { this.steps.push(s); return this; }
+  async execute({ client, context = new Context() } = {}) {
+    for (const s of this.steps) await s.run({ client, context });
+    return context;
+  }
+}
+
+export class TextGetStep {
+  constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; }
+  async run({ client, context }) { const v = await textGet(this.prompt, this.params, client); context.set(this.outKey, v); }
+}
+
+export class ImageStep {
+  constructor({ prompt, outKey, params = {} }) { this.prompt = prompt; this.outKey = outKey; this.params = params; }
+  async run({ client, context }) { const blob = await imageGen(this.prompt, this.params, client); context.set(this.outKey, { blob }); }
+}
+
+export class TtsStep {
+  constructor({ text, outKey, params = {} }) { this.text = text; this.outKey = outKey; this.params = params; }
+  async run({ client, context }) { const blob = await ttsGen(this.text, this.params, client); context.set(this.outKey, { blob }); }
+}
+
+export class VisionUrlStep {
+  constructor({ imageUrl, outKey, question, params = {} }) { this.imageUrl = imageUrl; this.outKey = outKey; this.params = { question, ...params }; }
+  async run({ client, context }) { const v = await visionAnalyze({ imageUrl: this.imageUrl, ...this.params }, client); context.set(this.outKey, v); }
+}
+
diff --git a/js/polliLib/src/sse.js b/js/polliLib/src/sse.js
new file mode 100644
index 0000000..8b49897
--- /dev/null
+++ b/js/polliLib/src/sse.js
@@ -0,0 +1,37 @@
+// Minimal SSE parser for fetch(Response).body (ReadableStream)
+export async function* sseEvents(response) {
+  const reader = response.body.getReader();
+  const decoder = new TextDecoder();
+  let buffer = '';
+  let eventLines = [];
+  while (true) {
+    const { value, done } = await reader.read();
+    if (done) break;
+    buffer += decoder.decode(value, { stream: true });
+    let idx;
+    while ((idx = buffer.indexOf('\n')) >= 0) {
+      const line = buffer.slice(0, idx).replace(/\r$/, '');
+      buffer = buffer.slice(idx + 1);
+      if (line === '') {
+        if (eventLines.length) {
+          const data = eventLines
+            .filter(l => l.startsWith('data:'))
+            .map(l => l.slice(5).trimStart())
+            .join('\n');
+          eventLines = [];
+          if (data) yield data;
+        }
+      } else {
+        eventLines.push(line);
+      }
+    }
+  }
+  if (eventLines.length) {
+    const data = eventLines
+      .filter(l => l.startsWith('data:'))
+      .map(l => l.slice(5).trimStart())
+      .join('\n');
+    if (data) yield data;
+  }
+}
+
diff --git a/js/polliLib/src/text.js b/js/polliLib/src/text.js
new file mode 100644
index 0000000..d2fa713
--- /dev/null
+++ b/js/polliLib/src/text.js
@@ -0,0 +1,77 @@
+import { getDefaultClient } from './client.js';
+import { sseEvents } from './sse.js';
+
+export async function text(prompt, {
+  model, seed, temperature, top_p, presence_penalty, frequency_penalty, json, system, stream, private: priv, referrer,
+} = {}, client = getDefaultClient()) {
+  const url = `${client.textBase}/${encodeURIComponent(prompt)}`;
+  const params = {};
+  if (model) params.model = model;
+  if (seed != null) params.seed = seed;
+  if (temperature != null) params.temperature = temperature;
+  if (top_p != null) params.top_p = top_p;
+  if (presence_penalty != null) params.presence_penalty = presence_penalty;
+  if (frequency_penalty != null) params.frequency_penalty = frequency_penalty;
+  if (json) params.json = 'true';
+  if (system) params.system = system;
+  if (priv != null) params.private = !!priv;
+  if (referrer) params.referrer = referrer;
+
+  if (stream) {
+    params.stream = 'true';
+    const r = await client.get(url, { params, headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`text(stream) error ${r.status}`);
+    return (async function* () {
+      for await (const data of sseEvents(r)) {
+        if (String(data).trim() === '[DONE]') break;
+        yield data;
+      }
+    })();
+  } else {
+    const r = await client.get(url, { params });
+    if (!r.ok) throw new Error(`text error ${r.status}`);
+    return await r.text();
+  }
+}
+
+export async function chat({ model, messages, seed, temperature, top_p, presence_penalty, frequency_penalty, max_tokens, stream, private: priv, tools, tool_choice, referrer }, client = getDefaultClient()) {
+  const url = `${client.textBase}/openai`;
+  const body = { model, messages };
+  if (seed != null) body.seed = seed;
+  if (temperature != null) body.temperature = temperature;
+  if (top_p != null) body.top_p = top_p;
+  if (presence_penalty != null) body.presence_penalty = presence_penalty;
+  if (frequency_penalty != null) body.frequency_penalty = frequency_penalty;
+  if (max_tokens != null) body.max_tokens = max_tokens;
+  if (priv != null) body.private = !!priv;
+  if (tools) body.tools = tools;
+  if (tool_choice) body.tool_choice = tool_choice;
+  if (referrer) body.referrer = referrer;
+
+  if (stream) {
+    body.stream = true;
+    const r = await client.postJson(url, body, { headers: { 'Accept': 'text/event-stream' } });
+    if (!r.ok) throw new Error(`chat(stream) error ${r.status}`);
+    return (async function* () {
+      for await (const data of sseEvents(r)) {
+        if (String(data).trim() === '[DONE]') break;
+        yield JSON.parse(data);
+      }
+    })();
+  } else {
+    const r = await client.postJson(url, body);
+    if (!r.ok) throw new Error(`chat error ${r.status}`);
+    return await r.json();
+  }
+}
+
+export async function textModels(client = getDefaultClient()) {
+  const r = await client.get(`${client.textBase}/models`);
+  if (!r.ok) throw new Error(`textModels error ${r.status}`);
+  return await r.json();
+}
+
+export async function search(query, model = 'searchgpt', client = getDefaultClient()) {
+  return await text(query, { model }, client);
+}
+
diff --git a/js/polliLib/src/tools.js b/js/polliLib/src/tools.js
new file mode 100644
index 0000000..09ade5e
--- /dev/null
+++ b/js/polliLib/src/tools.js
@@ -0,0 +1,35 @@
+import { chat as chatPost } from './text.js';
+
+export function functionTool(name, description, parameters) {
+  return { type: 'function', function: { name, description, parameters } };
+}
+
+export class ToolBox {
+  constructor() { this.map = new Map(); }
+  register(name, fn) { this.map.set(name, fn); return this; }
+  get(name) { return this.map.get(name); }
+}
+
+export async function chatWithTools({ client, model, messages, tools, toolbox, maxRounds = 3, tool_choice }) {
+  const history = [...messages];
+  for (let round = 0; round <= maxRounds; round++) {
+    const resp = await chatPost({ model, messages: history, tools, tool_choice }, client);
+    const choice = (resp.choices?.[0]?.message) ?? {};
+    const toolCalls = choice.tool_calls ?? [];
+    if (!toolCalls.length) return resp;
+
+    history.push({ role: 'assistant', tool_calls: toolCalls });
+
+    for (const tc of toolCalls) {
+      const fname = tc.function?.name;
+      let args = {};
+      try { args = JSON.parse(tc.function?.arguments ?? '{}'); } catch {}
+      const fn = toolbox.get(fname);
+      if (!fn) return resp;
+      const out = await fn(args);
+      history.push({ role: 'tool', tool_call_id: tc.id, name: fname, content: typeof out === 'string' ? out : JSON.stringify(out) });
+    }
+  }
+  return await chatPost({ model, messages: history }, client);
+}
+
diff --git a/js/polliLib/src/vision.js b/js/polliLib/src/vision.js
new file mode 100644
index 0000000..ce455b4
--- /dev/null
+++ b/js/polliLib/src/vision.js
@@ -0,0 +1,40 @@
+import { getDefaultClient } from './client.js';
+
+export async function vision({ imageUrl, file, data, imageFormat, question, model = 'openai', max_tokens } = {}, client = getDefaultClient()) {
+  if (!imageUrl && !file && !data) throw new Error('Provide imageUrl or file/data');
+  if (!imageUrl) {
+    const ab = file ? await file.arrayBuffer() : (data instanceof ArrayBuffer ? data : (data?.buffer ?? data));
+    if (!imageFormat) {
+      if (file?.type?.startsWith('image/')) imageFormat = file.type.split('/')[1];
+      else throw new Error('imageFormat is required when providing raw bytes');
+    }
+    const b64 = base64FromArrayBuffer(ab);
+    imageUrl = `data:image/${imageFormat};base64,${b64}`;
+  }
+  const payload = {
+    model,
+    messages: [{
+      role: 'user',
+      content: [
+        { type: 'text', text: question ?? 'Describe this image:' },
+        { type: 'image_url', image_url: { url: imageUrl } },
+      ],
+    }],
+  };
+  if (max_tokens != null) payload.max_tokens = max_tokens;
+  const r = await client.postJson(`${client.textBase}/openai`, payload);
+  if (!r.ok) throw new Error(`vision error ${r.status}`);
+  return await r.json();
+}
+
+function base64FromArrayBuffer(ab) {
+  const bytes = new Uint8Array(ab);
+  let binary = '';
+  const chunk = 0x8000;
+  for (let i = 0; i < bytes.length; i += chunk) {
+    const sub = bytes.subarray(i, i + chunk);
+    binary += String.fromCharCode.apply(null, sub);
+  }
+  return btoa(binary);
+}
+
diff --git a/tests/pollilib-smoke.mjs b/tests/pollilib-smoke.mjs
index f8bb7c8..50aba31 100644
--- a/tests/pollilib-smoke.mjs
+++ b/tests/pollilib-smoke.mjs
@@ -159,7 +159,7 @@ await step('pipeline end-to-end', async () => {
 await step('index.html contains critical tags', async () => {
   const p = path.join(process.cwd(), 'index.html');
   const html = await fs.readFile(p, 'utf8');
-  const checks = [ 'polliLib/polliLib-web.global.js', 'js/chat/chat-core.js', 'js/chat/chat-init.js', 'id="chat-box"' ];
+  const checks = [ 'js/polliLib/polliLib-web.global.js', 'js/chat/chat-core.js', 'js/chat/chat-init.js', 'id="chat-box"' ];
   const missing = checks.filter(s => !html.includes(s));
   if (missing.length) throw new Error('missing: ' + missing.join(', '));
   return 'tags ok';

From 9161c3a1e2e33b2d1c4b9b20f3ed7245a5da53d0 Mon Sep 17 00:00:00 2001
From: Hackall <36754621+hackall360@users.noreply.github.com>
Date: Sat, 13 Sep 2025 11:14:23 -0700
Subject: [PATCH 2/2] Point smoke test to js polliLib copy

---
 tests/pollilib-smoke.mjs | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/tests/pollilib-smoke.mjs b/tests/pollilib-smoke.mjs
index 50aba31..216bc54 100644
--- a/tests/pollilib-smoke.mjs
+++ b/tests/pollilib-smoke.mjs
@@ -1,18 +1,18 @@
 /*
   Non-blocking smoke tests for polliLib and minimal site structure.
   - Uses only Node 20 built-ins (no deps)
-  - Does not modify /polliLib; only imports from src
+  - Uses copy under /js/polliLib; does not modify original /polliLib
   - Intended to run in CI and summarize results
 */
 
-import { PolliClientWeb } from '../polliLib/src/client.js';
-import { text as textGet, chat, textModels, search } from '../polliLib/src/text.js';
-import { image, imageModels } from '../polliLib/src/image.js';
-import { tts } from '../polliLib/src/audio.js';
-import { vision } from '../polliLib/src/vision.js';
-import * as pipeline from '../polliLib/src/pipeline.js';
-import * as tools from '../polliLib/src/tools.js';
-import * as mcp from '../polliLib/src/mcp.js';
+import { PolliClientWeb } from '../js/polliLib/src/client.js';
+import { text as textGet, chat, textModels, search } from '../js/polliLib/src/text.js';
+import { image, imageModels } from '../js/polliLib/src/image.js';
+import { tts } from '../js/polliLib/src/audio.js';
+import { vision } from '../js/polliLib/src/vision.js';
+import * as pipeline from '../js/polliLib/src/pipeline.js';
+import * as tools from '../js/polliLib/src/tools.js';
+import * as mcp from '../js/polliLib/src/mcp.js';
 import fs from 'node:fs/promises';
 import path from 'node:path';