add txcount

Author: vans163

ex/lib/api/api_chain.ex

@@ -83,6 +83,20 @@ defmodule API.Chain do
       }
     end
 
+    def kpi() do
+      {_, uaw} = API.Contract.richlist()
+      tx_cnt = RocksDB.get_cf_prop(:tx, "rocksdb.estimate-num-keys") |> :erlang.binary_to_integer()
+      %{
+        ama_burned: Float.round(API.Contract.total_burned().float, 2),
+        fees_paid: Float.round(API.Contract.total_burned().float * 2, 2),
+        active_validator_keys: 67 + length(API.Epoch.score()),
+        active_peers: length(API.Peer.all()),
+        block_time: 500,
+        total_tx: tx_cnt,
+        uaw: uaw,
+      }
+    end
+
     def total_supply_y3() do
       cached = :persistent_term.get(:total_supply_y3, nil)
       if cached do cached else

ex/lib/api/db_entry.ex

@@ -107,6 +107,12 @@ defmodule DB.Entry do
       RocksDB.put(key, hash, db_handle(db_opts, :tx_filter, %{}))
     end)
 
+    if entry.header.height >= 445_00000 do
+      old_cnt = RocksDB.get("tx_count", db_handle(db_opts, :sysconf, %{})) || "0"
+      new_cnt = :erlang.binary_to_integer(old_cnt) + length(entry.txs)
+      RocksDB.put("tx_count", :erlang.integer_to_binary(new_cnt), db_handle(db_opts, :sysconf, %{}))
+    end
+
     receipts_by_txid = Map.new(receipts, fn r -> {r.txid, Map.drop(r, [:txid])} end)
     Enum.each(entry.txs, fn(txu)->
       receipt = Map.fetch!(receipts_by_txid, txu.hash)
@@ -164,6 +170,12 @@ defmodule DB.Entry do
       RocksDB.delete(key, db_handle(db_opts, :tx_filter, %{}))
     end)
 
+    if entry.header.height >= 445_00000 do
+      old_cnt = RocksDB.get("tx_count", db_handle(db_opts, :sysconf, %{})) || "0"
+      new_cnt = :erlang.binary_to_integer(old_cnt) - length(entry.txs)
+      RocksDB.put("tx_count", :erlang.integer_to_binary(new_cnt), db_handle(db_opts, :sysconf, %{}))
+    end
+
     Enum.each(entry.txs, fn(txu)->
         RocksDB.delete(txu.hash, db_handle(db_opts, :tx, %{}))
 

ex/lib/http/multiserver.ex

@@ -206,7 +206,7 @@ defmodule Ama.MultiServer do
                     function: query[:function],
 
                     limit: :erlang.binary_to_integer(query[:limit] || "100"),
-                    sort: case filters.sort do "desc" -> :desc; _ -> :asc end,
+                    sort: case query[:sort] do "desc" -> :desc; _ -> :asc end,
                     cursor: if query[:cursor_b58] do Base58.decode(query.cursor_b58) else query[:cursor] end,
                 }
                 {cursor, txs} = API.TX.get_by_filter(filters)