[TRIGGERS] Facebook Pages

components/facebook_pages/facebook_pages.app.mjs

@@ -101,6 +101,11 @@ export default {
       description: "The maximum number of results to return",
       optional: true,
     },
+    appId: {
+      type: "string",
+      label: "App ID",
+      description: "The Facebook App ID. You can find this in your Facebook App Dashboard.",
+    },
   },
   methods: {
     _baseUrl() {
@@ -139,6 +144,12 @@ export default {
       const page = data.find(({ id }) => id == pageId);
       return page.access_token;
     },
+    getAppAccessToken(args = {}) {
+      return this._makeRequest({
+        path: "/oauth/access_token",
+        ...args,
+      });
+    },
     getPost({
       pageId, postId, ...args
     }) {
@@ -221,5 +232,43 @@ export default {
         ...args,
       });
     },
+    createSubscription({
+      appId, ...args
+    } = {}) {
+      return this._makeRequest({
+        path: `/${appId}/subscriptions`,
+        method: "POST",
+        ...args,
+      });
+    },
+    deleteSubscription({
+      appId, ...args
+    } = {}) {
+      return this._makeRequest({
+        path: `/${appId}/subscriptions`,
+        method: "DELETE",
+        ...args,
+      });
+    },
+    createPageSubscription({
+      pageId, ...args
+    } = {}) {
+      return this._makeRequest({
+        path: `/${pageId}/subscribed_apps`,
+        method: "POST",
+        pageId,
+        ...args,
+      });
+    },
+    deletePageSubscription({
+      pageId, ...args
+    } = {}) {
+      return this._makeRequest({
+        path: `/${pageId}/subscribed_apps`,
+        method: "DELETE",
+        pageId,
+        ...args,
+      });
+    },
   },
 };

components/facebook_pages/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/facebook_pages",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream Facebook Pages Components",
   "main": "facebook_pages.app.mjs",
   "keywords": [
@@ -13,6 +13,6 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.5.1"
+    "@pipedream/platform": "^3.1.0"
   }
 }

components/facebook_pages/sources/README.md

