channel_subgraph_builder.h

// SPDX-FileCopyrightText: © 2025-2026 Alexandros Theodotou <alex@zrythm.org>
// SPDX-License-Identifier: LicenseRef-ZrythmLicense
 
#pragma once
 
#include "dsp/graph.h"
#include "structure/tracks/channel.h"
#include "utils/views.h"
 
namespace zrythm::structure::tracks
{
class ChannelSubgraphBuilder
{
public:
  static void add_nodes (dsp::graph::Graph &graph, Channel &ch);

  static void add_connections (
    dsp::graph::Graph     &graph,
    Channel               &ch,
    dsp::PortUuidReference track_processor_output);

  template <dsp::FinalPortSubclass T>
  static void add_connection_for_ports (
    dsp::graph::Graph &graph,
    const T           &src_port,
    const T           &dest_port)
  {
    auto * src = graph.get_nodes ().find_node_for_processable (src_port);
    auto * dest = graph.get_nodes ().find_node_for_processable (dest_port);
    assert (src);
    assert (dest);
    assert (src != dest && "Cannot connect a port to itself");
    assert (src_port.is_output () && "Source port must be an output port");
    assert (dest_port.is_input () && "Destination port must be an input port");
    src->connect_to (*dest);
  }

  static bool connect_like_ports (
    dsp::graph::Graph                                 &graph,
    const utils::RangeOf<dsp::PortUuidReference> auto &src_refs,
    const utils::RangeOf<dsp::PortUuidReference> auto &dest_refs)
  {
    const auto object_getter = [] (auto &&port_ref) { return port_ref.get (); };
    const auto src_output_ports =
      src_refs | std::views::transform (object_getter);
    const auto dest_input_ports =
      dest_refs | std::views::transform (object_getter);
 
    using utils::views::qobject_cast_and_filter;
    auto src_midi_out_ports =
      src_output_ports | qobject_cast_and_filter<dsp::MidiPort>;
    auto dest_midi_in_ports =
      dest_input_ports | qobject_cast_and_filter<dsp::MidiPort>;
    auto src_audio_out_ports =
      src_output_ports | qobject_cast_and_filter<dsp::AudioPort>;
    auto dest_audio_in_ports =
      dest_input_ports | qobject_cast_and_filter<dsp::AudioPort>;
    auto src_cv_out_ports =
      src_output_ports | qobject_cast_and_filter<dsp::CVPort>;
    auto dest_cv_in_ports =
      dest_input_ports | qobject_cast_and_filter<dsp::CVPort>;
 
    bool       connections_made{};
    const auto make_conns = [&connections_made, &graph] (const auto &ports) {
      const auto &[src_port, dest_port] = ports;
      add_connection_for_ports (graph, *src_port, *dest_port);
      connections_made = true;
    };
 
    std::ranges::for_each (
      std::views::zip (src_midi_out_ports, dest_midi_in_ports), make_conns);
    std::ranges::for_each (
      std::views::zip (src_audio_out_ports, dest_audio_in_ports), make_conns);
    std::ranges::for_each (
      std::views::zip (src_cv_out_ports, dest_cv_in_ports), make_conns);
 
    return connections_made;
  }
};
} // namespace zrythm::structure::tracks