OSDN Git Service

update the build-chain-transactions function.
[bytom/bytom-electron.git] / src / features / transactions / actions.js
index 3a525c3..d883334 100644 (file)
@@ -1,7 +1,9 @@
-import { chainClient } from 'utility/environment'
-import { parseNonblankJSON } from 'utility/string'
-import { push } from 'react-router-redux'
-import { baseCreateActions, baseListActions } from 'features/shared/actions'
+import uuid from 'uuid'
+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'
 
@@ -14,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
   }
@@ -32,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.`)
         }
       }
     })
@@ -43,67 +56,193 @@ 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
 }
 
-form.submitForm = (formParams) => function(dispatch) {
-  const buildPromise = chainClient().transactions.build(builder => {
+form.submitForm = (formParams) => function (dispatch) {
+  const client = chainClient()
+
+  const builderFunction = ( builder ) => {
     const processed = preprocessTransaction(formParams)
 
-    builder.actions = processed.actions.map(action => {
-      let result = {
-        address: action.address,
-        amount: action.amount,
-        account_id: action.accountId,
-        account_alias: action.accountAlias,
-        asset_id: action.assetId,
-        asset_alias: action.assetAlias,
-        type: action.type,
+    builder.actions = processed.actions
+    if (processed.baseTransaction) {
+      builder.baseTransaction = processed.baseTransaction
+    }
+  }
+
+  const submitSucceeded = () => {
+    dispatch(form.created())
+    dispatch(push({
+      pathname: '/transactions',
+      state: {
+        preserveFlash: true
       }
-      if (action.receiver) {
-        result.receiver = {
-          control_program: action.receiver.controlProgram,
-          expires_at: action.receiver.expiresAt
+    }))
+  }
+
+  // normal transactions
+  if( formParams.form === 'normalTx'){
+
+    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)
+  }
+
+  //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)
       }
-      return result
-    })
-    if (processed.baseTransaction) {
-      builder.baseTransaction = processed.baseTransaction
+
+      if( formParams.state.showAdvanced
+        && formParams.signTransaction ){
+        const transaction = JSON.parse(formParams.signTransaction)
+        return signAndSubmitTransaction(transaction)
+      }
+
+      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)
     }
-  })
 
-  if (formParams.submitAction == 'submit') {
     return buildPromise
-      .then((resp) => {
-        if (resp.status === 'fail') {
-          throw new Error(resp.msg)
-        }
+      .then(resp => signAndSubmitGeneratedTransaction(resp.data))
+  }
 
-        const tpl = resp.data
-        const password = (tpl.signing_instructions || []).map(() => '123456')
-        const client = chainClient()
-        const body = Object.assign({}, {password, 'transaction': tpl})
-        return client.connection.request('/sign-submit-transaction', body, true)
-      }).then(resp => {
+  //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') {
-          throw new Error(resp.msg)
+          dispatch({type: 'ERROR', payload: {'message': resp.msg}})
+        } else {
+          dispatch({type: 'DECODE_TRANSACTION', data:resp.data})
         }
-
-        dispatch(form.created())
-        dispatch(push({
-          pathname: '/transactions'
-        }))
+      })
+      .catch(err => {
+        dispatch({type: 'DECODE_TRANSACTION', data:[]})
+        throw {_error: err}
       })
   }
 }
@@ -111,4 +250,5 @@ form.submitForm = (formParams) => function(dispatch) {
 export default {
   ...list,
   ...form,
+  decode,
 }