From af7493f224e12475d496730fbac6061b5f5c1057 Mon Sep 17 00:00:00 2001 From: Fede85 Date: Fri, 6 Sep 2013 18:25:03 +0200 Subject: SpacebrewYun library to the 1.5 format --- libraries/SpacebrewYun/SpacebrewYun.cpp | 459 -------------------------------- 1 file changed, 459 deletions(-) delete mode 100644 libraries/SpacebrewYun/SpacebrewYun.cpp (limited to 'libraries/SpacebrewYun/SpacebrewYun.cpp') diff --git a/libraries/SpacebrewYun/SpacebrewYun.cpp b/libraries/SpacebrewYun/SpacebrewYun.cpp deleted file mode 100644 index 7c848e7..0000000 --- a/libraries/SpacebrewYun/SpacebrewYun.cpp +++ /dev/null @@ -1,459 +0,0 @@ -#include "SpacebrewYun.h" - - -SpacebrewYun::SpacebrewYun(const String& _name, const String& _description) { - name = _name; - description = _description; - subscribers = NULL; - publishers = NULL; - - server = "sandbox.spacebrew.cc"; - port = 9000; - - _connected = false; - _verbose = false; - _error_msg = false; - - sub_name = ""; - sub_msg = ""; - sub_type = ""; - - read_name = false; - read_msg = false; - - for ( int i = 0; i < pidLength; i++ ) { - pid [i] = '\0'; - } - - for ( int i = 0; i < sbPidsLen; i++ ) { - sbPids [i] = '\0'; - } - - Console.buffer(64); - -} - -int SpacebrewYun::sub_msg_int_max = 6; -int SpacebrewYun::sub_msg_bool_max = 5; -int SpacebrewYun::sub_msg_str_max = 50; -int SpacebrewYun::sub_name_max = 20; -SpacebrewYun::OnBooleanMessage SpacebrewYun::_onBooleanMessage = NULL; -SpacebrewYun::OnRangeMessage SpacebrewYun::_onRangeMessage = NULL; -SpacebrewYun::OnStringMessage SpacebrewYun::_onStringMessage = NULL; -SpacebrewYun::OnCustomMessage SpacebrewYun::_onCustomMessage = NULL; -SpacebrewYun::OnSBOpen SpacebrewYun::_onOpen = NULL; -SpacebrewYun::OnSBClose SpacebrewYun::_onClose = NULL; -SpacebrewYun::OnSBError SpacebrewYun::_onError = NULL; - -void SpacebrewYun::onOpen(OnSBOpen function){ - _onOpen = function; -} -void SpacebrewYun::onClose(OnSBClose function){ - _onClose = function; -} -void SpacebrewYun::onRangeMessage(OnRangeMessage function){ - _onRangeMessage = function; -} -void SpacebrewYun::onStringMessage(OnStringMessage function){ - _onStringMessage = function; -} -void SpacebrewYun::onBooleanMessage(OnBooleanMessage function){ - _onBooleanMessage = function; -} -void SpacebrewYun::onCustomMessage(OnCustomMessage function){ - _onCustomMessage = function; -} -void SpacebrewYun::onError(OnSBError function){ - _onError = function; -} - -void SpacebrewYun::addPublish(const String& name, const String& type) { - struct Publisher *p = new Publisher(); - p->name = createString(name.length() + 1); - p->type = createString(type.length() + 1); - p->confirmed = false; - p->time = 0; - if (type == "range") { - p->lastMsg = createString(sub_msg_int_max); - emptyString(p->lastMsg, sub_msg_int_max); - } - else if (type == "boolean") { - p->lastMsg = createString(sub_msg_bool_max); - emptyString(p->lastMsg, sub_msg_bool_max); - } - else { - p->lastMsg = createString(sub_msg_str_max); - emptyString(p->lastMsg, sub_msg_str_max); - } - name.toCharArray(p->name, name.length() + 1); - type.toCharArray(p->type, type.length() + 1); - - if (publishers == NULL){ - publishers = p; - } - else { - struct Publisher *curr = publishers; - int counter = 1; - while(curr->next != NULL){ - curr = curr->next; - counter++; - } - curr->next = p; - } - p->next = NULL; -} - -void SpacebrewYun::addSubscribe(const String& name, const String& type) { - Subscriber *s = new Subscriber(); - s->name = createString(name.length() + 1); - s->type = createString(type.length() + 1); - name.toCharArray(s->name, name.length() + 1); - type.toCharArray(s->type, type.length() + 1); - - if (subscribers == NULL){ - subscribers = s; - } - else { - struct Subscriber *curr = subscribers; - while(curr->next != NULL){ - curr = curr->next; - } - curr->next = s; - } -} - -void SpacebrewYun::connect(String _server, int _port) { - server = _server; - port = _port; - - killPids(); - - brew.begin("run-spacebrew"); // Process should launch the "curl" command - // brew.begin("python"); // Process should launch the "curl" command - // brew.addParameter("/usr/lib/python2.7/spacebrew/spacebrew.py"); // Process should launch the "curl" command - brew.addParameter("--server"); - brew.addParameter(server); - brew.addParameter("--port"); - brew.addParameter(String(port)); - brew.addParameter("-n"); - brew.addParameter(name); - brew.addParameter("-d"); - brew.addParameter(description); - - if (subscribers != NULL) { - struct Subscriber *curr = subscribers; - while(curr != NULL){ - if (_verbose) { - Serial.print(F("Creating subscribers: ")); - Serial.print(curr->name); - Serial.print(F(" of type: ")); - Serial.println(curr->type); - } - - brew.addParameter("-s"); // Add the URL parameter to "curl" - brew.addParameter(curr->name); // Add the URL parameter to "curl" - brew.addParameter(","); // Add the URL parameter to "curl" - brew.addParameter(curr->type); // Add the URL parameter to "curl" - - // if (curr->next == NULL) curr = NULL; - // else curr = curr->next; - - curr = curr->next; - } - } - if (publishers != NULL) { - struct Publisher *curr = publishers; - while(curr != NULL){ - if (_verbose) { - Serial.print(F("Creating publishers: ")); - Serial.print(curr->name); - Serial.print(F(" of type: ")); - Serial.println(curr->type); - } - brew.addParameter("-p"); // Add the URL parameter to "curl" - brew.addParameter(curr->name); // Add the URL parameter to "curl" - brew.addParameter(","); // Add the URL parameter to "curl" - brew.addParameter(curr->type); // Add the URL parameter to "curl" - - curr = curr->next; - } - } - - Console.begin(); - if (_verbose) { - Serial.println(F("Console started ")); - } - - brew.runAsynchronously(); - - if (_verbose) { - Serial.println(F("Brew started ")); - } - while (!Console) { ; } -} - -void SpacebrewYun::monitor() { - while (Console.available() > 0) { - char c = Console.read(); - - if (c == char(CONNECTION_START) && !_connected) { - if (_verbose) { - Serial.print(F("Connected to spacebrew server at: ")); - Serial.println(server); - Serial.print(F("Application name set to: ")); - Serial.println(name); - } - if (_onOpen != NULL){ - _onOpen(); - } - _connected = true; - } - else if (c == char(CONNECTION_END) && _connected) { - _connected = false; - if (_verbose) { - Serial.print(F("Disconnected from spacebrew server at: ")); - Serial.println(server); - } - if (_onClose != NULL){ - _onClose(); - } - } - - if (_verbose) { - if (c == char(CONNECTION_ERROR)) { - _error_msg = true; - Serial.println(F("ERROR :: with Spacebrew.py Connection ::")); - } - else if (_error_msg && c == char(MSG_END)) { - _error_msg = false; - Serial.println(); - } - if (_error_msg) { - Serial.print(c); - } - } - - if (_connected) { - if (c == char(MSG_START)) { - read_name = true; - } else if (c == char(MSG_DIV) || sub_name.length() > sub_name_max) { - read_name = false; - read_msg = true; - } else if (c == char(MSG_END) || sub_msg.length() > sub_msg_str_max) { - if (read_msg == true) { - read_msg = false; - onMessage(); - // delay(2); - } - if (read_confirm == true) { - read_confirm = false; - onConfirm(); - delay(2); - } - } else if (c == char(MSG_CONFIRM)) { - read_confirm = true; - } else { - if (read_name == true) { - sub_name += c; - } else if (read_confirm == true) { - sub_name += c; - } else if (read_msg == true) { - sub_msg += c; - } - else if (_verbose) { - Serial.print(c); - } - } - } - } - - if (publishers != NULL) { - struct Publisher *curr = publishers; - while((curr != NULL)){ - - if ( (curr->confirmed == 0) && ((millis() - curr->time) > 50) ) { - if (_verbose) { - Serial.print(F("resending msg: ")); - Serial.println(curr->name); - } - send(curr->name, curr->lastMsg); - } - curr = curr->next; - } - } - -} - -void SpacebrewYun::onConfirm() { - if (publishers != NULL) { - struct Publisher *curr = publishers; - while((curr != NULL)){ - if (sub_name.equals(curr->name) == true) { - curr->confirmed = true; - // if (_verbose) { - // Serial.print(F("confirmed ")); - // Serial.println(curr->name); - // } - break; - } - curr = curr->next; - } - } - - sub_name = ""; - sub_msg = ""; - sub_type = ""; -} - -boolean SpacebrewYun::connected() { - return SpacebrewYun::_connected; -} - -void SpacebrewYun::verbose(boolean verbose = true) { - _verbose = verbose; -} - -void SpacebrewYun::onMessage() { - if (subscribers != NULL) { - struct Subscriber *curr = subscribers; - while((curr != NULL) && (sub_type == "")){ - if (sub_name.equals(curr->name) == true) { - sub_type = curr->type; - } - curr = curr->next; - } - } - - if ( sub_type.equals("range") ) { - if (_onRangeMessage != NULL) { - _onRangeMessage( sub_name, int(sub_msg.toInt()) ); - } else { - Serial.println(F("ERROR :: Range message received, no callback method is registered")); - } - } else if ( sub_type.equals("boolean") ) { - if (_onBooleanMessage != NULL) { - _onBooleanMessage( sub_name, ( sub_msg.equals("false") ? false : true ) ); - } else { - Serial.println(F("ERROR :: Boolean message received, no callback method is registered")); - } - } else if ( sub_type.equals("string") ) { - if (_onStringMessage != NULL) { - _onStringMessage( sub_name, sub_msg ); - } else { - Serial.println(F("ERROR :: String message received, no callback method is registered")); - } - } else { - if (_onCustomMessage != NULL) { - _onCustomMessage( sub_name, sub_msg, sub_type ); - } else { - Serial.println(F("ERROR :: Custom message received, no callback method is registered")); - } - } - - sub_name = ""; - sub_msg = ""; - sub_type = ""; -} - - -void SpacebrewYun::send(const String& name, const String& value){ - if (publishers != NULL) { - - Console.print(char(29)); - Console.print(name); - Console.print(char(30)); - Console.print(value); - Console.print(char(31)); - Console.flush(); - - struct Publisher *curr = publishers; - while(curr != NULL){ - if (name.equals(curr->name) == true) { - int msg_len = 0; - - if (curr->type == "range") msg_len = sub_msg_int_max; - else if (curr->type == "boolean") msg_len = sub_msg_bool_max; - else msg_len = sub_msg_str_max; - - if (value.length() < msg_len) msg_len = value.length() + 1; - value.toCharArray(curr->lastMsg, msg_len); - - curr->confirmed = false; - curr->time = millis(); - - } - curr = curr->next; - } - } -} - - -/** - * method that gets the pid of all spacebrew.py instances running on the linino. - */ -void SpacebrewYun::getPids() { - - // request the pid of all python processes - // brew.begin("run-getsbpids"); // Process should launch the "curl" command - pids.begin("python"); - pids.addParameter("/usr/lib/python2.7/spacebrew/getprocpid.py"); // Process should launch the "curl" command - pids.run(); - - if (_verbose) { - Serial.println(F("Checking if spacebrew process already running")); - } - - int sbPidsIndex = 0; - int pidCharIndex = 0; - char c = '\0'; - - while ( pids.available() > 0 ) { - - c = pids.read(); - - if ( c >= '0' && c <= '9' ) { - pid[pidCharIndex] = c; - pidCharIndex = (pidCharIndex + 1) % pidLength; - } - - else if ( (c == ' ' || c == '\n') && pidCharIndex > 0) { - sbPids[sbPidsIndex] = atoi(pid); - if ( sbPidsIndex < (sbPidsLen - 1) ) sbPidsIndex = (sbPidsIndex + 1); - - for( int i = 0; i < pidLength; i++ ){ - pid[i] = '\0'; - pidCharIndex = 0; - } - } - } -} - -/** - * method that kills all of the spacebrew.py instances that are running - * on the linino. - */ -void SpacebrewYun::killPids() { - getPids(); - delay(400); - - for (int i = 0; i < sbPidsLen; i ++) { - if (sbPids[i] > 0) { - char * newPID = itoa(sbPids[i], pid, 10); - - if (_verbose) { - Serial.print(F("Stopping existing spacebrew processes with pids: ")); - Serial.println(newPID); - } - - Process p; - p.begin("kill"); - p.addParameter("-9"); - p.addParameter(newPID); // Process should launch the "curl" command - p.run(); // Run the process and wait for its termination - - delay(400); - } - } -} - - -- cgit v1.2.3-18-g5258