cd test/tap/tests/unit
make mysqlx_protocol_unit-t mysqlx_stats_unit-t mysqlx_config_store_unit-t \
     mysqlx_config_store_pure_unit-t mysqlx_config_store_concurrent_unit-t \
     mysqlx_route_store_unit-t mysqlx_admin_schema_unit-t \
     mysqlx_admin_commands_unit-t mysqlx_admin_disk_commands_unit-t \
     mysqlx_admin_alias_resolution_unit-t \
     plugin_manager_unit-t plugin_registry_unit-t plugin_config_unit-t \
     mysqlx_data_stream_unit-t mysqlx_connection_unit-t \
     mysqlx_session_unit-t mysqlx_thread_unit-t \
     mysqlx_message_dispatch_unit-t mysqlx_concurrent_unit-t \
     mysqlx_backend_auth_unit-t mysqlx_credential_verify_unit-t \
     mysqlx_robustness_unit-t mysqlx_tls_unit-t

# Run all unit tests
for t in mysqlx_*_unit-t plugin_*_unit-t; do
    ./$t
done

cd test/tap
make group-tests GROUP=unit-tests-g1

# Build the plugin
cd plugins/mysqlx && make

# Build and run integration tests
cd ../../test/tap/tests
make test_mysqlx_admin_tables-t test_mysqlx_listener_smoke-t test_mysqlx_plugin_load-t

./test_mysqlx_admin_tables-t
./test_mysqlx_listener_smoke-t
./test_mysqlx_plugin_load-t

# Using dbdeployer:
dbdeployer deploy single 8.4.8

export MYSQLX_E2E_HOST=127.0.0.1
export MYSQLX_E2E_PORT=33060
export MYSQLX_E2E_USER=mysqlx_test
export MYSQLX_E2E_PASS=mysqlx_test

cd test/tap/tests
make test_mysqlx_e2e_handshake-t test_mysqlx_e2e_routing-t

./test_mysqlx_e2e_handshake-t
./test_mysqlx_e2e_routing-t

cd test/tap
make group-tests GROUP=mysqlx-e2e-g1

SQLite3DB db;
db.open((char*)":memory:", SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_FULLMUTEX);
db.execute("CREATE TABLE mysqlx_endpoints (id INTEGER PRIMARY KEY, ...)");
db.execute("INSERT INTO mysqlx_endpoints VALUES (1, ...)");

int fds[2];
socketpair(AF_UNIX, SOCK_STREAM, 0, fds);

// Write an error frame on one end
mysqlx_send_error(fds[0], 1045, "Access denied");

// Read and verify on the other end
mysqlx_read_frame(fds[1], header, payload);

close(fds[0]);
close(fds[1]);

const int N_THREADS = 10;
const int N_ITER    = 10000;
std::atomic<int> barrier{0};

auto worker = [&]() {
    barrier.fetch_add(1);
    while (barrier.load() < N_THREADS) { /* spin */ }
    for (int i = 0; i < N_ITER; i++) {
        store.resolve_identity(...);
    }
};

std::vector<std::thread> threads;
for (int i = 0; i < N_THREADS; i++) threads.emplace_back(worker);
for (auto& t : threads) t.join();

ok(total_resolves == N_THREADS * N_ITER, "all resolves accounted for");

MysqlxDataStream ds;

// Feed a complete frame
uint8_t frame[] = {0x0a, 0x00, 0x00, 0x00, 0x01, /* body */};
ds.feed_bytes(frame, sizeof(frame));

ok(ds.has_complete_frame(), "complete frame detected");
auto& pkt = ds.front_frame();
ok(pkt[4] == 0x01, "message type is CON_CAPABILITIES_GET");
ds.pop_frame();
ok(!ds.has_complete_frame(), "no more frames after pop");

MysqlxSession sess;
sess.set_status(MysqlxSession::CONNECTING_CLIENT);
sess.handler_connecting_client();
ok(sess.get_status() == MysqlxSession::X_CAPABILITIES_GET,
   "transitioned to X_CAPABILITIES_GET");

# Install dbdeployer
curl -s https://raw.githubusercontent.com/ProxySQL/dbdeployer/master/scripts/dbdeployer-install.sh | bash

# Download and deploy MySQL 8.4
dbdeployer downloads get-by-version 8.4 --newest --minimal
dbdeployer unpack mysql-8.4.*.tar.xz
dbdeployer deploy single 8.4.8

# Verify X Protocol is active
mysql -u root -S ~/sandboxes/msb_8_4_8/socket.sock -e "SELECT @@mysqlx_port"
# Expected: 33060

Unit:           500+ assertions  (83%)
Integration:     63 assertions   (11%)
E2E:             20 assertions   ( 3%)
Concurrent:      30 assertions   ( 3%)
                    ─────────
Total:          600+ assertions

#include "tap.h"

int main() {
    plan(5);

    ok(1 + 1 == 2, "basic arithmetic");
    is_str("hello", "hello", "string equality");
    ok(true, "simple boolean");

    if (!some_condition) {
        skip(2, "condition not met");
    } else {
        ok(test_a(), "test A");
        ok(test_b(), "test B");
    }

    return exit_status();
}

// test/tap/tests/unit/mysqlx_pool_unit-t.cpp
#include "tap.h"
#include "test_globals.h"
#include "test_init.h"
#include "mysqlx_connection.h"
#include "mysqlx_thread.h"

int main() {
    plan(6);
    test_globals_init();

    // Test pool matching
    Mysqlx_Thread thr;
    thr.init(0);

    MysqlxConnection* conn = new MysqlxConnection();
    conn->set_hostgroup(1);
    conn->set_user("appuser");
    conn->set_schema("appdb");
    conn->set_state(MysqlxConnection::IDLE);
    conn->set_reusable(true);
    thr.return_connection_to_cache(conn);

    MysqlxConnection* found = thr.get_connection_from_cache(1, "appuser", "appdb");
    ok(found != nullptr, "connection found by matching hostgroup/user/schema");
    ok(found == conn, "got the same connection back");

    found = thr.get_connection_from_cache(1, "otheruser", "appdb");
    ok(found == nullptr, "no match for different user");

    found = thr.get_connection_from_cache(1, "appuser", "otherdb");
    ok(found == nullptr, "no match for different schema");

    found = thr.get_connection_from_cache(2, "appuser", "appdb");
    ok(found == nullptr, "no match for different hostgroup");

    ok(thr.get_cached_connection_count() == 0, "cache empty after all retrieved");

    return exit_status();
}