mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-18 12:23:09 -06:00
more fixes
This commit is contained in:
parent
9016bbd44b
commit
e2803ab4a6
|
|
@ -113,6 +113,7 @@ type outputRoomEventsStatements struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *outputRoomEventsStatements) prepare(db *sql.DB, rvs *roomVersionStatements, streamID *streamIDStatements) (err error) {
|
func (s *outputRoomEventsStatements) prepare(db *sql.DB, rvs *roomVersionStatements, streamID *streamIDStatements) (err error) {
|
||||||
|
s.roomVersions = rvs
|
||||||
s.streamIDStatements = streamID
|
s.streamIDStatements = streamID
|
||||||
_, err = db.Exec(outputRoomEventsSchema)
|
_, err = db.Exec(outputRoomEventsSchema)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,6 @@ package sqlite3
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"fmt"
|
|
||||||
|
|
||||||
"github.com/matrix-org/dendrite/common"
|
"github.com/matrix-org/dendrite/common"
|
||||||
"github.com/matrix-org/gomatrixserverlib"
|
"github.com/matrix-org/gomatrixserverlib"
|
||||||
|
|
@ -40,6 +39,5 @@ func (s *roomVersionStatements) selectRoomVersion(
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
roomVersion = gomatrixserverlib.RoomVersion(rv.String())
|
roomVersion = gomatrixserverlib.RoomVersion(rv.String())
|
||||||
fmt.Println("room version for", roomID, "is", rv.String())
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue