Feature/remove labels (#20447)

Name-18 · michelle0927 · web-flow · commit 83582e8bd4e1 · 2026-05-11T17:10:31.000-04:00
* feat(pipedrive): add remove-labels action

* fix: use plain Error for API failures, remove unused import

* fix: re-add ConfigurationError import

* fix: consistent return shape and loop in additionalProps

* fix: extract ENTITY_TYPES constant and safe error stringify

* fix: ENTITY_TYPES constant, safe stringify, trailing newline

* fix: validate entity ID, fetch inside try/catch, document last-write-wins

* fix: safe getItem fallback, entity ID validation, trailing newline

* refactor: use entityId and entityLabelIds props from app file

* fix(pipedrive): bump package version

* fix: update pnpm lockfile after rebase

* fix: bump component versions

* fix: bump component versions 2

---------

Co-authored-by: michelle0927 &lt;michelle0927@users.noreply.github.com&gt;
diff --git a/components/pipedrive/actions/add-activity/add-activity.mjs b/components/pipedrive/actions/add-activity/add-activity.mjs
@@ -7,7 +7,7 @@ export default {
   key: "pipedrive-add-activity",
   name: "Add Activity",
   description: "Adds a new activity. Includes `more_activities_scheduled_in_context` property in response's `additional_data` which indicates whether there are more undone activities scheduled with the same deal, person or organization (depending on the supplied data). See the Pipedrive API docs for Activities [here](https://developers.pipedrive.com/docs/api/v1/#!/Activities). For info on [adding an activity in Pipedrive](https://developers.pipedrive.com/docs/api/v1/Activities#addActivity)",
-  version: "0.1.23",
+  version: "0.1.24",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-deal/add-deal.mjs b/components/pipedrive/actions/add-deal/add-deal.mjs
@@ -6,7 +6,7 @@ export default {
   key: "pipedrive-add-deal",
   name: "Add Deal",
   description: "Adds a new deal. See the Pipedrive API docs for Deals [here](https://developers.pipedrive.com/docs/api/v1/Deals#addDeal)",
-  version: "0.1.24",
+  version: "0.1.25",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-labels/add-labels.mjs b/components/pipedrive/actions/add-labels/add-labels.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-add-labels",
   name: "Add Labels",
   description: "Adds labels to a lead, person, deal, or organization in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#updateLead)",
-  version: "0.0.3",
+  version: "0.0.4",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-lead/add-lead.mjs b/components/pipedrive/actions/add-lead/add-lead.mjs
@@ -6,7 +6,7 @@ export default {
   key: "pipedrive-add-lead",
   name: "Add Lead",
   description: "Create a new lead in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#addLead)",
-  version: "0.0.17",
+  version: "0.0.18",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-note/add-note.mjs b/components/pipedrive/actions/add-note/add-note.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-add-note",
   name: "Add Note",
   description: "Adds a new note. For info on [adding an note in Pipedrive](https://developers.pipedrive.com/docs/api/v1/Notes#addNote)",
-  version: "0.0.18",
+  version: "0.0.19",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-organization/add-organization.mjs b/components/pipedrive/actions/add-organization/add-organization.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-add-organization",
   name: "Add Organization",
   description: "Adds a new organization. See the Pipedrive API docs for Organizations [here](https://developers.pipedrive.com/docs/api/v1/Organizations#addOrganization)",
-  version: "0.1.20",
+  version: "0.1.21",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/add-person/add-person.mjs b/components/pipedrive/actions/add-person/add-person.mjs
@@ -6,7 +6,7 @@ export default {
   key: "pipedrive-add-person",
   name: "Add Person",
   description: "Adds a new person. See the Pipedrive API docs for People [here](https://developers.pipedrive.com/docs/api/v1/Persons#addPerson)",
-  version: "0.1.23",
+  version: "0.1.24",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/get-all-leads/get-all-leads.mjs b/components/pipedrive/actions/get-all-leads/get-all-leads.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-get-all-leads",
   name: "Get All Leads",
   description: "Get all leads from Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#getLeads)",
-  version: "0.0.3",
+  version: "0.0.4",
   type: "action",
   annotations: {
     destructiveHint: false,
diff --git a/components/pipedrive/actions/get-deal/get-deal.mjs b/components/pipedrive/actions/get-deal/get-deal.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-get-deal",
   name: "Get Deal",
   description: "Get a deal by its ID. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Deals)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   annotations: {
     destructiveHint: false,
diff --git a/components/pipedrive/actions/get-lead-by-id/get-lead-by-id.mjs b/components/pipedrive/actions/get-lead-by-id/get-lead-by-id.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-get-lead-by-id",
   name: "Get Lead by ID",
   description: "Get a lead by its ID. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#getLead)",
-  version: "0.0.8",
+  version: "0.0.9",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/get-person-details/get-person-details.mjs b/components/pipedrive/actions/get-person-details/get-person-details.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-get-person-details",
   name: "Get person details",
   description: "Get details of a person by their ID. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Persons#getPerson)",
-  version: "0.0.9",
+  version: "0.0.10",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/list-deals/list-deals.mjs b/components/pipedrive/actions/list-deals/list-deals.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-list-deals",
   name: "List Deals",
   description: "List deals in your Pipedrive account. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Deals#listDeals)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   annotations: {
     destructiveHint: false,
diff --git a/components/pipedrive/actions/merge-deals/merge-deals.mjs b/components/pipedrive/actions/merge-deals/merge-deals.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-merge-deals",
   name: "Merge Deals",
   description: "Merge two deals in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Deals#mergeDeals)",
-  version: "0.0.8",
+  version: "0.0.9",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/merge-persons/merge-persons.mjs b/components/pipedrive/actions/merge-persons/merge-persons.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-merge-persons",
   name: "Merge Persons",
   description: "Merge two persons in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Persons#mergePersons)",
-  version: "0.0.8",
+  version: "0.0.9",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/remove-duplicate-notes/remove-duplicate-notes.mjs b/components/pipedrive/actions/remove-duplicate-notes/remove-duplicate-notes.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-remove-duplicate-notes",
   name: "Remove Duplicate Notes",
   description: "Remove duplicate notes from an object in Pipedrive. See the documentation for [getting notes](https://developers.pipedrive.com/docs/api/v1/Notes#getNotes) and [deleting notes](https://developers.pipedrive.com/docs/api/v1/Notes#deleteNote)",
-  version: "0.0.11",
+  version: "0.0.12",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/remove-labels/remove-labels.mjs b/components/pipedrive/actions/remove-labels/remove-labels.mjs
@@ -0,0 +1,115 @@
+import { ConfigurationError } from "@pipedream/platform";
+import pipedriveApp from "../../pipedrive.app.mjs";
+
+const ENTITY_TYPES = [
+  "lead",
+  "person",
+  "deal",
+  "organization",
+];
+
+export default {
+  key: "pipedrive-remove-labels",
+  name: "Remove Labels",
+  description: "Removes one or more specific labels from a lead, person, deal, or organization in Pipedrive, leaving all other labels intact. [See the documentation](https://developers.pipedrive.com/docs/api/v1)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    destructiveHint: true,
+    openWorldHint: true,
+    readOnlyHint: false,
+  },
+  props: {
+    pipedriveApp,
+    type: {
+      type: "string",
+      label: "Entity Type",
+      description: "The type of the item to remove labels from",
+      options: ENTITY_TYPES,
+      reloadProps: true,
+    },
+    entityId: {
+      propDefinition: [
+        pipedriveApp,
+        "entityId",
+        ({ type }) => ({
+          type,
+        }),
+      ],
+    },
+    labelIds: {
+      propDefinition: [
+        pipedriveApp,
+        "removeLabelIds",
+        ({ type }) => ({
+          type,
+        }),
+      ],
+    },
+  },
+  methods: {
+    capitalizedType(type) {
+      return type.charAt(0).toUpperCase() + type.slice(1);
+    },
+    async getItem(type, id) {
+      const capitalizedType = this.capitalizedType(type);
+      const response = await this.pipedriveApp[`get${capitalizedType}`](id);
+      return response?.data ?? response;
+    },
+  },
+  async run({ $ }) {
+    const {
+      type, entityId, labelIds,
+    } = this;
+
+    if (!entityId) {
+      throw new ConfigurationError(`Please provide a valid ${type} ID.`);
+    }
+
+    if (!labelIds?.length) {
+      throw new ConfigurationError("Please select at least one label to remove.");
+    }
+
+    let updatedItem;
+    try {
+      const item = await this.getItem(type, entityId);
+      const currentLabelIds = item?.label_ids ?? [];
+
+      const removeSet = new Set(labelIds.map(String));
+      const updatedLabelIds = currentLabelIds.filter(
+        (id) => !removeSet.has(String(id)),
+      );
+
+      const removedCount = currentLabelIds.length - updatedLabelIds.length;
+      if (removedCount === 0) {
+        $.export("$summary", "No matching labels found on the item — nothing was changed.");
+        return item;
+      }
+
+      const response = await this.pipedriveApp[`update${this.capitalizedType(type)}`]({
+        [`${type}Id`]: entityId,
+        label_ids: updatedLabelIds,
+      });
+      updatedItem = response?.data ?? response;
+
+      $.export(
+        "$summary",
+        `Successfully removed ${removedCount} label(s) from the ${type}. ${updatedLabelIds.length} label(s) remain.`,
+      );
+    } catch (error) {
+      if (error instanceof ConfigurationError) {
+        throw error;
+      }
+      let serialized;
+      try {
+        serialized = JSON.stringify(error, null, 2);
+      } catch {
+        serialized = String(error);
+      }
+      const message = error?.message ?? serialized;
+      throw new Error(`Failed to update ${type} labels: ${message}`);
+    }
+
+    return updatedItem;
+  },
+};
diff --git a/components/pipedrive/actions/search-leads/search-leads.mjs b/components/pipedrive/actions/search-leads/search-leads.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-search-leads",
   name: "Search Leads",
   description: "Search for leads by name or email. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#searchLeads)",
-  version: "0.0.8",
+  version: "0.0.9",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/search-notes/search-notes.mjs b/components/pipedrive/actions/search-notes/search-notes.mjs
@@ -4,7 +4,7 @@ export default {
   key: "pipedrive-search-notes",
   name: "Search Notes",
   description: "Search for notes in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Notes#getNotes)",
-  version: "0.0.11",
+  version: "0.0.12",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/search-persons/search-persons.mjs b/components/pipedrive/actions/search-persons/search-persons.mjs
@@ -8,7 +8,7 @@ export default {
   key: "pipedrive-search-persons",
   name: "Search persons",
   description: "Searches all Persons by `name`, `email`, `phone`, `notes` and/or custom fields. This endpoint is a wrapper of `/v1/itemSearch` with a narrower OAuth scope. Found Persons can be filtered by Organization ID. See the Pipedrive API docs [here](https://developers.pipedrive.com/docs/api/v1/Persons#searchPersons)",
-  version: "0.1.23",
+  version: "0.1.24",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/update-deal/update-deal.mjs b/components/pipedrive/actions/update-deal/update-deal.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-update-deal",
   name: "Update Deal",
   description: "Updates the properties of a deal. See the Pipedrive API docs for Deals [here](https://developers.pipedrive.com/docs/api/v1/Deals#updateDeal)",
-  version: "0.1.22",
+  version: "0.1.23",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/update-lead/update-lead.mjs b/components/pipedrive/actions/update-lead/update-lead.mjs
@@ -5,7 +5,7 @@ export default {
   key: "pipedrive-update-lead",
   name: "Update Lead",
   description: "Updates a lead in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Leads#updateLead)",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/pipedrive/actions/update-person/update-person.mjs b/components/pipedrive/actions/update-person/update-person.mjs
@@ -6,7 +6,7 @@ export default {
   key: "pipedrive-update-person",
   name: "Update Person",
   description: "Updates an existing person in Pipedrive. [See the documentation](https://developers.pipedrive.com/docs/api/v1/Persons#updatePerson)",
-  version: "0.0.15",
+  version: "0.0.16",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/pipedrive/package.json b/components/pipedrive/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/pipedrive",
-  "version": "0.12.2",
+  "version": "0.13.0",
   "description": "Pipedream Pipedrive Components",
   "main": "pipedrive.app.mjs",
   "keywords": [
diff --git a/components/pipedrive/pipedrive.app.mjs b/components/pipedrive/pipedrive.app.mjs
diff --git a/components/pipedrive/sources/new-deal-instant/new-deal-instant.mjs b/components/pipedrive/sources/new-deal-instant/new-deal-instant.mjs
diff --git a/components/pipedrive/sources/new-event-instant/new-event-instant.mjs b/components/pipedrive/sources/new-event-instant/new-event-instant.mjs
diff --git a/components/pipedrive/sources/new-person-instant/new-person-instant.mjs b/components/pipedrive/sources/new-person-instant/new-person-instant.mjs
diff --git a/components/pipedrive/sources/updated-deal-instant/updated-deal-instant.mjs b/components/pipedrive/sources/updated-deal-instant/updated-deal-instant.mjs
diff --git a/components/pipedrive/sources/updated-lead-instant/updated-lead-instant.mjs b/components/pipedrive/sources/updated-lead-instant/updated-lead-instant.mjs
diff --git a/components/pipedrive/sources/updated-person-instant/updated-person-instant.mjs b/components/pipedrive/sources/updated-person-instant/updated-person-instant.mjs
