Method parse_command

src/control_socket.cpp:401–448

};

std::string control_socket_t::parse_command(const std::string &command) {
  // DEBUG("Parse command {}", command);
  json_t js;
  try {
    js = json_t::parse(command);
  } catch (const std::exception &e) {
    return json_t{{"error", e.what()}}.dump();
  }
  std::string method = js["method"];
  json_t retdata = {{"id", js["id"]}};
  try {
    for (const auto &cmd : COMMANDS) {
      if (cmd.name == method) {
        auto res = cmd.func(*this, js["params"]);
        retdata["result"] = res;

        return retdata.dump();
      }
    }
    // if matches the regex (^d*\..*), its a command to a peer
    std::smatch match;
    if (std::regex_match(method, match, PEER_COMMAND_RE)) {
      auto peer_id = std::stoi(match[1]);
      auto cmd = match[2];
      // DEBUG("Peer command: {} -> {}", peer_id, cmd.to_string());
      auto peer = router->get_peer_by_id(peer_id);
      if (peer) {
        auto res = peer->command(cmd, js["params"]);
        if (res.contains("error")) {
          retdata["error"] = res["error"];
        } else {
          retdata["result"] = res;
        }
      } else {
        retdata["error"] = FMT::format("Unknown peer '{}'", peer_id);
      }
      return retdata.dump();
    }

    retdata["error"] = FMT::format("Unknown method '{}'", method);
    ERROR("Error running method: {}", std::string(retdata["error"]));
    return retdata.dump();
  } catch (const std::exception &e) {
    ERROR("Error running method: {}", e.what());
    retdata["error"] = e.what();
    return retdata.dump();
  }
}
} // namespace rtpmididns