aboutsummaryrefslogtreecommitdiff
path: root/libraries/SpacebrewYun/SpacebrewYun.h
diff options
context:
space:
mode:
Diffstat (limited to 'libraries/SpacebrewYun/SpacebrewYun.h')
-rw-r--r--libraries/SpacebrewYun/SpacebrewYun.h137
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