WingMan

Subversion Repositories:
Compare Path: Rev
With Path: Rev
?path1? @ 32  →  ?path2? @ 35
/trunk/WingMan/Bindings/KeyBindingsSynchronizer.cs
@@ -5,7 +5,6 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using MQTTnet;
using WingMan.Communication;
 
namespace WingMan.Bindings
@@ -46,13 +45,15 @@
public event MouseKeyBindingsSynchronized OnMouseKeyBindingsSynchronized;
 
private async void MqttCommunicationOnMessageReceived(object sender,
MqttApplicationMessageReceivedEventArgs e)
MqttCommunicationMessageReceivedEventArgs e)
{
if (e.ApplicationMessage.Topic != "exchange")
if (e.Topic != "exchange")
return;
 
using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload))
using (var memoryStream = new MemoryStream())
{
await e.PayloadStream.CopyToAsync(memoryStream);
 
memoryStream.Position = 0L;
 
var mouseKeyBindingsExchange =
@@ -100,4 +101,4 @@
} while (!CancellationToken.IsCancellationRequested);
}
}
}
}
/trunk/WingMan/Bindings/KeySimulator.cs
@@ -4,7 +4,6 @@
using System.Threading.Tasks;
using WindowsInput;
using WindowsInput.Native;
using MQTTnet;
using WingMan.Communication;
using WingMan.Utilities;
 
@@ -41,13 +40,17 @@
 
public event MouseKeyBindingExecuting OnMouseKeyBindingExecuting;
 
private async void OnMqttMessageReceived(object sender, MqttApplicationMessageReceivedEventArgs e)
private async void OnMqttMessageReceived(object sender, MqttCommunicationMessageReceivedEventArgs e)
{
if (e.ApplicationMessage.Topic != "execute")
if (e.Topic != "execute")
return;
 
using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload))
using (var memoryStream = new MemoryStream())
{
await e.PayloadStream.CopyToAsync(memoryStream);
 
memoryStream.Position = 0L;
 
var executeMouseKeyBinding =
(ExecuteKeyBinding) ExecuteKeyBinding.XmlSerializer.Deserialize(memoryStream);
 
@@ -100,4 +103,4 @@
}
}
}
}
}