How to Automate HubSpot Lifecycle Stages from Shopify with Pipedream

pipedream.com > Workflows > + New Workflow

Create a new Pipedream workflow

Go to pipedream.com and log in. From the left sidebar, click 'Workflows', then click the blue '+ New Workflow' button in the top right. Give the workflow a clear name like 'Shopify → HubSpot Lifecycle Stages'. You'll land on the workflow canvas with an empty trigger slot waiting.

1. 1Click 'Workflows' in the left sidebar
2. 2Click '+ New Workflow' in the top right
3. 3Type a name: 'Shopify → HubSpot Lifecycle Stages'
4. 4Click 'Create'

Workflow Canvas > Add a trigger > Shopify > New Order (Instant)

Add the Shopify order paid webhook trigger

Click the grey 'Add a trigger' block. In the search box, type 'Shopify' and select it. From the event list, choose 'New Order (Instant)' — this fires via webhook the moment Shopify marks an order as paid. Connect your Shopify store by clicking 'Connect Shopify Account' and entering your store URL and API credentials. Pipedream will auto-register the webhook in your Shopify admin.

1. 1Click the 'Add a trigger' block
2. 2Search for 'Shopify' in the app search bar
3. 3Select 'New Order (Instant)' from the trigger list
4. 4Click 'Connect Shopify Account'
5. 5Enter your Shopify store URL (e.g., yourstore.myshopify.com) and generate a Private App API key
6. 6Click 'Save and continue'

Workflow Canvas > + Add a step > Run Node.js code

Extract and normalize order data in a Node.js code step

Click '+ Add a step' below the trigger and choose 'Run Node.js code'. This step pulls the customer email, order total, and order count from the Shopify payload. You'll also set a preliminary lifecycle stage variable here based on the order data — this keeps the logic in one place before you make any API calls. Paste the code from the Pro Tip section below into this code step.

1. 1Click '+ Add a step'
2. 2Select 'Run Node.js code'
3. 3Paste the lifecycle classification code into the editor
4. 4Click 'Test' to verify the step runs against the sample Shopify payload

Paste this into the Node.js code step (step 3) that sits immediately after the Shopify trigger. It parses the raw Shopify order payload, calculates lifecycle stage based on order count and total spend thresholds, and exports clean values for every downstream HubSpot step to reference via steps.classify_lifecycle.

