@observertc/observer-js - npm Package Compare versions

lib/Observer.d.ts

		@@ -13,2 +13,6 @@ import { ObserverReportsEmitter, ObserverSinkProcess, SinkConfig } from './sinks/ObserverSink';
		export type ObserverEvents = {
		'processing-started': undefined;
		'client-added': string;
		'client-removed': string;
		'processing-ended': undefined;
		'close': undefined;
		@@ -15,0 +19,0 @@ };

lib/Observer.js

		"use strict";
		var __importDefault = (this && this.__importDefault) \|\| function (mod) {
		return (mod && mod.__esModule) ? mod : { "default": mod };
		};
		Object.defineProperty(exports, "__esModule", { value: true });
		@@ -13,3 +10,3 @@ exports.Observer = void 0;
		const logger_1 = require("./common/logger");
		const events_1 = __importDefault(require("events"));
		const events_1 = require("events");
		const logger = (0, logger_1.createLogger)('Observer');
		@@ -41,3 +38,3 @@ class Observer {
		this._semaphores = _semaphores;
		this._emitter = new events_1.default();
		this._emitter = new events_1.EventEmitter();
		this._closed = false;
		@@ -48,2 +45,3 @@ this._sources = new Sources_1.Sources(config.sources);
		this._sources.on('observed-samples', (event) => {
		this._emitter.emit('processing-started');
		this._evaluator.addObservedSamples(event);
		@@ -53,8 +51,11 @@ });
		this._evaluator.addCreatedClientSource(event);
		this._emitter.emit('client-added', event.clientId);
		});
		this._sources.on('removed-client-source', (event) => {
		this._evaluator.addClosedClientSource(event);
		this._emitter.emit('client-added', event.clientId);
		});
		this._evaluator.on('ready', () => {
		this._sink.emit();
		this._emitter.emit('processing-ended');
		});
		@@ -61,0 +62,0 @@ logger.debug(`Observer is created with config`, this.config);

package.json

		{
		"name": "@observertc/observer-js",
		"version": "0.9.20-beta",
		"version": "0.9.21-beta",
		"description": "Server Side NodeJS Library for processing ObserveRTC Samples",
		@@ -39,2 +39,3 @@ "main": "lib/index.js",
		"@types/jest": "^27.5.2",
		"@types/node": "^20.9.0",
		"@typescript-eslint/eslint-plugin": "^5.38.0",
		@@ -41,0 +42,0 @@ "@typescript-eslint/parser": "^5.38.0",

src/Observer.ts

		@@ -12,3 +12,3 @@ import { ObserverReportsEmitter, ObserverSinkProcess, SinkConfig, SinkImpl } from './sinks/ObserverSink';
		import { ObservedSfuSource, ObservedSfuSourceConfig } from './sources/ObservedSfuSource';
		import EventEmitter from 'events';
		import { EventEmitter } from 'events';

		@@ -18,2 +18,6 @@ const logger = createLogger('Observer');
		export type ObserverEvents = {
		'processing-started': undefined,
		'client-added': string,
		'client-removed': string,
		'processing-ended': undefined,
		'close': undefined,
		@@ -92,2 +96,3 @@ }
		this._sources.on('observed-samples', (event) => {
		this._emitter.emit('processing-started');
		this._evaluator.addObservedSamples(event);
		@@ -97,8 +102,11 @@ });
		this._evaluator.addCreatedClientSource(event);
		this._emitter.emit('client-added', event.clientId);
		});
		this._sources.on('removed-client-source', (event) => {
		this._evaluator.addClosedClientSource(event);
		this._emitter.emit('client-added', event.clientId);
		});
		this._evaluator.on('ready', () => {
		this._sink.emit();
		this._emitter.emit('processing-ended');
		});
		@@ -105,0 +113,0 @@ logger.debug(`Observer is created with config`, this.config);

lib/Observer.d.ts.map

Sorry, the diff of this file is not supported yet

Improved metrics