live: AMI-fed live state, /api/live WebSocket, dashboard and status dots
LiveState loads extension states and registered devices from Asterisk on every AMI connect and follows ExtensionStatus/ContactStatus; the hub sends a snapshot then deltas batched every 250 ms (devices for admins only), pings every 30 s and closes unauthenticated sockets with 4401. The web UI keeps one reconnecting socket in a zustand store, shows a Reconnecting banner, a Dashboard (online, on a call, telephony engine) and status dots. Fix: Asterisk 24 has no 'pjsip reload'; reload with 'module reload res_pjsip.so'. AMI errors now carry the CLI output. Milestone check, automated: call-test.ts registers two baresip phones and holds a 30 s call with RTP both ways (pnpm test:asterisk); the recorded session drives the live-state tests. scripts/e2e/m2-live.mjs runs api + Asterisk + phones + browser on a private Docker network: a new extension is live in Asterisk in ~1.3 s, the dashboard shows 2/2 online and red dots during the call. Task: M2-T6
This commit is contained in:
iamdoubz committed
1 parent
1cfc13ead3
commit
c0c4036887
31 files changed
+4810
-28
No files matched your search
@@ -0,0 +1,280 @@
|
||||
// SPDX-License-Identifier: AGPL-3.0-or-later
|
||||
// M2 milestone check, automated (09 M2-T6): two softphones (baresip) register as 101 and 102,
|
||||
// 102 calls 101 through our generated dialplan, and RTP must flow both ways for CALL_SECONDS.
|
||||
// Everything runs on a private Docker bridge network: no host networking, no image builds.
|
||||
// Usage: node --conditions=source apps/api/test/asterisk/call-test.ts [--record <file>]
|
||||
// ASTERISK_IMAGE (default selfphoneng-asterisk), CALL_SECONDS (default 30)
|
||||
import { spawnSync } from 'node:child_process';
|
||||
import { mkdtempSync, rmSync, writeFileSync } from 'node:fs';
|
||||
import { Socket } from 'node:net';
|
||||
import { tmpdir } from 'node:os';
|
||||
import { join } from 'node:path';
|
||||
import { SettingsSchemas, type SettingKey } from '@selfphoneng/shared';
|
||||
import { AmiClient } from '../../src/ami/client.ts';
|
||||
import { GENERATED_FILES, render } from '../../src/generator/index.ts';
|
||||
import type { Snapshot } from '../../src/generator/load.ts';
|
||||
|
||||
const IMAGE = process.env.ASTERISK_IMAGE ?? 'selfphoneng-asterisk';
|
||||
const CALL_SECONDS = Number(process.env.CALL_SECONDS ?? 30);
|
||||
const RECORD = process.argv.includes('--record')
|
||||
? process.argv[process.argv.indexOf('--record') + 1]
|
||||
: undefined;
|
||||
const NET = 'sp-test';
|
||||
const AST = 'sp-test-ast';
|
||||
const PHONES = 'sp-test-phones';
|
||||
const AMI_PORT = 15038;
|
||||
const AMI_SECRET = 'call-test-secret';
|
||||
const PASS = { '101': 'CallTest101xxxxxxxxxxxxx', '102': 'CallTest102xxxxxxxxxxxxx' };
|
||||
|
||||
const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));
|
||||
const docker = (...args: string[]) => {
|
||||
const r = spawnSync('docker', args, { encoding: 'utf8' });
|
||||
return { ok: r.status === 0, out: `${r.stdout ?? ''}${r.stderr ?? ''}` };
|
||||
};
|
||||
const log = (...a: unknown[]) => console.log(`[call-test]`, ...a);
|
||||
|
||||
function snapshot(): Snapshot {
|
||||
const settings = Object.fromEntries(
|
||||
(Object.keys(SettingsSchemas) as SettingKey[])
|
||||
.filter((k) => k !== 'sms.webhookToken')
|
||||
.map((k) => [k, SettingsSchemas[k].parse(undefined)]),
|
||||
) as Snapshot['settings'];
|
||||
const ext = (number: '101' | '102', name: string) => ({
|
||||
id: `00000000-0000-4000-8000-000000000${number}`,
|
||||
number,
|
||||
name,
|
||||
sipPassword: PASS[number],
|
||||
webrtcEnabled: false,
|
||||
maxContacts: 5,
|
||||
ringSeconds: 25,
|
||||
voicemailEnabled: false,
|
||||
outboundClass: 'national' as const,
|
||||
outboundCallerId: null,
|
||||
emergencyCallerId: null,
|
||||
recordMode: 'never' as const,
|
||||
pickupGroup: null,
|
||||
language: 'en',
|
||||
mohClass: 'default',
|
||||
isAdmin: false,
|
||||
});
|
||||
return {
|
||||
today: '2026-10-17',
|
||||
settings,
|
||||
dids: [],
|
||||
extensions: [ext('101', 'Alice'), ext('102', 'Bob')],
|
||||
};
|
||||
}
|
||||
|
||||
/** baresip config for one phone: G.711 µ-law, a sine tone as the microphone, auto-answer. */
|
||||
function phoneConfig(dir: string, ext: '101' | '102', port: number, toneHz: number) {
|
||||
const d = join(dir, `phone-${ext}`);
|
||||
spawnSync('mkdir', ['-p', d]);
|
||||
writeFileSync(
|
||||
join(d, 'config'),
|
||||
[
|
||||
'poll_method epoll',
|
||||
`sip_listen 0.0.0.0:${port}`,
|
||||
'module_path /usr/lib/baresip/modules',
|
||||
'module g711.so',
|
||||
'module ausine.so',
|
||||
'module aufile.so',
|
||||
'module menu.so',
|
||||
'module account.so',
|
||||
`audio_source ausine,${toneHz}`,
|
||||
'ausrc_srate 48000', // ausine only runs at 48 kHz; baresip resamples for G.711
|
||||
'auplay_srate 48000',
|
||||
`audio_player aufile,/phones/phone-${ext}/heard.wav`,
|
||||
'audio_alert aufile,/dev/null',
|
||||
'rtp_ports 30000-30100',
|
||||
'',
|
||||
].join('\n'),
|
||||
);
|
||||
writeFileSync(
|
||||
join(d, 'accounts'),
|
||||
`<sip:${ext}@${AST};transport=udp>;auth_pass=${PASS[ext]};answermode=auto;audio_codecs=PCMU;regint=60\n`,
|
||||
);
|
||||
}
|
||||
|
||||
async function main() {
|
||||
const dir = mkdtempSync(join(tmpdir(), 'sp-call-'));
|
||||
const conf = join(dir, 'conf');
|
||||
spawnSync('mkdir', ['-p', conf]);
|
||||
const files = render(snapshot());
|
||||
for (const f of GENERATED_FILES) writeFileSync(join(conf, f), files[f]);
|
||||
// Test-only manager.conf: reachable through the published port (the real one is 127.0.0.1-only).
|
||||
writeFileSync(
|
||||
join(dir, 'manager.conf.template'),
|
||||
'[general]\nenabled = yes\nport = 5038\nbindaddr = 0.0.0.0\n\n[selfphoneng]\nsecret = ${AMI_SECRET}\npermit = 0.0.0.0/0.0.0.0\nread = all\nwrite = all\n',
|
||||
);
|
||||
phoneConfig(dir, '101', 5070, 440);
|
||||
phoneConfig(dir, '102', 5072, 880);
|
||||
|
||||
const problems: string[] = [];
|
||||
let recorder: Socket | undefined;
|
||||
let raw = '';
|
||||
const ami = new AmiClient({
|
||||
host: '127.0.0.1',
|
||||
port: AMI_PORT,
|
||||
username: 'selfphoneng',
|
||||
secret: AMI_SECRET,
|
||||
logger: { info() {}, warn() {}, error() {}, debug() {} },
|
||||
backoffMs: [500],
|
||||
});
|
||||
try {
|
||||
docker('rm', '-f', AST, PHONES);
|
||||
docker('network', 'create', NET);
|
||||
const run = docker(
|
||||
'run',
|
||||
'-d',
|
||||
'--rm',
|
||||
'--name',
|
||||
AST,
|
||||
'--network',
|
||||
NET,
|
||||
'-p',
|
||||
`127.0.0.1:${AMI_PORT}:5038`,
|
||||
'-e',
|
||||
`AMI_SECRET=${AMI_SECRET}`,
|
||||
'-v',
|
||||
`${conf}:/etc/asterisk/selfphoneng`,
|
||||
'-v',
|
||||
`${join(dir, 'manager.conf.template')}:/etc/asterisk/manager.conf.template:ro`,
|
||||
IMAGE,
|
||||
);
|
||||
if (!run.ok) throw new Error(`asterisk: ${run.out}`);
|
||||
for (
|
||||
let i = 0;
|
||||
i < 60 && !docker('exec', AST, 'asterisk', '-rx', 'core waitfullybooted').ok;
|
||||
i++
|
||||
)
|
||||
await sleep(500);
|
||||
|
||||
ami.start();
|
||||
await new Promise((r) => ami.once('connected', r));
|
||||
log('AMI connected from the host');
|
||||
if (RECORD) {
|
||||
// A second, raw AMI session so the fixture holds exactly what Asterisk sent.
|
||||
recorder = new Socket();
|
||||
recorder.setEncoding('latin1');
|
||||
recorder.on('data', (d: string) => (raw += d));
|
||||
await new Promise<void>((r) => recorder!.connect(AMI_PORT, '127.0.0.1', r));
|
||||
recorder.write(
|
||||
`Action: Login\r\nUsername: selfphoneng\r\nSecret: ${AMI_SECRET}\r\nEvents: on\r\nActionID: rec-1\r\n\r\n`,
|
||||
);
|
||||
}
|
||||
const states: string[] = [];
|
||||
ami.on('event:ExtensionStatus', (m) => states.push(`${m.Exten}:${m.StatusText}`));
|
||||
|
||||
log('starting baresip phones (installs baresip on first run)…');
|
||||
const phones = docker(
|
||||
'run',
|
||||
'-d',
|
||||
'--rm',
|
||||
'--name',
|
||||
PHONES,
|
||||
'--network',
|
||||
NET,
|
||||
'-v',
|
||||
`${dir}:/phones`,
|
||||
'debian:trixie-slim',
|
||||
'sh',
|
||||
'-c',
|
||||
'apt-get update -qq >/dev/null && apt-get install -y -qq --no-install-recommends baresip-core >/dev/null 2>&1 && ' +
|
||||
'(baresip -f /phones/phone-101 > /phones/phone-101/log 2>&1 &) && ' +
|
||||
'(baresip -f /phones/phone-102 > /phones/phone-102/log 2>&1 &) && sleep 600',
|
||||
);
|
||||
if (!phones.ok) throw new Error(`phones: ${phones.out}`);
|
||||
|
||||
let contacts = '';
|
||||
for (let i = 0; i < 180; i++) {
|
||||
contacts = await ami.command('pjsip show contacts').catch(() => '');
|
||||
if (/101\/sip:.*Avail/.test(contacts) && /102\/sip:.*Avail/.test(contacts)) break;
|
||||
await sleep(1000);
|
||||
}
|
||||
if (!/101\/sip:.*Avail/.test(contacts) || !/102\/sip:.*Avail/.test(contacts))
|
||||
throw new Error(`phones did not register:\n${contacts}`);
|
||||
log('101 and 102 registered');
|
||||
// Real list responses with registered phones, for the live-state fixture.
|
||||
recorder?.write(
|
||||
'Action: PJSIPShowContacts\r\nActionID: rec-2\r\n\r\n' +
|
||||
'Action: ExtensionStateList\r\nActionID: rec-3\r\n\r\n',
|
||||
);
|
||||
|
||||
// 102 rings first (auto-answer), then the dialplan dials 101 like a normal internal call.
|
||||
await ami.action({
|
||||
Action: 'Originate',
|
||||
Channel: 'PJSIP/102',
|
||||
Context: 'sp-from-ext',
|
||||
Exten: '101',
|
||||
Priority: '1',
|
||||
CallerID: '"Bob" <102>',
|
||||
Async: 'true',
|
||||
});
|
||||
let channels = '';
|
||||
for (let i = 0; i < 30; i++) {
|
||||
await sleep(1000);
|
||||
channels = await ami.command('core show channels concise');
|
||||
if (
|
||||
channels.split('\n').filter((l) => l.startsWith('PJSIP/')).length >= 2 &&
|
||||
/Up!Dial/.test(channels)
|
||||
)
|
||||
break;
|
||||
}
|
||||
if (!/Up!Dial/.test(channels)) throw new Error(`call did not connect:\n${channels}`);
|
||||
log(`call up, holding ${CALL_SECONDS} s`);
|
||||
await sleep(CALL_SECONDS * 1000);
|
||||
|
||||
const stats = await ami.command('pjsip show channelstats');
|
||||
const rows = stats.split('\n').filter((l) => /\b10[12]-[0-9a-f]+\b/.test(l));
|
||||
if (rows.length < 2) problems.push(`expected 2 channels in channelstats:\n${stats}`);
|
||||
for (const r of rows) {
|
||||
// Columns: BridgeId ChannelId ........ UpTime.. Codec. Count Lost Pct Jitter Count Lost Pct Jitter RTT....
|
||||
const nums = r.trim().split(/\s+/);
|
||||
const ulaw = nums.indexOf('ulaw');
|
||||
const rx = Number(nums[ulaw + 1]);
|
||||
const tx = Number(nums[ulaw + 5]);
|
||||
log(`${nums[1]}: rx ${rx} packets, tx ${tx} packets`);
|
||||
// 50 packets/s for 20 ms frames: demand at least half of that both ways.
|
||||
if (!(rx > CALL_SECONDS * 25) || !(tx > CALL_SECONDS * 25))
|
||||
problems.push(`one-way or no audio on ${nums[1]}: rx ${rx}, tx ${tx}`);
|
||||
}
|
||||
for (const e of ['101', '102'])
|
||||
if (!states.includes(`${e}:InUse`))
|
||||
problems.push(`no ExtensionStatus InUse for ${e} (got ${states.join(', ')})`);
|
||||
|
||||
await ami.command('channel request hangup all');
|
||||
for (let i = 0; i < 10 && /PJSIP\//.test(await ami.command('core show channels concise')); i++)
|
||||
await sleep(500);
|
||||
await sleep(1000);
|
||||
if (!states.slice(-4).some((s) => s.endsWith(':Idle')))
|
||||
problems.push(`extensions did not return to Idle: ${states.join(', ')}`);
|
||||
// eslint-disable-next-line no-control-regex -- strips Asterisk's ANSI colors
|
||||
const plainLog = docker('logs', AST).out.replace(/\x1b\[[0-9;]*m/g, '');
|
||||
const errors = plainLog.split('\n').filter((l) => /ERROR\[/.test(l));
|
||||
problems.push(...errors.map((l) => `log: ${l.trim()}`));
|
||||
} catch (e) {
|
||||
problems.push((e as Error).message);
|
||||
} finally {
|
||||
if (RECORD && raw) {
|
||||
writeFileSync(RECORD, raw, 'latin1');
|
||||
log(`recorded ${raw.length} bytes of AMI to ${RECORD}`);
|
||||
}
|
||||
if (problems.length)
|
||||
for (const e of ['101', '102'])
|
||||
log(`phone ${e} log (tail):
|
||||
${docker('exec', PHONES, 'tail', '-n', '25', `/phones/phone-${e}/log`).out}`);
|
||||
recorder?.destroy();
|
||||
ami.stop();
|
||||
docker('rm', '-f', PHONES, AST);
|
||||
docker('network', 'rm', NET);
|
||||
rmSync(dir, { recursive: true, force: true });
|
||||
}
|
||||
if (problems.length) {
|
||||
console.log('FAIL register-and-call');
|
||||
for (const p of problems) console.log(` ${p}`);
|
||||
process.exit(1);
|
||||
}
|
||||
console.log('ok register-and-call (two-way audio)');
|
||||
}
|
||||
|
||||
await main();
|
||||
Reference in new issue
Block a user