Fixed last commit
[project/luci.git] / modules / rpc / luasrc / jsonrpc.lua
1 --[[
2 LuCI - Lua Configuration Interface
3
4 Copyright 2008 Steven Barth <steven@midlink.org>
5 Copyright 2008 Jo-Philipp Wich <xm@leipzig.freifunk.net>
6
7 Licensed under the Apache License, Version 2.0 (the "License");
8 you may not use this file except in compliance with the License.
9 You may obtain a copy of the License at
10
11         http://www.apache.org/licenses/LICENSE-2.0
12
13 $Id$
14 ]]--
15
16 module("luci.jsonrpc", package.seeall)
17 require "luci.json"
18
19 function resolve(mod, method)
20         local path = luci.util.split(method, ".")
21         
22         for j=1, #path-1 do
23                 if not type(mod) == "table" then
24                         break
25                 end
26                 mod = rawget(mod, path[j])
27                 if not mod then
28                         break
29                 end
30         end
31         mod = type(mod) == "table" and rawget(mod, path[#path]) or nil
32         if type(mod) == "function" then
33                 return mod
34         end
35 end
36
37 function handle(tbl, rawsource, ...)
38         local decoder = luci.json.Decoder()
39         local stat = luci.ltn12.pump.all(rawsource, decoder:sink())
40         local json = decoder:get()
41         local response
42         local success = false
43         
44         if stat then
45                 if type(json.method) == "string"
46                  and (not json.params or type(json.params) == "table") then
47                         local method = resolve(tbl, json.method)
48                         if method then
49                                 response = reply(json.jsonrpc, json.id,
50                                  proxy(method, unpack(json.params or {})))
51                         else
52                                 response = reply(json.jsonrpc, json.id,
53                                  nil, {code=-32601, message="Method not found."})
54                         end
55                 else
56                         response = reply(json.jsonrpc, json.id,
57                          nil, {code=-32600, message="Invalid request."})
58                 end
59         else
60                 response = reply("2.0", nil,
61                  nil, {code=-32700, message="Parse error."})
62         end
63
64         return luci.json.Encoder(response, ...):source()
65 end
66
67 function reply(jsonrpc, id, res, err)
68         require "luci.json"
69         id = id or luci.json.null
70         
71         -- 1.0 compatibility
72         if jsonrpc ~= "2.0" then
73                 jsonrpc = nil
74                 res = res or luci.json.null
75                 err = err or luci.json.null
76         end
77         
78         return {id=id, result=res, error=err, jsonrpc=jsonrpc}
79 end
80
81 function proxy(method, ...)
82         local res = {luci.util.copcall(method, ...)}
83         local stat = table.remove(res, 1)
84         
85         if not stat then
86                 return nil, {code=-32602, message="Invalid params.", data=table.remove(res, 1)} 
87         else
88                 if #res <= 1 then
89                         return res[1] or luci.json.null
90                 else
91                         return res
92                 end
93         end
94 end