move pulsar send to telegram.go

utils/sqlite.go

@@ -70,12 +70,6 @@ func InsertTelegram(teleString string) {
 	db := getDb()
 	defer db.Close()
 	var insertSQL string
-	if Pulsar {
-		err := PulsarSend(teleString)
-		if err != nil {
-			Log.Error("error in send to pulsar", zap.Error(err))
-		}
-	}
 	if ClientReady && WriteToClient(teleString) == nil {
 		insertSQL = InsertOld
 	} else {

utils/telegram.go

@@ -1,6 +1,7 @@
 package utils
 
 import (
+	"go.uber.org/zap"
 	"regexp"
 	"strings"
 
@@ -33,6 +34,12 @@ func check() bool {
 			telegram += "\n"
 			_, _ = RawLog.Write([]byte(telegram + "\n"))
 			buffer = ""
+			if Pulsar {
+				err := PulsarSend(telegram)
+				if err != nil {
+					Log.Error("error in send to pulsar", zap.Error(err))
+				}
+			}
 			InsertTelegram(telegram)
 			return true
 		}