From 38e5d932726fc972574ecb784465a137c945900f Mon Sep 17 00:00:00 2001
From: Dmitri Bogomolov <4glitch@gmail.com>
Date: Fri, 14 Jun 2019 12:38:48 +0300
Subject: [PATCH] Resend onionpeer object if it expired while the node ran

---
 src/class_singleCleaner.py |  1 +
 src/class_singleWorker.py  | 13 ++++++++-----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/class_singleCleaner.py b/src/class_singleCleaner.py
index 82d6b491..e2cdbb89 100644
--- a/src/class_singleCleaner.py
+++ b/src/class_singleCleaner.py
@@ -84,6 +84,7 @@ class singleCleaner(threading.Thread, StoppableThread):
                     int(time.time()) - 7380:
                 timeWeLastClearedInventoryAndPubkeysTables = int(time.time())
                 Inventory().clean()
+                queues.workerQueue.put(('sendOnionPeerObj', ''))
                 # pubkeys
                 sqlExecute(
                     "DELETE FROM pubkeys WHERE time<? AND usedpersonally='no'",
diff --git a/src/class_singleWorker.py b/src/class_singleWorker.py
index e52419c4..d979ae19 100644
--- a/src/class_singleWorker.py
+++ b/src/class_singleWorker.py
@@ -130,10 +130,7 @@ class singleWorker(threading.Thread, StoppableThread):
         queues.workerQueue.put(('sendbroadcast', ''))
 
         # send onionpeer object
-        for peer in state.ownAddresses:
-            if peer.host.endswith('.onion'):
-                queues.workerQueue.put(('sendOnionPeerObj', peer))
-                break
+        queues.workerQueue.put(('sendOnionPeerObj', ''))
 
         while state.shutdown == 0:
             self.busy = 0
@@ -469,8 +466,14 @@ class singleWorker(threading.Thread, StoppableThread):
                 ' to the keys.dat file. Error message: %s', err
             )
 
-    def sendOnionPeerObj(self, peer):
+    def sendOnionPeerObj(self, peer=None):
         """Send onionpeer object representing peer"""
+        if not peer:  # find own onionhostname
+            for peer in state.ownAddresses:
+                if peer.host.endswith('.onion'):
+                    break
+            else:
+                return
         TTL = int(7 * 24 * 60 * 60 + helper_random.randomrandrange(-300, 300))
         embeddedTime = int(time.time() + TTL)
         streamNumber = 1  # Don't know yet what should be here