yonle/openradio

Only some simple live stream library.

openradio

A simple live streaming library written in JavaScript with ffmpeg.

This library require ffmpeg to be installed in your system/container.

Documentation

• module(options)
  • Options
  • play(ReadableStream)
  • playPCM(ReadableStream, options)
  • Objects
    • stream
    • header
  • Events
• module.video(options, rtmp_url)
  • Options
  • play(ReadableStream)
  • Events
  • Objects
    • stream
    • header

module(options)

A function to create a new broadcaster. Return stream.Duplex.

Options

• format The radio audio format. Default is mp3.
• rate Radio audio samplerate. Default is 44100.
• channels Radio audio channels. Default is 2.
• bitrate Radio audio bitrate. Default is 192.
• acodec Radio audio codec. Default is mp3.

Functions

• play(ReadableStream) A function to play audio from ReadableStream or "string". A string could be a URL, or file path.
• playPCM(ReadableStream, options) A function to play PCM audio from ReadableStream or "string". A string could be a URL, or Filepath. Available options:

1. rate The PCM audio bitrate. The default is 44100.
2. channels The PCM audio channels. The default is 2.

Objects

• stream The source of current audio. Return ReadableStream.
• header The radio buffer header.

Events

Some of events from stream.Duplex also included here.

• error A event that emit some error when occured.
• finish A event that emit when finished playing the current song.

module.video(options, rtmp_url)

Just like the main function, But instead of audio, It's for broadcasting Video.

• rtmp_url RTMP url to stream (Optional).

Options

• format Radio video format. Default is mpegts.
• vcodec Radio video codec. This is different from format option. Default is mpeg2video.
• arate Radio video audio samplerate. Default is 44100.
• achannels Radio video audio channels. Default is 2.
• abitrate Radio video audio bitrate. Default is 192.
• acodec Radio video audio codec. Default is aac.
• scale Radio video scale. Default is -1:720 means the output video will have a width of 720px and the height will be set based on the ratio of the original video.

Functions

• play(ReadableStream) A function to play video from ReadableStream or "string". A string could be a URL, or file path.

Events

Some of events from stream.Duplex also included here.

• error A event that emit some error when occured.
• finish A event that emit when finished playing the current video.

Objects

Same as the main function.

module.repeater(radio)

Simply a repeater for ReadableStream. Suitable when you face some performance issue in single duplex. Return a function.

const fs = require("fs");
const openradio = require("openradio");
const radio = openradio(); // Broadcaster
const repeater = openradio.repeater(radio); // Create a repeater of "radio" duplex.

// The repeater is responsible in writting incomming buffer from "radio" duplex
// for multiple WriteableStream at the same time without decreasing the duplex performance.

let r1 = repeater(fs.createWriteStream("stream1.mp3"));
let r2 = repeater(fs.createWriteStream("stream2.mp3"));
let r3 = repeater(fs.createWriteStream("stream3.mp3"));

// Assume that we're enough writting buffers to fs.createWriteStream("stream2.mp3")
// And so we're gonna stop writting.
r2();

// Even though the repeater stop writting, It's WriteableStream is not ended.
// So you need to end them manually.

Example

See example folder

Community

• Telegram
• #yonle at irc.lecturify.net.

License

Copyright 2023 Yonle [email protected]

Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:

1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.

2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.

3. Neither the name of the copyright holder nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

openradio's Issues

Error: must bypass byte-per-second

This error can happend when you aren't provide any byte-per-second argument in player.play function.

Use video instead of audio

Hi, Your project gave me a lot of interesting ideas , thank you

I changed the code to play video instead of audio but i have some issues , help me please whats wrong

1. only first sink can play video
2. only one video support two videos not play
3. when refresh browser video not play at all

this is my code

const Throttle = require("throttle");
const ffmpeg = require("prism-media").FFmpeg;
const http = require("http");
const axios = require('axios');
const exec = require('child_process').exec;
let sink = new Map();
let port = process.argv.slice(2)[0] || 8000;
let stream;
let host;
let header;
process.title = "Video";

const server = http
    .createServer((req, res) => {
        if (!stream) play();
        let generateId = () => Math.random().toString(36).slice(2);
        let id =
            generateId() +
            generateId() +
            generateId() +
            generateId() +
            generateId() +
            generateId();
        res.setHeader("Content-Type", "video/mp4");
        console.log('New Sink Connected (${id})');
        console.log(
            "------------------------------------\nTotal Sink:",
            sink.size
        );
        if (header) res.write(header);
        sink.set(id, res);
        req.on("close", () => {
            console.log('Sink (${id}) Disconnected.');
            console.log(
                "------------------------------------\nTotal Sink:",
                sink.size
            );
            sink.delete(id);
        });

    })

    .listen(8090);


let mp4 = ["b.mp4", "a.mp4"];
var idd = -1;

function convert() {
    idd = idd + 1;
    if (idd > 1) {
        idd = 0;
    }
    return new ffmpeg({
        args: [
            "-i",
            mp4[idd],
            "-analyzeduration",
            "0",
            "-loglevel",
            "0",
            "-s",
            "1280x720",
            "-acodec",
            "aac",
            "-vcodec",
            "libx264",
            "-movflags",
            "frag_keyframe+empty_moov",
            "-f",
            "mp4",
            "-map_metadata",
            "-1"
        ],
    });
}


async function play() {
    let newSong = 1;
    if (stream) {
        if (stream.playing) return;
    }

    stream = convert().pipe(Throttle(400000));
    stream.on("data", (chunk) => {
        if (header && newSong) return newSong = 0;

        if (!header && newSong) {
            header = chunk;
            newSong = 0;
        }
        sink.forEach((s) => {
            s.write(chunk);
        });
    });
    stream.playing = true;
    stream.on("end", () => {
        if (!stream) return;
        if (stream.stopped) return;
        stream.playing = false;
        return play();
    });

    stream.on("error", (err) => {
        console.error("An error occured when playing Skipping....");
        return play();
    });

} 

Delayed Updates

We're delayed openradio updates by fixing some major issue, and improvement of openradio. this takes a time to finish. So please wait

problems when Playing .m4a files

when trying to play an .m4a file in the queue it skips it and moves onto the next song

Support for binding to an IP address?

Could you add support for binding to an IP address? On a VPS you can't access localhost.

FFMPEG Zombie Process

Hi

thanks for openradio :)

when i'm use skip command previous ffmpeg not destroy and script start new process how to solve this problem?

`end` events is never emitted

end event is never emitted when the song is Finished.

Repeater: Heap memory issue

In some of weird conditions, Openradio repeater could be ended up making the single nodes process to be died.

<--- Last few GCs --->

[2726:0x7aefe78340]    49397 ms: Scavenge 444.4 (454.3) -> 444.3 (455.8) MB, 9.6 / 0.0 ms  (average mu = 0.634, current mu = 0.563) allocation failure
[2726:0x7aefe78340]    52390 ms: Mark-sweep 460.2 (470.8) -> 449.7 (461.1) MB, 2960.8 / 0.0 ms  (average mu = 0.331, current mu = 0.018) allocation failure scavenge might not succeed


<--- JS stacktrace --->

FATAL ERROR: Reached heap limit Allocation failed - JavaScript heap out of memory

I myself also don't know what was going on. The repeater code itself is simple, Still i think something isn't right