From 76eb67406959a4c34dffc197e89e1a97d84e9e18 Mon Sep 17 00:00:00 2001
From: Kevin Jahns <kevin.jahns@protonmail.com>
Date: Fri, 26 Apr 2019 18:31:14 +0200
Subject: [PATCH] sync: readSyncMessage accepts origin parameter

---
 package.json | 4 ++--
 sync.js      | 7 ++++---
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/package.json b/package.json
index a8f8c92..9226938 100644
--- a/package.json
+++ b/package.json
@@ -32,14 +32,14 @@
   "homepage": "https://github.com/y-js/y-protocols#readme",
   "dependencies": {},
   "devDependencies": {
-    "lib0": "0.0.1",
+    "lib0": "0.0.2",
     "rollup": "^1.1.2",
     "rollup-cli": "^1.0.9",
     "standard": "^12.0.1",
     "yjs": "file:../yjs"
   },
   "peerDependenies": {
-    "lib0": "^0.0.1",
+    "lib0": "*",
     "yjs": "*"
   }
 }
diff --git a/sync.js b/sync.js
index 6230497..c043520 100644
--- a/sync.js
+++ b/sync.js
@@ -111,8 +111,9 @@ export const readUpdate = Y.readModel
  * @param {decoding.Decoder} decoder A message received from another client
  * @param {encoding.Encoder} encoder The reply message. Will not be sent if empty.
  * @param {Y.Y} y
+ * @param {any} origin
  */
-export const readSyncMessage = (decoder, encoder, y) => {
+export const readSyncMessage = (decoder, encoder, y, origin) => {
   const messageType = decoding.readVarUint(decoder)
   switch (messageType) {
     case messageYjsSyncStep1:
@@ -120,11 +121,11 @@ export const readSyncMessage = (decoder, encoder, y) => {
       break
     case messageYjsSyncStep2:
       // @ts-ignore
-      y.transact(transaction => readSyncStep2(decoder, transaction, y.store))
+      y.transact(transaction => readSyncStep2(decoder, transaction, y.store), origin)
       break
     case messageYjsUpdate:
       // @ts-ignore
-      y.transact(transaction => readUpdate(decoder, transaction, y.store))
+      y.transact(transaction => readUpdate(decoder, transaction, y.store), origin)
       break
     default:
       throw new Error('Unknown message type')