From a6ee8101e61e35afa86ba8d5c318f7a0af421373 Mon Sep 17 00:00:00 2001 From: 0xdcarns Date: Mon, 25 Apr 2022 19:28:56 -0400 Subject: [PATCH] small refactors --- mq/handlers.go | 2 +- netclient/functions/common.go | 6 +++--- netclient/functions/join.go | 3 +-- netclient/functions/pull.go | 4 ++-- 4 files changed, 7 insertions(+), 8 deletions(-) diff --git a/mq/handlers.go b/mq/handlers.go index 136f738c..27d57fd0 100644 --- a/mq/handlers.go +++ b/mq/handlers.go @@ -48,7 +48,7 @@ func Ping(client mqtt.Client, msg mqtt.Message) { return } - logger.Log(3, "ping processed for node", node.ID) + logger.Log(3, "ping processed for node", node.Name, node.ID) // --TODO --set client version once feature is implemented. //node.SetClientVersion(msg.Payload()) }() diff --git a/netclient/functions/common.go b/netclient/functions/common.go index 4f38138b..1a2d3dbe 100644 --- a/netclient/functions/common.go +++ b/netclient/functions/common.go @@ -5,7 +5,7 @@ import ( "encoding/json" "errors" "fmt" - "io/ioutil" + "io" "log" "net" "net/http" @@ -169,7 +169,7 @@ func LeaveNetwork(network string, force bool) error { if response.StatusCode == http.StatusOK { logger.Log(0, "deleted node", cfg.Node.Name, " on network ", cfg.Network) } else { - bodybytes, _ := ioutil.ReadAll(response.Body) + bodybytes, _ := io.ReadAll(response.Body) defer response.Body.Close() return fmt.Errorf("error deleting node on server %s %s", response.Status, string(bodybytes)) } @@ -355,7 +355,7 @@ func Authenticate(cfg *config.ClientConfig) (string, error) { } defer response.Body.Close() if response.StatusCode != http.StatusOK { - bodybytes, _ := ioutil.ReadAll(response.Body) + bodybytes, _ := io.ReadAll(response.Body) return "", fmt.Errorf("failed to authenticate %s %s", response.Status, string(bodybytes)) } resp := models.SuccessResponse{} diff --git a/netclient/functions/join.go b/netclient/functions/join.go index 4c7bf7d3..930b8ad9 100644 --- a/netclient/functions/join.go +++ b/netclient/functions/join.go @@ -6,7 +6,6 @@ import ( "errors" "fmt" "io" - "io/ioutil" "log" "net/http" "runtime" @@ -141,7 +140,7 @@ func JoinNetwork(cfg *config.ClientConfig, privateKey string) error { var nodeGET models.NodeGet if err := json.NewDecoder(response.Body).Decode(&nodeGET); err != nil { //not sure the next line will work as response.Body probably needs to be reset before it can be read again - bodybytes, _ := ioutil.ReadAll(response.Body) + bodybytes, _ := io.ReadAll(response.Body) return fmt.Errorf("error decoding node from server %w %s", err, string(bodybytes)) } node := nodeGET.Node diff --git a/netclient/functions/pull.go b/netclient/functions/pull.go index 79a7abb0..d82bf8ea 100644 --- a/netclient/functions/pull.go +++ b/netclient/functions/pull.go @@ -4,7 +4,7 @@ import ( "encoding/json" "errors" "fmt" - "io/ioutil" + "io" "net/http" "os" "runtime" @@ -39,7 +39,7 @@ func Pull(network string, iface bool) (*models.Node, error) { return nil, err } if response.StatusCode != http.StatusOK { - bytes, err := ioutil.ReadAll(response.Body) + bytes, err := io.ReadAll(response.Body) if err != nil { fmt.Println(err) }