aboutsummaryrefslogtreecommitdiff
path: root/syncapi/storage/postgres/receipt_table.go
diff options
context:
space:
mode:
Diffstat (limited to 'syncapi/storage/postgres/receipt_table.go')
-rw-r--r--syncapi/storage/postgres/receipt_table.go10
1 files changed, 10 insertions, 0 deletions
diff --git a/syncapi/storage/postgres/receipt_table.go b/syncapi/storage/postgres/receipt_table.go
index 2a42ffd7..bbddaa93 100644
--- a/syncapi/storage/postgres/receipt_table.go
+++ b/syncapi/storage/postgres/receipt_table.go
@@ -23,6 +23,7 @@ import (
"github.com/matrix-org/dendrite/internal"
"github.com/matrix-org/dendrite/internal/sqlutil"
+ "github.com/matrix-org/dendrite/syncapi/storage/postgres/deltas"
"github.com/matrix-org/dendrite/syncapi/storage/tables"
"github.com/matrix-org/dendrite/syncapi/types"
"github.com/matrix-org/gomatrixserverlib"
@@ -73,6 +74,15 @@ func NewPostgresReceiptsTable(db *sql.DB) (tables.Receipts, error) {
if err != nil {
return nil, err
}
+ m := sqlutil.NewMigrator(db)
+ m.AddMigrations(sqlutil.Migration{
+ Version: "syncapi: fix sequences",
+ Up: deltas.UpFixSequences,
+ })
+ err = m.Up(context.Background())
+ if err != nil {
+ return nil, err
+ }
r := &receiptStatements{
db: db,
}