summaryrefslogtreecommitdiffhomepage
path: root/modules/luci-mod-rpc/luasrc/jsonrpc.lua
diff options
context:
space:
mode:
authorJo-Philipp Wich <jow@openwrt.org>2014-12-03 15:17:05 +0100
committerJo-Philipp Wich <jow@openwrt.org>2015-01-08 16:26:20 +0100
commit1bb4822dca6113f73e3bc89e2acf15935e6f8e92 (patch)
tree35e16f100466e4e00657199b38bb3d87d52bf73f /modules/luci-mod-rpc/luasrc/jsonrpc.lua
parent9edd0e46c3f880727738ce8ca6ff1c8b85f99ef4 (diff)
Rework LuCI build system
* Rename subdirectories to their repective OpenWrt package names * Make each LuCI module its own standalone package * Deploy a shared luci.mk which is used by each module Makefile Signed-off-by: Jo-Philipp Wich <jow@openwrt.org>
Diffstat (limited to 'modules/luci-mod-rpc/luasrc/jsonrpc.lua')
-rw-r--r--modules/luci-mod-rpc/luasrc/jsonrpc.lua94
1 files changed, 94 insertions, 0 deletions
diff --git a/modules/luci-mod-rpc/luasrc/jsonrpc.lua b/modules/luci-mod-rpc/luasrc/jsonrpc.lua
new file mode 100644
index 0000000000..71c95d549b
--- /dev/null
+++ b/modules/luci-mod-rpc/luasrc/jsonrpc.lua
@@ -0,0 +1,94 @@
+--[[
+LuCI - Lua Configuration Interface
+
+Copyright 2008 Steven Barth <steven@midlink.org>
+Copyright 2008 Jo-Philipp Wich <xm@leipzig.freifunk.net>
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+$Id$
+]]--
+
+module("luci.jsonrpc", package.seeall)
+require "luci.json"
+
+function resolve(mod, method)
+ local path = luci.util.split(method, ".")
+
+ for j=1, #path-1 do
+ if not type(mod) == "table" then
+ break
+ end
+ mod = rawget(mod, path[j])
+ if not mod then
+ break
+ end
+ end
+ mod = type(mod) == "table" and rawget(mod, path[#path]) or nil
+ if type(mod) == "function" then
+ return mod
+ end
+end
+
+function handle(tbl, rawsource, ...)
+ local decoder = luci.json.Decoder()
+ local stat = luci.ltn12.pump.all(rawsource, decoder:sink())
+ local json = decoder:get()
+ local response
+ local success = false
+
+ if stat then
+ if type(json.method) == "string"
+ and (not json.params or type(json.params) == "table") then
+ local method = resolve(tbl, json.method)
+ if method then
+ response = reply(json.jsonrpc, json.id,
+ proxy(method, unpack(json.params or {})))
+ else
+ response = reply(json.jsonrpc, json.id,
+ nil, {code=-32601, message="Method not found."})
+ end
+ else
+ response = reply(json.jsonrpc, json.id,
+ nil, {code=-32600, message="Invalid request."})
+ end
+ else
+ response = reply("2.0", nil,
+ nil, {code=-32700, message="Parse error."})
+ end
+
+ return luci.json.Encoder(response, ...):source()
+end
+
+function reply(jsonrpc, id, res, err)
+ require "luci.json"
+ id = id or luci.json.null
+
+ -- 1.0 compatibility
+ if jsonrpc ~= "2.0" then
+ jsonrpc = nil
+ res = res or luci.json.null
+ err = err or luci.json.null
+ end
+
+ return {id=id, result=res, error=err, jsonrpc=jsonrpc}
+end
+
+function proxy(method, ...)
+ local res = {luci.util.copcall(method, ...)}
+ local stat = table.remove(res, 1)
+
+ if not stat then
+ return nil, {code=-32602, message="Invalid params.", data=table.remove(res, 1)}
+ else
+ if #res <= 1 then
+ return res[1] or luci.json.null
+ else
+ return res
+ end
+ end
+end