Add partner fees verification query

cowprotocol/accounting/rewards/mainnet/.sqlfluff

@@ -1,4 +1,5 @@
 [sqlfluff:templater:jinja:context]
+result=per_trade_partner_fees,per_recipient_partner_fees
 cte_name = results,results_per_tx
 start_time='2024-08-20 00:00:00'
 end_time='2024-08-27 00:00:00'

cowprotocol/accounting/rewards/mainnet/partner_fees_query_3602560.sql

@@ -0,0 +1,72 @@
+-- This query computes the partner fees associated with each partner in a given time interval
+--
+-- Parameters:
+--  {{start_time}} - the timestamp for which the accounting should start (inclusively)
+--  {{end_time}} - the timestamp for which the accounting should end (exclusively)
+--  {{result}} - two views of the result, one aggregated and one on a per tx basis
+
+with
+per_trade_protocol_fees as (
+    select
+        t.block_time,
+        t.block_number,
+        t.order_uid,
+        t.tx_hash,
+        r.data.partner_fee_recipient as partner_recipient,  -- noqa: RF01
+        t.app_data,
+        usd_value,
+        cast(cast(r.data.protocol_fee as varchar) as int256) as protocol_fee,  -- noqa: RF01
+        r.data.protocol_fee_token,  -- noqa: RF01
+        json_extract(a.encode, '$.metadata.partnerFee.bps') as patnerFeeBps,
+        json_extract(a.encode, '$.metadata.widget.appCode') as app_code,
+        usd_value * cast(
+            json_extract(a.encode, '$.metadata.partnerFee.bps') as double
+        ) / 10000 as est_partner_revenue,
+        usd_value * cast(
+            json_extract(a.encode, '$.metadata.partnerFee.bps') as double
+        ) / 10000 * 0.15 as est_cow_revenue,
+        cast(
+            cast(
+                coalesce(r.data.partner_fee, r.data.protocol_fee) as varchar  -- noqa: RF01
+            ) as int256
+        ) * r.data.protocol_fee_native_price / pow(10, 18) as raw_integrator_fee_in_eth  -- noqa: RF01
+    from
+        cow_protocol_ethereum.trades as t
+    left join dune.cowprotocol.dataset_app_data_mainnet as a on t.app_data = a.contract_app_data
+    left join cowswap.raw_order_rewards as r
+        on
+            r.order_uid = cast(t.order_uid as varchar)
+            and t.tx_hash = from_hex(r.tx_hash)
+    where
+        json_extract(a.encode, '$.metadata.partnerFee.recipient') is not null
+        and t.block_number >= (select start_block from "query_3333356(start_time='{{start_time}}',end_time='{{end_time}}')")
+        and t.block_number < (select end_block from "query_3333356(start_time='{{start_time}}',end_time='{{end_time}}')")
+    order by
+        t.block_time desc
+),
+
+per_trade_partner_fees as (
+    select *
+    from
+        per_trade_protocol_fees
+    where
+        raw_integrator_fee_in_eth > 0
+),
+
+per_recipient_partner_fees as (
+    select
+        partner_recipient,
+        case
+            when partner_recipient = '0x63695Eee2c3141BDE314C5a6f89B98E62808d716' then sum(0.9 * raw_integrator_fee_in_eth)
+        end as partner_fee_part,
+        case
+            when partner_recipient = '0x63695Eee2c3141BDE314C5a6f89B98E62808d716' then sum(0.1 * raw_integrator_fee_in_eth)
+            else sum(0.15 * raw_integrator_fee_in_eth)
+        end as cow_dao_partner_fee_part
+    from
+        per_trade_partner_fees
+    group by
+        partner_recipient
+)
+
+select * from {{result}}