FlightGear - "; response += request; response += "

#include

#include "httpd.hxx" SG_USING_STD(string); #if !defined(SG_HAVE_NATIVE_SGI_COMPILERS) SG_USING_STD(cout); SG_USING_STD(istrstream); #endif bool FGHttpd::open() { if ( is_enabled() ) { SG_LOG( SG_IO, SG_ALERT, "This shouldn't happen, but the channel " << "is already in use, ignoring" ); return false; } server = new HttpdServer( port ); set_hz( 5 ); // default to processing requests @ 5Hz set_enabled( true ); return true; } bool FGHttpd::process() { netChannel::poll(); return true; } bool FGHttpd::close() { delete server; return true; } // Handle http GET requests void HttpdChannel::foundTerminator (void) { closeWhenDone (); const string s = buffer.getData(); if ( s.find( "GET " ) == 0 ) { printf("echo: %s\n", s.c_str()); string rest = s.substr(4); string request; string tmp; unsigned int pos = rest.find( " " ); if ( pos != string::npos ) { request = rest.substr( 0, pos ); } else { request = "/"; } SGPropertyNode *node = NULL; pos = request.find( "?" ); if ( pos != string::npos ) { // request to update property value string args = request.substr( pos + 1 ); request = request.substr( 0, pos ); printf("'%s' '%s'\n", request.c_str(), args.c_str()); request = urlDecode(request); // parse args looking for "value=" bool done = false; while ( ! done ) { string arg; pos = args.find("&"); if ( pos != string::npos ) { arg = args.substr( 0, pos ); args = args.substr( pos + 1 ); } else { arg = args; done = true; } printf(" arg = %s\n", arg.c_str() ); unsigned int apos = arg.find("="); if ( apos != string::npos ) { string a = arg.substr( 0, apos ); string b = arg.substr( apos + 1 ); printf(" a = %s b = %s\n", a.c_str(), b.c_str() ); if ( a == "value" ) { fgSetString( request, urlDecode(b) ); } } } } else { request = urlDecode(request); } node = globals->get_props()->getNode(request); string response = ""; response += ""; response += getTerminator(); response += ""; response += getTerminator(); response += "FlightGear - "; response += request; response += ""; response += getTerminator(); response += ""; response += getTerminator(); response += ""; response += getTerminator(); if (node == NULL) { response += "

Non-existent node requested!

"; response += getTerminator(); response += ""; response += request.c_str(); response += " does not exist."; response += getTerminator(); } else if ( node->nChildren() > 0 ) { // request is a path with children response += "

Contents of \""; response += request; response += "\"

"; response += getTerminator(); for (int i = 0; i < node->nChildren(); i++) { SGPropertyNode *child = node->getChild(i); string name = child->getName(); if ( node->getChild(name, 1) ) { char buf[16]; sprintf(buf, "[%d]", child->getIndex()); name += buf; } string line = ""; if ( child->nChildren() > 0 ) { line += ""; line += name; line += ""; line += "/
"; } else { string value = node->getStringValue ( name, "" ); line += ""; line += name; line += " ("; line += value; line += ")
"; } response += line; response += getTerminator(); } } else { // request for an individual data member string value = node->getStringValue(); response += ""; } response += ""; response += getTerminator(); response += ""; response += getTerminator(); push( "HTTP/1.1 200 OK" ); push( getTerminator() ); printf("size = %d\n", response.length()); char ctmp[256]; sprintf(ctmp, "Content-Length: %d", response.length()); push( ctmp ); push( getTerminator() ); push( "Connection: close" ); push( getTerminator() ); push( "Content-Type: text/html" ); push( getTerminator() ); push( getTerminator() ); push( response.c_str() ); } buffer.remove(); } // encode everything but "a-zA-Z0-9_.-/" (see RFC2396) string HttpdChannel::urlEncode(string s) { string r = ""; for ( int i = 0; i < (int)s.length(); i++ ) { if ( isalnum(s[i]) || s[i] == '_' || s[i] == '.' || s[i] == '-' || s[i] == '/' ) { r += s[i]; } else { char buf[16]; sprintf(buf, "%%%02X", (unsigned char)s[i]); r += buf; } } return r; } string HttpdChannel::urlDecode(string s) { string r = ""; int max = s.length(); int a, b; for ( int i = 0; i < max; i++ ) { if ( s[i] == '+' ) { r += ' '; } else if ( s[i] == '%' && i + 2 < max && isxdigit(s[i + 1]) && isxdigit(s[i + 2]) ) { i++; a = isdigit(s[i]) ? s[i] - '0' : toupper(s[i]) - 'A' + 10; i++; b = isdigit(s[i]) ? s[i] - '0' : toupper(s[i]) - 'A' + 10; r += (char)(a * 16 + b); } else { r += s[i]; } } return r; }