Skip to content

Commit 6968ad4

Browse files
committed
fix: remove bad ripple block timestamp updater script, do not persist underlying blocks if no transactions are stored within
1 parent 366fd30 commit 6968ad4

File tree

6 files changed

+5
-28
lines changed

6 files changed

+5
-28
lines changed

packages/fasset-indexer-xrp/src/client/xrp-client.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ import type {
33
IXrpAccountInfoResponse, IXrpAccountTxResponse,
44
IXrpBlock, IXrpBlockQueryResponse,
55
IXrpLedgerCurrentResponse, IXrpServerInfoResponse,
6-
IXrpTransaction,
76
IXrpWeirdAfTx
87
} from "./interface"
98

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,5 @@
11
export const FIRST_UNHANDLED_XRP_BLOCK_DB_KEY = 'firstUnhandledXrpBlock'
22
export const MIN_XRP_BLOCK_NUMBER_DB_KEY = 'minXrpBlockNumber'
3+
4+
export const XRP_BLOCK_HEIGHT_OFFSET = 15
5+
export const XRP_TIMESTAMP_UNIX_OFFSET = 946684800

packages/fasset-indexer-xrp/src/constants.ts

Lines changed: 0 additions & 6 deletions
This file was deleted.

packages/fasset-indexer-xrp/src/indexer/xrp-indexer.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { findOrCreateEntity, getVar, setVar, type EntityManager } from "fasset-i
44
import { PaymentReference } from "fasset-indexer-core/utils"
55
import { logger } from "fasset-indexer-core/logger"
66
import { IXrpMemo, IXrpBlock, IXrpTransaction } from "../client/interface"
7-
import { XRP_TIMESTAMP_UNIX_OFFSET } from "../constants"
7+
import { XRP_TIMESTAMP_UNIX_OFFSET } from "../config/constants"
88
import type { XrpContext } from "../context"
99

1010

@@ -140,7 +140,7 @@ export class XrpIndexer {
140140
return em.create(Entities.UnderlyingBlock, {
141141
hash: xrpBlock.ledger_hash, height: xrpBlock.ledger_index,
142142
timestamp: xrpBlock.close_time + XRP_TIMESTAMP_UNIX_OFFSET
143-
})
143+
}, { persist: false }) // persist only if a transaction is saved within
144144
}
145145

146146
private async storeReference(

packages/fasset-indexer-xrp/src/run/run-indexer.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ import { XrpIndexer } from "../indexer/xrp-indexer"
33
import { XrpConfigLoader } from "../config/config"
44
import { XrpContext } from "../context"
55
import { monitor } from "./run-monitor"
6-
import { fixRippleBlockTimestamp } from "../scripts/fix-ripple-block-timestamps"
76
import {
87
FIRST_UNHANDLED_XRP_BLOCK_DB_KEY,
98
MIN_XRP_BLOCK_NUMBER_DB_KEY
@@ -21,7 +20,6 @@ async function runIndexer() {
2120
)
2221
const runner = new IndexerRunner(indexer, 'xrp')
2322
await Promise.all([
24-
fixRippleBlockTimestamp(context),
2523
monitor(config, context),
2624
runner.run(config.xrpMinBlockNumber)
2725
])

packages/fasset-indexer-xrp/src/scripts/fix-ripple-block-timestamps.ts

Lines changed: 0 additions & 17 deletions
This file was deleted.

0 commit comments

Comments
 (0)