feat: import pending tx by worker

Signed-off-by: Miles Zhang <mingchang555@hotmail.com>

app/workers/import_pending_tx_worker.rb

@@ -4,7 +4,10 @@ class ImportPendingTxWorker
   sidekiq_options retry: 0, queue: "pending_tx"
 
   def perform(data)
-    if CkbTransaction.tx_committed.find_by(tx_hash: data["transaction"]["hash"])
+    committed_tx = CkbTransaction.tx_committed.find_by(tx_hash: data["transaction"]["hash"])
+    if committed_tx && committed_tx.confirmation_time.nil?
+      confirmation_time = committed_tx.block_timestamp - data["timestamp"].hex
+      committed_tx.update(confirmation_time:)
     else
       CkbSync::Transactions.new([data]).import
     end

config/sidekiq.yml

@@ -1,6 +1,7 @@
 ---
 :concurrency: 5
 :queues:
+  - pending_tx
   - critical
   - default
   - bitcoin

lib/websocket.rb

@@ -64,6 +64,7 @@ def subscribe(connection, topic)
       res = message.to_h
       if res[:method] == "subscribe"
         data = JSON.parse res[:params][:result]
+        ImportPendingTxWorker.perform_async(data)
       end
     end
   end