some adjusts

luancazarine · luancazarine · commit 0d7d40e6daf5 · 2024-12-09T10:46:51.000-03:00
diff --git a/components/testmonitor/actions/create-test-result/create-test-result.mjs b/components/testmonitor/actions/create-test-result/create-test-result.mjs
@@ -1,4 +1,9 @@
 import { ConfigurationError } from "@pipedream/platform";
+import FormData from "form-data";
+import fs from "fs";
+import {
+  checkTmp, parseObject,
+} from "../../common/utils.mjs";
 import testmonitor from "../../testmonitor.app.mjs";
 
 export default {
@@ -37,6 +42,24 @@ export default {
       type: "boolean",
       label: "Draft",
       description: "Denotes if this test result is marked as draft.",
+      reloadProps: true,
+    },
+    attachments: {
+      type: "string[]",
+      label: "Attachments",
+      description: "A list of attachment files.",
+      hidden: true,
+      optional: true,
+    },
+    testResultStatusId: {
+      propDefinition: [
+        testmonitor,
+        "testResultStatusId",
+        ({ projectId }) => ({
+          projectId,
+        }),
+      ],
+      hidden: true,
     },
     description: {
       type: "string",
@@ -45,20 +68,54 @@ export default {
       optional: true,
     },
   },
+  async additionalProps(props) {
+    if (!this.draft) {
+      props.attachments.hidden = false;
+      props.testResultStatusId.hidden = false;
+    }
+    return {};
+  },
   async run({ $ }) {
+    let testResultId;
+    let summary;
     try {
       const response = await this.testmonitor.createTestResult({
         $,
         data: {
           test_case_id: this.testCaseId,
           test_run_id: this.testRunId,
-          draft: this.draft,
           description: this.description,
+          draft: true,
+        },
+      });
+      testResultId = response.data.id;
+
+      try {
+        for (const file of parseObject(this.attachments)) {
+          const data = new FormData();
+          data.append("file", fs.createReadStream(checkTmp(file)));
+          await this.testmonitor.uploadAttachment({
+            $,
+            testResultId,
+            data,
+            headers: data.getHeaders(),
+          });
+        }
+      } catch (e) {
+        summary = ", but the attachments could not be loaded.";
+      }
+
+      const updateResponse = await this.testmonitor.updateTestResult({
+        $,
+        testResultId,
+        data: {
+          draft: this.draft,
+          test_result_status_id: this.testResultStatusId,
         },
       });
 
-      $.export("$summary", `Successfully created test result with Id: ${response.data.id}`);
-      return response;
+      $.export("$summary", `Successfully created test result with Id: ${testResultId}${summary}`);
+      return updateResponse;
     } catch (e) {
       throw new ConfigurationError((e.response.status === 400)
         ? "It seems that there is already a test with this configuration!"
diff --git a/components/testmonitor/common/utils.mjs b/components/testmonitor/common/utils.mjs
@@ -0,0 +1,31 @@
+export const checkTmp = (filename) => {
+  if (!filename.startsWith("/tmp")) {
+    return `/tmp/${filename}`;
+  }
+  return filename;
+};
+
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  if (Array.isArray(obj)) {
+    return obj.map((item) => {
+      if (typeof item === "string") {
+        try {
+          return JSON.parse(item);
+        } catch (e) {
+          return item;
+        }
+      }
+      return item;
+    });
+  }
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+  return obj;
+};
diff --git a/components/testmonitor/package.json b/components/testmonitor/package.json
@@ -11,6 +11,7 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "dependencies": {
     "@pipedream/platform": "^3.0.3",
+    "fs": "^0.0.1-security",
     "moment": "^2.29.4"
   },
   "publishConfig": {
diff --git a/components/testmonitor/testmonitor.app.mjs b/components/testmonitor/testmonitor.app.mjs
@@ -96,6 +96,28 @@ export default {
         }));
       },
     },
