SoundSet.hpp

#pragma once
#include <Media/AudioArray.hpp>
 
#include <halp/sound_set.hpp>
 
#include <QDateTime>
#include <QFileSystemWatcher>
#include <QObject>
#include <QStringList>
#include <QTimer>
 
#include <score_plugin_avnd_export.h>
 
#include <atomic>
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
namespace oscr
{
struct SoundSetOptions
{
  QStringList extensions; 
  bool recursive{};
  halp::sound_decoding decoding{};
  int rate{};
};
 
struct SoundSetEntry
{
  QString path;     
  std::string name; 
  QDateTime modified;
  qint64 size{};
 
  Media::audio_array data;
  std::vector<const float*> channels;
  int rate{};
  halp::sound_status status{};
 
  std::atomic<int32_t> pins{0};
  std::atomic<bool> requested{false};
};
 
struct SoundSetSnapshot
{
  std::vector<std::shared_ptr<SoundSetEntry>> entries;
  std::vector<halp::sound_view> views;
  std::string folder;
  uint64_t generation{};
 
  std::atomic<bool> superseded{false};
 
  void make_views();
  halp::sound_set_view view() const noexcept
  {
    return {views, folder, generation};
  }
};
 
class SCORE_PLUGIN_AVND_EXPORT SoundSetLoader final : public QObject
{
public:
  using publish_function = std::function<void(
      std::shared_ptr<SoundSetSnapshot> next, SoundSetSnapshot* previous)>;
  using dispose_function
      = std::function<void(std::vector<std::shared_ptr<SoundSetSnapshot>>)>;
 
  SoundSetLoader(
      SoundSetOptions opts, publish_function publish, dispose_function dispose,
      QObject* parent);
  ~SoundSetLoader();
 
  void setPath(const QString& path);
 
  const std::shared_ptr<SoundSetSnapshot>& current() const noexcept { return m_current; }
  std::size_t retiredCount() const noexcept { return m_retired.size(); }
 
  void reap();
 
private:
  void scheduleScan();
  void scan();
  void scanned(uint64_t token, std::shared_ptr<SoundSetSnapshot> snapshot);
  void decodeRequested();
  void decoded(uint64_t token, std::shared_ptr<SoundSetEntry> entry);
  void publishSnapshot(std::shared_ptr<SoundSetSnapshot> snapshot);
  void rewatch();
 
  SoundSetOptions m_opts;
  publish_function m_publish;
  dispose_function m_dispose;
 
  QString m_folder;
  uint64_t m_token{};
  uint64_t m_generation{};
 
  std::shared_ptr<SoundSetSnapshot> m_current;
  std::vector<std::shared_ptr<SoundSetSnapshot>> m_retired;
  std::vector<std::shared_ptr<SoundSetEntry>> m_decoding;
 
  QFileSystemWatcher m_watcher;
  QTimer m_rescan;
  QTimer m_reaper;
  QTimer m_requests;
};
 
SCORE_PLUGIN_AVND_EXPORT QStringList soundSetExtensions(std::string_view exts);
}