Add missing table

This commit is contained in:
Kegan Dougal 2020-05-26 19:09:17 +01:00
parent 08f5ee94d9
commit 9c139db82d
2 changed files with 10 additions and 0 deletions

View file

@ -87,6 +87,10 @@ func Open(dataSourceName string, dbProperties internal.DbProperties) (*Database,
if err != nil {
return nil, err
}
roomAliases, err := NewPostgresRoomAliasesTable(d.db)
if err != nil {
return nil, err
}
d.prevEvents, err = NewPostgresPreviousEventsTable(d.db)
if err != nil {
return nil, err
@ -102,6 +106,7 @@ func Open(dataSourceName string, dbProperties internal.DbProperties) (*Database,
StateBlockTable: stateBlock,
StateSnapshotTable: stateSnapshot,
PrevEventsTable: d.prevEvents,
RoomAliasesTable: roomAliases,
}
return &d, nil
}

View file

@ -111,6 +111,10 @@ func Open(dataSourceName string) (*Database, error) {
if err != nil {
return nil, err
}
roomAliases, err := NewSqliteRoomAliasesTable(d.db)
if err != nil {
return nil, err
}
d.Database = shared.Database{
DB: d.db,
EventsTable: d.events,
@ -122,6 +126,7 @@ func Open(dataSourceName string) (*Database, error) {
StateBlockTable: stateBlock,
StateSnapshotTable: stateSnapshot,
PrevEventsTable: d.prevEvents,
RoomAliasesTable: roomAliases,
}
return &d, nil
}