test: add get task and delete task e2e test.

Signed-off-by: Asklv <boironic@gmail.com>

Author: IRONICBo

test/e2e/v2/manager/task.go

@@ -31,8 +31,8 @@ import (
 )
 
 var _ = Describe("Get and Delete with Manager", func() {
-	Context("get /bin/md5sum task", func() {
-		It("get task should be ok", func() {
+	Context("get and delete /bin/md5sum task", func() {
+		It("get and delete task should be ok", func() {
 			// Create preheat job
 			managerPod, err := util.ManagerExec(0)
 			fmt.Println(err)
@@ -60,6 +60,69 @@ var _ = Describe("Get and Delete with Manager", func() {
 
 			done := waitForDone(job, managerPod)
 			Expect(done).Should(BeTrue())
+
+			fileMetadata := util.FileMetadata{
+				ID:     "6ba5a8781902368d2b07eb8b6d6044a96f49d5008feace1ea8e3ebfc0b96d0a1",
+				Sha256: "80f1d8cd843a98b23b30e90e7e43a14e05935351f354d678bc465f7be66ef3dd",
+			}
+
+			seedClientPods := make([]*util.PodExec, 3)
+			for i := 0; i < 3; i++ {
+				seedClientPods[i], err = util.SeedClientExec(i)
+				fmt.Println(err)
+				Expect(err).NotTo(HaveOccurred())
+			}
+
+			// Check the file is downloaded successfully
+			sha256sum, err := util.CalculateSha256ByTaskID(seedClientPods, fileMetadata.ID)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(fileMetadata.Sha256).To(Equal(sha256sum))
+
+			// Get task
+			req, err = structure.StructToMap(types.CreateGetTaskJobRequest{
+				Type: internaljob.GetTaskJob,
+				Args: types.GetTaskArgs{
+					TaskID: fileMetadata.ID,
+				},
+			})
+			Expect(err).NotTo(HaveOccurred())
+			out, err = managerPod.CurlCommand("POST", map[string]string{"Content-Type": "application/json"}, req,
+				"http://127.0.0.1:8080/api/v1/jobs").CombinedOutput()
+			fmt.Println(err)
+			Expect(err).NotTo(HaveOccurred())
+			fmt.Println(string(out))
+
+			job = &models.Job{}
+			err = json.Unmarshal(out, job)
+			fmt.Println(err)
+			Expect(err).NotTo(HaveOccurred())
+			// Check get task response is not null
+			Expect(job.Result).NotTo(BeNil())
+
+			// Delete task
+			req, err = structure.StructToMap(types.CreateDeleteTaskJobRequest{
+				Type: internaljob.DeleteTaskJob,
+				Args: types.DeleteTaskArgs{
+					TaskID: fileMetadata.ID,
+				},
+			})
+			Expect(err).NotTo(HaveOccurred())
+			out, err = managerPod.CurlCommand("POST", map[string]string{"Content-Type": "application/json"}, req,
+				"http://127.0.0.1:8080/api/v1/jobs").CombinedOutput()
+			fmt.Println(err)
+			Expect(err).NotTo(HaveOccurred())
+			fmt.Println(string(out))
+
+			job = &models.Job{}
+			err = json.Unmarshal(out, job)
+			fmt.Println(err)
+			Expect(err).NotTo(HaveOccurred())
+			// Check delete task response is not null
+			Expect(job.Result).NotTo(BeNil())
+
+			// Check file is deleted successfully
+			_, err = util.CalculateSha256ByTaskID(seedClientPods, fileMetadata.ID)
+			Expect(err).To(HaveOccurred())
 		})
 	})
 })