icarus/Controllers/Managers/SongManager.cs

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Threading.Tasks;

using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Configuration;

using Id3;
using Id3.Frames;
using MySql.Data;
using MySql.Data.MySqlClient;
using NLog;
using TagLib;

using Icarus.Controllers.Utilities;
using Icarus.Models;
using Icarus.Models.Context;

namespace Icarus.Controllers.Managers
{
	public class SongManager
    	{
        	#region Fields
		private static Logger _logger = NLog.Web.NLogBuilder.ConfigureNLog("nlog.config").GetCurrentClassLogger();
        	private MySqlConnection _conn;
        	private MySqlCommand _cmd;
        	private MySqlDataAdapter _dataDump;
        	private DataTable _results;
		private List<Song> _songs;
		private Song _song;
		private IConfiguration _config;
		private string _connectionString;
		private string _tempDirectoryRoot;
		private string _archiveDirectoryRoot;
		private string _compressedSongFilename;
		private string _message;
		#endregion


		#region Properties
		public Song SongDetails
		{
	    		get => _song;
	    		set => _song = value;
		}

		public string ArchiveDirectoryRoot
		{
			get => _archiveDirectoryRoot;
		    	set => _archiveDirectoryRoot = value;
		}
		public string CompressedSongFilename
		{
	 	   	get => _compressedSongFilename;
	    		set => _compressedSongFilename = value;
		}
		public string Message
		{
			get => _message;
			set => _message = value;
		}
		#endregion


		#region Constructors
		public SongManager()
		{
	    		Initialize();
            		InitializeConnection();
		}

		public SongManager(Song song)
		{
	    		Initialize();
            		InitializeConnection();
	    		_song = song;
		}
		public SongManager(IConfiguration config)
		{
	    		_config = config;
	    		Initialize();
            		InitializeConnection();
		}
		public SongManager(IConfiguration config, string tempDirectoryRoot)
		{
	    		_config = config;
	    		_tempDirectoryRoot = tempDirectoryRoot;
	    		Initialize();
            		InitializeConnection();
		}
		#endregion


		#region Methods
		// TODO: This method should update the Song, Album, and Artist records in the database
		public SongResult UpdateSong(Song song, MusicStoreContext songStore, AlbumStoreContext albumStore,
				ArtistStoreContext artistStore, GenreStoreContext genreStore,
				YearStoreContext yearStore)
		{
			try
			{
				var oldSongRecord = songStore.GetSong(song);
				song.SongPath = oldSongRecord.SongPath;

				MetadataRetriever updateMetadata = new MetadataRetriever();
				updateMetadata.UpdateMetadata(song, oldSongRecord);

				var updatedSong = updateMetadata.UpdatedSongRecord;

				// TODO: Add the following methods
				var updatedAlbum = UpdateAlbumInDatabase(oldSongRecord, updatedSong, albumStore);
				oldSongRecord.AlbumId = updatedAlbum.AlbumId;
				var updatedArtist = UpdateArtistInDatabase(oldSongRecord, updatedSong, artistStore);
				oldSongRecord.ArtistId = updatedArtist.ArtistId;
				var updatedGenre = UpdateGenreInDatabase(oldSongRecord, updatedSong, genreStore);
				oldSongRecord.GenreId = updatedGenre.GenreId;
				var updatedYear = UpdateYearInDatabase(oldSongRecord, updatedSong, yearStore);
				oldSongRecord.YearId = updatedYear.YearId;

				UpdateSongInDatabase(oldSongRecord, updatedSong, songStore);
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}

			return new SongResult();
		}

