aboutsummaryrefslogtreecommitdiff
path: root/channel.lua
blob: 2885e68bddb5da739df3b068ba7f46e174dcb335 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
-- bi-directional http-channel
-- with long-poll GET and POST on the same URL

local debug = true

local function Channel(http, url, cfg)
	cfg = cfg or {}
	local extra_headers = cfg.extra_headers or {}
	local timeout = cfg.timeout or 1
	local long_poll_timeout = cfg.long_poll_timeout or 30
	local error_retry = cfg.error_retry or 10

	-- assemble post-header with json content
	local post_headers = { "Content-Type: application/json" }
	for _,header in pairs(cfg.extra_headers) do
		table.insert(post_headers, header)
	end

	local recv_listeners = {}
	local run = true

	local recv_loop

	recv_loop = function()
		assert(run)

		-- long-poll GET
		http.fetch({
			url = url,
			extra_headers = extra_headers,
			timeout = long_poll_timeout
		}, function(res)
			if res.succeeded and res.code == 200 then
				local data = minetest.parse_json(res.data)

				if debug then
					minetest.log("action", "[webmail-rx] " .. dump(data))
				end

				if data then
					for _,listener in pairs(recv_listeners) do
						listener(data)
					end
				end
				-- reschedule immediately
				minetest.after(0, recv_loop)
			else
				-- error, retry after some time
				minetest.after(error_retry, recv_loop)
			end
		end)
	end


	local send = function(data)
		assert(run)
		-- POST

		if debug then
			minetest.log("action", "[webmail-tx] " .. dump(data))
		end

		http.fetch({
			url = url,
			extra_headers = post_headers,
			timeout = timeout,
			post_data = minetest.write_json(data)
		}, function(res)
			-- TODO: error-handling
		end)
	end

	local receive = function(listener)
		table.insert(recv_listeners, listener)
	end

	local close = function()
		run = false
	end

	recv_loop();

	return {
		send = send,
		receive = receive,
		close = close
	}

end



return Channel