from external_api.streams_analytics.providers.TrackStreamsProvider import TrackStreamsProvider
from external_api.base.analytics_models import TrackStreamsQuery, TrackStreamsResult
from external_api.base.clients.delphi_client import DelphiClient


class AmazonStreamsProvider(TrackStreamsProvider[DelphiClient]):
    async def fetch(self, query: TrackStreamsQuery) -> TrackStreamsResult:
        return await self.client.get_amazon_streams_analytics(query)