422300689

Build Type

github

Committed by GitHub

Commit Message

Merge e13919b4f into 4d358de9f

Pull Request Pull Request #938: Fix the text game restart after the main player person dead

Run Details

4399 of 7170 branches covered (61.35%)

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.

6542 of 8776 relevant lines covered (74.54%)

791857.0 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
{
    /// <summary>
    /// Base implementation of user actor task source.
    /// </summary>
    /// <typeparam name="TContext"></typeparam>
    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();
        }

        /// <inheritdoc />
        public void Dispose()
        {
            _spscChannel.Dispose();
            _cancellationTokenSource.Dispose();
        }

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

        /// <inheritdoc />
        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);
        }

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

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

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

        /// <inheritdoc />
        public bool CanIntent()
        {
            return !_intentionWait && !CurrentActorSetAndIsDead();
        }

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

        /// <inheritdoc />
        public void ProcessTaskComplete(IActorTask actorTask)
        {
            _intentionWait = false;
            _currentActorIntention = null;
        }

        /// <inheritdoc />
        public void CancelTask(IActorTask cancelledActorTask)
        {
            _intentionWait = false;
            _currentActorIntention = null;
            DropIntentionWaiting();
        }

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

kreghek / Zilon_Roguelike / 422300689

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