MafiaTelegramBot/MafiaTelegramBot/Game/GameRooms/GameRoom.GameProcess.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using MafiaTelegramBot.Controllers;
using MafiaTelegramBot.CustomCollections.Extensions;
using MafiaTelegramBot.DataBase.EntityDao;
using MafiaTelegramBot.Game.GameRoles;
using MafiaTelegramBot.Models;
using MafiaTelegramBot.Resources;
using Org.BouncyCastle.Utilities;
using Telegram.Bot.Types;
using Timer = System.Timers.Timer;

namespace MafiaTelegramBot.Game.GameRooms
{
    public partial class GameRoom
    {
        public void Start()
        {
            new Task(async () =>
            {
                IsRunning = true;
                await FirstNight();
                await FirstDay();
                await GameCycle();
                await EndOfGame();
            }).Start();
        }

        private async Task FirstDay()
        {
            IsDay = true;
            await PlayersCh.Send(strings.first_day_message);
            await Task.Run(async() =>
            {
                var turnsCount = _turnOrder.Count;
                Player firstPlayer = null;
                for (var i = 0; i < turnsCount; ++i)
                {
                    var player = _turnOrder.Dequeue();
                    if(!player.IsPlaying) continue;
                    await player.CurrentRole.DayAction();
                    if (firstPlayer != null && player.IsPlaying) _turnOrder.Enqueue(player);
                    else firstPlayer = player;
                }
                _turnOrder.Enqueue(firstPlayer);
            });
            IsFirstCycle = false;
            await PlayersCh.Send(strings.city_falls_asleep);
        }

        private async Task FirstNight()
        {
            IsFirstCycle = true;
            await Task.Run(async() =>
            {
                await PlayersCh.Send(strings.city_falls_asleep);
                var mafia = Players.Values.Where(player => player.GetRole() is Roles.Mafia).ToArray();
                var don = Players.Values.FirstOrDefault(player => player.GetRole() is Roles.Don);
                var message = strings.your_teammates;
                if (don != null) message += $" \\({don.TurnOrder}\\) {don.NickName} - {roles.Don}";
                message = mafia.Aggregate(message, (current, player) => current + $" \\({player.TurnOrder}\\) {player.NickName}");
                await MafiaCh.Send(message);
                var resetEvent = new ManualResetEvent(false);
                var timer = new Timer
                {
                    AutoReset = false,
                    Interval = 10 * 1000
                };
                timer.Elapsed += (_, _) => resetEvent.Set();
                timer.Start();
                foreach (var player in Players.Values)
                {
                    player.CurrentRole.KnownRoles.Add(player);
                    if(player.GetRole() is Roles.Don or Roles.Mafia) player.CurrentRole.KnownRoles.AddRange(
                        Players.Values.Where(p=> player.Id != p.Id && p.GetRole() is Roles.Mafia or Roles.Don)
                    );
                }
                resetEvent.WaitOne();
            });
        }

        private async Task GameCycle()
        {
            await Task.Run(async () =>
            {
                var alivePlayers = Players.Values.Where(p => p.IsAlive).ToList();
                var aliveMafia = alivePlayers.Where(p => p.GetRole() is Roles.Don or Roles.Mafia).ToList();
                var gameNotEnded = alivePlayers.Count > 2 * aliveMafia.Count && aliveMafia.Count > 0;
                while (gameNotEnded)
                {
                    IsDay = false;
                    await NightPhase();
                    await SummingUpPhase();
                    IsDay = true;
                    await DayPhase();
                    await DefencePhase();
                    await DispatchPhase();
                }
            });
        }

        private async Task DayPhase()
        {
            var turnsCount = _turnOrder.Count;
            Player firstPlayer = null;
            for (var i = 0; i < turnsCount; ++i)
            {
                var player = _turnOrder.Dequeue();
                if(!player.IsPlaying) continue;
                if (firstPlayer == null) player.IsFirst = true;
                await player.CurrentRole.DayAction();
                if (player.IsFirst) firstPlayer = player;
                else _turnOrder.Enqueue(player);
            }
            firstPlayer!.IsFirst = false;
            _turnOrder.Enqueue(firstPlayer);
        }

        private async Task NightPhase()
        {
            await Task.Run(async () =>
            {
                var resetEvent = new ManualResetEvent(false);
                var timer = new Timer{ Interval = 60*1000, AutoReset = false };
                foreach (var player in Players.Values.Where(p=>p.IsAlive))
                {
                    await player.CurrentRole.NightAction();
                }
                timer.Elapsed += (_, _) => resetEvent.Set();
                timer.Start();
                resetEvent.WaitOne();
            });
        }

        private async Task SummingUpPhase()
        {
            await Task.Run(async () =>
            {
                //TODO order of applying with priorities
                foreach (var player in Players.Values.Where(p=>p.IsAlive))
                {
                    await player.CurrentRole.ApplyNightActionResult();
                }
            });
        }

        private async Task DefencePhase()
        {
            await Task.Run( () =>
            {
                
            });
        }

        private async Task DispatchPhase()
        {
            await Task.Run( () =>
            {
                
            });
        }

        public async Task<Message> PutUpVote(long playerId, long targetId)
        {
            var player = await UserDao.GetPlayerById(playerId);
            VoteUpList.AddUnique(Players[targetId]);
            if (playerId != targetId)
            {
                var target = await UserDao.GetPlayerById(targetId);
                await PlayersCh.SendExcept(player.ChatId, $"{player.NickName} {strings.vote_to} {target.NickName}");
                return await Bot.SendWithMarkdown2(player.ChatId, $"{strings.you_vote_player} {target.NickName}");
            }
            await PlayersCh.SendExcept(player.ChatId, $"{player.NickName} {strings.vote_to_self}");
            return await Bot.SendWithMarkdown2(player.ChatId, strings.you_vote_to_self);
        }

        private async Task EndOfGame()
        {
            await Task.Run(async () =>
            {
                foreach (var (_, player) in Players)
                {
                    player.CurrentRole = new NoneRole();
                    player.IsPlaying = false;
                    player.IsSpeaker = false;
                    player.IsAlive = true;
                }
                IsRunning = false;
                IsDay = false;
                _turnOrder.Clear();
                if (!Players.ContainsKey(Owner.Id) || Players.Count == 0) new Task(async() => 
                    await RoomController.DissolveRoom(RoomEncrypter.GetCode(RoomName))).Start();
                else
                {
                    await Bot.SendWithMarkdown2(Owner.ChatId, strings.thanks_for_game, Keyboards.OwnerGameMenu);
                    await PlayersCh.SendExcept(Owner.Id, strings.thanks_for_game, Keyboards.PlayerGameMenu);
                }
            });
        }
    }
}