using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text.RegularExpressions;
using DataLayer;
using Dinah.Core;
using LibationFileManager;
using Lucene.Net.Analysis.Standard;
using Lucene.Net.Analysis.Tokenattributes;
using Lucene.Net.Documents;
using Lucene.Net.Index;
using Lucene.Net.Search;
using Lucene.Net.Store;

namespace LibationSearchEngine
{
    public class SearchEngine
    {
        public const Lucene.Net.Util.Version Version = Lucene.Net.Util.Version.LUCENE_30;

        public const string _ID_ = "_ID_";
        public const string TAGS = "tags";
        // special field for each book which includes all major parts of the book's metadata. enables non-targetting searching
        public const string ALL = "all";

        #region index rules
        // common fields used in the "all" default search field
        public const string ALL_AUDIBLE_PRODUCT_ID = nameof(Book.AudibleProductId);
        public const string ALL_TITLE = nameof(Book.Title);
        public const string ALL_AUTHOR_NAMES = "AuthorNames";
        public const string ALL_NARRATOR_NAMES = "NarratorNames";
        public const string ALL_SERIES_NAMES = "SeriesNames";

        internal static ReadOnlyDictionary<string, Func<LibraryBook, string>> idIndexRules { get; }
            = new ReadOnlyDictionary<string, Func<LibraryBook, string>>(
                new Dictionary<string, Func<LibraryBook, string>>
                {
                    [nameof(Book.AudibleProductId)] = lb => lb.Book.AudibleProductId.ToLowerInvariant(),
                    ["ProductId"] = lb => lb.Book.AudibleProductId.ToLowerInvariant(),
                    ["Id"] = lb => lb.Book.AudibleProductId.ToLowerInvariant(),
                    ["ASIN"] = lb => lb.Book.AudibleProductId.ToLowerInvariant()
				}
                );

		internal static ReadOnlyDictionary<string, Func<LibraryBook, string>> stringIndexRules { get; }
            = new ReadOnlyDictionary<string, Func<LibraryBook, string>>(
                new Dictionary<string, Func<LibraryBook, string>>
                {
                    [nameof(Book.Title)] = lb => lb.Book.Title,
                    [ALL_AUTHOR_NAMES] = lb => lb.Book.AuthorNames(),
                    ["Author"] = lb => lb.Book.AuthorNames(),
                    ["Authors"] = lb => lb.Book.AuthorNames(),
                    [ALL_NARRATOR_NAMES] = lb => lb.Book.NarratorNames(),
                    ["Narrator"] = lb => lb.Book.NarratorNames(),
                    ["Narrators"] = lb => lb.Book.NarratorNames(),
                    [nameof(Book.Publisher)] = lb => lb.Book.Publisher,

                    [ALL_SERIES_NAMES] = lb => lb.Book.SeriesNames(),
                    ["Series"] = lb => lb.Book.SeriesNames(),
                    ["SeriesId"] = lb => string.Join(", ", lb.Book.SeriesLink.Select(s => s.Series.AudibleSeriesId)),

                    ["CategoriesNames"] = lb => lb.Book.CategoriesIds() is null ? null : string.Join(", ", lb.Book.CategoriesIds()),
                    [nameof(Book.Category)] = lb => lb.Book.CategoriesIds() is null ? null : string.Join(", ", lb.Book.CategoriesIds()),
                    ["Categories"] = lb => lb.Book.CategoriesIds() is null ? null : string.Join(", ", lb.Book.CategoriesIds()),
                    ["CategoriesId"] = lb => lb.Book.CategoriesIds() is null ? null : string.Join(", ", lb.Book.CategoriesIds()),
                    ["CategoryId"] = lb => lb.Book.CategoriesIds() is null ? null : string.Join(", ", lb.Book.CategoriesIds()),

                    [TAGS.FirstCharToUpper()] = lb => lb.Book.UserDefinedItem.Tags,

                    ["Locale"] = lb => lb.Book.Locale,
                    ["Region"] = lb => lb.Book.Locale,
                    ["Account"] = lb => lb.Account,
                    ["Email"] = lb => lb.Account
                }
                );

		internal static ReadOnlyDictionary<string, Func<LibraryBook, string>> numberIndexRules { get; }
            = new ReadOnlyDictionary<string, Func<LibraryBook, string>>(
                new Dictionary<string, Func<LibraryBook, string>>
                {
                    // for now, all numbers are padded to 8 char.s
                    // This will allow a single method to auto-pad numbers. The method will match these as well as date: yyyymmdd
                    [nameof(Book.LengthInMinutes)] = lb => lb.Book.LengthInMinutes.ToLuceneString(),
                    ["Length"] = lb => lb.Book.LengthInMinutes.ToLuceneString(),
                    ["Minutes"] = lb => lb.Book.LengthInMinutes.ToLuceneString(),
                    ["Hours"] = lb => (lb.Book.LengthInMinutes / 60).ToLuceneString(),

                    ["ProductRating"] = lb => lb.Book.Rating.OverallRating.ToLuceneString(),
                    ["Rating"] = lb => lb.Book.Rating.OverallRating.ToLuceneString(),
                    ["UserRating"] = lb => userOverallRating(lb.Book),
                    ["MyRating"] = lb => userOverallRating(lb.Book),

                    [nameof(LibraryBook.DateAdded)] = lb => lb.DateAdded.ToLuceneString(),
                    [nameof(Book.DatePublished)] = lb => lb.Book.DatePublished?.ToLuceneString() ?? "",

                    ["LastDownload"] = lb => lb.Book.UserDefinedItem.LastDownloaded.ToLuceneString(),
                    ["LastDownloaded"] = lb => lb.Book.UserDefinedItem.LastDownloaded.ToLuceneString()
                }
                );

        internal static ReadOnlyDictionary<string, Func<LibraryBook, bool>> boolIndexRules { get; }
            = new ReadOnlyDictionary<string, Func<LibraryBook, bool>>(
                new Dictionary<string, Func<LibraryBook, bool>>
                {
                    ["HasDownloads"] = lb => lb.Book.HasPdf(),
                    ["HasDownload"] = lb => lb.Book.HasPdf(),
                    ["Downloads"] = lb => lb.Book.HasPdf(),
                    ["Download"] = lb => lb.Book.HasPdf(),
                    ["HasPDFs"] = lb => lb.Book.HasPdf(),
                    ["HasPDF"] = lb => lb.Book.HasPdf(),
                    ["PDFs"] = lb => lb.Book.HasPdf(),
                    ["PDF"] = lb => lb.Book.HasPdf(),

                    ["IsRated"] = lb => lb.Book.UserDefinedItem.Rating.OverallRating > 0f,
                    ["Rated"] = lb => lb.Book.UserDefinedItem.Rating.OverallRating > 0f,

                    ["IsAuthorNarrated"] = isAuthorNarrated,
                    ["AuthorNarrated"] = isAuthorNarrated,

                    [nameof(Book.IsAbridged)] = lb => lb.Book.IsAbridged,
                    ["Abridged"] = lb => lb.Book.IsAbridged,

                    ["IsLiberated"] = lb => isLiberated(lb.Book),
                    ["Liberated"] = lb => isLiberated(lb.Book),
                    ["LiberatedError"] = lb => liberatedError(lb.Book),

                    ["Podcast"] = lb => lb.Book.IsEpisodeChild(),
                    ["Podcasts"] = lb => lb.Book.IsEpisodeChild(),
                    ["IsPodcast"] = lb => lb.Book.IsEpisodeChild(),
                    ["Episode"] = lb => lb.Book.IsEpisodeChild(),
                    ["Episodes"] = lb => lb.Book.IsEpisodeChild(),
                    ["IsEpisode"] = lb => lb.Book.IsEpisodeChild(),

                    ["Absent"] = lb => lb.AbsentFromLastScan,
                    ["AbsentFromLastScan"] = lb => lb.AbsentFromLastScan,
                }
                );

        private static bool isAuthorNarrated(LibraryBook lb)
        {
            var authors = lb.Book.Authors.Select(a => a.Name).ToArray();
            var narrators = lb.Book.Narrators.Select(a => a.Name).ToArray();
            return authors.Intersect(narrators).Any();
        }
        private static string userOverallRating(Book book) => book.UserDefinedItem.Rating.OverallRating.ToLuceneString();
        private static bool isLiberated(Book book) => book.UserDefinedItem.BookStatus == LiberatedStatus.Liberated;
        private static bool liberatedError(Book book) => book.UserDefinedItem.BookStatus == LiberatedStatus.Error;

        // use these common fields in the "all" default search field
        private static IEnumerable<Func<LibraryBook, string>> allFieldIndexRules { get; }
            = new List<Func<LibraryBook, string>>
            {
                idIndexRules[ALL_AUDIBLE_PRODUCT_ID],
                stringIndexRules[ALL_TITLE],
                stringIndexRules[ALL_AUTHOR_NAMES],
                stringIndexRules[ALL_NARRATOR_NAMES],
                stringIndexRules[ALL_SERIES_NAMES]
            };
        #endregion

        #region get search fields. used for display in help
        public static IEnumerable<string> GetSearchIdFields()
        {
            foreach (var key in idIndexRules.Keys)
                yield return key;
        }

        public static IEnumerable<string> GetSearchStringFields()
        {
            foreach (var key in stringIndexRules.Keys)
                yield return key;
        }

        public static IEnumerable<string> GetSearchBoolFields()
        {
            foreach (var key in boolIndexRules.Keys)
                yield return key;
        }

