This project is derived from a blog post written by techinjungle.
See the official Pub/Sub API repo for more information on the Pub/Sub API.
Create a .env file at the root of the project:
SALESFORCE_LOGIN_URL=https://login.salesforce.com
SALESFORCE_USERNAME=YOUR_SALESFORCE_USERNAME
SALESFORCE_PASSWORD=YOUR_SALESFORCE_PASSWORD
PUB_SUB_ENDPOINT=api.pubsub.salesforce.com:7443
PUB_SUB_PROTO_FILE=pubsub_api.proto
PUB_SUB_TOPIC_NAME=/data/AccountChangeEvent
PUB_SUB_EVENT_RECEIVE_LIMIT=1Warning: this project relies on a username/password Salesforce authentication flow. This is only recommended for test purposes. Consider switching to JWT auth for extra security.
If using a Change Data Capture topic (like in the sample config), make sure to activate the event in Salesforce Setup > Change Data Capture.
Run the project with npm start
If everything goes well, you'll see output like this:
Connected to Salesforce org https://pozilcom-dev-ed.my.salesforce.com as [email protected]
Pub/Sub API client is ready to connect
Topic schema loaded: /data/AccountChangeEvent
Subscribe request sent for 1 events from /data/AccountChangeEvent...
At this point the script will be on hold and will wait for events. Once it receives events, it will display them like this:
Received 1 events, latest replay ID: 3228574
gRPC event payloads: [
{
"replayId": "3228574",
"payload": {
"ChangeEventHeader": {
"entityName": "Account",
"recordIds": [
"0017Q00000EiRcfQAF"
],
"changeType": "UPDATE",
"changeOrigin": "com/salesforce/api/soap/55.0;client=SfdcInternalAPI/",
"transactionKey": "0003dce7-caed-c47d-eec0-1d1894d2b0f8",
"sequenceNumber": 1,
"commitTimestamp": 1659010228000,
"commitNumber": 279597718697,
"commitUser": "0057Q000002aGVkQAM",
"nulledFields": [],
"diffFields": [],
"changedFields": [
"Rating",
"LastModifiedDate",
"BillingAddress.PostalCode"
]
},
"Name": null,
"Type": null,
"ParentId": null,
"BillingAddress": {
"com.sforce.eventbus.Address": {
"Street": null,
"City": null,
"State": null,
"PostalCode": {
"string": "94105"
},
"Country": null,
"StateCode": null,
"CountryCode": null,
"Latitude": null,
"Longitude": null,
"Xyz": null,
"GeocodeAccuracy": null
}
},
"ShippingAddress": null,
"Phone": null,
"Fax": null,
"AccountNumber": null,
"Website": null,
"Sic": null,
"Industry": null,
"AnnualRevenue": null,
"NumberOfEmployees": null,
"Ownership": null,
"TickerSymbol": null,
"Description": null,
"Rating": {
"string": "Hot"
},
"Site": null,
"OwnerId": null,
"CreatedDate": null,
"CreatedById": null,
"LastModifiedDate": {
"long": 1659010228000
},
"LastModifiedById": null,
"Jigsaw": null,
"JigsawCompanyId": null,
"CleanStatus": null,
"AccountSource": null,
"DunsNumber": null,
"Tradestyle": null,
"NaicsCode": null,
"NaicsDesc": null,
"YearStarted": null,
"SicDesc": null,
"DandbCompanyId": null,
"OperatingHoursId": null,
"CustomerPriority__c": null,
"SLA__c": null,
"Active__c": null,
"NumberofLocations__c": null,
"UpsellOpportunity__c": null,
"SLASerialNumber__c": null,
"SLAExpirationDate__c": null
}
}
]
Note that the event payload includes all object fields but fields that haven't changed are null.
Use the values from ChangeEventHeader.nulledFields, ChangeEventHeader.diffFields and ChangeEventHeader.changedFields to identify actual value changes.
After receiving the number of requested events (see PUB_SUB_EVENT_RECEIVE_LIMIT), the script will terminate with these messages:
gRPC stream status: {
code: 0,
details: '',
metadata: Metadata { _internal_repr: {}, flags: 0 }
}
gRPC stream ended
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent