Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion clientapi/routing/createroom.go
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ func createRoom(
if createRequest.Preset == spec.PresetTrustedPrivateChat {
additionalCreators = createRequest.Invite
}
createContent, err := roomserverAPI.GenerateCreateContent(ctx, createRequest.RoomVersion, userID.String(), createRequest.CreationContent, additionalCreators)
createContent, err := roomserverAPI.GenerateCreateContent(ctx, roomVersion, userID.String(), createRequest.CreationContent, additionalCreators)
if err != nil {
util.GetLogger(ctx).WithError(err).Error("GenerateCreateContent failed")
return util.JSONResponse{
Expand Down
2 changes: 1 addition & 1 deletion federationapi/routing/backfill.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ func Backfill(
var err error

// Check the room ID's format.
if _, _, err = gomatrixserverlib.SplitID('!', roomID); err != nil {
if _, err = spec.NewRoomID(roomID); err != nil {
return util.JSONResponse{
Code: http.StatusBadRequest,
JSON: spec.MissingParam("Bad room ID: " + err.Error()),
Expand Down
3 changes: 2 additions & 1 deletion federationapi/routing/threepid.go
Original file line number Diff line number Diff line change
Expand Up @@ -394,10 +394,11 @@ func sendToRemoteServer(
}
// Fallback to the room's server if the sender's domain is the same as
// the current server's
_, remoteServers[1], err = gomatrixserverlib.SplitID('!', inv.RoomID)
roomID, err := spec.NewRoomID(inv.RoomID)
if err != nil {
return
}
remoteServers[1] = roomID.Domain()

for _, server := range remoteServers {
err = federation.ExchangeThirdPartyInvite(ctx, cfg.Matrix.ServerName, server, proto)
Expand Down
2 changes: 1 addition & 1 deletion roomserver/internal/perform/perform_admin.go
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ func (r *Admin) PerformAdminPurgeRoom(
roomID string,
) error {
// Validate we actually got a room ID and nothing else
if _, _, err := gomatrixserverlib.SplitID('!', roomID); err != nil {
if _, err := spec.NewRoomID(roomID); err != nil {
return err
}

Expand Down
4 changes: 2 additions & 2 deletions roomserver/internal/perform/perform_peek.go
Original file line number Diff line number Diff line change
Expand Up @@ -114,11 +114,11 @@ func (r *Peeker) performPeekRoomByID(
roomID = req.RoomIDOrAlias

// Get the domain part of the room ID.
_, domain, err := gomatrixserverlib.SplitID('!', roomID)
specRoomID, err := spec.NewRoomID(roomID)
if err != nil {
return "", api.ErrInvalidID{Err: fmt.Errorf("room ID %q is invalid: %w", roomID, err)}
}

domain := specRoomID.Domain()
// handle federated peeks
// FIXME: don't create an outbound peek if we already have one going.
if !r.Cfg.Matrix.IsLocalServerName(domain) {
Expand Down
2 changes: 1 addition & 1 deletion roomserver/internal/perform/perform_unpeek.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ func (r *Unpeeker) performUnpeekRoomByID(
roomID, userID, deviceID string,
) (err error) {
// Get the domain part of the room ID.
_, _, err = gomatrixserverlib.SplitID('!', roomID)
_, err = spec.NewRoomID(roomID)
if err != nil {
return api.ErrInvalidID{Err: fmt.Errorf("room ID %q is invalid: %w", roomID, err)}
}
Expand Down
Loading