From 3d7eea02aa7a155b84c8c74ecbfd55a1941a9297 Mon Sep 17 00:00:00 2001 From: Comment Date: Fri, 26 Jul 2013 22:46:00 +0100 Subject: tidy files --- rotord/rotord.cpp | 230 ------------------------------------------------------ 1 file changed, 230 deletions(-) delete mode 100755 rotord/rotord.cpp (limited to 'rotord/rotord.cpp') diff --git a/rotord/rotord.cpp b/rotord/rotord.cpp deleted file mode 100755 index 6f2d765..0000000 --- a/rotord/rotord.cpp +++ /dev/null @@ -1,230 +0,0 @@ -#include "rotord.h" - -RenderContextHandler::RenderContextHandler(const std::string _content,const HTTPServerResponse::HTTPStatus _status){ - content=_content; - status=_status; -} - - -void RenderContextHandler::handleRequest(HTTPServerRequest& request,HTTPServerResponse& response) { - - response.setChunkedTransferEncoding(true); - response.setContentType("text/html"); - response.setStatus(status); - - std::ostream& ostr = response.send(); - - ostr << "\n"; //this is the mysterious extra header - ostr << content; - -} - - -HTTPRequestHandler* RotorRequestHandlerFactory::createRequestHandler(const HTTPServerRequest& request){ - - - Poco::URI theuri=Poco::URI(request.getURI()); - std::vector command; - theuri.getPathSegments(command); - - Logger& logger = Logger::get("Rotor"); - logger.information(request.clientAddress().toString()+" "+request.getMethod()); - - HTTPResponse::HTTPStatus status=HTTPResponse::HTTP_BAD_REQUEST; //by default - - std::string body; - std::ostringstream os; - os<name()==sID) { - logger.error("ERROR: tried to create thread with existing name "+sID); - XML.addValue("error","Render context /"+sID+"/ exists already"); - found=true; - } - } - if (!found){ - logger.information("starting thread "+sID); - manager.start(new Rotor::Render_context(sID)); - XML.addValue("sID",sID); - status=HTTPResponse::HTTP_OK; - } - } - } - } - else if (command[0]=="list") { - XML.pushTag("rotor"); - if (request.getMethod()=="GET") { - logger.information("sending tasklist"); - //std::list < Poco::AutoPtr < Poco::Task > >::iterator it; - //it=manager.taskList().begin(); - //for (it=manager.taskList().begin();it !=manager.taskList().end();++it) { - //content+=""+(*it)->name()+"\n"; - //} - - //massive problems making an iterator for the tasklist, the above crashes - //solution: auto type range-based for-loop - //this is c++11 specific but works - - for (auto& task: manager.taskList()) { //c++11 - XML.addValue("sID",task->name()); - } - status=HTTPResponse::HTTP_OK; - } - } - else if (command[0]=="exit") { - logger.information("exiting"); - exit(0); - } - else { - bool found=false; - for (auto& task: manager.taskList()) { //c++11 - if(task->name()==command[0]) { - //valid session command - found=true; - XML.addAttribute("rotor","context",task->name(),0); - XML.pushTag("rotor"); - if (command.size()==1) { - //just invoking sID - if (request.getMethod()=="DELETE") { - task->cancel(); - status=HTTPResponse::HTTP_OK; - logger.information("deleted context "+command[0]); - XML.addValue("status","context deleted successfully"); - } - else { - logger.error("ERROR: Render context invoked with no command: "+command[0]); - XML.addValue("error","Render context invoked with no command"); - } - } - else { //session modifier command- to be passed to render context - //some commands need to return error codes - //ie where the audio file isn't found - //on the other hand, some commands need to know state of the renderer? - - - vector sc; //method,id,command1,{command2,}{body} - sc.push_back(request.getMethod()); - for (auto& i: command){ - sc.push_back(i); - } - sc.push_back(body); - - ((Poco::AutoPtr)task)->session_command(sc,XML,status); - - } - } - } - if (!found) { - status=HTTPResponse::HTTP_NOT_FOUND; - logger.error("ERROR: context not found: "+command[0]); - XML.pushTag("rotor"); - XML.addValue("error","Render context not found"); - } - } - } - else { - logger.error("ERROR: Empty request"); - XML.addValue("error","Empty request"); - } - string content; - XML.copyXmlToString(content); - return new RenderContextHandler(content, status); -} - - -RotorServer::RotorServer(): _helpRequested(false) -{ -} - -RotorServer::~RotorServer() -{ -} - -void RotorServer::initialize(Application& self){ - loadConfiguration(); - ServerApplication::initialize(self); -} - -void RotorServer::uninitialize(){ - ServerApplication::uninitialize(); -} - -void RotorServer::defineOptions(OptionSet& options) { - ServerApplication::defineOptions(options); - options.addOption( - Option("help", "h", "display argument help information") - .required(false) - .repeatable(false) - .callback(OptionCallback(this, &RotorServer::handleHelp) - ) - ); -} - -void RotorServer::handleHelp(const std::string& name, const std::string& value){ - HelpFormatter helpFormatter(options()); - helpFormatter.setCommand(commandName()); - helpFormatter.setUsage("OPTIONS"); - helpFormatter.setHeader( - "Rotor"); - helpFormatter.format(std::cout); - stopOptionsProcessing(); - _helpRequested = true; -} - -int RotorServer::main(const std::vector& args){ - if (!_helpRequested) { - - unsigned short port; - - Logger& logger = Logger::get("Rotor"); - - xmlIO xml; - if(xml.loadFile("settings.xml") ){ - port=xml.getAttribute("Rotor","port",9000,0); - } - else logger.information("settings.xml not found, using defaults"); - - logger.information("rotord running on port "+ofToString(port)); - - port = (unsigned short) config().getInt("port", port); //override from command line - - std::string format(config().getString("format", DateTimeFormat::SORTABLE_FORMAT)); - - - - ServerSocket svs(port); - HTTPServer srv(new RotorRequestHandlerFactory(),svs, new HTTPServerParams); - srv.start(); - waitForTerminationRequest(); - srv.stop(); - } - return Application::EXIT_OK; -} - \ No newline at end of file -- cgit v1.2.3