Class WSController

Use WSController to negotiate a new RTCPeerConnection connection with the server using WebSocket custom signaling and keep that connection open for communication.

Example

// Listener channel (no 'stream' parameter), listen to a stream without sending data
const connection = new WSController({endPoint, streamName});
connection.onOpen = stream => videoElement.srcObject = stream;

// Streamer channel (with 'stream' parameter), sends and receives media streams
const connection = new WSController({endPoint, streamName}, {stream: await navigator.mediaDevices.getUserMedia()});
connection.onOpen = stream => {}

Hierarchy

SIPConnector
- WSController

Implements

IController

Index

Constructors

constructor

new WSController(connectParams, stream?): WSController
Instantiate the WSController, connect to the WebSocket endpoint and call _open() to create the RTCPeerConnection.

By default, a listener channel is negotiated. To create a streamer channel, pass a stream parameter.
Parameters
- connectParams: Params
- Optional stream: MediaStream
Returns WSController
Overrides SIPConnector.constructor
- Defined in src/connectors/WSController.ts:69

Properties

`Private` `Optional` _promise

_promise?: ((result) => void)

Type declaration

- (result): void
- Parameters
  - result: string | Error
  Returns void

`Private` `Optional` _reportReceivedTimestamp

_reportReceivedTimestamp?: number

`Private` `Optional` _reportWatchdogInterval

_reportWatchdogInterval?: Timeout

`Private` _ws

_ws: WebSocketReliable

log

log: ILog

Start a log

Param

Returns

a Log object with the levels of log to call

Accessors

closed

get closed(): boolean
True when connector is closed, in other words when onClose event is fired

Returns boolean
Implementation of IController.closed
Inherited from SIPConnector.closed
- Defined in src/connectors/SIPConnector.ts:91

codecs

get codecs(): Set<string>
Indicate codecs supported, should be set before than onOpen happen

Returns Set<string>
Implementation of IController.codecs
Inherited from SIPConnector.codecs
- Defined in src/connectors/SIPConnector.ts:112

opened

get opened(): boolean
True when connector is opened, in other words when onOpen event is fired

Returns boolean
Implementation of IController.opened
Inherited from SIPConnector.opened
- Defined in src/connectors/SIPConnector.ts:84

stream

get stream(): undefined | MediaStream
Media Stream description delivred from the server if we are player, or build from the local camera if we are the streamer.

Returns undefined | MediaStream
Implementation of IController.stream
Inherited from SIPConnector.stream
- Defined in src/connectors/SIPConnector.ts:98

streamName

get streamName(): string
Stream name, for example as+bc3f535f-37f3-458b-8171-b4c5e77a6137

Returns string
Implementation of IController.streamName
Inherited from SIPConnector.streamName
- Defined in src/connectors/SIPConnector.ts:105

Methods

`Private` _clearReportWatchdog

_clearReportWatchdog(): void
Returns void
- Defined in src/connectors/WSController.ts:242

`Protected` _eventHandler

_eventHandler(ev): void
Parameters
- ev: any
Returns void
- Defined in src/connectors/WSController.ts:156

`Protected` _open

_open(iceServer?): void
Main function which creates the RTCPeerConnection, creates the offer, calls the _sip method, then set the answer and calls onOpen
Parameters
- Optional iceServer: RTCIceServer
Returns void
Inherited from SIPConnector._open
- Defined in src/connectors/SIPConnector.ts:241

`Protected` _sip

_sip(offer): Promise<string>
Operates Session Initiation Protocol, this method implement the logic to send the SDP offer to the server and get the SDP answer in response.
Parameters
- offer: string
  SIP Offer
Returns Promise<string>
a Promise with SIP Answer as result
Overrides SIPConnector._sip
- Defined in src/connectors/WSController.ts:142

`Private` _startReportWatchdog

_startReportWatchdog(): void
Returns void
- Defined in src/connectors/WSController.ts:226

close

close(error?): void
Close the connector
Parameters
- Optional error: ConnectorError
  the error reason if is not a proper close
Returns void
Implementation of IController.close
Overrides SIPConnector.close
- Defined in src/connectors/WSController.ts:125

connectionInfos

connectionInfos(cacheDuration?): Promise<ConnectionInfos>
Returns connection info, such as round trip time, requests sent and received, bytes sent and received, and bitrates NOTE: This call is resource-intensive for the CPU.
Parameters
- cacheDuration: number = 1000
Returns Promise<ConnectionInfos>
A promise that resolves to an RTCStatsReport object
Implementation of IController.connectionInfos
Inherited from SIPConnector.connectionInfos
- Defined in src/connectors/SIPConnector.ts:147

off

off(name, event): boolean
Event unsubscription
Parameters
- name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"
  Name of event without the 'on' prefix (ex: 'log' to 'onLog' event declared)
- event: Function
  Unsubscriber Function, must be the one passed to on or once subscription methods
Returns boolean
Implementation of IController.off
Inherited from SIPConnector.off
- Defined in node_modules/@ceeblue/web-utils/dist/web-utils.d.ts:439

on

on(name, event, options?): void
Event subscription
Parameters
- name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"
  Name of event without the on prefix (ex: log to onLog event declared)
- event: Function
  Subscriber Function
- Optional options: {
  signal?: AbortSignal;
  }
  - Optional signal?: AbortSignal
    Optional AbortSignal to stop this or multiple subscriptions in same time
Returns void
Implementation of IController.on
Inherited from SIPConnector.on
- Defined in node_modules/@ceeblue/web-utils/dist/web-utils.d.ts:422

once

once(name, event, options?): void
Event subscription only one time, once time fired it's automatically unsubscribe
Parameters
- name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"
  Name of event without the on prefix (ex: log to onLog event declared)
