chore: update org page pipes to use slug instead of id

Signed-off-by: Joana Maia <jmaia@contractor.linuxfoundation.org>

Author: joanagmaia

services/libs/tinybird/pipes/org_page_activities_timeseries.pipe

@@ -3,10 +3,15 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
-NODE org_page_activities_timeseries_data
+NODE org_slug_lookup
 SQL >
     %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
+NODE org_page_activities_timeseries_data
+SQL >
     SELECT startDate, endDate, activityCount
     FROM org_page_activities_timeseries_copy_ds FINAL
-    WHERE organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+    WHERE organizationId = (SELECT id FROM org_slug_lookup)
     ORDER BY startDate

services/libs/tinybird/pipes/org_page_contributors.pipe

@@ -4,14 +4,20 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
+NODE org_slug_lookup
+SQL >
+    %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
 NODE org_page_contributors_activity_aggregates
 SQL >
     %
     {% if Boolean(count, false) %}
         SELECT count(distinct memberId)
         FROM activityRelations_deduplicated_cleaned_bucket_union
         WHERE
-            organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+            organizationId = (SELECT id FROM org_slug_lookup)
             {% if defined(startDate) %}
                 AND timestamp
                 >= {{ DateTime(startDate, description="Filter activity timestamp after") }}
@@ -26,7 +32,7 @@ SQL >
             ROUND(COUNT(*) * 100.0 / SUM(COUNT(*)) OVER (), 2) as "contributionPercentage"
         FROM activityRelations_deduplicated_cleaned_bucket_union
         WHERE
-            organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+            organizationId = (SELECT id FROM org_slug_lookup)
             {% if defined(startDate) %}
                 AND timestamp
                 >= {{ DateTime(startDate, description="Filter activity timestamp after") }}
@@ -47,7 +53,7 @@ SQL >
         SELECT count(distinct memberId) as count
         FROM activityRelations_deduplicated_cleaned_bucket_union
         WHERE
-            organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+            organizationId = (SELECT id FROM org_slug_lookup)
             {% if defined(startDate) %} AND timestamp >= {{ DateTime(startDate) }} {% end %}
             {% if defined(endDate) %} AND timestamp < {{ DateTime(endDate) }} {% end %}
     {% else %}

services/libs/tinybird/pipes/org_page_contributors_timeseries.pipe

@@ -3,10 +3,15 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
-NODE org_page_contributors_timeseries_data
+NODE org_slug_lookup
 SQL >
     %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
+NODE org_page_contributors_timeseries_data
+SQL >
     SELECT startDate, endDate, contributorCount
     FROM org_page_contributors_timeseries_copy_ds FINAL
-    WHERE organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+    WHERE organizationId = (SELECT id FROM org_slug_lookup)
     ORDER BY startDate

services/libs/tinybird/pipes/org_page_kpis.pipe

@@ -4,9 +4,14 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
-NODE org_page_kpis_main
+NODE org_slug_lookup
 SQL >
     %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
+NODE org_page_kpis_main
+SQL >
     SELECT
         activeContributors,
         if(
@@ -25,4 +30,4 @@ SQL >
         maintainerRoles,
         criticalProjects
     FROM org_page_kpis_copy_ds FINAL
-    WHERE organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+    WHERE organizationId = (SELECT id FROM org_slug_lookup)

services/libs/tinybird/pipes/org_page_profile.pipe

@@ -4,20 +4,24 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
-NODE org_page_profile_base
+NODE org_slug_lookup
 SQL >
     %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
+NODE org_page_profile_base
+SQL >
     SELECT id, displayName, logo, employees AS employeeCount, industry, headline AS description
     FROM organizations FINAL
-    WHERE id = {{ String(orgId, '', description="Organization ID", required=True) }}
+    WHERE id = (SELECT id FROM org_slug_lookup)
 
 NODE org_page_profile_website
 SQL >
-    %
     SELECT organizationId, argMax(value, updatedAt) AS website
     FROM organizationIdentities FINAL
     WHERE
-        organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+        organizationId = (SELECT id FROM org_slug_lookup)
         AND type = 'primary-domain'
     GROUP BY organizationId
 

services/libs/tinybird/pipes/org_page_projects.pipe

@@ -4,6 +4,12 @@ DESCRIPTION >
 
 TAGS "Organization page"
 
+NODE org_slug_lookup
+SQL >
+    %
+    SELECT id FROM organizations_populated_slug
+    WHERE slug = {{ String(orgSlug, '', description="Organization slug", required=True) }}
+
 NODE org_page_projects_main
 SQL >
     %
@@ -22,7 +28,7 @@ SQL >
         orgPrsOpened,
         technicalScore
     FROM org_page_projects_copy_ds FINAL
-    WHERE organizationId = {{ String(orgId, '', description="Organization ID", required=True) }}
+    WHERE organizationId = (SELECT id FROM org_slug_lookup)
     ORDER BY technicalScore DESC, activityCount DESC
     LIMIT {{ Int32(limit, 21, description="Page size + 1 for hasMore detection") }}
     OFFSET {{ Int32(offset, 0, description="Pagination offset") }}

services/libs/tinybird/pipes/organizations_leaderboard.pipe

@@ -18,7 +18,7 @@ DESCRIPTION >
     - `offset`: Optional integer for result pagination, defaults to 0
     - Response:
     - Count mode (`count=true`): `count` (total number of organizations)
-    - Data mode (default): `id`, `logo`, `displayName`, `contributionCount`, `contributionPercentage`
+    - Data mode (default): `id`, `slug`, `logo`, `displayName`, `contributionCount`, `contributionPercentage`
 
 NODE organizations_leaderboard_paginated
 SQL >
@@ -28,13 +28,14 @@ SQL >
     {% else %}
         SELECT
             org.id AS id,
+            org.slug AS slug,
             org.logo AS logo,
             org.displayName AS displayName,
             COUNT(af.id) AS contributionCount,
             ROUND(COUNT(af.id) * 100.0 / SUM(COUNT(af.id)) OVER (), 2) AS contributionPercentage
         FROM activities_filtered af
-        JOIN organizations org FINAL ON org.id = af.organizationId
-        GROUP BY org.id, org.logo, org.displayName
+        JOIN organizations_populated_slug org ON org.id = af.organizationId
+        GROUP BY org.id, org.slug, org.logo, org.displayName
         ORDER BY contributionCount DESC, id desc
         LIMIT {{ Int32(limit, 10) }}
         OFFSET {{ Int32(offset, 0) }}