@@ -0,0 +1,80 @@
+# Facebook Pages Webhook Sources
+
+This directory contains webhook sources for Facebook Pages events. These sources allow you to receive real-time notifications when various events occur on your Facebook Page.
+
+## Available Sources
+
+### 1. New Feed Activity (`new-feed-activity`)
+Emit new event when there's any new activity in your Facebook Page's feed. This includes new posts, comments, reactions, and shares.
+
+### 2. New Post to Page (`new-post`)
+Emit new event when a new post is made to your Facebook Page's feed.
+
+### 3. New Comment on Post (`new-comment`)
+Emit new event when a new comment is added to a post on your Facebook Page.
+
+### 4. New Reaction on Post (`new-reaction`)
+Emit new event when someone reacts to a post on your Facebook Page (likes, love, wow, etc.).
+
+### 5. New Share of Post (`new-share`)
+Emit new event when someone shares a post from your Facebook Page.
+
+### 6. Page Updated (`page-updated`)
+Emit new event when your Facebook Page information is updated (such as description, hours, location, etc.).
+
+### 7. New Message Received (`new-message`)
+Emit new event when your Facebook Page receives a new message via Messenger.
+
+## Setup Instructions
+
+To use these webhook sources, you need to:
+
+1. **Create a Facebook App**:
+   - Go to [Facebook Developers](https://developers.facebook.com/)
+   - Create a new app or use an existing one
+   - Note your App ID
+
+2. **Configure Webhooks in Facebook**:
+   - In your Facebook App dashboard, go to Webhooks
+   - Subscribe to the "Page" object
+   - When deploying a source in Pipedream, you'll get a webhook URL and verify token
+   - Use these values in your Facebook webhook configuration
+
+3. **Set Required Permissions**:
+   - For feed webhooks: `pages_manage_metadata` and `pages_show_list`
+   - For message webhooks: `pages_messaging`
+
+4. **Subscribe Your Page**:
+   - The webhook source will automatically subscribe your selected page to receive events
+   - Make sure your page has not disabled the App platform in its settings
+
+## Common Properties
+
+All webhook sources share these properties:
+
+- **Facebook Pages App**: Your Facebook Pages connection
+- **Page**: The Facebook Page to monitor for events
+- **Verify Token**: A custom string for webhook verification (auto-generated but can be customized)
+
+## Event Data
+
+Each webhook event includes relevant data such as:
+- Event type and timestamp
+- User information (when available)
+- Content (messages, post text, etc.)
+- Related IDs (post_id, comment_id, etc.)
+
+## Troubleshooting
+
+1. **Webhook not receiving events**: 
+   - Ensure your Facebook App has the correct permissions
+   - Verify the webhook is properly configured in Facebook
+   - Check that your page has the app installed
+
+2. **Verification failing**:
+   - Make sure the verify token matches exactly between Pipedream and Facebook
+   - The webhook URL must be publicly accessible (HTTPS)
+
+3. **Missing events**:
+   - Some events require specific permissions
+   - Check Facebook's webhook documentation for limitations

components/facebook_pages/sources/common/webhook.mjs

@@ -0,0 +1,112 @@
+import crypto from "crypto";
+import app from "../../facebook_pages.app.mjs";
+
+export default {
+  props: {
+    app,
+    db: "$.service.db",
+    http: {
+      type: "$.interface.http",
+      customResponse: true,
+    },
+    page: {
+      propDefinition: [
+        app,
+        "page",
+      ],
+    },
+    verifyToken: {
+      type: "string",
+      label: "Verify Token",
+      description: "A custom string you provide to Facebook for webhook verification. Facebook will send this token back when verifying your webhook endpoint.",
+      default: crypto.randomBytes(16).toString("hex"),
+    },
+  },
+  hooks: {
+    async activate() {
+      // Subscribe the page to the app with specified fields (page-level webhooks)
+      await this.app.createPageSubscription({
+        pageId: this.page,
+        params: {
+          subscribed_fields: this.getFields().join(","),
+        },
+      });
+
+      // Store page ID for deactivation
+      this._setPageId(this.page);
+
+      console.log(`Webhook URL: ${this.http.endpoint}`);
+      console.log(`Verify Token: ${this.verifyToken}`);
+      console.log("Subscribed page-level webhooks for fields:", this.getFields());
+    },
+    async deactivate() {
+      const pageId = this._getPageId();
+      if (pageId) {
+        await this.app.deletePageSubscription({
+          pageId,
+        });
+      }
+    },
+  },
+  methods: {
+    _getPageId() {
+      return this.db.get("pageId");
+    },
+    _setPageId(pageId) {
+      this.db.set("pageId", pageId);
+    },
+    getFields() {
+      throw new Error("getFields is not implemented");
+    },
+    generateMeta() {
+      throw new Error("generateMeta is not implemented");
+    },
+    processEvent() {
+      throw new Error("processEvent is not implemented");
+    },
+  },
+  async run({
+    query, body, method,
+  }) {
+    // Handle webhook verification from Facebook
+    if (method === "GET") {
+      const mode = query["hub.mode"];
+      const token = query["hub.verify_token"];
+      const challenge = query["hub.challenge"];
+
+      if (mode === "subscribe" && token === this.verifyToken) {
+        console.log("Webhook verified");
+        this.http.respond({
+          status: 200,
+          body: challenge,
+        });
+        return;
+      } else {
+        console.log("Webhook verification failed");
+        this.http.respond({
+          status: 403,
+        });
+        return;
+      }
+    }
+
+    // Handle webhook events
+    this.http.respond({
+      status: 200,
+    });
+
+    if (body?.object === "page" && body?.entry) {
+      body.entry.forEach((entry) => {
+        if (entry.changes) {
+          entry.changes.forEach((change) => {
+            const eventData = this.processEvent(change);
+            if (eventData) {
+              const meta = this.generateMeta(eventData);
+              this.$emit(eventData, meta);
+            }
+          });
+        }
+      });
+    }
+  },
+};

components/facebook_pages/sources/new-comment/new-comment.mjs

@@ -0,0 +1,57 @@
+import common from "../common/webhook.mjs";
+
+export default {
+  ...common,
+  key: "facebook_pages-new-comment",
+  name: "New Comment on Post",
+  description: "Emit new event when a new comment is added to a post on your Facebook Page.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getFields() {
+      return [
+        "feed",
+      ];
+    },
+    generateMeta(data) {
+      const {
+        comment_id, parent_id, created_time, from, message,
+      } = data;
+      const ts = created_time
+        ? created_time * 1000
+        : Date.now();
+      const id = comment_id || `comment-${parent_id}-${ts}`;
+
+      let summary = "New comment";
+      if (from?.name) {
+        summary = `New comment by ${from.name}`;
+      }
+      if (message) {
+        const preview = message.substring(0, 50);
+        summary += `: ${preview}${message.length > 50
+          ? "..."
+          : ""}`;
+      }
+
+      return {
+        id,
+        summary,
+        ts,
+      };
+    },
+    processEvent(change) {
+      if (change.field === "feed" && change.value) {
+        const {
+          item, verb,
+        } = change.value;
+        // Only emit events for new comments
+        if (item === "comment" && verb === "add") {
+          return change.value;
+        }
+      }
+      return null;
+    },
+  },
+};