import context
import net.http
import x.async as xasync

fn synthetic_http_handler(req http.Request) !http.Response {
    path := if req.url.contains('?') { req.url.all_before('?') } else { req.url }
    match path {
        '/health' {
            return http.new_response(status: .ok, body: 'healthy')
        }
        '/ready' {
            return http.new_response(status: .ok, body: 'ready')
        }
        else {
            return http.new_response(status: .not_found, body: 'missing')
        }
    }
}

fn main() {
    requests := [
        http.new_request(.get, '/health', ''),
        http.new_request(.get, '/ready', ''),
        http.new_request(.get, '/missing', ''),
    ]
    responses := chan string{cap: requests.len}
    mut pool := xasync.new_pool(workers: 2, queue_size: requests.len)!

    for req in requests {
        pool.try_submit(fn [req, responses] (mut ctx context.Context) ! {
            done := ctx.done()
            select {
                _ := <-done {
                    return ctx.err()
                }
                else {}
            }
            resp := synthetic_http_handler(req)!
            responses <- '${req.url} -> ${resp.status_code} ${resp.body}'
        })!
    }

    pool.close()!
    for _ in 0 .. requests.len {
        println(<-responses)
    }
}