		public bool DeleteSongFromFileSystem(Song songMetaData)
		{
		    	bool successful = false;
	    		try
	    		{
	        		var songPath = songMetaData.SongPath;
				System.IO.File.Delete(songPath);
				successful = true;
				DirectoryManager dirMgr = new DirectoryManager(_config, songMetaData);
				dirMgr.DeleteEmptyDirectories();
				Console.WriteLine("Song successfully deleted");
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
	    		}

	    		return successful;
		}
		// TODO: Implement method
		// This method should do the following, with the help of existing methods
		// or create helper methods to compelete to intended purpose:
		//
		// 1. Delete song from the filesystem
		// 2. Delete the song record from the database
		// 3. Decrement the SongCount value or delete the album record from the Database
		// 4. Decrement the SongCount value or delete the artist record from the Database
		public bool DeleteSongFromFileSystem(Song song, MusicStoreContext songStore,
				AlbumStoreContext albumStore, ArtistStoreContext artistStore)
		{

			return false;
		}

		public void SaveSongDetails()
		{
			try
	    		{
	        		using (MySqlConnection conn = new MySqlConnection(_connectionString))
				{
		    			conn.Open();
		    			string query = "INSERT INTO Songs(Title, AlbumTitle, Artist, Year, Genre, Duration, " +
					   "Filename, SongPath) VALUES(@Title, @AlbumTitle, @Artist, @Year, @Genre, " +
					   "@Duration, @Filename, @SongPath)";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
		    			{
		        			cmd.Parameters.AddWithValue("@Title", _song.Title);
						cmd.Parameters.AddWithValue("@AlbumTitle", _song.AlbumTitle);
						cmd.Parameters.AddWithValue("@Artist", _song.Artist);
						cmd.Parameters.AddWithValue("@Year", _song.Year);
						cmd.Parameters.AddWithValue("@Genre", _song.Genre);
						cmd.Parameters.AddWithValue("@Duration", _song.Duration);
						cmd.Parameters.AddWithValue("@Filename", _song.Filename);
						cmd.Parameters.AddWithValue("@SongPath", _song.SongPath);

						cmd.ExecuteNonQuery();
		    			}
				}
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An Error Occurred: {exMsg}");
	    		}
		}
		public void SaveSongDetails(Song song)
		{
	    		try
	    		{
	        		using (MySqlConnection conn = new MySqlConnection(_connectionString))
				{
		    			conn.Open();
		    			string query = "INSERT INTO Songs(Title, AlbumTitle, Artist, Year, Genre, Duration, " +
					   ", Filename, SongPath) VALUES(@Title, @AlbumTitle, @Artist, @Year, @Genre, " +
					   "@Duration, @Filename, @SongPath)";
		    			using (MySqlCommand cmd = new MySqlCommand(query, conn))
		    			{
		        			cmd.Parameters.AddWithValue("@Title", song.Title);
						cmd.Parameters.AddWithValue("@AlbumTitle", song.AlbumTitle);
						cmd.Parameters.AddWithValue("@Artist", song.Artist);
						cmd.Parameters.AddWithValue("@Year", song.Year);
						cmd.Parameters.AddWithValue("@Genre", song.Genre);
						cmd.Parameters.AddWithValue("@Duration", song.Duration);
						cmd.Parameters.AddWithValue("@Filename", song.Filename);
						cmd.Parameters.AddWithValue("@SongPath", song.SongPath);

						cmd.ExecuteNonQuery();
		   	 		}
				}
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An Error Occurred: {exMsg}");
	    		}
		}

