Fix sending reset

Author: bigmontz

packages/bolt-connection/src/bolt/bolt-protocol-v1.js

@@ -376,6 +376,10 @@ export default class BoltProtocol {
     return this._lastMessageSignature === 0x01
   }
 
+  isLastMessageReset () {
+    return this._lastMessageSignature === 0x0f
+  }
+
   /**
    * Notifies faltal erros to the observers and mark the protocol in the fatal error state.
    * @param {Error} error The error

packages/bolt-connection/src/connection/connection-channel.js

@@ -341,10 +341,22 @@ export default class ChannelConnection extends Connection {
   }
 
   _reset(observer) {
-    this._resetObservers.push(observer)
     if (this._reseting) {
+      if (!this._protocol.isLastMessageReset()) {
+        this._protocol.reset({
+          onError: error => {
+            observer.onError(error)
+          }, onComplete: () => {
+            observer.onComplete()
+          }
+        })
+      } else {
+        this._resetObservers.push(observer)
+      }
       return
     }
+
+    this._resetObservers.push(observer)
     this._reseting = true
 
     const notifyFinish = (notify) => {

packages/bolt-connection/test/connection/connection-channel.test.js

@@ -269,7 +269,8 @@ describe('ChannelConnection', () => {
 
         const protocol = {
           reset: jest.fn(),
-          resetFailure: jest.fn()
+          resetFailure: jest.fn(),
+          isLastMessageReset: jest.fn(() => true)
         }
         const protocolSupplier = () => protocol
         const connection = spyOnConnectionChannel({ channel, protocolSupplier })
@@ -454,7 +455,8 @@ describe('ChannelConnection', () => {
         reset: jest.fn(observer => {
           setTimeout(() => observer.onComplete(), 100)
         }),
-        resetFailure: jest.fn()
+        resetFailure: jest.fn(),
+        isLastMessageReset: jest.fn(() => true)
       }
       const protocolSupplier = () => protocol
       const connection = spyOnConnectionChannel({ channel, protocolSupplier })