add: remaining activity based code metrics (#2112)

* add: remaining activity based code metrics

* add: gas fees and transactions

* fix: from_id to null and add active addresses

warehouse/metrics_mesh/models/metrics_factories.py

@@ -39,6 +39,38 @@
             ref="forks.sql",
             vars={},
         ),
+        "commits": MetricQuery(
+            ref="commits.sql",
+            vars={},
+        ),
+        "pull_requests_opened": MetricQuery(
+            ref="prs_opened.sql",
+            vars={},
+        ),
+        "issues_opened": MetricQuery(
+            ref="issues_opened.sql",
+            vars={},
+        ),
+        "pull_requests_merged": MetricQuery(
+            ref="prs_merged.sql",
+            vars={},
+        ),
+        "issues_closed": MetricQuery(
+            ref="issues_closed.sql",
+            vars={},
+        ),
+        "transactions": MetricQuery(
+            ref="transactions.sql",
+            vars={},
+        ),
+        "gas_fees": MetricQuery(
+            ref="gas_fees.sql",
+            vars={},
+        ),
+        "active_addresses": MetricQuery(
+            ref="active_addresses.sql",
+            vars={},
+        ),
     },
     trailing_days=30,
     model_options=dict(

warehouse/metrics_mesh/oso_metrics/active_addresses.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  COUNT(distinct events.from_artifact_id) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('CONTRACT_INVOCATION_SUCCESS_DAILY_COUNT')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/active_days.sql

@@ -1,7 +1,7 @@
 select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
   events.event_source,
   events.to_artifact_id,
-  events.from_artifact_id,
+  '' as from_artifact_id,
   @metric_name as metric,
   COUNT(DISTINCT events.bucket_day) amount,
   from metrics.events_daily_to_artifact as events

warehouse/metrics_mesh/oso_metrics/commits.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('COMMIT_CODE')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/gas_fees.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('CONTRACT_INVOCATION_DAILY_L2_GAS_USED')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/issues_closed.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('ISSUE_CLOSED')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/issues_opened.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('ISSUE_OPENED')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/prs_merged.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('PULL_REQUEST_MERGED')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/prs_opened.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('PULL_REQUEST_OPENED')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source

warehouse/metrics_mesh/oso_metrics/transactions.sql

@@ -0,0 +1,14 @@
+select STR_TO_DATE(@end_ds, '%Y-%m-%d') as metrics_bucket_date,
+  events.event_source,
+  events.to_artifact_id,
+  '' as from_artifact_id,
+  @metric_name as metric,
+  SUM(events.amount) as amount
+from metrics.events_daily_to_artifact as events
+where event_type in ('CONTRACT_INVOCATION_SUCCESS_DAILY_COUNT')
+  and events.bucket_day BETWEEN STR_TO_DATE(@start_ds, '%Y-%m-%d') AND STR_TO_DATE(@end_ds, '%Y-%m-%d')
+group by 1,
+  metric,
+  from_artifact_id,
+  to_artifact_id,
+  event_source