fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-05-12 18:57:15 +00:00
Code Issues Projects Releases Wiki Activity

chore: use set-delayed-interval module on circuit (#809)

Browse Source
This commit is contained in:
Vasco Santos 2020-11-26 12:01:53 +01:00 committed by Vasco Santos
parent baedf3fe5a
commit b538ebdc0a
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/circuit/index.js
View File

@ -4,6 +4,11 @@ const debug = require('debug')
const log = debug('libp2p:relay') const log = debug('libp2p:relay')
log.error = debug('libp2p:relay:error') log.error = debug('libp2p:relay:error')
const {
setDelayedInterval,
clearDelayedInterval
} = require('set-delayed-interval')
const AutoRelay = require('./auto-relay') const AutoRelay = require('./auto-relay')
const { namespaceToCid } = require('./utils') const { namespaceToCid } = require('./utils')
const { const {
@ -33,6 +38,8 @@ class Relay {
// Create autoRelay if enabled // Create autoRelay if enabled
this._autoRelay = this._options.autoRelay.enabled && new AutoRelay({ libp2p, ...this._options.autoRelay }) this._autoRelay = this._options.autoRelay.enabled && new AutoRelay({ libp2p, ...this._options.autoRelay })
this._advertiseService = this._advertiseService.bind(this)
} }
/** /**
@ -45,9 +52,9 @@ class Relay {
const canHop = this._options.hop.enabled const canHop = this._options.hop.enabled
if (canHop && this._options.advertise.enabled) { if (canHop && this._options.advertise.enabled) {
this._timeout = setTimeout(() => { this._timeout = setDelayedInterval(
this._advertiseService() this._advertiseService, this._options.advertise.ttl, this._options.advertise.bootDelay
}, this._options.advertise.bootDelay) )
} }
} }
@ -57,7 +64,7 @@ class Relay {
* @returns {void} * @returns {void}
*/ */
stop () { stop () {
clearTimeout(this._timeout) clearDelayedInterval(this._timeout)
} }
/** /**
@ -77,14 +84,7 @@ class Relay {
} else { } else {
log.error(err) log.error(err)
} }
return
} }
// Restart timeout
this._timeout = setTimeout(() => {
this._advertiseService()
}, this._options.advertise.ttl)
} }
} }