421304936

Build Type

github

Committed by GitHub

Commit Message

Merge d33d59f90 into 4d358de9f

Pull Request Pull Request #938: Fix 919 game restart via text game

Run Details

4445 of 7170 branches covered (61.99%)

Branch coverage included in aggregate %.

34 of 39 new or added lines in 4 files covered. (87.18%)

1 existing line in 1 file now uncovered.

6550 of 8776 relevant lines covered (74.64%)

993452.74 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

72.31

/Zilon.Core/Zilon.Core/Tactics/Behaviour/HumanActorTaskSource.cs

﻿using System;
using System.Threading;
using System.Threading.Tasks;

using Zilon.Core.Common;
using Zilon.Core.PersonModules;

namespace Zilon.Core.Tactics.Behaviour
{
    public sealed class HumanActorTaskSource<TContext> : IDisposable, IHumanActorTaskSource<TContext>
        where TContext : ISectorTaskSourceContext
    {
        private readonly IReceiver<IActorTask> _actorTaskReceiver;
        private readonly ISender<IActorTask> _actorTaskSender;
        private readonly SpscChannel<IActorTask> _spscChannel;
        private CancellationTokenSource _cancellationTokenSource;
        private IActor _currentActorIntention;
        private bool _intentionWait;

        public HumanActorTaskSource()
        {
            _spscChannel = new SpscChannel<IActorTask>();
            _actorTaskSender = _spscChannel;
            _actorTaskReceiver = _spscChannel;
            _cancellationTokenSource = new CancellationTokenSource();
        }

        public void Dispose()
        {
            _spscChannel.Dispose();
            _cancellationTokenSource.Dispose();
        }

        private bool CurrentActorSetAndIsDead()
        {
            return (_currentActorIntention?.Person?.GetModuleSafe<ISurvivalModule>()?.IsDead).GetValueOrDefault();
        }

        public async Task IntentAsync(IIntention intention, IActor activeActor)
        {
            if (_intentionWait)
            {
                // Это может происходить, если в клиентском коде предварительно не выполнили проверку CanIntent().
                // Проверка нужна, чтобы не допустить получение очереди задач.
                // Текущая реализация не допускает переопределение задач.
                // Поэтому каждое новое намерение будет складывать по новой задаче в очередь, пока выполняется текущая задача
                // Текущая задача выполняется в основном игровом цикле, который накручивает счётчик итераций, чтобы выполнить предусловия задачи.
                throw new InvalidOperationException(
                    "Попытка задать новое намерение, пока не выполнена текущая задача.");
            }

            var currentIntention = intention ?? throw new ArgumentNullException(nameof(intention));

            var actorTask = currentIntention.CreateActorTask(activeActor);

            _intentionWait = true;
            _currentActorIntention = activeActor;

            await _actorTaskSender.SendAsync(actorTask, _cancellationTokenSource.Token).ConfigureAwait(false);
        }

        public async Task<IActorTask> GetActorTaskAsync(IActor actor, TContext context)
        {
            // Тезисы:
            // Этот источник команд ждёт, пока игрок не укажет задачу.
            // Задача генерируется из намерения. Это значит, что ждать нужно, пока не будет задано намерение.

            return await _actorTaskReceiver.ReceiveAsync(_cancellationTokenSource.Token).ConfigureAwait(false);
        }

        //TODO Избавиться от синхронного варианта.
        // Сейчас он оставлен прото из-за тестов. Сложностей с удалением нет, кроме рутины.
        [Obsolete("Использовать асинк-вариант вместо этого")]
        public void Intent(IIntention intention, IActor activeActor)
        {
            IntentAsync(intention, activeActor).Wait();
        }

        public bool CanIntent()
        {
            return !_intentionWait && !CurrentActorSetAndIsDead();
        }

        public void ProcessTaskExecuted(IActorTask actorTask)
        {
            // Пока ничего не делаем.
            // Это задел для парного оружия.
            // Парное оружие будет позволять выполнять удар вторым оружием,
            // когда задача выполнена, но не закончена.
        }

        public void ProcessTaskComplete(IActorTask actorTask)
        {
            _intentionWait = false;
            _currentActorIntention = null;
        }

        public void CancelTask(IActorTask cancelledActorTask)
        {
            _intentionWait = false;
            _currentActorIntention = null;
            DropIntention();
        }

        public void DropIntention()
        {
            _intentionWait = false;
            _currentActorIntention = null;

            _cancellationTokenSource.Cancel();

            _cancellationTokenSource = new CancellationTokenSource();

            try
            {
                _spscChannel.CancelReceiving();
            }
            catch (TaskCanceledException)
            {
                // This is expected cancellation behaviour.
                // Just ensure that exception is corrent and continue execution.
            }
        }
    }
}

