From 328ae09ce7ae974c6288a4dc886c9fe30b05ef3d Mon Sep 17 00:00:00 2001
From: GoEdgeLab <goedgecloud@gmail.com>
Date: Fri, 26 Aug 2022 16:47:46 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0edge-node=20bandwidth?=
 =?UTF-8?q?=E5=91=BD=E4=BB=A4=E6=9F=A5=E7=9C=8B=E5=AE=9E=E6=97=B6=E5=B8=A6?=
 =?UTF-8?q?=E5=AE=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cmd/edge-node/main.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/cmd/edge-node/main.go b/cmd/edge-node/main.go
index de0841c..9a90a19 100644
--- a/cmd/edge-node/main.go
+++ b/cmd/edge-node/main.go
@@ -318,6 +318,21 @@ func main() {
 			}
 		}
 	})
+	app.On("bandwidth", func() {
+		var sock = gosock.NewTmpSock(teaconst.ProcessName)
+		reply, err := sock.Send(&gosock.Command{Code: "bandwidth"})
+		if err != nil {
+			fmt.Println("[ERROR]" + err.Error())
+			return
+		}
+		var statsMap = maps.NewMap(reply.Params).Get("stats")
+		statsJSON, err := json.MarshalIndent(statsMap, "", "  ")
+		if err != nil {
+			fmt.Println("[ERROR]" + err.Error())
+			return
+		}
+		fmt.Println(string(statsJSON))
+	})
 	app.Run(func() {
 		var node = nodes.NewNode()
 		node.Start()