Merge pull request #2807 from nervosnetwork/testnet

Deploy to mainnet

Author: u2

app/controllers/api/v1/address_dao_transactions_controller.rb

@@ -16,8 +16,9 @@ def show
           # .select(select_fields + ["COUNT(cell_inputs.id) AS cell_inputs_count", "COUNT(cell_outputs.id) AS cell_outputs_count"])
           .select(select_fields)
           .recent.page(@page).per(@page_size)
+
         json =
-          Rails.cache.realize(ckb_dao_transactions.cache_key, version: ckb_dao_transactions.cache_version) do
+          Rails.cache.realize(ckb_dao_transactions.cache_key, version: ckb_dao_transactions.cache_version, expires_in: 1.hours) do
             options = FastJsonapi::PaginationMetaGenerator.new(request:, records: ckb_dao_transactions, page: @page, page_size: @page_size).call
             CkbTransactionsSerializer.new(ckb_dao_transactions, options.merge(params: { previews: true })).serialized_json
           end

app/controllers/api/v1/address_udt_transactions_controller.rb

@@ -21,7 +21,7 @@ def show
           .select(select_fields)
           .recent.page(@page).per(@page_size).fast_page
         json =
-          Rails.cache.realize(ckb_udt_transactions.cache_key, version: ckb_udt_transactions.cache_version) do
+          Rails.cache.realize(ckb_udt_transactions.cache_key, version: ckb_udt_transactions.cache_version, expires_in: 1.hours) do
             options = FastJsonapi::PaginationMetaGenerator.new(request:, records: ckb_udt_transactions, page: @page, page_size: @page_size).call
             CkbTransactionsSerializer.new(ckb_udt_transactions, options.merge(params: { previews: true })).serialized_json
           end

app/controllers/api/v1/blocks_controller.rb

@@ -9,7 +9,7 @@ def index
           blocks = Block.recent.select(:id, :miner_hash, :number, :timestamp, :reward, :ckb_transactions_count,
                                        :live_cell_changes, :updated_at).limit(ENV["HOMEPAGE_BLOCK_RECORDS_COUNT"].to_i)
           json =
-            Rails.cache.realize(blocks.cache_key, version: blocks.cache_version, race_condition_ttl: 3.seconds) do
+            Rails.cache.realize(blocks.cache_key, version: blocks.cache_version, race_condition_ttl: 3.seconds, expires_in: 2.minutes) do
               BlockListSerializer.new(blocks).serialized_json
             end
         else
@@ -34,7 +34,7 @@ def index
           total_count = TableRecordCount.find_by(table_name: "blocks")&.count
 
           json =
-            Rails.cache.realize(blocks.cache_key, version: blocks.cache_version, race_condition_ttl: 3.seconds) do
+            Rails.cache.realize(blocks.cache_key, version: blocks.cache_version, race_condition_ttl: 3.seconds, expires_in: 10.minutes) do
               options = FastJsonapi::PaginationMetaGenerator.new(request: request, records: blocks, page: @page,
                                                                  page_size: @page_size, total_count:).call
               BlockListSerializer.new(blocks, options).serialized_json

app/controllers/api/v1/ckb_transactions_controller.rb

@@ -12,7 +12,7 @@ def index
           ).limit((Settings.homepage_transactions_records_count || 15).to_i)
           json =
             Rails.cache.realize(ckb_transactions.cache_key,
-                                version: ckb_transactions.cache_version, race_condition_ttl: 3.seconds) do
+                                version: ckb_transactions.cache_version, race_condition_ttl: 3.seconds, expires_in: 2.minutes) do
               CkbTransactionListSerializer.new(ckb_transactions).serialized_json
             end
           render json:
