aboutsummaryrefslogtreecommitdiff
path: root/syncapi/storage/postgres/account_data_table.go
diff options
context:
space:
mode:
Diffstat (limited to 'syncapi/storage/postgres/account_data_table.go')
-rw-r--r--syncapi/storage/postgres/account_data_table.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/syncapi/storage/postgres/account_data_table.go b/syncapi/storage/postgres/account_data_table.go
index 3d75ad99..d1811aa6 100644
--- a/syncapi/storage/postgres/account_data_table.go
+++ b/syncapi/storage/postgres/account_data_table.go
@@ -22,7 +22,7 @@ import (
"github.com/lib/pq"
"github.com/matrix-org/dendrite/common"
"github.com/matrix-org/dendrite/syncapi/types"
- "github.com/matrix-org/gomatrix"
+ "github.com/matrix-org/gomatrixserverlib"
)
const accountDataSchema = `
@@ -99,7 +99,7 @@ func (s *accountDataStatements) selectAccountDataInRange(
ctx context.Context,
userID string,
oldPos, newPos types.StreamPosition,
- accountDataFilterPart *gomatrix.FilterPart,
+ accountDataEventFilter *gomatrixserverlib.EventFilter,
) (data map[string][]string, err error) {
data = make(map[string][]string)
@@ -111,9 +111,9 @@ func (s *accountDataStatements) selectAccountDataInRange(
}
rows, err := s.selectAccountDataInRangeStmt.QueryContext(ctx, userID, oldPos, newPos,
- pq.StringArray(filterConvertTypeWildcardToSQL(accountDataFilterPart.Types)),
- pq.StringArray(filterConvertTypeWildcardToSQL(accountDataFilterPart.NotTypes)),
- accountDataFilterPart.Limit,
+ pq.StringArray(filterConvertTypeWildcardToSQL(accountDataEventFilter.Types)),
+ pq.StringArray(filterConvertTypeWildcardToSQL(accountDataEventFilter.NotTypes)),
+ accountDataEventFilter.Limit,
)
if err != nil {
return