OSDN Git Service

update the build-chain-transactions function.
[bytom/bytom-electron.git] / src / features / transactions / actions.js
index 1c69abc..d883334 100644 (file)
@@ -1,8 +1,9 @@
 import uuid from 'uuid'
-import { chainClient, chainSigner } from 'utility/environment'
-import { parseNonblankJSON } from 'utility/string'
-import { push } from 'react-router-redux'
-import { baseCreateActions, baseListActions } from 'features/shared/actions'
+import {chainClient, btmID} from 'utility/environment'
+import {parseNonblankJSON} from 'utility/string'
+import {push} from 'react-router-redux'
+import {baseCreateActions, baseListActions} from 'features/shared/actions'
+import { normalTxActionBuilder, issueAssetTxActionBuilder } from './transactions'
 
 const type = 'transaction'
 
@@ -15,9 +16,20 @@ function preprocessTransaction(formParams) {
   const copy = JSON.parse(JSON.stringify(formParams))
   const builder = {
     baseTransaction: copy.baseTransaction,
-    actions: copy.actions,
+    actions: copy.actions || [],
   }
 
+  if (formParams.form === 'normalTx') {
+    const gasPrice = formParams.state.estimateGas * Number(formParams.gasLevel)
+    builder.actions = normalTxActionBuilder(formParams,  Number(gasPrice), 'amount')
+  }
+
+  if (formParams.form === 'issueAssetTx') {
+    const gasPrice = formParams.state.estimateGas * Number(formParams.gasLevel)
+    builder.actions = issueAssetTxActionBuilder(formParams, Number(gasPrice), 'amount')
+  }
+
+
   if (builder.baseTransaction == '') {
     delete builder.baseTransaction
   }
@@ -33,10 +45,10 @@ function preprocessTransaction(formParams) {
     intFields.forEach(key => {
       const value = a[key]
       if (value) {
-        if ((parseInt(value)+'') == value) {
+        if ((parseInt(value) + '') == value) {
           a[key] = parseInt(value)
         } else {
-          throw new Error(`Action ${parseInt(i)+1} ${key} must be an integer.`)
+          throw new Error(`Action ${parseInt(i) + 1} ${key} must be an integer.`)
         }
       }
     })
@@ -44,88 +56,199 @@ function preprocessTransaction(formParams) {
     try {
       a.referenceData = parseNonblankJSON(a.referenceData)
     } catch (err) {
-      throw new Error(`Action ${parseInt(i)+1} reference data should be valid JSON, or blank.`)
+      throw new Error(`Action ${parseInt(i) + 1} reference data should be valid JSON, or blank.`)
     }
 
     try {
       a.receiver = parseNonblankJSON(a.receiver)
     } catch (err) {
-      throw new Error(`Action ${parseInt(i)+1} receiver should be valid JSON.`)
+      throw new Error(`Action ${parseInt(i) + 1} receiver should be valid JSON.`)
     }
   }
 
   return builder
 }
 
-function getTemplateXpubs(tpl) {
-  const xpubs = []
-  tpl.signingInstructions.forEach((instruction) => {
-    instruction.witnessComponents.forEach((component) => {
-      component.keys.forEach((key) => {
-        xpubs.push(key.xpub)
-      })
-    })
-  })
-  return xpubs
-}
+form.submitForm = (formParams) => function (dispatch) {
+  const client = chainClient()
 
-form.submitForm = (formParams) => function(dispatch) {
-  const buildPromise = chainClient().transactions.build(builder => {
+  const builderFunction = ( builder ) => {
     const processed = preprocessTransaction(formParams)
 
     builder.actions = processed.actions
     if (processed.baseTransaction) {
       builder.baseTransaction = processed.baseTransaction
     }
-  })
+  }
 
-  if (formParams.submitAction == 'submit') {
-    return buildPromise
-      .then(tpl => {
-        const signer = chainSigner()
+  const submitSucceeded = () => {
+    dispatch(form.created())
+    dispatch(push({
+      pathname: '/transactions',
+      state: {
+        preserveFlash: true
+      }
+    }))
+  }
 
-        getTemplateXpubs(tpl).forEach(key => {
-          signer.addKey(key, chainClient().mockHsm.signerConnection)
-        })
+  // normal transactions
+  if( formParams.form === 'normalTx'){
 
-        return signer.sign(tpl)
-      }).then(signed => chainClient().transactions.submit(signed))
-      .then(resp => {
-        dispatch(form.created())
-        dispatch(push({
-          pathname: `/transactions/${resp.id}`,
-          state: {
-            preserveFlash: true
-          }
-        }))
+    const accountId = formParams.accountId
+    const accountAlias = formParams.accountAlias
+    const accountInfo = Object.assign({},  accountAlias!== ''? {alias: accountAlias}: {id: accountId})
+
+    const isBTM = (formParams.assetId === btmID) || (formParams.assetAlias === 'BTM')
+
+    return client.accounts.query(accountInfo)
+      .then( resp => {
+        if(resp.data[0].xpubs.length > 1){
+          throw {code: 'F_BTM003'}
+        }
+        const body = Object.assign({}, {xpub: resp.data[0].xpubs[0], password: formParams.password})
+        return client.mockHsm.keys.checkPassword(body)
+      })
+      .then( result => {
+        if(!result.data.checkResult){
+          throw new Error('PasswordWrong')
+        }
+        if(isBTM)
+          return client.transactions.buildChain(builderFunction)
+        else
+          return client.transactions.build(builderFunction)
+      })
+      .then( tpl => {
+        if(isBTM){
+          const body = Object.assign({}, {password: formParams.password, transactions: tpl.data})
+          return client.transactions.signBatch(body)
+        }
+        else{
+          const body = Object.assign({}, {password: formParams.password, transaction: tpl.data})
+          return client.transactions.sign(body)
+        }
       })
+      .then(signed => {
+        if(!signed.data.signComplete){
+          throw {code: 'F_BTM100'}
+        }
+        if(isBTM){
+          const rawTransactions = signed.data.transaction.map(tx => tx.rawTransaction)
+          return client.transactions.submitBatch(rawTransactions)
+        }
+        else{
+          return client.transactions.submit(signed.data.transaction.rawTransaction)
+        }
+      })
+      .then(submitSucceeded)
   }
 
-  // submitAction == 'generate'
-  return buildPromise
-    .then(tpl => {
-      const signer = chainSigner()
+  //advanced transactions
+  else if( formParams.form === 'advancedTx' ){
+    const buildPromise = (formParams.state.showAdvanced && formParams.signTransaction) ? null :
+      client.transactions.build(builderFunction)
+
+    if (formParams.submitAction == 'submit') {
+      const signAndSubmitTransaction = (transaction) => {
+        const body = Object.assign({}, {password: formParams.password, transaction: transaction})
+        return client.transactions.sign(body)
+          .then( signed => client.transactions.submit(signed.data.transaction.rawTransaction) )
+          .then(submitSucceeded)
+      }
 
-      getTemplateXpubs(tpl).forEach(key => {
-        signer.addKey(key, chainClient().mockHsm.signerConnection)
-      })
+      if( formParams.state.showAdvanced
+        && formParams.signTransaction ){
+        const transaction = JSON.parse(formParams.signTransaction)
+        return signAndSubmitTransaction(transaction)
+      }
 
-      return signer.sign({...tpl, allowAdditionalActions: true})
-    })
-    .then(signed => {
-      const id = uuid.v4()
-      dispatch({
-        type: 'GENERATED_TX_HEX',
-        generated: {
-          id: id,
-          hex: signed.rawTransaction,
-        },
+      return buildPromise
+        .then(tpl => signAndSubmitTransaction(tpl.data))
+    }
+
+    // submitAction == 'generate'
+    const signAndSubmitGeneratedTransaction = (transaction) => {
+      const body = Object.assign({}, {password: formParams.password, transaction: transaction})
+      return client.transactions.sign(body)
+        .then(resp => {
+          const id = uuid.v4()
+          dispatch({
+            type: 'GENERATED_TX_HEX',
+            generated: {
+              id: id,
+              hex: JSON.stringify(resp.data.transaction),
+            },
+          })
+          dispatch(push(`/transactions/generated/${id}`))
+        })
+    }
+
+    if (formParams.state.showAdvanced
+      && formParams.signTransaction) {
+      const transaction = JSON.parse(formParams.signTransaction)
+      return signAndSubmitGeneratedTransaction(transaction)
+    }
+
+    return buildPromise
+      .then(resp => signAndSubmitGeneratedTransaction(resp.data))
+  }
+
+  //issue Asset transactions
+  else if( formParams.form === 'issueAssetTx'){
+    //submit action
+    const signAndSubmitTransaction = (transaction) => {
+      const body = Object.assign({}, {password: formParams.password, transaction: transaction})
+      return client.transactions.sign(body)
+        .then( signed =>{
+          if(!signed.data.signComplete){
+            const id = uuid.v4()
+            dispatch({
+              type: 'GENERATED_TX_HEX',
+              generated: {
+                id: id,
+                hex: JSON.stringify(signed.data.transaction),
+              },
+            })
+            dispatch(push(`/transactions/generated/${id}`))
+
+          }else{
+            return client.transactions.submit(signed.data.transaction.rawTransaction)
+              .then(submitSucceeded)
+          }
+        })
+    }
+
+    if (formParams.submitAction == 'submit') {
+      return client.transactions.build(builderFunction)
+        .then(tpl => signAndSubmitTransaction(tpl.data))
+    }
+
+    if( formParams.submitAction == 'sign' ){
+      const transaction = JSON.parse(formParams.signTransaction)
+      return signAndSubmitTransaction(transaction)
+    }
+
+  }
+}
+
+const decode = (data) => {
+  return (dispatch) => {
+    return  chainClient().transactions.decodeTransaction(data)
+      .then((resp) => {
+        if (resp.status === 'fail') {
+          dispatch({type: 'ERROR', payload: {'message': resp.msg}})
+        } else {
+          dispatch({type: 'DECODE_TRANSACTION', data:resp.data})
+        }
       })
-      dispatch(push(`/transactions/generated/${id}`))
-    })
+      .catch(err => {
+        dispatch({type: 'DECODE_TRANSACTION', data:[]})
+        throw {_error: err}
+      })
+  }
 }
 
 export default {
   ...list,
   ...form,
+  decode,
 }