handle api with SafeGo

lz1998 · lz1998 · commit 0d4f911f706c · 2020-11-30T01:34:57.000+08:00
diff --git a/service/bot/remote.go b/service/bot/remote.go
@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/Mrs4s/MiraiGo/client"
+	"github.com/ProtobufBot/Go-Mirai-Client/pkg/util"
 	"github.com/ProtobufBot/Go-Mirai-Client/proto_gen/onebot"
 	"github.com/golang/protobuf/proto"
 	"github.com/gorilla/websocket"
@@ -100,7 +101,7 @@ func ListenApi(cli *client.QQClient) {
 			continue
 		}
 
-		go func() {
+		util.SafeGo(func() {
 			resp := handleApiFrame(cli, &req)
 			respBytes, err := resp.Marshal()
 			if err != nil {
@@ -110,7 +111,7 @@ func ListenApi(cli *client.QQClient) {
 			if err != nil {
 				log.Errorf("发送ApiResp错误 %v", err)
 			}
-		}()
+		})
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`"time"`
`8`	`8`
`9`	`9`	`"github.com/Mrs4s/MiraiGo/client"`
	`10`	`+ "github.com/ProtobufBot/Go-Mirai-Client/pkg/util"`
`10`	`11`	`"github.com/ProtobufBot/Go-Mirai-Client/proto_gen/onebot"`
`11`	`12`	`"github.com/golang/protobuf/proto"`
`12`	`13`	`"github.com/gorilla/websocket"`
`@@ -100,7 +101,7 @@ func ListenApi(cli *client.QQClient) {`
`100`	`101`	`continue`
`101`	`102`	`}`
`102`	`103`
`103`		`- go func() {`
	`104`	`+ util.SafeGo(func() {`
`104`	`105`	`resp := handleApiFrame(cli, &req)`
`105`	`106`	`respBytes, err := resp.Marshal()`
`106`	`107`	`if err != nil {`
`@@ -110,7 +111,7 @@ func ListenApi(cli *client.QQClient) {`
`110`	`111`	`if err != nil {`
`111`	`112`	`log.Errorf("发送ApiResp错误 %v", err)`
`112`	`113`	`}`
`113`		`- }()`
	`114`	`+ })`
`114`	`115`	`}`
`115`	`116`	`}`
`116`	`117`