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.username) == "string" and
18 util.contains(allowed_users, sdat.values.username)
20 return sid, sdat.values
26 function authenticator(validator, accs)
27 local http = require "luci.http"
28 local ctrl = require "luci.controller.rpc"
29 local auth = http.formvalue("auth", true) or http.getcookie("sysauth")
31 if auth then -- if authentication token was given
32 local sid, sdat = ctrl.session_retrieve(auth, accs)
33 if sdat then -- if given token is valid
34 return sdat.username, sid
36 http.status(403, "Forbidden")
42 local ctrl = require "luci.controller.rpc"
44 local rpc = node("rpc")
46 rpc.sysauth_authenticator = ctrl.authenticator
49 entry({"rpc", "uci"}, call("rpc_uci"))
50 entry({"rpc", "fs"}, call("rpc_fs"))
51 entry({"rpc", "sys"}, call("rpc_sys"))
52 entry({"rpc", "ipkg"}, call("rpc_ipkg"))
53 entry({"rpc", "ip"}, call("rpc_ip"))
54 entry({"rpc", "auth"}, call("rpc_auth")).sysauth = false
58 local ctrl = require "luci.controller.rpc"
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)
84 local sid, sdat = ctrl.session_retrieve(login.ubus_rpc_session, { user })
96 server.login = function(...)
97 local challenge = server.challenge(...)
99 http.header("Set-Cookie", 'sysauth=%s; path=%s' %{
101 http.getenv("SCRIPT_NAME")
107 http.prepare_content("application/json")
108 ltn12.pump.all(jsonrpc.handle(server, http.source()), http.write)
112 if not pcall(require, "luci.model.uci") then
113 luci.http.status(404, "Not Found")
116 local uci = require "luci.jsonrpcbind.uci"
117 local jsonrpc = require "luci.jsonrpc"
118 local http = require "luci.http"
119 local ltn12 = require "luci.ltn12"
121 http.prepare_content("application/json")
122 ltn12.pump.all(jsonrpc.handle(uci, http.source()), http.write)
126 local util = require "luci.util"
127 local io = require "io"
128 local fs2 = util.clone(require "nixio.fs")
129 local jsonrpc = require "luci.jsonrpc"
130 local http = require "luci.http"
131 local ltn12 = require "luci.ltn12"
133 function fs2.readfile(filename)
134 local stat, mime = pcall(require, "mime")
136 error("Base64 support not available. Please install LuaSocket.")
139 local fp = io.open(filename)
145 local sink = ltn12.sink.table(output)
146 local source = ltn12.source.chain(ltn12.source.file(fp), mime.encode("base64"))
147 return ltn12.pump.all(source, sink) and table.concat(output)
150 function fs2.writefile(filename, data)
151 local stat, mime = pcall(require, "mime")
153 error("Base64 support not available. Please install LuaSocket.")
156 local file = io.open(filename, "w")
157 local sink = file and ltn12.sink.chain(mime.decode("base64"), ltn12.sink.file(file))
158 return sink and ltn12.pump.all(ltn12.source.string(data), sink) or false
161 http.prepare_content("application/json")
162 ltn12.pump.all(jsonrpc.handle(fs2, http.source()), http.write)
166 local util = require "luci.util"
167 local sys = require "luci.sys"
168 local jsonrpc = require "luci.jsonrpc"
169 local http = require "luci.http"
170 local ltn12 = require "luci.ltn12"
172 local sys2 = util.clone(sys)
173 sys2.net = util.clone(sys.net)
174 sys2.wifi = util.clone(sys.wifi)
176 function sys2.wifi.getiwinfo(ifname, operation)
177 local iw = sys.wifi.getiwinfo(ifname)
180 assert(type(iwinfo[iw.type][operation]) == "function")
185 local rv = { ifname = ifname }
186 for n, f in pairs(iwinfo[iw.type]) do
187 if type(f) == "function" and
188 n ~= "scanlist" and n ~= "countrylist"
198 http.prepare_content("application/json")
199 ltn12.pump.all(jsonrpc.handle(sys2, http.source()), http.write)
203 if not pcall(require, "luci.model.ipkg") then
204 luci.http.status(404, "Not Found")
207 local ipkg = require "luci.model.ipkg"
208 local jsonrpc = require "luci.jsonrpc"
209 local http = require "luci.http"
210 local ltn12 = require "luci.ltn12"
212 http.prepare_content("application/json")
213 ltn12.pump.all(jsonrpc.handle(ipkg, http.source()), http.write)
217 if not pcall(require, "luci.ip") then
218 luci.http.status(404, "Not Found")
222 local util = require "luci.util"
223 local ip = require "luci.ip"
224 local jsonrpc = require "luci.jsonrpc"
225 local http = require "luci.http"
226 local ltn12 = require "luci.ltn12"
228 local ip2 = util.clone(ip)
231 for _, n in ipairs({ "new", "IPv4", "IPv6", "MAC" }) do
232 ip2[n] = function(address, netmask, operation, argument)
233 local cidr = ip[n](address, netmask)
234 if cidr and operation then
235 assert(type(cidr[operation]) == "function")
236 local cidr2 = cidr[operation](cidr, argument)
237 return (type(cidr2) == "userdata") and cidr2:string() or cidr2
239 return (type(cidr) == "userdata") and cidr:string() or cidr
243 http.prepare_content("application/json")
244 ltn12.pump.all(jsonrpc.handle(ip2, http.source()), http.write)