Add error handler to the stream to prevent unhandled errors

Signed-off-by: Constantin Chirila <[email protected]>

Author: ConstantinChirila

src/implementation/Client/GRPCClient/configuration.ts

@@ -127,16 +127,30 @@ export default class GRPCClientConfiguration implements IClientConfiguration {
       await cb(wrapped);
     });
 
+    // Add error handler to prevent unhandled errors
+    stream.on("error", (err) => {
+      // Log the error but don't throw - this prevents process crashes
+      console.warn("Configuration subscription stream error:", err);
+    });
+
     return {
       stop: async () => {
-        return new Promise((resolve, reject) => {
+        return new Promise((resolve) => {
+          // If no streamId, just clean up the stream without unsubscribing
+          if (!streamId) {
+            stream.removeAllListeners();
+            stream.destroy();
+            return resolve();
+          }
+
           const req = new UnsubscribeConfigurationRequest();
           req.setStoreName(storeName);
           req.setId(streamId);
 
           client.unsubscribeConfiguration(req, (err, res: UnsubscribeConfigurationResponse) => {
             if (err || !res.getOk()) {
-              return reject(res.getMessage());
+              // Don't reject, just log and clean up
+              console.warn("Failed to unsubscribe configuration:", err || res.getMessage());
             }
 
             // Clean up the node.js event emitter