Add Prisma as ORM [DRAFT]

Dockerfile

@@ -1,9 +1,9 @@
-FROM node:18 as build
+FROM node:18 AS build
 
 WORKDIR /app
 
 # add `/app/node_modules/.bin` to $PATH
-ENV PATH /app/node_modules/.bin:$PATH
+ENV PATH=/app/node_modules/.bin:$PATH
 
 # Generate build
 COPY package.json /app

README.md

@@ -65,6 +65,8 @@ PGUSER=
 PGDATABASE=
 PGPASSWORD=
 PGPORT=5432
+
+DATABASE_URL="postgresql://johndoe:randompassword@localhost:5432/mydb?schema=public"
 ```
 
 ## Usage

bridge.ts

@@ -2,7 +2,7 @@ import { TestNetWallet, Wallet, TokenMintRequest, BalanceResponse } from "mainne
 import { bigIntToVmNumber, binToHex } from '@bitauth/libauth';
 import { ethers } from "ethers";
 import {
-  writeInfoToDb,
+  writeBurnInfoToDb,
   getAllBridgeInfo,
   getRecentBridgeInfo,
   checkAmountBridgedDb,
@@ -12,8 +12,10 @@ import {
 import abi from "./abi.json" assert { type: 'json' }
 import express from "express";
 import cors from "cors";
-import 'dotenv/config'
+import * as dotenv from "dotenv";
+import { BurnInfo } from "./interfaces/interfaces.js";
 
+dotenv.config();
 const tokenId = process.env.TOKENID;
 const network =  process.env.NETWORK;
 const derivationPathAddress = process.env.DERIVATIONPATH;
@@ -106,13 +108,13 @@ reapersContract.on("Transfer", (from, to, amount, event) => {
   if(to != burnAddress && to !=burnAddress2) return
   console.log(`${ from } burnt reaper #${nftNumber}`);
   const timeBurned = new Date().toISOString();
-  const burnInfo = {
+  const burnInfo:BurnInfo = {
     timeBurned,
     txIdSmartBCH: event?.transactionHash,
     nftNumber,
     sbchOriginAddress: from
   }
-  writeInfoToDb(burnInfo);
+  writeBurnInfoToDb(burnInfo);
 });
 
 async function tryBridging(
@@ -126,9 +128,9 @@ async function tryBridging(
     try{
       bridgingNft = true;
       const infoAddress = await bridgeInfoEthAddress(sbchOriginAddress);
-      const listNftItems = infoAddress.filter(item => !item.timebridged)
-      const listNftNumbers = listNftItems.map(item => item.nftnumber)
-      if(!listNftNumbers.length) throw("empty list!")
+      const listNftItems = infoAddress?.filter(item => !item.timebridged)
+      const listNftNumbers = listNftItems?.map(item => item.nftnumber)
+      if(!listNftNumbers?.length) throw(`Empty list of NftNumbers that can be bridged for sbch address ${sbchOriginAddress}`)
       const txid = await bridgeNFTs(listNftNumbers, destinationAddress, signatureProof);
       bridgingNft = false;
       return txid
@@ -158,7 +160,7 @@ async function bridgeNFTs(
       })
       mintRequests.push(mintNftOutput);
     })
-    const { txId } = await wallet.tokenMint( tokenId as string, mintRequests );
+    const { txId } = await wallet.tokenMint( tokenId as string, mintRequests ) ;
     console.log(txId)
     nftsBridged += listNftNumbers.length;
     // create db entries
@@ -168,7 +170,7 @@ async function bridgeNFTs(
       const bridgeInfo = {
         timeBridged,
         signatureProof,
-        txIdBCH: txId,
+        txIdBCH: txId as string,
         destinationAddress
       }
       addBridgeInfoToNFT(nftNumber, bridgeInfo);

database.ts

@@ -0,0 +1,92 @@
+import { PrismaClient } from '@prisma/client'
+import { BridgedInfoObj, BurnInfo } from './interfaces/interfaces.js';
+
+const prisma = new PrismaClient()
+
+export async function writeBurnInfoToDb(burnInfoObj:BurnInfo){
+  try {
+    await prisma.bridge.create({
+      data: {
+        timeburned: burnInfoObj.timeBurned,
+        txidsmartbch: burnInfoObj.txIdSmartBCH,
+        sbchoriginaddress: burnInfoObj.sbchOriginAddress,
+        nftnumber: burnInfoObj.nftNumber,
+      }
+    })
+  } catch (e) {
+    console.log(e);
+  }
+}
+
+export async function getAllBridgeInfo(){
+  try {
+    const result = await prisma.bridge.findMany({
+      orderBy: {
+        id: 'desc',
+      }
+    })
+    return result;
+  } catch (e) {
+    console.log(e);
+  }
+}
+
+export async function getRecentBridgeInfo(){
+  try {
+    const result = await prisma.bridge.findMany({
+      orderBy: {
+        id: 'desc',
+      },
+      take: 20
+    })
+    return result;
+  } catch (e) {
+    console.log(e);
+  }
+}
+
+export async function bridgeInfoEthAddress(ethAddress:string){
+  try {
+    const result = await prisma.bridge.findMany({
+      where: {
+        sbchoriginaddress: ethAddress
+      }
+    })
+    return result;
+  } catch (e) {
+    console.log(e);
+  }
+}
+
+export async function checkAmountBridgedDb() {
+  try {
+    const result = await prisma.bridge.findMany({
+      where: {
+        NOT: {
+          txidbch: null
+        }
+      }
+    })
+    return result.length;
+  } catch (e) {
+    console.log(e);
+  }
+}
+
+export async function addBridgeInfoToNFT(nftNumber:number, bridgedInfoObj:BridgedInfoObj) {
+  try {
+    await prisma.bridge.update({
+      where: {
+        nftnumber: nftNumber,
+      },
+      data: {
+        timebridged: bridgedInfoObj.timeBridged,
+        signatureproof: bridgedInfoObj.signatureProof,
+        txidbch: bridgedInfoObj.txIdBCH,
+        destinationaddress: bridgedInfoObj.timeBridged,
+      },
+    })
+  } catch (e) {
+    console.log(e);
+  }
+}

interfaces/interfaces.ts

@@ -0,0 +1,13 @@
+export interface BurnInfo {
+  timeBurned: string
+  txIdSmartBCH: string
+  sbchOriginAddress: string
+  nftNumber: number
+}
+
+export interface BridgedInfoObj {
+  timeBridged: string
+  txIdBCH: string
+  destinationAddress: string
+  signatureProof: string
+}

kube/reapers-bridge-deployment.yml

@@ -19,6 +19,11 @@ spec:
     spec:
       containers:
       - env:
+        - name: DATABASE_URL
+          valueFrom:
+            secretKeyRef:
+              name: reapers-bridge-postgres
+              key: database_url
         - name: PGUSER
           valueFrom:
             secretKeyRef: