using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using MoreLinq;
using PetaPoco.Business;
using Sony.Filtr.Contracts.Entities;

namespace Sony.Filtr.Core.SpotifyTrackLink
{
    public class SpotifyLinkedTrackFactory
    {
        public async Task SaveSpotifyLinkedTracksAsync(List<SpotifyLinkedTrack> linkedTracks)
        {
            PetaPocoRepository.Instance.Db.BulkInsert(linkedTracks);
        }

        public async Task<List<SpotifyLinkedTrack>> GetSpotifyLinkedTracksAsync()
        {
            return PetaPocoRepository.ReadOnlyInstance.Fetch<SpotifyLinkedTrack>();
        }

        public async Task<List<SpotifyLinkedTrack>> GetSpotifyLinkedTracksAsync(string region, List<string> trackUris)
        {
            List<SpotifyLinkedTrack> allSpotifyLinkedTracks = new List<SpotifyLinkedTrack>();

            foreach (var trackUriBatch in trackUris.Batch(100))
            {
                allSpotifyLinkedTracks.AddRange(PetaPocoRepository.ReadOnlyInstance.Fetch<SpotifyLinkedTrack>("WHERE strRegion=@0 AND strTrackUri IN (@1)", region, trackUriBatch));
            }
            return allSpotifyLinkedTracks;
        }
    }
}