Orbit ActionCableSource

action-cable-source.ts

import Orbit, {
  Source,
  SourceSettings,
  RecordOperation,
  buildTransform
} from '@orbit/data';
import {
  JSONAPISerializer,
  JSONAPISerializerSettings,
  ResourceOperationsDocument
} from '@orbit/jsonapi';
import ActionCable from '@rails/actioncable';

export interface ActionCableSourceSettings extends SourceSettings {
  cable: ActionCable.Consumer,
  SerializerClass?: new (
    settings: JSONAPISerializerSettings
  ) => JSONAPISerializer;
}

export default class ActionCableSource extends Source {
  constructor(settings: ActionCableSourceSettings) {
    super(settings);

    const SerializerClass = settings.SerializerClass || JSONAPISerializer;
    const serializer = new SerializerClass({
      schema: settings.schema,
      keyMap: settings.keyMap
    });

    settings.cable.subscriptions.create('Operations', {
      received: (document) => {
        const operations = serializer.deserializeOperationsDocument(document);
        this.applyOperations(operations);
      }
    });
  }

  protected async applyOperations(
    operations: RecordOperation[]
  ): Promise<void> {
    const transforms = [buildTransform(operations)];
    await this._transformed(transforms);
  }
}