Platform Events y CDC: integraciones de Salesforce en tiempo real

public class OrderService {
 
    public static void publishOrderPlaced(Order__c order) {
        Order_Placed__e event = new Order_Placed__e(
            Order_Id__c = order.Id,
            Customer_Email__c = order.Customer_Email__c,
            Total_Amount__c = order.Total_Amount__c
        );
 
        Database.SaveResult result = EventBus.publish(event);
 
        if (!result.isSuccess()) {
            for (Database.Error err : result.getErrors()) {
                System.debug('Error publishing event: ' + err.getMessage());
            }
        }
    }
}

trigger OrderPlacedTrigger on Order_Placed__e (after insert) {
    List<Order_Placed__e> events = Trigger.new;
 
    for (Order_Placed__e event : events) {
        // Procesa cada evento
        System.debug('Order received: ' + event.Order_Id__c
            + ' from ' + event.Customer_Email__c);
 
        // Encola trabajo asíncrono si es necesario
        System.enqueueJob(new OrderFulfillmentQueueable(event.Order_Id__c));
    }
}

// orderNotifications.js
import { LightningElement, wire } from 'lwc';
import { subscribe, MessageContext } from 'lightning/empApi';
 
export default class OrderNotifications extends LightningElement {
    subscription = null;
    notifications = [];
 
    connectedCallback() {
        this.subscribeToEvents();
    }
 
    subscribeToEvents() {
        const channel = '/event/Order_Placed__e';
        subscribe(channel, -1, (event) => {
            const payload = event.data.payload;
            this.notifications = [
                ...this.notifications,
                {
                    id: Date.now(),
                    orderId: payload.Order_Id__c,
                    email: payload.Customer_Email__c,
                    amount: payload.Total_Amount__c
                }
            ];
        }).then(response => {
            this.subscription = response;
        });
    }
}

const jsforce = require('jsforce');
 
const conn = new jsforce.Connection({
    loginUrl: 'https://login.salesforce.com'
});
 
await conn.login(username, password);
 
conn.streaming.topic('/data/AccountChangeEvent').subscribe((event) => {
    const header = event.payload.ChangeEventHeader;
    console.log('Change type:', header.changeType); // CREATE, UPDATE, DELETE, UNDELETE
    console.log('Changed fields:', header.changedFields);
    console.log('Record IDs:', header.recordIds);
 
    // Sincroniza con tu base de datos
    syncToExternalSystem(event.payload);
});

// Almacena el último ReplayId procesado en un Custom Setting
public class EventReplayTracker {
 
    public static Long getLastReplayId(String channelName) {
        Event_Replay__c setting = Event_Replay__c.getInstance(channelName);
        return setting != null ? (Long) setting.Replay_Id__c : -1;
    }
 
    public static void updateReplayId(String channelName, Long replayId) {
        Event_Replay__c setting = Event_Replay__c.getInstance(channelName)
            ?? new Event_Replay__c(Name = channelName);
        setting.Replay_Id__c = replayId;
        upsert setting Name;
    }
}