revert source changes

Author: michelle0927

components/docusign/sources/new-change-in-envelope-status/common.mjs

@@ -1,5 +1,4 @@
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
-import fs from "fs";
 
 export default {
   dedupe: "unique",
@@ -34,30 +33,6 @@ export default {
         "any",
       ],
     },
-    downloadEnvelopeDocuments: {
-      type: "string",
-      label: "Download Envelope Documents",
-      description: "Download envelope documents to the `/tmp` directory",
-      options: [
-        {
-          label: "All Documents (PDF)",
-          value: "combined",
-        },
-        {
-          label: "All Documents (Zip)",
-          value: "archive",
-        },
-        {
-          label: "Certificate (PDF)",
-          value: "certificate",
-        },
-        {
-          label: "Portfolio (PDF)",
-          value: "portfolio",
-        },
-      ],
-      optional: true,
-    },
   },
   methods: {
     _getLastEvent() {
@@ -81,23 +56,6 @@ export default {
         ts,
       };
     },
-    getFilePath(envelopeId) {
-      const extension = this.downloadEnvelopeDocuments === "archive"
-        ? "zip"
-        : "pdf";
-      return `/tmp/${envelopeId}.${extension}`;
-    },
-    async downloadToTmp(baseUri, documentsUri, filePath) {
-      const content = await this.docusign._makeRequest({
-        config: {
-          url: `${baseUri}${documentsUri.slice(1)}/${this.downloadEnvelopeDocuments}`,
-          responseType: "arraybuffer",
-        },
-      });
-      const rawcontent = content.toString("base64");
-      const buffer = Buffer.from(rawcontent, "base64");
-      fs.writeFileSync(filePath, buffer);
-    },
   },
   async run(event) {
     const { timestamp: ts } = event;
@@ -110,9 +68,6 @@ export default {
       from_date: lastEvent,
       status: this.status.join(),
     };
-
-    const newEnvelopes = [];
-
     do {
       const {
         envelopes = [],
@@ -123,22 +78,12 @@ export default {
         params.start_position += endPosition + 1;
       }
       else done = true;
-      newEnvelopes.push(...envelopes);
-    } while (!done);
-
-    this._setLastEvent(new Date(ts * 1000).toISOString());
 
-    for (const envelope of newEnvelopes) {
-      if (this.downloadEnvelopeDocuments) {
-        const filePath = this.getFilePath(envelope.envelopeId);
-        await this.downloadToTmp(baseUri, envelope.documentsUri, filePath);
-        envelope.documents = {
-          filePath,
-        };
+      for (const envelope of envelopes) {
+        const meta = this.generateMeta(envelope);
+        this.$emit(envelope, meta);
       }
-      console.log(fs.readdirSync("/tmp"));
-      const meta = this.generateMeta(envelope);
-      this.$emit(envelope, meta);
-    }
+    } while (!done);
+    this._setLastEvent(new Date(ts * 1000).toISOString());
   },
 };

components/docusign/sources/new-change-in-envelope-status/new-change-in-envelope-status.mjs

@@ -4,7 +4,7 @@ import common from "./common.mjs";
 export default {
   ...common,
   key: "docusign-new-change-in-envelope-status",
-  version: "0.0.2",
+  version: "0.0.1",
   name: "New Change in Envelope Status",
   description: "Emit new event when an envelope's status is updated",
   type: "source",