bring money back to linea

src/bridge/StargateClient.ts

@@ -47,7 +47,7 @@ export class StargateClient {
   async bridge(toChainId: number) {
     if (toChainId === ChainId.ZKSYNC) throw new Error('Unsupported.')
     return await polly()
-      .waitAndRetry([1000 * 10, 1000 * 20, 1000 * 30, 1000 * 40])
+      .waitAndRetry([1000 * 10])
       .executeForPromise(async info => {
         try {
           const balance = await this.provider.getBalance(this.wallet.address)

src/jobs/BridgeJob.ts

@@ -35,7 +35,8 @@ export class BridgeJob extends CronJob {
       // get private key for the account
       const privateKey = PKMapping.instance.get(task.address)
       if (!privateKey) {
-        throw new Error(`${task.address}: private key not found`)
+        this.logger.warn(`${task.address}: private key not found`)
+        return
       }
       // do the bridge
       this.logger.info(`${task.id}: ${task.address} start bridging from ${task.fromChain} to ${task.toChain}`)

src/jobs/ConfirmJob.ts

@@ -26,7 +26,7 @@ export class ConfirmJob extends CronJob {
     try {
       const targetProvider = new ethers.JsonRpcProvider(chainInfoMap[task.toChain].rpcUrl)
       const balance = await targetProvider.getBalance(task.address)
-      if (balance > ethers.parseEther('0.01')) {
+      if (balance > ethers.parseEther('0.003')) {
         // if the balance is greater than 0.01, consider the bridge is successful
         await DBClient.instance.$transaction([
           DBClient.instance.task.update({

src/main.ts

@@ -45,6 +45,6 @@ app.listen(port, () => {
   console.log(`start listening at http://localhost:${port}`)
 })
 
-new CreateBridgeTaskJob().start('*/5 * * * *')
-new BridgeJob().start('* * * * *')
+// new CreateBridgeTaskJob().start('*/5 * * * *')
+new BridgeJob().start('*/5 * * * * *')
 new ConfirmJob().start('*/30 * * * * *')