fix(youtube): wire broadcasts into trigger options discovery

Author: alexeygrigorev

plugins/google/connector/youtube.py

@@ -561,6 +561,19 @@ def _fetch_video_options(event=None, connection_id=None, limit=DEFAULT_LIMIT):
     fetch=_fetch_video_options))
 
 
+def _fetch_broadcast_options(event=None, connection_id=None, limit=DEFAULT_LIMIT):
+    return trigger_discovery.options_from_registry(
+        "youtube.broadcasts", connection_id, limit, provider="youtube",
+        params=trigger_discovery.listing_params(event or "upcoming", ("status", "page_token")),
+        option_of=lambda item: {"value": item.get("id"),
+                                "label": item.get("name") or item.get("id")})
+
+
+register_trigger_discovery(TriggerDiscovery(
+    connector="youtube", label="YouTube", kind="options", resource="youtube.broadcasts",
+    fetch=_fetch_broadcast_options))
+
+
 def _live_upload(connection, *, transport=None):
     """The connected channel's newest upload as a video.published data dict.
 

tests/test_options_breadth.py

@@ -81,6 +81,12 @@ def test_option_fetches_map_the_event_slot_to_the_listing_params(monkeypatch):
     _options("youtube", "youtube.playlist_items", event="UU1234-abcd")
     assert seen[-1] == ("youtube.playlist_items", "conn-1", 5, {"playlist_id": "UU1234-abcd"})
 
+    _options("youtube", "youtube.broadcasts", event="upcoming/page-two")
+    assert seen[-1] == ("youtube.broadcasts", "conn-1", 5,
+                        {"status": "upcoming", "page_token": "page-two"})
+    _options("youtube", "youtube.broadcasts")
+    assert seen[-1] == ("youtube.broadcasts", "conn-1", 5, {"status": "upcoming"})
+
     # Two params: "<required>/<optional tail>" — a missing tail keeps the
     # provider default (worksheet defaults to Sheet1).
     _options("google-sheets", "google-sheets.rows", event="sheet-1/Tab 2")