1	using System;
2	using System.Threading;
3	using System.Threading.Tasks;
4
5	using Zilon.Core.Common;
6	using Zilon.Core.PersonModules;
7
8	namespace Zilon.Core.Tactics.Behaviour
9	{
10	public sealed class HumanActorTaskSource<TContext> : IDisposable, IHumanActorTaskSource<TContext>
11	where TContext : ISectorTaskSourceContext
12	{
13	private readonly IReceiver<IActorTask> _actorTaskReceiver;
14	private readonly ISender<IActorTask> _actorTaskSender;
15	private readonly SpscChannel<IActorTask> _spscChannel;
16	private CancellationTokenSource _cancellationTokenSource;
17	private IActor _currentActorIntention;
18	private bool _intentionWait;
19
20	public HumanActorTaskSource()	142✔
21	{	71✔
22	_spscChannel = new SpscChannel<IActorTask>();	142✔
23	_actorTaskSender = _spscChannel;	142✔
24	_actorTaskReceiver = _spscChannel;	142✔
25	_cancellationTokenSource = new CancellationTokenSource();	142✔
26	}	142✔
27
28	public void Dispose()
29	{	3✔
30	_spscChannel.Dispose();	6✔
31	_cancellationTokenSource.Dispose();	6✔
32	}	6✔
33
34	private bool CurrentActorSetAndIsDead()
35	{	88,922✔
36	return (_currentActorIntention?.Person?.GetModuleSafe<ISurvivalModule>()?.IsDead).GetValueOrDefault();	177,844!
37	}	88,922✔
38
39	public async Task IntentAsync(IIntention intention, IActor activeActor)
40	{	13,067✔
41	if (_intentionWait)	26,134!
42	{
43	// Это может происходить, если в клиентском коде предварительно не выполнили проверку CanIntent().
44	// Проверка нужна, чтобы не допустить получение очереди задач.
45	// Текущая реализация не допускает переопределение задач.
46	// Поэтому каждое новое намерение будет складывать по новой задаче в очередь, пока выполняется текущая задача
47	// Текущая задача выполняется в основном игровом цикле, который накручивает счётчик итераций, чтобы выполнить предусловия задачи.
48	throw new InvalidOperationException(	×
49	"Попытка задать новое намерение, пока не выполнена текущая задача.");	×
50	}
51
52	var currentIntention = intention ?? throw new ArgumentNullException(nameof(intention));	26,134!
53
54	var actorTask = currentIntention.CreateActorTask(activeActor);	26,134✔
55
56	_intentionWait = true;	26,134✔
57	_currentActorIntention = activeActor;	26,134✔
58
59	await _actorTaskSender.SendAsync(actorTask, _cancellationTokenSource.Token).ConfigureAwait(false);	26,134✔
60	}	26,134✔
61
62	public async Task<IActorTask> GetActorTaskAsync(IActor actor, TContext context)
63	{	13,067✔
64	// Тезисы:
65	// Этот источник команд ждёт, пока игрок не укажет задачу.
66	// Задача генерируется из намерения. Это значит, что ждать нужно, пока не будет задано намерение.
67
68	return await _actorTaskReceiver.ReceiveAsync(_cancellationTokenSource.Token).ConfigureAwait(false);	26,134✔
69	}	26,132✔
70
71	//TODO Избавиться от синхронного варианта.
72	// Сейчас он оставлен прото из-за тестов. Сложностей с удалением нет, кроме рутины.
73	[Obsolete("Использовать асинк-вариант вместо этого")]
74	public void Intent(IIntention intention, IActor activeActor)
75	{	13,065✔
76	IntentAsync(intention, activeActor).Wait();	26,130✔
77	}	26,130✔
78
79	public bool CanIntent()
80	{	6,703,550✔
81	return !_intentionWait && !CurrentActorSetAndIsDead();	13,407,100✔
82	}	6,703,550✔
83
84	public void ProcessTaskExecuted(IActorTask actorTask)
85	{	13,064✔
86	// Пока ничего не делаем.
87	// Это задел для парного оружия.
88	// Парное оружие будет позволять выполнять удар вторым оружием,
89	// когда задача выполнена, но не закончена.
90	}	26,128✔
91
92	public void ProcessTaskComplete(IActorTask actorTask)
93	{	13,063✔
94	_intentionWait = false;	26,126✔
95	_currentActorIntention = null;	26,126✔
96	}	26,126✔
97
98	public void CancelTask(IActorTask cancelledActorTask)
99	{	1✔
100	_intentionWait = false;	2✔
101	_currentActorIntention = null;	2✔
102	DropIntention();	2✔
103	}	2✔
104
105	public void DropIntention()
106	{	3✔
107	_intentionWait = false;	6✔
108	_currentActorIntention = null;	6✔
109
110	_cancellationTokenSource.Cancel();	6✔
111
112	_cancellationTokenSource = new CancellationTokenSource();	6✔
113
114	try
115	{	3✔
116	_spscChannel.CancelReceiving();	6✔
117	}	6✔
NEW 118	catch (TaskCanceledException)	×
119	{
120	// This is expected cancellation behaviour.
121	// Just ensure that exception is corrent and continue execution.
NEW 122	}	×
123	}	6✔
124	}
125	}

kreghek / Zilon_Roguelike / 421304936

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous