Asterisk AGI managment by NodeJS

index.js

const net = require('net');
const lib = require('./lib');
const server = net.createServer();

server.on('connection', async socket => {
  const variables = await lib.dataAwaiting(socket);
  console.log('variables', variables.toString());
  const data1= await lib.request(socket, Buffer.from('ANSWER\n'));
  const data2 = await lib.request(socket, Buffer.from('SAY DIGITS 321 X\n'));
  const data3 = await lib.request(socket, Buffer.from('Hangup\n'));
  await socket.end();
  console.log(data1, data2, data3);
});

server.listen(3007);

lib.js

/**
 * Sends data and retrieves data to/from socket.
 *
 * @param socket
 * @param data
 * @returns {Promise<unknown>}
 */
const request = (socket, data) => {
  return new Promise(async (resolve, reject) => {
    socket.once('data', data => {
      resolve(data);
    });
    socket.once('error', error => {
      reject(error);
    });

    await socket.write(data);
  });
};

/**
 * Waits for data from the socket.
 *
 * @param socket
 * @returns {Promise<unknown>}
 */
const dataAwaiting = (socket) => {
  return new Promise((resolve) => {
    socket.once('data', (data) => {
      resolve(data);
    });
  });
};

module.exports = {
  request, dataAwaiting
};