diff --git a/utils/sqlite.go b/utils/sqlite.go index c370901..a607032 100644 --- a/utils/sqlite.go +++ b/utils/sqlite.go @@ -90,10 +90,12 @@ func InsertTelegram(teleString string) { } func LoadUnprocessed() { + log.Println("loading telegram") db := getDb() defer db.Close() for { num := countTelegram() + log.Println("unprocessed : ", num) if num < 1 { break } @@ -103,7 +105,7 @@ func LoadUnprocessed() { defer rows.Close() for rows.Next() { var t telegram - err := rows.Scan(&t) + err := rows.Scan(&t.id, &t.text) checkDbErr(err, "error in scan telegram") if WriteToClient(t.text) == nil { processed(t)