Merge pull request #2535 from nervosnetwork/testnet

Deploy to mainnet

Author: zmcNotafraid

.env.example

@@ -129,4 +129,6 @@ BITCOIN_SIGNET_PASS=""
 PARTNER_DOMAINS="/localhost:\d*/"
 
 # -------------------------------- Fiber segment --------------------------------
-FIBER_NODE_URL=""
+FIBER_NODE_URL=""
+
+SSRI_URL="http://localhost:9090"

.env.test.local.travis

@@ -48,4 +48,6 @@ ASSET_URL=""
 
 # -------------------------------- portfolio segment --------------------------------
 AUTH_ACCESS_EXPIRE=1296000
-SECRET_KEY_BASE=
+SECRET_KEY_BASE=
+
+SSRI_URL="http://0.0.0.0:9090"

app/controllers/api/v1/xudts_controller.rb

@@ -110,7 +110,7 @@ def parse_tags
       end
 
       def xudt_type_params
-        params[:type].blank? ? ["xudt", "xudt_compatible"] : "xudt_compatible"
+        params[:type].blank? ? ["xudt", "xudt_compatible", "ssri"] : "xudt_compatible"
       end
     end
   end

app/controllers/api/v2/blocks_controller.rb

@@ -4,14 +4,18 @@ def ckb_node_versions
       result = Block.last_7_days_ckb_node_version
 
       render json: {
-        data: result.map { |k, v|
+        data: result.map do |k, v|
           {
-            version: (k || 'others'),
-            blocks_count: v
+            version: k || "others",
+            blocks_count: v,
           }
-        }
+        end,
       }
     end
+
+    def by_epoch
+      block = Block.where(epoch: params[:epoch_number]).order("number asc").limit(1).offset(params[:epoch_index].to_i).first
+      render json: BlockSerializer.new(block)
+    end
   end
 end
-

app/models/cell_input.rb

@@ -13,7 +13,7 @@ class CellInput < ApplicationRecord
     normal: 0, nervos_dao_deposit: 1, nervos_dao_withdrawing: 2, udt: 3, m_nft_issuer: 4,
     m_nft_class: 5, m_nft_token: 6, nrc_721_token: 7, nrc_721_factory: 8, cota_registry: 9,
     cota_regular: 10, spore_cluster: 11, spore_cell: 12, omiga_inscription_info: 13, omiga_inscription: 14,
-    xudt: 15, unique_cell: 16, xudt_compatible: 17, did_cell: 18, stablepp_pool: 19
+    xudt: 15, unique_cell: 16, xudt_compatible: 17, did_cell: 18, stablepp_pool: 19, ssri: 20
   }
 
   def output

app/models/cell_output.rb

@@ -33,6 +33,7 @@ class CellOutput < ApplicationRecord
     xudt_compatible: 17,
     did_cell: 18,
     stablepp_pool: 19,
+    ssri: 20,
   }
 
   belongs_to :ckb_transaction
@@ -147,7 +148,7 @@ def occupied?
 
   # @return [Boolean]
   def free?
-    type_hash.blank? && (data.present? && data == "0x")
+    type_hash.blank? && data.present? && data == "0x"
   end
 
   def address_hash

app/models/ckb_sync/new_node_data_processor.rb

@@ -28,19 +28,19 @@ def call
       return if target_block_number > tip_block_number - @offset.to_i
 
       target_block = CkbSync::Api.instance.get_block_by_number(target_block_number)
-      if !forked?(target_block, local_tip_block)
+      if forked?(target_block, local_tip_block)
+        self.reorg_started_at = Time.now
+        res = RevertBlockJob.perform_now(local_tip_block)
+        reorg_started_at.delete
+        res
+      else
         Rails.logger.error "process_block: #{target_block_number}"
         res =
           ApplicationRecord.cache do
             process_block(target_block)
           end
         reorg_started_at.delete
         res
-      else
-        self.reorg_started_at = Time.now
-        res = RevertBlockJob.perform_now(local_tip_block)
-        reorg_started_at.delete
-        res
       end
     rescue StandardError => e
       Rails.logger.error e.message
@@ -418,7 +418,7 @@ def update_or_create_udt_accounts!(local_block)
                                                                              :symbol, :decimal, :published, :code_hash, :type_hash, :created_at).take!
           if udt_account.present?
             case udt_type
-            when "sudt", "omiga_inscription", "xudt", "xudt_compatible"
+            when "sudt", "ssri", "omiga_inscription", "xudt", "xudt_compatible"
               udt_accounts_attributes << { id: udt_account.id, amount:,
                                            created_at: udt.created_at }
             when "m_nft_token", "nrc_721_token", "spore_cell", "did_cell"
@@ -447,7 +447,7 @@ def udt_type(cell_type)
 
     def udt_account_amount(udt_type, type_hash, address)
       case udt_type
-      when "sudt"
+      when "sudt", "ssri"
         address.cell_outputs.live.udt.where(type_hash:).sum(:udt_amount)
       when "xudt", "xudt_compatible", "omiga_inscription", "m_nft_token", "spore_cell", "did_cell"
         address.cell_outputs.live.where(cell_type: udt_type).where(type_hash:).sum(:udt_amount)
