registry-controller.hpp

#pragma once
#include "core/device/vdb/protocol.hpp"
#include "vex.h"
#include <functional>
#include "core/device/vdb/visitor.hpp"
#include "core/device/vdb/builtins.hpp"
 
namespace VDP {
class RegistryController {
  public:
    int num_bad = 0;
    int num_small = 0;
    using CallbackFn = std::function<void(const VDP::Channel &)>;
    RegistryController(AbstractDevice *device);
    void take_packet(const Packet &pac);
    PartPtr get_data(ChannelID id);

    ChannelID open_channel(PartPtr &for_data);
    bool send_data(ChannelID id);

    bool negotiate();
    int rec_switch_time = 1000;
 
  private:
  std::vector<Channel> channels;
    ChannelID new_channel_id() {
        ChannelID id = next_channel_id;
        next_channel_id++;
        return id;
    }
 
    int responses_in_queue;
    bool needs_ack = false;
    vex::timer timer;
    bool rec_mode = false;
    static constexpr size_t ack_ms = 500;
 
    AbstractDevice *device;
    // Our channels (us -> them)
    
    ChannelID next_channel_id = 0;
    CallbackFn on_broadcast = [&](VDP::Channel chan) {
        std::string schema_str = chan.data->pretty_print();
        printf(
          "VDB-Controller: No Broadcast Callback installed: Received broadcast "
          "for channel id "
          "%d:\n%s\n",
          int(chan.getID()), schema_str.c_str()
        );
    };
    CallbackFn on_data = [&](VDP::Channel new_data) {
        ResponsePacketVisitor RV(new_data.data);
        PartPtr original_data = channels[new_data.id].data;
        original_data->Visit(&RV);
        original_data->response();
    };
};
} // namespace VDP