offlight init

Author: luancazarine

components/offlight/actions/create-task/create-task.mjs

@@ -0,0 +1,67 @@
+import offlight from "../../offlight.app.mjs";
+import { axios } from "@pipedream/platform";
+
+export default {
+  key: "offlight-create-task",
+  name: "Create Task",
+  description: "Initiates the creation of a new task in Offlight. [See the documentation](https://www.offlight.work/docs/zapeir-api)",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    offlight,
+    taskName: {
+      propDefinition: [
+        offlight,
+        "taskName",
+      ],
+    },
+    taskNote: {
+      propDefinition: [
+        offlight,
+        "taskNote",
+      ],
+      optional: true,
+    },
+    taskDeadline: {
+      propDefinition: [
+        offlight,
+        "taskDeadline",
+      ],
+      optional: true,
+    },
+    identifier: {
+      propDefinition: [
+        offlight,
+        "identifier",
+      ],
+      optional: true,
+    },
+    sourceName: {
+      propDefinition: [
+        offlight,
+        "sourceName",
+      ],
+      optional: true,
+    },
+    sourceLink: {
+      propDefinition: [
+        offlight,
+        "sourceLink",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.offlight.createTask({
+      taskName: this.taskName,
+      taskNote: this.taskNote,
+      taskDeadline: this.taskDeadline,
+      identifier: this.identifier,
+      sourceName: this.sourceName,
+      sourceLink: this.sourceLink,
+    });
+
+    $.export("$summary", `Task successfully created with ID: ${response.id}`);
+    return response;
+  },
+};

components/offlight/offlight.app.mjs

@@ -1,11 +1,106 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "offlight",
-  propDefinitions: {},
+  propDefinitions: {
+    taskName: {
+      type: "string",
+      label: "Task Name",
+      description: "The name of the task.",
+    },
+    taskNote: {
+      type: "string",
+      label: "Task Note",
+      description: "A note about the task.",
+      optional: true,
+    },
+    taskDeadline: {
+      type: "string",
+      label: "Task Deadline",
+      description: "The deadline of the task (in ISO 8601 format).",
+      optional: true,
+    },
+    identifier: {
+      type: "string",
+      label: "Identifier",
+      description: "A unique identifier for the task.",
+      optional: true,
+    },
+    sourceName: {
+      type: "string",
+      label: "Source Name",
+      description: "The source name of the task.",
+      optional: true,
+    },
+    sourceLink: {
+      type: "string",
+      label: "Source Link",
+      description: "The source link of the task.",
+      optional: true,
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
+    _baseUrl() {
+      return "https://www.offlight.work";
+    },
+    async _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        method = "GET",
+        path = "/",
+        headers,
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        method,
+        url: this._baseUrl() + path,
+        headers: {
+          ...headers,
+          "X-API-KEY": this.$auth.api_key,
+        },
+      });
+    },
+    async createTask({
+      taskName,
+      taskNote,
+      taskDeadline,
+      identifier,
+      sourceName,
+      sourceLink,
+    }) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/zapier/task",
+        data: {
+          task_name: taskName,
+          task_note: taskNote,
+          task_deadline: taskDeadline,
+          identifier: identifier,
+          source_name: sourceName,
+          source_link: sourceLink,
+        },
+      });
+    },
+    async getDoneTasks(opts = {}) {
+      return this._makeRequest({
+        ...opts,
+        method: "GET",
+        path: "/zapier/doneTasks",
+      });
+    },
+    async paginate(fn, ...opts) {
+      let results = [];
+      let response;
+      do {
+        response = await fn(...opts);
+        results = results.concat(response);
+      } while (response.length);
+      return results;
+    },
   },
-};
+};

components/offlight/package.json

@@ -12,4 +12,4 @@
   "publishConfig": {
     "access": "public"
   }
-}
+}

components/offlight/sources/new-task-done-instant/new-task-done-instant.mjs

@@ -0,0 +1,50 @@
+import offlight from "../../offlight.app.mjs";
+import { axios } from "@pipedream/platform";
+
+export default {
+  key: "offlight-new-task-done-instant",
+  name: "New Task Done Instant",
+  description: "Emit new event when a task is marked as complete. [See the documentation](https://www.offlight.work/docs/zapeir-api)",
+  version: "0.0.{{ts}}",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    offlight: {
+      type: "app",
+      app: "offlight",
+    },
+    http: {
+      type: "$.interface.http",
+      customResponse: false,
+    },
+    db: "$.service.db",
+  },
+  hooks: {
+    async deploy() {
+      const tasks = await this.offlight.getDoneTasks({
+        max: 50,
+      });
+      for (const task of tasks) {
+        this.$emit(task, {
+          id: task.id,
+          summary: `Task ${task.name} marked as done`,
+          ts: Date.parse(task.doneAt),
+        });
+      }
+    },
+    async activate() {
+      // No specific activation for this component
+    },
+    async deactivate() {
+      // No specific deactivation for this component
+    },
+  },
+  async run(event) {
+    const { body: task } = event;
+    this.$emit(task, {
+      id: task.id,
+      summary: `Task ${task.name} marked as done`,
+      ts: Date.parse(task.doneAt),
+    });
+  },
+};