use std::{
	net::{SocketAddr, TcpListener},
	sync::Arc,
};

use axum::Router;
use axum_server::Handle;
use tokio::task::JoinSet;
use tuwunel_core::{Server, info};

pub(super) fn serve(
	server: &Arc<Server>,
	router: &Router,
	handle: &Handle<SocketAddr>,
	join_set: &mut JoinSet<Result<(), std::io::Error>>,
	addrs: &[SocketAddr],
	listeners: &Vec<TcpListener>,
) {
	let router = router
		.clone()
		.into_make_service_with_connect_info::<SocketAddr>();
	for listener in listeners {
		let acceptor = axum_server::from_tcp(listener.try_clone().unwrap())
			.unwrap()
			.handle(handle.clone())
			.serve(router.clone());
		join_set.spawn_on(acceptor, server.runtime());
	}

	info!("Listening on {addrs:?}");
}