Sparrow dom/tranaction hash

src/contractInterface/users/resolver.js

@@ -11,8 +11,8 @@ class UsersResolver {
     this.currentAdapter = this.adapters[this.currentVersion]
   }
 
-  async set({ profile, attestations = [] }) {
-    return this.currentAdapter.set({ profile, attestations })
+  async set({ profile, attestations = [], options = {} }) {
+    return this.currentAdapter.set({ profile, attestations, options })
   }
 
   async get(address) {

src/contractInterface/users/v00_adapter.js

@@ -20,13 +20,13 @@ class V00_UsersAdapter {
     this.contractName = 'V00_UserRegistry'
   }
 
-  async set({ profile, attestations = [] }) {
+  async set({ profile, attestations = [], options = {}}) {
     if (profile) {
       const selfAttestation = await this.profileAttestation(profile)
       attestations.push(selfAttestation)
     }
     const newAttestations = await this.newAttestations(attestations)
-    return await this.addAttestations(newAttestations)
+    return await this.addAttestations(newAttestations, options)
   }
 
   async get(address) {
@@ -91,7 +91,7 @@ class V00_UsersAdapter {
     })
   }
 
-  async addAttestations(attestations) {
+  async addAttestations(attestations, options) {
     const account = await this.contractService.currentAccount()
     const userRegistry = await this.contractService.deployed(
       this.contractService.contracts[this.contractName]
@@ -123,7 +123,7 @@ class V00_UsersAdapter {
           'ClaimHolderRegistered',
           'addClaims',
           [topics, issuers, sigs, data, dataOffsets],
-          { from: account, gas: 400000, contractAddress: identityAddress }
+          { ...options, from: account, gas: 400000, contractAddress: identityAddress }
         )
       } else {
         // create identity with presigned claims
@@ -138,7 +138,8 @@ class V00_UsersAdapter {
             data,
             dataOffsets
           ],
-          { from: account, gas }
+          { from: account, gas },
+          options
         )
       }
     } else if (!identityAddress) {

src/resources/users.js

@@ -5,8 +5,8 @@ class Users {
     this.resolver = new UsersResolver({ contractService, ipfsService })
   }
 
-  async set({ profile, attestations = [] }) {
-    return this.resolver.set({ profile, attestations })
+  async set({ profile, attestations = [], options = {}}) {
+    return this.resolver.set({ profile, attestations, options })
   }
 
   async get(address) {

src/services/contract-service.js

@@ -192,7 +192,7 @@ class ContractService {
     return withLibraryAddresses
   }
 
-  async deploy(contract, args, options) {
+  async deploy(contract, args, options, { confirmationCallback, transactionHashCallback } = {} ) {
     const bytecode = await this.getBytecode(contract)
     const deployed = await this.deployed(contract)
     const txReceipt = await new Promise((resolve, reject) => {
@@ -205,16 +205,53 @@ class ContractService {
         .on('receipt', receipt => {
           resolve(receipt)
         })
+        //.on('confirmation', confirmationCallback)
+        //.on('transactionHash', transactionHashCallback)
+        // Workaround for "confirmationCallback" not being triggered with web3 version:1.0.0-beta.34
+        .on('transactionHash', (hash) => {
+          if (transactionHashCallback)
+            transactionHashCallback(hash)
+          if (confirmationCallback)
+            this.checkForDeploymentCompletion(hash, confirmationCallback)
+        })
         .on('error', err => reject(err))
     })
     return txReceipt
   }
 
+  /* confirmation callback does not get triggered in current version of web3 version:1.0.0-beta.34
+   * so this function perpetually (until 5 confirmations) checks for presence of deployed contract.
+   *
+   * This could also be a problem in Ethereum node: https://github.com/ethereum/web3.js/issues/1255
+   */
+  async checkForDeploymentCompletion(hash, confirmationCallback) {
+    const transactionInfo = await this.web3.eth.getTransaction(hash)
+
+    // transaction not mined
+    if (transactionInfo.blockNumber === null){
+      setTimeout(() => {
+        this.checkForDeploymentCompletion(hash, confirmationCallback)
+      }, 1500)
+    } else {
+      const currentBlockNumber = await this.web3.eth.getBlockNumber()
+      const confirmations = currentBlockNumber - transactionInfo.blockNumber
+      confirmationCallback(confirmations, {
+        transactionHash: transactionInfo.hash
+      })
+      // do checks untill 5 block confirmations
+      if (confirmations < 5) {
+        setTimeout(() => {
+          this.checkForDeploymentCompletion(hash, confirmationCallback)
+        }, 1500)
+      }
+    }
+  }
+
   async call(
     contractName,
     functionName,
     args = [],
-    { contractAddress, from, gas, value, confirmationCallback, additionalGas = 0 } = {}
+    { contractAddress, from, gas, value, confirmationCallback, transactionHashCallback, additionalGas = 0 } = {}
   ) {
     const contractDefinition = this.contracts[contractName]
     if (typeof contractDefinition === 'undefined') {
@@ -239,6 +276,7 @@ class ContractService {
         .send(opts)
         .on('receipt', resolve)
         .on('confirmation', confirmationCallback)
+        .on('transactionHash', transactionHashCallback)
         .on('error', reject)
     })
     const block = await this.web3.eth.getBlock(transactionReceipt.blockNumber)