user_plugin_static.cpp

Go to the documentation of this file.

#include <Arduino.h>
#include <plugin/static.h>
#include <protocol/registry.h>
#include <run/run.h>
#include <utils/streaming_json.h>
#include <lucidac/lucidac.h>
#include <protocol/protocol.h>
#include <protocol/protocol_oob.h>
 
constexpr uint8_t bufsize = 300;
uint16_t *results = nullptr;
size_t cur_run = 0;
run::Run *reprun = nullptr;
 
void tear_down() {
    delete reprun;
    delete results;
    cur_run = 0;
}
 
 
class MonteCarloHandler : public msg::handlers::MessageHandler {
public:
  int handle(JsonObjectConst msg_in, JsonObject &msg_out) override {
    if(msg_in.containsKey("run_delete"))
        tear_down();
 
    if(msg_in.containsKey("run_config")) {
        auto run_config_json = msg_in["run_config"].as<JsonObjectConst>();
        auto run_config = run::RunConfig::from_json(run_config_json);
        if(reprun)
            tear_down();
        reprun = new run::Run("monte_carlo", run_config, daq::DAQConfig::silence());        
    }
 
    return success;
  }
};
 
FLASHMEM void static_plugin::setup() {
    msg::handlers::Registry::get().set("monte_carlo", new MonteCarloHandler(), net::auth::SecurityLevel::RequiresLogin);
}
 
FLASHMEM void static_plugin::loop() {
    if(reprun) {
        if(!results) {
            results = new uint16_t[bufsize]; // because RAM2 has more of leftover
        }
 
        // carry out the next run, not streaming any data during run.
        reprun->run(nullptr, nullptr, nullptr);
        // sample exactly one channel at end of run.
        results[cur_run++] = daq::sample_raw()[0];
 
        if(cur_run >= bufsize) {
            // stream out the results, reusing existing infrastructure.
            client::StreamingRunDataNotificationHandler streamer{
                platform::LUCIDAC::get(),
                msg::JsonLinesProtocol::get().broadcast
            };
            streamer.handle(results, bufsize, 1, *reprun);            
            cur_run = 0;
        }
    }
}