src/browser/speaker.js

"use strict";

/**
 * Note: Uses AudioContext.createScriptProcessor, which is deprecated,
 * but which no satisfactory substitute is availble.
 * @constructor
 * @param {BusConnector} bus
 * @suppress {deprecated}
 */
function SpeakerAdapter(bus)
{
    if(typeof window === "undefined")
    {
        return;
    }
    if(!window.AudioContext && !window.webkitAudioContext)
    {
        console.warn("Web browser doesn't support Web Audio API");
        return;
    }

    /** @const @type {BusConnector} */
    this.bus = bus;

    this.audio_context = new (window.AudioContext || window.webkitAudioContext)();

    this.beep_gain = this.audio_context.createGain();
    this.beep_gain.gain.setValueAtTime(0, this.audio_context.currentTime);
    this.beep_gain.connect(this.audio_context.destination);

    this.beep_oscillator = this.audio_context.createOscillator();
    this.beep_oscillator.type = "square";
    this.beep_oscillator.frequency.setValueAtTime(440, this.audio_context.currentTime);
    this.beep_oscillator.connect(this.beep_gain);
    this.beep_oscillator.start();

    this.beep_playing = false;
    this.beep_enable = false;
    this.beep_frequency = 440;
    this.pit_enabled = false;

    this.dac_processor = this.audio_context.createScriptProcessor(2048, 0, 2);
    this.dac_processor.onaudioprocess = this.dac_process.bind(this);
    this.dac_processor.connect(this.audio_context.destination);
    this.dac_buffer0 = new Float32Array(this.dac_processor.bufferSize);
    this.dac_buffer1 = new Float32Array(this.dac_processor.bufferSize);
    this.dac_enabled = true;

    bus.register("pcspeaker-enable", function(yesplease)
    {
        this.beep_enable = yesplease;
        this.beep_update();
    }, this);

    bus.register("pcspeaker-update", function(data)
    {
        var counter_mode = data[0];
        var counter_reload = data[1];
        this.pit_enabled = counter_mode == 3;
        this.beep_frequency = OSCILLATOR_FREQ * 1000 / counter_reload;
        this.beep_update();
    }, this);

    bus.register("speaker-update-data", function(data)
    {
        this.dac_buffer0 = data[0];
        this.dac_buffer1 = data[1];
    }, this);

    bus.register("speaker-request-samplerate", function()
    {
        bus.send("speaker-tell-samplerate", this.audio_context.sampleRate);
    }, this);

    bus.send("speaker-tell-samplerate", this.audio_context.sampleRate);

    bus.register("speaker-update-enable", function(enabled)
    {
        if(this.dac_enabled && !enabled)
        {
            this.dac_processor.disconnect(this.audio_context.destination);
            this.dac_enabled = false;
        }
        else if(!this.dac_enabled && enabled)
        {
            this.dac_processor.connect(this.audio_context.destination);
            this.dac_enabled = true;
        }
    }, this);

    if(DEBUG)
    {
        this.debug_dac = false;
        this.debug_dac_out = [];
        window["speaker_debug_dac_out"] = this.debug_dac_out;
        window["speaker_debug_start"] = () =>
        {
            this.debug_dac = true;
            setTimeout(() =>
            {
                this.debug_dac = false;
            },250);
        }
    }
}

SpeakerAdapter.prototype.beep_update = function()
{
    var current_time = this.audio_context.currentTime;

    if(this.pit_enabled && this.beep_enable)
    {
        this.beep_oscillator.frequency.setValueAtTime(this.beep_frequency, current_time);
        if(!this.beep_playing)
        {
            this.beep_gain.gain.setValueAtTime(1, current_time);
            this.beep_playing = true;
        }
    }
    else if(this.beep_playing)
    {
        this.beep_gain.gain.setValueAtTime(0, current_time);
        this.beep_playing = false;
    }
};

SpeakerAdapter.prototype.dac_process = function(event)
{
    if(!this.dac_enabled)
    {
        return;
    }

    var out = event.outputBuffer;

    out.copyToChannel(this.dac_buffer0, 0);
    out.copyToChannel(this.dac_buffer1, 1);

    this.bus.send("speaker-request-data", out.length);

    if(DEBUG)
    {
        if(this.debug_dac)
        {
            this.debug_dac_out.push(event.outputBuffer.getChannelData(0).slice());
        }
    }
};