diff --git a/src/endpoints/transactions/transaction.service.ts b/src/endpoints/transactions/transaction.service.ts index 968c70fc3..f44c873ae 100644 --- a/src/endpoints/transactions/transaction.service.ts +++ b/src/endpoints/transactions/transaction.service.ts @@ -348,6 +348,9 @@ export class TransactionService { } async processTransactions(transactions: Transaction[], options: { withScamInfo: boolean, withUsername: boolean, withActionTransferValue: boolean }): Promise { + + this.normalizeTimestampMs(transactions); + try { await this.pluginsService.processTransactions(transactions, options.withScamInfo); } catch (error) { @@ -372,6 +375,15 @@ export class TransactionService { await this.applyAssets(transactions, { withUsernameAssets: options.withUsername }); } + + private normalizeTimestampMs(transactions: Transaction[]): void { + for (const transaction of transactions) { + if ((!transaction.timestampMs || transaction.timestampMs === 0) && transaction.timestamp) { + transaction.timestampMs = transaction.timestamp * 1000; + } + } + } + private async getPendingResults(transaction: Transaction): Promise { const twentyMinutes = Constants.oneMinute() * 20 * 1000; const timestampLimit = (new Date().getTime() - twentyMinutes) / 1000;