Add CrossTabClient#forceConnect

Author: ai

cross-tab-client/index.d.ts

@@ -47,6 +47,11 @@ export class CrossTabClient<
    */
   role: 'follower' | 'leader'
 
+  /**
+   * Start web socket reconnection.
+   */
+  forceConnect(): void
+
   on(
     event: 'add' | 'clean' | 'preadd',
     listener: ClientActionListener<Action>

cross-tab-client/index.js

@@ -98,6 +98,16 @@ export class CrossTabClient extends Client {
     }
   }
 
+  forceConnect() {
+    if (this.state === 'disconnected') {
+      if (this.role === 'leader') {
+        this.node.connection.connect()
+      }
+    } else {
+      sendToTabs(this, 'connect', Date.now())
+    }
+  }
+
   getClientId() {
     let key = storageKey(this, 'client')
     if (!this.isLocalStorage) {
@@ -161,6 +171,8 @@ export class CrossTabClient extends Client {
         )
         this.node.emitter.emit('error', err)
       }
+    } else if (e.key === storageKey(this, 'connect')) {
+      if (this.role === 'leader') this.forceConnect()
     }
   }
 

cross-tab-client/index.test.ts

@@ -508,6 +508,31 @@ it('notifies other tabs on user change', () => {
   expect(users).toEqual(['20'])
 })
 
+it('forces connection from follower through leader', () => {
+  localStorage.setItem = (name, value) => {
+    emitStorage(name, value)
+  }
+
+  client = createClient()
+  let follower = createClient()
+
+  client.start()
+  giveLock()
+  follower.start()
+
+  client.state = 'disconnected'
+  let connect = spyOn(client.node.connection, 'connect')
+
+  client.forceConnect()
+  expect(connect.callCount).toEqual(1)
+
+  connect.callCount = 0
+  follower.forceConnect()
+  expect(connect.callCount).toEqual(1)
+
+  follower.destroy()
+})
+
 it('sends event on user changing in other tab', () => {
   client = createClient()
   let users: string[] = []