New Components - motive

components/adobe_photoshop_lightroom/adobe_photoshop_lightroom.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/applicantstack/applicantstack.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/benchmarkone/benchmarkone.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/claris_filemaker_server_admin_api/claris_filemaker_server_admin_api.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/claris_filemaker_server_data_api/claris_filemaker_server_data_api.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/claris_filemaker_server_odata_api/claris_filemaker_server_odata_api.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/current_rms/current_rms.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/elastic_cloud/elastic_cloud.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/felt/felt.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/globalping/globalping.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/langfuse/langfuse.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/mailtrap/mailtrap.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/morgen/morgen.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/motive/actions/find-user-details/find-user-details.mjs

@@ -0,0 +1,75 @@
+import { ConfigurationError } from "@pipedream/platform";
+import { clearObj } from "../../common/util.mjs";
+import motive from "../../motive.app.mjs";
+
+export default {
+  key: "motive-find-user-details",
+  name: "Find User Details",
+  description: "Retrieve user details based on specific criteria. [See the documentation](https://developer.gomotive.com/reference/users-lookup)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    motive,
+    alert: {
+      type: "alert",
+      alertType: "info",
+      content: "If you provide more than one prop, only one will be considered, the others will be ignored.",
+    },
+    username: {
+      type: "string",
+      label: "Username",
+      description: "Username to retrieve user details",
+      optional: true,
+    },
+    email: {
+      type: "string",
+      label: "Email",
+      description: "Email to retrieve user details",
+      optional: true,
+    },
+    driverCompanyId: {
+      propDefinition: [
+        motive,
+        "driverCompanyId",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    let response;
+    const criteria = [];
+
+    const {
+      username, email, driverCompanyId,
+    } = this;
+    if (!username && !email && !driverCompanyId) {
+      throw new Error("At least one of 'Username', 'Email', 'Driver Company Id' must be provided.");
+    }
+
+    if (username) criteria.push(`username: ${username}`);
+    if (email) criteria.push(`email: ${email}`);
+    if (driverCompanyId) criteria.push(`driverCompanyId: ${driverCompanyId}`);
+
+    try {
+      response = await this.motive.retrieveUserDetails({
+        $,
+        params: clearObj({
+          username,
+          email,
+          driver_company_id: driverCompanyId,
+        }),
+      });
+
+    } catch ({ response: { data } }) {
+      if (data.error_message === "user not found") {
+        response =  {
+          user: null,
+        };
+      } else {
+        throw new ConfigurationError(data.error_message);
+      }
+    }
+    $.export("$summary", `Successfully retrieved user details for ${criteria.join(", ")}`);
+    return response;
+  },
+};

components/motive/common/util.mjs

@@ -0,0 +1,16 @@
+export const clearObj = (obj) => {
+  return Object.entries(obj)
+    .filter(([
+      _,
+      v,
+    ]) => (v != null && v != "" && _ != "$emit"))
+    .reduce((acc, [
+      k,
+      v,
+    ]) => ({
+      ...acc,
+      [k]: (!Array.isArray(v) && v === Object(v))
+        ? clearObj(v)
+        : v,
+    }), {});
+};

components/motive/motive.app.mjs

@@ -1,11 +1,124 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "motive",
-  propDefinitions: {},
+  propDefinitions: {
+    driverId: {
+      type: "string",
+      label: "Driver ID",
+      description: "Filter to a specific driver",
+    },
+    safetyCategory: {
+      type: "string",
+      label: "Safety Category",
+      description: "Filter to a specific safety category",
+    },
+    driverCompanyId: {
+      type: "string",
+      label: "Driver Company ID",
+      description: "Driver company ID to retrieve user details",
+      async options({ page }) {
+        const { users } = await this.listUsers({
+          params: {
+            page_no: page + 1,
+            role: "driver",
+          },
+        });
+
+        return users.map(({ user }) => ({
+          label: user.email || `${user.first_name} ${user.last_name}`,
+          value: user.driver_company_id,
+        }));
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://api.gomotive.com/v1";
+    },
+    _headers() {
+      return {
+        Authorization: `Bearer ${this.$auth.oauth_access_token}`,
+      };
+    },
+    _makeRequest({
+      $ = this, path, ...opts
+    }) {
+      return axios($, {
+        url: this._baseUrl() + path,
+        headers: this._headers(),
+        ...opts,
+      });
+    },
+    listHosViolations(opts = {}) {
+      return this._makeRequest({
+        method: "GET",
+        path: "/hos_violations",
+        ...opts,
+      });
+    },
+    listUsers(opts = {}) {
+      return this._makeRequest({
+        path: "/users",
+        ...opts,
+      });
+    },
+    createWebhook(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/company_webhooks",
+        ...opts,
+      });
+    },
+    updateWebhook({
+      webhookId, ...opts
+    }) {
+      return this._makeRequest({
+        method: "PUT",
+        path: `/company_webhooks/${webhookId}`,
+        ...opts,
+      });
+    },
+    listDriverPerformanceEvents(opts = {}) {
+      return this._makeRequest({
+        method: "GET",
+        path: "/driver_performance_events",
+        ...opts,
+      });
+    },
+    retrieveUserDetails(opts = {}) {
+      return this._makeRequest({
+        method: "GET",
+        path: "/users/lookup",
+        ...opts,
+      });
+    },
+    async *paginate({
+      fn, params = {}, fieldName, maxResults = null, ...opts
+    }) {
+      let hasMore = false;
+      let count = 0;
+      let page = 0;
+
+      do {
+        params.page = ++page;
+        const data = await fn({
+          params,
+          ...opts,
+        });
+        const items = data[fieldName];
+        for (const d of items) {
+          yield d;
+
+          if (maxResults && ++count === maxResults) {
+            return count;
+          }
+        }
+
+        hasMore = items.length;
+
+      } while (hasMore);
     },
   },
 };

components/motive/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/motive",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Motive Components",
   "main": "motive.app.mjs",
   "keywords": [
@@ -11,5 +11,9 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3",
+    "uuid": "^11.0.4"
   }
-}
+}

components/motive/sources/common/base.mjs

@@ -0,0 +1,63 @@
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import motive from "../../motive.app.mjs";
+
+export default {
+  props: {
+    motive,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  methods: {
+    _getLastId() {
+      return this.db.get("lastId") || 0;
+    },
+    _setLastId(lastId) {
+      this.db.set("lastId", lastId);
+    },
+    async emitEvent(maxResults = false) {
+      const lastId = this._getLastId();
+      const fieldName = this.getFieldName();
+
+      const response = this.motive.paginate({
+        fn: this.getFunction(),
+        fieldName: `${fieldName}s`,
+      });
+
+      let responseArray = [];
+      for await (const item of response) {
+        const data = item[fieldName];
+        if (data.id <= lastId) break;
+        responseArray.push(data);
+      }
+
+      if (responseArray.length) {
+        if (maxResults && (responseArray.length > maxResults)) {
+          responseArray.length = maxResults;
+        }
+        this._setLastId(responseArray[0].id);
+      }
+
+      for (const item of responseArray.reverse()) {
+        const data = item[fieldName];
+        this.$emit(data, {
+          id: data.id,
+          summary: this.getSummary(data),
+          ts: Date.parse(data.start_time || new Date()),
+        });
+      }
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.emitEvent(25);
+    },
+  },
+  async run() {
+    await this.emitEvent();
+  },
+};