From 65232da9011ad2eab6a7d837a5cdafbac2b3429d Mon Sep 17 00:00:00 2001
From: Benjamin Wilson <admin@opensourceminer.com>
Date: Sat, 1 Feb 2025 11:57:34 -0500
Subject: [PATCH] block save => upsert

---
 src/ORM/rpc-block/rpc-block.service.ts | 6 +++---
 src/services/bitcoin-rpc.service.ts    | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

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<InsertResult> {
+        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);