dstest 0.1.6

Deterministic Simulation Testing for containerised services
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

--- @diagnostic disable:undefined-global
--- PostgreSQL lifecycle: connect, create table, insert, query, close.
--- Run: cat examples/pg.lua | cargo run

dstest.config({
    substrate = "docker",
    seed = 42,
})

local s = dstest.setup({
    image = "postgres:16-alpine",
    ports = { 5432 },
    env = {
        POSTGRES_PASSWORD = "password",
        POSTGRES_DB = "test_db",
    },
})

-- Get the container's bridge IP for a direct connection
local info = dstest.inspect(s)
dstest.info("container IP: " .. tostring(info.ip))

-- Give Postgres time to finish its boot cycle
dstest.info("waiting for database boot...")
dstest.exec(s, { "sleep", "3" })

local conn_str = string.format("postgres://postgres:password@%s:5432/test_db", info.ip)
dstest.info("connecting: " .. conn_str)

local pool = dstest.pg.connect(conn_str, 5)
dstest.info("connected")

-- Create a table
dstest.pg.query(pool, "CREATE TABLE users (id SERIAL PRIMARY KEY, name TEXT NOT NULL)")
dstest.info("created table: users")

-- Insert rows
dstest.pg.query(pool, "INSERT INTO users (name) VALUES ('alice'), ('bob'), ('carol')")
dstest.info("inserted 3 rows")

-- Query them back
local rows = dstest.pg.query(pool, "SELECT id, name FROM users ORDER BY id")
dstest.info(string.format("query returned %d rows:", #rows))
for _, row in ipairs(rows) do
    dstest.info(string.format("  id=%d  name=%s", row.id, row.name))
end

-- Verify count
assert(#rows == 3, "expected 3 users, got " .. #rows)

dstest.pg.close(pool)
dstest.info("pg example complete")