From 6892e0f0e02466be3cac6fc6f17267aeecb5961b Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 26 Apr 2022 16:02:21 +0100 Subject: [PATCH] Start account data ID from `from` --- syncapi/storage/postgres/account_data_table.go | 2 +- syncapi/storage/sqlite3/account_data_table.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/syncapi/storage/postgres/account_data_table.go b/syncapi/storage/postgres/account_data_table.go index 22bb4d7f..0a714691 100644 --- a/syncapi/storage/postgres/account_data_table.go +++ b/syncapi/storage/postgres/account_data_table.go @@ -118,7 +118,7 @@ func (s *accountDataStatements) SelectAccountDataInRange( var dataType string var roomID string - var id types.StreamPosition + id := r.From for rows.Next() { if err = rows.Scan(&id, &roomID, &dataType); err != nil { diff --git a/syncapi/storage/sqlite3/account_data_table.go b/syncapi/storage/sqlite3/account_data_table.go index e0d97ec3..d84159ac 100644 --- a/syncapi/storage/sqlite3/account_data_table.go +++ b/syncapi/storage/sqlite3/account_data_table.go @@ -114,7 +114,7 @@ func (s *accountDataStatements) SelectAccountDataInRange( var dataType string var roomID string - var id types.StreamPosition + id := r.From for rows.Next() { if err = rows.Scan(&id, &roomID, &dataType); err != nil {