Comparison

mod_json_streams: Add BOSH support (on HTTP path "/jsonstreams").

author	Waqas Hussain <waqas20@gmail.com>
date	Sat, 02 Apr 2011 03:10:04 +0500
parent	349:ee99eafdd168

comparison

equal deleted inserted replaced

-:ee99eafdd168
+:98569ec25ac2
 -- XEP-0295: JSON Encodings for XMPP
 --
 module.host = "*"
+local httpserver = require "net.httpserver";
 local filters = require "util.filters"
 local json = require "util.json"
 local json_escapes = {
 	["\""] = "\\\"", ["\\"] = "\\\\", ["\b"] = "\\b", ["\f"] = "\\f",
 end
 function module.unload()
 	filters.remove_filter_hook(filter_hook);
 end
+function encode(data)
+	if type(data) == "string" then
+		data = json.encode({ s = data });
+	elseif type(data) == "table" and data.body then
+		data.body = json.encode({ s = data.body });
+		data.headers["Content-Type"] = "application/json";
+	end
+	return data;
+end
+function handle_request(method, body, request)
+	local mod_bosh = modulemanager.get_module("*", "bosh")
+	if mod_bosh then
+		if body and method == "POST" then
+			pcall(function() body = json.decode(body).s; end);
+		end
+		local _send = request.send;
+		function request:send(data) return _send(self, encode(data)); end
+		return encode(mod_bosh.handle_request(method, body, request));
+	end
+	return "<html><body>mod_bosh not loaded</body></html>";
+end
+local function setup()
+	local ports = module:get_option("jsonstreams_ports") or { 5280 };
+	httpserver.new_from_config(ports, handle_request, { base = "jsonstreams" });
+end
+if prosody.start_time then -- already started
+	setup();
+else
+	prosody.events.add_handler("server-started", setup);
+end