updated version string

cmd/masa-node-cli/components.go

@@ -122,7 +122,7 @@ const logo = `
 const (
 	subtitle   = `masa oracle client`
 	navigation = `[yellow]use keys or mouse to navigate`
-	mouse      = `[green]v0.0.9-beta`
+	mouse      = `[green]v0.5.0`
 )
 
 // Splash shows the app info

pkg/config/constants.go

@@ -94,7 +94,7 @@ const (
 	AllowedPeer = "allowedPeer"
 	Signature   = "signature"
 	Debug       = "debug"
-	Version     = "v0.0.9-beta"
+	Version     = "v0.5.0"
 	FilePath    = "FILE_PATH"
 	Validator   = "VALIDATOR"
 	CachePath   = "CACHE_PATH"

pkg/db/operations.go

@@ -95,7 +95,8 @@ func ReadData(node *masa.OracleNode, key string) ([]byte, error) {
 	if err != nil {
 		logrus.WithFields(logrus.Fields{
 			"error": err,
-		}).Error("Failed to read from the database")
+			// we don't need to check for err since !exists gives an err also - we only need to know if the record exists or not in this context
+		}).Debug("Failed to read from the database")
 		return nil, err
 	}
 

pkg/workers/workers.go

@@ -207,10 +207,6 @@ func updateRecords(node *masa.OracleNode, workEvent db.WorkEvent) {
 			logrus.Errorf("Failed to write data for CID %s: %v", workEvent.CID, err)
 			return
 		}
-		//err = node.PubSubManager.Publish(config.TopicWithVersion(config.BlockTopic), workEvent.Payload)
-		//if err != nil {
-		//	logrus.Errorf("Error publishing block: %v", err)
-		//}
 	}
 
 	var nodeData pubsub.NodeData
@@ -342,9 +338,9 @@ func SendWork(node *masa.OracleNode, m *pubsub2.Message) {
 						return
 					}
 					spawnedPID := spawned.Pid
-					// Check if spawnedPID is nil
+					// Check if spawnedPID is nil we dont need to show this to the user
 					if spawnedPID == nil {
-						logrus.Errorf("spawnedPID is nil for IP: %s", ipAddr)
+						logrus.Debugf("spawned pid is not a worker for IP: %s", ipAddr)
 						return
 					}
 					client := node.ActorEngine.Spawn(props)
@@ -510,6 +506,7 @@ func processWork(data *pubsub2.Message, work string, startTime *time.Time, node
 		Duration:  duration.Seconds(),
 		Timestamp: time.Now().Unix(),
 	}
+
 	// @todo handle mutliple block publishes issue
 	// _ = node.PubSubManager.Publish(config.TopicWithVersion(config.BlockTopic), workEvent.Payload)