fantasy::BankInfo bank_info;

bank_info.name = "xiaoli";

bank_info.type = fantasy::TestType::EnumOne;

bank_info.test_one = 100;

bank_info.test_two = 101;

bank_info.test_map_one.emplace("fantasy", fantasy::TestType::EnumOne);

bank_info.test_map.emplace(false, 555);

bank_info.test_vector.emplace_back("vector");

bank_info.info.name = "rpc";

bank_info.date_time = frpc::getFrpcDateTime();

return bank_info;

virtual void hello_world(fantasy::BankInfo bank_info,

std::string bank_name,

uint64_t blance,

std::optional<std::string> date,

frpc::DateTime date_time,

std::function<void(std::string, fantasy::Info, uint64_t, std::optional<std::string>)> cb) noexcept override {

spdlog::info("fantasy::HelloWorldServer server recv: {}, bank_name: {}, blance: {}, date: {}, date_time: {}",

fantasy::toString(bank_info), bank_name, blance, date.has_value() ? date.value() : "nullopt", frpc::toString(date_time));

fantasy::Info info;

info.name = "test";

cb("hello world", std::move(info), 789, "2024");

}

frpc::ChannelConfig bi_config{};

bi_config.addr = addr;

auto server = fantasy::HelloWorldServer::create(

bi_config,

std::make_shared<Handler>(),

[](std::string error) {

spdlog::error("fantasy::HelloWorldServer error: {}", error);

});

auto monitor = std::make_unique<frpc::Monitor>(*(server->context()), *(server->socket()));

auto event_cb = [](std::optional<std::tuple<zmq_event_t, std::string>> data) {

if (!data.has_value())

return;

auto& [event, point] = data.value();

spdlog::info("monitor: {} {}", frpc::getEventName(event.event), point);

};

monitor->start(event_cb, ZMQ_EVENT_ACCEPTED | ZMQ_EVENT_DISCONNECTED);

server->start();

std::this_thread::sleep_for(std::chrono::seconds(8));

start(start_server);

frpc::ChannelConfig bi_config{};

bi_config.addr = addr;

auto client = fantasy::HelloWorldClient::create(bi_config, [](std::string error) {

spdlog::error("fantasy::HelloWorldClient error: {}", error);

});

client->start();

client->hello_world(

create_bank_info(),

std::string{"fantasy-bank"},

999,

"option",

frpc::getFrpcDateTime(),

[](std::string reply, fantasy::Info info, uint64_t count, std::optional<std::string> date) {

spdlog::info("fantasy::HelloWorldClient::hello_world recv: {},{},{},{}", reply, fantasy::toString(info),

count, date.has_value() ? date.value() : "nullopt");

});

client->hello_world(

create_bank_info(),

std::string{"fantasy-bank-1"},

999,

"option",

frpc::getFrpcDateTime(),

[](std::string reply, fantasy::Info info, uint64_t count, std::optional<std::string> date) {

spdlog::info("fantasy::HelloWorldClient::hello_world(timeout) recv: {},{},{},{}", reply, fantasy::toString(info), count,

date.has_value() ? date.value() : "nullopt");

},

std::chrono::milliseconds(200),

[] {

spdlog::info("fantasy::HelloWorldClient::timeout timeout!!!");

});

std::this_thread::sleep_for(std::chrono::seconds(10));

return 0;