port_observation_manager.h

// SPDX-FileCopyrightText: © 2026 Alexandros Theodotou <alex@zrythm.org>
// SPDX-License-Identifier: LicenseRef-ZrythmLicense
 
#pragma once
 
#include <memory>
#include <span>
#include <unordered_map>
#include <vector>
 
#include "dsp/port.h"
 
#include <QObject>
#include <QtQmlIntegration/qqmlintegration.h>
 
namespace zrythm::dsp
{
 
class PortObserver;
struct PortObservationCache;

class PortObservationManager : public QObject
{
  Q_OBJECT
  QML_ELEMENT
  QML_UNCREATABLE ("")
 
public:
  using RegistrationId = int;
 
  PortObservationManager (
    utils::IObjectRegistry &registry,
    QObject *               parent = nullptr);
 
  ~PortObservationManager () override;
 
  Q_DISABLE_COPY_MOVE (PortObservationManager)
 
  // Called by ObservationToken on construction/destruction
  RegistrationId register_request (const Port &port);
  void           unregister_request (RegistrationId id);
 
  // Cache access for registered requesters
  PortObservationCache &cache (RegistrationId id);
 
  // Called by graph builder during build
  PortObserver * get_observer (const Port &port) const;
 
  // Called by graph builder during build
  std::span<PortObserver * const> observers () const;
 
  // For testing — manually triggers drain
  void drain_all ();
 
Q_SIGNALS:
  void observationChanged ();
 
private:
  PortObserver * find_observer_by_uuid (const PortUuid &port_uuid) const;
 
  struct Impl;
  std::unique_ptr<Impl> impl_;
};
 
}