From 1366f25de2c09bd3170d0f8dcb1b1a96e0b1609b Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 21 Jan 2020 15:42:28 +0000 Subject: [PATCH] Add a couple of missing functions into the syncapi external storage interface --- syncapi/storage/storage.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/syncapi/storage/storage.go b/syncapi/storage/storage.go index bb41abeef..4e8a2c837 100644 --- a/syncapi/storage/storage.go +++ b/syncapi/storage/storage.go @@ -48,9 +48,11 @@ type Database interface { RemoveTypingUser(userID, roomID string) types.StreamPosition GetEventsInRange(ctx context.Context, from, to *types.PaginationToken, roomID string, limit int, backwardOrdering bool) (events []types.StreamEvent, err error) EventPositionInTopology(ctx context.Context, eventID string) (types.StreamPosition, error) + EventsAtTopologicalPosition(ctx context.Context, roomID string, pos types.StreamPosition) ([]types.StreamEvent, error) BackwardExtremitiesForRoom(ctx context.Context, roomID string) (backwardExtremities []string, err error) MaxTopologicalPosition(ctx context.Context, roomID string) (types.StreamPosition, error) StreamEventsToEvents(device *authtypes.Device, in []types.StreamEvent) []gomatrixserverlib.Event + SyncStreamPosition(ctx context.Context) (types.StreamPosition, error) } // NewPublicRoomsServerDatabase opens a database connection.