diff --git a/packages/client-app/internal_packages/deltas/lib/delta-processor.es6 b/packages/client-app/internal_packages/deltas/lib/delta-processor.es6 index e2f92ea09..5da3ed973 100644 --- a/packages/client-app/internal_packages/deltas/lib/delta-processor.es6 +++ b/packages/client-app/internal_packages/deltas/lib/delta-processor.es6 @@ -60,10 +60,12 @@ class DeltaProcessor { this.activationTime = Date.now() } - async process(rawDeltas = []) { + async process(rawDeltas = [], {source} = {}) { try { const deltas = await this._decorateDeltas(rawDeltas); - Actions.longPollReceivedRawDeltas(deltas); + if (source === "n1Cloud") { + Actions.longPollReceivedRawDeltas(deltas); + } const { modelDeltas, diff --git a/packages/client-app/internal_packages/deltas/lib/delta-streaming-connection.es6 b/packages/client-app/internal_packages/deltas/lib/delta-streaming-connection.es6 index 6ce3eb84c..c125ce04d 100644 --- a/packages/client-app/internal_packages/deltas/lib/delta-streaming-connection.es6 +++ b/packages/client-app/internal_packages/deltas/lib/delta-streaming-connection.es6 @@ -15,7 +15,7 @@ class DeltaStreamingConnection extends NylasLongConnection { // Update cursor when deltas received this.onResults((deltas = []) => { - if (opts.onDeltas) opts.onDeltas(deltas); + if (opts.onDeltas) opts.onDeltas(deltas, {source: "n1Cloud"}); const last = _.last(deltas); if (last && last.cursor) { this._setCursor(last.cursor) diff --git a/packages/client-app/internal_packages/deltas/lib/delta-streaming-in-memory-connection.es6 b/packages/client-app/internal_packages/deltas/lib/delta-streaming-in-memory-connection.es6 index 983f55bb6..9fd03e668 100644 --- a/packages/client-app/internal_packages/deltas/lib/delta-streaming-in-memory-connection.es6 +++ b/packages/client-app/internal_packages/deltas/lib/delta-streaming-in-memory-connection.es6 @@ -13,7 +13,7 @@ class DeltaStreamingInMemoryConnection { onDeltas = (allDeltas = []) => { const deltas = allDeltas.filter((d) => d.accountId === this._accountId); - this._onDeltas(deltas); + this._onDeltas(deltas, {source: "localSync"}); const last = deltas[deltas.length - 1] if (last) this._setCursor(last.cursor); } diff --git a/packages/client-app/internal_packages/worker-ui/lib/developer-bar.cjsx b/packages/client-app/internal_packages/worker-ui/lib/developer-bar.cjsx index d0be35ff8..551d5aaed 100644 --- a/packages/client-app/internal_packages/worker-ui/lib/developer-bar.cjsx +++ b/packages/client-app/internal_packages/worker-ui/lib/developer-bar.cjsx @@ -48,7 +48,7 @@ class DeveloperBar extends React.Component
@_onExpandSection('long-polling')}> {@_renderDeltaStates()} - Delta Streaming + Cloud Deltas
@@ -72,9 +72,7 @@ class DeveloperBar extends React.Component _renderDeltaStates: => _.map @state.longPollStates, (deltaStatus, accountId) =>
- { _.map deltaStatus, (val, deltaName) => -
- } +
_sectionContent: =>