/// Translated from C to D
module soundio.dummy;

extern(C): @nogc: nothrow: __gshared:
import core.stdc.config: c_long, c_ulong;

import soundio.soundio_internal;
import soundio.os;
import soundio.api;
import soundio.atomics;
import soundio.soundio_private;

import soundio.ring_buffer: SoundIoRingBufferImpl, soundio_ring_buffer_deinit, soundio_ring_buffer_init;
import core.stdc.stdio;
import core.stdc..string;
import core.atomic;

struct SoundIoDummy {
    SoundIoOsMutex* mutex;
    SoundIoOsCond* cond;
    bool devices_emitted;
}

struct SoundIoDeviceDummy {
    int make_the_struct_not_empty;
}

struct SoundIoOutStreamDummy {
    SoundIoOsThread* thread;
    SoundIoOsCond* cond;
    SoundIoAtomicFlag abort_flag;
    double period_duration;
    int buffer_frame_count;
    int frames_left;
    int write_frame_count;
    SoundIoRingBufferImpl ring_buffer;
    auto ring_buffer_ptr() {return cast(SoundIoRingBuffer*) &ring_buffer;}
    double playback_start_time;
    SoundIoAtomicFlag clear_buffer_flag;
    SoundIoAtomicBool pause_requested;
    SoundIoChannelArea[SOUNDIO_MAX_CHANNELS] areas;
}

struct SoundIoInStreamDummy {
    SoundIoOsThread* thread;
    SoundIoOsCond* cond;
    SoundIoAtomicFlag abort_flag;
    double period_duration;
    int frames_left;
    int read_frame_count;
    int buffer_frame_count;
    SoundIoRingBufferImpl ring_buffer;
    auto ring_buffer_ptr() {return cast(SoundIoRingBuffer*) &ring_buffer;}
    SoundIoAtomicBool pause_requested;
    SoundIoChannelArea[SOUNDIO_MAX_CHANNELS] areas;
}

static void playback_thread_run(void* arg) {
    SoundIoOutStreamPrivate* os = cast(SoundIoOutStreamPrivate*)arg;
    SoundIoOutStream* outstream = &os.pub;
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;

    {
        int fill_bytes = soundio_ring_buffer_fill_count(osd.ring_buffer_ptr);
        int free_bytes = soundio_ring_buffer_capacity(osd.ring_buffer_ptr) - fill_bytes;
        int free_frames = free_bytes / outstream.bytes_per_frame;
        osd.frames_left = free_frames;
        if (free_frames > 0)
            outstream.write_callback(outstream, 0, free_frames);
    }
    double start_time = soundio_os_get_time();
    c_long frames_consumed = 0;

    while (SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(osd.abort_flag)) {
        double now = soundio_os_get_time();
        double time_passed = now - start_time;
        double next_period = start_time +
            ceil_dbl(time_passed / osd.period_duration) * osd.period_duration;
        double relative_time = next_period - now;
        soundio_os_cond_timed_wait(osd.cond, null, relative_time);
        if (!SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(osd.clear_buffer_flag)) {
            soundio_ring_buffer_clear(osd.ring_buffer_ptr);
            int free_bytes = soundio_ring_buffer_capacity(osd.ring_buffer_ptr);
            int free_frames = free_bytes / outstream.bytes_per_frame;
            osd.frames_left = free_frames;
            if (free_frames > 0)
                outstream.write_callback(outstream, 0, free_frames);
            frames_consumed = 0;
            start_time = soundio_os_get_time();
            continue;
        }

        if (SOUNDIO_ATOMIC_LOAD(osd.pause_requested)) {
            start_time = now;
            frames_consumed = 0;
            continue;
        }

        int fill_bytes = soundio_ring_buffer_fill_count(osd.ring_buffer_ptr);
        int fill_frames = fill_bytes / outstream.bytes_per_frame;
        int free_bytes = soundio_ring_buffer_capacity(osd.ring_buffer_ptr) - fill_bytes;
        int free_frames = free_bytes / outstream.bytes_per_frame;

        double total_time = soundio_os_get_time() - start_time;
        c_long total_frames = cast(c_long) (total_time * outstream.sample_rate);
        int frames_to_kill = cast(int) (total_frames - frames_consumed);
        int read_count = soundio_int_min(frames_to_kill, fill_frames);
        int byte_count = read_count * outstream.bytes_per_frame;
        soundio_ring_buffer_advance_read_ptr(osd.ring_buffer_ptr, byte_count);
        frames_consumed += read_count;

        if (frames_to_kill > fill_frames) {
            outstream.underflow_callback(outstream);
            osd.frames_left = free_frames;
            if (free_frames > 0)
                outstream.write_callback(outstream, 0, free_frames);
            frames_consumed = 0;
            start_time = soundio_os_get_time();
        } else if (free_frames > 0) {
            osd.frames_left = free_frames;
            outstream.write_callback(outstream, 0, free_frames);
        }
    }
}

