MuleSoft technical guide

%dw 2.0
output application/json
---
payload map (row) -> {
  External_Id__c: row.id,
  AccountId: row.customerId,
  Amount__c: row.total,
  Status__c: upper(row.state)
}

// Real-time: Salesforce publishes a Platform Event, the iPaaS subscribes
trigger OrderEventTrigger on Order_Event__e (after insert) {
  List<Sync_Task__c> tasks = new List<Sync_Task__c>();
  for (Order_Event__e ev : Trigger.new) {
    tasks.add(new Sync_Task__c(Order_Id__c = ev.Order_Id__c, Status__c = 'Queued'));
  }
  insert tasks;
}

// Scheduled delta pull: only records changed since the last successful run
global class DeltaPullScheduler implements Schedulable {
  global void execute(SchedulableContext ctx) {
    Datetime since = IntegrationConfig.lastSync();
    ExternalService.pullUpdatedSince(since);     // the iPaaS flow filters by updatedSince
    IntegrationConfig.setLastSync(System.now());  // watermark for the next run
  }
}