@coast-team/mute-core - npm Package Compare versions

Comparing version 10.0.0-experiment-3.0 to 10.0.0-experiment-3.1

CHANGELOG.md

@@ -5,2 +5,12 @@ # Change Log
 
+<a name="10.0.0-experiment-3.1"></a>
+# [10.0.0-experiment-3.1](https://github.com/coast-team/mute-core/compare/v10.0.0-experiment-3.0...v10.0.0-experiment-3.1) (2019-07-12)
+
+
+### Bug Fixes
+
+* **syncmessage:** emit deserialization times of all ops ([00f5dd8](https://github.com/coast-team/mute-core/commit/00f5dd8))
+
+
+
 <a name="10.0.0-experiment-3.0"></a>
@@ -7,0 +17,0 @@ # [10.0.0-experiment-3.0](https://github.com/coast-team/mute-core/compare/v10.0.0-2.0...v10.0.0-experiment-3.0) (2019-07-10)

dist/types/src/core/SyncMessage.d.ts

@@ -25,2 +25,3 @@ import { Observable, Subject } from 'rxjs';
     protected abstract deserializeRichOperation(richOperationMsg: proto.RichOperationMsg): RichOperation<Op>;
+    private wrapperDeserializeRichOperation;
     private handleRichOpMsg;
@@ -27,0 +28,0 @@ private handleQuerySyncMsg;

package.json

 {
   "name": "@coast-team/mute-core",
   "description": "Core component of MUTE collaborative editor",
-  "version": "10.0.0-experiment-3.0",
+  "version": "10.0.0-experiment-3.1",
   "main": "./dist/mute-core.node.es5.cjs.js",
@@ -6,0 +6,0 @@ "module": "./dist/mutecore.node.es5.esm.js",

src/core/SyncMessage.ts

@@ -33,11 +33,3 @@ import { Observable, Subject, zip } from 'rxjs'
         case 'richOpMsg':
-          const t1 = process.hrtime()
-          const richOpe = this.handleRichOpMsg(msg.richOpMsg as proto.RichOperationMsg)
-          const t2 = process.hrtime()
-          this.experimentLogsSubject.next({
-            type: 'remote',
-            operation: richOpe,
-            time1: t1,
-            time2: t2,
-          })
+          this.handleRichOpMsg(msg.richOpMsg as proto.RichOperationMsg)
           break
@@ -130,4 +122,19 @@ case 'querySync':
 
+  private wrapperDeserializeRichOperation(
+    richOperationMsg: proto.RichOperationMsg
+  ): RichOperation<Op> {
+    const t1 = process.hrtime()
+    const richOpe = this.deserializeRichOperation(richOperationMsg)
+    const t2 = process.hrtime()
+    this.experimentLogsSubject.next({
+      type: 'remote',
+      operation: richOpe,
+      time1: t1,
+      time2: t2,
+    })
+    return richOpe
+  }
+
   private handleRichOpMsg(content: proto.RichOperationMsg): RichOperation<Op> {
-    const richOp = this.deserializeRichOperation(content)
+    const richOp = this.wrapperDeserializeRichOperation(content)
     this.remoteRichOperationSubject.next(richOp)
@@ -147,3 +154,3 @@ return richOp
     const richOps = richOpsMsg.map((o) =>
-      this.deserializeRichOperation(o as proto.RichOperationMsg)
+      this.wrapperDeserializeRichOperation(o as proto.RichOperationMsg)
     )
@@ -150,0 +157,0 @@

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

6894896

increased by0.03%

Lines of code

58797

increased by0.05%

No dependency changes