@standardserver/peer - npm Package Compare versions

Comparing version 0.4.1 to 0.4.2

dist/index.d.mts

@@ -1,2 +0,2 @@
-import { StandardRequest, EventStreamMessage, StandardResponse, StandardLazyResponse, StandardLazyRequest } from '@standardserver/core';
+import { StandardRequest, EventMeta, StandardResponse, StandardLazyResponse, StandardLazyRequest } from '@standardserver/core';
 import { Queue, AsyncCleanupFn, AsyncIteratorClass } from '@standardserver/shared';
@@ -91,4 +91,8 @@
      */
-    json: Omit<EventStreamMessage, 'data'> & {
+    json: EventMeta & {
         /**
+         * Kind of event
+         */
+        event: 'message' | 'error' | 'close';
+        /**
          * Event data.
@@ -95,0 +99,0 @@ */

dist/index.d.ts

@@ -1,2 +0,2 @@
-import { StandardRequest, EventStreamMessage, StandardResponse, StandardLazyResponse, StandardLazyRequest } from '@standardserver/core';
+import { StandardRequest, EventMeta, StandardResponse, StandardLazyResponse, StandardLazyRequest } from '@standardserver/core';
 import { Queue, AsyncCleanupFn, AsyncIteratorClass } from '@standardserver/shared';
@@ -91,4 +91,8 @@
      */
-    json: Omit<EventStreamMessage, 'data'> & {
+    json: EventMeta & {
         /**
+         * Kind of event
+         */
+        event: 'message' | 'error' | 'close';
+        /**
          * Event data.
@@ -95,0 +99,0 @@ */

dist/index.mjs

@@ -463,3 +463,3 @@ import { AsyncIteratorClass, isTypescriptObject, isAsyncIteratorObject, Queue, SequentialIdGenerator, AbortError, stringifyJSON } from '@standardserver/shared';
   }
-  if (maybe.json.event !== void 0 && typeof maybe.json.event !== "string") {
+  if (maybe.json.event !== "message" && maybe.json.event !== "error" && maybe.json.event !== "close") {
     return false;
@@ -476,3 +476,3 @@ }
 function isPeerOctetStreamMessage(maybe) {
-  return maybe.kind === "octet-stream" && isTypescriptObject(maybe.json) && typeof maybe.json.close === "boolean";
+  return maybe.kind === "octet-stream" && isTypescriptObject(maybe.json) && (typeof maybe.json.close === "undefined" || typeof maybe.json.close === "boolean");
 }
@@ -479,0 +479,0 @@ function isPeerStreamCancelMessage(maybe) {

package.json

 {
   "name": "@standardserver/peer",
   "type": "module",
-  "version": "0.4.1",
+  "version": "0.4.2",
   "license": "MIT",
@@ -25,4 +25,4 @@ "homepage": "https://standardserver.dev",
   "dependencies": {
-    "@standardserver/shared": "0.4.1",
-    "@standardserver/core": "0.4.1"
+    "@standardserver/shared": "0.4.2",
+    "@standardserver/core": "0.4.2"
   },
@@ -29,0 +29,0 @@ "scripts": {

No alert changes

Improved metrics

Total package byte prevSize

71723

0.28%

Lines of code

972

0.41%

Dependency changes

• + Added

  @standardserver/core@0.4.2
  (transitive)

• + Added

  @standardserver/shared@0.4.2
  (transitive)

• - Removed

  @standardserver/core@0.4.1
  (transitive)

• - Removed

  @standardserver/shared@0.4.1
  (transitive)

• Updated

  @standardserver/core@0.4.2

• Updated

  @standardserver/shared@0.4.2