diff --git a/src/ORM/rpc-block/rpc-block.service.ts b/src/ORM/rpc-block/rpc-block.service.ts index 1bc3c9c..0d6d3c0 100644 --- a/src/ORM/rpc-block/rpc-block.service.ts +++ b/src/ORM/rpc-block/rpc-block.service.ts @@ -19,7 +19,7 @@ export class RpcBlockService { } public saveBlock(blockHeight: number, data: string) { - return this.rpcBlockRepository.update(blockHeight, { data }); + return this.rpcBlockRepository.save( {blockHeight, data }); } public async deleteOldBlocks() { diff --git a/src/services/bitcoin-rpc.service.ts b/src/services/bitcoin-rpc.service.ts index 6fb73a0..c047e92 100644 --- a/src/services/bitcoin-rpc.service.ts +++ b/src/services/bitcoin-rpc.service.ts @@ -135,13 +135,7 @@ export class BitcoinRpcService implements OnModuleInit { try{ console.log(`Saving block ${blockHeight}`); const result = await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(blockTemplate)); - if(result.affected < 1){ - console.error('Block was not saved'); - console.error(result.raw); - }else { - console.log('block saved'); - } - + console.log('block saved'); }catch(e){ console.error('Error saving block', e); }