From fe1a8169e6f98f98148b1c7d991e559d0e074e35 Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Mon, 1 Feb 2021 17:13:54 +0800
Subject: [PATCH] move pulsar send to telegram.go

---
 utils/sqlite.go   | 6 ------
 utils/telegram.go | 7 +++++++
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 88f2473..50e97dd 100644
--- a/utils/sqlite.go
+++ b/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 {
diff --git a/utils/telegram.go b/utils/telegram.go
index 474b207..cfc300e 100644
--- a/utils/telegram.go
+++ b/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
 		}