fix: 🐛 recreate gRPC stream when it already exists

I think it's better to warn and recreate stream since the upper level bot does not have direct access to these private method to handle it properly. ✅ Closes: #172
wechaty · Oct 25, 2021 · 9f0d201 · 9f0d201
1 parent e0118c2
commit 9f0d201
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/client/puppet-service.ts b/src/client/puppet-service.ts
@@ -415,7 +415,9 @@ export class PuppetService extends Puppet {
     log.verbose('PuppetService', 'startGrpcStream()')
 
     if (this.eventStream) {
-      throw new Error('event stream exists')
+      this.stopGrpcStream()
+      log.warn('PuppetService', 'startGrpcStream() grpc stream is already started, will terminate and start new stream')
+      // throw new Error('event stream exists')
     }
 
     let retry = MAX_GRPC_CONNECTION_RETRIES