Compare commits
2 commits
9569e2c59b
...
98daa35b46
Author | SHA1 | Date | |
---|---|---|---|
98daa35b46 | |||
42baddcf97 |
6 changed files with 117 additions and 9 deletions
17
PixelHub-Client-Test/PixelHub-Client-Test.sln
Normal file
17
PixelHub-Client-Test/PixelHub-Client-Test.sln
Normal file
|
@ -0,0 +1,17 @@
|
||||||
|
|
||||||
|
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||||
|
# Visual Studio 2012
|
||||||
|
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PixelHub-Client-Test", "PixelHub-Client-Test\PixelHub-Client-Test.csproj", "{1D99DDDB-9457-4B8D-83B8-06663554F4C4}"
|
||||||
|
EndProject
|
||||||
|
Global
|
||||||
|
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||||
|
Debug|x86 = Debug|x86
|
||||||
|
Release|x86 = Release|x86
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||||
|
{1D99DDDB-9457-4B8D-83B8-06663554F4C4}.Debug|x86.ActiveCfg = Debug|x86
|
||||||
|
{1D99DDDB-9457-4B8D-83B8-06663554F4C4}.Debug|x86.Build.0 = Debug|x86
|
||||||
|
{1D99DDDB-9457-4B8D-83B8-06663554F4C4}.Release|x86.ActiveCfg = Release|x86
|
||||||
|
{1D99DDDB-9457-4B8D-83B8-06663554F4C4}.Release|x86.Build.0 = Release|x86
|
||||||
|
EndGlobalSection
|
||||||
|
EndGlobal
|
|
@ -95,11 +95,50 @@ void PixelBot::FindServer()
|
||||||
Serial.println();
|
Serial.println();
|
||||||
|
|
||||||
// If the advertiser isn't playing the role of a server, then we're not interested
|
// If the advertiser isn't playing the role of a server, then we're not interested
|
||||||
if(role != "server") continue;
|
if(strcmp(role, desiredRemoteRole) != 0)
|
||||||
|
{
|
||||||
|
Serial.print("Incompatible role "); Serial.print(role); Serial.println(".");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
Serial.println("Role ok!");
|
||||||
serverPort = atoi(serverPortText);
|
serverPort = atoi(serverPortText);
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
bool PixelBot::Connect()
|
||||||
|
{
|
||||||
|
Serial.print("Connecting to "); Serial.print(serverIp); Serial.print(":"); Serial.print(serverPort); Serial.print(" - ");
|
||||||
|
if(!tcpClient.connect(serverIp, serverPort)) {
|
||||||
|
Serial.println("failed!");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
Serial.println("success!");
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
void PixelBot::Listen()
|
||||||
|
{
|
||||||
|
while(true) {
|
||||||
|
if(!Tick()) {
|
||||||
|
Serial.println("[PixelBot/Server] Exiting main loop.");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
bool PixelBot::Tick()
|
||||||
|
{
|
||||||
|
// Make sure that there's something to read
|
||||||
|
if(tcpClient.available() == 0) {
|
||||||
|
delay(10);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
String nextLine = tcpClient.readStringUntil('\n');
|
||||||
|
Serial.print(" > "); Serial.println(nextLine);
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
|
@ -3,31 +3,60 @@
|
||||||
#include <ESP8266WiFi.h>
|
#include <ESP8266WiFi.h>
|
||||||
#include <WiFiUdp.h>
|
#include <WiFiUdp.h>
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Connects to a PixelHub server, receives commands, and acts upon them.
|
||||||
|
/// </summmary>
|
||||||
class PixelBot
|
class PixelBot
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
PixelBot();
|
PixelBot();
|
||||||
~PixelBot();
|
~PixelBot();
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Listens for beacon pings that reveal the location of the PixelHub server.
|
||||||
|
/// </summary>
|
||||||
|
/// <description>
|
||||||
|
/// Upon receiving a ping it parses the message to figure out the location of the PixelHub server.
|
||||||
|
/// Once done it fills out a few private variables ready for the TCP connection.
|
||||||
|
/// </description>
|
||||||
void FindServer();
|
void FindServer();
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Connects the TCP transport connection to the PixelHub server.
|
||||||
|
/// </summary>
|
||||||
|
bool Connect();
|
||||||
|
/// <summary>
|
||||||
|
/// Starts the main listening loop that handles commands from the PixelHub server.
|
||||||
|
/// </summary>
|
||||||
|
void Listen();
|
||||||
|
/// <summary>
|
||||||
|
/// Performs a single tick of the listen loop.
|
||||||
|
/// Very useful if you want to do other things at the same time as handling commands from the PixelHub server.
|
||||||
|
/// </summary>
|
||||||
|
bool Tick();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
// ~~~ Manual Settings ~~~ //
|
||||||
|
char desiredRemoteRole[7] = { 's', 'e', 'r', 'v', 'e', 'r', '\0' };
|
||||||
|
// ~~~ Automatic Settings ~~~ //
|
||||||
|
// The IP address of the remote PixelHub server. Autofilled by the FindServer() method.
|
||||||
char serverIp[16];
|
char serverIp[16];
|
||||||
|
// The port number that the PixelHub server is running on. Autofilled by the FindServer() method.
|
||||||
int serverPort = -1;
|
int serverPort = -1;
|
||||||
|
|
||||||
// ~~~ Auto Discovery System ~~~ //
|
// ~~~ Auto Discovery System ~~~ //
|
||||||
|
|
||||||
// The address that the PixelHub beacon is broadcasting on.
|
// The multicast address that the PixelHub beacon is broadcasting on.
|
||||||
IPAddress beaconAddress = IPAddress(239, 62, 148, 30);
|
IPAddress beaconAddress = IPAddress(239, 62, 148, 30);
|
||||||
// The port number that the PixelHub beacon is broadcasting on.
|
// The multicast port number that the PixelHub beacon is broadcasting on.
|
||||||
unsigned int beaconPort = 5050;
|
unsigned int beaconPort = 5050;
|
||||||
|
|
||||||
// The size of the datagram buffer that is used to buffer incoming messages.
|
// The size of the datagram buffer that is used to buffer incoming messages.
|
||||||
int datagramBufferSize = 256;
|
int datagramBufferSize = 256;
|
||||||
|
|
||||||
// ~~~ ~~~ //
|
// ~~~ PixelHub Server Client ~~~ //
|
||||||
|
|
||||||
// The TCP client
|
// The TCP client to use as the PixelHub server transport connection.
|
||||||
WiFiClient tcpClient = WiFiClient();
|
WiFiClient tcpClient = WiFiClient();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
|
@ -37,12 +37,13 @@ void setup()
|
||||||
|
|
||||||
printWiFiInfoLocal();
|
printWiFiInfoLocal();
|
||||||
pixelBot.FindServer();
|
pixelBot.FindServer();
|
||||||
|
pixelBot.Connect();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
void loop()
|
void loop()
|
||||||
{
|
{
|
||||||
|
pixelBot.Tick();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -1,5 +1,9 @@
|
||||||
//#include <string.h>
|
//#include <string.h>
|
||||||
//#include <algorithm>
|
//#include <algorithm>
|
||||||
|
#include <stdlib.h>
|
||||||
|
|
||||||
|
#include "Utilities.h"
|
||||||
|
#include "Arduino.h"
|
||||||
|
|
||||||
int findChar(char* str, char targetChar)
|
int findChar(char* str, char targetChar)
|
||||||
{
|
{
|
||||||
|
@ -16,3 +20,13 @@ int getPosition(const char *array, size_t size, char c)
|
||||||
return (end == match)? -1 : (match-array);
|
return (end == match)? -1 : (match-array);
|
||||||
}
|
}
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
void Utilities::PrintCharsAsHex(char* charArray, size_t length)
|
||||||
|
{
|
||||||
|
for(int i = 0; i < length; i++)
|
||||||
|
{
|
||||||
|
Serial.print((int)(charArray[i]), HEX);
|
||||||
|
Serial.print(" ");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
|
@ -9,7 +9,15 @@
|
||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
|
#include <stdlib.h>
|
||||||
|
|
||||||
int findChar(char* str, char targetChar);
|
int findChar(char* str, char targetChar);
|
||||||
|
|
||||||
int getPosition(const char *array, int size, char c);
|
int getPosition(const char *array, int size, char c);
|
||||||
|
|
||||||
|
class Utilities
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
static void PrintCharsAsHex(char* charArray, size_t length);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
Reference in a new issue