Asterisk Gateway Interface Server

A TypeScript implementation of an Asterisk Gateway Interface (AGI) server for building voice applications with Asterisk.

Requirements

• Node.js >= 22

Installation

npm install @gibme/asterisk-gateway-interface
Copy

yarn add @gibme/asterisk-gateway-interface
Copy

Documentation

Full API documentation is available at https://gibme-npm.github.io/asterisk-gateway-interface/

Quick Start

import AGI, { Channel } from '@gibme/asterisk-gateway-interface';

const agi = new AGI(3000, '0.0.0.0');

agi.on('channel', async (channel: Channel) => {
    await channel.answer();
    await channel.sayNumber(12345);
    await channel.hangup();
});

await agi.start();
Copy

Then configure your Asterisk dialplan to route calls to the AGI server:

exten => 100,1,AGI(agi://127.0.0.1:3000)
Copy

Usage

Creating a Server

import AGI from '@gibme/asterisk-gateway-interface';

// new AGI(port, ip, maximumListeners)
const agi = new AGI(3000, '0.0.0.0', 20);

agi.on('channel', async (channel) => {
    // Handle incoming AGI channels
});

agi.on('error', (error) => {
    console.error('Server error:', error);
});

agi.on('close', () => {
    console.log('Server closed');
});

await agi.start();

// Later, to stop the server:
await agi.stop();
Copy

Working with Channels

Each incoming AGI connection emits a channel event with a Channel instance that provides the full AGI command set:

Call Control

agi.on('channel', async (channel) => {
    // Answer the channel
    await channel.answer();

    // Hang up when done
    await channel.hangup();
});
Copy

Playing Audio

// Play a sound file (allow caller to interrupt with '#')
await channel.streamFile('welcome', '#');

// Play with finer control over playback position
await channel.controlStreamFile('instructions', '#', 3000, '*', '#', '#');

// Say things
await channel.sayNumber(42);
await channel.sayDigits(12345, '#');
await channel.sayAlpha('hello', '#');
await channel.sayPhonetic('world', '#');
await channel.sayDate(Math.floor(Date.now() / 1000));
await channel.sayTime(Math.floor(Date.now() / 1000));
Copy

Collecting Input

// Get digits from the caller
const response = await channel.getData('enter-account-number', 5000, 10);

// Wait for a single digit
const digit = await channel.waitForDigit(5000);

// Get a single key during audio playback
const option = await channel.getOption('press-one-for-sales', '#', 5000);

// Receive text (for text-capable channels)
const text = await channel.receiveText(5000);
Copy

Dialing

import { Channel, Driver } from '@gibme/asterisk-gateway-interface';

const result = await channel.dial(
    Driver.PJSIP,   // Channel driver
    '1001',          // Destination
    30,              // Timeout in seconds
    'tT'             // Dial options
);

if (result.status === Channel.Dial.Status.ANSWER) {
    console.log('Call was answered');
}
Copy

Database Operations

// Asterisk DB operations
await channel.databasePut('family', 'key', 'value');
const value = await channel.databaseGet('family', 'key');
await channel.databaseDel('family', 'key');
await channel.databaseDelTree('family');
Copy

Channel Variables

// Set and get channel variables
await channel.setVariable('MY_VAR', 'some_value');
const value = await channel.getVariable('MY_VAR');
const fullValue = await channel.getFullVariable('${CALLERID(num)}');
Copy

Recording

// Record audio to a file
await channel.recordFile(
    '/tmp/recording',  // Filename (without extension)
    'wav',             // Format
    '#',               // Escape digits
    30000,             // Max duration (ms)
    undefined,         // Offset
    true,              // Beep before recording
    undefined          // Silence threshold
);
Copy

SIP/PJSIP Headers

// Add, get, and remove SIP headers (works with SIP, PJSIP, and IAX2 channels)
await channel.addHeader('X-Custom-Header', 'my-value');
const header = await channel.getHeader('X-Custom-Header');
await channel.removeHeader('X-Custom-Header');
Copy

Channel Properties

The Channel object exposes Asterisk AGI environment variables as properties:

agi.on('channel', async (channel) => {
    console.log(channel.callerid);       // Caller ID number
    console.log(channel.calleridname);   // Caller ID name
    console.log(channel.callingpres);    // Calling presentation
    console.log(channel.channel);        // Channel name (e.g., "PJSIP/1000-00000001")
    console.log(channel.context);        // Dialplan context
    console.log(channel.extension);      // Dialplan extension
    console.log(channel.priority);       // Dialplan priority
    console.log(channel.uniqueid);       // Unique channel ID
    console.log(channel.accountcode);    // Account code
    console.log(channel.language);       // Channel language
    console.log(channel.channelType);    // Channel driver type (Driver enum)
    console.log(channel.network);        // Whether this is a network AGI request
    console.log(channel.network_script); // Network script path
});
Copy

Exports

import AGI, {
    AsteriskGatewayInterface, // AGI server class (same as default export)
    Channel,                  // Channel class with full AGI command set
    Driver,                   // Channel driver enum (PJSIP, SIP, IAX2, etc.)
    ContextState,             // Channel context state enum
    ResponseArguments         // Parsed AGI response arguments
} from '@gibme/asterisk-gateway-interface';
Copy

License

MIT