ストリーミング API による変更の登録

登録メカニズムの中心は src/js/channel/ServerConnection.js の _subscribeChannels メソッドです。

cometd.subscribe(channelName, function(event) {
  if (event && event.data && event.data.payload && 
      event.data.payload.ChangeEventHeader) {
    var header = event.data.payload.ChangeEventHeader;
    var entityName = header.entityName;
    var recordId = header.recordIds[0];
    var timestamp = header.commitTimestamp;
    var changeType = header.changeType;
        
    switch (changeType) {
      case "UPDATE":
        // Update logic ...
        break;
     case "CREATE":
        // Create logic
        break;
     case "DELETE":
        // Delete logic
        break;
    }
  }
}

Codey Outfitters の商品用の channelName は /data/Products__ChangeEvent です。チャネルで公開される各変更イベント通知は Bayeux 形式であり、商品在庫で更新されたレコードを表します。data.payload には、変更イベントデータと変更イベントの性質を示すヘッダーが含まれます。次のイベント通知例では、Codey Outfitters の商品レコードへの変更を記述しています。

{ 
  schema=”lswW55LyUCYeU7raSrmZ5A”,
  payload={
    ChangeEventHeader={
      commitUser=”005xx000001SvAn”, 
      sequenceNumber=15,
      entityName=”Products__x”,
      changeType=”UPDATE”, 
      changeOrigin=”Products?$deltaToken=3779”, 
      transactionKey=”f158f145-a...”, 
      commitTimestamp=1507759119826, 
      recordIds=[“x03xx0000000008”]
    },
    Name__c=”Camping Stove”,
    ExternalId=7801,
    UnitPrice__c=10.0,
    Stock__c=1500.0,
    OrderLimit__c=12.0,
    ProductId__c=7801.0
  },
  event={replayId=15}
}