aboutsummaryrefslogtreecommitdiff
path: root/roomserver/storage/sqlite3/membership_table.go
diff options
context:
space:
mode:
authorTill <2353100+S7evinK@users.noreply.github.com>2022-05-10 14:41:12 +0200
committerGitHub <noreply@github.com>2022-05-10 14:41:12 +0200
commit6db08b2874307c516b10ef9c9e996807fbfdb1ff (patch)
tree8fa54ade93306a3205c5fcfb5cfd56963890656c /roomserver/storage/sqlite3/membership_table.go
parent1897e2f1c07f1b06a540aa2b4ccedfc67008e52a (diff)
Add roomserver tests (2/?) (#2445)
* Add invite table tests; move variable declarations * Add Membership table tests * Move variable declarations * Add PrevEvents table tests * Add Published table test * Add Redactions tests Fix bug in SQLite markRedactionValidatedSQL * PR comments, better readability for invite tests
Diffstat (limited to 'roomserver/storage/sqlite3/membership_table.go')
-rw-r--r--roomserver/storage/sqlite3/membership_table.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/roomserver/storage/sqlite3/membership_table.go b/roomserver/storage/sqlite3/membership_table.go
index 7ed86b61..6f0fe8b6 100644
--- a/roomserver/storage/sqlite3/membership_table.go
+++ b/roomserver/storage/sqlite3/membership_table.go
@@ -136,12 +136,12 @@ type membershipStatements struct {
selectServerInRoomStmt *sql.Stmt
}
-func createMembershipTable(db *sql.DB) error {
+func CreateMembershipTable(db *sql.DB) error {
_, err := db.Exec(membershipSchema)
return err
}
-func prepareMembershipTable(db *sql.DB) (tables.Membership, error) {
+func PrepareMembershipTable(db *sql.DB) (tables.Membership, error) {
s := &membershipStatements{
db: db,
}
@@ -212,8 +212,8 @@ func (s *membershipStatements) SelectMembershipsFromRoom(
}
defer internal.CloseAndLogIfError(ctx, rows, "selectMembershipsFromRoom: rows.close() failed")
+ var eNID types.EventNID
for rows.Next() {
- var eNID types.EventNID
if err = rows.Scan(&eNID); err != nil {
return
}
@@ -239,8 +239,8 @@ func (s *membershipStatements) SelectMembershipsFromRoomAndMembership(
}
defer internal.CloseAndLogIfError(ctx, rows, "selectMembershipsFromRoomAndMembership: rows.close() failed")
+ var eNID types.EventNID
for rows.Next() {
- var eNID types.EventNID
if err = rows.Scan(&eNID); err != nil {
return
}
@@ -275,8 +275,8 @@ func (s *membershipStatements) SelectRoomsWithMembership(
}
defer internal.CloseAndLogIfError(ctx, rows, "SelectRoomsWithMembership: rows.close() failed")
var roomNIDs []types.RoomNID
+ var roomNID types.RoomNID
for rows.Next() {
- var roomNID types.RoomNID
if err := rows.Scan(&roomNID); err != nil {
return nil, err
}
@@ -307,9 +307,9 @@ func (s *membershipStatements) SelectJoinedUsersSetForRooms(ctx context.Context,
}
defer internal.CloseAndLogIfError(ctx, rows, "selectJoinedUsersSetForRooms: rows.close() failed")
result := make(map[types.EventStateKeyNID]int)
+ var userID types.EventStateKeyNID
+ var count int
for rows.Next() {
- var userID types.EventStateKeyNID
- var count int
if err := rows.Scan(&userID, &count); err != nil {
return nil, err
}
@@ -326,12 +326,12 @@ func (s *membershipStatements) SelectKnownUsers(ctx context.Context, txn *sql.Tx
}
result := []string{}
defer internal.CloseAndLogIfError(ctx, rows, "SelectKnownUsers: rows.close() failed")
+ var resUserID string
for rows.Next() {
- var userID string
- if err := rows.Scan(&userID); err != nil {
+ if err := rows.Scan(&resUserID); err != nil {
return nil, err
}
- result = append(result, userID)
+ result = append(result, resUserID)
}
return result, rows.Err()
}