Add support for join rule handling

bridgev2/errors.go

@@ -58,6 +58,7 @@ var (
 	ErrMediaConvertFailed              error = WrapErrorInStatus(errors.New("failed to convert media")).WithMessage("failed to convert media").WithIsCertain(true).WithSendNotice(true)
 	ErrMembershipNotSupported          error = WrapErrorInStatus(errors.New("this bridge does not support changing group membership")).WithIsCertain(true).WithErrorAsMessage().WithSendNotice(false)
 	ErrPowerLevelsNotSupported         error = WrapErrorInStatus(errors.New("this bridge does not support changing group power levels")).WithIsCertain(true).WithErrorAsMessage().WithSendNotice(false)
+	ErrJoinRuleNotSupported            error = WrapErrorInStatus(errors.New("this bridge does not support changing group join rule")).WithIsCertain(true).WithErrorAsMessage().WithSendNotice(false)
 )
 
 // RespError is a class of error that certain network interface methods can return to ensure that the error

bridgev2/networkinterface.go

@@ -688,6 +688,17 @@ type PowerLevelHandlingNetworkAPI interface {
 	HandleMatrixPowerLevels(ctx context.Context, msg *MatrixPowerLevelChange) (bool, error)
 }
 
+type MatrixJoinRulesChange struct {
+	MatrixRoomMeta[*event.JoinRulesEventContent]
+	OrigJoinRule event.JoinRule
+	NewJoinRule  event.JoinRule
+}
+
+type JoinRuleHandlingNetworkAPI interface {
+	NetworkAPI
+	HandleMatrixJoinRules(ctx context.Context, msg *MatrixJoinRulesChange) (bool, error)
+}
+
 type PushType int
 
 func (pt PushType) String() string {

bridgev2/portal.go

@@ -496,6 +496,8 @@ func (portal *Portal) handleMatrixEvent(sender *User, evt *event.Event) {
 		portal.handleMatrixMembership(ctx, login, origSender, evt)
 	case event.StatePowerLevels:
 		portal.handleMatrixPowerLevels(ctx, login, origSender, evt)
+	case event.StateJoinRules:
+		portal.HandleMatrixJoinRules(ctx, login, origSender, evt)
 	}
 }
 
@@ -1333,6 +1335,45 @@ func (portal *Portal) handleMatrixPowerLevels(
 	}
 }
 
+func (portal *Portal) HandleMatrixJoinRules(ctx context.Context, sender *UserLogin, origSender *OrigSender, evt *event.Event) {
+	log := zerolog.Ctx(ctx)
+	content, ok := evt.Content.Parsed.(*event.JoinRulesEventContent)
+	if !ok {
+		log.Error().Type("content_type", evt.Content.Parsed).Msg("Unexpected parsed content type")
+		portal.sendErrorStatus(ctx, evt, fmt.Errorf("%w: %T", ErrUnexpectedParsedContentType, evt.Content.Parsed))
+		return
+	}
+	api, ok := sender.Client.(JoinRuleHandlingNetworkAPI)
+	if !ok {
+		portal.sendErrorStatus(ctx, evt, ErrJoinRuleNotSupported)
+		return
+	}
+	prevContent := &event.JoinRulesEventContent{}
+	if evt.Unsigned.PrevContent != nil {
+		_ = evt.Unsigned.PrevContent.ParseRaw(evt.Type)
+		prevContent, _ = evt.Unsigned.PrevContent.Parsed.(*event.JoinRulesEventContent)
+	}
+	joinRuleChange := &MatrixJoinRulesChange{
+		MatrixRoomMeta: MatrixRoomMeta[*event.JoinRulesEventContent]{
+			MatrixEventBase: MatrixEventBase[*event.JoinRulesEventContent]{
+				Event:      evt,
+				Content:    content,
+				Portal:     portal,
+				OrigSender: origSender,
+			},
+			PrevContent: prevContent,
+		},
+		OrigJoinRule: content.JoinRule,
+		NewJoinRule:  prevContent.JoinRule,
+	}
+	_, err := api.HandleMatrixJoinRules(ctx, joinRuleChange)
+	if err != nil {
+		log.Err(err).Msg("Failed to handle Matrix join rule change")
+		portal.sendErrorStatus(ctx, evt, err)
+		return
+	}
+}
+
 func (portal *Portal) handleMatrixRedaction(ctx context.Context, sender *UserLogin, origSender *OrigSender, evt *event.Event) {
 	log := zerolog.Ctx(ctx)
 	content, ok := evt.Content.Parsed.(*event.RedactionEventContent)