Function client

robot/middleman/driver.cpp:234–356

}

int client(actor_system& sys, std::string_view mode, const std::string& host,
           uint16_t port) {
  auto& mm = sys.middleman();
  if (mode == "remote_actor") {
    auto cell = with_retry([&] { return mm.remote_actor(host, port); });
    auto cell2 = mm.remote_actor(host, port);
    if (!cell2 || *cell != *cell2) {
      std::cout << "calling remote_actor twice must return the same handle\n";
      return EXIT_FAILURE;
    }
    return cell_tests(sys, *cell);
  }
  if (mode == "remote_spawn") {
    auto nid = with_retry([&] { return mm.connect(host, port); });
    auto nid2 = mm.connect(host, port); // with cache
    if (!nid2 || *nid != *nid2) {
      std::cout << "calling connect twice must return the same node ID\n";
      return EXIT_FAILURE;
    }
    purge_cache(sys, host, port);
    auto nid3 = mm.connect(host, port); // without cache
    if (!nid3 || *nid != *nid3) {
      std::cout << "calling connect twice must return the same node ID\n";
      return EXIT_FAILURE;
    }
    auto cell = mm.remote_spawn<actor>(*nid, "cell", make_message(int32_t{7}),
                                       5s);
    if (!cell) {
      std::cout << "remote spawn failed: " << to_string(cell.error()) << "\n";
      return EXIT_FAILURE;
    }
    return cell_tests(sys, *cell);
  }
  if (mode == "remote_lookup") {
    auto nid = with_retry([&] { return mm.connect(host, port); });
    auto cell = mm.remote_lookup("cell", *nid);
    if (!cell) {
      std::cout << "remote_lookup failed\n";
      return EXIT_FAILURE;
    }
    return cell_tests(sys, actor_cast<actor>(cell));
  }
  if (mode == "unpublish") {
    auto ctrl = with_retry([&] { return mm.remote_actor(host, port); });
    bool unpublished = false;
    scoped_actor self{sys};
    self->mail(ok_atom_v).request(*ctrl, 5s).receive(
      [&unpublished] { unpublished = true; },
      [](const error& reason) {
        std::cout << "failed to unpublish: " << to_string(reason) << "\n";
      });
    if (!unpublished) {
      return EXIT_FAILURE;
    }
    with_retry([&] {
      purge_cache(sys, host, port);
      return !mm.remote_actor(host, port);
    });