// Step name: classify_lifecycle
// Pipedream Node.js code step — paste into 'Run Node.js code' after Shopify trigger
export default defineComponent({

// Step name: classify_lifecycle
// Pipedream Node.js code step — paste into 'Run Node.js code' after Shopify trigger

export default defineComponent({
  async run({ steps, $ }) {
    const order = steps.trigger.event.body;

    // Safely extract customer data from Shopify payload
    const customer = order.customer;
    if (!customer || !customer.email) {
      return $.flow.exit('No customer email in order payload — skipping.');
    }

    const email = customer.email.trim().toLowerCase();
    const firstName = customer.first_name || '';
    const lastName = customer.last_name || '';
    const orderCount = parseInt(customer.orders_count, 10) || 1;
    
    // Shopify sends total_spent as a string — parse it
    const totalSpent = parseFloat(customer.total_spent) || 0;

    // Define your lifecycle thresholds here
    // Adjust SPEND_THRESHOLD and REPEAT_ORDER_MIN to match your store
    const SPEND_THRESHOLD_EVANGELIST = 1000; // $1,000+ total spend
    const SPEND_THRESHOLD_OPPORTUNITY = 400; // $400+ total spend
    const REPEAT_ORDER_MIN = 2;              // 2+ orders = repeat customer

    // Determine lifecycle stage based on purchase behavior
    let lifecycleStage;
    if (totalSpent >= SPEND_THRESHOLD_EVANGELIST) {
      lifecycleStage = 'evangelist';
    } else if (totalSpent >= SPEND_THRESHOLD_OPPORTUNITY || orderCount >= REPEAT_ORDER_MIN) {
      lifecycleStage = 'opportunity';
    } else if (orderCount === 1) {
      lifecycleStage = 'customer';
    } else {
      lifecycleStage = 'lead';
    }

    const orderDate = new Date(order.created_at).toISOString().split('T')[0];

    console.log(`Customer: ${email} | Orders: ${orderCount} | Spent: $${totalSpent} | Stage: ${lifecycleStage}`);

    // Return values for downstream steps
    return {
      customer_email: email,
      first_name: firstName,
      last_name: lastName,
      total_spent: totalSpent,
      order_count: orderCount,
      lifecycle_stage: lifecycleStage,
      shopify_customer_id: String(customer.id),
      last_order_date: orderDate,
    };
  },
});

Workflow Canvas > + Add a step > HubSpot > Search Contacts

Look up the HubSpot contact by email

Add another step and select the HubSpot app. Choose the action 'Search Contacts'. Set the search property to 'email' and the value to the customer email extracted in the previous step using the reference {{steps.nodejs_1.customer_email}}. Connect your HubSpot account via 'Connected Accounts' — you'll need a Private App token with contacts read/write scope. This step returns the HubSpot contact ID you need for the update call.

1. 1Click '+ Add a step'
2. 2Search for 'HubSpot' and select it
3. 3Choose the action 'Search Contacts'
4. 4Set 'Property' to 'email'
5. 5Set 'Value' to {{steps.nodejs_1.customer_email}}
6. 6Click 'Connect HubSpot Account' and paste your Private App token

Workflow Canvas > + Add a step > Run Node.js code

Handle the case where no HubSpot contact exists

Add a Node.js code step immediately after the search step. Check whether the results array is empty. If no contact is found, use the HubSpot API to create a new contact with the customer's email, first name, and last name from the Shopify payload. Return the new contact's ID so subsequent steps can reference it consistently. This prevents the update step from throwing a 404 on net-new Shopify customers.

1. 1Click '+ Add a step'
2. 2Select 'Run Node.js code'
3. 3Write conditional logic: if results array length is 0, call HubSpot POST /crm/v3/objects/contacts
4. 4Return the contact ID whether created or found
5. 5Click 'Test' to verify both branches work

Workflow Canvas > + Add a step > Run Node.js code

Add a filter step to prevent lifecycle stage downgrades

HubSpot's lifecycle stage field has a strict progression: you cannot move a contact backward (e.g., from 'Customer' back to 'Lead') via a standard property update — but you can via API if you force it, which corrupts your funnel data. Add a Node.js code step that compares the contact's current lifecyclestage from the search result against the new stage you're about to set. If the new stage is not an advancement, export a flag and use Pipedream's $.flow.exit() to stop the workflow cleanly.

1. 1Click '+ Add a step'
2. 2Select 'Run Node.js code'
3. 3Define the stage order array: ['subscriber', 'lead', 'marketingqualifiedlead', 'salesqualifiedlead', 'opportunity', 'customer', 'evangelist']
4. 4Compare current stage index to new stage index
5. 5Call $.flow.exit('Stage not an advancement') if the new stage index is not higher

Workflow Canvas > + Add a step > HubSpot > Update Contact

Update the HubSpot contact's lifecycle stage

Add a HubSpot step and choose 'Update Contact'. Set 'Contact ID' to the resolved contact_id from step 5. Map 'Lifecycle Stage' to the lifecycle_stage value from step 3's code output. You can also map additional fields here: total Shopify spend to a custom HubSpot property, and order count to another. This is the step that actually writes to HubSpot.

1. 1Click '+ Add a step'
2. 2Search for 'HubSpot' and select 'Update Contact'
3. 3Set 'Contact ID' to {{steps.resolve_contact.contact_id}}
4. 4Set 'Lifecycle Stage' to {{steps.nodejs_1.lifecycle_stage}}
5. 5Add custom property: shopify_total_spend = {{steps.nodejs_1.total_spent}}
6. 6Add custom property: shopify_order_count = {{steps.nodejs_1.order_count}}
7. 7Click 'Test'

Workflow Canvas > + Add a step > Run Node.js code OR Settings > Error Handling

Add error handling and Slack alert for failures

Add a final Node.js code step that wraps in a try/catch. If any upstream step has thrown an error (check steps via Pipedream's event inspection), post a message to a Slack channel with the customer email, the attempted lifecycle stage, and the error message. This gives your team visibility without requiring manual log checks. Alternatively, use Pipedream's built-in error workflow feature under Settings > Error Handling.

1. 1Click '+ Add a step'
2. 2Select 'Run Node.js code'
3. 3Add a try/catch block referencing upstream step outputs
4. 4On catch, use the Slack API or Pipedream's Slack app to post to #ecommerce-alerts
5. 5Alternatively, go to workflow Settings > Error Handling and set a dedicated error workflow

Workflow Canvas > Deploy > Events tab

Deploy and verify with a live test order

Click 'Deploy' in the top right of the Pipedream workflow canvas. Place a real test order in your Shopify store (use a $0.00 discount code if needed) with an email tied to an existing HubSpot test contact. Watch the Pipedream run log in real time under the 'Events' tab. Confirm the contact's lifecycle stage updates in HubSpot within 60 seconds of the order being marked paid.

1. 1Click 'Deploy' button in the top right
2. 2Place a test order in Shopify with a known contact email
3. 3Open Pipedream > Workflows > [your workflow] > Events tab
4. 4Watch for the new event to appear and click it to inspect each step's output
5. 5Verify in HubSpot CRM that the contact's lifecycle stage has updated