mj-saunders
/
epicyon
forked from indymedia/epicyon
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add a few retries

main2
Bob Mottram 2019-10-01 13:35:39 +01:00
parent 1d3c74bd21
commit c1acbf0deb
1 changed files with 26 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
inbox.py
View File

@ -996,9 +996,19 @@ def receiveAnnounce(session,handle: str,baseDir: str, \
print('DEBUG: Obtaining actor for announce post from cache '+lookupActor) print('DEBUG: Obtaining actor for announce post from cache '+lookupActor)
if not getPersonFromCache(baseDir,lookupActor,personCache): if not getPersonFromCache(baseDir,lookupActor,personCache):
print('DEBUG: retrieve actor for announce post '+lookupActor) print('DEBUG: retrieve actor for announce post '+lookupActor)
for tries in range(3):
pubKey= \
getPersonPubKey(baseDir,session,lookupActor, \ getPersonPubKey(baseDir,session,lookupActor, \
personCache,debug, \ personCache,debug, \
__version__,httpPrefix,domain) __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: if debug:
print('DEBUG: announced/repeated post arrived in inbox') print('DEBUG: announced/repeated post arrived in inbox')
return True return True
@ -1185,9 +1195,19 @@ def obtainAvatarForReplyPost(session,baseDir: str,httpPrefix: str,domain: str,pe
print('DEBUG: Obtaining actor for reply post '+lookupActor) print('DEBUG: Obtaining actor for reply post '+lookupActor)
if not getPersonFromCache(baseDir,lookupActor,personCache): if not getPersonFromCache(baseDir,lookupActor,personCache):
print('DEBUG: retrieve actor for announce post '+lookupActor) print('DEBUG: retrieve actor for announce post '+lookupActor)
for tries in range(3):
pubKey= \
getPersonPubKey(baseDir,session,lookupActor, \ getPersonPubKey(baseDir,session,lookupActor, \
personCache,debug, \ personCache,debug, \
__version__,httpPrefix,domain) __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: {}, \ def inboxAfterCapabilities(session,keyId: str,handle: str,messageJson: {}, \
baseDir: str,httpPrefix: str,sendThreads: [], \ baseDir: str,httpPrefix: str,sendThreads: [], \