@aresrpg/sui-checkpoint-reader
Advanced tools
Comparing version 4.1.11 to 4.1.12
{ | ||
"name": "@aresrpg/sui-checkpoint-reader", | ||
"version": "4.1.11", | ||
"version": "4.1.12", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -295,13 +295,2 @@ import { setInterval, setTimeout } from 'timers/promises' | ||
const processing_state = { | ||
cached: 0, | ||
last_detected: 0, | ||
downloaded: 0, | ||
cleaned: 0, | ||
processing: 0, | ||
downloads_per_second: 0, | ||
processing_per_second: 0, | ||
elapsed: 0, | ||
} | ||
Object.assign(known_types, { | ||
@@ -328,4 +317,2 @@ '0x0000000000000000000000000000000000000000000000000000000000000002': | ||
processing_state.last_detected = file_number | ||
// if in configured range, we add it to the known checkpoints | ||
@@ -409,7 +396,2 @@ if (file_number >= from && file_number <= to) { | ||
processing_state.downloaded += Math.min( | ||
concurrent_downloads, | ||
to - sync_settings.current_checkpoint, | ||
) | ||
const end_time = performance.now() | ||
@@ -457,3 +439,2 @@ const elapsed = ((end_time - start_time) / 1000).toFixed(2) | ||
unlinkSync(path.join(checkpoints_folder, `${file}.chk`)) | ||
processing_state.cached++ | ||
} | ||
@@ -519,3 +500,2 @@ } | ||
}) | ||
processing_state.processing = current_checkpoint_number | ||
await process_checkpoint(parsed_checkpoint, current_checkpoint_number) | ||
@@ -528,5 +508,5 @@ processing_settings.current_checkpoint++ | ||
}, | ||
'missing checkpoint, retrying in 5s', | ||
'missing checkpoint, retrying in 100ms', | ||
) | ||
await setTimeout(2000) | ||
await setTimeout(100) | ||
} | ||
@@ -533,0 +513,0 @@ } catch (error) { |
733260
19494