test

packages/neuron-ui/src/components/Overview/index.tsx

@@ -34,7 +34,7 @@ import CopyZone from 'widgets/CopyZone'
 import { HIDE_BALANCE } from 'utils/const'
 import TransactionType from 'components/TransactionType'
 import { getLockedBalance } from 'services/remote/cellManage'
-import { getFirstSyncInfo, setCkbNodeDataPath, startSync } from 'services/remote'
+import { getFirstSyncInfo, setCkbNodeDataPath, startSync, testLongTimeTransaction } from 'services/remote'
 import FirstSync from 'widgets/Icons/FirstSync.png'
 import DataPathDialog from 'widgets/DataPathDialog'
 import styles from './overview.module.scss'
@@ -167,6 +167,7 @@ const Overview = () => {
   return (
     <PageContainer head={t('navbar.overview')} notice={pageNotice} isHomePage>
       <div className={styles.topContainer}>
+        <Button onClick={() => testLongTimeTransaction()}>Test Long Time Trasaction</Button>
         <div className={styles.mid}>
           <div className={styles.balance}>
             <span className={styles.balanceTitle}>

packages/neuron-ui/src/services/remote/app.ts

@@ -27,6 +27,7 @@ export const getFirstSyncInfo = remoteApi<void, { isFirstSync: boolean; needSize
   'get-first-sync-info'
 )
 export const startSync = remoteApi<void, void>('start-sync')
+export const testLongTimeTransaction = remoteApi<void, void>('long-time-hang')
 
 export type VerifyExternalCkbNodeRes =
   | {

packages/neuron-ui/src/services/remote/remoteApiWrapper.ts

@@ -167,6 +167,7 @@ type Action =
   | 'update-live-cell-local-info'
   | 'get-locked-balance'
   | 'update-live-cells-lock-status'
+  | 'long-time-hang'
 
 export const remoteApi =
   <P = any, R = any>(action: Action) =>

packages/neuron-wallet/src/block-sync-renderer/index.ts

@@ -206,3 +206,18 @@ export async function changeMultisigSyncStatus(status: boolean) {
   isSyncMultisigWithLight = status
   await resetSyncTask(true)
 }
+
+export function longtimeTransaction() {
+  const msg: Required<WorkerMessage<undefined>> = {
+    type: 'call',
+    channel: 'longTimeHang',
+    id: requestId++,
+    message: undefined,
+  }
+  child?.send(msg, err => {
+    if (err) {
+      logger.error(`Sync:\tlongtimeTransaction failed: ${msg}`)
+    }
+  })
+  return true
+}

packages/neuron-wallet/src/block-sync-renderer/task.ts

@@ -1,6 +1,6 @@
 import { type QueryOptions } from '@ckb-lumos/base'
 import initConnection from '../database/chain/ormconfig'
-import { register as registerTxStatusListener } from './tx-status-listener'
+import { longtimeTransaction, register as registerTxStatusListener } from './tx-status-listener'
 import SyncQueue from './sync/queue'
 import logger from '../utils/logger'
 import { ShouldInChildProcess } from '../exceptions'
@@ -21,6 +21,7 @@ export interface WorkerMessage<T = any> {
     | 'address-created'
     | 'indexer-error'
     | 'check-and-save-wallet-address'
+    | 'longTimeHang'
   message: T
 }
 
@@ -92,6 +93,11 @@ export const listener = async ({ type, id, channel, message }: WorkerMessage) =>
       }
       break
     }
+
+    case 'longTimeHang': {
+      longtimeTransaction()
+      break
+    }
     default: {
       // ignore
     }

packages/neuron-wallet/src/block-sync-renderer/tx-status-listener.ts

@@ -8,6 +8,7 @@ import logger from '../utils/logger'
 import { getConnection } from '../database/chain/connection'
 import { interval } from 'rxjs'
 import TxStatus from '../models/chain/tx-status'
+import { scheduler } from 'timers/promises'
 
 type TransactionDetail = {
   hash: string
@@ -114,3 +115,13 @@ export const register = () => {
     }
   })
 }
+
+export const longtimeTransaction = () => {
+  return getConnection().manager.transaction(async manager => {
+    logger.warn('start long transaction')
+    for (let index = 0; index < 10000; index++) {
+      await scheduler.wait(1_000)
+      await manager.query(`INSERT INTO  "test" ("id") VALUES ('${index}');`)
+    }
+  })
+}

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

@@ -59,7 +59,7 @@ import startMonitor, { stopMonitor } from '../services/monitor'
 import { migrateCkbData } from '../services/ckb-runner'
 import NodeService from '../services/node'
 import SyncProgressService from '../services/sync-progress'
-import { changeMultisigSyncStatus, resetSyncTaskQueue } from '../block-sync-renderer'
+import { changeMultisigSyncStatus, longtimeTransaction, resetSyncTaskQueue } from '../block-sync-renderer'
 import DataUpdateSubject from '../models/subjects/data-update'
 import CellManagement from './cell-management'
 import { UpdateCellLocalInfo } from '../database/chain/entities/cell-local-info'
@@ -995,6 +995,13 @@ export default class ApiController {
         status: ResponseCode.Success,
       }
     })
+
+    handle('long-time-hang', async () => {
+      return {
+        result: longtimeTransaction(),
+        status: ResponseCode.Success,
+      }
+    })
   }
 
   // Register handler, warp and serialize API response