X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fjson_server.cc;h=490f9fc5f6b211321c93b2609acbdc8924901c0f;hp=4af13387510885d701736bc5a5678bd5f7de4d0f;hb=b1dc9c3a2f7e55c9afc5bf2d5b465371b048e14f;hpb=4a0ae92e28d7d1f0dd648d1b620efc324fdef161 diff --git a/src/lib/json_server.cc b/src/lib/json_server.cc index 4af133875..490f9fc5f 100644 --- a/src/lib/json_server.cc +++ b/src/lib/json_server.cc @@ -18,15 +18,16 @@ */ -#include -#include -#include #include "json_server.h" #include "job_manager.h" #include "job.h" #include "util.h" #include "film.h" #include "transcode_job.h" +#include "raw_convert.h" +#include +#include +#include #include using std::string; @@ -151,48 +152,43 @@ JSONServer::request (string url, shared_ptr socket) action = r["action"]; } - locked_stringstream json; + string json; if (action == "status") { list > jobs = JobManager::instance()->get (); - json << "{ \"jobs\": ["; + json += "{ \"jobs\": ["; for (list >::iterator i = jobs.begin(); i != jobs.end(); ++i) { - json << "{ "; + json += "{ "; if ((*i)->film()) { - json << "\"dcp\": \"" << (*i)->film()->dcp_name() << "\", "; + json += "\"dcp\": \"" + (*i)->film()->dcp_name() + "\", "; } - json << "\"name\": \"" << (*i)->json_name() << "\", "; + json += "\"name\": \"" + (*i)->json_name() + "\", "; if ((*i)->progress ()) { - json << "\"progress\": " << (*i)->progress().get() << ", "; + json += "\"progress\": " + raw_convert((*i)->progress().get()) + ", "; } else { - json << "\"progress\": unknown, "; + json += "\"progress\": unknown, "; } - json << "\"status\": \"" << (*i)->json_status() << "\""; - json << " }"; + json += "\"status\": \"" + (*i)->json_status() + "\""; + json += " }"; list >::iterator j = i; ++j; if (j != jobs.end ()) { - json << ", "; + json += ", "; } } - json << "] }"; - - if (json.str().empty ()) { - json << "{ }"; - } + json += "] }"; } - locked_stringstream reply; - reply << "HTTP/1.1 200 OK\r\n" - << "Content-Length: " << json.str().length() << "\r\n" - << "Content-Type: application/json\r\n" - << "\r\n" - << json.str () << "\r\n"; - cout << "reply: " << json.str() << "\n"; - boost::asio::write (*socket, boost::asio::buffer (reply.str().c_str(), reply.str().length())); + string reply = "HTTP/1.1 200 OK\r\n" + "Content-Length: " + raw_convert(json.length()) + "\r\n" + "Content-Type: application/json\r\n" + "\r\n" + + json + "\r\n"; + cout << "reply: " << json << "\n"; + boost::asio::write (*socket, boost::asio::buffer (reply.c_str(), reply.length())); }