Options
All
  • Public
  • Public/Protected
  • All
Menu

DigitalEventFactory - Singleton factory for parsing and publishing delta events.

This factory intercepts WebSocket events, extracts only the changed fields (delta), and publishes lightweight payloads to subscribers through an RxJS Subject.

example

// Get factory instance const factory = DigitalEventFactory.instance;

// Subscribe to delta events factory.deltaEventSubject.subscribe(deltaEvent => { console.log('Received delta event:', deltaEvent); });

// Parse and publish a WebSocket event factory.parseAndPublishDeltaEvent(rawWebSocketEvent);

Hierarchy

  • DigitalEventFactory

Index

Constructors

Properties

RxJS Subject for publishing delta events to subscribers

logger: CcfLogger = ...

Logger instance for debugging and error tracking

Singleton instance

Accessors

Methods

  • Main coordinator method - parses raw WebSocket event and publishes delta. This is the primary entry point for event processing.

    example

    const factory = DigitalEventFactory.instance; factory.parseAndPublishDeltaEvent({ eventType: 'CaseStatusChanged', data: { case: { id: '123', status: 'closed' } } });

    remarks

    This method creates the appropriate delta event instance based on event type, validates the data, and publishes the parsed delta to subscribers via the deltaEventSubject. Uses 'any' type for eventData because WebSocket event structure varies by event type.

    Parameters

    Returns Promise<void | MessageAddedIntoCaseDeltaEvent>

Generated using TypeDoc