from external_api.streams_analytics.providers.TrackStreamsProvider import TrackStreamsProvider
from external_api.base.analytics_models import TrackStreamsQuery, TrackStreamsResult
from external_api.base.clients.apollo_client import ApolloClient


class AppleStreamsProvider(TrackStreamsProvider[ApolloClient]):
    async def fetch(self, query: TrackStreamsQuery) -> TrackStreamsResult:
        return await self.client.get_apple_streams_analytics(query)