		public async Task SaveSong(SongData songData)
		{
	    		try
	    		{
				using (MySqlConnection conn = new MySqlConnection(_connectionString))
				{
		    			conn.Open();
		    			string query = "INSERT INTO SongData(Data) VALUES(@Data)";
		    			using (MySqlCommand cmd = new MySqlCommand(query, conn))
		    			{
		        			cmd.Parameters.AddWithValue("@Data", songData.Data);

						cmd.ExecuteNonQuery();
		    			}
				}
	    		}
	    		catch(Exception ex)
	    		{
	        		var exMsg = ex.Message;
	 			Console.WriteLine($"An error occurred: {exMsg}");
	    		}
		}
		public async Task SaveSongToFileSystem(IFormFile song)
		{
	    		try
	    		{
				Console.WriteLine("Saving song to the filesystem");
	        		var filePath = Path.Combine(_tempDirectoryRoot, song.FileName);
				Console.WriteLine("Saving song to the filePath");
				await SaveSongToFileSystemTemp(song, filePath);
				System.IO.File.Delete(filePath);


				DirectoryManager dirMgr = new DirectoryManager(_config, _song);
				dirMgr.CreateDirectory();
				filePath = dirMgr.SongDirectory;
				if (!song.FileName.EndsWith(".mp3"))
		    			filePath += $"{song.FileName}.mp3";
				else
		    			filePath += $"{song.FileName}";

				Console.WriteLine($"Full path {filePath}");

				using (var fileStream = new FileStream(filePath, FileMode.Create))
				{
		    			await song.CopyToAsync(fileStream);
		    			_song.SongPath = filePath;

		    			Console.WriteLine($"Writing song to the directory: {filePath}");
				}
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An error occurred: {exMsg}");
	    		}
		}
		public async Task SaveSongToFileSystem(IFormFile songFile, MusicStoreContext sStoreContext,
				AlbumStoreContext alStoreContext,
				ArtistStoreContext arStoreContext) 
		{
			try
			{
				_logger.Info("Starting process to save song to the filesystem");
				var fileTempPath = Path.Combine(_tempDirectoryRoot, songFile.FileName);
				var song = await SaveSongTemp(songFile, fileTempPath);
				System.IO.File.Delete(fileTempPath);

				DirectoryManager dirMgr = new DirectoryManager(_config, song);
				dirMgr.CreateDirectory();
				var filePath = dirMgr.SongDirectory;
				if (!songFile.FileName.EndsWith(".mp3"))
					filePath += $"{songFile.FileName}.mp3";
				else
					filePath += $"{songFile.FileName}";

				_logger.Info($"Absolute song path: {filePath}");

				using (var fileStream = new FileStream(filePath, FileMode.Create))
				{
					await (songFile.CopyToAsync(fileStream));
					song.SongPath = filePath;

					_logger.Info("Song Successfully saved");
				}
				SaveSongToDatabase(song, sStoreContext, alStoreContext, arStoreContext);
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}
		}
		public async Task SaveSongToFileSystem(IFormFile songFile, MusicStoreContext songStore,
				AlbumStoreContext albumStore, ArtistStoreContext artistStore,
				GenreStoreContext genreStore, YearStoreContext yearStore)
		{
			try
			{
				_logger.Info("Starting the process of saving the song to the filesystem");

				var fileTempPath = Path.Combine(_tempDirectoryRoot, songFile.FileName);
				var song = await SaveSongTemp(songFile, fileTempPath);
				System.IO.File.Delete(fileTempPath);

				DirectoryManager dirMgr = new DirectoryManager(_config, song);
				dirMgr.CreateDirectory();

				var filePath = dirMgr.SongDirectory;
				var songFilename = songFile.FileName;

				if (!songFilename.EndsWith(".mp3"))
					filePath += $"{songFilename}.mp3";
				else
					filePath += $"{songFilename}";

				_logger.Info($"Absolute song path: {filePath}");

				using (var fileStream = new FileStream(filePath, FileMode.Create))
				{
					await (songFile.CopyToAsync(fileStream));
					song.SongPath = filePath;

					_logger.Info("Song successfully saved to filesystem");
				}

				SaveSongToDatabase(song, songStore, albumStore, artistStore, genreStore,
						yearStore);
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}
		}

