certusone
/
wormhole-explorer
mirror of https://github.com/certusone/wormhole-explorer.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

[1424] /x-chain-activity/tops : cast volume and count fields to uint before doing sum (#1537) 

* cast volume and count fields to uint before doing sum

* fix x-chain-activity unit-tests
This commit is contained in:
Mariano 2024-07-08 14:17:27 -03:00 committed by GitHub
parent dee5183cf7
commit 1bb17d9d50
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
api/handlers/transactions/repository.go
View File

@ -1249,12 +1249,14 @@ func (r *Repository) buildQueryChainActivityTopsByEmitter(q ChainActivityTopsQue
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -1285,12 +1287,14 @@ func (r *Repository) buildQueryChainActivityTopsByEmitter(q ChainActivityTopsQue
vols = data vols = data
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -1322,12 +1326,14 @@ func (r *Repository) buildQueryChainActivityHourly(start, stop, filterSourceChai
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -1359,12 +1365,14 @@ func (r *Repository) buildQueryChainActivityDaily(start, stop, filterSourceChain
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -1399,12 +1407,14 @@ func (r *Repository) buildQueryChainActivityMonthly(start, stop, filterSourceCha
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -1439,12 +1449,14 @@ func (r *Repository) buildQueryChainActivityYearly(start, stop, filterSourceChai
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})

16
api/handlers/transactions/repository_test.go
View File

@ -117,12 +117,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -160,12 +162,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -240,12 +244,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -282,12 +288,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -325,12 +333,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -368,12 +378,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -415,12 +427,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})
@ -462,12 +476,14 @@ func Test_buildChainActivityQueryTops(t *testing.T) {
vols = data vols = data
|> filter(fn: (r) => (r._field == "volume" and r._value > 0)) |> filter(fn: (r) => (r._field == "volume" and r._value > 0))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "volume"}) |> rename(columns: {_value: "volume"})
counts = data counts = data
|> filter(fn: (r) => (r._field == "count")) |> filter(fn: (r) => (r._field == "count"))
|> group(columns:["_time","to","emitter_chain"]) |> group(columns:["_time","to","emitter_chain"])
|> toUInt()
|> sum() |> sum()
|> rename(columns: {_value: "count"}) |> rename(columns: {_value: "count"})