dbt: event models by source (#1118)

* dbt: update project models

* add: events to project by source models

* add: additional models

* fix: white space

* fix: linting

poetry.toml

@@ -0,0 +1,2 @@
+[virtualenvs]
+in-project = true

warehouse/dbt/models/marts/code_metrics/code_metrics_by_project.sql

@@ -39,6 +39,7 @@ WITH project_commit_dates AS (
 project_repos_summary AS (
   SELECT
     p.project_id,
+    p.project_slug,
     p.project_name,
     r.repository_source,
     COUNT(DISTINCT r.id) AS repositories,
@@ -48,7 +49,7 @@ project_repos_summary AS (
   INNER JOIN {{ ref('projects') }} AS p
     ON r.project_id = p.project_id
   WHERE r.is_fork = false
-  GROUP BY p.project_id, p.project_name, r.repository_source
+  GROUP BY p.project_id, p.project_slug, p.project_name, r.repository_source
 ),
 
 -- CTE for calculating contributor counts and new contributors in the last 6 
@@ -128,6 +129,7 @@ activity_cte AS (
 -- Final query to join all the metrics together
 SELECT
   p.project_id,
+  p.project_slug,
   p.project_name,
   p.repository_source AS `source`,
   pcd.first_commit_date,

warehouse/dbt/models/marts/events/daily/events_daily_to_artifact_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events daily to an artifact by source
+#}
+
+SELECT
+  e.to_id AS artifact_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.time, DAY) AS bucket_day,
+  SUM(e.amount) AS amount
+FROM {{ ref('int_events_to_project') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/daily/events_daily_to_collection_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events daily to a collection by source
+#}
+
+SELECT
+  e.collection_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.time, DAY) AS bucket_day,
+  SUM(e.amount) AS amount
+FROM {{ ref('int_events_to_collection') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/daily/events_daily_to_project_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events daily to a project by source
+#}
+
+SELECT
+  e.project_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.time, DAY) AS bucket_day,
+  SUM(e.amount) AS amount
+FROM {{ ref('int_events_to_project') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/monthly/events_monthly_to_artifact_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events monthly to an artifact by source
+#}
+
+SELECT
+  e.artifact_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, MONTH) AS bucket_month,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_artifact_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/monthly/events_monthly_to_collection_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events monthly to a collection by source
+#}
+
+SELECT
+  e.collection_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, MONTH) AS bucket_month,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_collection_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/monthly/events_monthly_to_project_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events monthly to a project by source
+#}
+
+SELECT
+  e.project_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, MONTH) AS bucket_month,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_project_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/weekly/events_weekly_to_artifact_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events weekly to an artifact by source
+#}
+
+SELECT
+  e.artifact_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, WEEK) AS bucket_week,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_artifact_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/weekly/events_weekly_to_collection_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events weekly to a collection by source
+#}
+
+SELECT
+  e.collection_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, WEEK) AS bucket_week,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_collection_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/events/weekly/events_weekly_to_project_by_source.sql

@@ -0,0 +1,12 @@
+{# 
+  All events weekly to a project by source
+#}
+
+SELECT
+  e.project_id,
+  e.from_id,
+  e.event_type,
+  TIMESTAMP_TRUNC(e.bucket_day, WEEK) AS bucket_week,
+  SUM(e.amount) AS amount
+FROM {{ ref('events_daily_to_project_by_source') }} AS e
+GROUP BY 1, 2, 3, 4

warehouse/dbt/models/marts/onchain_metrics/onchain_metrics_by_project.sql

@@ -149,6 +149,7 @@ contracts AS (
 project_by_network AS (
   SELECT
     p.project_id,
+    p.project_slug,
     ctx.onchain_network,
     p.project_name
   FROM {{ ref('projects') }} AS p
@@ -159,6 +160,7 @@ project_by_network AS (
 -- Final query to join all the metrics together
 SELECT
   p.project_id,
+  p.project_slug,
   p.onchain_network AS network,
   p.project_name,
   -- TODO: add deployers owned by project