        	public async Task<List<Song>> RetrieveAllSongDetails()
        	{
            		try
            		{
                		InitializeResults();
                		_songs = new List<Song>();
                		_conn.Open();
                		string query = "SELECT * FROM Songs";

                		_cmd = new MySqlCommand(query, _conn);
                		_cmd.ExecuteNonQuery();

                		_dataDump = new MySqlDataAdapter(_cmd);
                		_dataDump.Fill(_results);
                		_dataDump.Dispose();

                		await PopulateSongDetails();


                		_conn.Close();

            		}
            		catch (Exception ex)
            		{
                		var exMsg = ex.Message;
                		Console.WriteLine($"An error ocurred: {exMsg}");
            		}

            		return _songs;
        	}
		public async Task<Song> RetrieveSongDetails(int id)
		{
	    		DataTable results = new DataTable();

	    		try
	    		{
	        		using (MySqlConnection conn = new MySqlConnection(_connectionString))
				{
		    			conn.Open();
		    			string query = "SELECT * FROM Songs WHERE Id=@Id";
		    			using (MySqlCommand cmd = new MySqlCommand(query, conn))
		    			{
		        			cmd.Parameters.AddWithValue("@Id", id);
		        	
						cmd.ExecuteNonQuery();

	                			using (MySqlDataAdapter dataDump = new MySqlDataAdapter(cmd))
						{
			    				dataDump.Fill(results);
						}
		    			}
				}
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An error occurred");
	    		}	
	    
       	    		DataRow row = results.Rows[0];

	    		return new Song
	    		{
	        		Id = Int32.Parse(row["Id"].ToString()),
				Filename = row["Filename"].ToString(),
				SongPath = row["SongPath"].ToString()
	    		};
		}
		public async Task<SongData> RetrieveSong(int id)
		{
	    		SongData song = new SongData();
	    		try
	    		{
	        		_song = await RetrieveSongDetails(id);
				song = await RetrieveSongFromFileSystem(_song);
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An error occurred: {exMsg}");
	    		}

	    		return song;
		}
		public async Task<SongData> RetrieveSong(Song songMetaData)
		{
	    		SongData song = new SongData();
	    		try
	    		{
				Console.WriteLine("Fetching song from filesystem");
				song = await RetrieveSongFromFileSystem(songMetaData);
	    		}
	    		catch (Exception ex)
	    		{
	        		var exMsg = ex.Message;
				Console.WriteLine($"An error occurred: {exMsg}");
	    		}

	    		return song;
		}


		private Song RetrieveMetaData(string filePath)
		{
			Song newSong = new Song
			{
	        		Title = "Untitled",
				Artist = "Untitled",
				AlbumTitle = "Untitled",
				Year = 0,
				Genre = "Untitled",
				Duration = 0,
				SongPath = ""
			};
	    		string title, artist, album, genre;
	    		int year, duration;
			
			Console.WriteLine("Stripping song metadata");
			try
			{
	    			TagLib.File tfile = TagLib.File.Create(filePath);


	    			using (var mp3 = new Mp3(filePath))
    	    			{
                			Id3Tag tag = mp3.GetTag(Id3TagFamily.Version2X);
					title = tag.Title;
        				Console.WriteLine("Title: {0}", title);
					newSong.Title = title;
					artist = tag.Artists;
        				Console.WriteLine("Artist: {0}", artist);
					newSong.Artist = artist;
	        			album = tag.Album;
        				Console.WriteLine("Album: {0}", album);
					newSong.AlbumTitle = album;
					genre = "Not Implemented";
					Console.WriteLine("Genre: {0}", genre);
					newSong.Genre = genre;
					year = (int)tag.Year;
					Console.WriteLine("Year: {0}", year);
					newSong.Year = year;
	    				duration = (int)tfile.Properties.Duration.TotalSeconds;
					Console.WriteLine("Duration: {0}", duration);
					newSong.Duration = duration;
    	    			}

	    			_song = newSong;
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				Console.WriteLine($"An error occurred when stripping metadata\n{msg}");
				_song = newSong;
			}

	    		return newSong;
		}

		private async Task<SongData> RetrieveSongFromFileSystem(Song details)
		{
            		byte[] uncompressedSong = System.IO.File.ReadAllBytes(details.SongPath);
			
	    		return new SongData
	    		{
	        		Data = uncompressedSong
	    		};
		}
		private async Task<Song> SaveSongTemp(IFormFile songFile, string filePath)
		{
			var song = new Song();


			using (var filestream = new FileStream(filePath, FileMode.Create))
			{
				_logger.Info("Saving song to temporary directory");
				await songFile.CopyToAsync(filestream);
				MetadataRetriever meta = new MetadataRetriever();
				song =  meta.RetrieveMetaData(filePath);

				_logger.Info("Assigning song filename");
				song.Filename = songFile.FileName;
			}

			return song;
		}

