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