aboutsummaryrefslogtreecommitdiff
path: root/userapi/storage/postgres/accounts_table.go
diff options
context:
space:
mode:
Diffstat (limited to 'userapi/storage/postgres/accounts_table.go')
-rw-r--r--userapi/storage/postgres/accounts_table.go18
1 files changed, 18 insertions, 0 deletions
diff --git a/userapi/storage/postgres/accounts_table.go b/userapi/storage/postgres/accounts_table.go
index e3cab56e..33fb6dd4 100644
--- a/userapi/storage/postgres/accounts_table.go
+++ b/userapi/storage/postgres/accounts_table.go
@@ -24,6 +24,7 @@ import (
"github.com/matrix-org/dendrite/clientapi/userutil"
"github.com/matrix-org/dendrite/internal/sqlutil"
"github.com/matrix-org/dendrite/userapi/api"
+ "github.com/matrix-org/dendrite/userapi/storage/postgres/deltas"
"github.com/matrix-org/dendrite/userapi/storage/tables"
log "github.com/sirupsen/logrus"
@@ -85,6 +86,23 @@ func NewPostgresAccountsTable(db *sql.DB, serverName gomatrixserverlib.ServerNam
if err != nil {
return nil, err
}
+ m := sqlutil.NewMigrator(db)
+ m.AddMigrations([]sqlutil.Migration{
+ {
+ Version: "userapi: add is active",
+ Up: deltas.UpIsActive,
+ Down: deltas.DownIsActive,
+ },
+ {
+ Version: "userapi: add account type",
+ Up: deltas.UpAddAccountType,
+ Down: deltas.DownAddAccountType,
+ },
+ }...)
+ err = m.Up(context.Background())
+ if err != nil {
+ return nil, err
+ }
return s, sqlutil.StatementList{
{&s.insertAccountStmt, insertAccountSQL},
{&s.updatePasswordStmt, updatePasswordSQL},