mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-12 01:13:10 -06:00
Return string rather than pointer to string
This commit is contained in:
parent
42dc455269
commit
d195222941
|
|
@ -35,7 +35,7 @@ func DirectoryRoom(
|
||||||
federation *gomatrixserverlib.FederationClient,
|
federation *gomatrixserverlib.FederationClient,
|
||||||
cfg *config.Dendrite,
|
cfg *config.Dendrite,
|
||||||
) util.JSONResponse {
|
) util.JSONResponse {
|
||||||
_, domain, err := gomatrixserverlib.ParseID('#', roomAlias)
|
_, domain, err := gomatrixserverlib.SplitID('#', roomAlias)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return util.JSONResponse{
|
return util.JSONResponse{
|
||||||
Code: 400,
|
Code: 400,
|
||||||
|
|
|
||||||
|
|
@ -60,7 +60,7 @@ func (r createRoomRequest) Validate() *util.JSONResponse {
|
||||||
// It should be a struct (with pointers into a single string to avoid copying) and
|
// It should be a struct (with pointers into a single string to avoid copying) and
|
||||||
// we should update all refs to use UserID types rather than strings.
|
// we should update all refs to use UserID types rather than strings.
|
||||||
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/types.py#L92
|
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/types.py#L92
|
||||||
if _, _, err := gomatrixserverlib.ParseID('@', userID); err != nil {
|
if _, _, err := gomatrixserverlib.SplitID('@', userID); err != nil {
|
||||||
return &util.JSONResponse{
|
return &util.JSONResponse{
|
||||||
Code: 400,
|
Code: 400,
|
||||||
JSON: jsonerror.BadJSON("user id must be in the form @localpart:domain"),
|
JSON: jsonerror.BadJSON("user id must be in the form @localpart:domain"),
|
||||||
|
|
|
||||||
|
|
@ -89,7 +89,7 @@ func (r joinRoomReq) joinRoomByID() util.JSONResponse {
|
||||||
|
|
||||||
// joinRoomByAlias joins a room using a room alias.
|
// joinRoomByAlias joins a room using a room alias.
|
||||||
func (r joinRoomReq) joinRoomByAlias(roomAlias string) util.JSONResponse {
|
func (r joinRoomReq) joinRoomByAlias(roomAlias string) util.JSONResponse {
|
||||||
_, domain, err := gomatrixserverlib.ParseID('#', roomAlias)
|
_, domain, err := gomatrixserverlib.SplitID('#', roomAlias)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return util.JSONResponse{
|
return util.JSONResponse{
|
||||||
Code: 400,
|
Code: 400,
|
||||||
|
|
|
||||||
|
|
@ -223,10 +223,10 @@ func joinedHostsFromEvents(evs []gomatrixserverlib.Event) ([]types.JoinedHost, e
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if *membership != "join" {
|
if membership != "join" {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
_, serverName, err := gomatrixserverlib.ParseID('@', *ev.StateKey())
|
_, serverName, err := gomatrixserverlib.SplitID('@', *ev.StateKey())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -193,7 +193,7 @@ func (r *uploadRequest) Validate(maxFileSizeBytes config.FileSizeBytes) *util.JS
|
||||||
// It should be a struct (with pointers into a single string to avoid copying) and
|
// It should be a struct (with pointers into a single string to avoid copying) and
|
||||||
// we should update all refs to use UserID types rather than strings.
|
// we should update all refs to use UserID types rather than strings.
|
||||||
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/types.py#L92
|
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/types.py#L92
|
||||||
if _, _, err := gomatrixserverlib.ParseID('@', string(r.MediaMetadata.UserID)); err != nil {
|
if _, _, err := gomatrixserverlib.SplitID('@', string(r.MediaMetadata.UserID)); err != nil {
|
||||||
return &util.JSONResponse{
|
return &util.JSONResponse{
|
||||||
Code: 400,
|
Code: 400,
|
||||||
JSON: jsonerror.BadJSON("user id must be in the form @localpart:domain"),
|
JSON: jsonerror.BadJSON("user id must be in the form @localpart:domain"),
|
||||||
|
|
|
||||||
|
|
@ -125,15 +125,13 @@ func (d *SyncServerDatabase) updateRoomState(
|
||||||
// ignore non state events
|
// ignore non state events
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
var (
|
var membership *string
|
||||||
membership *string
|
|
||||||
err error
|
|
||||||
)
|
|
||||||
if event.Type() == "m.room.member" {
|
if event.Type() == "m.room.member" {
|
||||||
membership, err = event.Membership()
|
value, err := event.Membership()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
membership = &value
|
||||||
}
|
}
|
||||||
if err := d.roomstate.upsertRoomState(txn, event, membership, int64(streamPos)); err != nil {
|
if err := d.roomstate.upsertRoomState(txn, event, membership, int64(streamPos)); err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
@ -477,7 +475,7 @@ func getMembershipFromEvent(ev *gomatrixserverlib.Event, userID string) string {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
return *membership
|
return membership
|
||||||
}
|
}
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -73,7 +73,7 @@ func (n *Notifier) OnNewEvent(ev *gomatrixserverlib.Event, pos types.StreamPosit
|
||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
// Keep the joined user map up-to-date
|
// Keep the joined user map up-to-date
|
||||||
switch *membership {
|
switch membership {
|
||||||
case "invite":
|
case "invite":
|
||||||
userIDs = append(userIDs, userID)
|
userIDs = append(userIDs, userID)
|
||||||
case "join":
|
case "join":
|
||||||
|
|
|
||||||
|
|
@ -482,15 +482,15 @@ func (e Event) PrevEventIDs() []string {
|
||||||
// is an "m.room.member" event.
|
// is an "m.room.member" event.
|
||||||
// Returns an error if the event is not a m.room.member event or if the content
|
// Returns an error if the event is not a m.room.member event or if the content
|
||||||
// is not valid m.room.member content.
|
// is not valid m.room.member content.
|
||||||
func (e Event) Membership() (*string, error) {
|
func (e Event) Membership() (string, error) {
|
||||||
if e.fields.Type != MRoomMember {
|
if e.fields.Type != MRoomMember {
|
||||||
return nil, fmt.Errorf("gomatrixserverlib: not an m.room.member event")
|
return "", fmt.Errorf("gomatrixserverlib: not an m.room.member event")
|
||||||
}
|
}
|
||||||
var content memberContent
|
var content memberContent
|
||||||
if err := json.Unmarshal(e.fields.Content, &content); err != nil {
|
if err := json.Unmarshal(e.fields.Content, &content); err != nil {
|
||||||
return nil, err
|
return "", err
|
||||||
}
|
}
|
||||||
return &content.Membership, nil
|
return content.Membership, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// AuthEvents returns references to the events needed to auth the event.
|
// AuthEvents returns references to the events needed to auth the event.
|
||||||
|
|
@ -570,8 +570,8 @@ func (er EventReference) MarshalJSON() ([]byte, error) {
|
||||||
return json.Marshal(&tuple)
|
return json.Marshal(&tuple)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ParseID splits a matrix ID into a local part and a server name.
|
// SplitID splits a matrix ID into a local part and a server name.
|
||||||
func ParseID(sigil byte, id string) (local string, domain ServerName, err error) {
|
func SplitID(sigil byte, id string) (local string, domain ServerName, err error) {
|
||||||
// IDs have the format: SIGIL LOCALPART ":" DOMAIN
|
// IDs have the format: SIGIL LOCALPART ":" DOMAIN
|
||||||
// Split on the first ":" character since the domain can contain ":"
|
// Split on the first ":" character since the domain can contain ":"
|
||||||
// characters.
|
// characters.
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue