diff --git a/pkg/node/worker.go b/pkg/node/worker.go index 50ddf0d..f5f85b8 100644 --- a/pkg/node/worker.go +++ b/pkg/node/worker.go @@ -234,18 +234,18 @@ func (worker *Worker) handleStartMiner(msg *Message) (*Message, error) { // Start the miner miner, err := worker.minerManager.StartMiner(payload.MinerType, config) if err != nil { - ack := MinerAckPayload{ + acknowledgement := MinerAckPayload{ Success: false, Error: err.Error(), } - return msg.Reply(MsgMinerAck, ack) + return msg.Reply(MsgMinerAck, acknowledgement) } - ack := MinerAckPayload{ + acknowledgement := MinerAckPayload{ Success: true, MinerName: miner.GetName(), } - return msg.Reply(MsgMinerAck, ack) + return msg.Reply(MsgMinerAck, acknowledgement) } // response, err := worker.handleStopMiner(message) @@ -260,15 +260,15 @@ func (worker *Worker) handleStopMiner(msg *Message) (*Message, error) { } err := worker.minerManager.StopMiner(payload.MinerName) - ack := MinerAckPayload{ + acknowledgement := MinerAckPayload{ Success: err == nil, MinerName: payload.MinerName, } if err != nil { - ack.Error = err.Error() + acknowledgement.Error = err.Error() } - return msg.Reply(MsgMinerAck, ack) + return msg.Reply(MsgMinerAck, acknowledgement) } // response, err := worker.handleGetLogs(message) @@ -344,19 +344,19 @@ func (worker *Worker) handleDeploy(conn *PeerConnection, msg *Message) (*Message } if err := worker.profileManager.SaveProfile(profile); err != nil { - ack := DeployAckPayload{ + acknowledgement := DeployAckPayload{ Success: false, Name: payload.Name, Error: err.Error(), } - return msg.Reply(MsgDeployAck, ack) + return msg.Reply(MsgDeployAck, acknowledgement) } - ack := DeployAckPayload{ + acknowledgement := DeployAckPayload{ Success: true, Name: payload.Name, } - return msg.Reply(MsgDeployAck, ack) + return msg.Reply(MsgDeployAck, acknowledgement) case BundleMiner, BundleFull: // Determine installation directory @@ -389,7 +389,7 @@ func (worker *Worker) handleDeploy(conn *PeerConnection, msg *Message) (*Message } // Success response - ack := DeployAckPayload{ + acknowledgement := DeployAckPayload{ Success: true, Name: payload.Name, } @@ -400,7 +400,7 @@ func (worker *Worker) handleDeploy(conn *PeerConnection, msg *Message) (*Message "miner_path": minerPath, }) - return msg.Reply(MsgDeployAck, ack) + return msg.Reply(MsgDeployAck, acknowledgement) default: return nil, &ProtocolError{Code: ErrCodeInvalidMessage, Message: "unknown bundle type: " + payload.BundleType}