fix: refactor market_data api (#2428)

Signed-off-by: Miles Zhang <mingchang555@hotmail.com>
nervosnetwork · Feb 8, 2025 · de35943 · de35943
1 parent 20b9531
commit de35943
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/app/models/ckb_sync/new_node_data_processor.rb b/app/models/ckb_sync/new_node_data_processor.rb
@@ -335,6 +335,7 @@ def process_deposit_dao_events!(local_block, dao_contract)
           }
         end
         DaoEvent.upsert_all(dao_events_attributes, unique_by: %i[block_id ckb_transaction_id cell_index event_type]) if dao_events_attributes.present?
+        Rails.cache.delete("unmade_dao_interests")
       end
       # update dao contract info
       dao_contract.update!(

diff --git a/app/models/market_data.rb b/app/models/market_data.rb
@@ -98,13 +98,13 @@ def total_supply
   def unmade_dao_interests
     @unmade_dao_interests ||=
       Rails.cache.fetch("unmade_dao_interests", expires_in: 1.day) do
-        # tip_dao = tip_block.dao
-        # total = 0
-        # CellOutput.nervos_dao_deposit.generated_before(tip_block.timestamp).unconsumed_at(tip_block.timestamp).find_each do |cell_output|
-        #   total += DaoCompensationCalculator.new(cell_output, tip_dao).call
-        # end
-        # total
-        0
+        tip_dao = tip_block.dao
+        total = 0
+        DaoEvent.depositor.created_before(tip_block.timestamp).find_each do |dao_event|
+          cell_output = CellOutput.find_by(ckb_transaction_id: dao_event.ckb_transaction_id, cell_index: dao_event.cell_index)
+          total += DaoCompensationCalculator.new(cell_output, tip_dao).call
+        end
+        total
       end
   end