new components

Author: michelle0927

components/charthop/actions/record-compensation-change/record-compensation-change.mjs

@@ -0,0 +1,36 @@
+import charthop from "../../charthop.app.mjs";
+
+export default {
+  key: "charthop-search-organization",
+  name: "Search Organization",
+  description: "Return people, job, group, and field data for a particular org that match a provided search string. [See the documentation](https://api.charthop.com/swagger#/search/searchOrgData)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    charthop,
+    orgId: {
+      propDefinition: [
+        charthop,
+        "orgId",
+      ],
+    },
+    q: {
+      type: "string",
+      label: "Query",
+      description: "The search query",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.charthop.searchOrganization({
+      $,
+      orgId: this.orgId,
+      params: {
+        q: this.q,
+        includeFormer: true,
+      },
+    });
+
+    $.export("$summary", "Successfully completed search query");
+    return response;
+  },
+};

components/charthop/actions/search-organization/search-organization.mjs

@@ -62,14 +62,21 @@ export default {
       ...fields
     } = this;
 
-    const response = await charthop.updatePerson({
+    await charthop.updatePerson({
       $,
       orgId,
       personId: employeeId,
       data: {
         ...fields,
       },
     });
+
+    const response = await charthop.getPerson({
+      $,
+      orgId,
+      personId: employeeId,
+    });
+
     $.export("$summary", `Successfully updated employee with ID ${employeeId}`);
     return response;
   },

components/charthop/actions/update-employee-details/update-employee-details.mjs

@@ -64,29 +64,38 @@ export default {
         };
       },
     },
-
-    // Action: Modify Compensation Records
-    modifyCompensationEmployeeId: {
-      type: "string",
-      label: "Employee ID",
-      description: "ID of the employee for compensation update.",
-    },
-    modifyCompensationDetails: {
-      type: "string",
-      label: "Compensation Details",
-      description: "Details of the compensation update. Provide as a JSON string.",
-    },
-    modifyCompensationEffectiveDate: {
-      type: "string",
-      label: "Effective Date",
-      description: "Optional effective date for the compensation update.",
-      optional: true,
-    },
-    modifyCompensationReason: {
+    groupTypeId: {
       type: "string",
-      label: "Reason for Change",
-      description: "Optional reason for the compensation update.",
-      optional: true,
+      label: "Group Type ID",
+      description: "The identifier of a group type",
+      async options({
+        orgId, prevContext,
+      }) {
+        const params = {
+          includeAll: true,
+        };
+        if (prevContext?.from) {
+          params.from = prevContext.from;
+        }
+        const { data } = await this.listGroupTypes({
+          orgId,
+          params: {
+            ...params,
+          },
+        });
+        const options = data?.map(({
+          id: value, name: label,
+        }) => ({
+          value,
+          label,
+        })) || [];
+        return {
+          options,
+          context: {
+            from: data[data.length - 1].id,
+          },
+        };
+      },
     },
   },
   methods: {
@@ -121,6 +130,30 @@ export default {
         ...opts,
       });
     },
+    listJobs({
+      orgId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/v2/org/${orgId}/job`,
+        ...opts,
+      });
+    },
+    listGroupTypes({
+      orgId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/v1/org/${orgId}/group-type`,
+        ...opts,
+      });
+    },
+    listGroups({
+      orgId, type, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/v2/org/${orgId}/group/${type}`,
+        ...opts,
+      });
+    },
     getPerson({
       orgId, personId, ...opts
     }) {
@@ -147,5 +180,35 @@ export default {
         ...opts,
       });
     },
+    searchOrganization({
+      orgId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/v1/org/${orgId}/search`,
+        ...opts,
+      });
+    },
+    async *paginate({
+      resourceFn,
+      args,
+      max,
+    }) {
+      let count = 0;
+      do {
+        const {
+          data, next,
+        } = await resourceFn(args);
+        for (const item of data) {
+          yield item;
+          if (max && ++count >= max) {
+            return;
+          }
+          args.params = {
+            ...args.params,
+            from: next,
+          };
+        }
+      } while (args.params?.next);
+    },
   },
 };

components/charthop/charthop.app.mjs

@@ -0,0 +1,93 @@
+import charthop from "../../charthop.app.mjs";
+import {
+  ConfigurationError, DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+} from "@pipedream/platform";
+
+export default {
+  props: {
+    charthop,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    orgId: {
+      propDefinition: [
+        charthop,
+        "orgId",
+      ],
+    },
+  },
+  methods: {
+    _getLastId() {
+      return this.db.get("lastId");
+    },
+    _setLastId(lastId) {
+      this.db.set("lastId", lastId);
+    },
+    generateMeta(item) {
+      return {
+        id: item.id,
+        summary: this.getSummary(item),
+        ts: Date.now(),
+      };
+    },
+    emitEvents(items) {
+      items.forEach((item) => {
+        const meta = this.generateMeta(item);
+        this.$emit(item, meta);
+      });
+    },
+    getArgs() {
+      return {
+        orgId: this.orgId,
+      };
+    },
+    async getResults() {
+      const lastId = this._getLastId();
+      const resourceFn = this.getResourceFn();
+      const args = this.getArgs();
+
+      if (lastId) {
+        args.params = {
+          ...args.params,
+          from: lastId,
+        };
+      }
+
+      const items = this.charthop.paginate({
+        resourceFn,
+        args,
+      });
+
+      const results = [];
+      for await (const item of items) {
+        results.push(item);
+      }
+
+      if (results.length) {
+        this._setLastId(results[results.length - 1].id);
+      }
+
+      return results;
+    },
+    getResourceFn() {
+      throw new ConfigurationError("getResourceFn is not implemented");
+    },
+    getSummary() {
+      throw new ConfigurationError("getSummary is not implemented");
+    },
+  },
+  hooks: {
+    async deploy() {
+      const results = await this.getResults();
+      this.emitEvents(results.slice(-25));
+    },
+  },
+  async run() {
+    const results = await this.getResults();
+    this.emitEvents(results);
+  },
+};