Croupier C++ SDK 快速参考

CroupierClient client(config);
FunctionDescriptor desc{"wallet.transfer", "1.0.0"};
client.RegisterFunction(desc, [](const std::string& ctx, const std::string& payload) {
    // 处理函数逻辑
    return "{\"status\":\"ok\"}";
});

VirtualObjectDescriptor wallet;
wallet.id = "wallet.entity";
wallet.operations["transfer"] = "wallet.transfer";

std::map<std::string, FunctionHandler> handlers;
handlers["wallet.transfer"] = [](auto ctx, auto payload) { /* ... */ };

client.RegisterVirtualObject(wallet, handlers);

ComponentDescriptor comp;
comp.id = "economy-system";
comp.entities = {wallet, currency};
comp.functions = {market_trade};

client.RegisterComponent(comp);

client.LoadComponentFromFile("economy-system.json");

config.game_id = "my-game";              // 🎮 必需
config.env = "production";               // 🔧 必需
config.insecure = false;                 // 🔐 生产需要关闭
config.auth_token = "Bearer token...";   // 🔑 认证

ClientConfig config;
config.insecure = true;  // 允许不安全连接

ClientConfig config;
config.insecure = false;
config.cert_file = "/etc/certs/client.crt";
config.key_file = "/etc/certs/client.key";
config.ca_file = "/etc/certs/ca.crt";
config.auth_token = "Bearer <JWT>";
config.headers["X-Request-Id"] = "trace_123";

InvokeOptions opts;
opts.idempotency_key = croupier::sdk::utils::NewIdempotencyKey();
opts.trace_id = "trace_xyz";  // 审计
opts.metadata["user_id"] = "admin_1";

invoker.Invoke("player.ban", payload, opts);

// 标准签名
std::string HandlerFunction(
    const std::string& context,   // 调用上下文（目前未用）
    const std::string& payload    // JSON 字符串
);

// 实现模板
std::string MyHandler(const std::string& ctx, const std::string& payload) {
    // 1. 解析
    auto data = utils::ParseJSON(payload);
    std::string param = data["key"];
    
    // 2. 处理
    std::string result = DoSomething(param);
    
    // 3. 返回
    std::map<std::string, std::string> resp;
    resp["result"] = result;
    return utils::ToJSON(resp);
}

auto objects = client.GetRegisteredObjects();
auto components = client.GetRegisteredComponents();

for (const auto& obj : objects) {
    std::cout << "Object: " << obj.id << " with " 
              << obj.operations.size() << " operations" << std::endl;
}

try {
    client.RegisterVirtualObject(desc, handlers);
    client.Connect();
} catch (const std::exception& e) {
    std::cerr << "Error: " << e.what() << std::endl;
    // 实现重连逻辑
}

bool RegisterFunction(const FunctionDescriptor&, FunctionHandler);
bool RegisterVirtualObject(const VirtualObjectDescriptor&, const std::map<...>&);
bool RegisterComponent(const ComponentDescriptor&);
bool LoadComponentFromFile(const std::string&);
bool Connect();
void Serve();
void Stop();
std::vector<VirtualObjectDescriptor> GetRegisteredObjects() const;
std::vector<ComponentDescriptor> GetRegisteredComponents() const;

bool Connect();
std::string Invoke(const std::string& func_id, const std::string& payload, const InvokeOptions&);
std::string StartJob(const std::string& func_id, const std::string& payload, const InvokeOptions&);
std::future<std::vector<JobEvent>> StreamJob(const std::string& job_id);
bool CancelJob(const std::string& job_id);

std::string NewIdempotencyKey();                                    // 生成唯一 ID
bool ValidateJSON(const std::string&, const std::map<...>&);       // 验证 JSON
std::map<std::string, std::string> ParseJSON(const std::string&);  // 解析 JSON
std::string ToJSON(const std::map<...>&);                          // 转换为 JSON
bool ValidateObjectDescriptor(const VirtualObjectDescriptor&);     // 验证对象
bool ValidateComponentDescriptor(const ComponentDescriptor&);      // 验证组件
std::string GenerateObjectTemplate(const std::string& id);         // 生成模板