summaryrefslogtreecommitdiffstats
path: root/src/http/HTTPClientReceiver.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2011-10-22 00:21:43 +0000
committerDavid Robillard <d@drobilla.net>2011-10-22 00:21:43 +0000
commit14ab4dcff7f8461dfed27b6352249b683c1f4bae (patch)
treef263ecca5c5c2a220bd00c69bba11a03ad266dc5 /src/http/HTTPClientReceiver.cpp
parent91bd13d3767452ba0575d69447f23eed1c508603 (diff)
downloadingen-14ab4dcff7f8461dfed27b6352249b683c1f4bae.tar.gz
ingen-14ab4dcff7f8461dfed27b6352249b683c1f4bae.tar.bz2
ingen-14ab4dcff7f8461dfed27b6352249b683c1f4bae.zip
Move *all* OSC and HTTP stuff to their respective modules.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@3578 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/http/HTTPClientReceiver.cpp')
-rw-r--r--src/http/HTTPClientReceiver.cpp241
1 files changed, 241 insertions, 0 deletions
diff --git a/src/http/HTTPClientReceiver.cpp b/src/http/HTTPClientReceiver.cpp
new file mode 100644
index 00000000..0ec5aaa4
--- /dev/null
+++ b/src/http/HTTPClientReceiver.cpp
@@ -0,0 +1,241 @@
+/* This file is part of Ingen.
+ * Copyright 2008-2011 David Robillard <http://drobilla.net>
+ *
+ * Ingen is free software; you can redistribute it and/or modify it under the
+ * terms of the GNU General Public License as published by the Free Software
+ * Foundation; either version 2 of the License, or (at your option) any later
+ * version.
+ *
+ * Ingen is distributed in the hope that it will be useful, but WITHOUT ANY
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+ * FOR A PARTICULAR PURPOSE. See the GNU General Public License for details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#include <assert.h>
+#include <errno.h>
+#include <string.h>
+#include <sys/socket.h>
+
+#include <libsoup/soup.h>
+
+#include "ingen/shared/World.hpp"
+#include "raul/log.hpp"
+
+#include "HTTPClientReceiver.hpp"
+
+#define LOG(s) s << "[HTTPClientReceiver] "
+
+using namespace std;
+using namespace Raul;
+
+namespace Ingen {
+
+using namespace Serialisation;
+
+namespace Client {
+
+static SoupSession* client_session = NULL;
+static HTTPClientReceiver* client_receiver = NULL;
+
+HTTPClientReceiver::HTTPClientReceiver(
+ Shared::World* world,
+ const std::string& url,
+ SharedPtr<ClientInterface> target)
+ : _target(target)
+ , _world(world)
+ , _url(url)
+{
+ start(false);
+ client_receiver = this;
+}
+
+HTTPClientReceiver::~HTTPClientReceiver()
+{
+ stop();
+ if (client_receiver == this)
+ client_receiver = NULL;
+}
+
+HTTPClientReceiver::Listener::Listener(HTTPClientReceiver* receiver, const std::string& uri)
+ : _uri(uri)
+ , _receiver(receiver)
+{
+ const string port_str = uri.substr(uri.find_last_of(":")+1);
+ int port = atoi(port_str.c_str());
+
+ LOG(info) << "Client HTTP listen: " << uri << " (port " << port << ")" << endl;
+
+ struct sockaddr_in servaddr;
+
+ // Create listen address
+ memset(&servaddr, 0, sizeof(servaddr));
+ servaddr.sin_family = AF_INET;
+ servaddr.sin_port = htons(port);
+
+ // Create listen socket
+ if ((_sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
+ LOG(error) << "Error creating listening socket: %s" << strerror(errno) << endl;
+ _sock = -1;
+ return;
+ }
+
+ // Set remote address (FIXME: always localhost)
+ if (inet_aton("127.0.0.1", &servaddr.sin_addr) <= 0) {
+ LOG(error) << "Invalid remote IP address" << endl;
+ _sock = -1;
+ return;
+ }
+
+ // Connect to server
+ if (connect(_sock, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0) {
+ LOG(error) << "Error calling connect: " << strerror(errno) << endl;
+ _sock = -1;
+ return;
+ }
+}
+
+HTTPClientReceiver::Listener::~Listener()
+{
+ close(_sock);
+}
+
+void
+HTTPClientReceiver::send(SoupMessage* msg)
+{
+ if (!client_session) {
+ LOG(debug) << "Starting session" << endl;
+ client_session = soup_session_sync_new();
+ }
+
+ assert(SOUP_IS_MESSAGE(msg));
+ soup_session_queue_message(client_session, msg, message_callback, client_receiver);
+}
+
+void
+HTTPClientReceiver::close_session()
+{
+ if (client_session) {
+ SoupSession* s = client_session;
+ client_session = NULL;
+ soup_session_abort(s);
+ }
+}
+
+void
+HTTPClientReceiver::update(const std::string& str)
+{
+ //LOG(info) << _world->parser()->parse_update(_world, _target.get(), str, _url);
+}
+
+void
+HTTPClientReceiver::Listener::_run()
+{
+ char in = '\0';
+ char last = '\0';
+ char llast = '\0';
+ string recv;
+
+ while (true) {
+ while (read(_sock, &in, 1) > 0 ) {
+ recv += in;
+ if (in == '\n' && last == '\n' && llast == '\n') {
+ if (!recv.empty()) {
+ _receiver->update(recv);
+ recv.clear();
+ last = '\0';
+ llast = '\0';
+ }
+ break;
+ }
+ llast = last;
+ last = in;
+ }
+ }
+
+ LOG(info) << "HTTP listener finished" << endl;
+}
+
+void
+HTTPClientReceiver::message_callback(SoupSession* session, SoupMessage* msg, void* ptr)
+{
+ if (ptr == NULL)
+ return;
+
+ HTTPClientReceiver* me = (HTTPClientReceiver*)ptr;
+ const string path = soup_message_get_uri(msg)->path;
+
+ if (msg->response_body->data == NULL) {
+ LOG(error) << "Empty client message" << endl;
+ return;
+ }
+
+ if (path == "/") {
+ me->_target->response_ok(0);
+
+ } else if (path == "/plugins") {
+ if (msg->response_body->data == NULL) {
+ LOG(error) << "Empty response" << endl;
+ } else {
+ Glib::Mutex::Lock lock(me->_mutex);
+ me->_target->response_ok(0);
+ me->_world->parser()->parse_string(me->_world, me->_target.get(),
+ Glib::ustring(msg->response_body->data), me->_url);
+ }
+
+ } else if (path.substr(0, 6) == "/patch") {
+ if (msg->response_body->data == NULL) {
+ LOG(error) << "Empty response" << endl;
+ } else {
+ Glib::Mutex::Lock lock(me->_mutex);
+ me->_target->response_ok(0);
+ me->_world->parser()->parse_string(
+ me->_world,
+ me->_target.get(),
+ Glib::ustring(msg->response_body->data),
+ path);
+ }
+
+ } else if (path == "/stream") {
+ if (msg->response_body->data == NULL) {
+ LOG(error) << "Empty response" << endl;
+ } else {
+ Glib::Mutex::Lock lock(me->_mutex);
+ string uri = string(soup_uri_to_string(soup_message_get_uri(msg), false));
+ uri = uri.substr(0, uri.find_last_of(":"));
+ uri += string(":") + msg->response_body->data;
+ LOG(info) << "Stream URI: " << uri << endl;
+ me->_listener = boost::shared_ptr<Listener>(new Listener(me, uri));
+ me->_listener->start();
+ }
+
+ } else {
+ LOG(error) << "Unknown message: " << path << endl;
+ me->update(msg->response_body->data);
+ }
+}
+
+void
+HTTPClientReceiver::start(bool dump)
+{
+ if (!_world->parser())
+ _world->load_module("serialisation");
+
+ SoupMessage* msg = soup_message_new("GET", (_url + "/stream").c_str());
+ assert(SOUP_IS_MESSAGE(msg));
+ soup_session_queue_message(client_session, msg, message_callback, this);
+}
+
+void
+HTTPClientReceiver::stop()
+{
+ //unregister_client();
+ close_session();
+}
+
+} // namespace Client
+} // namespace Ingen
+