bridge.hpp

Go to the documentation of this file.

/*
  ____       _     _                   _
 | __ ) _ __(_) __| | __ _  ___    ___| | __ _ ___ ___
 |  _ \| '__| |/ _` |/ _` |/ _ \  / __| |/ _` / __/ __|
 | |_) | |  | | (_| | (_| |  __/ | (__| | (_| \__ \__ \
 |____/|_|  |_|\__,_|\__, |\___|  \___|_|\__,_|___/___/
                     |___/
 
This class is a pure frontend class: it acts as a bridge between the output of
an external program and the mads framework.
 
Author(s): Paolo Bosetti
*/
 
#ifndef BRIDGE_HPP
#define BRIDGE_HPP
 
 
#include "mads.hpp"
#include "agent.hpp"
#include <regex>
#include <iostream>
 
using json = nlohmann::json;
 
namespace Mads {
 
class Bridge : public Agent {
public:
  Bridge(std::string name, std::string settings_path)
      : Agent(name, settings_path) {
    load_settings();
  }
 
  void route() {
    zmq::multipart_t message;
    string payload, compressed;
    regex re("^(\\w+):\\s*(\\{.*\\})\\s*$");
    smatch match;
    json j;
    while (getline(cin, payload)) {
      if (payload == "exit") {
        Mads::Runtime::stop_process();
        break;
      }
      if (regex_search(payload, match, re) && match.size() > 1) {
        _pub_topic = match[1];
        payload = match[2];
      }
      cout << "Topic: " << _pub_topic << ", Payload: " << payload << endl;
      try {
        j = json::parse(payload);
        publish(j, _pub_topic);
      } catch (const std::exception &e) {
        cerr << "Failed to parse JSON: " << e.what() << endl;
        continue;
      }
    }
  }
 
private:
  void load_settings() override {
    // NONE
  }
 
};
 
} // namespace Mads
 
#endif // BRIDGE_HPP