Gmail - Adding checks for service account key

components/gmail/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/gmail",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Pipedream Gmail Components",
   "main": "gmail.app.mjs",
   "keywords": [

components/gmail/sources/new-email-received/new-email-received.mjs

@@ -15,7 +15,7 @@
   name: "New Email Received",
   description: "Emit new event when a new email is received.",
   type: "source",
-  version: "0.1.10",
+  version: "0.1.11",
   dedupe: "unique",
   props: {
     gmail,
@@ -31,14 +31,14 @@
         "Configuring this source as a `webhook` (instant) trigger requires a custom OAuth client. [Refer to the guide here to get started](https://pipedream.com/apps/gmail/#getting-started).",
       reloadProps: true,
     },
     serviceAccountKeyJson: {
       type: "string",
       label: "Service Account Key JSON",
       optional: true,
       hidden: true,
       reloadProps: true,
     },
     serviceAccountKeyJsonInstructions: {
       type: "alert",
       alertType: "info",
       content: `1) [Create a service account in GCP](https://cloud.google.com/iam/docs/creating-managing-service-accounts) and set the following permission: **Pub/Sub Admin**
@@ -96,7 +96,7 @@
       optional: true,
       hidden: true,
     },
     permissionAlert: {
       type: "alert",
       alertType: "error",
       content: `Unable to grant publish permission to Gmail API service account.
@@ -109,7 +109,7 @@
       `,
       hidden: true,
     },
     latencyWarningAlert: {
       type: "alert",
       alertType: "warning",
       content:
@@ -166,7 +166,7 @@
       // create topic prop
       let topicName = this.topic;
       if (this.topicType === "new") {
-        const authKeyJSON = JSON.parse(this.serviceAccountKeyJson);
+        const authKeyJSON = this.getServiceAccountKeyJson();
         const { project_id: projectId } = authKeyJSON;
         topicName = `projects/${projectId}/topics/${this.convertNameToValidPubSubTopicName(
           uuidv4(),
@@ -317,8 +317,18 @@
     _setLastReceivedTime(lastReceivedTime) {
       this.db.set("lastReceivedTime", lastReceivedTime);
     },
+    getServiceAccountKeyJson() {
+      try {
+        return JSON.parse(this.serviceAccountKeyJson);
+      } catch (err) {
+        throw new ConfigurationError(`Error parsing \`Service Account Key JSON\`. Ensure its contents are valid JSON. \`${err}\``);
+      }
+    },
     sdkParams() {
-      const authKeyJSON = JSON.parse(this.serviceAccountKeyJson);
+      if (!this.serviceAccountKeyJson) {
+        throw new ConfigurationError("Not able to create a webhook or subscribe to topics without configuring a service account. Please reconfigure the trigger type and try again.");
+      }
+      const authKeyJSON = this.getServiceAccountKeyJson();
       const {
         project_id: projectId, client_email, private_key,
       } = authKeyJSON;
@@ -332,6 +342,7 @@
       return sdkParams;
     },
     async getTopics() {
+
       const sdkParams = this.sdkParams();
       const pubSubClient = new PubSub(sdkParams);
       const topics = (await pubSubClient.getTopics())[0];