usecrate::stream::Dispatcher;

usecrate::ws::WsStream;

pubfntcp(self) ->Result<Dispatcher<S>>{

ifmatches!(self.typ,ListenerType::TCP){

Ok(Err(e)) =>returnErr(e.into()),

Err(_) =>returnErr(crate::MqttError::ReadTimeout.into()),

Ok(Dispatcher::new(tls_s,self.remote_addr,self.cfg))

let cert_info =Self::get_extract_cert_info(&tls_s,self.cfg.cert_cn_as_username);

Ok(Dispatcher::new(tls_s,self.remote_addr, cert_info,self.cfg))

Ok(Ok(ws_stream)) =>{

Ok(Dispatcher::new(WsStream::new(ws_stream),self.remote_addr,self.cfg.clone()))

Ok(Dispatcher::new(WsStream::new(ws_stream),self.remote_addr,None,self.cfg.clone()))

Ok(Err(e)) =>Err(e.into()),

Err(_) =>Err(crate::MqttError::ReadTimeout.into()),

Ok(Err(e)) =>returnErr(e.into()),

Err(_) =>returnErr(crate::MqttError::ReadTimeout.into()),

let cert_info =Self::get_extract_cert_info(&tls_s,self.cfg.cert_cn_as_username);

match tokio::time::timeout(self.cfg.handshake_timeout,accept_hdr_async(tls_s, on_handshake)).await{

Ok(Ok(ws_stream)) =>{

Ok(Dispatcher::new(WsStream::new(ws_stream),self.remote_addr,self.cfg.clone()))

Ok(Dispatcher::new(WsStream::new(ws_stream),self.remote_addr,cert_info,self.cfg.clone()))

Ok(Err(e)) =>Err(e.into()),

Err(_) =>Err(crate::MqttError::ReadTimeout.into()),

fnget_extract_cert_info<C:TlsCertExtractor>(io:&C,cert_cn_as_username:bool) ->Option<CertInfo>{

if cert_cn_as_username{

let cert_info:Option<CertInfo> = io.extract_cert_info();

ifletSome(ref cert) = cert_info{

log::info!("Client certificate: {}", cert);

log::info!("CN: {:?}, Org: {:?}", cert.common_name, cert.organization);

log::info!("cert_info: {:?}", cert_info);

cert_info