SpacebrewYun library to the 1.5 format

1 files changed, 0 insertions, 459 deletions

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);						
-		}
-	}
-}
-
-