#include "processmodel.h"
//1. make a basic executable that represents a render context
//get message passing going
//incorporate in REST server
//fill in the details
RotorRequestHandler::RotorRequestHandler(const std::string& format): _format(format){
}
void RotorRequestHandler::handleRequest(HTTPServerRequest& request,HTTPServerResponse& response) {
Timestamp now;
std::string dt(DateTimeFormatter::format(now, _format));
response.setChunkedTransferEncoding(true);
response.setContentType("text/html");
std::ostream& ostr = response.send();
ostr << "RotorServer powered by "
"POCO C++ Libraries";
ostr << "";
ostr << "";
ostr << dt;
ostr << "
";
}
AudioAnalyserHandler::AudioAnalyserHandler(const vampHost::Settings& _settings): settings(_settings){
}
void AudioAnalyserHandler::handleRequest(HTTPServerRequest& request,HTTPServerResponse& response) {
response.setChunkedTransferEncoding(true);
response.setContentType("text/html");
//string audioData=vampHost::runPlugin();
std::ostream& ostr = response.send();
ostr << "RotorServer powered by "
"POCO C++ Libraries";
ostr << "";
ostr << "";
vampHost::runPlugin("",settings.soname,settings.filtername, "",0, settings.inputFile, ostr,true);
ostr << "
";
}
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";
ostr << content;
}
HTTPRequestHandler* RotorRequestHandlerFactory::createRequestHandler(const HTTPServerRequest& request){
Application& app = Application::instance();
Poco::URI theuri=Poco::URI(request.getURI());
std::vector command;
theuri.getPathSegments(command);
app.logger().information(request.clientAddress().toString()+" "+request.getMethod());
string content="";
HTTPResponse::HTTPStatus status=HTTPResponse::HTTP_BAD_REQUEST; //by default
std::string body;
std::ostringstream os;
os<\n";
status=HTTPResponse::HTTP_OK;
}
if (request.getMethod()=="PUT") { //undocumented manual thread name
if (body.size()) {
string sID=body;
cerr << "Rotor: starting thread "<< sID << endl;
manager.start(new Rotor::Render_context(sID));
content=""+sID+"\n";
status=HTTPResponse::HTTP_OK;
}
}
}
else if (command[0]=="list") {
if (request.getMethod()=="GET") {
//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
content+=""+task->name()+" \n";
}
status=HTTPResponse::HTTP_OK;
}
}
else if (command[0]=="styles") {
//eventually retrieve from sql;
//a bit of weirdness here: prefer to just get whole file to a string.
if (request.getMethod()=="GET") {
std::string stylesfile = "styles.xml";
Poco::File f=Poco::File(stylesfile);
if (f.exists()) {
Poco::FileInputStream file(stylesfile);
//while (!file.eof()) {
// file >> content;
//}
Poco::StreamCopier::copyToString(file, content);
status=HTTPResponse::HTTP_OK;
}
else {
content="Rotor: internal error: styles not found\n";
}
}
else {
content="Rotor: bad request\n";
}
}
else if (command[0]=="exit") {
exit(0);
}
else {
bool found=false;
for (auto& task: manager.taskList()) { //c++11
if(task->name()==command[0]) {
//valid session command
found=true;
if (command.size()==1) {
//just invoking sID
if (request.getMethod()=="DELETE") {
task->cancel();
content="1\n";
status=HTTPResponse::HTTP_OK;
}
else {
content="Rotor: render context invoked with no command\n";
}
}
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);
Rotor::Command_response response=((Poco::AutoPtr)task)->session_command(sc);
content=response.description;
status=response.status;
}
}
}
if (!found) {
status=HTTPResponse::HTTP_NOT_FOUND;
content="Rotor: render context not found\n";
}
}
}
else {
content="Rotor: empty request";
}
*/
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 main(int argc, char** argv)
{
std::vector args;
args.push_back("-ax");
if (argc>1) {
std::string cmd=std::string(argv[1]);
Poco::Pipe outPipe;
Poco::Pipe inPipe;
ProcessHandle ph = Process::launch(cmd, args, &inPipe, &outPipe, 0);
Poco::PipeInputStream istr(outPipe);
Poco::PipeOutputStream ostr(inPipe);
//std::ofstream ostr("processes.txt");
//
while (true){
Poco::StreamCopier::copyStream(istr,std::cout);
//ostr<& args){
if (!_helpRequested) {
unsigned short port;
xmlIO xml;
if(xml.loadFile("settings.xml") ){
port=xml.getAttribute("Rotor","port",9980,0);
}
else cerr<<"Rotord: settings.xml not found, using defaults"<