mirror of
https://github.com/jambonz/jambonz-feature-server.git
synced 2025-12-20 16:50:39 +00:00
6abfdafe05
* initial adds for otel tracing * initial basic testing * basic tracing for incoming calls * linting * add traceId to the webhook params * trace webhook calls * tracing: add new commands as tags when receiving async commands over websocket * tracing new commands * add summary for config verb * trace async commands * bugfix: undefined ref * tracing: give time for final webhooks before closing root span * tracing bugfix: span for background gather was not ended * tracing - minor tag changes * tracing - add span atttribute for reason call ended * trace call status webhooks, add app version to trace output * config: add support for automatically re-enabling * env var to customize service name in tracing UI * config: change to use 'sticky' attribute to re-enable bargein automatically * fix warnings * when adulting create a new root span * when background gather triggers bargein via vad clear queue of tasks * additional trace attributes for dial and refer * fix dial tracing * add better summary for dial * fix prev commit * add exponential backoff to WsRequestor reconnection logic * add calling number to log metadata, as this will be frequently the key data given for troubleshooting * add accountSid to log metadata * make handshake timeout for ws connections configurable with default 1.5 secs * rename env var * fix bug prev checkin * logging fixes * consistent env naming
53 lines
1.4 KiB
JavaScript
53 lines
1.4 KiB
JavaScript
const Task = require('./task');
|
|
const {TaskName, TaskPreconditions} = require('../utils/constants');
|
|
|
|
class TaskPlay extends Task {
|
|
constructor(logger, opts) {
|
|
super(logger, opts);
|
|
this.preconditions = TaskPreconditions.Endpoint;
|
|
|
|
this.url = this.data.url;
|
|
this.loop = this.data.loop || 1;
|
|
this.earlyMedia = this.data.earlyMedia === true;
|
|
}
|
|
|
|
get name() { return TaskName.Play; }
|
|
|
|
get summary() {
|
|
return `${this.name}:{url=${this.url}}`;
|
|
}
|
|
|
|
async exec(cs, ep) {
|
|
await super.exec(cs);
|
|
this.ep = ep;
|
|
try {
|
|
while (!this.killed && (this.loop === 'forever' || this.loop--) && this.ep.connected) {
|
|
if (cs.isInConference) {
|
|
const {memberId, confName, confUuid} = cs;
|
|
await this.playToConfMember(this.ep, memberId, confName, confUuid, this.url);
|
|
}
|
|
else await ep.play(this.url);
|
|
}
|
|
} catch (err) {
|
|
this.logger.info(err, `TaskPlay:exec - error playing ${this.url}`);
|
|
}
|
|
this.emit('playDone');
|
|
}
|
|
|
|
async kill(cs) {
|
|
super.kill(cs);
|
|
if (this.ep.connected && !this.playComplete) {
|
|
this.logger.debug('TaskPlay:kill - killing audio');
|
|
if (cs.isInConference) {
|
|
const {memberId, confName} = cs;
|
|
this.killPlayToConfMember(this.ep, memberId, confName);
|
|
}
|
|
else {
|
|
await this.ep.api('uuid_break', this.ep.uuid).catch((err) => this.logger.info(err, 'Error killing audio'));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = TaskPlay;
|