1 files changed, 85 insertions, 0 deletions
diff --git a/src/http/HTTPClientReceiver.hpp b/src/http/HTTPClientReceiver.hpp
new file mode 100644
index 00000000..d7165c81
--- /dev/null
+++ b/src/http/HTTPClientReceiver.hpp
@@ -0,0 +1,85 @@
+/* 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
+ */
+
+#ifndef INGEN_CLIENT_HTTPCLIENTRECEIVER_HPP
+#define INGEN_CLIENT_HTTPCLIENTRECEIVER_HPP
+
+#include <cstdlib>
+
+#include <boost/utility.hpp>
+#include <glibmm/thread.h>
+
+#include "ingen/ClientInterface.hpp"
+#include "ingen/serialisation/Parser.hpp"
+#include "raul/Deletable.hpp"
+#include "raul/SharedPtr.hpp"
+#include "raul/Thread.hpp"
+#include "sord/sordmm.hpp"
+
+typedef struct _SoupSession SoupSession;
+typedef struct _SoupMessage SoupMessage;
+
+namespace Ingen {
+namespace Client {
+
+class HTTPClientReceiver : public boost::noncopyable, public Raul::Deletable
+{
+public:
+	HTTPClientReceiver(Shared::World*             world,
+	                   const std::string&         url,
+	                   SharedPtr<ClientInterface> target);
+
+	~HTTPClientReceiver();
+
+	static void send(SoupMessage* msg);
+	static void close_session();
+
+	std::string uri() const { return _url; }
+
+	void start(bool dump);
+	void stop();
+
+private:
+	static void message_callback(SoupSession* session, SoupMessage* msg, void* ptr);
+
+	void update(const std::string& str);
+
+	class Listener : public Raul::Thread {
+	public:
+		Listener(HTTPClientReceiver* receiver, const std::string& uri);
+		~Listener();
+		void _run();
+	private:
+		std::string         _uri;
+		int                 _sock;
+		HTTPClientReceiver* _receiver;
+	};
+
+	friend class Listener;
+
+	SharedPtr<Listener>        _listener;
+	Glib::Mutex                _mutex;
+	SharedPtr<ClientInterface> _target;
+	Shared::World*             _world;
+	const std::string          _url;
+	bool                       _quit_flag;
+};
+
+} // namespace Client
+} // namespace Ingen
+
+#endif // INGEN_CLIENT_HTTPCLIENTRECEIVER_HPP