fix: spore cluster and cell query should be mapping

Signed-off-by: Miles Zhang <[email protected]>

app/models/ckb_sync/api.rb

@@ -87,6 +87,17 @@ def spore_cell_code_hashes
       end
     end
 
+    def spore_code_hash_mapping
+      if mode == CKB::MODE::MAINNET
+        { Settings.spore_cell1_code_hash => Settings.spore_cluster1_code_hash }
+      else
+        {
+          Settings.spore_cell1_code_hash => Settings.spore_cluster1_code_hash,
+          Settings.spore_cell2_code_hash => Settings.spore_cluster2_code_hash,
+        }
+      end
+    end
+
     def omiga_inscription_info_code_hash
       Settings.omiga_inscription_info_code_hash
     end

app/models/ckb_sync/new_node_data_processor.rb

@@ -673,8 +673,8 @@ def build_udts!(local_block, outputs, outputs_data)
             if cell_type == "spore_cell"
               parsed_spore_cell = CkbUtils.parse_spore_cell_data(outputs_data[tx_index][index])
               if parsed_spore_cell[:cluster_id].present?
-                binary_hashes = CkbUtils.hexes_to_bins_sql(CkbSync::Api.instance.spore_cluster_code_hashes)
-                spore_cluster_type = TypeScript.where("code_hash IN (#{binary_hashes})").where(
+                cluster_code_hash = CkbSync::Api.instance.spore_code_hash_mapping[output.type.code_hash]
+                spore_cluster_type = TypeScript.where(code_hash: cluster_code_hash).where(
                   args: parsed_spore_cell[:cluster_id],
                 ).first
                 if spore_cluster_type.present?

app/workers/token_transfer_detect_worker.rb

@@ -144,8 +144,8 @@ def find_or_create_m_nft_collection(_cell, type_script)
   def find_or_create_spore_collection(_cell, type_script)
     spore_cell = type_script.cell_outputs.order("id desc").first
     parsed_spore_cell = CkbUtils.parse_spore_cell_data(spore_cell.data)
-    binary_hashes = CkbUtils.hexes_to_bins_sql(CkbSync::Api.instance.spore_cluster_code_hashes)
-    spore_cluster_type = TypeScript.where("code_hash IN (#{binary_hashes})").where(
+    cluster_code_hash = CkbSync::Api.instance.spore_code_hash_mapping[type_script.code_hash]
+    spore_cluster_type = TypeScript.where(code_hash: cluster_code_hash).where(
       args: parsed_spore_cell[:cluster_id],
     ).first
     coll = TokenCollection.find_or_create_by(