From c1acbf0deb1913a7d808274a086b4b341182b7af Mon Sep 17 00:00:00 2001 From: Bob Mottram Date: Tue, 1 Oct 2019 13:35:39 +0100 Subject: [PATCH] Add a few retries --- inbox.py | 32 ++++++++++++++++++++++++++------ 1 file changed, 26 insertions(+), 6 deletions(-) diff --git a/inbox.py b/inbox.py index 34df912e7..1a9badf56 100644 --- a/inbox.py +++ b/inbox.py @@ -996,9 +996,19 @@ def receiveAnnounce(session,handle: str,baseDir: str, \ print('DEBUG: Obtaining actor for announce post from cache '+lookupActor) if not getPersonFromCache(baseDir,lookupActor,personCache): print('DEBUG: retrieve actor for announce post '+lookupActor) - getPersonPubKey(baseDir,session,lookupActor, \ - personCache,debug, \ - __version__,httpPrefix,domain) + for tries in range(3): + pubKey= \ + getPersonPubKey(baseDir,session,lookupActor, \ + personCache,debug, \ + __version__,httpPrefix,domain) + if pubKey: + print('DEBUG: public key: '+str(pubKey)) + break + + if debug: + print('DEBUG: Retry '+str(tries+1)+ \ + ' obtaining actor for '+lookupActor) + time.sleep(5) if debug: print('DEBUG: announced/repeated post arrived in inbox') return True @@ -1185,9 +1195,19 @@ def obtainAvatarForReplyPost(session,baseDir: str,httpPrefix: str,domain: str,pe print('DEBUG: Obtaining actor for reply post '+lookupActor) if not getPersonFromCache(baseDir,lookupActor,personCache): print('DEBUG: retrieve actor for announce post '+lookupActor) - getPersonPubKey(baseDir,session,lookupActor, \ - personCache,debug, \ - __version__,httpPrefix,domain) + for tries in range(3): + pubKey= \ + getPersonPubKey(baseDir,session,lookupActor, \ + personCache,debug, \ + __version__,httpPrefix,domain) + if pubKey: + print('DEBUG: public key: '+str(pubKey)) + break + + if debug: + print('DEBUG: Retry '+str(tries+1)+ \ + ' obtaining actor for '+lookupActor) + time.sleep(5) def inboxAfterCapabilities(session,keyId: str,handle: str,messageJson: {}, \ baseDir: str,httpPrefix: str,sendThreads: [], \