//! Tests for the listener and the worker pool.
//! 监听器与工作线程池的测试。
//!
//! They live here rather than inside the module so that `src/` holds no test
//! code, as it does in `apsis-rs`. An integration test is a separate crate and
//! reaches only what the library makes public, so the few internal items the
//! tests need are opened through `apsis_book::testkit`.
//!
//! 它们放在这里而不是模块内部，使 `src/` 不含测试代码，与 `apsis-rs` 一致。
//! 集成测试是独立的 crate，只能触达库公开的部分，因此测试所需的那少数内部条目
//! 经 `apsis_book::testkit` 开放。
use apsis_book::http::request::{Request, RequestError};
use apsis_book::http::response::{Response, Status};
use std::net::SocketAddr;
use std::net::TcpStream;
use std::sync::Arc;
use std::thread;

use apsis_book::http::server::*;
use apsis_book::testkit::error_response;

use std::io::{Read, Write};

#[test]
fn serves_a_request_over_a_real_socket() {
    let server = Server::bind_address(
        "127.0.0.1:0"
            .parse()
            .expect("the literal address must parse"),
        ServerConfig {
            workers: 2,
            ..ServerConfig::default()
        },
    )
    .unwrap();
    let address = server.local_address().unwrap();

    let handler =
        Arc::new(|_request: &Request, _peer: SocketAddr| Response::json("{}".to_string()));
    let running = thread::spawn(move || server.run(handler));

    let mut stream = TcpStream::connect(address).unwrap();
    stream
        .write_all(b"GET / HTTP/1.1\r\nHost: localhost\r\n\r\n")
        .unwrap();
    let mut response = String::new();
    stream.read_to_string(&mut response).unwrap();
    assert!(response.starts_with("HTTP/1.1 200 OK\r\n"));
    assert!(response.ends_with("{}"));

    drop(stream);
    // The accept loop ends when the listener is dropped with the thread.
    // 接受循环在线程随监听器一同被丢弃时结束。
    let _ = running;
}

#[test]
fn converts_parse_failures_into_statuses() {
    assert_eq!(
        error_response(RequestError::Malformed("x")).status,
        Status::BadRequest
    );
    assert_eq!(
        error_response(RequestError::TooLarge("x")).status,
        Status::ContentTooLarge
    );
}