From 8b7e6ca8bcdedea56a98b026e9f5dab975019a05 Mon Sep 17 00:00:00 2001 From: Mohammed Sohail Date: Mon, 24 Mar 2025 12:17:26 +0300 Subject: [PATCH] (temp): migration (disable dual syncer) --- cmd/main.go | 4 ++-- internal/syncer/syncer.go | 4 +++- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/cmd/main.go b/cmd/main.go index 9f86c1d..117f653 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -71,7 +71,7 @@ func main() { wg.Add(1) go func() { defer wg.Done() - syncer.Run() + // syncer.Run() }() <-ctx.Done() @@ -80,7 +80,7 @@ func main() { wg.Add(1) go func() { - syncer.Stop() + // syncer.Stop() defer wg.Done() }() diff --git a/internal/syncer/syncer.go b/internal/syncer/syncer.go index fc3e76a..98ad747 100644 --- a/internal/syncer/syncer.go +++ b/internal/syncer/syncer.go @@ -15,6 +15,7 @@ const syncInterval = time.Hour * 1 type ( KVRow struct { + ID int `db:"id"` Key []byte `db:"key"` Value []byte `db:"value"` Updated time.Time `db:"updated"` @@ -91,7 +92,8 @@ func (s *Syncer) Process(ctx context.Context) error { } decodedValue := data.DecodeValue(row.Value) - s.logg.Debug("processing row", "key_type", decodedKeyDataType, "session_id", sessionID, "value", decodedValue, "timestamp", row.Updated, "column", column) + s.logg.Info("processing row", "id", row.ID) + s.logg.Debug("processing row", "id", row.ID, "key_type", decodedKeyDataType, "session_id", sessionID, "value", decodedValue, "timestamp", row.Updated, "column", column) query := fmt.Sprintf(` INSERT INTO ussd_data (phone_number, %s) VALUES ($1, $2)