// Copyright (c) ppy Pty Ltd <contact@ppy.sh>. Licensed under the MIT Licence.
// See the LICENCE file in the repository root for full licence text.

using System;
using System.IO;
using System.Linq;
using osu.Framework.Allocation;
using osu.Framework.Logging;
using osu.Framework.Platform;
using osu.Framework.Platform.Windows;
using osu.Game.Beatmaps;
using osu.Game.Beatmaps.Legacy;
using osu.Game.Online.API;
using osu.Game.Online.API.Requests;
using osu.Game.Rulesets;
using osu.Game.Tournament.Models;

namespace osu.Game.Tournament.IPC
{
    public class FileBasedIPC : MatchIPCInfo
    {
        [Resolved]
        protected IAPIProvider API { get; private set; }

        [Resolved]
        protected RulesetStore Rulesets { get; private set; }

        private int lastBeatmapId;

        [BackgroundDependencyLoader]
        private void load(LadderInfo ladder, GameHost host)
        {
            StableStorage stable;

            try
            {
                stable = new StableStorage(host as DesktopGameHost);
            }
            catch (Exception e)
            {
                Logger.Error(e, "Stable installation could not be found; disabling file based IPC");
                return;
            }

            const string file_ipc_filename = "ipc.txt";
            const string file_ipc_state_filename = "ipc-state.txt";
            const string file_ipc_scores_filename = "ipc-scores.txt";
            const string file_ipc_channel_filename = "ipc-channel.txt";

            if (stable.Exists(file_ipc_filename))
                Scheduler.AddDelayed(delegate
                {
                    try
                    {
                        using (var stream = stable.GetStream(file_ipc_filename))
                        using (var sr = new StreamReader(stream))
                        {
                            var beatmapId = int.Parse(sr.ReadLine());
                            var mods = int.Parse(sr.ReadLine());

                            if (lastBeatmapId != beatmapId)
                            {
                                lastBeatmapId = beatmapId;

                                var existing = ladder.CurrentMatch.Value?.Round.Value?.Beatmaps.FirstOrDefault(b => b.ID == beatmapId && b.BeatmapInfo != null);

                                if (existing != null)
                                    Beatmap.Value = existing.BeatmapInfo;
                                else
                                {
                                    var req = new GetBeatmapRequest(new BeatmapInfo { OnlineBeatmapID = beatmapId });
                                    req.Success += b => Beatmap.Value = b.ToBeatmap(Rulesets);
                                    API.Queue(req);
                                }
                            }

                            Mods.Value = (LegacyMods)mods;
                        }
                    }
                    catch
                    {
                        // file might be in use.
                    }

                    try
                    {
                        using (var stream = stable.GetStream(file_ipc_channel_filename))
                        using (var sr = new StreamReader(stream))
                        {
                            ChatChannel.Value = sr.ReadLine();
                        }
                    }
                    catch (Exception)
                    {
                        // file might be in use.
                    }

                    try
                    {
                        using (var stream = stable.GetStream(file_ipc_state_filename))
                        using (var sr = new StreamReader(stream))
                        {
                            State.Value = (TourneyState)Enum.Parse(typeof(TourneyState), sr.ReadLine());
                        }
                    }
                    catch (Exception)
                    {
                        // file might be in use.
                    }

                    try
                    {
                        using (var stream = stable.GetStream(file_ipc_scores_filename))
                        using (var sr = new StreamReader(stream))
                        {
                            Score1.Value = int.Parse(sr.ReadLine());
                            Score2.Value = int.Parse(sr.ReadLine());
                        }
                    }
                    catch (Exception)
                    {
                        // file might be in use.
                    }
                }, 250, true);
        }

        /// <summary>
        /// A method of accessing an osu-stable install in a controlled fashion.
        /// </summary>
        private class StableStorage : WindowsStorage
        {
            protected override string LocateBasePath()
            {
                bool checkExists(string p)
                {
                    return File.Exists(Path.Combine(p, "ipc.txt"));
                }

                string stableInstallPath = string.Empty;

                try
                {
                    try
                    {
                        stableInstallPath = "G:\\My Drive\\Main\\osu!tourney";

                        if (checkExists(stableInstallPath))
                            return stableInstallPath;

                        stableInstallPath = "G:\\My Drive\\Main\\osu!mappool";

                        if (checkExists(stableInstallPath))
                            return stableInstallPath;
                    }
                    catch
                    {
                    }

                    stableInstallPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), @"osu!");
                    if (checkExists(stableInstallPath))
                        return stableInstallPath;

                    stableInstallPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.UserProfile), ".osu");
                    if (checkExists(stableInstallPath))
                        return stableInstallPath;

                    return null;
                }
                finally
                {
                    Logger.Log($"Stable path for tourney usage: {stableInstallPath}");
                }
            }

            public StableStorage(DesktopGameHost host)
                : base(string.Empty, host)
            {
            }
        }
    }
}