feat: widget endpoint support for multi repo filtering

services/libs/tinybird/pipes/activities_filtered.pipe

@@ -13,8 +13,9 @@ SQL >
             AND a.timestamp
             < {{ DateTime(endDate, description="Filter activity timestamp before", required=False) }}
         {% end %}
-        {% if defined(repo) %}
-            AND a.channel = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND a.channel
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
         {% if defined(platform) %}
             AND a.platform

services/libs/tinybird/pipes/activities_filtered_historical_cutoff.pipe

@@ -17,8 +17,9 @@ SQL >
             AND a.timestamp
             < {{ DateTime(endDate, description="Filter activity timestamp before", required=False) }}
         {% end %}
-        {% if defined(repo) %}
-            AND a.channel = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND a.channel
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
         {% if defined(platform) %}
             AND a.platform

services/libs/tinybird/pipes/activities_filtered_retention.pipe

@@ -33,8 +33,9 @@ SQL >
             AND a.timestamp
             < {{ DateTime(endDate, description="Filter activity timestamp before", required=False) }}
         {% end %}
-        {% if defined(repo) %}
-            AND a.channel = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND a.channel
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
         {% if defined(platform) %}
             AND a.platform

services/libs/tinybird/pipes/activityRepositories_filtered.pipe

@@ -9,8 +9,9 @@ SQL >
     from insightsProjects final
     where
         1 = 1
-        {% if defined(repo) %}
-            AND repo = {{ String(repo, description="Filter project repo", required=False) }}
+        {% if defined(repos) %}
+            AND repo
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
         {% if defined(search) %}
             AND repo

services/libs/tinybird/pipes/activity_heatmap_by_weekday_and_2hours_blocks.pipe

@@ -16,8 +16,9 @@ SQL >
             AND a.timestamp
             < {{ DateTime(endDate, description="Filter activity timestamp before", required=False) }}
         {% end %}
-        {% if defined(repo) %}
-            AND a.channel = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND a.channel
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
     group by weekday, two_hours_block
 

services/libs/tinybird/pipes/member_roles.pipe

@@ -1,5 +1,3 @@
-TOKEN "member_roles_endpoint_read_1372" READ
-
 NODE member_roles_result
 SQL >
     %
@@ -10,7 +8,8 @@ SQL >
         {% if defined(project) %}
             AND insightsProjectId = (SELECT insightsProjectId FROM segments_filtered)
         {% end %}
-        {% if defined(repo) %}
-            AND repoUrl = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND repoUrl
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}
     GROUP BY memberId

services/libs/tinybird/pipes/package_metrics.pipe

@@ -22,6 +22,10 @@ SQL >
         {% if defined(name) %}
             AND p.name = {{ String(name, description="Filter by package name", required=False) }}
         {% end %}
+        {% if defined(repos) %}
+            AND p.repo
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
+        {% end %}
 
 NODE package_downloads_timeseries_bounds
 SQL >
@@ -120,15 +124,26 @@ SQL >
 NODE package_downloads_initial_aggregation
 SQL >
     %
-    SELECT
-        {% if defined(granularity) %} p.date, {% end %}
-        sum(p.downloadsCount) as downloadsCount,
-        sum(p.dockerDownloadsCount) as "dockerDownloadsCount",
-        sum(p.dockerDependentsCount) as "dockerDependentsCount",
-        sum(p.dependentPackagesCount) as "dependentPackagesCount",
-        sum(p.dependentReposCount) as "dependentReposCount"
-    FROM package_downloads_filtered p
-    group by p.insightsProjectId {% if defined(granularity) %}, p.date {% end %}
+    {% if defined(granularity) %}
+        SELECT
+            p.date,
+            sum(p.downloadsCount) as downloadsCount,
+            sum(p.dockerDownloadsCount) as "dockerDownloadsCount",
+            sum(p.dockerDependentsCount) as "dockerDependentsCount",
+            sum(p.dependentPackagesCount) as "dependentPackagesCount",
+            sum(p.dependentReposCount) as "dependentReposCount"
+        FROM package_downloads_filtered p
+        group by p.insightsProjectId, p.date
+    {% else %}
+        SELECT
+            max(p.downloadsCount) as downloadsCount,
+            max(p.dockerDownloadsCount) as "dockerDownloadsCount",
+            max(p.dockerDependentsCount) as "dockerDependentsCount",
+            max(p.dependentPackagesCount) as "dependentPackagesCount",
+            max(p.dependentReposCount) as "dependentReposCount"
+        FROM package_downloads_filtered p
+        group by p.insightsProjectId
+    {% end %}
 
 NODE package_downloads_timeseries_merge
 SQL >

services/libs/tinybird/pipes/packages.pipe

@@ -4,7 +4,7 @@ SQL >
     SELECT distinct p.repo, p.name, p.ecosystem
     FROM packageDownloads p
     where
-        insightsProjectId = (select insightsProjectId from segments_filtered)
+        p.insightsProjectId = (select insightsProjectId from segments_filtered)
         {% if defined(search) %}
             AND (
                 p.name
@@ -17,3 +17,7 @@ SQL >
                 || '%'
             )
         {% end %}
+        {% if defined(repos) %}
+            AND p.repo
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
+        {% end %}

services/libs/tinybird/pipes/pull_requests_filtered.pipe

@@ -8,6 +8,7 @@ SQL >
     FROM pull_requests_analyzed pra
     where
         pra.segmentId = (SELECT segmentId FROM segments_filtered)
-        {% if defined(repo) %}
-            AND pra.channel = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND pra.channel
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}

services/libs/tinybird/pipes/security_and_best_practices.pipe

@@ -79,6 +79,7 @@ SQL >
             = {{ String(project, description="Filter by project slug", required=True) }}
         {% else %} AND false
         {% end %}
-        {% if defined(repo) %}
-            AND s.repo = {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND s.repo
+            IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
         {% end %}

services/libs/tinybird/pipes/segments_filtered.pipe

@@ -9,9 +9,9 @@ SQL >
             AND slug = {{ String(project, description="Filter by project slug", required=True) }}
         {% else %} AND false
         {% end %}
-        {% if defined(repo) %}
-            AND has(
-                insightsProjects.repositories,
-                {{ String(repo, description="Filter activity repo", required=False) }}
+        {% if defined(repos) %}
+            AND arrayAll(
+                r -> has(insightsProjects.repositories, r),
+                {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
             )
         {% end %}