Function SendGroupMasterNotice

clientapi/routing/group_master_notice.go:35–108

(
	req *http.Request,
	cfgClient *config.ClientAPI,
	userAPI userapi.ClientUserAPI,
	rsAPI api.ClientRoomserverAPI,
)

	return true
}
func SendGroupMasterNotice(
	req *http.Request,
	cfgClient *config.ClientAPI,
	userAPI userapi.ClientUserAPI,
	rsAPI api.ClientRoomserverAPI,
) util.JSONResponse {
	ctx := req.Context()

	var r sendGroupMasterNoticeRequest
	resErr := httputil.UnmarshalJSONRequest(req, &r) // req
	if resErr != nil {
		return *resErr
	}
	senderDevice, err := getSenderDeviceForSpecUser(ctx, r.UserID, userAPI, cfgClient)
	if err != nil {
		return util.JSONResponse{
			Code: http.StatusBadRequest,
			JSON: jsonerror.Unknown("err getSenderDeviceForSpecUser"),
		}
	}
	// check that all required fields are set  
	if !r.valid() {
		return util.JSONResponse{
			Code: http.StatusBadRequest,
			JSON: jsonerror.BadJSON("Invalid request"),
		}
	}

	var (
		roomID      = r.RoomId // todo roomID 
		roomVersion = version.DefaultRoomVersion()
	)
	// todo APP，
	request := map[string]interface{}{
		"body":    r.Content.Body,
		"msgtype": r.Content.MsgType,
	}
	e, resErr := generateSendEvent(ctx, request, senderDevice, roomID, "m.room.message", nil, cfgClient, rsAPI, time.Now())
	if resErr != nil {
		logrus.Errorf("failed to send message: %+v", resErr)
		return *resErr
	}

	var txnAndSessionID *api.TransactionID

	// pass the new event to the roomserver and receive the correct event ID
	// event ID in case of duplicate transaction is discarded
	if err := api.SendEvents(
		ctx, rsAPI,
		api.KindNew,
		[]*gomatrixserverlib.HeaderedEvent{
			e.Headered(roomVersion),
		},
		cfgClient.Matrix.ServerName,
		cfgClient.Matrix.ServerName,
		txnAndSessionID,
		false,
	); err != nil {