static void capture_thread_run(void* arg) {
    SoundIoInStreamPrivate* is_ = cast(SoundIoInStreamPrivate*)arg;
    SoundIoInStream* instream = &is_.pub;
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;

    c_long frames_consumed = 0;
    double start_time = soundio_os_get_time();
    while (SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(isd.abort_flag)) {
        double now = soundio_os_get_time();
        double time_passed = now - start_time;
        double next_period = start_time +
            ceil_dbl(time_passed / isd.period_duration) * isd.period_duration;
        double relative_time = next_period - now;
        soundio_os_cond_timed_wait(isd.cond, null, relative_time);

        if (SOUNDIO_ATOMIC_LOAD(isd.pause_requested)) {
            start_time = now;
            frames_consumed = 0;
            continue;
        }

        int fill_bytes = soundio_ring_buffer_fill_count(isd.ring_buffer_ptr);
        int free_bytes = soundio_ring_buffer_capacity(isd.ring_buffer_ptr) - fill_bytes;
        int fill_frames = fill_bytes / instream.bytes_per_frame;
        int free_frames = free_bytes / instream.bytes_per_frame;

        double total_time = soundio_os_get_time() - start_time;
        c_long total_frames = cast(c_long) (total_time * instream.sample_rate);
        int frames_to_kill = cast(int) (total_frames - frames_consumed);
        int write_count = soundio_int_min(frames_to_kill, free_frames);
        int byte_count = write_count * instream.bytes_per_frame;
        soundio_ring_buffer_advance_write_ptr(isd.ring_buffer_ptr, byte_count);
        frames_consumed += write_count;

        if (frames_to_kill > free_frames) {
            instream.overflow_callback(instream);
            frames_consumed = 0;
            start_time = soundio_os_get_time();
        }
        if (fill_frames > 0) {
            isd.frames_left = fill_frames;
            instream.read_callback(instream, 0, fill_frames);
        }
    }
}

static void destroy_dummy(SoundIoPrivate* si) {
    SoundIoDummy* sid = &si.backend_data.dummy;

    if (sid.cond)
        soundio_os_cond_destroy(sid.cond);

    if (sid.mutex)
        soundio_os_mutex_destroy(sid.mutex);
}

static void flush_events_dummy(SoundIoPrivate* si) {
    SoundIo* soundio = &si.pub;
    SoundIoDummy* sid = &si.backend_data.dummy;
    if (sid.devices_emitted)
        return;
    sid.devices_emitted = true;
    soundio.on_devices_change(soundio);
}

static void wait_events_dummy(SoundIoPrivate* si) {
    SoundIoDummy* sid = &si.backend_data.dummy;
    flush_events_dummy(si);
    soundio_os_cond_wait(sid.cond, null);
}

static void wakeup_dummy(SoundIoPrivate* si) {
    SoundIoDummy* sid = &si.backend_data.dummy;
    soundio_os_cond_signal(sid.cond, null);
}

static void force_device_scan_dummy(SoundIoPrivate* si) {
    // nothing to do; dummy devices never change
}

static void outstream_destroy_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;

    if (osd.thread) {
        SOUNDIO_ATOMIC_FLAG_CLEAR(osd.abort_flag);
        soundio_os_cond_signal(osd.cond, null);
        soundio_os_thread_destroy(osd.thread);
        osd.thread = null;
    }
    soundio_os_cond_destroy(osd.cond);
    osd.cond = null;

    soundio_ring_buffer_deinit(osd.ring_buffer_ptr);
}

