From 38513fb4eda740c4cc37bed5cf7beb83310cd96b Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Fri, 1 May 2020 14:27:48 +0100
Subject: [PATCH] Add PerformJoin template

---
 roomserver/api/perform.go           | 59 +++++++++++++++++++++++++++++
 roomserver/internal/api.go          | 13 +++++++
 roomserver/internal/perform_join.go | 16 ++++++++
 3 files changed, 88 insertions(+)
 create mode 100644 roomserver/api/perform.go
 create mode 100644 roomserver/internal/perform_join.go

diff --git a/roomserver/api/perform.go b/roomserver/api/perform.go
new file mode 100644
index 000000000..5725c4fb2
--- /dev/null
+++ b/roomserver/api/perform.go
@@ -0,0 +1,59 @@
+package api
+
+import (
+	"context"
+
+	commonHTTP "github.com/matrix-org/dendrite/common/http"
+	"github.com/opentracing/opentracing-go"
+)
+
+const (
+	// RoomserverPerformJoinPath is the HTTP path for the PerformJoinRequest API.
+	RoomserverPerformJoinPath = "/api/roomserver/performJoin"
+
+	// RoomserverPerformLeavePath is the HTTP path for the PerformLeaveRequest API.
+	RoomserverPerformLeavePath = "/api/roomserver/performLeave"
+)
+
+type PerformJoinRequest struct {
+	RoomID  string                 `json:"room_id"`
+	UserID  string                 `json:"user_id"`
+	Content map[string]interface{} `json:"content"`
+}
+
+type PerformJoinResponse struct {
+}
+
+// Handle an instruction to make_join & send_join with a remote server.
+func (h *httpRoomserverInternalAPI) PerformJoin(
+	ctx context.Context,
+	request *PerformJoinRequest,
+	response *PerformJoinResponse,
+) error {
+	span, ctx := opentracing.StartSpanFromContext(ctx, "PerformJoin")
+	defer span.Finish()
+
+	apiURL := h.roomserverURL + RoomserverPerformJoinPath
+	return commonHTTP.PostJSON(ctx, span, h.httpClient, apiURL, request, response)
+}
+
+type PerformLeaveRequest struct {
+	RoomID string `json:"room_id"`
+	UserID string `json:"user_id"`
+}
+
+type PerformLeaveResponse struct {
+}
+
+// Handle an instruction to make_leave & send_leave with a remote server.
+func (h *httpRoomserverInternalAPI) PerformLeave(
+	ctx context.Context,
+	request *PerformLeaveRequest,
+	response *PerformLeaveResponse,
+) error {
+	span, ctx := opentracing.StartSpanFromContext(ctx, "PerformLeave")
+	defer span.Finish()
+
+	apiURL := h.roomserverURL + RoomserverPerformLeavePath
+	return commonHTTP.PostJSON(ctx, span, h.httpClient, apiURL, request, response)
+}
diff --git a/roomserver/internal/api.go b/roomserver/internal/api.go
index d1c443f24..1dc985efa 100644
--- a/roomserver/internal/api.go
+++ b/roomserver/internal/api.go
@@ -46,6 +46,19 @@ func (r *RoomserverInternalAPI) SetupHTTP(servMux *http.ServeMux) {
 			return util.JSONResponse{Code: http.StatusOK, JSON: &response}
 		}),
 	)
+	servMux.Handle(api.RoomserverPerformJoinPath,
+		common.MakeInternalAPI("performJoin", func(req *http.Request) util.JSONResponse {
+			var request api.PerformJoinRequest
+			var response api.PerformJoinResponse
+			if err := json.NewDecoder(req.Body).Decode(&request); err != nil {
+				return util.MessageResponse(http.StatusBadRequest, err.Error())
+			}
+			if err := r.PerformJoin(req.Context(), &request, &response); err != nil {
+				return util.ErrorResponse(err)
+			}
+			return util.JSONResponse{Code: http.StatusOK, JSON: &response}
+		}),
+	)
 	servMux.Handle(
 		api.RoomserverQueryLatestEventsAndStatePath,
 		common.MakeInternalAPI("queryLatestEventsAndState", func(req *http.Request) util.JSONResponse {
diff --git a/roomserver/internal/perform_join.go b/roomserver/internal/perform_join.go
new file mode 100644
index 000000000..ec9414ed0
--- /dev/null
+++ b/roomserver/internal/perform_join.go
@@ -0,0 +1,16 @@
+package internal
+
+import (
+	"context"
+
+	"github.com/matrix-org/dendrite/roomserver/api"
+)
+
+// WriteOutputEvents implements OutputRoomEventWriter
+func (r *RoomserverInternalAPI) PerformJoin(
+	ctx context.Context,
+	req *api.PerformJoinRequest,
+	res *api.PerformJoinResponse,
+) error {
+	return nil
+}