some adjusts

Author: luancazarine

components/agentset/common/utils.mjs

@@ -31,12 +31,3 @@ export const parseObject = (obj) => {
   }
   return obj;
 };
-
-export const prepareDateTime = (data) => {
-  return data.completedAt ||
-  data.failedAt ||
-  data.processingAt ||
-  data.preProcessingAt ||
-  data.queuedAt ||
-  data.createdAt;
-};

components/agentset/sources/common/base.mjs

@@ -1,6 +1,5 @@
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 import agentset from "../../agentset.app.mjs";
-import { prepareDateTime } from "../../common/utils.mjs";
 
 export default {
   props: {
@@ -18,13 +17,6 @@ export default {
         "namespaceId",
       ],
     },
-    statuses: {
-      propDefinition: [
-        agentset,
-        "statuses",
-      ],
-      optional: true,
-    },
   },
   methods: {
     _getLastData() {
@@ -40,7 +32,6 @@ export default {
         fn: this.getFunction(),
         namespaceId: this.namespaceId,
         params: {
-          statuses: this.statuses,
           orderBy: "createdAt",
           order: "desc",
           pageSize: 100,
@@ -50,8 +41,7 @@ export default {
 
       let responseArray = [];
       for await (const item of response) {
-        const dateTime = prepareDateTime(item);
-        if (Date.parse(dateTime) <= lastData) break;
+        if (Date.parse(item.createdAt) <= lastData) break;
         responseArray.push(item);
       }
 
@@ -60,11 +50,10 @@ export default {
       }
 
       for (const item of responseArray.reverse()) {
-        const dateTime = prepareDateTime(item);
         this.$emit(item, {
-          id: `${item.id}-${item.status}`,
+          id: `${item.id}`,
           summary: this.getSummary(item),
-          ts: Date.parse(dateTime),
+          ts: Date.parse(item.createdAt),
         });
       }
     },

components/agentset/sources/document-status-updated/document-status-updated.mjs renamed to components/agentset/sources/new-document-created/new-document-created.mjs

@@ -3,9 +3,9 @@ import sampleEmit from "./test-event.mjs";
 
 export default {
   ...common,
-  key: "agentset-document-status-updated",
-  name: "Document Status Updated",
-  description: "Emit new event when a document status is updated. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/documents/list)",
+  key: "agentset-new-document-created",
+  name: "New Document Created",
+  description: "Emit new event when a new document is created. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/documents/list)",
   version: "0.0.1",
   type: "source",
   dedupe: "unique",
@@ -15,7 +15,7 @@ export default {
       return this.agentset.listDocuments;
     },
     getSummary(item) {
-      return `Document ${item.name || item.id} has a new status: ${item.status}`;
+      return `New document cerated: ${item.name || item.id}`;
     },
   },
   sampleEmit,

components/agentset/sources/document-status-updated/test-event.mjs renamed to components/agentset/sources/new-document-created/test-event.mjs

@@ -3,9 +3,9 @@ import sampleEmit from "./test-event.mjs";
 
 export default {
   ...common,
-  key: "agentset-ingest-job-status-updated",
-  name: "Ingest Job Status Updated",
-  description: "Emit new event when a ingest job status is updated. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/ingest-jobs/list)",
+  key: "agentset-new-ingest-job-created",
+  name: "New Ingest Job Created",
+  description: "Emit new event when a ingest job is created. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/ingest-jobs/list)",
   version: "0.0.1",
   type: "source",
   dedupe: "unique",
@@ -15,7 +15,7 @@ export default {
       return this.agentset.listIngestJobs;
     },
     getSummary(item) {
-      return `Ingest Job (${item.id}) has a new status: ${item.status}`;
+      return `New ingest job created (${item.id})`;
     },
   },
   sampleEmit,