Mercurial > lxmppd-hg-xmllex / file comparison
comparison: plugins/mod_actions_http.lua
plugins/mod_actions_http.lua
- changeset 709
- 8bb83563cb21
- parent 700
- 9666ad50a353
- child 1522
- 569d58d21612
equal
deleted
inserted
replaced
| 708:b72d408f5f15 | 709:8bb83563cb21 |
|---|---|
| 1 | |
| 2 local httpserver = require "net.httpserver"; | |
| 3 local t_concat, t_insert = table.concat, table.insert; | |
| 4 | |
| 5 local log = log; | |
| 6 | |
| 7 local response_404 = { status = "404 Not Found", body = "<h1>No such action</h1>Sorry, I don't have the action you requested" }; | |
| 8 | |
| 9 local control = require "core.actions".actions; | |
| 10 | |
| 11 | |
| 12 local urlcodes = setmetatable({}, { __index = function (t, k) t[k] = string.char(tonumber("0x"..k)); return t[k]; end }); | |
| 13 | |
| 14 local function urldecode(s) | |
| 15 return s and (s:gsub("+", " "):gsub("%%([a-fA-F0-9][a-fA-F0-9])", urlcodes)); | |
| 16 end | |
| 17 | |
| 18 local function query_to_table(query) | |
| 19 if type(query) == "string" and #query > 0 then | |
| 20 if query:match("=") then | |
| 21 local params = {}; | |
| 22 for k, v in query:gmatch("&?([^=%?]+)=([^&%?]+)&?") do | |
| 23 if k and v then | |
| 24 params[urldecode(k)] = urldecode(v); | |
| 25 end | |
| 26 end | |
| 27 return params; | |
| 28 else | |
| 29 return urldecode(query); | |
| 30 end | |
| 31 end | |
| 32 end | |
| 33 | |
| 34 | |
| 35 | |
| 36 local http_path = { http_base }; | |
| 37 local function handle_request(method, body, request) | |
| 38 local path = request.url.path:gsub("^/[^/]+/", ""); | |
| 39 | |
| 40 local curr = control; | |
| 41 | |
| 42 for comp in path:gmatch("([^/]+)") do | |
| 43 curr = curr[comp]; | |
| 44 if not curr then | |
| 45 return response_404; | |
| 46 end | |
| 47 end | |
| 48 | |
| 49 if type(curr) == "table" then | |
| 50 local s = {}; | |
| 51 for k,v in pairs(curr) do | |
| 52 t_insert(s, tostring(k)); | |
| 53 t_insert(s, " = "); | |
| 54 if type(v) == "function" then | |
| 55 t_insert(s, "action") | |
| 56 elseif type(v) == "table" then | |
| 57 t_insert(s, "list"); | |
| 58 else | |
| 59 t_insert(s, tostring(v)); | |
| 60 end | |
| 61 t_insert(s, "\n"); | |
| 62 end | |
| 63 return t_concat(s); | |
| 64 elseif type(curr) == "function" then | |
| 65 local params = query_to_table(request.url.query); | |
| 66 params.host = request.headers.host:gsub(":%d+", ""); | |
| 67 local ok, ret1, ret2 = pcall(curr, params); | |
| 68 if not ok then | |
| 69 return "EPIC FAIL: "..tostring(ret1); | |
| 70 elseif not ret1 then | |
| 71 return "FAIL: "..tostring(ret2); | |
| 72 else | |
| 73 return "OK: "..tostring(ret2); | |
| 74 end | |
| 75 end | |
| 76 end | |
| 77 | |
| 78 httpserver.new{ port = 5280, base = "control", handler = handle_request, ssl = false } |
