fixes
This commit is contained in:
parent
f2503af80a
commit
ece291f0be
3 changed files with 2 additions and 15 deletions
|
|
@ -23,7 +23,6 @@ const sanitizeFileName = (fileName: string): string => {
|
||||||
const openWriter = (fileName: string): Writer => {
|
const openWriter = (fileName: string): Writer => {
|
||||||
const now = new Date()
|
const now = new Date()
|
||||||
const date = `${now.getFullYear()}-${z(now.getMonth() + 1)}-${z(now.getDate())}`
|
const date = `${now.getFullYear()}-${z(now.getMonth() + 1)}-${z(now.getDate())}`
|
||||||
// const sanitizedFileName = sanitizeFileName(fileName)
|
|
||||||
const logPath = `${logsDir}/${fileName}_${date}.log`
|
const logPath = `${logsDir}/${fileName}_${date}.log`
|
||||||
// Ensure parent directory exists
|
// Ensure parent directory exists
|
||||||
const dirPath = logPath.substring(0, logPath.lastIndexOf('/'))
|
const dirPath = logPath.substring(0, logPath.lastIndexOf('/'))
|
||||||
|
|
|
||||||
|
|
@ -268,6 +268,7 @@ export default class {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
this.addressPaidCb({ hash: tx.txHash, index: outputIndex }, output.address, Number(output.amount), 'lnd')
|
this.addressPaidCb({ hash: tx.txHash, index: outputIndex }, output.address, Number(output.amount), 'lnd')
|
||||||
|
.catch(err => log(ERROR, "failed to process root address output:", err.message || err))
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -285,6 +286,7 @@ export default class {
|
||||||
const outputIndex = Number(output.outputIndex)
|
const outputIndex = Number(output.outputIndex)
|
||||||
log(`processing missed chain tx: address=${output.address}, txHash=${tx.txHash}, amount=${amount}, outputIndex=${outputIndex}`)
|
log(`processing missed chain tx: address=${output.address}, txHash=${tx.txHash}, amount=${amount}, outputIndex=${outputIndex}`)
|
||||||
this.addressPaidCb({ hash: tx.txHash, index: outputIndex }, output.address, amount, 'lnd')
|
this.addressPaidCb({ hash: tx.txHash, index: outputIndex }, output.address, amount, 'lnd')
|
||||||
|
.catch(err => log(ERROR, "failed to process user address output:", err.message || err))
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,14 +0,0 @@
|
||||||
import { MigrationInterface, QueryRunner } from "typeorm";
|
|
||||||
|
|
||||||
export class TrackedProviderHeight1766504040000 implements MigrationInterface {
|
|
||||||
name = 'TrackedProviderHeight1766504040000'
|
|
||||||
|
|
||||||
public async up(queryRunner: QueryRunner): Promise<void> {
|
|
||||||
await queryRunner.query(`ALTER TABLE "tracked_provider" ADD "latest_checked_height" integer NOT NULL DEFAULT (0)`);
|
|
||||||
}
|
|
||||||
|
|
||||||
public async down(queryRunner: QueryRunner): Promise<void> {
|
|
||||||
await queryRunner.query(`ALTER TABLE "tracked_provider" DROP COLUMN "latest_checked_height"`);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue