6598306412

Committed 21 Oct 2023 03:54PM UTC coverage: 45.09% (-7.4%) from 52.519%

Build # 6598306412

Build Type

Pull #50

github

Committed by

web-flow

Commit Message

Merge bff596568 into 14b7ce9a7

Pull Request Pull Request #50: Add XInput in preparation for gamepad triggers + add xmldoc

Run Details

751 of 2289 branches covered (0.0%)

Branch coverage included in aggregate %.

2384 of 2384 new or added lines in 80 files covered. (100.0%)

3845 of 7904 relevant lines covered (48.65%)

15964.61 hits per line

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

30.77

/Core/Key2Joy.Contracts/Plugins/Remoting/RemoteEventSubscriber.cs

using System;
using System.Collections.Generic;
using System.IO;

namespace Key2Joy.Contracts.Plugins.Remoting;

public class RemoteEventSubscriber
{
    internal static readonly TimeSpan MaxHeartbeatInterval = TimeSpan.FromSeconds(10);

    public const string SignalReady = "READY";
    public const string SignalHeartbeat = "HEARTBEAT";
    public const string SignalExit = "EXIT";

    private static readonly Dictionary<string, SubscriptionRegistration> Subscriptions = new();

    public static RemoteEventSubscriberClient ClientInstance { get; private set; }

    /// <summary>
    /// Exposes a named pipe endpoint corresponding to the unique name for this plugin host
    /// </summary>
    public static RemoteEventSubscriberHost InitHostForPlugin(string portName) => new RemoteEventSubscriberHost(portName);

    public static void InitClient(string portName)
    {
        ClientInstance = new RemoteEventSubscriberClient(portName);

        try
        {
            ClientInstance.SendToHost(SignalReady);
        }
        catch (IOException ex)
        {
            Output.WriteLine(ex.ToString());
            Console.WriteLine(ex);
        }
    }

    public static SubscriptionRegistration SubscribeEvent(string eventName, RemoteEventHandlerCallback handler)
    {
        var subscriptionId = Guid.NewGuid().ToString();
        SubscriptionRegistration subscription = new(eventName, subscriptionId, handler);

        Subscriptions.Add(subscriptionId, subscription);

        return subscription;
    }

    public static void HandleInvoke(string subscriptionId)
    {
        // Find subscription and call related event
        if (!TryGetSubscription(subscriptionId, out var fullSubscriptionInfo))
        {
            throw new ApplicationException($"Could not find event subscription with id {subscriptionId}!");
        }

        fullSubscriptionInfo.EventHandler?.Invoke(fullSubscriptionInfo.CustomSender, new RemoteEventArgs(fullSubscriptionInfo.Ticket));
    }

    public static void UnsubscribeEvent(string subscriptionId) => Subscriptions.Remove(subscriptionId);

    public static bool TryGetSubscription(string subscriptionId, out SubscriptionRegistration subscription) => Subscriptions.TryGetValue(subscriptionId, out subscription);
}

1	using System;
2	using System.Collections.Generic;
3	using System.IO;
4
5	namespace Key2Joy.Contracts.Plugins.Remoting;
6
7	public class RemoteEventSubscriber
8	{
9	internal static readonly TimeSpan MaxHeartbeatInterval = TimeSpan.FromSeconds(10);	15✔
10
11	public const string SignalReady = "READY";
12	public const string SignalHeartbeat = "HEARTBEAT";
13	public const string SignalExit = "EXIT";
14
15	private static readonly Dictionary<string, SubscriptionRegistration> Subscriptions = new();	15✔
16
17	public static RemoteEventSubscriberClient ClientInstance { get; private set; }	42✔
18
19	/// <summary>
20	/// Exposes a named pipe endpoint corresponding to the unique name for this plugin host
21	/// </summary>
22	public static RemoteEventSubscriberHost InitHostForPlugin(string portName) => new RemoteEventSubscriberHost(portName);	16✔
23
24	public static void InitClient(string portName)
25	{
26	ClientInstance = new RemoteEventSubscriberClient(portName);	14✔
27
28	try
29	{
30	ClientInstance.SendToHost(SignalReady);	14✔
31	}	14✔
32	catch (IOException ex)	×
33	{
34	Output.WriteLine(ex.ToString());	×
35	Console.WriteLine(ex);	×
36	}	×
37	}	14✔
38
39	public static SubscriptionRegistration SubscribeEvent(string eventName, RemoteEventHandlerCallback handler)
40	{
41	var subscriptionId = Guid.NewGuid().ToString();	×
42	SubscriptionRegistration subscription = new(eventName, subscriptionId, handler);	×
43
44	Subscriptions.Add(subscriptionId, subscription);	×
45
46	return subscription;	×
47	}
48
49	public static void HandleInvoke(string subscriptionId)
50	{
51	// Find subscription and call related event
52	if (!TryGetSubscription(subscriptionId, out var fullSubscriptionInfo))	×
53	{
54	throw new ApplicationException($"Could not find event subscription with id {subscriptionId}!");	×
55	}
56
57	fullSubscriptionInfo.EventHandler?.Invoke(fullSubscriptionInfo.CustomSender, new RemoteEventArgs(fullSubscriptionInfo.Ticket));	×
58	}	×
59
60	public static void UnsubscribeEvent(string subscriptionId) => Subscriptions.Remove(subscriptionId);	×
61
62	public static bool TryGetSubscription(string subscriptionId, out SubscriptionRegistration subscription) => Subscriptions.TryGetValue(subscriptionId, out subscription);	×
63	}

luttje / Key2Joy / 6598306412

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