Slack - New Private Channel Created

components/slack_v2/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/slack_v2",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Slack_v2 Components",
   "main": "slack_v2.app.mjs",
   "keywords": [

components/slack_v2/sources/common/base-polling.mjs

@@ -0,0 +1,50 @@
+import slack from "../../slack_v2.app.mjs";
+import {
+  DEFAULT_POLLING_SOURCE_TIMER_INTERVAL, ConfigurationError,
+} from "@pipedream/platform";
+
+export default {
+  props: {
+    slack,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  methods: {
+    _getLastTs() {
+      return this.db.get("lastTs") || 0;
+    },
+    _setLastTs(lastTs) {
+      this.db.set("lastTs", lastTs);
+    },
+    getResources() {
+      throw new ConfigurationError("getResources is not implemented");
+    },
+    generateMeta() {
+      throw new ConfigurationError("generateMeta is not implemented");
+    },
+    async processEvents(max) {
+      const results = await this.getResources(max);
+      if (!results.length) {
+        return;
+      }
+
+      results.forEach((result) => {
+        const meta = this.generateMeta(result);
+        this.$emit(result, meta);
+      });
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.processEvents(10);
+    },
+  },
+  async run() {
+    await this.processEvents();
+  },
+};

components/slack_v2/sources/new-private-channel-created/new-private-channel-created.mjs

@@ -0,0 +1,55 @@
+import common from "../common/base-polling.mjs";
+
+export default {
+  ...common,
+  key: "slack_v2-new-private-channel-created",
+  name: "New Private Channel Created",
+  version: "0.0.1",
+  description: "Emit new event when a new private channel is created. [See the documentation](https://api.slack.com/methods/conversations.list)",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    async getResources(max) {
+      const privateChannels = [];
+      const params = {
+        limit: 1000,
+        types: "private_channel",
+      };
+      const lastTs = this._getLastTs();
+      let maxTs = lastTs;
+
+      do {
+        const {
+          channels, response_metadata: { next_cursor: nextCursor },
+        } = await this.slack.conversationsList(params);
+        if (!channels.length) {
+          break;
+        }
+        for (const channel of channels) {
+          const ts = channel.created;
+          if (ts > lastTs) {
+            privateChannels.push(channel);
+            maxTs = Math.max(ts, maxTs);
+          }
+        }
+        params.cursor = nextCursor;
+      } while (params.cursor);
+
+      this._setLastTs(maxTs);
+
+      if (max && privateChannels.length > max) {
+        privateChannels.length = max;
+      }
+
+      return privateChannels;
+    },
+    generateMeta(channel) {
+      return {
+        id: channel.id,
+        summary: `New private channel created - ${channel.name}`,
+        ts: channel.created,
+      };
+    },
+  },
+};