https-dns 0.2.0

use https_dns::utils::{build_request_message, build_test_listener};
use std::{collections::HashMap, net::Ipv6Addr};
use tokio::{net::UdpSocket, test};
use trust_dns_proto::{
    op::Message,
    rr::{Name, RData, RecordType},
};
#[test]
async fn aaaa_record() {
    let udp_listener = build_test_listener().await;
    tokio::spawn(async move {
        udp_listener.listen().await;
    });

    let result_map = HashMap::from([
        (
            "dns.google",
            vec![
                Ipv6Addr::new(0x2001, 0x4860, 0x4860, 0, 0, 0, 0, 0x8888),
                Ipv6Addr::new(0x2001, 0x4860, 0x4860, 0, 0, 0, 0, 0x8844),
            ],
        ),
        (
            "one.one.one.one",
            vec![
                Ipv6Addr::new(0x2606, 0x4700, 0x4700, 0, 0, 0, 0, 0x1111),
                Ipv6Addr::new(0x2606, 0x4700, 0x4700, 0, 0, 0, 0, 0x1001),
            ],
        ),
    ]);

    for (host, socket_addr_list) in result_map {
        let request_name: Name = host.parse().unwrap();
        let request_message = build_request_message(request_name, RecordType::AAAA);
        let raw_request_message = request_message.to_vec().unwrap();

        let udp_socket = UdpSocket::bind("127.0.0.1:10054").await.unwrap();
        udp_socket.connect("127.0.0.1:10053").await.unwrap();

        udp_socket.send(&raw_request_message).await.unwrap();
        let mut buffer = [0; 4096];
        udp_socket.recv(&mut buffer).await.unwrap();

        let response_message = Message::from_vec(&buffer).unwrap();
        let record_data = &response_message.answers()[0].data().unwrap();
        if let RData::AAAA(ipv6_address) = record_data {
            assert!(socket_addr_list.contains(ipv6_address));
        } else {
            panic!("the record type is not AAAA")
        }
    }
}