Confluence adjustments

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

@@ -4,7 +4,7 @@
   key: "confluence-create-page",
   name: "Create Page",
   description: "Creates a new page in the space. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-pages-post)",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
@@ -13,7 +13,7 @@
   type: "action",
   props: {
     confluence,
     draftInfo: {
       type: "alert",
       alertType: "info",
       content: "Pages are created as published by default, unless specified as a draft in the `Status` prop.",

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.6",
+  version: "0.0.7",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

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.6",
+  version: "0.0.7",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,

components/confluence/actions/get-page-by-id/get-page-by-id.mjs

@@ -1,10 +1,12 @@
 import confluence from "../../confluence.app.mjs";
+import { parseObjectEntries } from "../../common/utils.mjs";
+import { BODY_FORMAT_FULL_OPTIONS } from "../../common/constants.mjs";
 
 export default {
   key: "confluence-get-page-by-id",
   name: "Get Page by ID",
   description: "Retrieve a page by its ID. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-pages-id-get)",
-  version: "0.0.2",
+  version: "0.1.0",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
@@ -19,6 +21,47 @@ export default {
         "pageId",
       ],
     },
+    bodyFormat: {
+      propDefinition: [
+        confluence,
+        "bodyFormat",
+      ],
+      options: BODY_FORMAT_FULL_OPTIONS,
+    },
+    getDraft: {
+      type: "boolean",
+      label: "Get Draft",
+      description: "If true, retrieves the draft version of this page.",
+      optional: true,
+      default: false,
+    },
+    status: {
+      type: "string[]",
+      label: "Status",
+      description: "Filter the page being retrieved by its status.",
+      optional: true,
+      options: [
+        "current",
+        "archived",
+        "trashed",
+        "deleted",
+        "historical",
+        "draft",
+      ],
+    },
+    version: {
+      type: "integer",
+      label: "Version",
+      description: "Allows you to retrieve a previously published version. Specify the previous version's number to retrieve its details.",
+      optional: true,
+    },
+    additionalOptions: {
+      type: "object",
+      label: "Additional Options",
+      description:
+        "Additional parameters to send in the request. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-pages-id-get) for available parameters. Values will be parsed as JSON where applicable.",
+      optional: true,
+    },
   },
   async run({ $ }) {
     const cloudId = await this.confluence.getCloudId({
@@ -28,6 +71,13 @@ export default {
       $,
       cloudId,
       pageId: this.pageId,
+      params: {
+        "body-format": this.bodyFormat,
+        "get-draft": this.getDraft,
+        "status": this.status,
+        "version": this.version,
+        ...parseObjectEntries(this.additionalOptions),
+      },
     });
     $.export("$summary", `Successfully retrieved page with ID: ${this.pageId}`);
     return response;

components/confluence/actions/get-pages-in-space/get-pages-in-space.mjs

@@ -4,7 +4,7 @@ export default {
   key: "confluence-get-pages-in-space",
   name: "Get Pages in Space",
   description: "Retrieve a list of pages in a space. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-spaces-id-pages-get)",
-  version: "0.0.2",
+  version: "0.0.3",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
@@ -43,12 +43,6 @@ export default {
         "bodyFormat",
       ],
     },
-    subType: {
-      propDefinition: [
-        confluence,
-        "subType",
-      ],
-    },
     cursor: {
       propDefinition: [
         confluence,
@@ -71,13 +65,12 @@ export default {
       cloudId,
       spaceId: this.spaceId,
       params: {
-        sort: this.sort,
-        status: this.status,
-        title: this.pageTitle,
-        bodyFormat: this.bodyFormat,
-        subType: this.subType,
-        cursor: this.cursor,
-        limit: this.limit,
+        "sort": this.sort,
+        "status": this.status,
+        "title": this.pageTitle,
+        "body-format": this.bodyFormat,
+        "cursor": this.cursor,
+        "limit": this.limit,
       },
     });
     $.export("$summary", `Successfully retrieved ${response.results.length} page${response.results.length === 1

components/confluence/actions/get-pages/get-pages.mjs

@@ -4,7 +4,7 @@ export default {
   key: "confluence-get-pages",
   name: "Get Pages",
   description: "Retrieve a list of pages. [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-pages-get)",
-  version: "0.0.2",
+  version: "0.0.3",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
@@ -64,13 +64,13 @@ export default {
       $,
       cloudId,
       params: {
-        sort: this.sort,
-        status: this.status,
-        title: this.pageTitle,
-        bodyFormat: this.bodyFormat,
-        subType: this.subType,
-        cursor: this.cursor,
-        limit: this.limit,
+        "sort": this.sort,
+        "status": this.status,
+        "title": this.pageTitle,
+        "body-format": this.bodyFormat,
+        "subtype": this.subType,
+        "cursor": this.cursor,
+        "limit": this.limit,
       },
     });
     $.export("$summary", `Successfully retrieved ${response.results.length} page${response.results.length === 1

components/confluence/actions/search-content/search-content.mjs

@@ -4,7 +4,7 @@ export default {
   key: "confluence-search-content",
   name: "Search Content",
   description: "Searches for content using the Confluence Query Language (CQL). [See the documentation](https://developer.atlassian.com/cloud/confluence/rest/v1/api-group-search#api-wiki-rest-api-search-get)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

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.6",
+  version: "0.0.7",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,

components/confluence/common/constants.mjs

@@ -0,0 +1,13 @@
+export const BODY_FORMAT_OPTIONS = [
+  "storage",
+  "atlas_doc_format",
+];
+
+export const BODY_FORMAT_FULL_OPTIONS = [
+  ...BODY_FORMAT_OPTIONS,
+  "view",
+  "export_view",
+  "anonymous_export_view",
+  "styled_view",
+  "editor",
+];

components/confluence/common/utils.mjs

@@ -0,0 +1,33 @@
+import { ConfigurationError } from "@pipedream/platform";
+
+function optionalParseAsJSON(value) {
+  if (typeof value !== "string") {
+    return value;
+  }
+
+  try {
+    return JSON.parse(value);
+  } catch (e) {
+    return value;
+  }
+}
+
+export function parseObjectEntries(obj = {}) {
+  if (typeof obj === "string") {
+    try {
+      obj = JSON.parse(obj);
+    } catch (e) {
+      throw new ConfigurationError(`Invalid JSON string provided: ${e.message}`);
+    }
+  }
+
+  return Object.fromEntries(
+    Object.entries(obj || {}).map(([
+      key,
+      value,
+    ]) => [
+      key,
+      optionalParseAsJSON(value),
+    ]),
+  );
+}

components/confluence/confluence.app.mjs

@@ -1,4 +1,5 @@
 import { axios } from "@pipedream/platform";
+import { BODY_FORMAT_OPTIONS } from "./common/constants.mjs";
 
 export default {
   type: "app",
@@ -192,10 +193,7 @@ export default {
       type: "string",
       label: "Body Format",
       description: "The content format types to be returned in the body field of the response. If available, the representation will be available under a response field of the same name under the body field.",
-      options: [
-        "storage",
-        "atlas_doc_format",
-      ],
+      options: BODY_FORMAT_OPTIONS,
       optional: true,
     },
     subType: {

components/confluence/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/confluence",
-  "version": "0.3.0",
+  "version": "0.4.0",
   "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.5",
+  version: "0.0.6",
   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.5",
+  version: "0.0.6",
   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.5",
+  version: "0.0.6",
   type: "source",
   dedupe: "unique",
   methods: {