WingMan
/trunk/WingMan/Communication/MqttCommunication.cs |
@@ -63,7 +63,7 @@ |
|
private IPAddress IpAddress { get; set; } |
|
private int Port { get; set; } |
public int Port { get; set; } |
|
private string Password { get; set; } |
|
@@ -159,9 +159,9 @@ |
|
private async Task StopClient() |
{ |
await Client.StopAsync(); |
|
UnbindClientHandlers(); |
|
await Client.StopAsync(); |
} |
|
public void BindClientHandlers() |
@@ -186,7 +186,7 @@ |
{ |
using (var inputStream = new MemoryStream(e.ApplicationMessage.Payload)) |
{ |
using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
using (var decryptedStream = await Aes.Decrypt(inputStream, Password)) |
{ |
using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
{ |
@@ -254,9 +254,9 @@ |
|
private async Task StopServer() |
{ |
await Server.StopAsync(); |
|
UnbindServerHandlers(); |
|
await Server.StopAsync(); |
} |
|
private void BindServerHandlers() |
@@ -287,7 +287,7 @@ |
{ |
using (var inputStream = new MemoryStream(e.ApplicationMessage.Payload)) |
{ |
using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
using (var decryptedStream = await Aes.Decrypt(inputStream, Password)) |
{ |
using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
{ |
@@ -383,7 +383,7 @@ |
|
compressStream.Position = 0L; |
|
using (var outputStream = await AES.Encrypt(compressStream, Password)) |
using (var outputStream = await Aes.Encrypt(compressStream, Password)) |
{ |
var data = outputStream.ToArray(); |
switch (Type) |