AutomationFlowsCRM & Sales › Pipedrive to Stripe Product Sync

Pipedrive to Stripe Product Sync

Original n8n title: Functionitem Http

Functionitem Http. Uses pipedriveTrigger, functionItem, httpRequest, itemLists. Event-driven trigger; 7 nodes.

Event trigger★★★★☆ complexity7 nodesPipedrive TriggerFunction ItemHTTP RequestItem Lists
CRM & Sales Trigger: Event Nodes: 7 Complexity: ★★★★☆ Added:

This workflow follows the HTTP Request → Itemlists recipe pattern — see all workflows that pair these two integrations.

The workflow JSON

Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →

Download .json
{
  "nodes": [
    {
      "id": "e95fc182-b13e-4eab-852b-66ea821c4129",
      "name": "On product created",
      "type": "n8n-nodes-base.pipedriveTrigger",
      "position": [
        440,
        500
      ],
      "parameters": {
        "action": "added",
        "object": "product"
      },
      "credentials": {
        "pipedriveApi": {
          "name": "<your credential>"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "a64af9df-3084-4376-ace9-50f0f21bbf35",
      "name": "Set item to only current product data",
      "type": "n8n-nodes-base.functionItem",
      "position": [
        680,
        500
      ],
      "parameters": {
        "functionCode": "// Code here will run once per input item.\n// More info and help: https://docs.n8n.io/nodes/n8n-nodes-base.functionItem\n// Tip: You can use luxon for dates and $jmespath for querying JSON structures\n\n// Add a new field called 'myNewField' to the JSON of the item\nitem = item.current;\n\n// You can write logs to the browser console\nconsole.log('Done!');\n\nreturn item;"
      },
      "typeVersion": 1
    },
    {
      "id": "79b265a9-4021-4a1a-9b4a-4f3aeace9fe5",
      "name": "Create product in Stripe",
      "type": "n8n-nodes-base.httpRequest",
      "position": [
        900,
        660
      ],
      "parameters": {
        "url": "https://api.stripe.com/v1/products",
        "options": {},
        "requestMethod": "POST",
        "authentication": "predefinedCredentialType",
        "queryParametersUi": {
          "parameter": [
            {
              "name": "name",
              "value": "={{ $json[\"name\"] }}"
            },
            {
              "name": "description",
              "value": "={{ $json[\"description\"] || ' '}}"
            }
          ]
        },
        "nodeCredentialType": "stripeApi"
      },
      "credentials": {
        "stripeApi": {
          "name": "<your credential>"
        }
      },
      "typeVersion": 2
    },
    {
      "id": "69e40a2b-1680-42f9-add9-cbef9bc0f63f",
      "name": "Add created product Id to data",
      "type": "n8n-nodes-base.merge",
      "position": [
        1320,
        520
      ],
      "parameters": {
        "mode": "mergeByIndex"
      },
      "typeVersion": 1
    },
    {
      "id": "bc7428ba-829f-4a9b-af61-ea11c102d1d3",
      "name": "Keep only productId of created product",
      "type": "n8n-nodes-base.set",
      "position": [
        1100,
        660
      ],
      "parameters": {
        "values": {
          "string": [
            {
              "name": "StripeCreatedProductId",
              "value": "={{ $json[\"id\"] }}"
            }
          ]
        },
        "options": {},
        "keepOnlySet": true
      },
      "typeVersion": 1
    },
    {
      "id": "8571acfb-8ee9-410d-a5ca-9b173d034202",
      "name": "Create price records in Stripe",
      "type": "n8n-nodes-base.httpRequest",
      "position": [
        1760,
        520
      ],
      "parameters": {
        "url": "https://api.stripe.com/v1/prices",
        "options": {},
        "requestMethod": "POST",
        "authentication": "predefinedCredentialType",
        "queryParametersUi": {
          "parameter": [
            {
              "name": "currency",
              "value": "={{ $json[\"prices\"].currency }}"
            },
            {
              "name": "unit_amount",
              "value": "={{ $json[\"prices\"].price * 100 }}"
            },
            {
              "name": "product",
              "value": "={{ $json[\"StripeCreatedProductId\"] }}"
            }
          ]
        },
        "nodeCredentialType": "stripeApi"
      },
      "credentials": {
        "stripeApi": {
          "name": "<your credential>"
        }
      },
      "typeVersion": 2
    },
    {
      "id": "f849ae73-aa7d-49b2-81a9-7470278d30a3",
      "name": "Split prices to seperate items",
      "type": "n8n-nodes-base.itemLists",
      "position": [
        1540,
        520
      ],
      "parameters": {
        "include": "selectedOtherFields",
        "options": {},
        "fieldToSplitOut": "prices",
        "fieldsToInclude": {
          "fields": [
            {
              "fieldName": "StripeCreatedProductId"
            }
          ]
        }
      },
      "typeVersion": 1
    }
  ],
  "connections": {
    "On product created": {
      "main": [
        [
          {
            "node": "Set item to only current product data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Create product in Stripe": {
      "main": [
        [
          {
            "node": "Keep only productId of created product",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Add created product Id to data": {
      "main": [
        [
          {
            "node": "Split prices to seperate items",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Split prices to seperate items": {
      "main": [
        [
          {
            "node": "Create price records in Stripe",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Set item to only current product data": {
      "main": [
        [
          {
            "node": "Create product in Stripe",
            "type": "main",
            "index": 0
          },
          {
            "node": "Add created product Id to data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Keep only productId of created product": {
      "main": [
        [
          {
            "node": "Add created product Id to data",
            "type": "main",
            "index": 1
          }
        ]
      ]
    }
  }
}

Credentials you'll need

Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.

Pro

For the full experience including quality scoring and batch install features for each workflow upgrade to Pro

About this workflow

Functionitem Http. Uses pipedriveTrigger, functionItem, httpRequest, itemLists. Event-driven trigger; 7 nodes.

Source: https://github.com/Zie619/n8n-workflows — original creator credit. Request a take-down →

More CRM & Sales workflows → · Browse all categories →

Related workflows

Workflows that share integrations, category, or trigger type with this one. All free to copy and import.

CRM & Sales

Pipedrive Stickynote. Uses itemLists, pipedrive, httpRequest, pipedriveTrigger. Event-driven trigger; 11 nodes.

Item Lists, Pipedrive, HTTP Request +1
CRM & Sales

Functionitem Zendesk. Uses noOp, functionItem, httpRequest, zendesk. Scheduled trigger; 21 nodes.

Function Item, HTTP Request, Zendesk +2
CRM & Sales

This workflow is built for digital agencies and sales teams that sell services to ecommerce brands. If you prospect Shopify store owners and want a repeatable, automated pipeline from discovery to CRM

HTTP Request, HubSpot
CRM & Sales

Functionitem Zendesk. Uses functionItem, zendesk, pipedrive, httpRequest. Scheduled trigger; 17 nodes.

Function Item, Zendesk, Pipedrive +1
CRM & Sales

Property Lead Contact Enrichment from CRM. Uses httpRequest, spreadsheetFile, hubspot, emailSend. Event-driven trigger; 16 nodes.

HTTP Request, Spreadsheet File, HubSpot +1