Merge pull request #30 from hackmdio/fix/incorrect-persistence-leader-check

fix/incorrect persistence leader aquire check

Author: Yukaii

src/y-socket-io/y-socket-io.js

@@ -859,10 +859,13 @@ export class YSocketIO {
     assert(this.client)
     const redis = this.client.redis
     const key = this.getLeaderKeyOf(namespace)
-    const ok = await redis.set(key, this.serverId, {
+    const prevVal = await redis.set(key, this.serverId, {
       NX: true,
-      PX: PERSIST_LEADER_HEARTBEAT_INTERVAL
+      PX: PERSIST_LEADER_HEARTBEAT_INTERVAL,
+      GET: true
     })
+
+    const ok = prevVal === this.serverId || prevVal === null
     if (!ok) return false
 
     this.persistentLeaderOf.add(namespace)