Compare commits
3 commits
41f55c3ef2
...
fa9335602e
Author | SHA1 | Date | |
---|---|---|---|
fa9335602e | |||
007a5beeaf | |||
0c669012b6 |
5 changed files with 59 additions and 9 deletions
|
@ -54,7 +54,7 @@ namespace PixelHub.Server
|
||||||
/// Sends the given command to the remote PixelBot.
|
/// Sends the given command to the remote PixelBot.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="command">The command to send.</param>
|
/// <param name="command">The command to send.</param>
|
||||||
public async Task Send(PixelCommand command)
|
public async Task Send(PixelMessage command)
|
||||||
{
|
{
|
||||||
byte[] message = command.AsCompiledCommand();
|
byte[] message = command.AsCompiledCommand();
|
||||||
await client.GetStream().WriteAsync(message, 0, message.Length);
|
await client.GetStream().WriteAsync(message, 0, message.Length);
|
||||||
|
|
|
@ -40,14 +40,15 @@
|
||||||
<Compile Include="SBRL.Utilities\ForgetTask.cs" />
|
<Compile Include="SBRL.Utilities\ForgetTask.cs" />
|
||||||
<Compile Include="SBRL.Utilities\Utilities.cs" />
|
<Compile Include="SBRL.Utilities\Utilities.cs" />
|
||||||
<Compile Include="SBRL.Utilities\PrefixedWriter.cs" />
|
<Compile Include="SBRL.Utilities\PrefixedWriter.cs" />
|
||||||
<Compile Include="PixelCommand.cs" />
|
|
||||||
<Compile Include="PixelBot.cs" />
|
<Compile Include="PixelBot.cs" />
|
||||||
<Compile Include="NetTools.cs" />
|
<Compile Include="NetTools.cs" />
|
||||||
<Compile Include="PixelCommands\ResetCommand.cs" />
|
<Compile Include="PixelMessage.cs" />
|
||||||
|
<Compile Include="PixelMessages\HandshakeRequestMessage.cs" />
|
||||||
|
<Compile Include="PixelMessages\ResetMessage.cs" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
|
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<Folder Include="SBRL.Utilities\" />
|
<Folder Include="SBRL.Utilities\" />
|
||||||
<Folder Include="PixelCommands\" />
|
<Folder Include="PixelMessages\" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
</Project>
|
</Project>
|
||||||
|
|
|
@ -34,7 +34,7 @@ namespace PixelHub
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Specifies a single command that is to be sent to a PixelBot.
|
/// Specifies a single command that is to be sent to a PixelBot.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public abstract class PixelCommand
|
public abstract class PixelMessage
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// A random number generator. Useful for generating default message ids.
|
/// A random number generator. Useful for generating default message ids.
|
||||||
|
@ -73,7 +73,20 @@ namespace PixelHub
|
||||||
public byte[] Header
|
public byte[] Header
|
||||||
{
|
{
|
||||||
get {
|
get {
|
||||||
|
byte[] result = new byte[HeaderSize];
|
||||||
|
// Fetch all the components needed to build the message header and convert them to byte arrays
|
||||||
|
byte[] rawProtocolVersion = BitConverter.GetBytes(ProtocolVersion);
|
||||||
|
byte[] rawMessageType = BitConverter.GetBytes((ushort)MessageType);
|
||||||
|
byte[] rawMessageId = BitConverter.GetBytes((ushort)MessageId);
|
||||||
|
byte[] rawMessageLength = BitConverter.GetBytes(Payload.Length);
|
||||||
|
|
||||||
|
// Copy the pieces into the correct places
|
||||||
|
Buffer.BlockCopy(rawProtocolVersion, 0, result, 0, rawProtocolVersion.Length);
|
||||||
|
Buffer.BlockCopy(rawMessageType, 0, result, 2, rawProtocolVersion.Length);
|
||||||
|
Buffer.BlockCopy(rawMessageId, 0, result, 4, rawProtocolVersion.Length);
|
||||||
|
Buffer.BlockCopy(rawMessageLength, 0, result, 8, rawProtocolVersion.Length);
|
||||||
|
|
||||||
|
return result;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -82,16 +95,23 @@ namespace PixelHub
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public abstract byte[] Payload { get; protected set; }
|
public abstract byte[] Payload { get; protected set; }
|
||||||
|
|
||||||
public PixelCommand()
|
public PixelMessage()
|
||||||
{
|
{
|
||||||
byte[] rawMessageId = new byte[sizeof(uint)];
|
byte[] rawMessageId = new byte[sizeof(uint)];
|
||||||
rand.NextBytes(rawMessageId);
|
rand.NextBytes(rawMessageId);
|
||||||
MessageId = BitConverter.ToUInt32(rawMessageId, 0);
|
MessageId = BitConverter.ToUInt32(rawMessageId, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Returns this message in it's raw format that's sent and received over the wire.
|
||||||
|
/// </summary>
|
||||||
|
/// <returns>This message, as a byte array.</returns>
|
||||||
public byte[] AsCompiledCommand()
|
public byte[] AsCompiledCommand()
|
||||||
{
|
{
|
||||||
byte[] message = new byte[HeaderSize + Payload.Length];
|
byte[] message = new byte[HeaderSize + Payload.Length];
|
||||||
|
Buffer.BlockCopy(Header, 0, message, 0, HeaderSize);
|
||||||
|
Buffer.BlockCopy(Payload, 0, message, HeaderSize, Payload.Length);
|
||||||
|
return message;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
|
@ -0,0 +1,29 @@
|
||||||
|
using System;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
|
namespace PixelHub.Server.PixelMessages
|
||||||
|
{
|
||||||
|
public class HandshakeRequestMessage : PixelMessage
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// The type of PixelBot the client thinks it is. Rather like a user-agent string actually.
|
||||||
|
/// </summary>
|
||||||
|
public string PixelBotType = string.Empty;
|
||||||
|
|
||||||
|
public override byte[] Payload {
|
||||||
|
get {
|
||||||
|
return Encoding.UTF8.GetBytes(PixelBotType);
|
||||||
|
}
|
||||||
|
protected set {
|
||||||
|
PixelBotType = Encoding.UTF8.GetString(value);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public new MessageTypes MessageType { get; private set; } = MessageTypes.HandshakeRequest;
|
||||||
|
|
||||||
|
public HandshakeRequestMessage()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
@ -1,12 +1,12 @@
|
||||||
using System;
|
using System;
|
||||||
|
|
||||||
namespace PixelHub.Server.PixelCommands
|
namespace PixelHub.Server.PixelMessages
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Hard-resets the PixelBot. Useful if something has gone wrong, or to reset it's internal state.
|
/// Hard-resets the PixelBot. Useful if something has gone wrong, or to reset it's internal state.
|
||||||
/// Note that this will cause the PixelBot to drop it's connection!
|
/// Note that this will cause the PixelBot to drop it's connection!
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class ResetCommand : PixelCommand
|
public class ResetMessage : PixelMessage
|
||||||
{
|
{
|
||||||
public override byte[] Payload {
|
public override byte[] Payload {
|
||||||
get {
|
get {
|
||||||
|
@ -19,7 +19,7 @@ namespace PixelHub.Server.PixelCommands
|
||||||
|
|
||||||
public new MessageTypes MessageType { get; private set; } = MessageTypes.Reset;
|
public new MessageTypes MessageType { get; private set; } = MessageTypes.Reset;
|
||||||
|
|
||||||
public ResetCommand()
|
public ResetMessage()
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
Reference in a new issue