Sources

 - New Hours Of Service Violation
 - New Safety Event

Actions
 - Find User Details

Author: luancazarine

components/motive/motive.app.mjs

@@ -94,5 +94,31 @@ export default {
         ...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/sources/common/base.mjs

@@ -1,61 +1,63 @@
-import { v4 as uuid } from "uuid";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 import motive from "../../motive.app.mjs";
 
 export default {
   props: {
     motive,
-    http: "$.interface.http",
     db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
   },
   methods: {
-    _getHookId() {
-      return this.db.get("hookId");
+    _getLastId() {
+      return this.db.get("lastId") || 0;
     },
-    _setHookId(hookId) {
-      this.db.set("hookId", hookId);
+    _setLastId(lastId) {
+      this.db.set("lastId", lastId);
     },
-    filterEvent() {
-      return true;
+    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() {
-      const response = await this.motive.createWebhook({
-        data: {
-          url: this.http.endpoint,
-          secret: uuid(),
-          actions: this.getActions(),
-          format: "json",
-          enabled: true,
-          webhook_type: "POST",
-        },
-      });
-      this._setHookId(response.company_webhook.id);
-    },
-    async activate() {
-      await this.motive.updateWebhook({
-        webhookId: this._getHookId(),
-        data: {
-          enabled: true,
-        },
-      });
-    },
-    async deactivate() {
-      await this.motive.updateWebhook({
-        webhookId: this._getHookId(),
-        data: {
-          enabled: false,
-        },
-      });
+      await this.emitEvent(25);
     },
   },
-  async run({ body }) {
-    if (this.filterEvent(body)) {
-      this.$emit(body, {
-        id: body.id,
-        summary: this.getSummary(body),
-        ts: Date.parse(body.end_time || new Date()),
-      });
-    }
+  async run() {
+    await this.emitEvent();
   },
 };

components/motive/sources/new-hours-of-service-violation-instant/new-hours-of-service-violation-instant.mjs

@@ -0,0 +1,25 @@
+import common from "../common/base.mjs";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  ...common,
+  key: "motive-new-hours-of-service-violation",
+  name: "New Hours of Service Violation",
+  description: "Emit new event when a hos is emited.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getFunction() {
+      return this.motive.listHosViolations;
+    },
+    getFieldName() {
+      return "hos_violation";
+    },
+    getSummary(item) {
+      return `New HOS Violation: ${item.id}`;
+    },
+  },
+  sampleEmit,
+};

components/motive/sources/new-hours-of-service-violation-instant/test-event.mjs

@@ -0,0 +1,17 @@
+export default {
+  "id": 97,
+  "type": "ca_duty_15",
+  "start_time": "2016-03-12T19:00:00Z",
+  "end_time": null,
+  "name": "15 Hour On Duty Limit",
+  "user": {
+    "id": 156,
+    "first_name": "Harold",
+    "last_name": "Hoeger",
+    "username": "hobart",
+    "email": null,
+    "driver_company_id": null,
+    "status": "deactivated",
+    "role": "driver"
+  }
+}

components/motive/sources/new-hours-of-service-violation/new-hours-of-service-violation.mjs

@@ -3,18 +3,19 @@ import sampleEmit from "./test-event.mjs";
 
 export default {
   ...common,
-  key: "motive-new-safety-event-instant",
-  name: "New Safety Event (Instant)",
+  key: "motive-new-safety-event",
+  name: "New Safety Event",
   description: "Emit new safety-related events like harsh braking or acceleration.",
   version: "0.0.1",
   type: "source",
   dedupe: "unique",
   methods: {
     ...common.methods,
-    getActions() {
-      return [
-        "driver_performance_event_created",
-      ];
+    getFunction() {
+      return this.motive.listDriverPerformanceEvents;
+    },
+    getFieldName() {
+      return "driver_performance_event";
     },
     getSummary(event) {
       return `New Safety Event: ${event.type}`;