Add discovery

This commit is contained in:
Nirvana
2026-03-03 13:45:47 +01:00
parent ea23f7b07e
commit 753ac4843f
3 changed files with 4 additions and 24 deletions
@@ -287,7 +287,7 @@ class DRMOperations:
return configs
def get_channel_drm_configs(self, provider_name: str, channel_id: str, **kwargs) -> List:
def get_content_drm_configs(self, provider_name: str, channel_id: str, **kwargs) -> List:
"""
Get DRM configurations for a channel with two-phase plugin processing.
@@ -75,24 +75,4 @@ class EventOperations:
logger.debug(
f"Retrieved manifest for event '{event_id}' from '{provider_name}'"
)
return manifest_url
def get_event_drm_configs(
self, provider_name: str, event_id: str, **kwargs
) -> List:
"""
Get DRM configurations for a specific event.
Delegates to provider.get_drm() — the same method used for
channels — because DRM resolution is content-type-agnostic.
"""
provider = self.registry.get_provider(provider_name)
if not provider:
raise ValueError(f"Provider '{provider_name}' not found or disabled")
drm_configs = provider.get_drm(content_id=event_id, **kwargs)
logger.debug(
f"Retrieved {len(drm_configs)} DRM config(s) for event '{event_id}' "
f"from '{provider_name}'"
)
return drm_configs
return manifest_url
+2 -2
View File
@@ -162,7 +162,7 @@ class ProviderManager:
# ==========================================================================
def get_channel_drm_configs(self, provider_name: str, channel_id: str, **kwargs) -> List:
return self.drm_ops.get_channel_drm_configs(provider_name, channel_id, **kwargs)
return self.drm_ops.get_content_drm_configs(provider_name, channel_id, **kwargs)
def list_drm_plugins(self) -> Dict:
return self.drm_ops.list_drm_plugins()
@@ -228,7 +228,7 @@ class ProviderManager:
return self.event_ops.get_event_manifest(provider_name, event_id, **kwargs)
def get_event_drm_configs(self, provider_name: str, event_id: str, **kwargs) -> List:
return self.event_ops.get_event_drm_configs(provider_name, event_id, **kwargs)
return self.drm_ops.get_content_drm_configs(provider_name, event_id, **kwargs)
# ==========================================================================
# SUBSCRIPTION OPERATIONS (delegate to SubscriptionOperations)