1 -- Copyright 2008 Steven Barth <steven@midlink.org>
2 -- Copyright 2008 Jo-Philipp Wich <jow@openwrt.org>
3 -- Licensed to the public under the Apache License 2.0.
5 module("luci.controller.rpc", package.seeall)
8 function session_retrieve(sid, allowed_users)
9 local util = require "luci.util"
10 local sdat = util.ubus("session", "get", {
11 ubus_rpc_session = sid
14 if type(sdat) == "table" and
15 type(sdat.values) == "table" and
16 type(sdat.values.token) == "string" and
17 type(sdat.values.secret) == "string" and
18 type(sdat.values.username) == "string" and
19 util.contains(allowed_users, sdat.values.username)
21 return sid, sdat.values
27 function authenticator(validator, accs)
28 local http = require "luci.http"
29 local ctrl = require "luci.controller.rpc"
30 local auth = http.formvalue("auth", true) or http.getcookie("sysauth")
32 if auth then -- if authentication token was given
33 local sid, sdat = ctrl.session_retrieve(auth, accs)
34 if sdat then -- if given token is valid
35 return sdat.username, sid
37 http.status(403, "Forbidden")
43 local ctrl = require "luci.controller.rpc"
45 local rpc = node("rpc")
47 rpc.sysauth_authenticator = ctrl.authenticator
50 entry({"rpc", "uci"}, call("rpc_uci"))
51 entry({"rpc", "fs"}, call("rpc_fs"))
52 entry({"rpc", "sys"}, call("rpc_sys"))
53 entry({"rpc", "ipkg"}, call("rpc_ipkg"))
54 entry({"rpc", "ip"}, call("rpc_ip"))
55 entry({"rpc", "auth"}, call("rpc_auth")).sysauth = false
59 local jsonrpc = require "luci.jsonrpc"
60 local http = require "luci.http"
61 local sys = require "luci.sys"
62 local ltn12 = require "luci.ltn12"
63 local util = require "luci.util"
66 server.challenge = function(user, pass)
67 local config = require "luci.config"
68 local login = util.ubus("session", "login", {
71 timeout = tonumber(config.sauth.sessiontime)
74 if type(login) == "table" and
75 type(login.ubus_rpc_session) == "string"
77 util.ubus("session", "set", {
78 ubus_rpc_session = login.ubus_rpc_session,
80 token = sys.uniqueid(16),
81 secret = sys.uniqueid(16)
85 local sid, sdat = ctrl.session_retrieve(login.ubus_rpc_session, { user })
98 server.login = function(...)
99 local challenge = server.challenge(...)
101 http.header("Set-Cookie", 'sysauth=%s; path=%s' %{
103 http.getenv("SCRIPT_NAME")
109 http.prepare_content("application/json")
110 ltn12.pump.all(jsonrpc.handle(server, http.source()), http.write)
114 if not pcall(require, "luci.model.uci") then
115 luci.http.status(404, "Not Found")
118 local uci = require "luci.jsonrpcbind.uci"
119 local jsonrpc = require "luci.jsonrpc"
120 local http = require "luci.http"
121 local ltn12 = require "luci.ltn12"
123 http.prepare_content("application/json")
124 ltn12.pump.all(jsonrpc.handle(uci, http.source()), http.write)
128 local util = require "luci.util"
129 local io = require "io"
130 local fs2 = util.clone(require "nixio.fs")
131 local jsonrpc = require "luci.jsonrpc"
132 local http = require "luci.http"
133 local ltn12 = require "luci.ltn12"
135 function fs2.readfile(filename)
136 local stat, mime = pcall(require, "mime")
138 error("Base64 support not available. Please install LuaSocket.")
141 local fp = io.open(filename)
147 local sink = ltn12.sink.table(output)
148 local source = ltn12.source.chain(ltn12.source.file(fp), mime.encode("base64"))
149 return ltn12.pump.all(source, sink) and table.concat(output)
152 function fs2.writefile(filename, data)
153 local stat, mime = pcall(require, "mime")
155 error("Base64 support not available. Please install LuaSocket.")
158 local file = io.open(filename, "w")
159 local sink = file and ltn12.sink.chain(mime.decode("base64"), ltn12.sink.file(file))
160 return sink and ltn12.pump.all(ltn12.source.string(data), sink) or false
163 http.prepare_content("application/json")
164 ltn12.pump.all(jsonrpc.handle(fs2, http.source()), http.write)
168 local util = require "luci.util"
169 local sys = require "luci.sys"
170 local jsonrpc = require "luci.jsonrpc"
171 local http = require "luci.http"
172 local ltn12 = require "luci.ltn12"
174 local sys2 = util.clone(sys)
175 sys2.net = util.clone(sys.net)
176 sys2.wifi = util.clone(sys.wifi)
178 function sys2.wifi.getiwinfo(ifname, operation)
179 local iw = sys.wifi.getiwinfo(ifname)
182 assert(type(iwinfo[iw.type][operation]) == "function")
187 local rv = { ifname = ifname }
188 for n, f in pairs(iwinfo[iw.type]) do
189 if type(f) == "function" and
190 n ~= "scanlist" and n ~= "countrylist"
200 http.prepare_content("application/json")
201 ltn12.pump.all(jsonrpc.handle(sys2, http.source()), http.write)
205 if not pcall(require, "luci.model.ipkg") then
206 luci.http.status(404, "Not Found")
209 local ipkg = require "luci.model.ipkg"
210 local jsonrpc = require "luci.jsonrpc"
211 local http = require "luci.http"
212 local ltn12 = require "luci.ltn12"
214 http.prepare_content("application/json")
215 ltn12.pump.all(jsonrpc.handle(ipkg, http.source()), http.write)
219 if not pcall(require, "luci.ip") then
220 luci.http.status(404, "Not Found")
224 local util = require "luci.util"
225 local ip = require "luci.ip"
226 local jsonrpc = require "luci.jsonrpc"
227 local http = require "luci.http"
228 local ltn12 = require "luci.ltn12"
230 local ip2 = util.clone(ip)
233 for _, n in ipairs({ "new", "IPv4", "IPv6", "MAC" }) do
234 ip2[n] = function(address, netmask, operation, argument)
235 local cidr = ip[n](address, netmask)
236 if cidr and operation then
237 assert(type(cidr[operation]) == "function")
238 local cidr2 = cidr[operation](cidr, argument)
239 return (type(cidr2) == "userdata") and cidr2:string() or cidr2
241 return (type(cidr) == "userdata") and cidr:string() or cidr
245 http.prepare_content("application/json")
246 ltn12.pump.all(jsonrpc.handle(ip2, http.source()), http.write)