add client ready flag
This commit is contained in:
@@ -12,6 +12,7 @@ const ServerType = "tcp"
|
||||
var ServerRunning = false
|
||||
var client net.Conn
|
||||
var server net.Listener
|
||||
var ClientReady = false
|
||||
|
||||
func Listen(address string) {
|
||||
var err error
|
||||
@@ -29,6 +30,7 @@ func Listen(address string) {
|
||||
}
|
||||
if client == nil {
|
||||
client = conn
|
||||
ClientReady = false
|
||||
log.Println("client connected ", client.RemoteAddr())
|
||||
LoadUnprocessed()
|
||||
} else {
|
||||
|
||||
+3
-1
@@ -70,7 +70,7 @@ func InsertTelegram(teleString string) {
|
||||
db := getDb()
|
||||
defer db.Close()
|
||||
var insertSQL string
|
||||
if IsClientConnected() && WriteToClient(teleString) == nil {
|
||||
if ClientReady && WriteToClient(teleString) == nil {
|
||||
insertSQL = InsertOld
|
||||
} else {
|
||||
insertSQL = InsertNew
|
||||
@@ -104,6 +104,8 @@ func LoadUnprocessed() {
|
||||
}
|
||||
}
|
||||
}
|
||||
ClientReady = true
|
||||
log.Println("client is ready for new telegram")
|
||||
}
|
||||
|
||||
func getTelegram(db *sql.DB) []telegram {
|
||||
|
||||
Reference in New Issue
Block a user