diff --git a/src/ORM/rpc-block/rpc-block.service.ts b/src/ORM/rpc-block/rpc-block.service.ts index 0d6d3c0..75f1d54 100644 --- a/src/ORM/rpc-block/rpc-block.service.ts +++ b/src/ORM/rpc-block/rpc-block.service.ts @@ -1,6 +1,6 @@ import { Injectable } from '@nestjs/common'; import { InjectRepository } from '@nestjs/typeorm'; -import { Repository } from 'typeorm'; +import { InsertResult, Repository } from 'typeorm'; import { RpcBlockEntity } from './rpc-block.entity'; @@ -18,8 +18,8 @@ export class RpcBlockService { }); } - public saveBlock(blockHeight: number, data: string) { - return this.rpcBlockRepository.save( {blockHeight, data }); + public saveBlock(blockHeight: number, data: string): Promise { + return this.rpcBlockRepository.upsert({ blockHeight, data }, ['blockHeight']); } public async deleteOldBlocks() { diff --git a/src/services/bitcoin-rpc.service.ts b/src/services/bitcoin-rpc.service.ts index c047e92..c924e48 100644 --- a/src/services/bitcoin-rpc.service.ts +++ b/src/services/bitcoin-rpc.service.ts @@ -134,7 +134,7 @@ export class BitcoinRpcService implements OnModuleInit { try{ console.log(`Saving block ${blockHeight}`); - const result = await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(blockTemplate)); + await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(blockTemplate)); console.log('block saved'); }catch(e){ console.error('Error saving block', e);