wip check allowance for dt and ocean at pool creation

src/balancer/OceanPool.ts

@@ -118,28 +118,36 @@ export class OceanPool extends Pool {
       const address = createTxid.events.BPoolRegistered.returnValues[0]
       const oceanWeight = 10 - parseFloat(dtWeight)
       this.dtAddress = dtAddress
-      observer.next(PoolCreateProgressStep.ApprovingDatatoken)
       let txid
-      txid = await this.approve(
+      let dtAllowance
-        account,
+      dtAllowance = await this.allowance(dtAddress, account, address)
-        dtAddress,
+      if (dtAllowance < dtAmount){
-        address,
+        observer.next(PoolCreateProgressStep.ApprovingDatatoken)
-        this.web3.utils.toWei(String(dtAmount))
+        txid = await this.approve(
-      )
+          account,
-      if (!txid) {
+          dtAddress,
-        this.logger.error('ERROR: Failed to call approve DT token')
+          address,
-        return null
+          this.web3.utils.toWei(String(dtAmount))
+        )
+        if (!txid) {
+          this.logger.error('ERROR: Failed to call approve DT token')
+          return null
+        }  
       }
-      observer.next(PoolCreateProgressStep.ApprovingOcean)
+      let oceanAllowance
-      txid = await this.approve(
+      oceanAllowance = await this.allowance(dtAddress, account, address)
-        account,
+      if (oceanAllowance < oceanAmount){
-        this.oceanAddress,
+        observer.next(PoolCreateProgressStep.ApprovingOcean)
-        address,
+        txid = await this.approve(
-        this.web3.utils.toWei(String(oceanAmount))
+          account,
-      )
+          this.oceanAddress,
-      if (!txid) {
+          address,
-        this.logger.error('ERROR: Failed to call approve OCEAN token')
+          this.web3.utils.toWei(String(oceanAmount))
-        return null
+        )
+        if (!txid) {
+          this.logger.error('ERROR: Failed to call approve OCEAN token')
+          return null
+        }
       }
       observer.next(PoolCreateProgressStep.SetupPool)
       txid = await super.setup(

src/balancer/Pool.ts

@@ -4,6 +4,7 @@ import { TransactionReceipt } from 'web3-core'
 import { Logger, getFairGasPrice } from '../utils'
 import BigNumber from 'bignumber.js'
 import jsonpoolABI from '@oceanprotocol/contracts/artifacts/BPool.json'
+import defaultDatatokensABI from '@oceanprotocol/contracts/artifacts/DataTokenTemplate.json'
 import { PoolFactory } from './PoolFactory'
 
 const MaxUint256 =
@@ -107,6 +108,25 @@ export class Pool extends PoolFactory {
     return result
   }
 
+  /**
+   * Get Alloance for both DataToken and Ocean
+   * @param {String } tokenAdress
+   * @param {String} owner
+   * @param {String} spender
+   */
+  public async allowance(
+    tokenAdress: string,
+    owner: string,
+    spender: string
+  ): Promise<string> {
+    const tokenAbi = (defaultDatatokensABI.abi as AbiItem[])
+    const datatoken = new this.web3.eth.Contract(tokenAbi, tokenAdress, {
+      from: spender
+    })
+    const trxReceipt = await datatoken.methods.allowance(owner, spender).call()
+    return this.web3.utils.fromWei(trxReceipt)
+  }
+
   /**
    * Approve spender to spent amount tokens
    * @param {String} account