@nexus_js/connect - npm Package Compare versions

Comparing version 0.9.28 to 0.9.29

dist/sse.d.ts

@@ -15,7 +15,2 @@ /**
 export declare const CONNECT_PATH = "/_nexus/connect/";
-export interface ConnectSseOptions {
-    cors?: {
-        allowOrigin?: string;
-    };
-}
 /** Extract the topic name from a /_nexus/connect/:topic URL. */
@@ -29,3 +24,3 @@ export declare function topicFromUrl(url: URL): string;
  */
-export declare function handleSSERequest(request: Request, topic: string, opts?: ConnectSseOptions): Response;
+export declare function handleSSERequest(request: Request, topic: string): Response;
 /**
@@ -42,3 +37,3 @@ * Node.js adapter — writes SSE directly to a ServerResponse.
     end: () => void;
-}, topic: string, opts?: ConnectSseOptions): void;
+}, topic: string): void;
 //# sourceMappingURL=sse.d.ts.map

dist/sse.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"sse.d.ts","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AAKH,eAAO,MAAM,YAAY,qBAAqB,CAAC;AAE/C,MAAM,WAAW,iBAAiB;IAChC,IAAI,CAAC,EAAE;QACL,WAAW,CAAC,EAAE,MAAM,CAAC;KACtB,CAAC;CACH;AAED,gEAAgE;AAChE,wBAAgB,YAAY,CAAC,GAAG,EAAE,GAAG,GAAG,MAAM,CAE7C;AAED,uEAAuE;AACvE,wBAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAElD;AAED;;;GAGG;AACH,wBAAgB,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,MAAM,EAAE,IAAI,GAAE,iBAAsB,GAAG,QAAQ,CAuCxG;AAED;;;GAGG;AACH,wBAAgB,oBAAoB,CAClC,GAAG,EAAE;IAAE,MAAM,CAAC,EAAE,WAAW,CAAC;IAAC,EAAE,CAAC,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,EAAE,EAAE,MAAM,IAAI,KAAK,IAAI,CAAA;CAAE,EAC3E,GAAG,EAAE;IAAE,SAAS,EAAE,CAAC,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,KAAK,IAAI,CAAC;IAAC,KAAK,EAAE,CAAC,CAAC,EAAE,MAAM,KAAK,OAAO,CAAC;IAAC,GAAG,EAAE,MAAM,IAAI,CAAA;CAAE,EAClH,KAAK,EAAE,MAAM,EACb,IAAI,GAAE,iBAAsB,GAC3B,IAAI,CA2BN"}
+{"version":3,"file":"sse.d.ts","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AAKH,eAAO,MAAM,YAAY,qBAAqB,CAAC;AAE/C,gEAAgE;AAChE,wBAAgB,YAAY,CAAC,GAAG,EAAE,GAAG,GAAG,MAAM,CAE7C;AAED,uEAAuE;AACvE,wBAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAElD;AAED;;;GAGG;AACH,wBAAgB,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,MAAM,GAAG,QAAQ,CAuC1E;AAED;;;GAGG;AACH,wBAAgB,oBAAoB,CAClC,GAAG,EAAE;IAAE,MAAM,CAAC,EAAE,WAAW,CAAC;IAAC,EAAE,CAAC,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,EAAE,EAAE,MAAM,IAAI,KAAK,IAAI,CAAA;CAAE,EAC3E,GAAG,EAAE;IAAE,SAAS,EAAE,CAAC,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,KAAK,IAAI,CAAC;IAAC,KAAK,EAAE,CAAC,CAAC,EAAE,MAAM,KAAK,OAAO,CAAC;IAAC,GAAG,EAAE,MAAM,IAAI,CAAA;CAAE,EAClH,KAAK,EAAE,MAAM,GACZ,IAAI,CA2BN"}

dist/sse.js

@@ -29,3 +29,3 @@ /**
  */
-export function handleSSERequest(request, topic, opts = {}) {
+export function handleSSERequest(request, topic) {
     const { readable, writable } = new TransformStream();
@@ -60,3 +60,3 @@ const writer = writable.getWriter();
             'x-accel-buffering': 'no',
-            'access-control-allow-origin': opts.cors?.allowOrigin ?? '*',
+            'access-control-allow-origin': '*',
         },
@@ -69,3 +69,3 @@ });
  */
-export function handleSSERequestNode(req, res, topic, opts = {}) {
+export function handleSSERequestNode(req, res, topic) {
     res.writeHead(200, {
@@ -76,3 +76,3 @@ 'content-type': 'text/event-stream; charset=utf-8',
         'x-accel-buffering': 'no',
-        'access-control-allow-origin': opts.cors?.allowOrigin ?? '*',
+        'access-control-allow-origin': '*',
     });
@@ -79,0 +79,0 @@ res.write(`event: connected\ndata: ${JSON.stringify({ topic, ts: Date.now() })}\n\n`);

dist/sse.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"sse.js","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AAEH,OAAO,EAAE,MAAM,EAAuB,MAAM,aAAa,CAAC;AAE1D,MAAM,YAAY,GAAI,MAAM,CAAC;AAC7B,MAAM,CAAC,MAAM,YAAY,GAAG,kBAAkB,CAAC;AAQ/C,gEAAgE;AAChE,MAAM,UAAU,YAAY,CAAC,GAAQ;IACnC,OAAO,kBAAkB,CAAC,GAAG,CAAC,QAAQ,CAAC,KAAK,CAAC,YAAY,CAAC,MAAM,CAAC,CAAC,CAAC;AACrE,CAAC;AAED,uEAAuE;AACvE,MAAM,UAAU,gBAAgB,CAAC,GAAQ;IACvC,OAAO,GAAG,CAAC,QAAQ,CAAC,UAAU,CAAC,YAAY,CAAC,IAAI,GAAG,CAAC,QAAQ,CAAC,MAAM,GAAG,YAAY,CAAC,MAAM,CAAC;AAC5F,CAAC;AAED;;;GAGG;AACH,MAAM,UAAU,gBAAgB,CAAC,OAAgB,EAAE,KAAa,EAAE,OAA0B,EAAE;IAC5F,MAAM,EAAE,QAAQ,EAAE,QAAQ,EAAE,GAAG,IAAI,eAAe,EAAc,CAAC;IACjE,MAAM,MAAM,GAAI,QAAQ,CAAC,SAAS,EAAE,CAAC;IACrC,MAAM,OAAO,GAAG,IAAI,WAAW,EAAE,CAAC;IAElC,MAAM,IAAI,GAAG,CAAC,KAAa,EAAQ,EAAE;QACnC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;IACtD,CAAC,CAAC;IAEF,0BAA0B;IAC1B,IAAI,CAAC,2BAA2B,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAEjF,sDAAsD;IACtD,MAAM,WAAW,GAAG,MAAM,CAAC,SAAS,CAAU,KAAK,EAAE,CAAC,GAA4B,EAAE,EAAE;QACpF,IAAI,CAAC,OAAO,GAAG,CAAC,EAAE,2BAA2B,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;IAC/E,CAAC,CAAC,CAAC;IAEH,6DAA6D;IAC7D,MAAM,SAAS,GAAG,WAAW,CAAC,GAAG,EAAE;QACjC,IAAI,CAAC,iBAAiB,CAAC,CAAC;IAC1B,CAAC,EAAE,YAAY,CAAC,CAAC;IAEjB,kCAAkC;IAClC,OAAO,CAAC,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,GAAG,EAAE;QAC5C,aAAa,CAAC,SAAS,CAAC,CAAC;QACzB,WAAW,EAAE,CAAC;QACd,MAAM,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;IACjC,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAEnB,OAAO,IAAI,QAAQ,CAAC,QAAQ,EAAE;QAC5B,MAAM,EAAE,GAAG;QACX,OAAO,EAAE;YACP,cAAc,EAAe,kCAAkC;YAC/D,eAAe,EAAc,wBAAwB;YACrD,YAAY,EAAiB,YAAY;YACzC,mBAAmB,EAAU,IAAI;YACjC,6BAA6B,EAAE,IAAI,CAAC,IAAI,EAAE,WAAW,IAAI,GAAG;SAC7D;KACF,CAAC,CAAC;AACL,CAAC;AAED;;;GAGG;AACH,MAAM,UAAU,oBAAoB,CAClC,GAA2E,EAC3E,GAAkH,EAClH,KAAa,EACb,OAA0B,EAAE;IAE5B,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;QACjB,cAAc,EAAe,kCAAkC;QAC/D,eAAe,EAAc,UAAU;QACvC,YAAY,EAAiB,YAAY;QACzC,mBAAmB,EAAU,IAAI;QACjC,6BAA6B,EAAE,IAAI,CAAC,IAAI,EAAE,WAAW,IAAI,GAAG;KAC7D,CAAC,CAAC;IAEH,GAAG,CAAC,KAAK,CAAC,2BAA2B,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAEtF,MAAM,WAAW,GAAG,MAAM,CAAC,SAAS,CAAU,KAAK,EAAE,CAAC,GAA4B,EAAE,EAAE;QACpF,GAAG,CAAC,KAAK,CAAC,OAAO,GAAG,CAAC,EAAE,2BAA2B,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;IACpF,CAAC,CAAC,CAAC;IAEH,MAAM,SAAS,GAAG,WAAW,CAAC,GAAG,EAAE;QACjC,GAAG,CAAC,KAAK,CAAC,iBAAiB,CAAC,CAAC;IAC/B,CAAC,EAAE,YAAY,CAAC,CAAC;IAEjB,MAAM,OAAO,GAAG,GAAS,EAAE;QACzB,aAAa,CAAC,SAAS,CAAC,CAAC;QACzB,WAAW,EAAE,CAAC;QACd,GAAG,CAAC,GAAG,EAAE,CAAC;IACZ,CAAC,CAAC;IAEF,GAAG,CAAC,EAAE,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC3B,GAAG,CAAC,MAAM,EAAE,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;AACjE,CAAC"}
+{"version":3,"file":"sse.js","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AAEH,OAAO,EAAE,MAAM,EAAuB,MAAM,aAAa,CAAC;AAE1D,MAAM,YAAY,GAAI,MAAM,CAAC;AAC7B,MAAM,CAAC,MAAM,YAAY,GAAG,kBAAkB,CAAC;AAE/C,gEAAgE;AAChE,MAAM,UAAU,YAAY,CAAC,GAAQ;IACnC,OAAO,kBAAkB,CAAC,GAAG,CAAC,QAAQ,CAAC,KAAK,CAAC,YAAY,CAAC,MAAM,CAAC,CAAC,CAAC;AACrE,CAAC;AAED,uEAAuE;AACvE,MAAM,UAAU,gBAAgB,CAAC,GAAQ;IACvC,OAAO,GAAG,CAAC,QAAQ,CAAC,UAAU,CAAC,YAAY,CAAC,IAAI,GAAG,CAAC,QAAQ,CAAC,MAAM,GAAG,YAAY,CAAC,MAAM,CAAC;AAC5F,CAAC;AAED;;;GAGG;AACH,MAAM,UAAU,gBAAgB,CAAC,OAAgB,EAAE,KAAa;IAC9D,MAAM,EAAE,QAAQ,EAAE,QAAQ,EAAE,GAAG,IAAI,eAAe,EAAc,CAAC;IACjE,MAAM,MAAM,GAAI,QAAQ,CAAC,SAAS,EAAE,CAAC;IACrC,MAAM,OAAO,GAAG,IAAI,WAAW,EAAE,CAAC;IAElC,MAAM,IAAI,GAAG,CAAC,KAAa,EAAQ,EAAE;QACnC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;IACtD,CAAC,CAAC;IAEF,0BAA0B;IAC1B,IAAI,CAAC,2BAA2B,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAEjF,sDAAsD;IACtD,MAAM,WAAW,GAAG,MAAM,CAAC,SAAS,CAAU,KAAK,EAAE,CAAC,GAA4B,EAAE,EAAE;QACpF,IAAI,CAAC,OAAO,GAAG,CAAC,EAAE,2BAA2B,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;IAC/E,CAAC,CAAC,CAAC;IAEH,6DAA6D;IAC7D,MAAM,SAAS,GAAG,WAAW,CAAC,GAAG,EAAE;QACjC,IAAI,CAAC,iBAAiB,CAAC,CAAC;IAC1B,CAAC,EAAE,YAAY,CAAC,CAAC;IAEjB,kCAAkC;IAClC,OAAO,CAAC,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,GAAG,EAAE;QAC5C,aAAa,CAAC,SAAS,CAAC,CAAC;QACzB,WAAW,EAAE,CAAC;QACd,MAAM,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;IACjC,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAEnB,OAAO,IAAI,QAAQ,CAAC,QAAQ,EAAE;QAC5B,MAAM,EAAE,GAAG;QACX,OAAO,EAAE;YACP,cAAc,EAAe,kCAAkC;YAC/D,eAAe,EAAc,wBAAwB;YACrD,YAAY,EAAiB,YAAY;YACzC,mBAAmB,EAAU,IAAI;YACjC,6BAA6B,EAAE,GAAG;SACnC;KACF,CAAC,CAAC;AACL,CAAC;AAED;;;GAGG;AACH,MAAM,UAAU,oBAAoB,CAClC,GAA2E,EAC3E,GAAkH,EAClH,KAAa;IAEb,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;QACjB,cAAc,EAAe,kCAAkC;QAC/D,eAAe,EAAc,UAAU;QACvC,YAAY,EAAiB,YAAY;QACzC,mBAAmB,EAAU,IAAI;QACjC,6BAA6B,EAAE,GAAG;KACnC,CAAC,CAAC;IAEH,GAAG,CAAC,KAAK,CAAC,2BAA2B,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAEtF,MAAM,WAAW,GAAG,MAAM,CAAC,SAAS,CAAU,KAAK,EAAE,CAAC,GAA4B,EAAE,EAAE;QACpF,GAAG,CAAC,KAAK,CAAC,OAAO,GAAG,CAAC,EAAE,2BAA2B,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;IACpF,CAAC,CAAC,CAAC;IAEH,MAAM,SAAS,GAAG,WAAW,CAAC,GAAG,EAAE;QACjC,GAAG,CAAC,KAAK,CAAC,iBAAiB,CAAC,CAAC;IAC/B,CAAC,EAAE,YAAY,CAAC,CAAC;IAEjB,MAAM,OAAO,GAAG,GAAS,EAAE;QACzB,aAAa,CAAC,SAAS,CAAC,CAAC;QACzB,WAAW,EAAE,CAAC;QACd,GAAG,CAAC,GAAG,EAAE,CAAC;IACZ,CAAC,CAAC;IAEF,GAAG,CAAC,EAAE,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC3B,GAAG,CAAC,MAAM,EAAE,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;AACjE,CAAC"}

package.json

 {
   "name": "@nexus_js/connect",
-  "version": "0.9.28",
+  "version": "0.9.29",
   "description": "Nexus Connect — Edge-State Sync via SSE. $socket() rune for real-time state across all connected clients.",
@@ -21,3 +21,3 @@ "type": "module",
     "typescript": "^5.5.0",
-    "vitest": "^4.0.0"
+    "vitest": "^2.0.0"
   },
@@ -34,6 +34,2 @@ "license": "MIT",
   },
-  "funding": {
-    "type": "individual",
-    "url": "https://buymeacoffee.com/bierfor084"
-  },
   "keywords": [
@@ -60,3 +56,2 @@ "nexus",
     "dev": "tsc -p tsconfig.json --watch",
-    "typecheck": "tsc --noEmit -p tsconfig.json",
     "test": "vitest run --passWithNoTests",
@@ -63,0 +58,0 @@ "clean": "rm -rf dist"

No alert changes

Worsened metrics

Total package byte prevSize

27858

-2.06%

Lines of code

387

-1.28%

No dependency changes