mirror of
https://github.com/1f349/dendrite.git
synced 2024-12-23 08:44:11 +00:00
617 lines
20 KiB
Go
617 lines
20 KiB
Go
// Copyright 2017 Vector Creations Ltd
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package routing
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
appserviceAPI "github.com/matrix-org/dendrite/appservice/api"
|
|
roomserverAPI "github.com/matrix-org/dendrite/roomserver/api"
|
|
roomserverVersion "github.com/matrix-org/dendrite/roomserver/version"
|
|
"github.com/matrix-org/dendrite/userapi/api"
|
|
|
|
"github.com/matrix-org/dendrite/clientapi/httputil"
|
|
"github.com/matrix-org/dendrite/clientapi/jsonerror"
|
|
"github.com/matrix-org/dendrite/internal/eventutil"
|
|
"github.com/matrix-org/dendrite/setup/config"
|
|
"github.com/matrix-org/gomatrixserverlib"
|
|
"github.com/matrix-org/util"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// https://matrix.org/docs/spec/client_server/r0.2.0.html#post-matrix-client-r0-createroom
|
|
type createRoomRequest struct {
|
|
Invite []string `json:"invite"`
|
|
Name string `json:"name"`
|
|
Visibility string `json:"visibility"`
|
|
Topic string `json:"topic"`
|
|
Preset string `json:"preset"`
|
|
CreationContent json.RawMessage `json:"creation_content"`
|
|
InitialState []fledglingEvent `json:"initial_state"`
|
|
RoomAliasName string `json:"room_alias_name"`
|
|
GuestCanJoin bool `json:"guest_can_join"`
|
|
RoomVersion gomatrixserverlib.RoomVersion `json:"room_version"`
|
|
PowerLevelContentOverride json.RawMessage `json:"power_level_content_override"`
|
|
IsDirect bool `json:"is_direct"`
|
|
}
|
|
|
|
const (
|
|
presetPrivateChat = "private_chat"
|
|
presetTrustedPrivateChat = "trusted_private_chat"
|
|
presetPublicChat = "public_chat"
|
|
)
|
|
|
|
const (
|
|
historyVisibilityShared = "shared"
|
|
// TODO: These should be implemented once history visibility is implemented
|
|
// historyVisibilityWorldReadable = "world_readable"
|
|
// historyVisibilityInvited = "invited"
|
|
)
|
|
|
|
func (r createRoomRequest) Validate() *util.JSONResponse {
|
|
whitespace := "\t\n\x0b\x0c\r " // https://docs.python.org/2/library/string.html#string.whitespace
|
|
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/handlers/room.py#L81
|
|
// Synapse doesn't check for ':' but we will else it will break parsers badly which split things into 2 segments.
|
|
if strings.ContainsAny(r.RoomAliasName, whitespace+":") {
|
|
return &util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("room_alias_name cannot contain whitespace or ':'"),
|
|
}
|
|
}
|
|
for _, userID := range r.Invite {
|
|
// TODO: We should put user ID parsing code into gomatrixserverlib and use that instead
|
|
// (see https://github.com/matrix-org/gomatrixserverlib/blob/3394e7c7003312043208aa73727d2256eea3d1f6/eventcontent.go#L347 )
|
|
// 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.
|
|
// https://github.com/matrix-org/synapse/blob/v0.19.2/synapse/types.py#L92
|
|
if _, _, err := gomatrixserverlib.SplitID('@', userID); err != nil {
|
|
return &util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("user id must be in the form @localpart:domain"),
|
|
}
|
|
}
|
|
}
|
|
switch r.Preset {
|
|
case presetPrivateChat, presetTrustedPrivateChat, presetPublicChat, "":
|
|
default:
|
|
return &util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("preset must be any of 'private_chat', 'trusted_private_chat', 'public_chat'"),
|
|
}
|
|
}
|
|
|
|
// Validate creation_content fields defined in the spec by marshalling the
|
|
// creation_content map into bytes and then unmarshalling the bytes into
|
|
// eventutil.CreateContent.
|
|
|
|
creationContentBytes, err := json.Marshal(r.CreationContent)
|
|
if err != nil {
|
|
return &util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("malformed creation_content"),
|
|
}
|
|
}
|
|
|
|
var CreationContent gomatrixserverlib.CreateContent
|
|
err = json.Unmarshal(creationContentBytes, &CreationContent)
|
|
if err != nil {
|
|
return &util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("malformed creation_content"),
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// https://matrix.org/docs/spec/client_server/r0.2.0.html#post-matrix-client-r0-createroom
|
|
type createRoomResponse struct {
|
|
RoomID string `json:"room_id"`
|
|
RoomAlias string `json:"room_alias,omitempty"` // in synapse not spec
|
|
}
|
|
|
|
// fledglingEvent is a helper representation of an event used when creating many events in succession.
|
|
type fledglingEvent struct {
|
|
Type string `json:"type"`
|
|
StateKey string `json:"state_key"`
|
|
Content interface{} `json:"content"`
|
|
}
|
|
|
|
// CreateRoom implements /createRoom
|
|
func CreateRoom(
|
|
req *http.Request, device *api.Device,
|
|
cfg *config.ClientAPI,
|
|
profileAPI api.ClientUserAPI, rsAPI roomserverAPI.ClientRoomserverAPI,
|
|
asAPI appserviceAPI.AppServiceInternalAPI,
|
|
) util.JSONResponse {
|
|
var r createRoomRequest
|
|
resErr := httputil.UnmarshalJSONRequest(req, &r)
|
|
if resErr != nil {
|
|
return *resErr
|
|
}
|
|
if resErr = r.Validate(); resErr != nil {
|
|
return *resErr
|
|
}
|
|
evTime, err := httputil.ParseTSParam(req)
|
|
if err != nil {
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.InvalidArgumentValue(err.Error()),
|
|
}
|
|
}
|
|
return createRoom(req.Context(), r, device, cfg, profileAPI, rsAPI, asAPI, evTime)
|
|
}
|
|
|
|
// createRoom implements /createRoom
|
|
// nolint: gocyclo
|
|
func createRoom(
|
|
ctx context.Context,
|
|
r createRoomRequest, device *api.Device,
|
|
cfg *config.ClientAPI,
|
|
profileAPI api.ClientUserAPI, rsAPI roomserverAPI.ClientRoomserverAPI,
|
|
asAPI appserviceAPI.AppServiceInternalAPI,
|
|
evTime time.Time,
|
|
) util.JSONResponse {
|
|
// TODO (#267): Check room ID doesn't clash with an existing one, and we
|
|
// probably shouldn't be using pseudo-random strings, maybe GUIDs?
|
|
roomID := fmt.Sprintf("!%s:%s", util.RandomString(16), cfg.Matrix.ServerName)
|
|
|
|
logger := util.GetLogger(ctx)
|
|
userID := device.UserID
|
|
|
|
// Clobber keys: creator, room_version
|
|
|
|
roomVersion := roomserverVersion.DefaultRoomVersion()
|
|
if r.RoomVersion != "" {
|
|
candidateVersion := gomatrixserverlib.RoomVersion(r.RoomVersion)
|
|
_, roomVersionError := roomserverVersion.SupportedRoomVersion(candidateVersion)
|
|
if roomVersionError != nil {
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.UnsupportedRoomVersion(roomVersionError.Error()),
|
|
}
|
|
}
|
|
roomVersion = candidateVersion
|
|
}
|
|
|
|
// TODO: visibility/presets/raw initial state
|
|
// TODO: Create room alias association
|
|
// Make sure this doesn't fall into an application service's namespace though!
|
|
|
|
logger.WithFields(log.Fields{
|
|
"userID": userID,
|
|
"roomID": roomID,
|
|
"roomVersion": roomVersion,
|
|
}).Info("Creating new room")
|
|
|
|
profile, err := appserviceAPI.RetrieveUserProfile(ctx, userID, asAPI, profileAPI)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("appserviceAPI.RetrieveUserProfile failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
|
|
createContent := map[string]interface{}{}
|
|
if len(r.CreationContent) > 0 {
|
|
if err = json.Unmarshal(r.CreationContent, &createContent); err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("json.Unmarshal for creation_content failed")
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("invalid create content"),
|
|
}
|
|
}
|
|
}
|
|
createContent["creator"] = userID
|
|
createContent["room_version"] = roomVersion
|
|
powerLevelContent := eventutil.InitialPowerLevelsContent(userID)
|
|
joinRuleContent := gomatrixserverlib.JoinRuleContent{
|
|
JoinRule: gomatrixserverlib.Invite,
|
|
}
|
|
historyVisibilityContent := gomatrixserverlib.HistoryVisibilityContent{
|
|
HistoryVisibility: historyVisibilityShared,
|
|
}
|
|
|
|
if r.PowerLevelContentOverride != nil {
|
|
// Merge powerLevelContentOverride fields by unmarshalling it atop the defaults
|
|
err = json.Unmarshal(r.PowerLevelContentOverride, &powerLevelContent)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("json.Unmarshal for power_level_content_override failed")
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.BadJSON("malformed power_level_content_override"),
|
|
}
|
|
}
|
|
}
|
|
|
|
switch r.Preset {
|
|
case presetPrivateChat:
|
|
joinRuleContent.JoinRule = gomatrixserverlib.Invite
|
|
historyVisibilityContent.HistoryVisibility = historyVisibilityShared
|
|
case presetTrustedPrivateChat:
|
|
joinRuleContent.JoinRule = gomatrixserverlib.Invite
|
|
historyVisibilityContent.HistoryVisibility = historyVisibilityShared
|
|
for _, invitee := range r.Invite {
|
|
powerLevelContent.Users[invitee] = 100
|
|
}
|
|
case presetPublicChat:
|
|
joinRuleContent.JoinRule = gomatrixserverlib.Public
|
|
historyVisibilityContent.HistoryVisibility = historyVisibilityShared
|
|
}
|
|
|
|
createEvent := fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomCreate,
|
|
Content: createContent,
|
|
}
|
|
powerLevelEvent := fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomPowerLevels,
|
|
Content: powerLevelContent,
|
|
}
|
|
joinRuleEvent := fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomJoinRules,
|
|
Content: joinRuleContent,
|
|
}
|
|
historyVisibilityEvent := fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomHistoryVisibility,
|
|
Content: historyVisibilityContent,
|
|
}
|
|
membershipEvent := fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomMember,
|
|
StateKey: userID,
|
|
Content: gomatrixserverlib.MemberContent{
|
|
Membership: gomatrixserverlib.Join,
|
|
DisplayName: profile.DisplayName,
|
|
AvatarURL: profile.AvatarURL,
|
|
},
|
|
}
|
|
|
|
var nameEvent *fledglingEvent
|
|
var topicEvent *fledglingEvent
|
|
var guestAccessEvent *fledglingEvent
|
|
var aliasEvent *fledglingEvent
|
|
|
|
if r.Name != "" {
|
|
nameEvent = &fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomName,
|
|
Content: eventutil.NameContent{
|
|
Name: r.Name,
|
|
},
|
|
}
|
|
}
|
|
|
|
if r.Topic != "" {
|
|
topicEvent = &fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomTopic,
|
|
Content: eventutil.TopicContent{
|
|
Topic: r.Topic,
|
|
},
|
|
}
|
|
}
|
|
|
|
if r.GuestCanJoin {
|
|
guestAccessEvent = &fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomGuestAccess,
|
|
Content: eventutil.GuestAccessContent{
|
|
GuestAccess: "can_join",
|
|
},
|
|
}
|
|
}
|
|
|
|
var roomAlias string
|
|
if r.RoomAliasName != "" {
|
|
roomAlias = fmt.Sprintf("#%s:%s", r.RoomAliasName, cfg.Matrix.ServerName)
|
|
// check it's free TODO: This races but is better than nothing
|
|
hasAliasReq := roomserverAPI.GetRoomIDForAliasRequest{
|
|
Alias: roomAlias,
|
|
IncludeAppservices: false,
|
|
}
|
|
|
|
var aliasResp roomserverAPI.GetRoomIDForAliasResponse
|
|
err = rsAPI.GetRoomIDForAlias(ctx, &hasAliasReq, &aliasResp)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("aliasAPI.GetRoomIDForAlias failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
if aliasResp.RoomID != "" {
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.RoomInUse("Room ID already exists."),
|
|
}
|
|
}
|
|
|
|
aliasEvent = &fledglingEvent{
|
|
Type: gomatrixserverlib.MRoomCanonicalAlias,
|
|
Content: eventutil.CanonicalAlias{
|
|
Alias: roomAlias,
|
|
},
|
|
}
|
|
}
|
|
|
|
var initialStateEvents []fledglingEvent
|
|
for i := range r.InitialState {
|
|
if r.InitialState[i].StateKey != "" {
|
|
initialStateEvents = append(initialStateEvents, r.InitialState[i])
|
|
continue
|
|
}
|
|
|
|
switch r.InitialState[i].Type {
|
|
case gomatrixserverlib.MRoomCreate:
|
|
continue
|
|
|
|
case gomatrixserverlib.MRoomPowerLevels:
|
|
powerLevelEvent = r.InitialState[i]
|
|
|
|
case gomatrixserverlib.MRoomJoinRules:
|
|
joinRuleEvent = r.InitialState[i]
|
|
|
|
case gomatrixserverlib.MRoomHistoryVisibility:
|
|
historyVisibilityEvent = r.InitialState[i]
|
|
|
|
case gomatrixserverlib.MRoomGuestAccess:
|
|
guestAccessEvent = &r.InitialState[i]
|
|
|
|
case gomatrixserverlib.MRoomName:
|
|
nameEvent = &r.InitialState[i]
|
|
|
|
case gomatrixserverlib.MRoomTopic:
|
|
topicEvent = &r.InitialState[i]
|
|
|
|
default:
|
|
initialStateEvents = append(initialStateEvents, r.InitialState[i])
|
|
}
|
|
}
|
|
|
|
// send events into the room in order of:
|
|
// 1- m.room.create
|
|
// 2- room creator join member
|
|
// 3- m.room.power_levels
|
|
// 4- m.room.join_rules
|
|
// 5- m.room.history_visibility
|
|
// 6- m.room.canonical_alias (opt)
|
|
// 7- m.room.guest_access (opt)
|
|
// 8- other initial state items
|
|
// 9- m.room.name (opt)
|
|
// 10- m.room.topic (opt)
|
|
// 11- invite events (opt) - with is_direct flag if applicable TODO
|
|
// 12- 3pid invite events (opt) TODO
|
|
// This differs from Synapse slightly. Synapse would vary the ordering of 3-7
|
|
// depending on if those events were in "initial_state" or not. This made it
|
|
// harder to reason about, hence sticking to a strict static ordering.
|
|
// TODO: Synapse has txn/token ID on each event. Do we need to do this here?
|
|
eventsToMake := []fledglingEvent{
|
|
createEvent, membershipEvent, powerLevelEvent, joinRuleEvent, historyVisibilityEvent,
|
|
}
|
|
if guestAccessEvent != nil {
|
|
eventsToMake = append(eventsToMake, *guestAccessEvent)
|
|
}
|
|
eventsToMake = append(eventsToMake, initialStateEvents...)
|
|
if nameEvent != nil {
|
|
eventsToMake = append(eventsToMake, *nameEvent)
|
|
}
|
|
if topicEvent != nil {
|
|
eventsToMake = append(eventsToMake, *topicEvent)
|
|
}
|
|
if aliasEvent != nil {
|
|
// TODO: bit of a chicken and egg problem here as the alias doesn't exist and cannot until we have made the room.
|
|
// This means we might fail creating the alias but say the canonical alias is something that doesn't exist.
|
|
eventsToMake = append(eventsToMake, *aliasEvent)
|
|
}
|
|
|
|
// TODO: invite events
|
|
// TODO: 3pid invite events
|
|
|
|
var builtEvents []*gomatrixserverlib.HeaderedEvent
|
|
authEvents := gomatrixserverlib.NewAuthEvents(nil)
|
|
for i, e := range eventsToMake {
|
|
depth := i + 1 // depth starts at 1
|
|
|
|
builder := gomatrixserverlib.EventBuilder{
|
|
Sender: userID,
|
|
RoomID: roomID,
|
|
Type: e.Type,
|
|
StateKey: &e.StateKey,
|
|
Depth: int64(depth),
|
|
}
|
|
err = builder.SetContent(e.Content)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("builder.SetContent failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
if i > 0 {
|
|
builder.PrevEvents = []gomatrixserverlib.EventReference{builtEvents[i-1].EventReference()}
|
|
}
|
|
var ev *gomatrixserverlib.Event
|
|
ev, err = buildEvent(&builder, &authEvents, cfg, evTime, roomVersion)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("buildEvent failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
|
|
if err = gomatrixserverlib.Allowed(ev, &authEvents); err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("gomatrixserverlib.Allowed failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
|
|
// Add the event to the list of auth events
|
|
builtEvents = append(builtEvents, ev.Headered(roomVersion))
|
|
err = authEvents.AddEvent(ev)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("authEvents.AddEvent failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
}
|
|
|
|
inputs := make([]roomserverAPI.InputRoomEvent, 0, len(builtEvents))
|
|
for _, event := range builtEvents {
|
|
inputs = append(inputs, roomserverAPI.InputRoomEvent{
|
|
Kind: roomserverAPI.KindNew,
|
|
Event: event,
|
|
Origin: cfg.Matrix.ServerName,
|
|
SendAsServer: roomserverAPI.DoNotSendToOtherServers,
|
|
})
|
|
}
|
|
if err = roomserverAPI.SendInputRoomEvents(ctx, rsAPI, inputs, false); err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("roomserverAPI.SendInputRoomEvents failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
|
|
// TODO(#269): Reserve room alias while we create the room. This stops us
|
|
// from creating the room but still failing due to the alias having already
|
|
// been taken.
|
|
if roomAlias != "" {
|
|
aliasReq := roomserverAPI.SetRoomAliasRequest{
|
|
Alias: roomAlias,
|
|
RoomID: roomID,
|
|
UserID: userID,
|
|
}
|
|
|
|
var aliasResp roomserverAPI.SetRoomAliasResponse
|
|
err = rsAPI.SetRoomAlias(ctx, &aliasReq, &aliasResp)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("aliasAPI.SetRoomAlias failed")
|
|
return jsonerror.InternalServerError()
|
|
}
|
|
|
|
if aliasResp.AliasExists {
|
|
return util.JSONResponse{
|
|
Code: http.StatusBadRequest,
|
|
JSON: jsonerror.RoomInUse("Room alias already exists."),
|
|
}
|
|
}
|
|
}
|
|
|
|
// If this is a direct message then we should invite the participants.
|
|
if len(r.Invite) > 0 {
|
|
// Build some stripped state for the invite.
|
|
var globalStrippedState []gomatrixserverlib.InviteV2StrippedState
|
|
for _, event := range builtEvents {
|
|
// Chosen events from the spec:
|
|
// https://spec.matrix.org/v1.3/client-server-api/#stripped-state
|
|
switch event.Type() {
|
|
case gomatrixserverlib.MRoomCreate:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomName:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomAvatar:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomTopic:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomCanonicalAlias:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomEncryption:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomMember:
|
|
fallthrough
|
|
case gomatrixserverlib.MRoomJoinRules:
|
|
ev := event.Event
|
|
globalStrippedState = append(
|
|
globalStrippedState,
|
|
gomatrixserverlib.NewInviteV2StrippedState(ev),
|
|
)
|
|
}
|
|
}
|
|
|
|
// Process the invites.
|
|
for _, invitee := range r.Invite {
|
|
// Build the invite event.
|
|
inviteEvent, err := buildMembershipEvent(
|
|
ctx, invitee, "", profileAPI, device, gomatrixserverlib.Invite,
|
|
roomID, r.IsDirect, cfg, evTime, rsAPI, asAPI,
|
|
)
|
|
if err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("buildMembershipEvent failed")
|
|
continue
|
|
}
|
|
inviteStrippedState := append(
|
|
globalStrippedState,
|
|
gomatrixserverlib.NewInviteV2StrippedState(inviteEvent.Event),
|
|
)
|
|
// Send the invite event to the roomserver.
|
|
var inviteRes roomserverAPI.PerformInviteResponse
|
|
event := inviteEvent.Headered(roomVersion)
|
|
if err := rsAPI.PerformInvite(ctx, &roomserverAPI.PerformInviteRequest{
|
|
Event: event,
|
|
InviteRoomState: inviteStrippedState,
|
|
RoomVersion: event.RoomVersion,
|
|
SendAsServer: string(cfg.Matrix.ServerName),
|
|
}, &inviteRes); err != nil {
|
|
util.GetLogger(ctx).WithError(err).Error("PerformInvite failed")
|
|
return util.JSONResponse{
|
|
Code: http.StatusInternalServerError,
|
|
JSON: jsonerror.InternalServerError(),
|
|
}
|
|
}
|
|
if inviteRes.Error != nil {
|
|
return inviteRes.Error.JSONResponse()
|
|
}
|
|
}
|
|
}
|
|
|
|
if r.Visibility == "public" {
|
|
// expose this room in the published room list
|
|
var pubRes roomserverAPI.PerformPublishResponse
|
|
if err := rsAPI.PerformPublish(ctx, &roomserverAPI.PerformPublishRequest{
|
|
RoomID: roomID,
|
|
Visibility: "public",
|
|
}, &pubRes); err != nil {
|
|
return jsonerror.InternalAPIError(ctx, err)
|
|
}
|
|
if pubRes.Error != nil {
|
|
// treat as non-fatal since the room is already made by this point
|
|
util.GetLogger(ctx).WithError(pubRes.Error).Error("failed to visibility:public")
|
|
}
|
|
}
|
|
|
|
response := createRoomResponse{
|
|
RoomID: roomID,
|
|
RoomAlias: roomAlias,
|
|
}
|
|
|
|
return util.JSONResponse{
|
|
Code: 200,
|
|
JSON: response,
|
|
}
|
|
}
|
|
|
|
// buildEvent fills out auth_events for the builder then builds the event
|
|
func buildEvent(
|
|
builder *gomatrixserverlib.EventBuilder,
|
|
provider gomatrixserverlib.AuthEventProvider,
|
|
cfg *config.ClientAPI,
|
|
evTime time.Time,
|
|
roomVersion gomatrixserverlib.RoomVersion,
|
|
) (*gomatrixserverlib.Event, error) {
|
|
eventsNeeded, err := gomatrixserverlib.StateNeededForEventBuilder(builder)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
refs, err := eventsNeeded.AuthEventReferences(provider)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
builder.AuthEvents = refs
|
|
event, err := builder.Build(
|
|
evTime, cfg.Matrix.ServerName, cfg.Matrix.KeyID,
|
|
cfg.Matrix.PrivateKey, roomVersion,
|
|
)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("cannot build event %s : Builder failed to build. %w", builder.Type, err)
|
|
}
|
|
return event, nil
|
|
}
|