Method __call_procedure__

crates/bindings-cpp/src/internal/Module.cpp:581–628

Dispatch function for procedures

// Dispatch function for procedures
int16_t Module::__call_procedure__(
    uint32_t id,
    uint64_t sender_0, uint64_t sender_1, uint64_t sender_2, uint64_t sender_3,
    uint64_t conn_id_0, uint64_t conn_id_1,
    uint64_t timestamp_microseconds,
    BytesSource args_source,
    BytesSink result_sink
) {
    // Check if procedure ID is valid
    if (id >= g_procedure_handlers.size()) {
        fprintf(stderr, "ERROR: Invalid procedure ID %u (have %zu procedures)\n", 
                id, g_procedure_handlers.size());
        return -1;  // NO_SUCH_PROCEDURE
    }
    
    // Create sender identity from the 4 uint64_t parts
    std::array<uint8_t, 32> sender_bytes{};
    std::memcpy(sender_bytes.data(), &sender_0, 8);
    std::memcpy(sender_bytes.data() + 8, &sender_1, 8);
    std::memcpy(sender_bytes.data() + 16, &sender_2, 8);
    std::memcpy(sender_bytes.data() + 24, &sender_3, 8);
    
    Identity sender_identity(sender_bytes);
    
    // Create timestamp from microseconds
    Timestamp timestamp = Timestamp::from_micros_since_epoch(
        static_cast<int64_t>(timestamp_microseconds));
    
    // Create connection ID from the two 64-bit parts (full 128-bit value)
    ConnectionId connection_id;
    if (conn_id_0 != 0 || conn_id_1 != 0) {
        connection_id = ConnectionId(u128(conn_id_1, conn_id_0));
    }
    
    // Create procedure context
    ProcedureContext ctx(sender_identity, timestamp, connection_id);
    
    // Get the handler
    const auto& handler_info = g_procedure_handlers[id];
    
    // Call the procedure handler - this may trap if there's an error
    std::vector<uint8_t> result_data = handler_info.handler(ctx, args_source);
    
    // If we got here, procedure succeeded - write result
    WriteBytes(result_sink, result_data);
    
    return 0;  // Success (StatusCode::OK)
}

int16_t Module::__call_http_handler__(
    uint32_t id,