@@ -44,7 +44,7 @@ def index
           total_count = TableRecordCount.find_by(table_name: "ckb_transactions")&.count
           json =
             Rails.cache.realize(ckb_transactions.cache_key,
-                                version: ckb_transactions.cache_version, race_condition_ttl: 3.seconds) do
+                                version: ckb_transactions.cache_version, race_condition_ttl: 3.seconds, expires_in: 10.minutes) do
               options = FastJsonapi::PaginationMetaGenerator.new(
                 request:,
                 records: ckb_transactions,
@@ -87,7 +87,7 @@ def query
                                                    :block_number, :block_timestamp, :is_cellbase, :updated_at, :created_at)
         json =
           Rails.cache.realize(ckb_transactions.cache_key,
-                              version: ckb_transactions.cache_version, race_condition_ttl: 1.minute) do
+                              version: ckb_transactions.cache_version, race_condition_ttl: 1.minute, expires_in: 10.minutes) do
             options = FastJsonapi::PaginationMetaGenerator.new(
               request:,
               records: ckb_transactions,

app/controllers/api/v1/contracts_controller.rb

@@ -6,7 +6,7 @@ def show
 
         dao_contract = DaoContract.default_contract
         json =
-          Rails.cache.realize(dao_contract.cache_key, version: dao_contract.cache_version, race_condition_ttl: 3.seconds) do
+          Rails.cache.realize(dao_contract.cache_key, version: dao_contract.cache_version, race_condition_ttl: 3.seconds, expires_in: 5.minutes) do
             DaoContractSerializer.new(dao_contract).serialized_json
           end
 

app/controllers/api/v1/daily_statistics_controller.rb

@@ -15,7 +15,7 @@ def show
 
       def rendered_json(daily_statistics)
         Rails.cache.realize("#{daily_statistics.cache_key}/#{params[:id]}", version: daily_statistics.cache_version,
-                                                                            race_condition_ttl: 3.seconds) do
+                                                                            race_condition_ttl: 3.seconds, expires_in: 1.day) do
           case params[:id]
           when "avg_hash_rate"
             DailyStatisticSerializer.new(daily_statistics.presence || [], { params: { indicator: params[:id] } })

app/models/block.rb

@@ -95,7 +95,7 @@ def self.last_7_days_ckb_node_version
   # @param block_hash [String] block hash
   # @return [Hash] raw hash of the block
   def self.fetch_raw_hash_with_cycles(block_hash)
-    Rails.cache.fetch(["Block", block_hash, "raw_hash_with_cycles"], expires_in: 1.day) do
+    Rails.cache.fetch(["Block", block_hash, "raw_hash_with_cycles"], expires_in: 10.minutes) do
       res = CkbSync::Api.instance.directly_single_call_rpc method: "get_block", params: [block_hash, "0x2", true]
 
       r = res["result"].with_indifferent_access
@@ -133,7 +133,7 @@ def self.fetch_raw_hash_with_cycles_by_number(number)
     r = res["result"].with_indifferent_access
     # because the chain may reorg sometimes
     # so we can only store cache against block hash
-    Rails.cache.write(["Block", r["block"]["header"]["hash"], "raw_hash"], r["block"], expires_in: 1.day)
+    Rails.cache.write(["Block", r["block"]["header"]["hash"], "raw_hash"], r["block"], expires_in: 10.minutes)
     # store transaction hash directly to cache ahead
     r["block"]["transactions"].each do |tx|
       CkbTransaction.write_raw_hash_cache tx["hash"], tx
@@ -165,7 +165,7 @@ def raw_hash
   # @return [CKB::Types::Block]
   def sdk_block
     @sdk_block ||=
-      Rails.cache.fetch(["Block", block_hash, "object"], expires_in: 1.hour) do
+      Rails.cache.fetch(["Block", block_hash, "object"], expires_in: 10.minutes) do
         CKB::Types::Block.from_h(original_raw_hash)
       end
   end
@@ -238,7 +238,7 @@ def self.cached_find(query_key)
           where(number: query_key).first
         end
       if block.present?
-        Rails.cache.fetch([name, query_key], race_condition_ttl: 3.seconds, expires_in: 30.minutes) do
+        Rails.cache.fetch([name, query_key], race_condition_ttl: 3.seconds, expires_in: 10.minutes) do
           BlockSerializer.new(block)
         end
       end
