Fix Confluence cursor handling for pagination

components/confluence/actions/create-post/create-post.mjs

@@ -4,7 +4,7 @@ export default {
   key: "confluence-create-post",
   name: "Create Post",
   description: "Creates a new page or blog post on Confluence. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-blog-post/#api-blogposts-post)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     confluence,

components/confluence/actions/delete-post/delete-post.mjs

@@ -4,7 +4,7 @@ export default {
   key: "confluence-delete-post",
   name: "Delete Post",
   description: "Removes a blog post from Confluence by its ID. Use with caution, the action is irreversible. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-blog-post/#api-blogposts-id-delete)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     confluence,

components/confluence/actions/update-post/update-post.mjs

@@ -5,7 +5,7 @@ export default {
   key: "confluence-update-post",
   name: "Update a Post",
   description: "Updates a page or blog post on Confluence by its ID. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-blog-post/#api-blogposts-id-put)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     confluence,

components/confluence/confluence.app.mjs

@@ -30,7 +30,7 @@ export default {
         return {
           options,
           context: {
-            cursor: links?.next,
+            cursor: this._extractCursorFromLink(links?.next),
           },
         };
       },
@@ -61,7 +61,7 @@ export default {
         return {
           options,
           context: {
-            cursor: links?.next,
+            cursor: this._extractCursorFromLink(links?.next),
           },
         };
       },
@@ -106,6 +106,16 @@ export default {
         ...otherOpts,
       });
     },
+    _extractCursorFromLink(link) {
+      if (!link) return null;
+      try {
+        const url = new URL(link);
+        return url.searchParams.get("cursor");
+      } catch (e) {
+        console.log("Error extracting cursor from link:", e);
+        return null;
+      }
+    },
     async getCloudId(opts = {}) {
       const response = await this._makeRequest({
         url: "https://api.atlassian.com/oauth/token/accessible-resources",
@@ -203,8 +213,9 @@ export default {
             return;
           }
         }
-        hasMore = links?.next;
-        args.params.cursor = hasMore;
+        const cursor = this._extractCursorFromLink(links?.next);
+        hasMore = cursor;
+        args.params.cursor = cursor;
       } while (hasMore);
     },
   },

components/confluence/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/confluence",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Pipedream Confluence Components",
   "main": "confluence.app.mjs",
   "keywords": [

components/confluence/sources/new-page-or-blog-post/new-page-or-blog-post.mjs

@@ -6,7 +6,7 @@ export default {
   key: "confluence-new-page-or-blog-post",
   name: "New Page or Blog Post",
   description: "Emit new event whenever a new page or blog post is created in a specified space",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   props: {

components/confluence/sources/watch-blog-posts/watch-blog-posts.mjs

@@ -4,9 +4,9 @@
 export default {
   ...common,
   key: "confluence-watch-blog-posts",
   name: "Watch Blog Posts",
   description: "Emit new event when a blog post is created or updated",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {

components/confluence/sources/watch-pages/watch-pages.mjs

@@ -4,9 +4,9 @@
 export default {
   ...common,
   key: "confluence-watch-pages",
   name: "Watch Pages",
   description: "Emit new event when a page is created or updated in Confluence",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {