aboutsummaryrefslogtreecommitdiff
path: root/plugins/ice/src/plugin.vala
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/ice/src/plugin.vala')
-rw-r--r--plugins/ice/src/plugin.vala19
1 files changed, 17 insertions, 2 deletions
diff --git a/plugins/ice/src/plugin.vala b/plugins/ice/src/plugin.vala
index ec4fe9cb..17090d26 100644
--- a/plugins/ice/src/plugin.vala
+++ b/plugins/ice/src/plugin.vala
@@ -22,10 +22,10 @@ public class Dino.Plugins.Ice.Plugin : RootInterface, Object {
stream.get_module(JingleRawUdp.Module.IDENTITY).set_local_ip_address_handler(get_local_ip_addresses);
}
});
- app.stream_interactor.stream_negotiated.connect(on_stream_negotiated);
+ app.stream_interactor.stream_negotiated.connect(external_discovery_refresh_services);
}
- private async void on_stream_negotiated(Account account, XmppStream stream) {
+ private async void external_discovery_refresh_services(Account account, XmppStream stream) {
Module? ice_udp_module = stream.get_module(JingleIceUdp.Module.IDENTITY) as Module;
if (ice_udp_module == null) return;
Gee.List<Xep.ExternalServiceDiscovery.Service> services = yield ExternalServiceDiscovery.request_services(stream);
@@ -59,6 +59,21 @@ public class Dino.Plugins.Ice.Plugin : RootInterface, Object {
ice_udp_module.stun_ip = ip.to_string();
ice_udp_module.stun_port = 7886;
}
+
+ if (ice_udp_module.turn_service != null) {
+ DateTime? expires = ice_udp_module.turn_service.expires;
+ if (expires != null) {
+ uint delay = (uint) (expires.to_unix() - new DateTime.now_utc().to_unix()) / 2;
+
+ debug("Next server external service discovery in %us (because of TURN credentials' expiring time)", delay);
+
+ Timeout.add_seconds(delay, () => {
+ if (app.stream_interactor.connection_manager.get_state(account) != ConnectionManager.ConnectionState.CONNECTED) return false;
+ on_stream_negotiated.begin(account, stream);
+ return false;
+ });
+ }
+ }
}
public void shutdown() {