@@ -249,7 +249,7 @@ def self.cached_find(query_key)
   # @param epoch_number [Integer]
   # @return [Hash] {number: block_number, bytes: block_size}
   def self.largest_in_epoch(epoch_number)
-    Rails.cache.fetch([:epoch, epoch_number, :largest_block]) do
+    Rails.cache.fetch([:epoch, epoch_number, :largest_block], expires_in: 12.hour) do
       b = Block.where(epoch: epoch_number).order(block_size: :desc).first
       if b&.block_size
         {

app/models/cell_output.rb

@@ -155,7 +155,7 @@ def dao
   def self.find_by_pointer(tx_hash, index)
     Rails.cache.fetch(["cell_output", tx_hash, index], skip_nil: true,
                                                        race_condition_ttl: 10.seconds,
-                                                       expires_in: 1.day) do
+                                                       expires_in: 1.hour) do
       tx_id = CkbTransaction.tx_committed.find_by_tx_hash(tx_hash)&.id
       Rails.logger.info("find_by_pointer: tx_hash: #{tx_hash}, index: #{index}, tx_id: #{tx_id}")
       if tx_id

app/models/ckb_transaction.rb

@@ -52,13 +52,13 @@ class CkbTransaction < ApplicationRecord
   after_commit :flush_cache
 
   def self.cached_find(query_key)
-    Rails.cache.realize([name, query_key], race_condition_ttl: 3.seconds) do
+    Rails.cache.realize([name, query_key], race_condition_ttl: 3.seconds, expires_in: 1.hour) do
       find_by(tx_hash: query_key)
     end
   end
 
   def self.largest_in_epoch(epoch_number)
