[TRIGGER] LinkedIn Page / Profile Post

jcortes · jcortes · commit b4922b94b5f1 · 2025-03-03T17:32:54.000-05:00
diff --git a/components/linkedin/actions/create-comment/create-comment.mjs b/components/linkedin/actions/create-comment/create-comment.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-create-comment",
   name: "Create Comment",
   description: "Create a comment on a share or user generated content post. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/network-update-social-actions#create-comment)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/create-image-post-organization/create-image-post-organization.mjs b/components/linkedin/actions/create-image-post-organization/create-image-post-organization.mjs
@@ -6,7 +6,7 @@ export default {
   key: "linkedin-create-image-post-organization",
   name: "Create Image Post (Organization)",
   description: "Create an image post on LinkedIn. [See the docs here](https://learn.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/images-api?view=li-lms-2023-09&tabs=http#uploading-an-image)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/create-image-post-user/create-image-post-user.mjs b/components/linkedin/actions/create-image-post-user/create-image-post-user.mjs
@@ -6,7 +6,7 @@ export default {
   key: "linkedin-create-image-post-user",
   name: "Create Image Post (User)",
   description: "Create an image post on LinkedIn. [See the docs here](https://learn.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/images-api?view=li-lms-2023-09&tabs=http#uploading-an-image)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/create-like-on-share/create-like-on-share.mjs b/components/linkedin/actions/create-like-on-share/create-like-on-share.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-create-like-on-share",
   name: "Create Like On Share",
   description: "Creates a like on a share. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/network-update-social-actions#create-a-like-on-a-share)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/create-text-post-organization/create-text-post-organization.mjs b/components/linkedin/actions/create-text-post-organization/create-text-post-organization.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-create-text-post-organization",
   name: "Create a Simple Post (Organization)",
   description: "Create post on LinkedIn using text, URL or article. [See the docs](https://learn.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/posts-api?view=li-lms-2022-11&tabs=http#create-organic-posts) for more information",
-  version: "0.0.5",
+  version: "0.0.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/create-text-post-user/create-text-post-user.mjs b/components/linkedin/actions/create-text-post-user/create-text-post-user.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-create-text-post-user",
   name: "Create a Simple Post (User)",
   description: "Create post on LinkedIn using text, URL or article. [See the docs](https://learn.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/posts-api?view=li-lms-2022-11&tabs=http#create-organic-posts) for more information",
-  version: "0.0.5",
+  version: "0.0.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/delete-post/delete-post.mjs b/components/linkedin/actions/delete-post/delete-post.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-delete-post",
   name: "Delete Post",
   description: "Removes a post from user's wall. [See the docs](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/share-api?tabs=http#delete-shares) for more information",
-  version: "0.0.5",
+  version: "0.0.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/fetch-ad-account/fetch-ad-account.mjs b/components/linkedin/actions/fetch-ad-account/fetch-ad-account.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-fetch-ad-account",
   name: "Fetch Ad Account",
   description: "Fetches an individual adAccount given its id. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/ads/account-structure/create-and-manage-accounts#fetch-ad-account)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-current-member-profile/get-current-member-profile.mjs b/components/linkedin/actions/get-current-member-profile/get-current-member-profile.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-current-member-profile",
   name: "Get Current Member Profile",
   description: "Gets the profile of the current authenticated member. [See the docs here](https://docs.microsoft.com/en-us/linkedin/shared/integrations/people/profile-api#retrieve-current-members-profile)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-member-organization-access-control/get-member-organization-access-control.mjs b/components/linkedin/actions/get-member-organization-access-control/get-member-organization-access-control.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-member-organization-access-control",
   name: "Get Member's Organization Access Control Information",
   description: "Gets the organization access control information of the current authenticated member. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/organizations/organization-access-control?context=linkedin/compliance/context#find-a-members-organization-access-control-information)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-member-profile/get-member-profile.mjs b/components/linkedin/actions/get-member-profile/get-member-profile.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-member-profile",
   name: "Get Member Profile",
   description: "Gets another member's profile, given its person id. [See the docs here](https://docs.microsoft.com/en-us/linkedin/shared/integrations/people/profile-api#retrieve-other-members-profile)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-multiple-member-profiles/get-multiple-member-profiles.mjs b/components/linkedin/actions/get-multiple-member-profiles/get-multiple-member-profiles.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-multiple-member-profiles",
   name: "Get Multiple Member Profiles",
   description: "Gets multiple member profiles at once. [See the docs here](https://docs.microsoft.com/en-us/linkedin/shared/integrations/people/profile-api#retrieve-other-members-profile)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-organization-access-control/get-organization-access-control.mjs b/components/linkedin/actions/get-organization-access-control/get-organization-access-control.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-organization-access-control",
   name: "Gets Organization Access Control",
   description: "Gets an organization's access control information, given the organization urn. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/organizations/organization-access-control?context=linkedin/compliance/context#find-access-control-information)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/get-organization-administrators/get-organization-administrators.mjs b/components/linkedin/actions/get-organization-administrators/get-organization-administrators.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-get-organization-administrators",
   name: "Get Organization Administrators",
   description: "Gets the administator members of an organization, given the organization urn. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/organizations/organization-access-control?context=linkedin/compliance/context#find-organization-administrators)",
-  version: "0.2.5",
+  version: "0.2.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/retrieve-comments-on-comments/retrieve-comments-on-comments.mjs b/components/linkedin/actions/retrieve-comments-on-comments/retrieve-comments-on-comments.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-retrieve-comments-on-comments",
   name: "Retrieves Comments on Comments",
   description: "Retrieves comments on comments, given the parent comment urn. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/network-update-social-actions#retrieve-comments-on-comments)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/retrieve-comments-shares/retrieve-comments-shares.mjs b/components/linkedin/actions/retrieve-comments-shares/retrieve-comments-shares.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-retrieve-comments-shares",
   name: "Retrieve Comments On Shares",
   description: "Retrieve comments on shares given the share urn. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/shares/network-update-social-actions#retrieve-comments-on-shares)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/actions/search-organization/search-organization.mjs b/components/linkedin/actions/search-organization/search-organization.mjs
@@ -4,7 +4,7 @@ export default {
   key: "linkedin-search-organization",
   name: "Search Organization",
   description: "Searches for an organization by vanity name or email domain. [See the docs here](https://docs.microsoft.com/en-us/linkedin/marketing/integrations/community-management/organizations/organization-lookup-api)",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "action",
   props: {
     linkedin,
diff --git a/components/linkedin/common/constants.mjs b/components/linkedin/common/constants.mjs
@@ -75,6 +75,11 @@ const ROLE_STATES = [
   "REVOKED",
 ];
 
+const DEFAULT_LIMIT = 20;
+const DEFAULT_MAX = 100;
+const IS_FIRST_RUN = "isFirstRun";
+const LAST_DATE_AT = "lastDateAt";
+
 export default {
   VERSION_PATH,
   BASE_URL,
@@ -85,4 +90,8 @@ export default {
   PIVOT_OPTIONS,
   ORGANIZATION_ROLES,
   ROLE_STATES,
+  DEFAULT_LIMIT,
+  DEFAULT_MAX,
+  IS_FIRST_RUN,
+  LAST_DATE_AT,
 };
diff --git a/components/linkedin/common/utils.mjs b/components/linkedin/common/utils.mjs
@@ -0,0 +1,38 @@
+async function iterate(iterations) {
+  const items = [];
+  for await (const item of iterations) {
+    items.push(item);
+  }
+  return items;
+}
+
+function getNestedProperty(obj, propertyString) {
+  const properties = propertyString.split(".");
+  return properties.reduce((prev, curr) => prev?.[curr], obj);
+}
+
+function defaultEncodeFn(key, value) {
+  return `${key}=${value}`;
+}
+
+function encodeFn(key, value) {
+  return `${key}=${encodeURIComponent(value)}`;
+}
+
+function getParamsSerializer(encodeFn = defaultEncodeFn) {
+  return (params) => {
+    return Object.entries(params)
+      .map(([
+        key,
+        value,
+      ]) => encodeFn(key, value))
+      .join("&");
+  };
+}
+
+export default {
+  iterate,
+  getNestedProperty,
+  encodeFn,
+  getParamsSerializer,
+};
diff --git a/components/linkedin/linkedin.app.mjs b/components/linkedin/linkedin.app.mjs
@@ -1,6 +1,7 @@
 import { axios as axiosPD } from "@pipedream/platform";
 import axios from "axios";
 import constants from "./common/constants.mjs";
+import utils from "./common/utils.mjs";
 
 export default {
   type: "app",
@@ -268,5 +269,65 @@ export default {
         ...args,
       });
     },
+    listPosts(args = {}) {
+      return this._makeRequest({
+        path: "/posts",
+        paramsSerializer: utils.getParamsSerializer(utils.encodeFn),
+        ...args,
+      });
+    },
+    async *getIterations({
+      resourcesFn, resourcesFnArgs, resourceName,
+      lastDateAt, dateField,
+      max = constants.DEFAULT_MAX,
+    }) {
+      let page = 0;
+      let resourcesCount = 0;
+
+      while (true) {
+        const response =
+          await resourcesFn({
+            ...resourcesFnArgs,
+            params: {
+              ...resourcesFnArgs?.params,
+              count: constants.DEFAULT_LIMIT,
+              start: page * constants.DEFAULT_LIMIT,
+            },
+          });
+
+        const nextResources = utils.getNestedProperty(response, resourceName);
+
+        if (!nextResources?.length) {
+          console.log("No more resources found");
+          return;
+        }
+
+        for (const resource of nextResources) {
+          const isDateGreater =
+            lastDateAt
+              && resource[dateField] > lastDateAt;
+
+          if (!lastDateAt || isDateGreater) {
+            yield resource;
+            resourcesCount += 1;
+          }
+
+          if (resourcesCount >= max) {
+            console.log("Reached max resources");
+            return;
+          }
+        }
+
+        if (nextResources.length < constants.DEFAULT_LIMIT) {
+          console.log("No next page found");
+          return;
+        }
+
+        page += 1;
+      }
+    },
+    paginate(args = {}) {
+      return utils.iterate(this.getIterations(args));
+    },
   },
 };
diff --git a/components/linkedin/package.json b/components/linkedin/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/linkedin",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "description": "Pipedream Linkedin Components",
   "main": "linkedin.app.mjs",
   "keywords": [
diff --git a/components/linkedin/sources/common/polling.mjs b/components/linkedin/sources/common/polling.mjs
diff --git a/components/linkedin/sources/new-post-created/new-post-created.mjs b/components/linkedin/sources/new-post-created/new-post-created.mjs
diff --git a/components/linkedin/sources/new-post-created/test-event.mjs b/components/linkedin/sources/new-post-created/test-event.mjs
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
