pub async fn tcp_conn_handler(
    stream: &mut TcpStream,
    addr: SocketAddr,
    datastore_sender: Sender<Command>,
    agent_tx: Sender<AgentState>,
    capture_packets: bool,
    allowed_shutdown: bool
) -> Result<()>