Creating polling sources

Author: GTFalcao

components/sage_accounting/sage_accounting.app.mjs

@@ -456,5 +456,23 @@ export default {
         ...args,
       });
     },
+    async listProducts(args) {
+      return this._paginatedRequest({
+        path: "/products",
+        ...args,
+      });
+    },
+    async listServices(args) {
+      return this._paginatedRequest({
+        path: "/services",
+        ...args,
+      });
+    },
+    async listContactPayments(args) {
+      return this._paginatedRequest({
+        path: "/contact_payments",
+        ...args,
+      });
+    },
   },
 };

components/sage_accounting/sources/common/polling.mjs

@@ -0,0 +1,55 @@
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import sageAccounting from "../../sage_accounting.app.mjs";
+
+export default {
+  props: {
+    sageAccounting,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  methods: {
+    _getSavedIds() {
+      return this.db.get("savedIds") || [];
+    },
+    _setSavedIds(ids) {
+      this.db.set("savedIds", ids);
+    },
+    async startEvent(maxItems) {
+      const savedIds = this._getSavedIds();
+      const items = await this.getItems();
+
+      const newIds = [];
+      for (const item of items) {
+        const id = this.getItemId(item);
+        if (!savedIds.includes(id)) {
+          const meta = this.generateMeta(item);
+          if (maxItems === undefined || (typeof maxItems === "number" && --maxItems >= 0)) {
+            this.$emit(item, meta);
+          }
+          newIds.push(id);
+        }
+      }
+
+      if (newIds.length > 0) {
+        const ids = [
+          ...savedIds,
+          ...newIds,
+        ].slice(-100);
+        this._setSavedIds(ids);
+      }
+    },
+  },
+  async run() {
+    await this.startEvent();
+  },
+  hooks: {
+    async deploy() {
+      await this.startEvent(5);
+    },
+  },
+};

components/sage_accounting/sources/new-contact-payment-created/new-contact-payment-created.mjs

@@ -0,0 +1,39 @@
+import common from "../common/polling.mjs";
+
+export default {
+  ...common,
+  key: "sage_accounting-new-contact-payment-created",
+  name: "New Contact Payment Created",
+  description: "Emit new event when a contact payment is created in Sage Accounting. [See the documentation](https://developer.sage.com/accounting/reference/payments/#tag/Contact-Payments/operation/getContactPayments)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    generateMeta(payment) {
+      const id = this.getItemId(payment);
+      const summary = this.getItemSummary(payment);
+      return {
+        id,
+        summary: `New Contact Payment Created: ${summary}`,
+        ts: Date.parse(payment.created_at) || Date.now(),
+      };
+    },
+    getItemId(payment) {
+      return payment.id;
+    },
+    getItemSummary(payment) {
+      const contactName = payment.contact?.displayed_as || payment.contact?.name || "Unknown Contact";
+      const amount = payment.total_amount || payment.net_amount || "Unknown Amount";
+      return `${contactName} - ${amount}`;
+    },
+    async getItems() {
+      const payments = await this.sageAccounting.listContactPayments({
+        params: {
+          items_per_page: 100,
+        },
+      });
+      return payments || [];
+    },
+  },
+};

components/sage_accounting/sources/new-product-created/new-product-created.mjs

@@ -0,0 +1,37 @@
+import common from "../common/polling.mjs";
+
+export default {
+  ...common,
+  key: "sage_accounting-new-product-created",
+  name: "New Product Created",
+  description: "Emit new event when a product is created in Sage Accounting. [See the documentation](https://developer.sage.com/accounting/reference/products-services/#tag/Products/operation/getProducts)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    generateMeta(product) {
+      const id = this.getItemId(product);
+      const summary = this.getItemSummary(product);
+      return {
+        id,
+        summary: `New Product Created: ${summary}`,
+        ts: Date.parse(product.created_at) || Date.now(),
+      };
+    },
+    getItemId(product) {
+      return product.id;
+    },
+    getItemSummary(product) {
+      return product.description || product.displayed_as || product.id;
+    },
+    async getItems() {
+      const products = await this.sageAccounting.listProducts({
+        params: {
+          items_per_page: 100,
+        },
+      });
+      return products || [];
+    },
+  },
+};

components/sage_accounting/sources/new-service-created/new-service-created.mjs

@@ -0,0 +1,37 @@
+import common from "../common/polling.mjs";
+
+export default {
+  ...common,
+  key: "sage_accounting-new-service-created",
+  name: "New Service Created",
+  description: "Emit new event when a service is created in Sage Accounting. [See the documentation](https://developer.sage.com/accounting/reference/products-services/#tag/Services/operation/getServices)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    generateMeta(service) {
+      const id = this.getItemId(service);
+      const summary = this.getItemSummary(service);
+      return {
+        id,
+        summary: `New Service Created: ${summary}`,
+        ts: Date.parse(service.created_at) || Date.now(),
+      };
+    },
+    getItemId(service) {
+      return service.id;
+    },
+    getItemSummary(service) {
+      return service.description || service.displayed_as || service.id;
+    },
+    async getItems() {
+      const services = await this.sageAccounting.listServices({
+        params: {
+          items_per_page: 100,
+        },
+      });
+      return services || [];
+    },
+  },
+};