mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-18 12:23:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix npe

Browse source
This commit is contained in:
Kegan Dougal 2020-05-13 18:43:41 +01:00
parent f9cda7a52f
commit 63298b666a
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
syncapi/storage/sqlite3/account_data_table.go
View file

@ -56,8 +56,10 @@ type accountDataStatements struct {
selectAccountDataInRangeStmt *sql.Stmt selectAccountDataInRangeStmt *sql.Stmt
} }
func NewSqliteAccountDataTable(db *sql.DB) (tables.AccountData, error) { func NewSqliteAccountDataTable(db *sql.DB, streamID *streamIDStatements) (tables.AccountData, error) {
s := &accountDataStatements{} s := &accountDataStatements{
streamIDStatements: streamID,
}
_, err := db.Exec(accountDataSchema) _, err := db.Exec(accountDataSchema)
if err != nil { if err != nil {
return nil, err return nil, err

2
syncapi/storage/sqlite3/syncserver.go
View file

@ -93,7 +93,7 @@ func (d *SyncServerDatasource) prepare() (err error) {
if err = d.streamID.prepare(d.db); err != nil { if err = d.streamID.prepare(d.db); err != nil {
return err return err
} }
accountData, err := NewSqliteAccountDataTable(d.db) accountData, err := NewSqliteAccountDataTable(d.db, &d.streamID)
if err != nil { if err != nil {
return err return err
} }