streamr-client-protocol - npm Package Compare versions

Comparing version 9.1.0-brubeck.0 to 9.1.0-brubeck.1

dist/src/protocol/message_layer/MessageID.d.ts

 import MessageRef from './MessageRef';
+export declare type MessageIDArray = [string, number, number, number, string, string];
 export default class MessageID {
@@ -10,6 +11,7 @@ streamId: string;
     constructor(streamId: string, streamPartition: number, timestamp: number, sequenceNumber: number, publisherId: string, msgChainId: string);
-    toArray(): (string | number)[];
-    static fromArray(arr: any[]): MessageID;
+    toArray(): MessageIDArray;
+    static fromArray(arr: MessageIDArray): MessageID;
     serialize(): string;
     toMessageRef(): MessageRef;
+    clone(): MessageID;
 }

dist/src/protocol/message_layer/MessageID.js

@@ -40,4 +40,7 @@ "use strict";
     }
+    clone() {
+        return new MessageID(...this.toArray());
+    }
 }
 exports.default = MessageID;
 //# sourceMappingURL=MessageID.js.map

dist/src/protocol/message_layer/MessageIDStrict.d.ts

@@ -1,5 +0,6 @@
-import MessageID from './MessageID';
+import MessageID, { MessageIDArray } from './MessageID';
 export default class MessageIDStrict extends MessageID {
     constructor(streamId: string, streamPartition: number, timestamp: number, sequenceNumber: number, publisherId: string, msgChainId: string);
-    static fromArray(arr: any[]): MessageIDStrict;
+    static fromArray(arr: MessageIDArray): MessageIDStrict;
+    clone(): MessageIDStrict;
 }

dist/src/protocol/message_layer/MessageIDStrict.js

@@ -19,4 +19,7 @@ "use strict";
     }
+    clone() {
+        return new MessageIDStrict(...this.toArray());
+    }
 }
 exports.default = MessageIDStrict;
 //# sourceMappingURL=MessageIDStrict.js.map

dist/src/protocol/message_layer/MessageRef.d.ts

@@ -9,2 +9,3 @@ export default class MessageRef {
     serialize(): string;
+    clone(): MessageRef;
 }

dist/src/protocol/message_layer/MessageRef.js

@@ -39,4 +39,7 @@ "use strict";
     }
+    clone() {
+        return new MessageRef(this.timestamp, this.sequenceNumber);
+    }
 }
 exports.default = MessageRef;
 //# sourceMappingURL=MessageRef.js.map

dist/src/protocol/message_layer/MessageRefStrict.d.ts

@@ -7,2 +7,3 @@ import MessageRef from './MessageRef';
     constructor(timestamp: number, sequenceNumber: number);
+    clone(): MessageRefStrict;
 }

dist/src/protocol/message_layer/MessageRefStrict.js

@@ -16,4 +16,7 @@ "use strict";
     }
+    clone() {
+        return new MessageRefStrict(this.timestamp, this.sequenceNumber);
+    }
 }
 exports.default = MessageRefStrict;
 //# sourceMappingURL=MessageRefStrict.js.map

dist/src/protocol/message_layer/StreamMessage.js

@@ -83,4 +83,4 @@ "use strict";
         return new StreamMessage({
-            messageId: this.messageId,
-            prevMsgRef: this.prevMsgRef,
+            messageId: this.messageId.clone(),
+            prevMsgRef: this.prevMsgRef ? this.prevMsgRef.clone() : null,
             content,
@@ -87,0 +87,0 @@ messageType: this.messageType,

dist/src/protocol/message_layer/StreamMessageSerializerV30.d.ts

 import StreamMessage from './StreamMessage';
 import { Serializer } from '../../Serializer';
 export default class StreamMessageSerializerV30 extends Serializer<StreamMessage> {
-    toArray(streamMessage: StreamMessage): (string | number | (string | number)[] | null)[];
+    toArray(streamMessage: StreamMessage): (string | number | number[] | import("./MessageID").MessageIDArray | null)[];
     fromArray(arr: any[]): StreamMessage<any>;
 }

dist/src/protocol/message_layer/StreamMessageSerializerV31.d.ts

 import StreamMessage from './StreamMessage';
 import { Serializer } from '../../Serializer';
 export default class StreamMessageSerializerV31 extends Serializer<StreamMessage> {
-    toArray(streamMessage: StreamMessage): (string | number | (string | number)[] | null)[];
+    toArray(streamMessage: StreamMessage): (string | number | number[] | import("./MessageID").MessageIDArray | null)[];
     fromArray(arr: any[]): StreamMessage<any>;
 }

dist/src/protocol/message_layer/StreamMessageSerializerV32.d.ts

 import StreamMessage from './StreamMessage';
 import { Serializer } from '../../Serializer';
 export default class StreamMessageSerializerV32 extends Serializer<StreamMessage> {
-    toArray(streamMessage: StreamMessage): (string | number | (string | number)[] | null)[];
+    toArray(streamMessage: StreamMessage): (string | number | number[] | import("./MessageID").MessageIDArray | null)[];
     fromArray(arr: any[]): StreamMessage<any>;
 }

package.json

 {
   "name": "streamr-client-protocol",
-  "version": "9.1.0-brubeck.0",
+  "version": "9.1.0-brubeck.1",
   "description": "JavaScript classes implementing the Streamr client-to-node protocol",
@@ -5,0 +5,0 @@ "repository": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

668681

increased by0.17%

Lines of code

8817

increased by0.19%

No dependency changes