686954196

Build Type

github

Committed by GitHub

Commit Message

Merge 328528e80 into 0a9d5c71e

Pull Request Pull Request #1069: Fix 966 automove

Run Details

2333 of 3732 branches covered (62.51%)

Branch coverage included in aggregate %.

11 of 121 new or added lines in 12 files covered. (9.09%)

10 existing lines in 7 files now uncovered.

6134 of 8050 relevant lines covered (76.2%)

94442.52 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 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()
        {
            throw new NotImplementedException();
        }

        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 is null)
            {
                // Means Start was not called.
            }
            else
            {
                _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 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	throw new NotImplementedException();	×
29	}
30
31	private async Task StartGameLoopUpdateAsync(CancellationToken cancelToken)
32	{
33	while (_gameLoopContext.HasNextIteration)
34	{
35	cancelToken.ThrowIfCancellationRequested();
36
37	try
38	{
39	await _gameLoopContext.UpdateAsync(cancelToken);
40	}
41	catch (Exception exception)
42	{
43	ErrorOccured?.Invoke(this, new ErrorOccuredEventArgs(exception));
44	}
45
46	var animationBlockerTask = _animationBlockerService.WaitBlockersAsync();
47	var fuseDelayTask = Task.Delay(10_000, cancelToken);
48
49	await Task.WhenAny(animationBlockerTask, fuseDelayTask).ConfigureAwait(false);
50	_animationBlockerService.DropBlockers();
51	}
52	}
53
54	public bool IsStarted { get; private set; }
55
56	public event EventHandler<ErrorOccuredEventArgs>? ErrorOccured;
57
58	public void Start()
59	{
NEW 60	_cancellationTokenSource = new CancellationTokenSource();	×
61
NEW 62	var cancelToken = _cancellationTokenSource.Token;	×
63
NEW 64	var updateTask = StartGameLoopUpdateAsync(cancelToken);	×
65
NEW 66	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnFaulted);	×
NEW 67	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnCanceled);	×
NEW 68	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnRanToCompletion);	×
69
NEW 70	IsStarted = true;	×
NEW 71	}	×
72
73	public void Stop()
74	{
NEW 75	if (_cancellationTokenSource is null)	×
76	{
77	// Means Start was not called.
78	}
79	else
80	{
NEW 81	_cancellationTokenSource.Cancel();	×
82	}
NEW 83	}	×
84	}
85	}

kreghek / Zilon_Roguelike / 686954196

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