fix sources

Author: michelle0927

components/google_docs/sources/common/base.mjs

@@ -1,17 +1,17 @@
 import newFilesInstant from "@pipedream/google_drive/sources/new-files-instant/new-files-instant.mjs";
-import app from "../../google_docs.app.mjs";
+import googleDrive from "../../google_docs.app.mjs";
 import { MY_DRIVE_VALUE } from "@pipedream/google_drive/common/constants.mjs";
 
 export default {
   ...newFilesInstant,
   props: {
-    app,
+    googleDrive,
     db: "$.service.db",
     http: "$.interface.http",
     timer: newFilesInstant.props.timer,
     folders: {
       propDefinition: [
-        app,
+        googleDrive,
         "folderId",
       ],
       type: "string[]",
@@ -30,7 +30,7 @@ export default {
   methods: {
     ...newFilesInstant.methods,
     getDriveId() {
-      return app.methods.getDriveId(MY_DRIVE_VALUE);
+      return googleDrive.methods.getDriveId(MY_DRIVE_VALUE);
     },
     shouldProcess(file) {
       return (
@@ -48,7 +48,7 @@ export default {
     async getDocumentsFromFiles(files, limit) {
       return files.reduce(async (acc, file) => {
         const docs = await acc;
-        const fileInfo = await this.app.getFile(file.id);
+        const fileInfo = await this.googleDrive.getFile(file.id);
         return docs.length >= limit
           ? docs
           : docs.concat(fileInfo);
@@ -59,13 +59,13 @@ export default {
 
       if (!foldersIds?.length) {
         const opts = this.getDocumentsFromFolderOpts("root");
-        const { files } = await this.app.listFilesInPage(null, opts);
+        const { files } = await this.googleDrive.listFilesInPage(null, opts);
         return this.getDocumentsFromFiles(files, limit);
       }
 
       return foldersIds.reduce(async (docs, folderId) => {
         const opts = this.getDocumentsFromFolderOpts(folderId);
-        const { files } = await this.app.listFilesInPage(null, opts);
+        const { files } = await this.googleDrive.listFilesInPage(null, opts);
         const nextDocuments = await this.getDocumentsFromFiles(files, limit);
         return (await docs).concat(nextDocuments);
       }, []);
@@ -75,7 +75,7 @@ export default {
         if (!this.shouldProcess(file)) {
           continue;
         }
-        const doc = await this.app.getDocument(file.id);
+        const doc = await this.googleDrive.getDocument(file.id);
         this.$emit(doc, this.generateMeta(doc));
       }
     },

components/google_docs/sources/new-document-created/new-document-created.mjs

@@ -27,7 +27,7 @@ export default {
         fields: "*",
       });
 
-      const { files } = await this.app.listFilesInPage(null, args);
+      const { files } = await this.googleDrive.listFilesInPage(null, args);
       if (!files?.length) {
         return;
       }

components/google_docs/sources/new-or-updated-document/new-or-updated-document.mjs

@@ -2,7 +2,7 @@ import common from "../common/base.mjs";
 import {
   GOOGLE_DRIVE_NOTIFICATION_CHANGE,
   GOOGLE_DRIVE_NOTIFICATION_UPDATE,
-} from "../../../google_drive/common/constants.mjs";
+} from "@pipedream/google_drive/common/constants.mjs";
 
 export default {
   ...common,
@@ -31,7 +31,7 @@ export default {
       const filteredFiles = this.checkMinimumInterval(changedFiles);
 
       for (const file of filteredFiles) {
-        file.parents = (await this.app.getFile(file.id, {
+        file.parents = (await this.googleDrive.getFile(file.id, {
           fields: "parents",
         })).parents;
 
@@ -42,7 +42,7 @@ export default {
           continue;
         }
 
-        const doc = await this.app.getDocument(file.id);
+        const doc = await this.googleDrive.getDocument(file.id);
         const meta = this.generateMeta(doc);
         this.$emit(doc, meta);
       }