Tasks.cpp

Go to the documentation of this file.

#include "Tasks.hpp"
#include "Awaiters/DelayAwaiters.hpp"
#include "MayaFlux/Nodes/Generators/Logic.hpp"
#include "MayaFlux/Vruta/Scheduler.hpp"
 
#include "MayaFlux/Vruta/ChronUtils.hpp"
 
#include "MayaFlux/Journal/Archivist.hpp"
 
namespace MayaFlux::Kriya {
 
std::shared_ptr<Vruta::Routine> metro(double interval_seconds, std::function<void()> callback, Vruta::ProcessingToken token)
{
    if (token == Vruta::ProcessingToken::FRAME_ACCURATE) {
        auto coro = [](double interval, std::function<void()> cb) -> Vruta::GraphicsRoutine {
            uint64_t units = Vruta::seconds_to_frames(interval);
            if (units < 1) {
                MF_RT_WARN(Journal::Component::Kriya, Journal::Context::CoroutineScheduling,
                    "metro interval {}s is shorter than one frame, clamping to 1 frame", interval);
            }
            units = std::max<uint64_t>(1, units);
            auto& p = co_await GetGraphicsPromise {};
            while (!p.should_terminate) {
                cb();
                co_await FrameDelay { .frames_to_wait = units };
            }
        };
        return std::make_shared<Vruta::GraphicsRoutine>(coro(interval_seconds, std::move(callback)));
    }
    auto coro = [](double interval, std::function<void()> cb) -> Vruta::SoundRoutine {
        uint64_t units = Vruta::seconds_to_samples(interval);
        if (units < 1) {
            MF_RT_WARN(Journal::Component::Kriya, Journal::Context::CoroutineScheduling,
                "metro interval {}s is shorter than one sample, clamping to 1 sample", interval);
        }
        units = std::max<uint64_t>(1, units);
        auto& p = co_await GetAudioPromise {};
        while (!p.should_terminate) {
            cb();
            co_await SampleDelay { units };
        }
    };
    return std::make_shared<Vruta::SoundRoutine>(coro(interval_seconds, std::move(callback)));
}
 
std::shared_ptr<Vruta::Routine> sequence(std::vector<std::pair<double, std::function<void()>>> sequence, Vruta::ProcessingToken token)
{
    if (token == Vruta::ProcessingToken::FRAME_ACCURATE) {
        auto coro = [](std::vector<std::pair<double, std::function<void()>>> seq) -> Vruta::GraphicsRoutine {
            for (const auto& [time, cb] : seq) {
                co_await FrameDelay { .frames_to_wait = Vruta::seconds_to_frames(time) };
                cb();
            }
        };
        return std::make_shared<Vruta::GraphicsRoutine>(coro(std::move(sequence)));
    }
    auto coro = [](std::vector<std::pair<double, std::function<void()>>> seq) -> Vruta::SoundRoutine {
        for (const auto& [time, cb] : seq) {
            co_await SampleDelay { Vruta::seconds_to_samples(time) };
            cb();
        }
    };
    return std::make_shared<Vruta::SoundRoutine>(coro(std::move(sequence)));
}
 
Vruta::SoundRoutine line(float start_value, float end_value, float duration_seconds, uint32_t step_duration, bool restartable)
{
    auto& promise_ref = co_await GetAudioPromise {};
 
    promise_ref.set_state("current_value", start_value);
    promise_ref.set_state("end_value", end_value);
    promise_ref.set_state("restart", false);
 
    const unsigned int sample_rate = Vruta::s_registered_sample_rate;
    if (step_duration < 1) {
        step_duration = 1;
    }
 
    uint64_t total_samples = static_cast<uint64_t>(static_cast<double>(duration_seconds) * sample_rate);
    float per_sample_step = (end_value - start_value) / (float)total_samples;
    float sample_step = per_sample_step * (float)step_duration;
 
    promise_ref.set_state("step", sample_step);
 
    for (;;) {
        auto current_value = promise_ref.get_state<float>("current_value");
        auto last_value = promise_ref.get_state<float>("end_value");
        auto step = promise_ref.get_state<float>("step");
 
        if (!current_value || !last_value || !step) {
            MF_ERROR(Journal::Component::Kriya, Journal::Context::CoroutineScheduling, "Line task state not properly initialized");
            co_return;
        }
 
        *current_value = start_value;
 
        uint64_t samples_elapsed = 0;
 
        co_await SampleDelay { 1 };
 
        while (samples_elapsed < total_samples) {
            *current_value += *step;
 
            if ((*step > 0 && *current_value >= *last_value) || (*step < 0 && *current_value <= *last_value)) {
                *current_value = *last_value;
            }
 
            samples_elapsed += step_duration;
            co_await SampleDelay { step_duration };
        }
 
        if (!restartable)
            break;
 
        auto restart_requested = promise_ref.get_state<bool>("restart");
        if (restart_requested && *restart_requested) {
            *restart_requested = false;
            continue;
        }
 
        promise_ref.auto_resume = false;
        co_await std::suspend_always {};
    }
}
 
Vruta::SoundRoutine Gate(
    std::function<void()> callback,
    std::shared_ptr<Nodes::Generator::Logic> logic_node,
    bool open)
{
    auto& promise_ref = co_await GetAudioPromise {};
 
    if (!logic_node) {
        logic_node = std::make_shared<Nodes::Generator::Logic>(0.5);
    }
 
    if (open) {
        logic_node->while_true([callback](const Nodes::NodeContext& /*ctx*/) {
            callback();
        });
    } else {
        logic_node->while_false([callback](const Nodes::NodeContext& /*ctx*/) {
            callback();
        });
    }
 
    while (true) {
        if (promise_ref.should_terminate) {
            break;
        }
 
        logic_node->process_sample(0.0);
 
        co_await SampleDelay { 1 };
    }
}
 
Vruta::SoundRoutine Trigger(
    bool target_state,
    std::function<void()> callback,
    std::shared_ptr<Nodes::Generator::Logic> logic_node)
{
    auto& promise_ref = co_await GetAudioPromise {};
 
    if (!logic_node) {
        logic_node = std::make_shared<Nodes::Generator::Logic>(0.5);
    }
 
    logic_node->on_change_to(target_state,
        [callback](const Nodes::NodeContext& /*ctx*/) {
            callback();
        });
 
    while (true) {
        if (promise_ref.should_terminate) {
            break;
        }
 
        logic_node->process_sample(0.0);
 
        co_await SampleDelay { 1 };
    }
}
 
Vruta::SoundRoutine Toggle(
    std::function<void()> callback,
    std::shared_ptr<Nodes::Generator::Logic> logic_node)
{
    auto& promise_ref = co_await GetAudioPromise {};
 
    if (!logic_node) {
        logic_node = std::make_shared<Nodes::Generator::Logic>(0.5);
    }
 
    logic_node->on_change([callback](const Nodes::NodeContext& /*ctx*/) {
        callback();
    });
 
    while (true) {
        if (promise_ref.should_terminate) {
            break;
        }
 
        logic_node->process_sample(0.0);
 
        co_await SampleDelay { 1 };
    }
}
}