        public static IEnumerable<string> GetSearchNumberFields()
        {
            foreach (var key in numberIndexRules.Keys)
                yield return key;
        }
        #endregion

        #region create and update index
        /// <summary>create new. ie: full re-index</summary>
        public void CreateNewIndex(IEnumerable<LibraryBook> library, bool overwrite = true)
        {
            // location of index/create the index
            using var index = getIndex();
            var exists = IndexReader.IndexExists(index);
            var createNewIndex = overwrite || !exists;

            // analyzer for tokenizing text. same analyzer should be used for indexing and searching
            using var analyzer = new StandardAnalyzer(Version);
            using var ixWriter = new IndexWriter(index, analyzer, createNewIndex, IndexWriter.MaxFieldLength.UNLIMITED);
            foreach (var libraryBook in library)
            {
                var doc = createBookIndexDocument(libraryBook);
                ixWriter.AddDocument(doc);
            }
        }

        /// <summary>Long running. Use await Task.Run(() => UpdateBook(productId))</summary>
        public void UpdateBook(LibationContext context, string productId)
        {
            var libraryBook = context.GetLibraryBook_Flat_NoTracking(productId);
            var term = new Term(_ID_, productId);

            var document = createBookIndexDocument(libraryBook);
            var createNewIndex = false;

            using var index = getIndex();
            using var analyzer = new StandardAnalyzer(Version);
            using var ixWriter = new IndexWriter(index, analyzer, createNewIndex, IndexWriter.MaxFieldLength.UNLIMITED);
            ixWriter.DeleteDocuments(term);
            ixWriter.AddDocument(document);
        }

        private static Document createBookIndexDocument(LibraryBook libraryBook)
        {
            var doc = new Document();

            // refine with
            // http://codeclimber.net.nz/archive/2009/09/10/how-subtext-lucenenet-index-is-structured/

            // fields are key value pairs and MULTIPLE FIELDS CAN HAVE THE SAME KEY.
            // splitting authors and narrators and/or tags into multiple fields could be interesting research.
            // it could allow for more advanced searches, or maybe it could break broad searches.

            // all searching should be lowercase
            // external callers have the reasonable expectation that product id will be returned CASE SPECIFIC
            doc.AddRaw(_ID_, libraryBook.Book.AudibleProductId);

            // concat all common fields for the default 'all' field
            var allConcat =
                allFieldIndexRules
                .Select(rule => rule(libraryBook))
                .Aggregate((a, b) => $"{a} {b}");
            doc.AddAnalyzed(ALL, allConcat);

            foreach (var kvp in idIndexRules)
                doc.AddNotAnalyzed(kvp.Key, kvp.Value(libraryBook));

            foreach (var kvp in stringIndexRules)
                doc.AddAnalyzed(kvp.Key, kvp.Value(libraryBook));

            foreach (var kvp in boolIndexRules)
                doc.AddBool(kvp.Key, kvp.Value(libraryBook));

            foreach (var kvp in numberIndexRules)
                doc.AddNotAnalyzed(kvp.Key, kvp.Value(libraryBook));

            return doc;
        }

        // update single document entry
        // all fields, including 'tags' are case-specific
        public void UpdateTags(string productId, string tags) => updateAnalyzedField(productId, TAGS, tags);

        // all fields are case-specific
        private static void updateAnalyzedField(string productId, string fieldName, string newValue)
            => updateDocument(
                productId,
                d =>
                {
                    // fields are key value pairs. MULTIPLE FIELDS CAN POTENTIALLY HAVE THE SAME KEY.
                    // ie: must remove old before adding new else will create unwanted duplicates.
                    d.RemoveField(fieldName.ToLower());
                    d.AddAnalyzed(fieldName, newValue);
                });

        // update single document entry
        public void UpdateLiberatedStatus(Book book)
            => updateDocument(
                book.AudibleProductId,
                d =>
                {
                    //
                    // TODO: better synonym handling. This is too easy to mess up
                    //

                    // fields are key value pairs. MULTIPLE FIELDS CAN POTENTIALLY HAVE THE SAME KEY.
                    // ie: must remove old before adding new else will create unwanted duplicates.
                    var v1 = isLiberated(book);
                    d.RemoveField("isliberated");
                    d.AddBool("IsLiberated", v1);
                    d.RemoveField("liberated");
                    d.AddBool("Liberated", v1);

                    var v2 = liberatedError(book);
                    d.RemoveField("liberatederror");
                    d.AddBool("LiberatedError", v2);

                    var v3 = book.UserDefinedItem.LastDownloaded?.ToLuceneString() ?? "";
					d.RemoveField("LastDownload");
					d.AddNotAnalyzed("LastDownload", v3);
					d.RemoveField("LastDownloaded");
					d.AddNotAnalyzed("LastDownloaded", v3);
				});