		private async Task SaveSongToFileSystemTemp(IFormFile song, string filePath)
		{
	    		using (var fileStream = new FileStream(filePath, FileMode.Create))
	    		{
				Console.WriteLine("Retrieving song and storing it in memory");
				_logger.Info("Retrieving song and storing it in memory");
	        		await song.CopyToAsync(fileStream);
				Console.WriteLine($"Retrieving metadata of song from filepath {filePath}");
				_logger.Info($"Retrieving metadata of song from filepath {filePath}");
				MetadataRetriever meta = new MetadataRetriever();
				_song = meta.RetrieveMetaData(filePath);
	
				Console.WriteLine("Assigning song filename");
				_song.Filename = song.FileName;
				Console.WriteLine($"Song filename retrieved: {song.FileName}");
	    		}
		}

		private bool SongRecordChanged(Song currentSong, Song songUpdates)
		{
			var currentTitle = currentSong.Title;
			var currentArtist = currentSong.Artist;
			var currentAlbum = currentSong.AlbumTitle;
			var currentGenre = currentSong.Genre;
			var currentYear = currentSong.Year;

			if (!currentTitle.Equals(songUpdates.Title) || !currentArtist.Equals(songUpdates.Artist) ||
					!currentAlbum.Equals(songUpdates.AlbumTitle) ||
					!currentGenre.Equals(songUpdates.Genre) || currentYear != songUpdates.Year)
			{
				return true;
			}

			return false;
		}

		private void Initialize()
		{
	    		try
	    		{
	        		_connectionString = _config.GetConnectionString("IcarusDev");
	    		}
	    		catch (Exception ex)
	    		{
	        		Console.WriteLine($"Error Occurred: {ex.Message}");
	    		}
			
		}
        	private void InitializeConnection()
        	{
            		_conn = new MySqlConnection(_connectionString);
        	}
       	 	private void InitializeResults()
        	{
            		_results = new DataTable();
        	}

