Hotfix/cbuffer

src/cbuffer.ts

@@ -92,7 +92,7 @@ export class CBuffer {
     startIdx = startIdx | 0;
     beforeIdx = beforeIdx || this.buffer.length;
     for (let i = startIdx; i < beforeIdx; i++) {
-      callback(context, this.buffer[i], i);
+      callback.call(context, this.buffer[i], i);
     }
   }
 

src/tinode.ts

@@ -1335,7 +1335,7 @@ export class Tinode {
      */
     isTopicOnline(topicName: string): boolean {
         const me = this.getMeTopic();
-        const cont = me && me.getContact(name);
+        const cont = me && me.getContact(topicName);
         return cont && cont.online;
     }
 }

src/topic/topic-me.ts

@@ -104,8 +104,8 @@ export class TopicMe extends Topic {
                     if (!sub.noForwarding) {
                         const topic = this.tinode.getTopic(topicName);
                         if (topic) {
-                            sub._noForwarding = true;
-                            topic._processMetaDesc(sub);
+                            sub.noForwarding = true;
+                            topic.processMetaDesc(sub);
                         }
                     }
                 }

src/topic/topic.ts

@@ -152,7 +152,7 @@ export class Topic {
         // If topic name is explicitly provided, use it. If no name, then it's a new group topic, use "new".
         const ctrl = await this.tinode.subscribe(this.name || TopicNames.TOPIC_NEW, getParams, setParams);
 
-        if (ctrl.code >= 300) {
+        if (ctrl.code >= 400) {
             // Do nothing if the topic is already subscribed to.
             return ctrl;
         }

src/utilities.ts

@@ -185,7 +185,7 @@ export class Utilities {
         for (const prop in src) {
             if (src.hasOwnProperty(prop) &&
                 (!ignore || !ignore[prop]) &&
-                (prop !== '_noForwarding')) {
+                (prop !== 'noForwarding')) {
 
                 dst[prop] = Utilities.mergeObj(dst[prop], src[prop]);
             }