        public void UpdateUserRatings(Book book)
            =>updateDocument(
                book.AudibleProductId,
                d =>
                {
                    //
                    // TODO: better synonym handling. This is too easy to mess up
                    //

                    // fields are key value pairs. MULTIPLE FIELDS CAN POTENTIALLY HAVE THE SAME KEY.
                    // ie: must remove old before adding new else will create unwanted duplicates.
                    var v1 = userOverallRating(book);
                    d.RemoveField("userrating");
                    d.AddNotAnalyzed("UserRating", v1);
                    d.RemoveField("myrating");
                    d.AddNotAnalyzed("MyRating", v1);
                });

        private static void updateDocument(string productId, Action<Document> action)
        {
            var productTerm = new Term(_ID_, productId);

            using var index = getIndex();

            // get existing document
            using var searcher = new IndexSearcher(index);
            var query = new TermQuery(productTerm);
            var docs = searcher.Search(query, 1);
            var scoreDoc = docs.ScoreDocs.SingleOrDefault();
            if (scoreDoc is null)
                return;
            var document = searcher.Doc(scoreDoc.Doc);


            // perform update
            action(document);


            // update index
            var createNewIndex = false;
            using var analyzer = new StandardAnalyzer(Version);
            using var ixWriter = new IndexWriter(index, analyzer, createNewIndex, IndexWriter.MaxFieldLength.UNLIMITED);
            ixWriter.UpdateDocument(productTerm, document, analyzer);
        }
        #endregion

        // the workaround which allows displaying all books when query is empty
        public const string ALL_QUERY = "*:*";

        #region search
        public SearchResultSet Search(string searchString)
		{
			using var analyzer = new StandardAnalyzer(Lucene.Net.Util.Version.LUCENE_30);

			Serilog.Log.Logger.Debug("original search string: {@DebugInfo}", new { searchString });
            searchString = QuerySanitizer.Sanitize(searchString, analyzer);
            Serilog.Log.Logger.Debug("formatted search string: {@DebugInfo}", new { searchString });

            var results = generalSearch(searchString, analyzer);
            Serilog.Log.Logger.Debug("Hit(s): {@DebugInfo}", new { count = results.Docs.Count() });
            displayResults(results);

            return results;
        }

        private SearchResultSet generalSearch(string searchString, StandardAnalyzer analyzer)
        {
            var defaultField = ALL;

            using var index = getIndex();
            using var searcher = new IndexSearcher(index);
			var query = analyzer.GetQuery(defaultField, searchString);

			// lucene doesn't allow only negations. eg this returns nothing:
			//     -tags:hidden
			// work arounds: https://kb.ucla.edu/articles/pure-negation-query-in-lucene
			// HOWEVER, doing this to any other type of query can cause EVERYTHING to be a match unless "Occur" is carefully set
			// this should really check that all leaf nodes are MUST_NOT
			if (query is BooleanQuery boolQuery)
            {
                var occurs = getOccurs_recurs(boolQuery);
                if (occurs.Any() && occurs.All(o => o == Occur.MUST_NOT))
                    boolQuery.Add(new MatchAllDocsQuery(), Occur.MUST);
            }

            var docs = searcher
                .Search(query, searcher.MaxDoc + 1)
                .ScoreDocs
                .Select(ds => new ScoreDocExplicit(searcher.Doc(ds.Doc), ds.Score))
                .ToList();
            var queryString = query.ToString();
            Serilog.Log.Logger.Debug("query: {@DebugInfo}", new { queryString });
            return new SearchResultSet(queryString, docs);
        }

        private IEnumerable<Occur> getOccurs_recurs(BooleanQuery query)
        {
            var returnList = new List<Occur>();

            foreach (var clause in query)
            {
                returnList.Add(clause.Occur);

                if (clause.Query is BooleanQuery boolQuery)
                    returnList.AddRange(getOccurs_recurs(boolQuery));
            }

            return returnList;
        }

        private void displayResults(SearchResultSet docs)
        {
            //for (int i = 0; i < docs.Docs.Count(); i++)
            //{
            //    var sde = docs.Docs.First();

            //    Document doc = sde.Doc;
            //    float score = sde.Score;

            //    Serilog.Log.Logger.Debug($"{(i + 1)}) score={score}. Fields:");
            //    var allFields = doc.GetFields();
            //    foreach (var f in allFields)
            //        Serilog.Log.Logger.Debug($"   [{f.Name}]={f.StringValue}");
            //}
        }
        #endregion

        private static Directory getIndex() => FSDirectory.Open(SearchEngineDirectory);

        // not customizable. don't move to config
        private static string SearchEngineDirectory { get; }
            = new System.IO.DirectoryInfo(Configuration.Instance.LibationFiles).CreateSubdirectory("SearchEngine").FullName;
    }
}