How to Bi-directional contact sync with Pipedream

Workflows > New > Sources > HTTP / Webhook Requests

Create HTTP trigger for Google Sheets changes

Navigate to pipedream.com and click New Workflow. Select HTTP / Webhook Requests as your trigger source. This creates an instant webhook URL that Google Sheets Apps Script will call when rows change. Copy the webhook URL from the trigger configuration - you'll need this for the Apps Script setup.

1. 1Click 'New Workflow' from your Pipedream dashboard
2. 2Select 'HTTP / Webhook Requests' from the trigger sources
3. 3Name your workflow 'Sheets to Salesforce Sync'
4. 4Copy the generated webhook URL

Google Sheets > Extensions > Apps Script

Add Google Sheets Apps Script trigger

Open your Google Sheet and go to Extensions > Apps Script. Create an onEdit trigger that sends a POST request to your Pipedream webhook when cells change. The script needs to identify which row changed and send the contact data as JSON. Test the script by editing a contact row and checking if the webhook receives data.

1. 1Click Extensions > Apps Script in your Google Sheet
2. 2Replace the default code with the webhook POST function
3. 3Set your Pipedream webhook URL in the script
4. 4Save and authorize the script permissions

This code prevents infinite sync loops by checking if a contact was recently updated from the opposite system. Paste it as a Code step before each update action in both workflows.

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

export default defineComponent({
  async run({ steps, $ }) {
    const salesforceData = steps.trigger.event;
    const lastSyncTime = salesforceData.Last_Sync__c;
    const lastModified = new Date(salesforceData.LastModifiedDate);
    const syncThreshold = 5 * 60 * 1000; // 5 minutes
    
    // Skip if recently synced from Sheets
    if (lastSyncTime) {
      const timeSinceSync = Date.now() - new Date(lastSyncTime).getTime();
      if (timeSinceSync < syncThreshold) {
        console.log('Skipping sync - recently updated from Sheets');
        return $.respond({ skip: true, reason: 'Recent sync detected' });
      }
    }
    
    // Check for rapid successive updates
    const timeSinceModified = Date.now() - lastModified.getTime();
    if (timeSinceModified < 30000) { // 30 seconds
      console.log('Skipping sync - too soon after last modification');
      return $.respond({ skip: true, reason: 'Rate limit applied' });
    }
    
    return {
      shouldSync: true,
      contactId: salesforceData.Id,
      syncTimestamp: new Date().toISOString()
    };
  }
});

Workflow Steps > Add Step > Apps > Salesforce

Connect Salesforce account

Add a new step in Pipedream and search for Salesforce. Select 'Update Record' as your action since you'll be updating existing contacts. Connect your Salesforce account through OAuth - this requires admin permissions to create connected apps. Pipedream handles the OAuth flow but you need proper Salesforce API access.

1. 1Click the + button below your HTTP trigger
2. 2Search for and select 'Salesforce'
3. 3Choose 'Update Record' action
4. 4Click 'Connect Account' and complete OAuth

Workflow Steps > Add Step > Code

Configure Salesforce contact lookup

Before updating a contact, you need to find it by email address. Add a Code step above the Salesforce update to query for existing contacts. Use the Salesforce REST API to search by email and return the Contact ID. This prevents creating duplicates and ensures you're updating the right record.

1. 1Click + to add a step above Salesforce Update
2. 2Select 'Run Node.js Code'
3. 3Add the contact search code using Salesforce API
4. 4Reference the email from steps.trigger.event.body.email

Salesforce Step > Field Mapping

Map Google Sheets fields to Salesforce

Configure the Salesforce Update Record step to map your Google Sheets columns to Contact fields. Use the Contact ID from your code step as the record identifier. Map common fields like FirstName, LastName, Email, Phone, and MailingAddress. Reference the webhook data using steps.trigger.event.body notation.

1. 1Set Object Type to 'Contact'
2. 2Set Record ID to steps.code.contact_id
3. 3Map FirstName to steps.trigger.event.body.first_name
4. 4Map additional fields like Email, Phone, Company

Workflows > New > Salesforce > Updated Record

Create second workflow for Salesforce to Sheets

Create a new workflow to handle the reverse sync when Salesforce contacts change. Start with a Salesforce trigger - use 'Updated Record' and select Contact object. This monitors Salesforce for contact changes and fires immediately when fields are modified. Configure it to trigger only on specific fields to avoid infinite loops.

1. 1Click 'New Workflow' and name it 'Salesforce to Sheets Sync'
2. 2Select Salesforce as the trigger source
3. 3Choose 'Updated Record' trigger
4. 4Select 'Contact' object and specify field filters

Workflow Steps > Add Step > Google Sheets > Update Spreadsheet Row

Add Google Sheets connection for updates

Add a Google Sheets step to your Salesforce-triggered workflow. Choose 'Update Spreadsheet Row' action and connect your Google account. You'll need to specify the spreadsheet ID, worksheet name, and how to identify which row to update. Use email address as the lookup field since it should match between systems.

1. 1Click + to add a Google Sheets step
2. 2Select 'Update Spreadsheet Row' action
3. 3Connect your Google account via OAuth
4. 4Choose your contact spreadsheet and worksheet

Google Sheets Step > Row Configuration

Configure row lookup and field mapping

Set up the Google Sheets step to find the correct row by email address and update the corresponding fields. Configure the lookup column (usually email) and map Salesforce contact fields to your sheet columns. Include a timestamp column to track when the sync occurred from each direction.

1. 1Set 'Lookup Column' to your email column name
2. 2Set 'Lookup Value' to steps.trigger.event.Email
3. 3Map FirstName to your first name column
4. 4Add a 'Last Updated' timestamp field

Workflow Steps > Add Step > Code > Loop Prevention

Add duplicate prevention logic

Create a Code step in both workflows to prevent infinite sync loops. Check if the update originated from the same platform by comparing timestamps or adding a sync flag. Skip the sync if the record was recently updated from the opposite direction. This prevents changes from bouncing back and forth endlessly.

1. 1Add a Code step before each update action
2. 2Compare LastModifiedDate with sync timestamps
3. 3Return null to skip sync if recently updated
4. 4Log the skip reason for debugging

Workflows > Test > Event History

Test both sync directions

Test the complete bi-directional sync by updating a contact in Google Sheets and verifying it updates in Salesforce. Then update a different field in Salesforce and confirm it syncs back to Sheets. Check the workflow logs for any errors and verify that your loop prevention is working correctly.

1. 1Update a phone number in Google Sheets
2. 2Check Salesforce for the updated phone number
3. 3Update an address in Salesforce
4. 4Verify the address appears in Google Sheets