diff --git a/src/github.com/matrix-org/dendrite/clientapi/auth/storage/accounts/accounts_table.go b/src/github.com/matrix-org/dendrite/clientapi/auth/storage/accounts/accounts_table.go index 8ea2d517..3b4e6bd5 100644 --- a/src/github.com/matrix-org/dendrite/clientapi/auth/storage/accounts/accounts_table.go +++ b/src/github.com/matrix-org/dendrite/clientapi/auth/storage/accounts/accounts_table.go @@ -17,10 +17,10 @@ package accounts import ( "context" "database/sql" - "fmt" "time" "github.com/matrix-org/dendrite/clientapi/auth/authtypes" + "github.com/matrix-org/dendrite/clientapi/userutil" "github.com/matrix-org/gomatrixserverlib" ) @@ -97,7 +97,7 @@ func (s *accountsStatements) insertAccount( return &authtypes.Account{ Localpart: localpart, - UserID: makeUserID(localpart, s.serverName), + UserID: userutil.MakeUserID(localpart, s.serverName), ServerName: s.serverName, AppServiceID: appserviceID, }, nil @@ -116,12 +116,8 @@ func (s *accountsStatements) selectAccountByLocalpart( stmt := s.selectAccountByLocalpartStmt err = stmt.QueryRowContext(ctx, localpart).Scan(&acc.Localpart, &acc.AppServiceID) if err == nil { - acc.UserID = makeUserID(localpart, s.serverName) + acc.UserID = userutil.MakeUserID(localpart, s.serverName) acc.ServerName = s.serverName } return } - -func makeUserID(localpart string, server gomatrixserverlib.ServerName) string { - return fmt.Sprintf("@%s:%s", localpart, string(server)) -} diff --git a/src/github.com/matrix-org/dendrite/clientapi/auth/storage/devices/devices_table.go b/src/github.com/matrix-org/dendrite/clientapi/auth/storage/devices/devices_table.go index 9512acfc..96d6521d 100644 --- a/src/github.com/matrix-org/dendrite/clientapi/auth/storage/devices/devices_table.go +++ b/src/github.com/matrix-org/dendrite/clientapi/auth/storage/devices/devices_table.go @@ -17,12 +17,12 @@ package devices import ( "context" "database/sql" - "fmt" "time" "github.com/matrix-org/dendrite/common" "github.com/matrix-org/dendrite/clientapi/auth/authtypes" + "github.com/matrix-org/dendrite/clientapi/userutil" "github.com/matrix-org/gomatrixserverlib" ) @@ -126,7 +126,7 @@ func (s *devicesStatements) insertDevice( } return &authtypes.Device{ ID: id, - UserID: makeUserID(localpart, s.serverName), + UserID: userutil.MakeUserID(localpart, s.serverName), AccessToken: accessToken, }, nil } @@ -163,7 +163,7 @@ func (s *devicesStatements) selectDeviceByToken( stmt := s.selectDeviceByTokenStmt err := stmt.QueryRowContext(ctx, accessToken).Scan(&dev.ID, &localpart) if err == nil { - dev.UserID = makeUserID(localpart, s.serverName) + dev.UserID = userutil.MakeUserID(localpart, s.serverName) dev.AccessToken = accessToken } return &dev, err @@ -178,7 +178,7 @@ func (s *devicesStatements) selectDeviceByID( err := stmt.QueryRowContext(ctx, localpart, deviceID).Scan(&created) if err == nil { dev.ID = deviceID - dev.UserID = makeUserID(localpart, s.serverName) + dev.UserID = userutil.MakeUserID(localpart, s.serverName) } return &dev, err } @@ -200,13 +200,9 @@ func (s *devicesStatements) selectDevicesByLocalpart( if err != nil { return devices, err } - dev.UserID = makeUserID(localpart, s.serverName) + dev.UserID = userutil.MakeUserID(localpart, s.serverName) devices = append(devices, dev) } return devices, nil } - -func makeUserID(localpart string, server gomatrixserverlib.ServerName) string { - return fmt.Sprintf("@%s:%s", localpart, string(server)) -} diff --git a/src/github.com/matrix-org/dendrite/clientapi/userutil/userutil.go b/src/github.com/matrix-org/dendrite/clientapi/userutil/userutil.go index de2d1959..4cea3c18 100644 --- a/src/github.com/matrix-org/dendrite/clientapi/userutil/userutil.go +++ b/src/github.com/matrix-org/dendrite/clientapi/userutil/userutil.go @@ -14,6 +14,7 @@ package userutil import ( "errors" + "fmt" "strings" "github.com/matrix-org/gomatrixserverlib" @@ -41,3 +42,8 @@ func ParseUsernameParam(usernameParam string, expectedServerName *gomatrixserver } return localpart, nil } + +// MakeUserID generates user ID from localpart & server name +func MakeUserID(localpart string, server gomatrixserverlib.ServerName) string { + return fmt.Sprintf("@%s:%s", localpart, string(server)) +}