aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

use freshgun for tryAndWait

Browse source
This commit is contained in:
Daniel Lugo 2020-02-25 17:44:04 -04:00
parent 19f14e6d83
commit c6f8e37c5f
1 changed files with 23 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

39
services/gunDB/contact-api/utils/index.js
View file

@ -81,15 +81,21 @@ const tryAndWait = async (promGen, shouldRetry = () => false) => {
) )
if (shouldRetry(resolvedValue)) { if (shouldRetry(resolvedValue)) {
throw new Error('force retrying') logger.info(
'force retrying' +
` args: ${promGen.toString()} -- ${shouldRetry.toString()}`
)
} else {
return resolvedValue
} }
return resolvedValue
} catch (e) { } catch (e) {
logger.error(e) logger.error(e)
} }
logger.info(`\n retrying \n`) logger.info(
`\n retrying \n` +
` args: ${promGen.toString()} -- ${shouldRetry.toString()}`
)
await delay(3000) await delay(3000)
@ -102,24 +108,25 @@ const tryAndWait = async (promGen, shouldRetry = () => false) => {
) )
if (shouldRetry(resolvedValue)) { if (shouldRetry(resolvedValue)) {
throw new Error('force retrying') logger.info(
'force retrying' +
` args: ${promGen.toString()} -- ${shouldRetry.toString()}`
)
} else {
return resolvedValue
} }
return resolvedValue
} catch (e) { } catch (e) {
logger.error(e) logger.error(e)
} }
logger.info(`\n recreating gun and retrying one last time \n`) logger.info(
`\n recreating a fresh gun and retrying one last time \n` +
await require('../../Mediator/index').instantiateGun() ` args: ${promGen.toString()} -- ${shouldRetry.toString()}`
return timeout10(
promGen(
require('../../Mediator/index').getGun(),
require('../../Mediator/index').getUser()
)
) )
const { gun, user } = await require('../../Mediator/index').freshGun()
return timeout10(promGen(gun, user))
/* eslint-enable no-empty */ /* eslint-enable no-empty */
/* eslint-enable init-declarations */ /* eslint-enable init-declarations */
} }