Fix properties callback bug on refresh

Author: pirropirro

src/client/CloudClient.ts

@@ -8,10 +8,12 @@ import { IConnection, CloudMessage } from '../connection/IConnection';
 import { ICloudClient, CloudOptions, OnMessageCallback, CloudMessageValue } from './ICloudClient';
 
 const NOOP = () => null;
+type PropertyCallbacks = { cb: OnMessageCallback<any>[]; propertyName: string; thingId };
 export class CloudClient implements ICloudClient {
   private connection: IConnection;
   private subscriptions: { [key: string]: Subscription[] } = {};
   private callbacks: { [key: string]: OnMessageCallback<any>[] } = {};
+  private propertyCallbacks: { [key: string]: PropertyCallbacks } = {};
 
   private options: CloudOptions = {
     ssl: false,
@@ -71,6 +73,7 @@ export class CloudClient implements ICloudClient {
       Object.values(this.subscriptions).forEach((subs, topic) => {
         subs.forEach((sub) => sub.unsubscribe());
         delete this.callbacks[topic];
+        delete this.propertyCallbacks[topic];
         delete this.subscriptions[topic];
       });
 
@@ -97,8 +100,12 @@ export class CloudClient implements ICloudClient {
           delete this.subscriptions[topic];
 
           const callbacks = [...this.callbacks[topic]];
+          const { thingId, propertyName, ...others } = this.propertyCallbacks[topic] || { cb: [] };
+          const propertiesCallbacks = [...others.cb];
           delete this.callbacks[topic];
+          delete this.propertyCallbacks[topic];
           callbacks.forEach((cb) => this.subscribe(topic, cb));
+          propertiesCallbacks.forEach((cb) => this.onPropertyValue(thingId, propertyName, cb));
         });
 
         const { onConnected = NOOP } = this.options;
@@ -166,10 +173,10 @@ export class CloudClient implements ICloudClient {
 
     const topic = `/a/t/${thingId}/e/o`;
 
-    this.callbacks[topic] = this.callbacks[topic] = [];
+    this.propertyCallbacks[topic] = this.propertyCallbacks[topic] = { thingId, propertyName: name, cb: [] };
     this.subscriptions[topic] = this.subscriptions[topic] = [];
 
-    this.callbacks[topic].push(cb);
+    this.propertyCallbacks[topic].cb.push(cb);
     this.subscriptions[topic].push(
       this.messagesFrom(topic)
         .pipe(filter((v) => v.propertyName === name))