diff --git a/cmd/masa-node-cli/components.go b/cmd/masa-node-cli/components.go index 0f78696f..966e3e5a 100644 --- a/cmd/masa-node-cli/components.go +++ b/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 diff --git a/pkg/config/constants.go b/pkg/config/constants.go index c8f861ed..9ddbbf5f 100644 --- a/pkg/config/constants.go +++ b/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" diff --git a/pkg/db/operations.go b/pkg/db/operations.go index 0d5f7aa0..b6cc65b8 100644 --- a/pkg/db/operations.go +++ b/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 } diff --git a/pkg/workers/workers.go b/pkg/workers/workers.go index 2b5269e4..27c29971 100644 --- a/pkg/workers/workers.go +++ b/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)