Sweeper.hpp

#pragma once
#include <ossia/dataflow/exec_state_facade.hpp>
#include <ossia/dataflow/execution_state.hpp>
#include <ossia/network/common/path.hpp>
 
#include <QCoreApplication>
#include <QTimer>
 
#include <AvndProcesses/AddressTools.hpp>
#include <halp/audio.hpp>
#include <halp/controls.hpp>
#include <halp/meta.hpp>
#include <rnd/random.hpp>
 
namespace avnd_tools
{
 
// Given:
// address: /foo.*/value
//  -> /foo.1/value, /foo.2/value, etc.
// input: [1, 34, 6, 4]
// -> writes 1 on foo.1/value, 34 on foo.2/value, etc
 
struct PatternSweeper : PatternObject
{
  halp_meta(name, "Sweeper")
  halp_meta(author, "ossia team")
  halp_meta(category, "Control/Data processing")
  halp_meta(description, "Sweep a message to all nodes matching a pattern")
  halp_meta(c_name, "avnd_pattern_sweep")
  halp_meta(uuid, "55f4fe13-f71b-4c20-ac32-74668e82664c")
 
  struct
  {
    halp::val_port<"Input", ossia::value> input;
    PatternSelector pattern;
 
    halp::time_chooser<"Interval"> time;
    struct
    {
      halp__enum("Mode", Upwards, Upwards, Downwards, UpDown, RandomWalk, Random);
    } mode;
  } inputs;
 
  struct
  {
 
  } outputs;
 
  std::size_t current_parameter = 0;
  double last_message_sent_pos = std::numeric_limits<double>::lowest();
  enum
  {
    up,
    down
  } direction{up};
  rnd::pcg pcg_state;
 
  void prepare()
  {
    std::random_device dev;
    pcg_state.seed(dev);
  }
 
  void next()
  {
    if(this->roots.size() <= 1)
    {
      current_parameter = 0;
      return;
    }
    using mode = decltype(inputs.mode)::enum_type;
    switch(inputs.mode)
    {
      case mode::Upwards:
        current_parameter++;
        current_parameter = current_parameter % this->roots.size();
        break;
      case mode::Downwards:
        if(current_parameter == 0)
          current_parameter = this->roots.size() - 1;
        else
          current_parameter--;
        break;
      case mode::UpDown: {
      case_updown:
        if(direction == up)
        {
          if(current_parameter + 1 == this->roots.size())
          {
            direction = down;
            current_parameter--;
          }
          else
          {
            current_parameter++;
          }
        }
        else
        {
          if(current_parameter == 0)
          {
            direction = up;
            current_parameter++;
          }
          else
          {
            current_parameter--;
          }
        }
        break;
      }
      case mode::RandomWalk: {
        if(std::bernoulli_distribution{}(pcg_state))
          direction = up;
        else
          direction = down;
        goto case_updown;
        break;
      }
      case mode::Random: {
        auto dist = std::uniform_int_distribution<int>(0, std::ssize(this->roots) - 1);
        current_parameter = dist(pcg_state);
        break;
      }
    }
  }
 
  using tick = halp::tick_musical;
  void operator()(const halp::tick_musical& tk)
  {
    auto elapsed_ns = (tk.position_in_nanoseconds - last_message_sent_pos);
    if(!m_path || this->roots.empty())
      return;
 
    if(elapsed_ns < inputs.time.value * 1e9)
      return;
    last_message_sent_pos = tk.position_in_nanoseconds;
 
    if(current_parameter >= 0 && current_parameter < this->roots.size())
    {
      if(auto p = roots[current_parameter]->get_parameter())
      {
        p->push_value(inputs.input.value);
      }
 
      next();
    }
  }
};
}