From 08dcc1462981b0cf482975c58087e3e6ebeb2291 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Sun, 22 Jan 2023 00:02:53 +0300
Subject: [PATCH] update

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 test2/worker.go | 28 +++++++++++++++++-----------
 1 file changed, 17 insertions(+), 11 deletions(-)

diff --git a/test2/worker.go b/test2/worker.go
index 191364b..954ad28 100644
--- a/test2/worker.go
+++ b/test2/worker.go
@@ -23,14 +23,14 @@ type Input struct {
 type TipMsg struct {
 	Channel  string `json:"channel"`
 	Messages []struct {
-		Name   string `json:"name"`
-		Amount int64  `json:"amount"`
-		From   string `json:"from_username"`
+		Data string `json:"data"`
 	} `json:"messages"`
 }
 
 type Donate struct {
-	Amount int64 `json:"amount"`
+	Name   string `json:"name"`
+	From   string `json:"from_username"`
+	Amount int64  `json:"amount"`
 }
 
 func getAuth(room string) (string, string, error) {
@@ -295,21 +295,27 @@ func statRoom(room, server string, _ url.URL) {
 
 			*/
 
-			donate := &TipMsg{}
+			tipMsg := &TipMsg{}
 
 			timeout = time.Now().Unix() + 60*60
 
-			if err := json.Unmarshal([]byte(m), &donate); err != nil {
+			if err := json.Unmarshal([]byte(m), tipMsg); err != nil {
 				fmt.Println(err.Error())
 				continue
 			}
-			fmt.Printf("donate %#+v\n", donate)
-			if donate.Channel != "room:tip_alert:"+room_uid {
+			// fmt.Printf("msg %s\n", m)
+
+			if tipMsg.Channel != "room:tip_alert:"+room_uid {
 				continue
 			}
-			for _, msg := range donate.Messages {
-				if len(msg.From) > 3 {
-					fmt.Println(msg.From, " send ", msg.Amount, "tokens")
+			for _, msg := range tipMsg.Messages {
+				donate := &Donate{}
+				if err := json.Unmarshal([]byte(msg.Data), donate); err != nil {
+					fmt.Println(err.Error())
+					continue
+				}
+				if len(donate.From) > 3 {
+					fmt.Println(donate.From, " send ", donate.Amount, "tokens")
 				}
 			}