test

api/network/send.ts

@@ -107,6 +107,7 @@ export function signAndSend(opts, mqttTopic?:string){
 		try {
 			if(mqttTopic) {
 				await tribes.publish(mqttTopic, data, function(){
+					console.log("PUB HERE")
 					if(mqttTopic) checkIfConfirmation(data)
 				})
 			} else {
@@ -120,6 +121,7 @@ export function signAndSend(opts, mqttTopic?:string){
 }
 
 function checkIfConfirmation(data){
+	console.log("checkIfConfirmation",data)
 	if(data.type===constants.message_types.confirmation) {
 		tribeOwnerAutoConfirmation(data.message.id)
 	}

api/utils/tribes.ts

@@ -67,6 +67,7 @@ export function subscribe(topic) {
 
 export function publish(topic, msg, cb) {
   if (client) client.publish(topic, msg, null, function(err){
+    console.log("CALLBACK")
     if(err) console.log(err)
     else if(cb) cb()
   })

dist/api/network/send.js

@@ -115,6 +115,7 @@ function signAndSend(opts, mqttTopic) {
             try {
                 if (mqttTopic) {
                     yield tribes.publish(mqttTopic, data, function () {
+                        console.log("PUB HERE");
                         if (mqttTopic)
                             checkIfConfirmation(data);
                     });
@@ -132,6 +133,7 @@ function signAndSend(opts, mqttTopic) {
 }
 exports.signAndSend = signAndSend;
 function checkIfConfirmation(data) {
+    console.log("checkIfConfirmation", data);
     if (data.type === constants.message_types.confirmation) {
         confirmations_1.tribeOwnerAutoConfirmation(data.message.id);
     }

dist/api/utils/tribes.js

@@ -82,6 +82,7 @@ exports.subscribe = subscribe;
 function publish(topic, msg, cb) {
     if (client)
         client.publish(topic, msg, null, function (err) {
+            console.log("CALLBACK");
             if (err)
                 console.log(err);
             else if (cb)