anotherim/anotherim-desktop
2
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Don't go through ConnectionManager for initial connection attempt

Browse source
This commit is contained in:
fiaxh 2019-12-23 03:04:42 +01:00 committed by Marvin W
parent 6257e9705c
commit 1eb01251e8
No known key found for this signature in database
GPG key ID: 072E9235DB996F2A
2 changed files with 41 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
libdino/src/service/counterpart_interaction_manager.vala
View file

@ -90,7 +90,7 @@ public class CounterpartInteractionManager : StreamInteractionModule, Object {
Entities.Message? message = stream_interactor.get_module(MessageStorage.IDENTITY).get_message_by_stanza_id(stanza_id, conversation); Entities.Message? message = stream_interactor.get_module(MessageStorage.IDENTITY).get_message_by_stanza_id(stanza_id, conversation);
if (message == null) return; if (message == null) return;
// Don't move read marker backwards because we get old info from another client // Don't move read marker backwards because we get old info from another client
if (conversation.read_up_to.local_time.compare(message.local_time) > 0) return; if (conversation.read_up_to == null || conversation.read_up_to.local_time.compare(message.local_time) > 0) return;
conversation.read_up_to = message; conversation.read_up_to = message;
} else { } else {
// We received a marker from someone else. Search the respective message and mark it. // We received a marker from someone else. Search the respective message and mark it.

55
libdino/src/service/registration.vala
View file

@ -23,29 +23,47 @@ public class Register : StreamInteractionModule, Object{
} }
public async ConnectionManager.ConnectionError.Source? add_check_account(Account account) { public async ConnectionManager.ConnectionError.Source? add_check_account(Account account) {
SourceFunc callback = add_check_account.callback; XmppStream stream = new XmppStream();
stream.log = new XmppLog(account.bare_jid.to_string(), Application.print_xmpp);
stream.add_module(new Tls.Module());
stream.add_module(new Iq.Module());
stream.add_module(new Xep.SrvRecordsTls.Module());
stream.add_module(new Sasl.Module(account.bare_jid.to_string(), account.password));
ConnectionManager.ConnectionError.Source? ret = null; ConnectionManager.ConnectionError.Source? ret = null;
ulong handler_id_connected = stream_interactor.stream_negotiated.connect((connected_account, stream) => { SourceFunc callback = add_check_account.callback;
if (connected_account.equals(account)) { stream.stream_negotiated.connect(() => {
account.persist(db); if (callback == null) return;
account.enabled = true;
Idle.add((owned)callback); Idle.add((owned)callback);
}
}); });
ulong handler_id_error = stream_interactor.connection_manager.connection_error.connect((connected_account, error) => { stream.get_module(Tls.Module.IDENTITY).invalid_certificate.connect((peer_cert, errors) => {
if (connected_account.equals(account)) { if (callback == null) return;
ret = error.source; ret = ConnectionManager.ConnectionError.Source.TLS;
}
stream_interactor.disconnect_account.begin(account);
Idle.add((owned)callback); Idle.add((owned)callback);
}); });
stream.get_module(Sasl.Module.IDENTITY).received_auth_failure.connect((stream, node) => {
if (callback == null) return;
ret = ConnectionManager.ConnectionError.Source.SASL;
Idle.add((owned)callback);
});
stream.connect.begin(account.bare_jid.domainpart, (_, res) => {
try {
stream.connect.end(res);
} catch (Error e) {
debug("Error connecting to stream: %s", e.message);
}
if (callback != null) {
ret = ConnectionManager.ConnectionError.Source.CONNECTION;
Idle.add((owned)callback);
}
});
stream_interactor.connect_account(account);
yield; yield;
stream_interactor.disconnect(handler_id_connected);
stream_interactor.connection_manager.disconnect(handler_id_error);
try {
yield stream.disconnect();
} catch (Error e) {}
return ret; return ret;
} }
@ -164,10 +182,15 @@ public class Register : StreamInteractionModule, Object{
}); });
yield; yield;
string? ret = null;
if (stream.negotiation_complete) { if (stream.negotiation_complete) {
return yield stream.get_module(Xep.InBandRegistration.Module.IDENTITY).submit_to_server(stream, jid, form); ret = yield stream.get_module(Xep.InBandRegistration.Module.IDENTITY).submit_to_server(stream, jid, form);
} }
return null; try {
yield stream.disconnect();
} catch (Error e) {}
return ret;
} }
} }