feat: add 4337 source and staging models (#3127)

* feat: add 4337 source and staging models

* feat(docs): add 4337 source to docs

Author: ccerv1

apps/docs/docs/integrate/datasets/index.mdx

@@ -67,6 +67,13 @@ Here are some of our featured public datasets:
     </div>
     <h3>Superchain</h3>
   </a>
+  <a href="#superchain-4337" className="datalink-card">
+    <div className="datalink-header">
+      <img src={OptimismLogo} alt="Optimism Logo" className="datalink-logo" />
+      <span className="tag">Updated daily</span>
+    </div>
+    <h3>Superchain 4337</h3>
+  </a>
   <a href="#arbitrum-one" className="datalink-card">
     <div className="datalink-header">
       <img src={ArbitrumLogo} alt="Arbitrum Logo" className="datalink-logo" />
@@ -475,6 +482,37 @@ For example, to get all transactions to the 4337 EntryPoint contracts for all OP
   order by dt, chain
 ```
 
+### Superchain 4337
+
+<img src={OptimismLogo} width="100" />
+
+<Button
+  size={"compact"}
+  color={"blue"}
+  target={"_blank"}
+  link={
+    "https://console.cloud.google.com/bigquery/analytics-hub/exchanges/projects/87806073973/locations/us/dataExchanges/open_source_observer_190181416ae/listings/superchain_4337_account_abstraction_data"
+  }
+  children={"Subscribe on BigQuery"}
+/>{" "}
+
+The Superchain 4337 dataset provides comprehensive data about ERC-4337 (Account Abstraction) activity across all OP Stack chains. This dataset is crucial for understanding the adoption and usage patterns of smart contract wallets, bundlers, and paymasters in the Superchain ecosystem. The data helps track which applications are leading the way in improving onchain UX through account abstraction.
+
+All tables are partitioned by date (`dt`) and clustered by chain name (`chain`). The dataset includes decoded UserOps and Paymaster IDs to trace events from unique user smart contract wallet addresses to their wallet providers, paymasters, bundlers, and the applications they interact with.
+
+For example, to see which paymasters are handling the most UserOperations across all chains:
+
+```sql
+select
+  chain,
+  paymaster,
+  approx_count_distinct(userophash) as user_ops
+from `optimism_superchain_4337_account_abstraction_data.useroperationevent_logs_v1`
+where dt > '2025-02-01'
+group by 1,2
+order by 3 desc
+```
+
 ### Arbitrum One
 
 <img src={ArbitrumLogo} width="100" />

warehouse/metrics_mesh/models/staging/superchain/stg_superchain__4337_traces.sql

@@ -0,0 +1,36 @@
+MODEL (
+  name metrics.stg_superchain__4337_traces,
+  kind INCREMENTAL_BY_TIME_RANGE (
+    time_column block_timestamp,
+    batch_size 180,
+    batch_concurrency 1,
+    lookback 7
+  ),
+  start '2021-10-01',
+  cron '@daily',
+  partitioned_by (DAY("block_timestamp"), "chain"),
+  grain (block_timestamp, chain, transaction_hash, userop_hash, from_address, to_address, sender_address, paymaster_address, method_id)
+);
+
+select
+  @from_unix_timestamp(block_timestamp) as block_timestamp,
+  transaction_hash,
+  userop_hash,
+  from_address,
+  to_address,
+  userop_sender as sender_address,
+  userop_paymaster as paymaster_address,
+  CAST(useropevent_actualgascost AS DECIMAL(38, 0)) as userop_gas_price,
+  CAST(useropevent_actualgasused AS DECIMAL(38, 0)) as userop_gas_used,
+  CAST(value AS DECIMAL(38, 0)) as value,
+  method_id,
+  @chain_name(chain) as chain
+from @oso_source('bigquery.optimism_superchain_4337_account_abstraction_data.enriched_entrypoint_traces_v1')
+where
+  network = 'mainnet'
+  and status = '1'
+  and trace_type in ('call', 'create', 'create2')
+  and call_type != 'staticcall'
+  and useropevent_success = true
+  -- Bigquery requires we specify partitions to filter for this data source
+  and dt between @start_dt and @end_dt 

warehouse/metrics_mesh/models/staging/superchain/stg_superchain__4337_userop_logs.sql

@@ -0,0 +1,30 @@
+MODEL (
+  name metrics.stg_superchain__4337_userop_logs,
+  kind INCREMENTAL_BY_TIME_RANGE (
+    time_column block_timestamp,
+    batch_size 180,
+    batch_concurrency 1,
+    lookback 7
+  ),
+  start '2021-10-01',
+  cron '@daily',
+  partitioned_by (DAY("block_timestamp"), "chain"),
+  grain (block_timestamp, chain, transaction_hash, userop_hash, sender_address, paymaster_address, contract_address)
+);
+
+select
+  @from_unix_timestamp(block_timestamp) as block_timestamp,
+  transaction_hash,
+  userophash as userop_hash,
+  sender as sender_address,
+  paymaster as paymaster_address,
+  contract_address,
+  CAST(actualGasCost AS DECIMAL(38, 0)) as userop_gas_price,
+  CAST(actualGasUsed AS DECIMAL(38, 0)) as userop_gas_used,
+  @chain_name(chain) as chain
+from @oso_source('bigquery.optimism_superchain_4337_account_abstraction_data.useroperationevent_logs_v1')
+where
+  network = 'mainnet'
+  and success = true
+  -- Bigquery requires we specify partitions to filter for this data source
+  and dt between @start_dt and @end_dt 

warehouse/metrics_tools/local/utils.py

@@ -62,6 +62,20 @@
         ),
         table="bigquery.optimism_superchain_raw_onchain_data.traces",
     ),
+    "opensource-observer.optimism_superchain_4337_account_abstraction_data.useroperationevent_logs_v1": TableMappingDestination(
+        row_restriction=RowRestriction(
+            time_column="dt",
+            wheres=["chain_id = 252"],
+        ),
+        table="bigquery.optimism_superchain_4337_account_abstraction_data.useroperationevent_logs_v1",
+    ),
+    "opensource-observer.optimism_superchain_4337_account_abstraction_data.enriched_entrypoint_traces_v1": TableMappingDestination(
+        row_restriction=RowRestriction(
+            time_column="dt",
+            wheres=["chain_id = 252"],
+        ),
+        table="bigquery.optimism_superchain_4337_account_abstraction_data.enriched_entrypoint_traces_v1",
+    ),
 }
 
 defillama_tables = {