+    testResultStatusId: {
+      type: "integer",
+      label: "Test Result Status Id",
+      description: "The test result status identifier.",
+      async options({
+        page, projectId,
+      }) {
+        const { data } = await this.getResultStatuses({
+          params: {
+            page: page + 1,
+            project_id: projectId,
+          },
+        });
+
+        return data.map(({
+          id: value, name: label,
+        }) => ({
+          label,
+          value,
+        }));
+      },
+    },
     query: {
       type: "string",
       label: "Query",
@@ -130,20 +152,23 @@ export default {
     _apiUrl() {
       return `https://${this.$auth.domain}.testmonitor.com/api/v1`;
     },
-    _getHeaders() {
+    _getHeaders(headers = {}) {
       return {
+        ...headers,
         "Authorization": `Bearer ${this.$auth.api_token}`,
       };
     },
     async _makeRequest({
-      $ = this, path, ...opts
+      $ = this, path, headers, ...opts
     }) {
       const config = {
         url: `${this._apiUrl()}/${path}`,
-        headers: this._getHeaders(),
+        headers: this._getHeaders(headers),
         ...opts,
       };
 
+      console.log("config: ", config);
+
       return axios($, config);
     },
     createTestResult(opts = {}) {
@@ -153,6 +178,24 @@ export default {
         ...opts,
       });
     },
+    updateTestResult({
+      testResultId, ...opts
+    }) {
+      return this._makeRequest({
+        method: "PUT",
+        path: `test-results/${testResultId}`,
+        ...opts,
+      });
+    },
+    uploadAttachment({
+      testResultId, ...opts
+    }) {
+      return this._makeRequest({
+        method: "POST",
+        path: `test-result/${testResultId}/attachments`,
+        ...opts,
+      });
+    },
     getTestCases(opts = {}) {
       return this._makeRequest({
         path: "test-cases",
@@ -166,11 +209,11 @@ export default {
       });
     },
     getIssue({
-      $, issueId,
+      issueId, ...opts
     }) {
       return this._makeRequest({
-        $,
         path: `issues/${issueId}`,
+        ...opts,
       });
     },
     getIssues(params) {
@@ -180,11 +223,11 @@ export default {
       });
     },
     getProject({
-      $, projectId,
+      projectId, ...opts
     }) {
       return this._makeRequest({
-        $,
         path: `projects/${projectId}`,
+        ...opts,
       });
     },
     getProjects(params) {
@@ -194,11 +237,17 @@ export default {
       });
     },
     getTestResult({
-      $, testResultId,
+      testResultId, ...opts
     }) {
       return this._makeRequest({
-        $,
         path: `test-results/${testResultId}`,
+        ...opts,
+      });
+    },
+    getResultStatuses(opts = {}) {
+      return this._makeRequest({
+        path: "test-result-statuses",
+        ...opts,
       });
     },
     getTestResults(params) {
diff --git a/components/testmonitor/yarn.lock b/components/testmonitor/yarn.lock
@@ -0,0 +1,95 @@
+# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
+# yarn lockfile v1
+
+
+"@pipedream/platform@^3.0.3":
+  version "3.0.3"
+  resolved "https://registry.yarnpkg.com/@pipedream/platform/-/platform-3.0.3.tgz#b0f1d1274e061fb581635a30fabc830358975fd2"
+  integrity sha512-7elalas41lnT8i6EAFkqB7fT/+hkLGEQ1njS6A7CVguTrEswaIYk/seKmkfkRY7+O6qncgnXswYIKCBML9Co7w==
+  dependencies:
+    axios "^1.7.4"
+    fp-ts "^2.0.2"
+    io-ts "^2.0.0"
+    querystring "^0.2.1"
+
+asynckit@^0.4.0:
+  version "0.4.0"
+  resolved "https://registry.yarnpkg.com/asynckit/-/asynckit-0.4.0.tgz#c79ed97f7f34cb8f2ba1bc9790bcc366474b4b79"
+  integrity sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q==
+
+axios@^1.7.4:
+  version "1.7.9"
+  resolved "https://registry.yarnpkg.com/axios/-/axios-1.7.9.tgz#d7d071380c132a24accda1b2cfc1535b79ec650a"
+  integrity sha512-LhLcE7Hbiryz8oMDdDptSrWowmB4Bl6RCt6sIJKpRB4XtVf0iEgewX3au/pJqm+Py1kCASkb/FFKjxQaLtxJvw==
+  dependencies:
+    follow-redirects "^1.15.6"
+    form-data "^4.0.0"
+    proxy-from-env "^1.1.0"
+
+combined-stream@^1.0.8:
+  version "1.0.8"
+  resolved "https://registry.yarnpkg.com/combined-stream/-/combined-stream-1.0.8.tgz#c3d45a8b34fd730631a110a8a2520682b31d5a7f"
+  integrity sha512-FQN4MRfuJeHf7cBbBMJFXhKSDq+2kAArBlmRBvcvFE5BB1HZKXtSFASDhdlz9zOYwxh8lDdnvmMOe/+5cdoEdg==
+  dependencies:
+    delayed-stream "~1.0.0"
+
+delayed-stream@~1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/delayed-stream/-/delayed-stream-1.0.0.tgz#df3ae199acadfb7d440aaae0b29e2272b24ec619"
+  integrity sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==
+
+follow-redirects@^1.15.6:
+  version "1.15.9"
+  resolved "https://registry.yarnpkg.com/follow-redirects/-/follow-redirects-1.15.9.tgz#a604fa10e443bf98ca94228d9eebcc2e8a2c8ee1"
+  integrity sha512-gew4GsXizNgdoRyqmyfMHyAmXsZDk6mHkSxZFCzW9gwlbtOW44CDtYavM+y+72qD/Vq2l550kMF52DT8fOLJqQ==
+
+form-data@^4.0.0:
+  version "4.0.1"
+  resolved "https://registry.yarnpkg.com/form-data/-/form-data-4.0.1.tgz#ba1076daaaa5bfd7e99c1a6cb02aa0a5cff90d48"
+  integrity sha512-tzN8e4TX8+kkxGPK8D5u0FNmjPUjw3lwC9lSLxxoB/+GtsJG91CO8bSWy73APlgAZzZbXEYZJuxjkHH2w+Ezhw==
+  dependencies:
+    asynckit "^0.4.0"
+    combined-stream "^1.0.8"
+    mime-types "^2.1.12"
+
+fp-ts@^2.0.2:
+  version "2.16.9"
+  resolved "https://registry.yarnpkg.com/fp-ts/-/fp-ts-2.16.9.tgz#99628fc5e0bb3b432c4a16d8f4455247380bae8a"
+  integrity sha512-+I2+FnVB+tVaxcYyQkHUq7ZdKScaBlX53A41mxQtpIccsfyv8PzdzP7fzp2AY832T4aoK6UZ5WRX/ebGd8uZuQ==
+
+fs@^0.0.1-security:
+  version "0.0.1-security"
+  resolved "https://registry.yarnpkg.com/fs/-/fs-0.0.1-security.tgz#8a7bd37186b6dddf3813f23858b57ecaaf5e41d4"
+  integrity sha512-3XY9e1pP0CVEUCdj5BmfIZxRBTSDycnbqhIOGec9QYtmVH2fbLpj86CFWkrNOkt/Fvty4KZG5lTglL9j/gJ87w==
+
+io-ts@^2.0.0:
+  version "2.2.21"
+  resolved "https://registry.yarnpkg.com/io-ts/-/io-ts-2.2.21.tgz#4ef754176f7082a1099d04c7d5c4ea53267c530a"
+  integrity sha512-zz2Z69v9ZIC3mMLYWIeoUcwWD6f+O7yP92FMVVaXEOSZH1jnVBmET/urd/uoarD1WGBY4rCj8TAyMPzsGNzMFQ==
+
+mime-db@1.52.0:
+  version "1.52.0"
+  resolved "https://registry.yarnpkg.com/mime-db/-/mime-db-1.52.0.tgz#bbabcdc02859f4987301c856e3387ce5ec43bf70"
+  integrity sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==
+
+mime-types@^2.1.12:
+  version "2.1.35"
+  resolved "https://registry.yarnpkg.com/mime-types/-/mime-types-2.1.35.tgz#381a871b62a734450660ae3deee44813f70d959a"
+  integrity sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==
+  dependencies:
+    mime-db "1.52.0"
+
+moment@^2.29.4:
+  version "2.30.1"
+  resolved "https://registry.yarnpkg.com/moment/-/moment-2.30.1.tgz#f8c91c07b7a786e30c59926df530b4eac96974ae"
+  integrity sha512-uEmtNhbDOrWPFS+hdjFCBfy9f2YoyzRpwcl+DqpC6taX21FzsTLQVbMV/W7PzNSX6x/bhC1zA3c2UQ5NzH6how==
+
+proxy-from-env@^1.1.0:
+  version "1.1.0"
+  resolved "https://registry.yarnpkg.com/proxy-from-env/-/proxy-from-env-1.1.0.tgz#e102f16ca355424865755d2c9e8ea4f24d58c3e2"
+  integrity sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg==
+
+querystring@^0.2.1:
+  version "0.2.1"
+  resolved "https://registry.yarnpkg.com/querystring/-/querystring-0.2.1.tgz#40d77615bb09d16902a85c3e38aa8b5ed761c2dd"
+  integrity sha512-wkvS7mL/JMugcup3/rMitHmd9ecIGd2lhFhK9N3UUQ450h66d1r3Y9nvXzQAW1Lq+wyx61k/1pfKS5KuKiyEbg==
