//! Simple HTTP Get example with low level codec.
//! We use captive.apple.com as target service.

use bytes::Bytes;
use http::{request::Builder, Method, Version};
use monoio::io::{sink::SinkExt, stream::Stream};
use monoio_http::{
    common::body::{Body, StreamHint},
    h1::{
        codec::ClientCodec,
        payload::{FramedPayload, Payload, PayloadError},
    },
};

#[monoio::main]
async fn main() {
    let request = Builder::new()
        .method(Method::GET)
        .uri("/")
        .version(Version::HTTP_11)
        .header(http::header::HOST, "captive.apple.com")
        .header(http::header::ACCEPT, "*/*")
        .header(http::header::USER_AGENT, "monoio-http")
        .body(Payload::<Bytes, PayloadError>::None)
        .unwrap();

    println!("Request constructed, will connect");
    let conn = monoio::net::TcpStream::connect("captive.apple.com:80")
        .await
        .expect("unable to connect");
    // You can also use raw io with encoder and decoder manually.
    let mut codec = ClientCodec::new(conn);

    println!("Connected, will send request");
    codec
        .send_and_flush(request)
        .await
        .expect("unable to send request");
    println!("Request send, will wait for response");
    let resp = codec
        .next()
        .await
        .expect("disconnected")
        .expect("parse response failed");

    println!("Status code: {}", resp.status());
    let body = resp.into_body().with_io(codec);
    if body.stream_hint() != StreamHint::Fixed {
        panic!("unexpected body type");
    }
    process_payload(body).await;
}

async fn process_payload(mut payload: FramedPayload<ClientCodec<monoio::net::TcpStream>>) {
    let data = payload
        .next_data()
        .await
        .unwrap()
        .expect("unable to read response body");
    println!("Response body: {}", String::from_utf8_lossy(&data));
}