block save => upsert

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<InsertResult> {
+        return this.rpcBlockRepository.upsert({ blockHeight, data }, ['blockHeight']);
     }
 
     public async deleteOldBlocks() {

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);