17822349975

Committed 18 Sep 2025 08:10AM UTC coverage: 87.183% (-0.7%) from 87.848%

Build # 17822349975

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #204 from djsuperchief/202-create-exchange

#202, #203 create exchange and router for internal messaging.

Run Details

518 of 660 branches covered (78.48%)

Branch coverage included in aggregate %.

173 of 211 new or added lines in 16 files covered. (81.99%)

2 existing lines in 1 file now uncovered.

3019 of 3397 relevant lines covered (88.87%)

23.35 hits per line

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

80.56

/source/core/Kyameru.Core/Entities/ProcessableDelegate.cs

﻿using System;
using System.Threading;
using System.Threading.Tasks;
using Kyameru.Core.Entities;

namespace Kyameru.Core.Entities
{
    internal class ProcessableDelegate : IProcessor
    {
        public event EventHandler<Log> OnLog;

        private Action<Routable> processAction;
        private readonly Func<Routable, Task> processFunc;

        public ProcessableDelegate(Action<Routable> processor)
        {
            processAction = processor;
        }

        public ProcessableDelegate(Func<Routable, Task> processor)
        {
            processFunc = processor;
        }
        public async Task ProcessAsync(Routable routable, CancellationToken cancellationToken)
        {
            if (!cancellationToken.IsCancellationRequested)
            {
                OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Information, "Running process delegate"));
                try
                {
                    if (processAction != null)
                    {
                        processAction.Invoke(routable);
                    }
                    else
                    {
                        await processFunc.Invoke(routable);
                    }
                }
                catch (Exception ex)
                {
                    OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Error, ex.ToString(), ex));
                }
                
            }

            await Task.CompletedTask;
        }
    }
}

1	using System;
2	using System.Threading;
3	using System.Threading.Tasks;
4	using Kyameru.Core.Entities;
5
6	namespace Kyameru.Core.Entities
7	{
8	internal class ProcessableDelegate : IProcessor
9	{
10	public event EventHandler<Log> OnLog;
11
12	private Action<Routable> processAction;
13	private readonly Func<Routable, Task> processFunc;
14
15	public ProcessableDelegate(Action<Routable> processor)	20✔
16	{	20✔
17	processAction = processor;	20✔
18	}	20✔
19
20	public ProcessableDelegate(Func<Routable, Task> processor)	5✔
21	{	5✔
22	processFunc = processor;	5✔
23	}	5✔
24	public async Task ProcessAsync(Routable routable, CancellationToken cancellationToken)
25	{	17✔
26	if (!cancellationToken.IsCancellationRequested)	17✔
27	{	17✔
28	OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Information, "Running process delegate"));	17!
29	try
30	{	17✔
31	if (processAction != null)	17✔
32	{	15✔
33	processAction.Invoke(routable);	15✔
34	}	15✔
35	else
36	{	2✔
37	await processFunc.Invoke(routable);	2✔
38	}	2✔
39	}	17✔
NEW 40	catch (Exception ex)	×
UNCOV 41	{	×
NEW 42	OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Error, ex.ToString(), ex));	×
UNCOV 43	}	×
44
45	}	17✔
46
47	await Task.CompletedTask;	17✔
48	}	17✔
49	}
50	}

djsuperchief / Kyameru / 17822349975

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