-    Rails.cache.fetch(["epoch", epoch_number, "largest_tx"]) do
+    Rails.cache.fetch(["epoch", epoch_number, "largest_tx"], expires_in: 12.hour) do
       tx = CkbTransaction.where(block: { epoch_number: }).order(bytes: :desc).first
       if tx.bytes
         {
@@ -77,7 +77,7 @@ def self.write_raw_hash_cache(tx_hash, raw_hash = nil)
       raw_hash = tx_hash
       tx_hash = raw_hash["hash"]
     end
-    Rails.cache.write([name, tx_hash, "raw_hash"], raw_hash, expires_in: 1.day)
+    Rails.cache.write([name, tx_hash, "raw_hash"], raw_hash, expires_in: 10.minutes)
   end
 
   # fetch using rpc method "get_transaction"
@@ -86,7 +86,7 @@ def self.write_raw_hash_cache(tx_hash, raw_hash = nil)
   # @param write_raw_hash_cache [Boolean] if we should write raw hash of transaction without status to cache
   # @return [Hash]
   def self.fetch_raw_hash_with_status(tx_hash, write_raw_hash_cache: true)
-    Rails.cache.fetch([name, tx_hash, "raw_hash_with_status"], expires_in: 1.day, skip_nil: true) do
+    Rails.cache.fetch([name, tx_hash, "raw_hash_with_status"], expires_in: 10.minutes, skip_nil: true) do
       res = CkbSync::Api.instance.directly_single_call_rpc method: "get_transaction", params: [tx_hash]
       h = res["result"].with_indifferent_access
       self.write_raw_hash_cache(tx_hash, h["transaction"]) if write_raw_hash_cache
@@ -99,7 +99,7 @@ def self.fetch_raw_hash_with_status(tx_hash, write_raw_hash_cache: true)
   # @param tx_hash [String]
   # @return [Hash]
   def self.fetch_raw_hash(tx_hash)
-    Rails.cache.fetch([name, tx_hash, "raw_hash"], expires_in: 1.day, skip_nil: true) do
+    Rails.cache.fetch([name, tx_hash, "raw_hash"], expires_in: 10.minutes, skip_nil: true) do
       fetch_raw_hash_with_status(tx_hash, write_raw_hash_cache: false)["transaction"]
     end
   end
@@ -108,9 +108,9 @@ def self.fetch_raw_hash(tx_hash)
   # @param tx_hash [String]
   # @return [CKB::Types::TransactionWithStatus]
   def self.fetch_sdk_transaction_with_status(tx_hash, write_object_cache: true)
-    Rails.cache.fetch([name, tx_hash, "object_with_status"], expires_in: 1.day, skip_nil: true) do
+    Rails.cache.fetch([name, tx_hash, "object_with_status"], expires_in: 10.minutes, skip_nil: true) do
       tx = CKB::Types::TransactionWithStatus.from_h fetch_raw_hash_with_status(tx_hash)
-      Rails.cache.write([name, tx_hash, "object"], tx.transaction, expires_in: 1.day) if write_object_cache
+      Rails.cache.write([name, tx_hash, "object"], tx.transaction, expires_in: 10.minutes) if write_object_cache
       tx
     end
   end
@@ -119,13 +119,13 @@ def self.fetch_sdk_transaction_with_status(tx_hash, write_object_cache: true)
   # @param tx_hash [String]
   # @return [CKB::Types::Transaction]
   def self.fetch_sdk_transaction(tx_hash)
-    Rails.cache.fetch([name, tx_hash, "object"], expires_in: 1.day, skip_nil: true) do
+    Rails.cache.fetch([name, tx_hash, "object"], expires_in: 10.minutes, skip_nil: true) do
       sdk_tx_with_status = Rails.cache.read([name, tx_hash, "object_with_status"])
       if sdk_tx_with_status
         return sdk_transaction_with_status.transaction
       else
         tx = CKB::Types::Transaction.from_h fetch_raw_hash(tx_hash).with_indifferent_access
-        Rails.cache.write([name, tx_hash, "object"], tx, expires_in: 1.day)
+        Rails.cache.write([name, tx_hash, "object"], tx, expires_in: 10.minutes)
         tx
       end
     end
@@ -199,7 +199,7 @@ def detailed_message
 
   # convert current record to raw hash with standard RPC json data structure
   def to_raw
-    Rails.cache.fetch([self.class.name, tx_hash, "raw_hash"], expires_in: 1.day) do
+    Rails.cache.fetch([self.class.name, tx_hash, "raw_hash"], expires_in: 10.minutes) do
       _outputs = cell_outputs.order(cell_index: :asc).to_a
       cell_deps = cell_dependencies.includes(:cell_output).to_a
 

app/models/monetary_data.rb

@@ -12,7 +12,7 @@ def id
   end
 
   def nominal_apc(max_year = 20)
-    Rails.cache.realize("nominal_apc#{max_year}") do
+    Rails.cache.realize("nominal_apc#{max_year}", expires_in: 1.day) do
       total_supplies_per_year(max_year).each_with_index.map do |_, index|
         cumulative_total_supply =
           if index.zero?
@@ -29,7 +29,7 @@ def nominal_apc(max_year = 20)
   end
 
   def nominal_inflation_rate(max_year = 50)
-    Rails.cache.realize("nominal_inflation_rate#{max_year}") do
+    Rails.cache.realize("nominal_inflation_rate#{max_year}", expires_in: 1.day) do
       secondary_issuance_monthly = SECONDARY_SUPPLY_PER_YEAR / 12
       rs =
         total_supplies_per_year(max_year).each_with_index.map do |_, index|
@@ -51,7 +51,7 @@ def nominal_inflation_rate(max_year = 50)
   end
 
   def real_inflation_rate(max_year = 50)
-    Rails.cache.realize("real_inflation#{max_year}") do
+    Rails.cache.realize("real_inflation#{max_year}", expires_in: 1.day) do
       nominal_inflation_rate(max_year).
         zip(nominal_apc(max_year)).
         map { |item| item.reduce(:-).truncate(8) }