static int outstream_open_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    SoundIoOutStream* outstream = &os.pub;
    SoundIoDevice* device = outstream.device;

    SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(osd.clear_buffer_flag);
    SOUNDIO_ATOMIC_STORE(osd.pause_requested, false);

    if (outstream.software_latency == 0.0) {
        outstream.software_latency = soundio_double_clamp(
                device.software_latency_min, 1.0, device.software_latency_max);
    }

    osd.period_duration = outstream.software_latency / 2.0;

    int buffer_size = cast(int) (outstream.bytes_per_frame * outstream.sample_rate * outstream.software_latency);
    if (auto err = soundio_ring_buffer_init(osd.ring_buffer_ptr, buffer_size)) {
        outstream_destroy_dummy(si, os);
        return err;
    }
    int actual_capacity = soundio_ring_buffer_capacity(osd.ring_buffer_ptr);
    osd.buffer_frame_count = actual_capacity / outstream.bytes_per_frame;
    outstream.software_latency = osd.buffer_frame_count / cast(double) outstream.sample_rate;

    osd.cond = soundio_os_cond_create();
    if (!osd.cond) {
        outstream_destroy_dummy(si, os);
        return SoundIoError.NoMem;
    }

    return 0;
}

static int outstream_pause_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os, bool pause) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    SOUNDIO_ATOMIC_STORE(osd.pause_requested, pause);
    return 0;
}

static int outstream_start_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    SoundIo* soundio = &si.pub;
    assert(!osd.thread);
    SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(osd.abort_flag);
    if (auto err = soundio_os_thread_create(&playback_thread_run, os,
                    soundio.emit_rtprio_warning, &osd.thread))
    {
        return err;
    }
    return 0;
}

static int outstream_begin_write_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os, SoundIoChannelArea** out_areas, int* frame_count) {
    SoundIoOutStream* outstream = &os.pub;
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;

    if (*frame_count > osd.frames_left)
        return SoundIoError.Invalid;

    char* write_ptr = soundio_ring_buffer_write_ptr(osd.ring_buffer_ptr);
    for (int ch = 0; ch < outstream.layout.channel_count; ch += 1) {
        osd.areas[ch].ptr = write_ptr + outstream.bytes_per_sample * ch;
        osd.areas[ch].step = outstream.bytes_per_frame;
    }

    osd.write_frame_count = *frame_count;
    *out_areas = osd.areas.ptr;
    return 0;
}

static int outstream_end_write_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    SoundIoOutStream* outstream = &os.pub;
    int byte_count = osd.write_frame_count * outstream.bytes_per_frame;
    soundio_ring_buffer_advance_write_ptr(osd.ring_buffer_ptr, byte_count);
    osd.frames_left -= osd.write_frame_count;
    return 0;
}

static int outstream_clear_buffer_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os) {
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    SOUNDIO_ATOMIC_FLAG_CLEAR(osd.clear_buffer_flag);
    soundio_os_cond_signal(osd.cond, null);
    return 0;
}

static int outstream_get_latency_dummy(SoundIoPrivate* si, SoundIoOutStreamPrivate* os, double* out_latency) {
    SoundIoOutStream* outstream = &os.pub;
    SoundIoOutStreamDummy* osd = &os.backend_data.dummy;
    int fill_bytes = soundio_ring_buffer_fill_count(osd.ring_buffer_ptr);

    *out_latency = (fill_bytes / outstream.bytes_per_frame) / cast(double)outstream.sample_rate;
    return 0;
}

static void instream_destroy_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_) {
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;

    if (isd.thread) {
        SOUNDIO_ATOMIC_FLAG_CLEAR(isd.abort_flag);
        soundio_os_cond_signal(isd.cond, null);
        soundio_os_thread_destroy(isd.thread);
        isd.thread = null;
    }
    soundio_os_cond_destroy(isd.cond);
    isd.cond = null;

    soundio_ring_buffer_deinit(isd.ring_buffer_ptr);
}

static int instream_open_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_) {
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;
    SoundIoInStream* instream = &is_.pub;
    SoundIoDevice* device = instream.device;

    SOUNDIO_ATOMIC_STORE(isd.pause_requested, false);

    if (instream.software_latency == 0.0) {
        instream.software_latency = soundio_double_clamp(
                device.software_latency_min, 1.0, device.software_latency_max);
    }

    isd.period_duration = instream.software_latency;

    double target_buffer_duration = isd.period_duration * 4.0;

    int buffer_size = cast(int) (instream.bytes_per_frame * instream.sample_rate * target_buffer_duration);
    if (auto err = soundio_ring_buffer_init(isd.ring_buffer_ptr, buffer_size)) {
        instream_destroy_dummy(si, is_);
        return err;
    }

    int actual_capacity = soundio_ring_buffer_capacity(isd.ring_buffer_ptr);
    isd.buffer_frame_count = actual_capacity / instream.bytes_per_frame;

    isd.cond = soundio_os_cond_create();
    if (!isd.cond) {
        instream_destroy_dummy(si, is_);
        return SoundIoError.NoMem;
    }

    return 0;
}

static int instream_pause_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_, bool pause) {
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;
    SOUNDIO_ATOMIC_STORE(isd.pause_requested, pause);
    return 0;
}

static int instream_start_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_) {
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;
    SoundIo* soundio = &si.pub;
    assert(!isd.thread);
    SOUNDIO_ATOMIC_FLAG_TEST_AND_SET(isd.abort_flag);
    if (auto err = soundio_os_thread_create(&capture_thread_run, is_,
                    soundio.emit_rtprio_warning, &isd.thread))
    {
        return err;
    }
    return 0;
}

static int instream_begin_read_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_, SoundIoChannelArea** out_areas, int* frame_count) {
    SoundIoInStream* instream = &is_.pub;
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;

    assert(*frame_count <= isd.frames_left);

    char* read_ptr = soundio_ring_buffer_read_ptr(isd.ring_buffer_ptr);
    for (int ch = 0; ch < instream.layout.channel_count; ch += 1) {
        isd.areas[ch].ptr = read_ptr + instream.bytes_per_sample * ch;
        isd.areas[ch].step = instream.bytes_per_frame;
    }

    isd.read_frame_count = *frame_count;
    *out_areas = isd.areas.ptr;

    return 0;
}

static int instream_end_read_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_) {
    SoundIoInStreamDummy* isd = &is_.backend_data.dummy;
    SoundIoInStream* instream = &is_.pub;
    int byte_count = isd.read_frame_count * instream.bytes_per_frame;
    soundio_ring_buffer_advance_read_ptr(isd.ring_buffer_ptr, byte_count);
    isd.frames_left -= isd.read_frame_count;
    return 0;
}

static int instream_get_latency_dummy(SoundIoPrivate* si, SoundIoInStreamPrivate* is_, double* out_latency) {
    SoundIoInStream* instream = &is_.pub;
    SoundIoInStreamDummy* osd = &is_.backend_data.dummy;
    int fill_bytes = soundio_ring_buffer_fill_count(osd.ring_buffer_ptr);

    *out_latency = (fill_bytes / instream.bytes_per_frame) / cast(double)instream.sample_rate;
    return 0;
}

extern(D) int set_all_device_formats(SoundIoDevice* device) {
    device.format_count = 18;
    device.formats = ALLOCATE!SoundIoFormat(device.format_count);
    if (!device.formats)
        return SoundIoError.NoMem;

    device.formats[0] = SoundIoFormat.Float32NE;
    device.formats[1] = SoundIoFormat.Float32FE;
    device.formats[2] = SoundIoFormat.S32NE;
    device.formats[3] = SoundIoFormat.S32FE;
    device.formats[4] = SoundIoFormat.U32NE;
    device.formats[5] = SoundIoFormat.U32FE;
    device.formats[6] = SoundIoFormat.S24NE;
    device.formats[7] = SoundIoFormat.S24FE;
    device.formats[8] = SoundIoFormat.U24NE;
    device.formats[9] = SoundIoFormat.U24FE;
    device.formats[10] = SoundIoFormat.Float64NE;
    device.formats[11] = SoundIoFormat.Float64FE;
    device.formats[12] = SoundIoFormat.S16NE;
    device.formats[13] = SoundIoFormat.S16FE;
    device.formats[14] = SoundIoFormat.U16NE;
    device.formats[15] = SoundIoFormat.U16FE;
    device.formats[16] = SoundIoFormat.S8;
    device.formats[17] = SoundIoFormat.U8;

    return 0;
}

extern(D) void set_all_device_sample_rates(SoundIoDevice* device) {
    SoundIoDevicePrivate* dev = cast(SoundIoDevicePrivate*)device;
    device.sample_rate_count = 1;
    device.sample_rates = &dev.prealloc_sample_rate_range;
    device.sample_rates[0].min = SOUNDIO_MIN_SAMPLE_RATE;
    device.sample_rates[0].max = SOUNDIO_MAX_SAMPLE_RATE;
}

