diff options
Diffstat (limited to 'libraries/SpacebrewYun/SpacebrewYun.h')
-rw-r--r-- | libraries/SpacebrewYun/SpacebrewYun.h | 137 |
1 files changed, 0 insertions, 137 deletions
diff --git a/libraries/SpacebrewYun/SpacebrewYun.h b/libraries/SpacebrewYun/SpacebrewYun.h deleted file mode 100644 index df608c1..0000000 --- a/libraries/SpacebrewYun/SpacebrewYun.h +++ /dev/null @@ -1,137 +0,0 @@ - -#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_CONFIRM = char(7), - MSG_START = char(29), - MSG_DIV = char(30), - MSG_END = char(31) -}; - -struct Publisher { - char *name; - char *type; - char *lastMsg; - Publisher *next; - int confirmed; - long time; -}; - -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(); - void onConfirm(); - - 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 ? String("true") : String("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; - boolean read_confirm; - static int sub_name_max; - static int sub_msg_str_max; - static int sub_msg_int_max; - static int sub_msg_bool_max; - // int sub_name_max; - // int sub_msg_str_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; - } - - static void emptyString(char * str, int len){ - for (int i = 0; i < len; i++) { - str[i] = '\0'; - } - } - -}; - -#endif |