- event: Function
  Subscriber Function
- Optional options: {
  signal?: AbortSignal;
  }
  - Optional signal?: AbortSignal
Returns void
Implementation of IController.once
Inherited from SIPConnector.once
- Defined in node_modules/@ceeblue/web-utils/dist/web-utils.d.ts:431

send

send(type, params): void
Send a generic command to control the streaming session
Parameters
- type: string
  type of command
- params: object
  parameters of the command
Returns void
Implementation of IController.send
- Defined in src/connectors/WSController.ts:111

setRTPProps

setRTPProps(nack?, drop?): void
Sets server properties for packet error (nack) and delayed packet loss (drop) for a streamer controller and fires an onRTPProps event if changed successfully. NOTE: Method can also retrieve current server values if called without arguments.
Parameters
- Optional nack: number
  Waiting period before declaring a packet error
- Optional drop: number
  Waiting period before considering delayed packets as lost
Returns void
Implementation of IController.setRTPProps
- Defined in src/connectors/WSController.ts:90

setTracks

setTracks(tracks): void
Configure the audio and video track to play for a player controller
Parameters
- tracks: {
  audio?: number;
  video?: number;
  }
  - Optional audio?: number
  - Optional video?: number
Returns void
Implementation of IController.setTracks
- Defined in src/connectors/WSController.ts:104

setVideoBitrate

setVideoBitrate(value): void
Configure the video bitrate on the server side for a streamer controller
Parameters
- value: number
  video bitrate in bps
Returns void
Implementation of IController.setVideoBitrate
- Defined in src/connectors/WSController.ts:97

Events

onClose

onClose(error?): void
Call when connector is closed
Parameters
- Optional error: ConnectorError
  error description on an improper closure
Returns void
Implementation of IController.onClose
Inherited from SIPConnector.onClose
- Defined in src/connectors/SIPConnector.ts:73

onMediaReport

onMediaReport(mediaReport): void
Call to distribute MediaReport
Parameters
- mediaReport: MediaReport
  Media report informations
Returns void
Implementation of IController.onMediaReport
- Defined in src/connectors/WSController.ts:37

onOpen

onOpen(stream): void
Call when connector is open
Parameters
- stream: MediaStream
  MediaStream description provided from the server if we are the player, or build from the local camera if we are the streamer.
Returns void
Implementation of IController.onOpen
Inherited from SIPConnector.onOpen
- Defined in src/connectors/SIPConnector.ts:65

onPlaying

onPlaying(playing): void
Call to distribute PlayingInfos
Parameters
- playing: PlayingInfos
  Current playing informations
Returns void
Implementation of IController.onPlaying
- Defined in src/connectors/WSController.ts:53

onRTPProps

onRTPProps(rtpProps): void
Call to distribute RTPProps
Parameters
- rtpProps: RTPProps
  RTP properties
Returns void
Implementation of IController.onRTPProps
- Defined in src/connectors/WSController.ts:31

onVideoBitrate

onVideoBitrate(videoBitrate, videoBitrateConstraint): void
Call to distribute video bitrate informations
Parameters
- videoBitrate: number
  Current video bitrate
- videoBitrateConstraint: number
  Video bitrate constraint computed by the server
Returns void
Implementation of IController.onVideoBitrate
- Defined in src/connectors/WSController.ts:43

Class WSController

Example

Hierarchy

Implements

Index

Constructors

Properties

Accessors

Methods

Events

Constructors

constructor

Parameters

connectParams: Params

Optional stream: MediaStream

Returns WSController

Properties

Private Optional _promise

Type declaration

Parameters

result: string | Error

Returns void

Private Optional _reportReceivedTimestamp

Private Optional _reportWatchdogInterval

Private _ws

log

Param

Returns

Accessors

closed

Returns boolean

codecs

Returns Set<string>

opened

Returns boolean

stream

Returns undefined | MediaStream

streamName

Returns string

Methods

Private _clearReportWatchdog

Returns void

Protected _eventHandler

Parameters

ev: any

Returns void

Protected _open

Parameters

Optional iceServer: RTCIceServer

Returns void

Protected _sip

Parameters

offer: string

Returns Promise<string>

Private _startReportWatchdog

Returns void

close

Parameters

Optional error: ConnectorError

Returns void

connectionInfos

Parameters

cacheDuration: number = 1000

Returns Promise<ConnectionInfos>

off

Parameters

name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"

event: Function

Returns boolean

on

Parameters

name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"

event: Function

Optional options: { signal?: AbortSignal; }

Optional signal?: AbortSignal

Returns void

once

Parameters

name: "open" | "close" | "playing" | "Close" | "RTPProps" | "MediaReport" | "VideoBitrate" | "Playing" | "Open" | "rtpprops" | "mediareport" | "videobitrate"

event: Function

`Optional` stream: MediaStream

`Private` `Optional` _promise

`Private` `Optional` _reportReceivedTimestamp

`Private` `Optional` _reportWatchdogInterval

`Private` _ws

`Private` _clearReportWatchdog

`Protected` _eventHandler

`Protected` _open

`Optional` iceServer: RTCIceServer

`Protected` _sip

`Private` _startReportWatchdog

`Optional` error: ConnectorError

`Optional` options: {
signal?: AbortSignal;
}

`Optional` signal?: AbortSignal

`Optional` options: {
signal?: AbortSignal;
}

`Optional` signal?: AbortSignal

`Optional` nack: number

`Optional` drop: number

tracks: {
audio?: number;
video?: number;
}

`Optional` audio?: number

`Optional` video?: number

`Optional` error: ConnectorError