diff --git a/roomserver/storage/sqlite3/event_json_table.go b/roomserver/storage/sqlite3/event_json_table.go index dc26885bb..9fc5ad973 100644 --- a/roomserver/storage/sqlite3/event_json_table.go +++ b/roomserver/storage/sqlite3/event_json_table.go @@ -18,6 +18,7 @@ package sqlite3 import ( "context" "database/sql" + "fmt" "strings" "github.com/matrix-org/dendrite/internal" @@ -111,3 +112,9 @@ func (s *eventJSONStatements) BulkSelectEventJSON( } return results[:i], nil } + +func (s *eventJSONStatements) PurgeEventJSONs( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/events_table.go b/roomserver/storage/sqlite3/events_table.go index 943f256eb..28b8afaf2 100644 --- a/roomserver/storage/sqlite3/events_table.go +++ b/roomserver/storage/sqlite3/events_table.go @@ -646,3 +646,9 @@ func (s *eventStatements) SelectEventRejected( err = stmt.QueryRowContext(ctx, roomNID, eventID).Scan(&rejected) return } + +func (s *eventStatements) PurgeEvents( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/invite_table.go b/roomserver/storage/sqlite3/invite_table.go index e051d63af..e02497153 100644 --- a/roomserver/storage/sqlite3/invite_table.go +++ b/roomserver/storage/sqlite3/invite_table.go @@ -18,6 +18,7 @@ package sqlite3 import ( "context" "database/sql" + "fmt" "github.com/matrix-org/dendrite/internal" "github.com/matrix-org/dendrite/internal/sqlutil" @@ -158,3 +159,9 @@ func (s *inviteStatements) SelectInviteActiveForUserInRoom( } return result, eventIDs, nil } + +func (s *inviteStatements) PurgeInvites( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/membership_table.go b/roomserver/storage/sqlite3/membership_table.go index f3303eb0e..540985d04 100644 --- a/roomserver/storage/sqlite3/membership_table.go +++ b/roomserver/storage/sqlite3/membership_table.go @@ -407,3 +407,9 @@ func (s *membershipStatements) DeleteMembership( ) return err } + +func (s *membershipStatements) PurgeMemberships( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/previous_events_table.go b/roomserver/storage/sqlite3/previous_events_table.go index 2a146ef64..a59732263 100644 --- a/roomserver/storage/sqlite3/previous_events_table.go +++ b/roomserver/storage/sqlite3/previous_events_table.go @@ -129,3 +129,9 @@ func (s *previousEventStatements) SelectPreviousEventExists( stmt := sqlutil.TxStmt(txn, s.selectPreviousEventExistsStmt) return stmt.QueryRowContext(ctx, eventID, eventReferenceSHA256).Scan(&ok) } + +func (s *previousEventStatements) PurgePreviousEvents( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/published_table.go b/roomserver/storage/sqlite3/published_table.go index 50dfa5492..77426afcf 100644 --- a/roomserver/storage/sqlite3/published_table.go +++ b/roomserver/storage/sqlite3/published_table.go @@ -17,6 +17,7 @@ package sqlite3 import ( "context" "database/sql" + "fmt" "github.com/matrix-org/dendrite/internal" "github.com/matrix-org/dendrite/internal/sqlutil" @@ -106,3 +107,9 @@ func (s *publishedStatements) SelectAllPublishedRooms( } return roomIDs, rows.Err() } + +func (s *publishedStatements) PurgePublished( + ctx context.Context, txn *sql.Tx, roomID string, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/redactions_table.go b/roomserver/storage/sqlite3/redactions_table.go index db6f57a1b..702713fd1 100644 --- a/roomserver/storage/sqlite3/redactions_table.go +++ b/roomserver/storage/sqlite3/redactions_table.go @@ -17,9 +17,11 @@ package sqlite3 import ( "context" "database/sql" + "fmt" "github.com/matrix-org/dendrite/internal/sqlutil" "github.com/matrix-org/dendrite/roomserver/storage/tables" + "github.com/matrix-org/dendrite/roomserver/types" ) const redactionsSchema = ` @@ -121,3 +123,9 @@ func (s *redactionStatements) MarkRedactionValidated( _, err := stmt.ExecContext(ctx, validated, redactionEventID) return err } + +func (s *redactionStatements) PurgeRedactions( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/room_aliases_table.go b/roomserver/storage/sqlite3/room_aliases_table.go index 3bdbbaa35..ca63c55bf 100644 --- a/roomserver/storage/sqlite3/room_aliases_table.go +++ b/roomserver/storage/sqlite3/room_aliases_table.go @@ -18,6 +18,7 @@ package sqlite3 import ( "context" "database/sql" + "fmt" "github.com/matrix-org/dendrite/internal" "github.com/matrix-org/dendrite/internal/sqlutil" @@ -143,3 +144,9 @@ func (s *roomAliasesStatements) DeleteRoomAlias( _, err := stmt.ExecContext(ctx, alias) return err } + +func (s *roomAliasesStatements) PurgeRoomAliases( + ctx context.Context, txn *sql.Tx, roomID string, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/state_block_table.go b/roomserver/storage/sqlite3/state_block_table.go index 4e67d4da1..353eab978 100644 --- a/roomserver/storage/sqlite3/state_block_table.go +++ b/roomserver/storage/sqlite3/state_block_table.go @@ -141,3 +141,9 @@ func (s *stateBlockStatements) BulkSelectStateBlockEntries( } return results, err } + +func (s *stateBlockStatements) PurgeStateBlocks( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +} diff --git a/roomserver/storage/sqlite3/state_snapshot_table.go b/roomserver/storage/sqlite3/state_snapshot_table.go index 73827522c..3f4d8ba83 100644 --- a/roomserver/storage/sqlite3/state_snapshot_table.go +++ b/roomserver/storage/sqlite3/state_snapshot_table.go @@ -146,3 +146,9 @@ func (s *stateSnapshotStatements) BulkSelectStateForHistoryVisibility( ) ([]types.EventNID, error) { return nil, tables.OptimisationNotSupportedError } + +func (s *stateSnapshotStatements) PurgeStateSnapshots( + ctx context.Context, txn *sql.Tx, roomNID types.RoomNID, +) error { + return fmt.Errorf("not implemented on SQLite") +}