make mq call async in signal api call

controllers/hosts.go

@@ -491,18 +491,18 @@ func signalPeer(w http.ResponseWriter, r *http.Request) {
 	// push the signal to host through mq
 	found := false
 	for _, hostI := range hosts {
+		hostI := hostI
 		if hostI.PublicKey.String() == signal.ToHostPubKey {
 			// found host publish message and break
 			found = true
-			err = mq.HostUpdate(&models.HostUpdate{
-				Action: models.SignalHost,
-				Host:   hostI,
-				Signal: signal,
-			})
-			if err != nil {
-				logic.ReturnErrorResponse(w, r, logic.FormatError(errors.New("failed to publish signal to peer: "+err.Error()), "badrequest"))
-				return
-			}
+			go func(host models.Host) {
+				mq.HostUpdate(&models.HostUpdate{
+					Action: models.SignalHost,
+					Host:   hostI,
+					Signal: signal,
+				})
+			}(hostI)
+
 			break
 		}
 	}

database/database.go

@@ -215,8 +215,6 @@ func FetchRecord(tableName string, key string) (string, error) {
 
 // FetchRecords - fetches all records in given table
 func FetchRecords(tableName string) (map[string]string, error) {
-	dbMutex.RLock()
-	defer dbMutex.RUnlock()
 	return getCurrentDB()[FETCH_ALL].(func(string) (map[string]string, error))(tableName)
 }
 

mq/mq.go

@@ -33,7 +33,7 @@ func setMqOptions(user, password string, opts *mqtt.ClientOptions) {
 	opts.SetPassword(password)
 	opts.SetAutoReconnect(true)
 	opts.SetConnectRetry(true)
-	opts.SetConnectRetryInterval(time.Second << 2)
+	opts.SetConnectRetryInterval(time.Second * 5)
 	opts.SetKeepAlive(time.Minute)
 	opts.SetWriteTimeout(time.Minute)
 }

mq/publishers.go

@@ -407,7 +407,7 @@ func NodeUpdate(node *models.Node) error {
 
 // HostUpdate -- publishes a host update to clients
 func HostUpdate(hostUpdate *models.HostUpdate) error {
-	logger.Log(3, "publishing host update to "+hostUpdate.Host.ID.String())
+	logger.Log(4, "publishing host update to "+hostUpdate.Host.ID.String())
 
 	data, err := json.Marshal(hostUpdate)
 	if err != nil {