@@ -763,7 +763,7 @@ def build_cells_and_locks!(
       build_cell_outputs!(node_block, outputs, ckb_txs, local_block, cell_outputs_attributes, output_capacities, tags,
                           udt_address_ids, contained_udt_ids, contained_addr_ids, addrs_changes, token_transfer_ckb_tx_ids)
       if cell_outputs_attributes.present?
-        tx_hashes = cell_outputs_attributes.map { |attr| attr[:tx_hash] }
+        tx_hashes = cell_outputs_attributes.pluck(:tx_hash)
         binary_hashes = CkbUtils.hexes_to_bins_sql(tx_hashes)
         CellOutput.pending.where("tx_hash IN (#{binary_hashes})").update_all(status: :live)
         id_hashes = CellOutput.upsert_all(cell_outputs_attributes, unique_by: %i[tx_hash cell_index status],
@@ -821,7 +821,7 @@ def build_cells_and_locks!(
       CellInput.upsert_all(cell_inputs_attributes,
                            unique_by: %i[ckb_transaction_id index])
       if prev_cell_outputs_attributes.present?
-        cell_ouput_ids = prev_cell_outputs_attributes.map { |attr| attr[:id] }
+        cell_ouput_ids = prev_cell_outputs_attributes.pluck(:id)
         CellOutput.live.where(id: cell_ouput_ids).update_all(status: :dead)
         CellOutput.upsert_all(prev_cell_outputs_attributes,
                               unique_by: %i[tx_hash cell_index status],
@@ -962,6 +962,12 @@ def build_cell_inputs(
               udt_address_ids[tx_index] << address_id
               contained_udt_ids[tx_index] << Udt.where(type_hash:,
                                                        udt_type: "sudt").pick(:id)
+            when "ssri"
+              tags[tx_index] << "ssri"
+              udt_address_ids[tx_index] << address_id
+              contained_udt_ids[tx_index] << Udt.where(type_hash:,
+                                                       udt_type: "ssri").pick(:id)
+
             when "omiga_inscription"
               tags[tx_index] << "omiga_inscription"
               udt_address_ids[tx_index] << address_id
@@ -1039,6 +1045,12 @@ def build_cell_outputs!(
             contained_udt_ids[tx_index] << Udt.where(
               type_hash: item.type.compute_hash, udt_type: "sudt",
             ).pick(:id)
+          elsif attr[:cell_type] == "ssri"
+            tags[tx_index] << "ssri"
+            udt_address_ids[tx_index] << address.id
+            contained_udt_ids[tx_index] << Udt.where(
+              type_hash: item.type.compute_hash, udt_type: "ssri",
+            ).pick(:id)
           elsif attr[:cell_type] == "omiga_inscription"
             tags[tx_index] << "omiga_inscription"
             udt_address_ids[tx_index] << address_id
@@ -1068,7 +1080,7 @@ def build_cell_outputs!(
     end
 
     def occupied?(type_hash, cell_data)
-      cell_data.present? && cell_data != "0x" || type_hash.present?
+      (cell_data.present? && cell_data != "0x") || type_hash.present?
     end
 
     def cell_output_attributes(output, address, ckb_transaction, local_block, cell_index, output_data)

app/models/contract.rb

@@ -1,6 +1,7 @@
 class Contract < ApplicationRecord
   has_many :cell_deps_out_points, foreign_key: :deployed_cell_output_id, primary_key: :deployed_cell_output_id
   has_many :cell_dependencies, through: :cell_deps_out_points
+  has_one :ssri_contract
   belongs_to :deployed_cell_output, class_name: "CellOutput"
   belongs_to :contract_cell, class_name: "CellOutput", optional: true
 

app/models/ssri_contract.rb

@@ -0,0 +1,29 @@
+class SsriContract < ApplicationRecord
+  belongs_to :contract
+
+  scope :udt, -> { where(is_udt: true) }
+
+  def self.udt_code_hashes
+    Rails.cache.fetch("ssri_contracts:udt_code_hashes") do
+      udt.pluck(:code_hash, :hash_type)
+    end
+  end
+end
+
+# == Schema Information
+#
+# Table name: ssri_contracts
+#
+#  id          :bigint           not null, primary key
+#  contract_id :bigint
+#  methods     :string           default([]), is an Array
+#  is_udt      :boolean
+#  code_hash   :binary
+#  hash_type   :string
+#  created_at  :datetime         not null
+#  updated_at  :datetime         not null
+#
+# Indexes
+#
+#  index_ssri_contracts_on_contract_id  (contract_id) UNIQUE
+#

app/models/udt.rb

@@ -8,7 +8,7 @@ class Udt < ApplicationRecord
   has_many :udt_holder_allocations
 
   enum udt_type: { sudt: 0, m_nft_token: 1, nrc_721_token: 2, spore_cell: 3,
-                   omiga_inscription: 4, xudt: 5, xudt_compatible: 6, did_cell: 7 }
+                   omiga_inscription: 4, xudt: 5, xudt_compatible: 6, did_cell: 7, ssri: 8 }
 
   validates_presence_of :total_amount
   validates :decimal,
@@ -46,6 +46,13 @@ def type_script
   def holders_count
     udt_holder_allocations.sum("ckb_holder_count + btc_holder_count")
   end
+
+  def ssri_contract_outpoint
+    return unless udt_type == "ssri"
+
+    cell = SsriContract.find_by(code_hash: code_hash, hash_type: hash_type).contract.deployed_cell_output
+    { tx_hash: cell.tx_hash, cell_index: cell.cell_index }
+  end
 end
 
 # == Schema Information