		private void SaveSongToDatabase(Song song, MusicStoreContext songStore, AlbumStoreContext albumStore,
				ArtistStoreContext artistStore)
		{
			_logger.Info("Starting process to save the song to the database");
			
			SaveAlbumToDatabase(ref song, albumStore);
			SaveArtistToDatabase(ref song, artistStore);
			
			_logger.Info($"Song;\nTitle {song.Title}\nAlbum {song.AlbumTitle}\nAlbum Id {song.AlbumId}\nArtist {song.ArtistId}");

			songStore.SaveSong(song);
		}
		private void SaveSongToDatabase(Song song, MusicStoreContext songStore, AlbumStoreContext albumStore,
				ArtistStoreContext artistStore, GenreStoreContext genreStore, YearStoreContext yearStore)
		{
			_logger.Info("Starting process to save the song to the database");

			SaveAlbumToDatabase(ref song, albumStore);
			SaveArtistToDatabase(ref song, artistStore);
			SaveGenreToDatabase(ref song, genreStore);
			SaveYearToDatabase(ref song, yearStore);

			var info = "Saving Song to DB";
			Console.WriteLine(info);
			_logger.Info(info);
			songStore.SaveSong(song);
		}
		private void SaveAlbumToDatabase(ref Song song, AlbumStoreContext albumStore)
		{
			_logger.Info("Starting process to save the album record of the song to the database");

			var album = new Album();

			album.Title = song.AlbumTitle;
			album.AlbumArtist = song.Artist;

			if (!albumStore.DoesAlbumExist(song))
			{
				album.SongCount = 1;
				albumStore.SaveAlbum(album);
				album = albumStore.GetAlbum(song);
			}
			else
			{
				var albumRetrieved = albumStore.GetAlbum(song);
				album.AlbumId = albumRetrieved.AlbumId;
				album.SongCount = albumRetrieved.SongCount + 1;

				albumStore.UpdateAlbum(album);
			}

			song.AlbumId = album.AlbumId;
		}
		private void SaveArtistToDatabase(ref Song song, ArtistStoreContext artistStore)
		{
			_logger.Info("Starting process to save the artist record of the song to the database");

			var artist = new Artist();

			artist.Name = song.Artist;
			artist.SongCount = 1;

			if (!artistStore.DoesArtistExist(song))
			{
				artist.SongCount = 1;
				artistStore.SaveArtist(artist);
				artist = artistStore.GetArtist(song);
			}
			else
			{
				var artistRetrieved = artistStore.GetArtist(song);
				artist.ArtistId = artistRetrieved.ArtistId;
				artist.SongCount = artistRetrieved.SongCount + 1;

				artistStore.UpdateArtist(artist);
			}

			song.ArtistId = artist.ArtistId;
		}
		private void SaveGenreToDatabase(ref Song song, GenreStoreContext genreStore)
		{
			_logger.Info("Starting process to save the genre record of the song to the database");

			var genre = new Genre
			{
				GenreName = song.Genre,
				SongCount = 1
			};

			if (!genreStore.DoesGenreExist(song))
			{
				genreStore.SaveGenre(genre);
				genre = genreStore.GetGenre(song);
				var genreDump = $"Genre id {genre.GenreId} GenreName {genre.GenreName}" +
					$" Genre song Count {genre.SongCount}";
				Console.WriteLine(genreDump);
				_logger.Info(genreDump);
			}
			else
			{
				var genreRetrieved = genreStore.GetGenre(song);
				genre.GenreId = genreRetrieved.GenreId;
				genre.SongCount = genreRetrieved.SongCount + 1;

				genreStore.UpdateGenre(genre);
			}

			song.GenreId = genre.GenreId;
		}
		private void SaveYearToDatabase(ref Song song, YearStoreContext yearStore)
		{
			_logger.Info("Starting process to save the year record of the song to the database");

			var year = new Year
			{
				YearValue = song.Year.Value,
				SongCount = 1
			};

			if (!yearStore.DoesYearExist(song))
			{
				yearStore.SaveYear(year);
				year = yearStore.GetSongYear(song);
			}
			else
			{
				var yearRetrieved = yearStore.GetSongYear(song);
				year.YearId = yearRetrieved.YearId;
				year.SongCount = yearRetrieved.SongCount + 1;

				yearStore.UpdateYear(year);
			}

			song.YearId = year.YearId;
		}

