MSC4140: test split delayed event mgmt endpoints

Author: AndrewFerr

tests/msc4140/delayed_event_test.go

@@ -20,6 +20,14 @@ import (
 const hsName = "hs1"
 const eventType = "com.example.test"
 
+type DelayedEventAction string
+
+const (
+	DelayedEventActionCancel  = "cancel"
+	DelayedEventActionRestart = "restart"
+	DelayedEventActionSend    = "send"
+)
+
 // TODO: Test pagination of `GET /_matrix/client/v1/delayed_events` once
 // it is implemented in a homeserver.
 
@@ -46,7 +54,7 @@ func TestDelayedEvents(t *testing.T) {
 	})
 
 	t.Run("delayed event lookups are authenticated", func(t *testing.T) {
-		res := unauthedClient.Do(t, "GET", getPathForUpdateDelayedEvents())
+		res := unauthedClient.Do(t, "GET", getPathForDelayedEvents())
 		must.MatchResponse(t, res, match.HTTPResponse{
 			StatusCode: 401,
 		})
@@ -173,66 +181,42 @@ func TestDelayedEvents(t *testing.T) {
 		})
 	})
 
-	t.Run("cannot update a delayed event without a delay ID", func(t *testing.T) {
-		res := unauthedClient.Do(t, "POST", append(getPathForUpdateDelayedEvents(), ""))
-		must.MatchResponse(t, res, match.HTTPResponse{
-			StatusCode: 404,
-		})
-	})
-
-	t.Run("cannot update a delayed event without a request body", func(t *testing.T) {
-		res := unauthedClient.Do(t, "POST", append(getPathForUpdateDelayedEvents(), "abc"))
-		must.MatchResponse(t, res, match.HTTPResponse{
-			StatusCode: 400,
-			JSON: []match.JSON{
-				match.JSONKeyEqual("errcode", "M_NOT_JSON"),
-			},
-		})
-	})
-
 	t.Run("cannot update a delayed event without an action", func(t *testing.T) {
 		res := unauthedClient.Do(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), "abc"),
+			append(getPathForDelayedEvents(), "abc"),
 			client.WithJSONBody(t, map[string]interface{}{}),
 		)
-		must.MatchResponse(t, res, match.HTTPResponse{
-			StatusCode: 400,
-			JSON: []match.JSON{
-				match.JSONKeyEqual("errcode", "M_MISSING_PARAM"),
-			},
-		})
+		// TODO: specify failure as 404 when/if Synapse removes the action-in-body version of this endpoint
+		must.MatchFailure(t, res)
 	})
 
 	t.Run("cannot update a delayed event with an invalid action", func(t *testing.T) {
 		res := unauthedClient.Do(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), "abc"),
-			client.WithJSONBody(t, map[string]interface{}{
-				"action": "oops",
-			}),
+			append(getPathForDelayedEvents(), "abc", "oops"),
+			client.WithJSONBody(t, map[string]interface{}{}),
 		)
 		must.MatchResponse(t, res, match.HTTPResponse{
-			StatusCode: 400,
-			JSON: []match.JSON{
-				match.JSONKeyEqual("errcode", "M_INVALID_PARAM"),
-			},
+			StatusCode: 404,
 		})
 	})
 
 	t.Run("parallel", func(t *testing.T) {
-		for _, action := range []string{"cancel", "restart", "send"} {
+		for _, action := range []DelayedEventAction{
+			DelayedEventActionCancel,
+			DelayedEventActionRestart,
+			DelayedEventActionSend,
+		} {
 			t.Run(fmt.Sprintf("cannot %s a delayed event without a matching delay ID", action), func(t *testing.T) {
 				t.Parallel()
 				res := unauthedClient.Do(
 					t,
 					"POST",
-					append(getPathForUpdateDelayedEvents(), "abc"),
-					client.WithJSONBody(t, map[string]interface{}{
-						"action": action,
-					}),
+					getPathForUpdateDelayedEvent("abc", action),
+					client.WithJSONBody(t, map[string]interface{}{}),
 				)
 				must.MatchResponse(t, res, match.HTTPResponse{
 					StatusCode: 404,
@@ -269,10 +253,8 @@ func TestDelayedEvents(t *testing.T) {
 		unauthedClient.MustDo(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), delayID),
-			client.WithJSONBody(t, map[string]interface{}{
-				"action": "cancel",
-			}),
+			getPathForUpdateDelayedEvent(delayID, DelayedEventActionCancel),
+			client.WithJSONBody(t, map[string]interface{}{}),
 		)
 		matchDelayedEvents(t, user, 0)
 
@@ -313,10 +295,8 @@ func TestDelayedEvents(t *testing.T) {
 		unauthedClient.MustDo(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), delayID),
-			client.WithJSONBody(t, map[string]interface{}{
-				"action": "send",
-			}),
+			getPathForUpdateDelayedEvent(delayID, DelayedEventActionSend),
+			client.WithJSONBody(t, map[string]interface{}{}),
 		)
 		matchDelayedEvents(t, user, 0)
 		res = user.Do(t, "GET", getPathForState(roomID, eventType, stateKey))
@@ -357,10 +337,8 @@ func TestDelayedEvents(t *testing.T) {
 		unauthedClient.MustDo(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), delayID),
-			client.WithJSONBody(t, map[string]interface{}{
-				"action": "restart",
-			}),
+			getPathForUpdateDelayedEvent(delayID, DelayedEventActionRestart),
+			client.WithJSONBody(t, map[string]interface{}{}),
 		)
 
 		time.Sleep(1 * time.Second)
@@ -497,10 +475,14 @@ func TestDelayedEvents(t *testing.T) {
 	})
 }
 
-func getPathForUpdateDelayedEvents() []string {
+func getPathForDelayedEvents() []string {
 	return []string{"_matrix", "client", "unstable", "org.matrix.msc4140", "delayed_events"}
 }
 
+func getPathForUpdateDelayedEvent(delayId string, action DelayedEventAction) []string {
+	return append(getPathForDelayedEvents(), delayId, string(action))
+}
+
 func getPathForSend(roomID string, eventType string, txnId string) []string {
 	return []string{"_matrix", "client", "v3", "rooms", roomID, "send", eventType, txnId}
 }
@@ -517,7 +499,7 @@ func getDelayQueryParam(delayStr string) client.RequestOpt {
 
 func getDelayedEvents(t *testing.T, user *client.CSAPI) *http.Response {
 	t.Helper()
-	return user.MustDo(t, "GET", getPathForUpdateDelayedEvents())
+	return user.MustDo(t, "GET", getPathForDelayedEvents())
 }
 
 // Checks if the number of delayed events match the given number. This will
@@ -526,7 +508,7 @@ func matchDelayedEvents(t *testing.T, user *client.CSAPI, wantNumber int) {
 	t.Helper()
 
 	// We need to retry this as replication can sometimes lag.
-	user.MustDo(t, "GET", getPathForUpdateDelayedEvents(),
+	user.MustDo(t, "GET", getPathForDelayedEvents(),
 		client.WithRetryUntil(
 			500*time.Millisecond,
 			func(res *http.Response) bool {
@@ -556,10 +538,8 @@ func cleanupDelayedEvents(t *testing.T, user *client.CSAPI) {
 		user.MustDo(
 			t,
 			"POST",
-			append(getPathForUpdateDelayedEvents(), delayID),
-			client.WithJSONBody(t, map[string]interface{}{
-				"action": "cancel",
-			}),
+			getPathForUpdateDelayedEvent(delayID, DelayedEventActionCancel),
+			client.WithJSONBody(t, map[string]interface{}{}),
 		)
 	}