Skip to content

Commit

Permalink
extend cost coverage query to all networks (#105)
Browse files Browse the repository at this point in the history
  • Loading branch information
@harisang
harisang authored Jan 14, 2025
1 parent 6ee39f1 commit 8354bcc
Show file tree
Hide file tree
Showing 2 changed files with 77 additions and 44 deletions.
1 change: 1 addition & 0 deletions cowprotocol/accounting/cost_coverage/.sqlfluff
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
[sqlfluff:templater:jinja:context]
start_time='2024-08-01 12:00'
end_time='2024-08-02 12:00'
blockchain='ethereum'
120 changes: 76 additions & 44 deletions cowprotocol/accounting/cost_coverage/cost_coverage_2601653.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,73 +3,107 @@
-- this query is aligned with the weekly payouts so its results
-- are useful when start/end date aligns with an accounting period
-- Parameters:
-- {{start_time}}: the start date of an accounting week
-- {{end_time}}: the end date of an accounting week
-- {{start_time}}: the start date of an accounting week
-- {{end_time}}: the end date of an accounting week
-- {{blockchain}}: network to run the analysis on
with
purchased_eth as (
wrapped_native_token as (
select
case '{{blockchain}}'
when 'ethereum' then 0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2 -- WETH
when 'gnosis' then 0xe91d153e0b41518a2ce8dd3d7944fa863463a97d -- WXDAI
when 'arbitrum' then 0x82af49447d8a07e3bd95bd0d56f35241523fbab1 -- WETH
when 'base' then 0x4200000000000000000000000000000000000006 -- WETH
end as native_token_address
),

cow_token_address as (
select
case '{{blockchain}}'
when 'ethereum' then 0xDEf1CA1fb7FBcDC777520aa7f396b4E015F497aB
when 'gnosis' then 0x177127622c4a00f3d409b75571e12cb3c8973d3c
when 'arbitrum' then 0xcb8b5cd20bdcaea9a010ac1f8d835824f5c87a04
when 'base' then 0xc694a91e6b071bf030a18bd3053a7fe09b6dae69
end as cow_address
),

rewards_safe as (
select
case '{{blockchain}}'
when 'ethereum' then 0xa03be496e67ec29bc62f01a428683d7f9c204930
when 'gnosis' then 0xa03be496e67ec29bc62f01a428683d7f9c204930
when 'arbitrum' then 0x66331f0b9cb30d38779c786bda5a3d57d12fba50
when 'base' then 0xa03be496e67ec29bc62f01a428683d7f9c204930
end as rewards_safe_address
),

purchased_native_token as (
select
block_time,
sum(units_bought) as fees
from cow_protocol_ethereum.trades
from cow_protocol_{{blockchain}}.trades
where
buy_token_address in (0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2, 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee)
(
buy_token_address = (select native_token_address from wrapped_native_token)
or buy_token_address = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
)
and trader in (0x84e5c8518c248de590d5302fd7c32d2ae6b0123c, 0x9008D19f58AAbD9eD0D60971565AA8510560ab41)
and receiver = 0xa03be496e67ec29bc62f01a428683d7f9c204930
and receiver = (select rewards_safe_address from rewards_safe)
and block_date between (timestamp '{{start_time}}' + interval '12' hour) and (timestamp '{{end_time}}' + interval '12' hour)
-- fee withdrawals are currently executed daily at midnight UTC. However, the fee withdrawal at the end of an accounting period
-- should not be included in the next accounting period, this is why we add a shift of 12 hours, in order to ensure that the
-- last withdrawal for an accounting period is indeed mapped to that accounting period and not to the one that follows
group by block_time
),

-- WETH Transfer from settlement contract to rewards safe
transferred_eth as (
-- Native token Transfer from settlement contract to rewards safe
transferred_native_token as (
select
evt_block_time as block_time,
sum(value / 1e18) as fees
from erc20_ethereum.evt_Transfer
from erc20_{{blockchain}}.evt_Transfer
where
"from" = 0x9008d19f58aabd9ed0d60971565aa8510560ab41
and to = 0xa03be496e67ec29bc62f01a428683d7f9c204930
and contract_address = 0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2
and evt_tx_hash not in (select tx_hash from cow_protocol_ethereum.trades where block_date between (timestamp '{{start_time}}' + interval '12' hour) and (timestamp '{{end_time}}' + interval '12' hour))
and to = (select rewards_safe_address from rewards_safe)
and contract_address = (select native_token_address from wrapped_native_token)
and evt_tx_hash not in (select tx_hash from cow_protocol_{{blockchain}}.trades where block_date between (timestamp '{{start_time}}' + interval '12' hour) and (timestamp '{{end_time}}' + interval '12' hour))
and evt_block_time between (timestamp '{{start_time}}' + interval '12' hour) and (timestamp '{{end_time}}' + interval '12' hour)
group by evt_block_time
),

fees_eth as (
fees_native_token as (
select
max(block_time) as latest_withdrawal_time,
sum(fees) as fees
from (
select
block_time,
fees
from purchased_eth
from purchased_native_token
union all
select
block_time,
fees
from transferred_eth
from transferred_native_token
)
),

outgoing_eth as (
select sum(value / 1e18) as eth
from ethereum.traces
outgoing_native_token as (
select sum(value / 1e18) as native_token
from {{blockchain}}.traces
where
"from" = 0xa03be496e67ec29bc62f01a428683d7f9c204930
"from" = (select rewards_safe_address from rewards_safe)
and success = true
and (lower(call_type) not in ('delegatecall', 'callcode', 'staticcall') or call_type is null)
and block_time between (timestamp '{{start_time}}' + interval '2' day) and (timestamp '{{end_time}}' + interval '2' day)
),

outgoing_cow as (
select sum(value) / 1e18 as cow
from erc20_ethereum.evt_Transfer
from erc20_{{blockchain}}.evt_Transfer
where
contract_address = 0xdef1ca1fb7fbcdc777520aa7f396b4e015f497ab
and "from" = 0xa03be496e67ec29bc62f01a428683d7f9c204930
contract_address = (select cow_address from cow_token_address)
and "from" = (select rewards_safe_address from rewards_safe)
and evt_block_time between (timestamp '{{start_time}}' + interval '2' day) and (timestamp '{{end_time}}' + interval '2' day)
),

Expand All @@ -78,46 +112,44 @@ conversion_prices as (
(
select avg(price) from prices.usd
where
blockchain = 'ethereum'
and contract_address = 0xdef1ca1fb7fbcdc777520aa7f396b4e015f497ab
blockchain = '{{blockchain}}'
and contract_address = (select cow_address from cow_token_address)
and date(minute) = cast('{{end_time}}' as timestamp) - interval '1' day
) as cow_price,
(
select avg(price) from prices.usd
where
blockchain = 'ethereum'
and contract_address = 0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2
blockchain = '{{blockchain}}'
and contract_address = (select native_token_address from wrapped_native_token)
and date(minute) = cast('{{end_time}}' as timestamp) - interval '1' day
) as eth_price
) as native_token_price
),

protocol_fees_collected as (
select sum(cast(cast(data.protocol_fee as varchar) as int256) * data.protocol_fee_native_price / pow(10, 18) - coalesce(case when data.partner_fee_recipient is not null then cast(data.partner_fee as int256) * data.protocol_fee_native_price / pow(10, 18) end, 0)) as protocol_fee_in_eth --noqa: RF01
from cowswap.raw_order_rewards as r
inner join ethereum.blocks as b on number = block_number
select sum(protocol_fee * protocol_fee_native_price / pow(10, 18) - coalesce(case when partner_fee_recipient is not null then partner_fee * protocol_fee_native_price / pow(10, 18) end, 0)) as protocol_fee_in_native_token --noqa: RF01
from "query_4364122(blockchain='{{blockchain}}')" as r
inner join {{blockchain}}.blocks as b on number = block_number
where
r.block_number > 19068880
and data.protocol_fee_native_price > 0 --noqa: RF01
and b.time between timestamp '{{start_time}}' and timestamp '{{end_time}}'
and r.order_uid not in (select cast(order_uid as varchar) from query_3639473)
b.time between timestamp '{{start_time}}' and timestamp '{{end_time}}'
and r.order_uid not in (select order_uid from query_3639473)
),

results as (
select
(select eth from outgoing_eth) as outgoing_eth,
(select native_token from outgoing_native_token) as outgoing_native_token,
(select cow from outgoing_cow) as outgoing_cow,
(select eth from outgoing_eth) + (select cow from outgoing_cow) * (select cow_price / eth_price from conversion_prices) as total_outgoing_eth,
(select fees from fees_eth) as fees_eth,
(select latest_withdrawal_time from fees_eth) as last_withdrawal,
(select protocol_fee_in_eth from protocol_fees_collected) as protocol_fee_in_eth
(select native_token from outgoing_native_token) + (select cow from outgoing_cow) * (select cow_price / native_token_price from conversion_prices) as total_outgoing_native_token,
(select fees from fees_native_token) as fees_native_token,
(select latest_withdrawal_time from fees_native_token) as last_withdrawal,
(select protocol_fee_in_native_token from protocol_fees_collected) as protocol_fee_in_native_token
)

select
*,
-- does not include outgoing cow.
fees_eth / outgoing_eth as cost_coverage,
-- converts outgoing cow and adds to outgoing eth.
fees_eth / total_outgoing_eth as effective_cost_coverage,
fees_eth - outgoing_eth as profit,
fees_eth - total_outgoing_eth as effective_profit
fees_native_token / outgoing_native_token as cost_coverage,
-- converts outgoing cow and adds to outgoing native token.
fees_native_token / total_outgoing_native_token as effective_cost_coverage,
fees_native_token - outgoing_native_token as profit,
fees_native_token - total_outgoing_native_token as effective_profit
from results

0 comments on commit 8354bcc

Please sign in to comment.