Add http action type and Sonar mute toggle (chatCapture, media channels)
This commit is contained in:
@@ -1,12 +1,16 @@
|
|||||||
public static class ActionFactory
|
public static class ActionFactory
|
||||||
{
|
{
|
||||||
public static IAction? Create(BindingConfig config)
|
public static IAction? Create(BindingConfig config, string? sonarAddress)
|
||||||
{
|
{
|
||||||
return config.Type switch
|
return config.Type switch
|
||||||
{
|
{
|
||||||
"launch" => new LaunchAction(config.Target),
|
"launch" => new LaunchAction(config.Target),
|
||||||
"url" => new UrlAction(config.Target),
|
"url" => new UrlAction(config.Target),
|
||||||
"keystroke" => new KeystrokeAction(config.Target),
|
"keystroke" => new KeystrokeAction(config.Target),
|
||||||
|
"http" => new HttpAction(config.Method, config.Target, config.Body),
|
||||||
|
"sonar-toggle-mute" => sonarAddress is not null
|
||||||
|
? new SonarToggleMuteAction(sonarAddress, config.Target)
|
||||||
|
: null,
|
||||||
_ => null
|
_ => null
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,8 +2,9 @@ public class BindingConfig
|
|||||||
{
|
{
|
||||||
public string Type { get; set; } = "";
|
public string Type { get; set; } = "";
|
||||||
public string Target { get; set; } = "";
|
public string Target { get; set; } = "";
|
||||||
|
public string Method { get; set; } = "GET";
|
||||||
|
public string? Body { get; set; }
|
||||||
}
|
}
|
||||||
|
|
||||||
public class Config
|
public class Config
|
||||||
{
|
{
|
||||||
public Dictionary<string, BindingConfig> Bindings { get; set; } = new();
|
public Dictionary<string, BindingConfig> Bindings { get; set; } = new();
|
||||||
|
|||||||
@@ -0,0 +1,38 @@
|
|||||||
|
using System.Net.Http;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
|
public class HttpAction : IAction
|
||||||
|
{
|
||||||
|
private static readonly HttpClient Client = new();
|
||||||
|
|
||||||
|
private readonly HttpMethod _method;
|
||||||
|
private readonly string _url;
|
||||||
|
private readonly string? _body;
|
||||||
|
|
||||||
|
public HttpAction(string method, string url, string? body)
|
||||||
|
{
|
||||||
|
_method = new HttpMethod(method.ToUpperInvariant());
|
||||||
|
_url = url;
|
||||||
|
_body = body;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Execute()
|
||||||
|
{
|
||||||
|
var request = new HttpRequestMessage(_method, _url);
|
||||||
|
if (_body is not null)
|
||||||
|
request.Content = new StringContent(_body, Encoding.UTF8, "application/json");
|
||||||
|
|
||||||
|
Client.SendAsync(request).ContinueWith(async t =>
|
||||||
|
{
|
||||||
|
if (t.IsFaulted)
|
||||||
|
{
|
||||||
|
Console.WriteLine($"[HttpAction] Échec requête {_method} {_url} : {t.Exception?.GetBaseException().Message}");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
var response = t.Result;
|
||||||
|
var body = await response.Content.ReadAsStringAsync();
|
||||||
|
Console.WriteLine($"[HttpAction] {_method} {_url} → HTTP {(int)response.StatusCode} : {body}");
|
||||||
|
}, TaskScheduler.Default);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -31,6 +31,8 @@ public class KeystrokeAction : IAction, IDisposable
|
|||||||
"enter" or "return" => KeyCode.VcEnter,
|
"enter" or "return" => KeyCode.VcEnter,
|
||||||
"space" => KeyCode.VcSpace,
|
"space" => KeyCode.VcSpace,
|
||||||
"delete" or "del" => KeyCode.VcDelete,
|
"delete" or "del" => KeyCode.VcDelete,
|
||||||
|
_ when System.Text.RegularExpressions.Regex.IsMatch(name, @"^f([1-9]|1[0-9]|2[0-4])$")
|
||||||
|
=> Enum.Parse<KeyCode>($"Vc{name.ToUpperInvariant()}"),
|
||||||
_ when name.Length == 1 => Enum.Parse<KeyCode>($"Vc{char.ToUpperInvariant(name[0])}"),
|
_ when name.Length == 1 => Enum.Parse<KeyCode>($"Vc{char.ToUpperInvariant(name[0])}"),
|
||||||
_ => throw new ArgumentException($"Touche inconnue : {name}")
|
_ => throw new ArgumentException($"Touche inconnue : {name}")
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -6,53 +6,92 @@ var configJson = File.ReadAllText(configPath);
|
|||||||
var config = JsonSerializer.Deserialize<Config>(configJson, new JsonSerializerOptions { PropertyNameCaseInsensitive = true })
|
var config = JsonSerializer.Deserialize<Config>(configJson, new JsonSerializerOptions { PropertyNameCaseInsensitive = true })
|
||||||
?? new Config();
|
?? new Config();
|
||||||
|
|
||||||
|
var sonarAddress = await SonarAddressResolver.GetSonarAddressAsync();
|
||||||
|
Console.WriteLine($"Adresse Sonar résolue : {sonarAddress ?? "AUCUNE"}");
|
||||||
|
|
||||||
var actions = new Dictionary<int, IAction>();
|
var actions = new Dictionary<int, IAction>();
|
||||||
foreach (var (key, binding) in config.Bindings)
|
foreach (var (key, binding) in config.Bindings)
|
||||||
{
|
{
|
||||||
var action = ActionFactory.Create(binding);
|
if (binding.Target.Contains("{sonar}") && sonarAddress is not null)
|
||||||
|
binding.Target = binding.Target.Replace("{sonar}", sonarAddress);
|
||||||
|
|
||||||
|
var action = ActionFactory.Create(binding, sonarAddress);
|
||||||
if (action is not null && int.TryParse(key, out var bit))
|
if (action is not null && int.TryParse(key, out var bit))
|
||||||
actions[bit] = action;
|
actions[bit] = action;
|
||||||
}
|
}
|
||||||
|
|
||||||
var device = DeviceList.Local.GetHidDevices(vendorID: 0x2341, productID: 0x8036).FirstOrDefault();
|
Console.WriteLine($"{actions.Count} binding(s) chargé(s) :");
|
||||||
if (device is null)
|
foreach (var (bit, _) in actions)
|
||||||
{
|
Console.WriteLine($" bit {bit} -> {config.Bindings.First(b => int.Parse(b.Key) == bit).Value.Type}");
|
||||||
Console.WriteLine("Pad non trouvé. Vérifie qu'il est branché.");
|
Console.WriteLine();
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
using var stream = device.Open();
|
|
||||||
stream.ReadTimeout = Timeout.Infinite;
|
|
||||||
|
|
||||||
var buffer = new byte[device.GetMaxInputReportLength()];
|
const ushort VendorId = 0x2341;
|
||||||
ushort lastMask = 0;
|
const ushort ProductId = 0x8036;
|
||||||
|
|
||||||
Console.WriteLine("En écoute...\n");
|
|
||||||
|
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
int count;
|
var device = DeviceList.Local.GetHidDevices(vendorID: VendorId, productID: ProductId).FirstOrDefault();
|
||||||
try { count = stream.Read(buffer, 0, buffer.Length); }
|
|
||||||
catch (TimeoutException) { continue; }
|
|
||||||
|
|
||||||
int offset = count > 2 ? 1 : 0;
|
if (device is null)
|
||||||
ushort mask = (ushort)(buffer[offset] | (buffer[offset + 1] << 8));
|
|
||||||
|
|
||||||
if (mask != lastMask)
|
|
||||||
{
|
{
|
||||||
ushort changed = (ushort)(mask ^ lastMask);
|
Console.WriteLine("Pad non trouvé, nouvelle tentative dans 2s...");
|
||||||
for (int bit = 0; bit < 12; bit++)
|
Thread.Sleep(2000);
|
||||||
{
|
continue;
|
||||||
bool bitChanged = (changed & (1 << bit)) != 0;
|
}
|
||||||
bool nowPressed = (mask & (1 << bit)) != 0;
|
|
||||||
|
|
||||||
// On déclenche seulement au moment où le bouton est pressé, pas relâché
|
Console.WriteLine($"Pad connecté : {device.DevicePath}");
|
||||||
if (bitChanged && nowPressed && actions.TryGetValue(bit, out var action))
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
ListenToDevice(device, actions);
|
||||||
|
}
|
||||||
|
catch (Exception ex) when (ex is IOException or TimeoutException or ObjectDisposedException)
|
||||||
|
{
|
||||||
|
Console.WriteLine("Pad déconnecté. En attente de reconnexion...");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void ListenToDevice(HidDevice device, Dictionary<int, IAction> actions)
|
||||||
|
{
|
||||||
|
using var stream = device.Open();
|
||||||
|
stream.ReadTimeout = Timeout.Infinite;
|
||||||
|
|
||||||
|
var buffer = new byte[device.GetMaxInputReportLength()];
|
||||||
|
ushort lastMask = 0;
|
||||||
|
|
||||||
|
while (true)
|
||||||
|
{
|
||||||
|
int count = stream.Read(buffer, 0, buffer.Length);
|
||||||
|
if (count == 0) throw new IOException("Rapport vide, device probablement déconnecté");
|
||||||
|
|
||||||
|
int offset = count > 2 ? 1 : 0;
|
||||||
|
ushort mask = (ushort)(buffer[offset] | (buffer[offset + 1] << 8));
|
||||||
|
|
||||||
|
Console.WriteLine($"Rapport reçu, mask={Convert.ToString(mask, 2).PadLeft(12, '0')}");
|
||||||
|
|
||||||
|
if (mask != lastMask)
|
||||||
|
{
|
||||||
|
ushort changed = (ushort)(mask ^ lastMask);
|
||||||
|
for (int bit = 0; bit < 12; bit++)
|
||||||
{
|
{
|
||||||
Console.WriteLine($"Bouton {bit} → exécution de l'action");
|
bool bitChanged = (changed & (1 << bit)) != 0;
|
||||||
action.Execute();
|
bool nowPressed = (mask & (1 << bit)) != 0;
|
||||||
|
|
||||||
|
if (bitChanged && nowPressed && actions.TryGetValue(bit, out var action))
|
||||||
|
{
|
||||||
|
Console.WriteLine($"Bouton {bit} → exécution de l'action");
|
||||||
|
try
|
||||||
|
{
|
||||||
|
action.Execute();
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
Console.WriteLine($"Erreur lors de l'exécution : {ex.Message}");
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
lastMask = mask;
|
||||||
}
|
}
|
||||||
lastMask = mask;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,43 @@
|
|||||||
|
using System.Net.Http;
|
||||||
|
using System.Security.Cryptography.X509Certificates;
|
||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
public static class SonarAddressResolver
|
||||||
|
{
|
||||||
|
private static readonly HttpClient Client = CreateInsecureClient();
|
||||||
|
|
||||||
|
private static HttpClient CreateInsecureClient()
|
||||||
|
{
|
||||||
|
var handler = new HttpClientHandler
|
||||||
|
{
|
||||||
|
ServerCertificateCustomValidationCallback = (msg, cert, chain, errors) => true
|
||||||
|
};
|
||||||
|
return new HttpClient(handler);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static async Task<string?> GetSonarAddressAsync()
|
||||||
|
{
|
||||||
|
var corePropsPath = Path.Combine(
|
||||||
|
Environment.GetFolderPath(Environment.SpecialFolder.CommonApplicationData),
|
||||||
|
"SteelSeries", "SteelSeries Engine 3", "coreProps.json");
|
||||||
|
|
||||||
|
if (!File.Exists(corePropsPath))
|
||||||
|
return null;
|
||||||
|
|
||||||
|
using var coreDoc = JsonDocument.Parse(File.ReadAllText(corePropsPath));
|
||||||
|
if (!coreDoc.RootElement.TryGetProperty("ggEncryptedAddress", out var ggAddr))
|
||||||
|
return null;
|
||||||
|
|
||||||
|
var subAppsJson = await Client.GetStringAsync($"https://{ggAddr.GetString()}/subApps");
|
||||||
|
using var subAppsDoc = JsonDocument.Parse(subAppsJson);
|
||||||
|
|
||||||
|
var webServerAddress = subAppsDoc.RootElement
|
||||||
|
.GetProperty("subApps")
|
||||||
|
.GetProperty("sonar")
|
||||||
|
.GetProperty("metadata")
|
||||||
|
.GetProperty("webServerAddress")
|
||||||
|
.GetString();
|
||||||
|
|
||||||
|
return webServerAddress?.Replace("http://", "").Replace("https://", "");
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,60 @@
|
|||||||
|
using System.Net.Http;
|
||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
public class SonarToggleMuteAction : IAction
|
||||||
|
{
|
||||||
|
private static readonly HttpClient Client = CreateClient();
|
||||||
|
|
||||||
|
private readonly string _address;
|
||||||
|
private readonly string _channel;
|
||||||
|
private bool? _lastKnownMuted;
|
||||||
|
|
||||||
|
public SonarToggleMuteAction(string address, string channel)
|
||||||
|
{
|
||||||
|
_address = address;
|
||||||
|
_channel = channel;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Execute()
|
||||||
|
{
|
||||||
|
_ = ToggleAsync();
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task ToggleAsync()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
// Première pression : on part du principe qu'on est démuté, donc on mute.
|
||||||
|
// Ensuite, on se base sur l'état réel renvoyé par Sonar à chaque appel.
|
||||||
|
var desiredMuted = !(_lastKnownMuted ?? false);
|
||||||
|
|
||||||
|
var url = $"http://{_address}/volumeSettings/classic/{_channel}/Mute/{(desiredMuted ? "true" : "false")}";
|
||||||
|
var response = await Client.PutAsync(url, new StringContent(""));
|
||||||
|
var body = await response.Content.ReadAsStringAsync();
|
||||||
|
|
||||||
|
using var doc = JsonDocument.Parse(body);
|
||||||
|
var actualMuted = doc.RootElement
|
||||||
|
.GetProperty("devices")
|
||||||
|
.GetProperty(_channel)
|
||||||
|
.GetProperty("classic")
|
||||||
|
.GetProperty("muted")
|
||||||
|
.GetBoolean();
|
||||||
|
|
||||||
|
_lastKnownMuted = actualMuted;
|
||||||
|
Console.WriteLine($"[SonarToggleMute] {_channel} -> muted={actualMuted}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
Console.WriteLine($"[SonarToggleMute] Erreur : {ex.Message}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private static HttpClient CreateClient()
|
||||||
|
{
|
||||||
|
var handler = new HttpClientHandler
|
||||||
|
{
|
||||||
|
ServerCertificateCustomValidationCallback = (msg, cert, chain, errors) => true
|
||||||
|
};
|
||||||
|
return new HttpClient(handler);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -2,6 +2,13 @@
|
|||||||
"bindings": {
|
"bindings": {
|
||||||
"0": { "type": "launch", "target": "notepad.exe" },
|
"0": { "type": "launch", "target": "notepad.exe" },
|
||||||
"1": { "type": "url", "target": "https://github.com" },
|
"1": { "type": "url", "target": "https://github.com" },
|
||||||
"2": { "type": "keystroke", "target": "ctrl+shift+esc" }
|
"2": { "type": "keystroke", "target": "ctrl+shift+esc" },
|
||||||
|
"3": { "type": "keystroke", "target": "f13" },
|
||||||
|
"4": {
|
||||||
|
"type": "http",
|
||||||
|
"method": "PUT",
|
||||||
|
"target": "http://{sonar}/volumeSettings/classic/chatCapture/Mute/true"
|
||||||
|
},
|
||||||
|
"5": { "type": "sonar-toggle-mute", "target": "media" }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user