Get mic audio stream in real time and send it vía websockets to a server

README.md

Dependencies

sox, node

On Ubuntu/Debian:

sudo apt install sox nodejs

On macOS:

brew install sox nodejs

Install and run

npm i

node server.mjs

The client can be another linux or macOS machine.

** WARNING! lower down your volume before running the example since it will produce echo **

node client.mjs

If you want to stream the audio to another device (e.g a raspberry pi intercom system) you can filter by meta.id on client.on('stream', (stream, meta) => ...)

client.mjs

import { BinaryClient } from 'binaryjs';
import { spawn } from 'child_process';

const SERVER_IP = '127.0.0.1';
const PORT = 9000;

const client = BinaryClient(`ws://${SERVER_IP}:${PORT}`);
const args = ['-d', '-q', '-b', '16', '-r', '44100', '-c', '2', '-t', 'wav','-'];
const speaker = spawn('play', ['-']);
const sox = spawn('sox', args);

client.on('open', () => {
  const stream = client.createStream();
  sox.stdout.on('data', chunk => {
    if (stream.writable) {
      stream.write(chunk)
    }
  });

  client.on('stream', (stream, meta) => {
    stream.on('data', data => speaker.stdin.write(data))
  });
});

process.on('SIGTERM', () => {
  sox.stdin.pause();
  sox.kill();
  client.close();
});

package.json

{
  "dependencies": {
    "binaryjs": "^0.2.1"
  },
  "author": "@mallendeo",
  "license": "MIT"
}

server.mjs

import { BinaryServer } from 'binaryjs';

const server = BinaryServer({ port: 9000 });
server.on('connection', client => {
  console.log('Client connected: ', client.id);
  client.on('stream', stream => {
    stream.on('data', data => {
      client.send(data, { id: client.id });
    });
  });
});

process.on('SIGTERM', () => {
  speaker.stdin.pause();
  speaker.kill();
});

Can you make some Readme file? Most people didn't know how to run this example.

@vuk2295 I just updated the example. It's from an old raspberry pi project, and it's very inefficient since it uses uncompressed raw audio.

@epic80 I never saw this comment until github notified me about @vuk2295 one, sorry about that 😓. This still works with the latest version of node. I don't remember if I ever made a repo for this.