feat: using new tx service and delete old

Author: classicalliu

packages/neuron-wallet/src/controllers/transactions.ts

@@ -1,5 +1,8 @@
 import { Transaction } from '../types/cell-types'
-import TransactionsService, { PaginationResult, TransactionsByLockHashesParam } from '../services/transactions'
+import TransactionsService, {
+  PaginationResult,
+  TransactionsByLockHashesParam,
+} from '../services/tx/transaction-service'
 
 import AddressesService from '../services/addresses'
 import WalletsService from '../services/wallets'

packages/neuron-wallet/src/database/address/dao.ts

@@ -2,10 +2,11 @@ import { Not, In } from 'typeorm'
 import AddressEntity, { AddressVersion } from './entities/address'
 import { AddressType } from '../../models/keys/address'
 import { getConnection } from './ormconfig'
-import TransactionsService, { OutputStatus } from '../../services/transactions'
+import TransactionsService from '../../services/tx/transaction-service'
 import CellsService from '../../services/cells'
 import LockUtils from '../../models/lock-utils'
 import { TransactionStatus } from '../../types/cell-types'
+import { OutputStatus } from '../../services/tx/params'
 
 export interface Address {
   walletId: string

packages/neuron-wallet/src/database/chain/migrations/1562038960990-AddStatusToTx.ts

@@ -1,6 +1,6 @@
 import {MigrationInterface, QueryRunner, TableColumn, getConnection} from "typeorm";
 import TransactionEntity from '../entities/transaction'
-import { OutputStatus } from '../../../services/transactions'
+import { OutputStatus } from '../../../services/tx/params'
 import { TransactionStatus } from '../../../types/cell-types'
 
 export class AddStatusToTx1562038960990 implements MigrationInterface {

packages/neuron-wallet/src/listeners/tx-status.ts

@@ -1,9 +1,9 @@
 import { remote } from 'electron'
 import { interval } from 'rxjs'
-import TransactionsService from '../services/transactions'
 import { TransactionStatus } from '../types/cell-types'
 import LockUtils from '../models/lock-utils'
 import AddressesUsedSubject from '../models/subjects/addresses-used-subject'
+import FailedTransaction from '../services/tx/failed-transaction'
 
 const { nodeService } = remote.require('./startup/sync-block-task/params')
 
@@ -21,7 +21,7 @@ const getTransactionStatus = async (hash: string) => {
 }
 
 const trackingStatus = async () => {
-  const pendingTransactions = await TransactionsService.pendings()
+  const pendingTransactions = await FailedTransaction.pendings()
   if (!pendingTransactions.length) {
     return
   }
@@ -39,7 +39,7 @@ const trackingStatus = async () => {
   if (!failedTxs.length) {
     return
   }
-  const blake160s = await TransactionsService.updateFailedTxs(failedTxs.map(tx => tx.hash))
+  const blake160s = await FailedTransaction.updateFailedTxs(failedTxs.map(tx => tx.hash))
   const usedAddresses = blake160s.map(blake160 => LockUtils.blake160ToAddress(blake160))
   AddressesUsedSubject.getSubject().next(usedAddresses)
 }

packages/neuron-wallet/src/services/cells.ts

@@ -2,7 +2,7 @@ import { getConnection, In } from 'typeorm'
 import OutputEntity from '../database/chain/entities/output'
 import { Cell, OutPoint, Input } from '../types/cell-types'
 import { CapacityNotEnough } from '../exceptions'
-import { OutputStatus } from './transactions'
+import { OutputStatus } from './tx/params'
 
 export const MIN_CELL_CAPACITY = '6000000000'
 

packages/neuron-wallet/src/services/sync/check-and-save/tx.ts

@@ -2,7 +2,7 @@ import { getConnection } from 'typeorm'
 import { Subject } from 'rxjs'
 import { Transaction, Cell, OutPoint } from '../../../types/cell-types'
 import OutputEntity from '../../../database/chain/entities/output'
-import TransactionsService from '../../transactions'
+import SaveTransaction from '../../tx/save-transaction'
 import CheckOutput from './output'
 import LockUtils from '../../../models/lock-utils'
 import { addressesUsedSubject as addressesUsedSubjectParam } from '../renderer-params'
@@ -32,7 +32,7 @@ export default class CheckTx {
   public checkAndSave = async (lockHashes: string[]): Promise<boolean> => {
     const addresses = await this.check(lockHashes)
     if (addresses.length > 0) {
-      await TransactionsService.saveFetchTx(this.tx)
+      await SaveTransaction.saveFetchTx(this.tx)
       this.addressesUsedSubject.next(addresses)
       return true
     }

packages/neuron-wallet/src/services/sync/queue.ts

@@ -3,8 +3,8 @@ import { Block, BlockHeader } from '../../types/cell-types'
 import RangeForCheck from './range-for-check'
 import BlockNumber from './block-number'
 import Utils from './utils'
-import TransactionsService from '../transactions'
 import QueueAdapter from './queue-adapter'
+import SaveTransaction from '../tx/save-transaction'
 
 export default class Queue {
   private q: any
@@ -106,7 +106,7 @@ export default class Queue {
         const rangeFirstBlockHeader: BlockHeader = range[0]
         await this.currentBlockNumber.updateCurrent(BigInt(rangeFirstBlockHeader.number))
         await this.rangeForCheck.setRange([])
-        await TransactionsService.deleteWhenFork(rangeFirstBlockHeader.number)
+        await SaveTransaction.deleteWhenFork(rangeFirstBlockHeader.number)
         await this.cleanQueue()
         this.startBlockNumber = await this.currentBlockNumber.getCurrent()
         this.batchPush()