ARCHIVE/sashimono
1
0
Fork 0
mirror of https://github.com/EvernodeXRPL/sashimono.git synced 2026-07-28 09:30:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Modify reputation scheduler

Browse Source
This commit is contained in:
chalith
2024-04-03 16:43:46 +05:30
parent 358f720593
commit aeb0d1357d
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
reputationd/lib/reputationd.js
View File

@@ -78,7 +78,8 @@ class ReputationD {
await this.#connectRegistry();
this.lastReputationMoment = 0;
const repInfo = await this.hostClient.getReputationInfo();
this.lastReputationMoment = repInfo ? repInfo.lastRegisteredMoment : 0;
this.xrplApi.on(evernode.XrplApiEvents.DISCONNECTED, async (e) => {
console.log(`Exiting due to server disconnect (code ${e})...`);
@@ -252,10 +253,16 @@ class ReputationD {
let startTimeout = 0;
const momentStartTime = await this.hostClient.getMomentStartIndex();
const currentTime = evernode.UtilHelpers.getCurrentUnixTime();
const currentTimestamp = evernode.UtilHelpers.getCurrentUnixTime();
const currentMoment = await this.hostClient.getMoment();
if ((currentTime - momentStartTime) < (momentSize * this.#reportTimeQuota))
startTimeout = (momentStartTime + (momentSize * this.#reportTimeQuota) - currentTime) * 1000 // Converting seconds to milliseconds.
if ((currentTimestamp - momentStartTime) < (momentSize * this.#reportTimeQuota))
startTimeout = (momentStartTime + (momentSize * this.#reportTimeQuota) - currentTimestamp) * 1000 // Converting seconds to milliseconds.
// If already registered for this moment, Schedule for next moment
if ((this.lastReputationMoment === currentMoment))
startTimeout += (momentSize * 1000);
console.log(`Reputation sender scheduled to start in ${startTimeout} milliseconds.`);
@@ -360,6 +367,9 @@ class ReputationD {
delete result.instance.ip;
}
// Set reputation contract info in domain.
await this.hostClient.setReputationContractInfo(result.instance.port, result.instance.pubkey);
this.cfg.contractInstance = { ...result.instance, created_timestamp: acquiredTimestamp };
this.#persistConfig();