#include "rotord.h"
/*
ultimately- audio analysis request will spawn a task - there will be another call that will check progress
audio analysis will be saved - to a file? into a db?
for now - dump analysis into the http request
architecture - running rendering process
main vamp library segmenter, beat detector
http://127.0.0.1:9000/vamp/qm-vamp-plugins/qm-segmenter/01.wav
Running plugin: "qm-segmenter"...
Using block size = 26460, step size = 8820
Plugin accepts 1 -> 1 channel(s)
Sound file has 2 (will mix/augment if necessary)
Output is: "segmentation"
Done
./rotord: symbol lookup error: /usr/local/lib/vamp/qm-vamp-plugins.so: undefined symbol: clapack_dgetrf
next:
load a movie and retreive frames
save a movie
how do we deal with frames in libavcodec - can we request a frame by number
how do we deal with resolution
*/
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 << "
";
}
RotorRequestHandlerFactory::RotorRequestHandlerFactory(const std::string& format):_format(format){
}
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::vector _command): command(_command){
}
void RenderContextHandler::handleRequest(HTTPServerRequest& request,HTTPServerResponse& response) {
response.setChunkedTransferEncoding(true);
response.setContentType("text/html");
std::ostream& ostr = response.send();
string content;
if (command.size()) {
if (command[0]=="new") {
Poco:UUID sID=idGen.create();
context[sID]=new Rotor::Render_context();
context[sID].run();
content=""+sID.toString()+"";
}
else {
Poco:UUID sID;
if (sID.tryParse(command[0]) {
iterator iter = context.find(sID);
if (iter!=context.end()) {
//successfully located context
if (command.size()==1) {
//just invoking sID
if (request.getMethod()=="DELETE") {
}
}
else {
}
}
else {
resp.setStatus(HTTPResponse::HTTP_NOT_FOUND);
content="Rotor: render context not found";
}
}
else resp.setStatus(HTTPResponse::HTTP_BAD_REQUEST);
content="Rotor: command not found";
}
}
else {
content="Rotor: empty request";
}
ostr << "";
ostr << content;
}
HTTPRequestHandler* RotorRequestHandlerFactory::createRequestHandler(const HTTPServerRequest& request){
Application& app = Application::instance();
Poco::URI theuri=Poco::URI(request.getURI());
std::vector segments;
theuri.getPathSegments(segments);
std::ostringstream ostr;
ostr << segments.size();
std::string out;
for (uint i=0;i3) {
// vamp/plugin/filter/filename
// how do deal with error condition?
//Settings(string _so="",string _filter="",string _id="",string _input="");
return new AudioAnalyserHandler(vampHost::Settings(segments[1],segments[2],segments[3]));
//string audioData=runPlugin(string myname, string soname, string id,
// string output, int outputNo, string wavname,
// string outfilename, bool useFrames);
return 0;
}
else if (segments[0]=="new") {
// create a new render context
return 0;
}
else {
return 0;
}
*/
return new RenderContextHandler(segments);
//at this point we are within app
//making a new contexthandler?
//how will this have access to the thread that it refers to
//how will messages be passed
//we need to do testing etc here and
}
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 = (unsigned short) config().getInt("port", 9980);
std::string format(config().getString("format", DateTimeFormat::SORTABLE_FORMAT));
ServerSocket svs(port);
HTTPServer srv(new RotorRequestHandlerFactory(format),svs, new HTTPServerParams);
srv.start();
waitForTerminationRequest();
srv.stop();
}
return Application::EXIT_OK;
}