Add server side support

[lulf]

Add support for listening for incoming TCP connections and creating AMQP connections, sessions and links.

[giovibal]

It will be great to have this functionality.
It seems it was implemented but commented out:

dove/src/conn.rs

Lines 138 to 163 in bc93b2f

	/*
	pub struct Listener {
	pub listener: TcpListener,
	pub sasl_mechanisms: Option<Vec<SaslMechanism>>,
	}
	pub fn listen(host: &str, port: u16, _opts: ListenOptions) -> Result<Listener> {
	let addr = format!("{}:{}", host, port).parse().unwrap();
	let listener = TcpListener::bind(addr)?;
	Ok(Listener {
	listener,
	sasl_mechanisms: None,
	})
	}
	impl Listener {
	pub fn accept(&mut self) -> Result<Connection> {
	let (stream, _addr) = self.listener.accept()?;
	let transport: Transport = Transport::new(stream, 1024)?;
	let mut connection = Connection::new(transport);
	connection.state = ConnectionState::StartWait;
	Ok(connection)
	}
	}
	*/

... and...

dove/src/conn.rs

Lines 235 to 260 in bc93b2f

	/*
	TODO: Listener
	ConnectionState::StartWait => {
	let header = self.transport.read_protocol_header()?;
	if let Some(header) = header {
	match header {
	SASL_10_HEADER if self.sasl.is_some() => {
	self.transport.write_protocol_header(&SASL_10_HEADER)?;
	self.state = ConnectionState::Sasl;
	self.transport.flush()?;
	}
	AMQP_10_HEADER if self.skip_sasl() => {
	self.transport.write_protocol_header(&AMQP_10_HEADER)?;
	self.state = ConnectionState::Opened;
	self.transport.flush()?;
	}
	_ => {
	self.transport.write_protocol_header(&AMQP_10_HEADER)?;
	self.state = ConnectionState::Closed;
	self.transport.flush()?;
	self.transport.close()?;
	}
	}
	}
	}
	*/

Why it is commented out ?
it works but need some tests and bugfix, or it need a complete rethink / reimpl ?

Thank you

[lulf]

@giovibal The internal code is written with server-support in mind, but there are these bits and pieces that I haven't really tested and is just commented. I think we need a friendly to use API on top as well, so some work is needed.