Try using inputer instead

roomserver/internal/api.go

@@ -166,8 +166,10 @@ func (r *RoomserverInternalAPI) SetFederationAPI(fsAPI fsAPI.FederationInternalA
 		URSAPI: r,
 	}
 	r.Admin = &perform.Admin{
-		DB:     r.DB,
+		DB:      r.DB,
-		Leaver: r.Leaver,
+		Cfg:     r.Cfg,
+		Inputer: r.Inputer,
+		Queryer: r.Queryer,
 	}
 
 	if err := r.Inputer.Start(); err != nil {

roomserver/internal/perform/perform_admin.go

@@ -16,15 +16,24 @@ package perform
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
+	"time"
 
+	"github.com/matrix-org/dendrite/internal/eventutil"
 	"github.com/matrix-org/dendrite/roomserver/api"
+	"github.com/matrix-org/dendrite/roomserver/internal/input"
+	"github.com/matrix-org/dendrite/roomserver/internal/query"
 	"github.com/matrix-org/dendrite/roomserver/storage"
+	"github.com/matrix-org/dendrite/setup/config"
+	"github.com/matrix-org/gomatrixserverlib"
 )
 
 type Admin struct {
-	DB     storage.Database
+	DB      storage.Database
-	Leaver *Leaver
+	Cfg     *config.RoomServer
+	Queryer *query.Queryer
+	Inputer *input.Inputer
 }
 
 // PerformEvacuateRoom will remove all local users from the given room.
@@ -67,22 +76,78 @@ func (r *Admin) PerformAdminEvacuateRoom(
 		return
 	}
 
+	inputEvents := make([]api.InputRoomEvent, 0, len(memberEvents))
+
+	latestReq := &api.QueryLatestEventsAndStateRequest{
+		RoomID: req.RoomID,
+		StateToFetch: []gomatrixserverlib.StateKeyTuple{
+			{
+				EventType: "m.room.create",
+				StateKey:  "",
+			},
+		},
+	}
+	latestRes := &api.QueryLatestEventsAndStateResponse{}
+	if err = r.Queryer.QueryLatestEventsAndState(ctx, latestReq, latestRes); err != nil {
+		res.Error = &api.PerformError{
+			Code: api.PerformErrorBadRequest,
+			Msg:  fmt.Sprintf("r.Queryer.QueryLatestEventsAndState: %s", err),
+		}
+		return
+	}
+
 	for _, memberEvent := range memberEvents {
 		if memberEvent.StateKey() == nil {
 			continue
 		}
-		userID := *memberEvent.StateKey()
+
-		leaveReq := &api.PerformLeaveRequest{
+		var memberContent gomatrixserverlib.MemberContent
-			RoomID: req.RoomID,
+		if err = json.Unmarshal(memberEvent.Content(), &memberContent); err != nil {
-			UserID: userID,
-		}
-		leaveRes := &api.PerformLeaveResponse{}
-		if _, err = r.Leaver.PerformLeave(ctx, leaveReq, leaveRes); err != nil {
 			res.Error = &api.PerformError{
 				Code: api.PerformErrorBadRequest,
-				Msg:  fmt.Sprintf("r.Leaver.PerformLeave (%s): %s", userID, err),
+				Msg:  fmt.Sprintf("json.Unmarshal: %s", err),
 			}
 			return
 		}
+		memberContent.Membership = gomatrixserverlib.Leave
+
+		stateKey := *memberEvent.StateKey()
+		fledglingEvent := &gomatrixserverlib.EventBuilder{
+			RoomID:   req.RoomID,
+			Type:     gomatrixserverlib.MRoomMember,
+			StateKey: &stateKey,
+			Sender:   stateKey,
+		}
+
+		if fledglingEvent.Content, err = json.Marshal(memberContent); err != nil {
+			res.Error = &api.PerformError{
+				Code: api.PerformErrorBadRequest,
+				Msg:  fmt.Sprintf("json.Marshal: %s", err),
+			}
+			return
+		}
+
+		event, err := eventutil.BuildEvent(ctx, fledglingEvent, nil, time.Now(), nil, latestRes)
+		if err != nil {
+			res.Error = &api.PerformError{
+				Code: api.PerformErrorBadRequest,
+				Msg:  fmt.Sprintf("eventutil.BuildEvent: %s", err),
+			}
+			return
+		}
+
+		inputEvents = append(inputEvents, api.InputRoomEvent{
+			Kind:         api.KindNew,
+			Event:        event,
+			Origin:       r.Cfg.Matrix.ServerName,
+			SendAsServer: string(r.Cfg.Matrix.ServerName),
+		})
 	}
+
+	inputReq := &api.InputRoomEventsRequest{
+		InputRoomEvents: inputEvents,
+		Asynchronous:    true,
+	}
+	inputRes := &api.InputRoomEventsResponse{}
+	r.Inputer.InputRoomEvents(ctx, inputReq, inputRes)
 }