update

im/tg/tg.go

@@ -27,30 +27,32 @@ var Handler = func(message *tb.Message) {
 }
 
 func init() {
-	token := tg.Get("token")
+	go func() {
-	if token == "" {
+		token := tg.Get("token")
-		logs.Warn("未提供telegram机器人token")
+		if token == "" {
-		return
+			logs.Warn("未提供telegram机器人token")
-	}
+			return
-	var err error
+		}
-	b, err = tb.NewBot(tb.Settings{
+		var err error
-		Token:  token,
+		b, err = tb.NewBot(tb.Settings{
-		Poller: &tb.LongPoller{Timeout: 10 * time.Second},
+			Token:  token,
-	})
+			Poller: &tb.LongPoller{Timeout: 10 * time.Second},
+		})
 
-	if err != nil {
+		if err != nil {
-		logs.Warn("监听telegram机器人失败：%v", err)
+			logs.Warn("监听telegram机器人失败：%v", err)
-		return
+			return
-	}
+		}
-	core.Pushs["tg"] = func(i int, s string) {
+		core.Pushs["tg"] = func(i int, s string) {
-		b.Send(&tb.User{ID: i}, s)
+			b.Send(&tb.User{ID: i}, s)
-	}
+		}
-	core.GroupPushs["tg"] = func(i, j int, s string) {
+		core.GroupPushs["tg"] = func(i, j int, s string) {
-		b.Send(&tb.Chat{ID: int64(i)}, s)
+			b.Send(&tb.Chat{ID: int64(i)}, s)
-	}
+		}
-	b.Handle(tb.OnText, Handler)
+		b.Handle(tb.OnText, Handler)
-	logs.Info("监听telegram机器人")
+		logs.Info("监听telegram机器人")
-	b.Start()
+		b.Start()
+	}()
 }
 
 func (sender *Sender) GetContent() string {