midi_queue.h

/*
 * Copyright © 2026 Synthstrom Audible Limited
 *
 * This file is part of The Synthstrom Audible Deluge Firmware.
 *
 * The Synthstrom Audible Deluge Firmware is free software: you can redistribute it and/or modify it under the
 * terms of the GNU General Public License as published by the Free Software Foundation,
 * either version 3 of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */
 
#pragma once
 
#include "OSLikeStuff/timers_interrupts/clock_type.h"
#include "definitions_cxx.hpp"
#include "model/midi/message.h"
#include <cstddef>
#include <cstdint>
#include <etl/queue_spsc_atomic.h>

constexpr uint32_t kSystemTicksPerSampleQ8 = ((uint64_t)DELUGE_CLOCKS_PER << 8) / kSampleRate;

int32_t samplesTilWindowOffsetPlays(int32_t samplesBeforeLappingPlayHead, int32_t offset);

uint32_t dueAtWindowOffset(uint32_t windowStartTicks, int32_t samplesBeforeLappingPlayHead, int32_t offset);
 
struct QueuedMIDI {
    MIDIMessage message;
    int16_t filter;
    bool usb;
    bool din;
    uint32_t due; 
};
static_assert(sizeof(QueuedMIDI) == 12);

class MIDIQueue {
public:
    static constexpr size_t kCapacity = 256;
    static constexpr int32_t kMaxTicksAhead = DELUGE_CLOCKS_PER / 100;

    bool push(MIDIMessage message, int32_t filter, bool usb, bool din, uint32_t due, uint32_t now);

    bool popDue(QueuedMIDI& out, uint32_t now, bool all = false);

    bool popOldest(QueuedMIDI& out);

    bool nextDue(uint32_t& due);
 
    [[nodiscard]] bool empty() const { return queue_.empty(); }
    [[nodiscard]] bool full() const { return queue_.full(); }
    [[nodiscard]] size_t size() const { return queue_.size(); }
 
private:
    etl::queue_spsc_atomic<QueuedMIDI, kCapacity> queue_;
};