hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2024-12-26 15:08:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Print number of events

Browse source
This commit is contained in:
Neil Alexander 2021-04-19 14:49:18 +01:00
parent 3bae18d9cc
commit 4198adfab8
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go
View file

@ -58,7 +58,7 @@ func UpStateBlocksRefactor(tx *sql.Tx) error {
_, err = tx.Exec(`
CREATE SEQUENCE IF NOT EXISTS roomserver_state_snapshot_nid_seq;
CREATE TABLE IF NOT EXISTS roomserver_state_snapshots (
state_snapshot_nid bigint PRIMARY KEY DEFAULT nextval('roomserver_state_snapshot_nid_seq'),
state_snapshot_nid bigserial PRIMARY KEY,
room_nid bigint NOT NULL,
state_block_nids bigint[] NOT NULL,
UNIQUE (room_nid, state_block_nids)
@ -152,7 +152,7 @@ func UpStateBlocksRefactor(tx *sql.Tx) error {
RETURNING state_block_nid
`, eventsarray).Scan(&blocknid)
if err != nil {
return fmt.Errorf("tx.QueryRow.Scan (insert new block): %w", err)
return fmt.Errorf("tx.QueryRow.Scan (insert new block with %d events): %w", len(eventsarray), err)
}
newblocks = append(newblocks, blocknid)