Dev

.github/workflows/auto-tag.yml

@@ -10,8 +10,8 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v3
-    - uses: butlerlogic/action-autotag@stable
+    - uses: butlerlogic/action-autotag@1.1.2
       env:
         GITHUB_TOKEN: "${{ secrets.GITHUB_TOKEN }}"
       with:
-        strategy: package
+        strategy: package

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@lumerin/wallet-core",
-  "version": "1.0.64",
+  "version": "1.0.90",
   "author": {
     "name": "Lumerin",
     "email": "developer@lumerin.io",
@@ -34,12 +34,13 @@
     "abi-decoder": "^2.4.0",
     "axios": "0.21.1",
     "axios-cookiejar-support": "1.0.1",
+    "bottleneck": "^2.19.5",
     "chalk": "^2.4.2",
     "cheerio": "^1.0.0-rc.12",
-    "contracts-js": "github:Lumerin-protocol/contracts-js#v0.0.24",
+    "contracts-js": "github:Lumerin-protocol/contracts-js#v0.1.0",
     "cross-port-killer": "^1.4.0",
     "debug": "4.1.1",
-    "ecies-geth": "^1.6.2",
+    "ecies-geth": "^1.7.0",
     "electron-log": "^4.4.8",
     "ethereumjs-wallet": "1.0.1",
     "ip": "^1.1.8",

src/plugins/contracts/api.js

@@ -19,7 +19,7 @@ async function _loadContractInstance(
   try {
     const implementationContract = Implementation(web3, implementationAddress)
     const contract = await implementationContract.methods
-      .getPublicVariables()
+      .getPublicVariablesV2()
       .call()
     const stats = await implementationContract.methods.getStats().call()
 
@@ -39,10 +39,14 @@ async function _loadContractInstance(
 
     const {
       _state: state,
-      _price: price, // cost to purchase the contract
-      _limit: limit, // max th provided
-      _speed: speed, // th/s of contract
-      _length: length, // duration of the contract in seconds
+      _terms: {
+        _price: price, // cost to purchase the contract
+        _limit: limit, // max th provided
+        _speed: speed, // th/s of contract
+        _length: length, // duration of the contract in seconds
+        _version: version,
+        _profitTarget: profitTarget
+      }, 
       _startingBlockTimestamp: timestamp, // timestamp of the block at moment of purchase
       _buyer: buyer, // wallet address of the purchasing party
       _seller: seller, // wallet address of the selling party
@@ -60,6 +64,8 @@ async function _loadContractInstance(
         speed: data._speed,
         length: data._length,
         limit: data._limit,
+        version: data._version,
+        profitTarget: data._profitTarget
       }
     }
 
@@ -84,9 +90,12 @@ async function _loadContractInstance(
         hasFutureTerms,
         futureTerms,
         history: buyerHistory,
+        version,
+        profitTarget
       },
     }
   } catch (err) {
+    logger.error(err)
     logger.error(
       'Error when trying to load Contracts by address in the Implementation contract: ',
       err
@@ -109,20 +118,32 @@ async function getContracts(
   lumerin,
   cloneFactory,
   addresses,
-  walletAddress
+  walletAddress,
+  eventBus
 ) {
-  return Promise.all(
-    addresses.map((address) =>
-      getContract(
-        web3,
-        web3Subscriptionable,
-        lumerin,
-        cloneFactory,
-        address,
-        walletAddress
-      )
+  const chunkSize = 5
+  const result = []
+  for (let i = 0; i < addresses.length; i += chunkSize) {
+    const contracts = await Promise.all(
+      addresses
+        .slice(i, i + chunkSize)
+        .map((address) =>
+          getContract(
+            web3,
+            web3Subscriptionable,
+            lumerin,
+            cloneFactory,
+            address,
+            walletAddress
+          )
+        )
     )
-  )
+    eventBus.emit('contract-updated', {
+      actives: contracts,
+    })
+    result.push(...contracts)
+  }
+  return result
 }
 
 /**
@@ -155,24 +176,31 @@ async function getContract(
   return contractInfo.data
 }
 
+/**
+ * @param {import('contracts-js').CloneFactoryContext} cloneFactory
+ */
+const getMarketplaceFee = (cloneFactory) => async () => {
+  return await cloneFactory.methods.marketplaceFee().call()
+}
+
 /**
  * @param {import('web3').default} web3
  * @param {import('contracts-js').CloneFactoryContext} cloneFactory
  */
-function createContract(web3, cloneFactory, plugins) {
+function createContract(web3, cloneFactory) {
   if (!web3) {
     logger.error('Not a valid Web3 instance')
     return
   }
 
   return async function (params) {
-    // const { gasPrice } = await plugins.wallet.getGasPrice()
     let {
       price,
       limit = 0,
       speed,
       duration,
       sellerAddress,
+      profit = 0,
       validatorAddress = '0x0000000000000000000000000000000000000000',
       privateKey,
     } = params
@@ -191,37 +219,41 @@ function createContract(web3, cloneFactory, plugins) {
 
     const account = web3.eth.accounts.privateKeyToAccount(privateKey)
     web3.eth.accounts.wallet.create(0).add(account)
+    const marketplaceFee = await cloneFactory.methods.marketplaceFee().call()
 
     const gas = await cloneFactory.methods
-      .setCreateNewRentalContract(
+      .setCreateNewRentalContractV2(
         price,
         limit,
         speed,
         duration,
+        +profit,
         validatorAddress,
         pubKey.toString('hex')
       )
       .estimateGas({
         from: sellerAddress,
+        value: marketplaceFee,
       })
 
     return cloneFactory.methods
-      .setCreateNewRentalContract(
+      .setCreateNewRentalContractV2(
         price,
         limit,
         speed,
         duration,
+        +profit,
         validatorAddress,
         pubKey.toString('hex')
       )
-      .send({ from: sellerAddress, gas })
+      .send({ from: sellerAddress, gas, value: marketplaceFee })
   }
 }
 
 /**
  * @param {import('web3').default} web3
  */
-function cancelContract(web3) {
+function cancelContract(web3, cloneFactory) {
   if (!web3) {
     logger.error('Not a valid Web3 instance')
     return
@@ -230,7 +262,6 @@ function cancelContract(web3) {
   return async function (params) {
     const {
       walletAddress,
-      gasLimit = 1000000,
       contractId,
       privateKey,
       closeOutType,
@@ -239,17 +270,21 @@ function cancelContract(web3) {
     const account = web3.eth.accounts.privateKeyToAccount(privateKey)
     web3.eth.accounts.wallet.create(0).add(account)
 
+    const marketplaceFee = await cloneFactory.methods.marketplaceFee().call()
+
     const gas = await Implementation(web3, contractId)
       .methods.setContractCloseOut(closeOutType)
       .estimateGas({
         from: walletAddress,
+        value: marketplaceFee,
       })
 
     return await Implementation(web3, contractId)
       .methods.setContractCloseOut(closeOutType)
       .send({
         from: walletAddress,
         gas,
+        value: marketplaceFee,
       })
   }
 }
@@ -267,7 +302,6 @@ function setContractDeleteStatus(web3, cloneFactory, onUpdate) {
   return async function (params) {
     const {
       walletAddress,
-      gasLimit = 3000000,
       contractId,
       privateKey,
       deleteContract,
@@ -311,8 +345,8 @@ function setContractDeleteStatus(web3, cloneFactory, onUpdate) {
  */
 function purchaseContract(web3, cloneFactory, lumerin) {
   return async (params) => {
-    const { walletId, contractId, url, privateKey, price } = params
-    const sendOptions = { from: walletId, gas: 1_000_000 }
+    const { walletId, contractId, url, privateKey, price, version } = params
+    const sendOptions = { from: walletId }
 
     //getting pubkey from contract to be purchased
     const implementationContract = Implementation(web3, contractId)
@@ -335,23 +369,42 @@ function purchaseContract(web3, cloneFactory, lumerin) {
       throw new Error('Contract is deleted already')
     }
 
-    const totalPrice = (+price + price * 0.01).toString()
+    const increaseAllowanceEstimate = await lumerin.methods
+      .increaseAllowance(cloneFactory.options.address, price)
+      .estimateGas({
+        from: walletId,
+      })
 
     await lumerin.methods
-      .increaseAllowance(cloneFactory.options.address, totalPrice)
-      .send(sendOptions)
+      .increaseAllowance(cloneFactory.options.address, price)
+      .send({
+        from: walletId,
+        gas: increaseAllowanceEstimate,
+      })
+
+    const marketplaceFee = await cloneFactory.methods.marketplaceFee().call()
 
     const purchaseGas = await cloneFactory.methods
-      .setPurchaseRentalContract(contractId, ciphertext.toString('hex'))
+      .setPurchaseRentalContract(
+        contractId,
+        ciphertext.toString('hex'),
+        version
+      )
       .estimateGas({
         from: sendOptions.from,
+        value: marketplaceFee,
       })
 
     const purchaseResult = await cloneFactory.methods
-      .setPurchaseRentalContract(contractId, ciphertext.toString('hex'))
+      .setPurchaseRentalContract(
+        contractId,
+        ciphertext.toString('hex'),
+        version
+      )
       .send({
         ...sendOptions,
         gas: purchaseGas,
+        value: marketplaceFee,
       })
 
     logger.debug('Finished puchase transaction', purchaseResult)
@@ -375,20 +428,21 @@ function editContract(web3, cloneFactory, lumerin) {
       limit = 0,
       speed,
       duration,
+      profit = 0
     } = params
-    const sendOptions = { from: walletId, gas: 1_000_000 }
+    const sendOptions = { from: walletId }
 
     const account = web3.eth.accounts.privateKeyToAccount(privateKey)
     web3.eth.accounts.wallet.create(0).add(account)
 
     const editGas = await cloneFactory.methods
-      .setUpdateContractInformation(contractId, price, limit, speed, duration)
+      .setUpdateContractInformationV2(contractId, price, limit, speed, duration, +profit)
       .estimateGas({
         from: sendOptions.from,
-      })
-
+      });
+      
     const editResult = await cloneFactory.methods
-      .setUpdateContractInformation(contractId, price, limit, speed, duration)
+      .setUpdateContractInformationV2(contractId, price, limit, speed, duration, +profit)
       .send({
         ...sendOptions,
         gas: editGas,
@@ -406,4 +460,5 @@ module.exports = {
   purchaseContract,
   setContractDeleteStatus,
   editContract,
+  getMarketplaceFee,
 }

src/plugins/contracts/events-listener.js

@@ -33,9 +33,10 @@ class ContractEventsListener {
         .on('connected', () => {
           logger.debug(`Start listen contract (${id}) events`)
         })
-        .on('data', () => {
+        .on('data', async () => {
           logger.debug(`Contract (${id}) updated`)
           if (this.onUpdate){
+            await new Promise((resolve) => setTimeout(resolve, 1000))
             this.onUpdate(id, this.walletAddress || walletAddress)
           }
         })
@@ -49,9 +50,10 @@ class ContractEventsListener {
         .on('connected', () => {
           logger.debug('Start listen clone factory events')
         })
-        .on('data', (event) => {
+        .on('data', async (event) => {
           const contractId = event.returnValues._address
           logger.debug('New contract created', contractId)
+          await new Promise((resolve) => setTimeout(resolve, 1000))
           this.onUpdate(contractId, this.walletAddress)
         })
     }