midi_panic_processor.h

// SPDX-FileCopyrightText: © 2025 Alexandros Theodotou <alex@zrythm.org>
// SPDX-License-Identifier: LicenseRef-ZrythmLicense
 
#pragma once
 
#include <atomic>
 
#include "dsp/processor_base.h"
 
namespace zrythm::dsp
{

class MidiPanicProcessor final : public QObject, public dsp::ProcessorBase
{
  Q_OBJECT
 
public:
  MidiPanicProcessor (
    utils::IObjectRegistry &registry,
    QObject *               parent = nullptr);

  void request_panic () { panic_.store (true); }
 
  // ============================================================================
  // ProcessorBase Interface
  // ============================================================================
 
  void custom_process_block (
    dsp::graph::ProcessBlockInfo time_nfo,
    const dsp::ITransport       &transport,
    const dsp::TempoMap         &tempo_map) noexcept override
  {
    const auto panic = panic_.exchange (false);
    if (!panic)
      return;
 
    // queue panic event
    midi_out_->midi_events_.queued_events_.panic_without_lock (
      time_nfo.buffer_offset_);
  }
 
  void custom_prepare_for_processing (
    const graph::GraphNode * node,
    units::sample_rate_t     sample_rate,
    units::sample_u32_t      max_block_length) override
  {
    midi_out_ = get_output_ports ().front ().get_object_as<dsp::MidiPort> ();
  }
 
  void custom_release_resources () override { midi_out_ = nullptr; }
 
  // ============================================================================
 
private:
  std::atomic_bool panic_;
 
  // Processing caches
  dsp::MidiPort * midi_out_{};
};
} // namespace zrythm::dsp