extern(D) int set_all_device_channel_layouts(SoundIoDevice* device) {
    device.layout_count = soundio_channel_layout_builtin_count();
    device.layouts = ALLOCATE!SoundIoChannelLayout(device.layout_count);
    if (!device.layouts)
        return SoundIoError.NoMem;
    for (int i = 0; i < device.layout_count; i += 1)
        device.layouts[i] = *soundio_channel_layout_get_builtin(i);
    return 0;
}

int soundio_dummy_init(SoundIoPrivate* si) {
    SoundIo* soundio = &si.pub;
    SoundIoDummy* sid = &si.backend_data.dummy;

    sid.mutex = soundio_os_mutex_create();
    if (!sid.mutex) {
        destroy_dummy(si);
        return SoundIoError.NoMem;
    }

    sid.cond = soundio_os_cond_create();
    if (!sid.cond) {
        destroy_dummy(si);
        return SoundIoError.NoMem;
    }

    assert(!si.safe_devices_info);
    si.safe_devices_info = ALLOCATE!SoundIoDevicesInfo(1);
    if (!si.safe_devices_info) {
        destroy_dummy(si);
        return SoundIoError.NoMem;
    }

    si.safe_devices_info.default_input_index = 0;
    si.safe_devices_info.default_output_index = 0;

    // create output device
    {
        SoundIoDevicePrivate* dev = ALLOCATE!SoundIoDevicePrivate(1);
        if (!dev) {
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }
        SoundIoDevice* device = &dev.pub;

        device.ref_count = 1;
        device.soundio = soundio;
        device.id = strdup("dummy-out");
        device.name = strdup("Dummy Output Device");
        if (!device.id || !device.name) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }

        if (auto err = set_all_device_channel_layouts(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return err;
        }
        if (auto err = set_all_device_formats(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return err;
        }
        set_all_device_sample_rates(device);

        device.software_latency_current = 0.1;
        device.software_latency_min = 0.01;
        device.software_latency_max = 4.0;

        device.sample_rate_current = 48000;
        device.aim = SoundIoDeviceAim.Output;

        if (si.safe_devices_info.output_devices.append(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }
    }

    // create input device
    {
        SoundIoDevicePrivate* dev = ALLOCATE!SoundIoDevicePrivate(1);
        if (!dev) {
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }
        SoundIoDevice* device = &dev.pub;

        device.ref_count = 1;
        device.soundio = soundio;
        device.id = strdup("dummy-in");
        device.name = strdup("Dummy Input Device");
        if (!device.id || !device.name) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }

        if (auto err = set_all_device_channel_layouts(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return err;
        }

        if (auto err = set_all_device_formats(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return err;
        }
        set_all_device_sample_rates(device);
        device.software_latency_current = 0.1;
        device.software_latency_min = 0.01;
        device.software_latency_max = 4.0;
        device.sample_rate_current = 48000;
        device.aim = SoundIoDeviceAim.Input;

        if (si.safe_devices_info.input_devices.append(device)) {
            soundio_device_unref(device);
            destroy_dummy(si);
            return SoundIoError.NoMem;
        }
    }

    si.destroy = &destroy_dummy;
    si.flush_events = &flush_events_dummy;
    si.wait_events = &wait_events_dummy;
    si.wakeup = &wakeup_dummy;
    si.force_device_scan = &force_device_scan_dummy;

    si.outstream_open = &outstream_open_dummy;
    si.outstream_destroy = &outstream_destroy_dummy;
    si.outstream_start = &outstream_start_dummy;
    si.outstream_begin_write = &outstream_begin_write_dummy;
    si.outstream_end_write = &outstream_end_write_dummy;
    si.outstream_clear_buffer = &outstream_clear_buffer_dummy;
    si.outstream_pause = &outstream_pause_dummy;
    si.outstream_get_latency = &outstream_get_latency_dummy;

    si.instream_open = &instream_open_dummy;
    si.instream_destroy = &instream_destroy_dummy;
    si.instream_start = &instream_start_dummy;
    si.instream_begin_read = &instream_begin_read_dummy;
    si.instream_end_read = &instream_end_read_dummy;
    si.instream_pause = &instream_pause_dummy;
    si.instream_get_latency = &instream_get_latency_dummy;

    return 0;
}