fix: use repos_to_channel for PR & issues (#3810)

Author: mbani01

services/libs/tinybird/pipes/issues_average_resolve_velocity.pipe

@@ -21,7 +21,7 @@ SQL >
         {% if defined(repos) %}
             AND channel
             IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
-        {% else %} AND channel IN (SELECT url FROM repositories FINAL WHERE excluded = false)
+        {% else %} AND channel IN (SELECT channel FROM repos_to_channels)
         {% end %}
         {% if defined(startDate) %}
             AND openedAt > {{ DateTime(startDate, description="Filter after date", required=False) }}

services/libs/tinybird/pipes/pull_requests_average_resolve_velocity.pipe

@@ -25,7 +25,7 @@ SQL >
         {% if defined(repos) %}
             AND channel
             IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
-        {% else %} AND channel IN (SELECT url FROM repositories FINAL WHERE excluded = false)
+        {% else %} AND channel IN (SELECT channel FROM repos_to_channels)
         {% end %}
         {% if defined(startDate) %}
             AND openedAt > {{ DateTime(startDate, description="Filter after date", required=False) }}

services/libs/tinybird/pipes/pull_requests_filtered.pipe

@@ -12,12 +12,8 @@ DESCRIPTION >
 
 NODE pull_requests_filtered_0
 SQL >
-    %
     SELECT *
     FROM pull_requests_analyzed pra
-    where
+    WHERE
         pra.segmentId = (SELECT segmentId FROM segments_filtered)
-        {% if defined(repos) %}
-            AND pra.channel IN (SELECT channel FROM repos_to_channels)
-        {% else %} AND pra.channel IN (SELECT url FROM repositories FINAL where excluded = false)
-        {% end %}
+        AND pra.channel IN (SELECT channel FROM repos_to_channels)

services/libs/tinybird/pipes/repos_to_channels.pipe

@@ -4,21 +4,27 @@ DESCRIPTION >
     - Non-Gerrit repos are passed through unchanged.
     - Used by activity filtering pipes to match repos against activity channels.
     - Parameters:
-    - `repos`: Required array of repository URLs to expand
+    - `repos`: Optional array of repository URLs to expand. If not provided, defaults to all non-excluded, enabled repositories.
     - Response: `channel` - all possible channel URL formats for the given repos
 
 TAGS "Repository URLs", "Gerrit"
 
 NODE repos_to_expand
 DESCRIPTION >
-    Get repository URLs to expand from repos param
+    Get repository URLs to expand from repos param, or default to all non-excluded enabled repositories
 
 SQL >
     %
-    SELECT
-        arrayJoin(
-            {{ Array(repos, 'String', description="Repository URLs to expand", required=True) }}
-        ) AS url
+    {% if defined(repos) %}
+        SELECT
+            arrayJoin(
+                {{ Array(repos, 'String', description="Repository URLs to expand", required=False) }}
+            ) AS url
+    {% else %}
+        SELECT url
+        FROM repositories FINAL
+        WHERE excluded = false AND isNull (deletedAt) AND enabled = true
+    {% end %}
 
 NODE gerrit_repos
 DESCRIPTION >