feat(ps): support delete pods

Author: jianxiaoguo

api/ps.go

@@ -72,3 +72,7 @@ type ContainerState struct {
 
 // PodState defines a collection of container state.
 type PodState []ContainerState
+
+type PodIDs struct {
+	PodIDs string `json:"pod_ids"`
+}

ps/ps.go

@@ -99,6 +99,23 @@ func Describe(c *drycc.Client, appID string, podID string, results int) (api.Pod
 	return podState, count, reqErr
 }
 
+// delete a pod
+func Delete(c *drycc.Client, appID string, podIDs string) error {
+	u := fmt.Sprintf("/v2/apps/%s/pods/", appID)
+
+	req := api.PodIDs{PodIDs: podIDs}
+
+	body, err := json.Marshal(req)
+	if err != nil {
+		return err
+	}
+	res, err := c.Request("DELETE", u, body)
+	if err == nil {
+		res.Body.Close()
+	}
+	return err
+}
+
 // ByType organizes processes of an app by process type.
 func ByType(processes api.PodsList) api.PodTypes {
 	var pts api.PodTypes

ps/ps_test.go

@@ -65,6 +65,8 @@ const podStateFixture string = `
 	}]
 }`
 
+const podDeleteExpected string = `{"pod_ids":"test-pod-web"}`
+
 type fakeHTTPServer struct{}
 
 func (fakeHTTPServer) ServeHTTP(res http.ResponseWriter, req *http.Request) {
@@ -79,6 +81,23 @@ func (fakeHTTPServer) ServeHTTP(res http.ResponseWriter, req *http.Request) {
 		res.Write([]byte(podStateFixture))
 		return
 	}
+	if req.URL.Path == "/v2/apps/example-go/pods/" && req.Method == "DELETE" {
+		body, err := io.ReadAll(req.Body)
+
+		if err != nil {
+			fmt.Println(err)
+			res.WriteHeader(http.StatusInternalServerError)
+			res.Write(nil)
+		}
+		if string(body) != podDeleteExpected {
+			fmt.Printf("Expected '%s', Got '%s'\n", podDeleteExpected, body)
+			res.WriteHeader(http.StatusInternalServerError)
+			res.Write(nil)
+			return
+		}
+		res.WriteHeader(http.StatusNoContent)
+		return
+	}
 
 	fmt.Printf("Unrecognized URL %s\n", req.URL)
 	res.WriteHeader(http.StatusNotFound)
@@ -301,3 +320,20 @@ func TestByType(t *testing.T) {
 		t.Errorf("Expected: %v, Got %v", expected, actual)
 	}
 }
+
+func TestPodsDelete(t *testing.T) {
+	t.Parallel()
+
+	handler := fakeHTTPServer{}
+	server := httptest.NewServer(handler)
+	defer server.Close()
+
+	drycc, err := drycc.New(false, server.URL, "abc")
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if err = Delete(drycc, "example-go", "test-pod-web"); err != nil {
+		t.Fatal(err)
+	}
+}