mirror of
https://github.com/TakeV-Lambda/dino.git
synced 2024-09-30 22:45:51 +00:00
54 lines
1.8 KiB
Vala
54 lines
1.8 KiB
Vala
|
public class Xmpp.StartTlsXmppStream : TlsXmppStream {
|
||
|
|
||
|
private const string TLS_NS_URI = "urn:ietf:params:xml:ns:xmpp-tls";
|
||
|
|
||
|
string host;
|
||
|
uint16 port;
|
||
|
|
||
|
public StartTlsXmppStream(Jid remote, string host, uint16 port) {
|
||
|
this.remote_name = remote;
|
||
|
this.host = host;
|
||
|
this.port = port;
|
||
|
}
|
||
|
|
||
|
public override async void connect() throws IOStreamError {
|
||
|
try {
|
||
|
SocketClient client = new SocketClient();
|
||
|
debug("Connecting to %s %i (starttls)", host, port);
|
||
|
IOStream stream = yield client.connect_to_host_async(host, port);
|
||
|
reset_stream(stream);
|
||
|
|
||
|
yield setup();
|
||
|
|
||
|
StanzaNode node = yield read();
|
||
|
var starttls_node = node.get_subnode("starttls", TLS_NS_URI);
|
||
|
if (starttls_node == null) {
|
||
|
warning("%s does not offer starttls", remote_name.to_string());
|
||
|
}
|
||
|
|
||
|
write(new StanzaNode.build("starttls", TLS_NS_URI).add_self_xmlns());
|
||
|
|
||
|
node = yield read();
|
||
|
|
||
|
if (node.ns_uri != TLS_NS_URI || node.name != "proceed") {
|
||
|
warning("Server did not 'proceed' starttls request");
|
||
|
}
|
||
|
|
||
|
try {
|
||
|
var identity = new NetworkService("xmpp-client", "tcp", remote_name.to_string());
|
||
|
var conn = TlsClientConnection.new(get_stream(), identity);
|
||
|
reset_stream(conn);
|
||
|
|
||
|
conn.accept_certificate.connect(on_invalid_certificate);
|
||
|
} catch (Error e) {
|
||
|
stderr.printf("Failed to start TLS: %s\n", e.message);
|
||
|
}
|
||
|
|
||
|
yield setup();
|
||
|
|
||
|
attach_negotation_modules();
|
||
|
} catch (Error e) {
|
||
|
throw new IOStreamError.CONNECT("Failed connecting to %s:%i (starttls): %s", host, port, e.message);
|
||
|
}
|
||
|
}
|
||
|
}
|