using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
using PetaPoco.Business;

using Sony.Filtr.Database;

namespace Sony.Filtr.AppleMusic.Curators
{

    public class AppleMusicCuratorManager
    {
        public async Task AddOrUpdateCuratorAsync(AppleMusicCurator curator)
        {
            using (var conn = await DatabaseHandler.GetOpenConnectionAsync())
            {
                const string sql = "INSERT INTO tblAppleMusicCurator (Id, Name, CuratorType, CuratorLink) VALUES (@id, @name, @type, @link) " +
                                   "ON DUPLICATE KEY UPDATE Name = VALUES(Name), CuratorType = VALUES(CuratorType), CuratorLink = VALUES(CuratorLink)";

                var cmd = new MySqlCommand(sql, conn);

                cmd.Parameters.AddWithValue("@id", curator.Id);
                cmd.Parameters.AddWithValue("@name", curator.Name);
                cmd.Parameters.AddWithValue("@type", curator.CuratorType);
                cmd.Parameters.AddWithValue("@link", curator.CuratorLink);

                await cmd.ExecuteNonQueryAsync();
            }
           
        }

        public List<AppleMusicCurator> GetCurators()
        {
           return PetaPocoRepository.ReadOnlyInstance.Fetch<AppleMusicCurator>();
        }
    }
}