mirror of
https://github.com/arduino/Arduino.git
synced 2025-01-22 11:52:14 +01:00
123 lines
2.8 KiB
C++
123 lines
2.8 KiB
C++
|
|
#ifndef YUNSPACEBREW_H
|
|
#define YUNSPACEBREW_H
|
|
|
|
#include "Arduino.h"
|
|
#include <Bridge.h>
|
|
#include <Console.h>
|
|
#include <Process.h>
|
|
|
|
enum SBmsg {
|
|
CONNECTION_START = char(28),
|
|
CONNECTION_END = char(27),
|
|
CONNECTION_ERROR = char(26),
|
|
MSG_START = char(29),
|
|
MSG_DIV = char(30),
|
|
MSG_END = char(31)
|
|
};
|
|
|
|
struct Publisher {
|
|
char *name;
|
|
char *type;
|
|
char *defaultValue;
|
|
Publisher * next;
|
|
};
|
|
|
|
struct Subscriber{
|
|
char *name;
|
|
char *type;
|
|
Subscriber * next;
|
|
};
|
|
|
|
int const pidLength = 6;
|
|
int const sbPidsLen = 4;
|
|
|
|
class SpacebrewYun {
|
|
|
|
public:
|
|
|
|
SpacebrewYun(const String&, const String&);
|
|
void addPublish(const String&, const String&);
|
|
void addSubscribe(const String&, const String&);
|
|
|
|
void connect(String, int);
|
|
void connect() { connect(server, port); };
|
|
void connect(String _server) { connect(String(_server), port); };
|
|
|
|
void monitor();
|
|
void onMessage();
|
|
|
|
boolean connected();
|
|
|
|
void send(const String&, const String&);
|
|
void send(const String& name, char * value) { send(name, String(value)); }
|
|
void send(const String& name, bool value){ send(name, (value ? "true" : "false")); };
|
|
void send(const String& name, int value) { send(name, String(value)); };
|
|
void send(const String& name, long value) { send(name, String(value)); };
|
|
void send(const String& name, float value) { send(name, String(value)); };
|
|
|
|
void verbose(boolean);
|
|
|
|
typedef void (*OnBooleanMessage)(String name, boolean value);
|
|
typedef void (*OnRangeMessage)(String name, int value);
|
|
typedef void (*OnStringMessage)(String name, String value);
|
|
typedef void (*OnCustomMessage)(String name, String value, String type);
|
|
typedef void (*OnSBOpen)();
|
|
typedef void (*OnSBClose)();
|
|
typedef void (*OnSBError)(int code, String message);
|
|
|
|
void onOpen(OnSBOpen function);
|
|
void onClose(OnSBClose function);
|
|
void onRangeMessage(OnRangeMessage function);
|
|
void onStringMessage(OnStringMessage function);
|
|
void onBooleanMessage(OnBooleanMessage function);
|
|
void onCustomMessage(OnCustomMessage function);
|
|
void onError(OnSBError function);
|
|
|
|
private:
|
|
|
|
Process brew;
|
|
String name;
|
|
String server;
|
|
String description;
|
|
boolean _connected;
|
|
boolean _error_msg;
|
|
boolean _verbose;
|
|
int port;
|
|
|
|
/**Output should be at least 5 cells**/
|
|
static OnBooleanMessage _onBooleanMessage;
|
|
static OnRangeMessage _onRangeMessage;
|
|
static OnStringMessage _onStringMessage;
|
|
static OnCustomMessage _onCustomMessage;
|
|
static OnSBOpen _onOpen;
|
|
static OnSBClose _onClose;
|
|
static OnSBError _onError;
|
|
|
|
Subscriber * subscribers;
|
|
Publisher * publishers;
|
|
String sub_name;
|
|
String sub_msg;
|
|
String sub_type;
|
|
|
|
boolean read_name;
|
|
boolean read_msg;
|
|
int sub_name_max;
|
|
int sub_msg_max;
|
|
|
|
Process pids;
|
|
char pid [6];
|
|
int sbPids [4];
|
|
|
|
void killPids();
|
|
void getPids();
|
|
|
|
static char * createString(int len){
|
|
char * out = ( char * )malloc( len + 1 );
|
|
return out;
|
|
}
|
|
|
|
};
|
|
|
|
#endif
|