From 463712744c366ac6f935344b3a0f099e3ee1bbd4 Mon Sep 17 00:00:00 2001
From: oiupoyt <oiupoyt.cat@gmail.com>
Date: Sun, 20 Sep 2026 01:47:51 +0530
Subject: [PATCH] test: add Worker regression suite and fix the package
 entrypoint

Covers the missing-key 503, hasKey reporting, input validation without an
upstream call, the hazy-to-decisive override, upstream failures preserving
status plus fallback, and deterministic offline fallbacks.

Also points "main" at server.js, since index.js did not exist.
---
 package.json         |   5 +-
 test/worker.test.mjs | 111 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 114 insertions(+), 2 deletions(-)
 create mode 100644 test/worker.test.mjs

diff --git a/package.json b/package.json
index 42ab9fe..921d81b 100644
--- a/package.json
+++ b/package.json
@@ -2,9 +2,10 @@
   "name": "jev-8ball",
   "version": "1.0.0",
   "description": "",
-  "main": "index.js",
+  "main": "server.js",
   "scripts": {
-    "start": "node server.js"
+    "start": "node server.js",
+    "test": "node --test"
   },
   "keywords": [],
   "type": "commonjs",
diff --git a/test/worker.test.mjs b/test/worker.test.mjs
new file mode 100644
index 0000000..21182b1
--- /dev/null
+++ b/test/worker.test.mjs
@@ -0,0 +1,111 @@
+/**
+ * Regression tests for the Cloudflare Worker entrypoint.
+ * Run with: npm test
+ */
+import assert from 'node:assert/strict';
+import test from 'node:test';
+
+import worker from '../worker.mjs';
+
+const realFetch = globalThis.fetch;
+
+function ask(body) {
+  return new Request('https://oracle.test/api/ask', {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: typeof body === 'string' ? body : JSON.stringify(body)
+  });
+}
+
+function status() {
+  return new Request('https://oracle.test/api/status');
+}
+
+test.afterEach(() => {
+  globalThis.fetch = realFetch;
+});
+
+test('a missing key is reported instead of silently using a bundled one', async () => {
+  const response = await worker.fetch(ask({ question: 'Will it deploy?' }), {}, {});
+  assert.equal(response.status, 503);
+  assert.match((await response.json()).error, /not configured/i);
+});
+
+test('status reports hasKey straight from the environment', async () => {
+  const without = await worker.fetch(status(), {}, {});
+  assert.equal((await without.json()).hasKey, false);
+  const withKey = await worker.fetch(status(), { OPENROUTER_API_KEY: 'test-key' }, {});
+  assert.equal((await withKey.json()).hasKey, true);
+});
+
+test('invalid input is rejected before any upstream call', async () => {
+  const env = { OPENROUTER_API_KEY: 'test-key' };
+  globalThis.fetch = () => {
+    throw new Error('upstream must not be called');
+  };
+  assert.equal((await worker.fetch(ask('{ not json'), env, {})).status, 400);
+  assert.equal((await worker.fetch(ask({ question: '   ' }), env, {})).status, 400);
+  assert.equal((await worker.fetch(ask({}), env, {})).status, 400);
+});
+
+test('a decisive verdict replaces a hazy aphorism', async () => {
+  globalThis.fetch = async () =>
+    new Response(
+      JSON.stringify({
+        answers: {
+          favorable: { noul: 0.9 },
+          sentiment: { choice: 'neutral', confidence: 0.93, probabilities: { affirmative: 0.9 } },
+          aphorism: { choice: 'reply_hazy' }
+        },
+        usage: { cost: 0.000001 },
+        model: 'typesafe/jev-1.13'
+      }),
+      { status: 200 }
+    );
+
+  const response = await worker.fetch(
+    ask({ question: 'Will it deploy?' }),
+    { OPENROUTER_API_KEY: 'test-key' },
+    {}
+  );
+  assert.equal(response.status, 200);
+  assert.equal(response.headers.get('Access-Control-Allow-Origin'), '*');
+  const payload = await response.json();
+  assert.equal(payload.aphorismKey, 'certain');
+  assert.equal(payload.answer, 'It is certain.');
+  assert.equal(payload.sentiment, 'affirmative');
+  assert.equal(payload.noul, 0.9);
+  assert.equal(payload.offline, undefined);
+});
+
+test('an upstream failure keeps its status and still ships a usable fallback', async () => {
+  globalThis.fetch = async () => new Response('rate limited', { status: 429 });
+  const response = await worker.fetch(
+    ask({ question: 'Any luck?' }),
+    { OPENROUTER_API_KEY: 'test-key' },
+    {}
+  );
+  assert.equal(response.status, 429);
+  assert.equal(response.headers.get('Access-Control-Allow-Origin'), '*');
+  const payload = await response.json();
+  assert.equal(payload.error, 'OpenRouter decision error');
+  assert.ok(payload.fallback.answer);
+});
+
+test('a thrown upstream error becomes a deterministic offline fallback', async () => {
+  const env = { OPENROUTER_API_KEY: 'test-key' };
+  globalThis.fetch = async () => {
+    throw new Error('network down');
+  };
+  const realError = console.error;
+  console.error = () => {};
+  try {
+    const first = await (await worker.fetch(ask({ question: 'Any luck?' }), env, {})).json();
+    const second = await (await worker.fetch(ask({ question: 'Any luck?' }), env, {})).json();
+    assert.equal(first.offline, true);
+    assert.ok(first.answer);
+    assert.equal(first.answer, second.answer);
+  } finally {
+    console.error = realError;
+  }
+});