From f6695eb9c49e764522f90e9e1e64c7d7d33f6ca8 Mon Sep 17 00:00:00 2001
From: "theo@manjaro" <ayte@tutanota.com>
Date: Mon, 4 Jul 2022 10:59:17 +0200
Subject: [PATCH] Using threads to fetch from the IPmirrors

---
 src/utils/network.py | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/src/utils/network.py b/src/utils/network.py
index e55e8a4c9..ab1b246bf 100644
--- a/src/utils/network.py
+++ b/src/utils/network.py
@@ -22,6 +22,7 @@ import os
 import re
 import logging
 import time
+import threading
 
 from moulinette.utils.filesystem import read_file, write_to_file
 from moulinette.utils.network import download_text
@@ -102,8 +103,7 @@ def get_public_ips(protocol=4):
         ip_url_yunohost_tab = settings_get("security.ipmirrors.v"+str(protocol)).split(",")
         ip_count = {} # Count the number of times an IP has appeared
 
-        # Check URLS
-        for url in ip_url_yunohost_tab[:3]:
+        def thread_fun(ip_count,url):
             logger.debug(f"Fetching IP from {url}")
             try:
                 ip = download_text(url, timeout=15).strip()
@@ -116,6 +116,15 @@ def get_public_ips(protocol=4):
                     f"Could not get public IPv{protocol} from {url} : {e}"
                 )
 
+        # Check URLS
+        threads = []
+        for url in ip_url_yunohost_tab[:3]: # Launch threads
+            thread = threading.Thread(target=thread_fun, args=(ip_count,url))
+            thread.start()
+            threads.append(thread)
+        for thread in threads: # Wait for the threads to finish
+            thread.join()
+
         ip_list_with_count = [ (ip,ip_count[ip]) for ip in ip_count ]
         ip_list_with_count.sort(key=lambda x: x[1]) # Sort by frequency
         ips = [ x[0] for x in ip_list_with_count ]