		private Album UpdateAlbumInDatabase(Song oldSongRecord, Song newSongRecord, AlbumStoreContext albumStore)
		{
			var albumRecord = albumStore.GetAlbum(oldSongRecord);
			var oldAlbumTitle = oldSongRecord.AlbumTitle;
			var oldAlbumArtist = oldSongRecord.Artist;
			var newAlbumTitle = newSongRecord.AlbumTitle;
			var newAlbumArtist = newSongRecord.Artist;

			var info = string.Empty;

			if (string.IsNullOrEmpty(newAlbumArtist))
			{
				newAlbumArtist = oldAlbumArtist;
			}
			if (string.IsNullOrEmpty(newAlbumTitle))
			{
				newAlbumTitle = oldAlbumTitle;
			}

			if ((string.IsNullOrEmpty(newAlbumTitle) && string.IsNullOrEmpty(newAlbumArtist) || 
						oldAlbumTitle.Equals(newAlbumTitle) && oldAlbumArtist.Equals(newAlbumArtist)))
			{
				_logger.Info("No change to the song's album");
				return albumRecord;
			}

			info = "Change to the song's album";
			_logger.Info(info);

			if (albumRecord.SongCount > 1)
			{
				_logger.Info("Decrementing existing album's song count");

				albumRecord.SongCount -= 1;
				albumStore.UpdateAlbum(albumRecord);
			}
			else
			{
				_logger.Info("Deleting existing album record that no longer has any songs");

				albumStore.DeleteAlbum(albumRecord);
			}

			if (!albumStore.DoesAlbumExist(newSongRecord))
			{
				_logger.Info("Creating new album record");

				var newAlbumRecord = new Album
				{
					Title = newAlbumTitle,
					AlbumArtist = newAlbumArtist,
					SongCount = 1
				};

				albumStore.SaveAlbum(newAlbumRecord);
			}
			else
			{
				_logger.Info("Updating existing album record");

				var existingAlbumRecord = albumStore.GetAlbum(newSongRecord);
				existingAlbumRecord.AlbumArtist = newAlbumArtist;
				existingAlbumRecord.SongCount += 1;

				albumStore.UpdateAlbum(existingAlbumRecord);
			}

			return albumStore.GetAlbum(newSongRecord);
		}
		private Artist UpdateArtistInDatabase(Song oldSongRecord, Song newSongRecord, ArtistStoreContext artistStore)
		{
			var oldArtistRecord = artistStore.GetArtist(oldSongRecord);
			var oldArtistName = oldArtistRecord.Name;
			var newArtistName = newSongRecord.Artist;

			if (string.IsNullOrEmpty(newArtistName) || oldArtistName.Equals(newArtistName))
			{
				_logger.Info("No change to the song's Artist");
				return oldArtistRecord;
			}

			_logger.Info("Change to the song's record found");

			if (oldArtistRecord.SongCount > 1)
			{
				_logger.Info("Decrementing existing artist's song count");

				oldArtistRecord.SongCount -= 1;
				artistStore.UpdateArtist(oldArtistRecord);
			}
			else
			{
				_logger.Info("Deleting artist record that no longer has any songs");

				artistStore.DeleteArtist(oldArtistRecord);
			}

			if (!artistStore.DoesArtistExist(newSongRecord))
			{
				_logger.Info("Creating new artist record");

				var newArtistRecord = new Artist
				{
					Name = newArtistName,
					SongCount = 1
				};

				artistStore.SaveArtist(newArtistRecord);
			}
			else
			{
				_logger.Info("Updating existing artist record");

				var existingArtistRecord = artistStore.GetArtist(newSongRecord);
				existingArtistRecord.SongCount += 1;

				artistStore.UpdateArtist(existingArtistRecord);
			}

			return artistStore.GetArtist(newSongRecord);
		}
		private Genre UpdateGenreInDatabase(Song oldSongRecord, Song newSongRecord, GenreStoreContext genreStore)
		{
			var oldGenreRecord = genreStore.GetGenre(oldSongRecord);
			var oldGenreName = oldGenreRecord.GenreName;
			var newGenreName = newSongRecord.Genre;

			if (string.IsNullOrEmpty(newGenreName) || oldGenreName.Equals(newGenreName))
			{
				_logger.Info("No change to the song's Genre");
				return oldGenreRecord;
			}

			_logger.Info("Change to the song's genre found");

			if (oldGenreRecord.SongCount > 1)
			{
				_logger.Info("Decrementing exisiting genre song count");

				oldGenreRecord.SongCount -= 1;
				genreStore.UpdateGenre(oldGenreRecord);
			}
			else
			{
				_logger.Info("Deleting genre record");

				genreStore.DeleteGenre(oldGenreRecord);
			}

			if (!genreStore.DoesGenreExist(newSongRecord))
			{
				_logger.Info("Creating new genre record");

				var newGenreRecord = new Genre
				{
					GenreName = newGenreName,
					SongCount = 1
				};

				genreStore.SaveGenre(newGenreRecord);
			}
			else
			{
				_logger.Info("Updating existing genre record");

				var existingGenreRecord = genreStore.GetGenre(newSongRecord);
				existingGenreRecord.SongCount += 1;

				genreStore.UpdateGenre(existingGenreRecord);
			}

			return genreStore.GetGenre(newSongRecord);

		}
		private Year UpdateYearInDatabase(Song oldSongRecord, Song newSongRecord, YearStoreContext yearStore)
		{
			var oldYearRecord = yearStore.GetSongYear(oldSongRecord);
			var oldYearValue = oldYearRecord.YearValue;
			var newYearValue = newSongRecord.Year;

			if (oldYearValue == newYearValue || newYearValue == 0 || newYearValue == null)
			{
				_logger.Info("No change to the song's Year");
				return oldYearRecord;
			}

			_logger.Info("Change to the song's year found");

			if (oldYearRecord.SongCount > 1)
			{
				_logger.Info("Decrementing song count of year record");

				oldYearRecord.SongCount -= 1;
				yearStore.UpdateYear(oldYearRecord);
			}
			else
			{
				_logger.Info("Deleting year record");

				yearStore.DeleteYear(oldYearRecord);
			}

			if(!yearStore.DoesYearExist(newSongRecord))
			{
				_logger.Info("Creating new year record");

				var newYearRecord = new Year
				{
					YearValue = newYearValue.Value,
					SongCount = 1
				};

				yearStore.SaveYear(newYearRecord);
			}
			else
			{
				_logger.Info("Updating existing year record");

				var existingYearRecord = yearStore.GetSongYear(newSongRecord);
				existingYearRecord.SongCount += 1;

				yearStore.UpdateYear(existingYearRecord);
			}

			return yearStore.GetSongYear(newSongRecord);
		}
		private void UpdateSongInDatabase(Song oldSongRecord, Song newSongRecord, MusicStoreContext songStore)
		{
			var updatedSongRecord = oldSongRecord;

			if (!SongRecordChanged(updatedSongRecord, newSongRecord))
			{
				_logger.Info("No change to the song record");
				return;
			}

			_logger.Info("Changes to song record found");
			Console.WriteLine($"Song id {updatedSongRecord.Id}");
			Console.WriteLine("Before updated song values");

			MetadataRetriever.PrintMetadata(updatedSongRecord);

			if (!string.IsNullOrEmpty(newSongRecord.Title))
			{
				updatedSongRecord.Title = newSongRecord.Title;
			}
			if (!string.IsNullOrEmpty(newSongRecord.AlbumTitle))
			{
				updatedSongRecord.AlbumTitle = newSongRecord.AlbumTitle;
			}
			if (!string.IsNullOrEmpty(newSongRecord.Artist))
			{
				updatedSongRecord.Artist = newSongRecord.Artist;
			}
			if (!string.IsNullOrEmpty(newSongRecord.Genre))
			{
				updatedSongRecord.Genre = newSongRecord.Genre;
			}
			if (newSongRecord.Year != null || newSongRecord.Year > 0)
			{
				updatedSongRecord.Year = newSongRecord.Year;
			}

			_logger.Info("Applied changes to song record");

			Console.WriteLine("Updated song values\n");
			MetadataRetriever.PrintMetadata(updatedSongRecord);

			if (songStore.DoesSongExist(newSongRecord))
			{
				songStore.UpdateSong(updatedSongRecord);
			}
			else
			{
				songStore.SaveSong(updatedSongRecord);
			}
		}

        	private async Task PopulateSongDetails()
        	{
            		foreach (DataRow row in _results.Rows)
            		{
                		Song song = new Song();
                		foreach (DataColumn col in _results.Columns)
                		{
                    			string colStr = col.ToString().ToUpper();
                    			switch (colStr)
                    			{
                        			case "ID":
                            				song.Id = Int32.Parse(row[col].ToString());
                            				break;
                        			case "TITLE":
                            				song.Title = row[col].ToString();
                            				break;
                        			case "ALBUM":
                            				song.AlbumTitle = row[col].ToString();
                            				break;
                        			case "ARTIST":
                            				song.Artist = row[col].ToString();
                            				break;
                        			case "YEAR":
                            				song.Year = Int32.Parse(row[col].ToString());
                            				break;
                        			case "GENRE":
                            				song.Genre = row[col].ToString();
                            				break;
                        			case "DURATION":
                            				song.Duration = Int32.Parse(row[col].ToString());
                            				break;
                        			case "FILENAME":
                            				song.Filename = row[col].ToString();
                            				break;
                        			case "SONGPATH":
                            				song.SongPath = row[col].ToString();
                            			break;
                    			}
                		}
                		_songs.Add(song);
            		}
        	}
        	#endregion	
    	}
}