697055226

Build Type

github

Committed by GitHub

Commit Message

Merge 3e2fb21f1 into 0a9d5c71e

Pull Request Pull Request #1069: Fix 966 automove

Run Details

2319 of 3734 branches covered (62.1%)

Branch coverage included in aggregate %.

79 of 120 new or added lines in 10 files covered. (65.83%)

16 existing lines in 8 files now uncovered.

6143 of 8050 relevant lines covered (76.31%)

55043.38 hits per line

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

0.0

/Zilon.Core/Zilon.Core/Client/Sector/GlobeLoopUpdater.cs

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

using JetBrains.Annotations;

namespace Zilon.Core.Client.Sector
{
    public sealed class GlobeLoopUpdater : IDisposable, IGlobeLoopUpdater
    {
        [NotNull] private readonly IAnimationBlockerService _animationBlockerService;

        [NotNull] private readonly IGameLoopContext _gameLoopContext;

        private CancellationTokenSource? _cancellationTokenSource;

        public GlobeLoopUpdater(
            IGameLoopContext gameLoopContext,
            IAnimationBlockerService animationBlockerService)
        {
            _gameLoopContext = gameLoopContext ?? throw new ArgumentNullException(nameof(gameLoopContext));
            _animationBlockerService = animationBlockerService ??
                                       throw new ArgumentNullException(nameof(animationBlockerService));
        }

        public void Dispose()
        {
            if (_cancellationTokenSource != null)
            {
                _cancellationTokenSource.Dispose();
            }
        }

        private async Task StartGameLoopUpdateAsync(CancellationToken cancelToken)
        {
            while (_gameLoopContext.HasNextIteration)
            {
                cancelToken.ThrowIfCancellationRequested();

                try
                {
                    await _gameLoopContext.UpdateAsync(cancelToken);
                }
                catch (Exception exception)
                {
                    ErrorOccured?.Invoke(this, new ErrorOccuredEventArgs(exception));
                }

                var animationBlockerTask = _animationBlockerService.WaitBlockersAsync();
                var fuseDelayTask = Task.Delay(10_000, cancelToken);

                await Task.WhenAny(animationBlockerTask, fuseDelayTask).ConfigureAwait(false);
                _animationBlockerService.DropBlockers();
            }
        }

        public bool IsStarted { get; private set; }

        public event EventHandler<ErrorOccuredEventArgs>? ErrorOccured;

        public void Start()
        {
            _cancellationTokenSource = new CancellationTokenSource();

            var cancelToken = _cancellationTokenSource.Token;

            var updateTask = StartGameLoopUpdateAsync(cancelToken);

            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnFaulted);
            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnCanceled);
            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnRanToCompletion);

            IsStarted = true;
        }

        public void Stop()
        {
            if (_cancellationTokenSource != null)
            {
                _cancellationTokenSource.Cancel();
            }
        }
    }
}

1	using System;
2	using System.Threading;
3	using System.Threading.Tasks;
4
5	using JetBrains.Annotations;
6
7	namespace Zilon.Core.Client.Sector
8	{
9	public sealed class GlobeLoopUpdater : IDisposable, IGlobeLoopUpdater
10	{
11	[NotNull] private readonly IAnimationBlockerService _animationBlockerService;
12
13	[NotNull] private readonly IGameLoopContext _gameLoopContext;
14
15	private CancellationTokenSource? _cancellationTokenSource;
16
NEW 17	public GlobeLoopUpdater(	×
18	IGameLoopContext gameLoopContext,	×
19	IAnimationBlockerService animationBlockerService)	×
20	{
21	_gameLoopContext = gameLoopContext ?? throw new ArgumentNullException(nameof(gameLoopContext));	×
NEW 22	_animationBlockerService = animationBlockerService ??	×
NEW 23	throw new ArgumentNullException(nameof(animationBlockerService));	×
24	}	×
25
26	public void Dispose()
27	{
NEW 28	if (_cancellationTokenSource != null)	×
29	{
NEW 30	_cancellationTokenSource.Dispose();	×
31	}
32	}	×
33
34	private async Task StartGameLoopUpdateAsync(CancellationToken cancelToken)
35	{
36	while (_gameLoopContext.HasNextIteration)
37	{
38	cancelToken.ThrowIfCancellationRequested();
39
40	try
41	{
42	await _gameLoopContext.UpdateAsync(cancelToken);
43	}
44	catch (Exception exception)
45	{
46	ErrorOccured?.Invoke(this, new ErrorOccuredEventArgs(exception));
47	}
48
49	var animationBlockerTask = _animationBlockerService.WaitBlockersAsync();
50	var fuseDelayTask = Task.Delay(10_000, cancelToken);
51
52	await Task.WhenAny(animationBlockerTask, fuseDelayTask).ConfigureAwait(false);
53	_animationBlockerService.DropBlockers();
54	}
55	}
56
57	public bool IsStarted { get; private set; }
58
59	public event EventHandler<ErrorOccuredEventArgs>? ErrorOccured;
60
61	public void Start()
62	{
NEW 63	_cancellationTokenSource = new CancellationTokenSource();	×
64
NEW 65	var cancelToken = _cancellationTokenSource.Token;	×
66
NEW 67	var updateTask = StartGameLoopUpdateAsync(cancelToken);	×
68
NEW 69	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnFaulted);	×
NEW 70	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnCanceled);	×
NEW 71	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnRanToCompletion);	×
72
NEW 73	IsStarted = true;	×
NEW 74	}	×
75
76	public void Stop()
77	{
NEW 78	if (_cancellationTokenSource != null)	×
79	{
NEW 80	_cancellationTokenSource.Cancel();	×
81	}
NEW 82	}	×
83	}
84	}

kreghek / Zilon_Roguelike / 697055226

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