luci/applications/luci-app-attendedsysupgrade/luasrc/view/attendedsysupgrade.htm
Paul Spooren 802d5b6bec luci-app-attendedsysupgrade: use rpc-sys pkglist
The bash package rpcd-mod-packagelist is no longer required as it has
been ported to rpc-sys by @dangowrt. The luci app now uses that feature.

The packagelist.acls is no longer required and has been removed.

luci-app-attendedsysupgrade: follow new server api

a new api uses more status codes and headers instead of genric 400 code
with json payload.

show error message when ubus call fail

fix typo

more info here
https://github.com/aparcar/attendedsysupgrade-server#response-status-codes

luci-app-attendedsysupgrade: refactoring

luci-app-attendedsysupgrade: use checksum

now compares cgi-io md5 checksum with md5 of server
as well checks if enough free memory is available to store image

Added needed ACL to let Luci request "system info"

rename "image" to "firmware" in output strings. This was requested as
"unification"

rpcd-mod-packelist used to return a variable called "packagelist", the
new "rpc-sys packagelist" returns a variable called "packages". This has
been adapted.

Signed-off-by: Paul Spooren <paul@spooren.de>
2017-11-24 02:10:31 +01:00

520 lines
19 KiB
HTML

<%
-- all lua code provided by https://github.com/jow-/
-- thank you very much!
function apply_acls(filename, session)
local json = require "luci.jsonc"
local util = require "luci.util"
local fs = require "nixio.fs"
local grants = { }
local acl = json.parse(fs.readfile(filename))
if type(acl) ~= "table" then
return
end
local group, perms
for group, perms in pairs(acl) do
local perm, scopes
for perm, scopes in pairs(perms) do
if type(scopes) == "table" then
local scope, objects
for scope, objects in pairs(scopes) do
if type(objects) == "table" then
if not grants[scope] then
grants[scope] = { }
end
if next(objects) == 1 then
local _, object
for _, object in ipairs(objects) do
if not grants[scope][object] then
grants[scope][object] = { }
end
table.insert(grants[scope][object], perm)
end
else
local object, funcs
for object, funcs in pairs(objects) do
if type(funcs) == "table" then
local _, func
for _, func in ipairs(funcs) do
if not grants[scope][object] then
grants[scope][object] = { }
end
table.insert(grants[scope][object], func)
end
end
end
end
end
end
end
end
end
local _, scope, object, func
for scope, _ in pairs(grants) do
local objects = { }
for object, _ in pairs(_) do
for _, func in ipairs(_) do
table.insert(objects, { object, func })
end
end
util.ubus("session", "grant", {
ubus_rpc_session = session,
scope = scope, objects = objects
})
end
end
apply_acls("/usr/share/rpcd/acl.d/attendedsysupgrade.json", luci.dispatcher.context.authsession)
%>
<%+header%>
<h2 name="content"><%:Attended Sysupgrade%></h2>
<div class="cbi-map-descr">
Easily search and install new releases and package upgrades. Sysupgrade firmware are created on demand based on locally installed packages.
</div>
<div style="display: none" id="info_box" class="alert-message info"></div>
<div style="display: none" id="error_box" class="alert-message danger"></div>
<div style="display: none" id="packages" class="alert-message success"></div>
<p>
<textarea style="display: none; width: 100%;" id="edit_packages" rows="15"></textarea>
</p>
<fieldset class="cbi-section">
<form method="post" action="">
<div class="cbi-selection-node">
<div class="cbi-value" id="keep_container" style="display: none">
<div class="cbi-section-descr">
Check "Keep settings" to retain the current configuration (requires a compatible firmware).
</div>
<label class="cbi-value-title" for="keep">Keep settings:</label>
<div class="cbi-value-field">
<input name="keep" id="keep" checked="checked" type="checkbox">
</div>
</div>
<div class="cbi-value" id="edit_button" style="display: none">
<div class="cbi-value-field">
<input class="cbi-button" value="Edit installed packages" onclick="edit_packages()" type="button">
</div>
</div>
<div class="cbi-value cbi-value" id="server_div" style="display:none">
<label class="cbi-value-title" for="server">Server:</label>
<div class="cbi-value-field">
<input onclick="edit_server()" class="cbi-button cbi-button-edit" value="" type="button" id="server" name="server">
</div>
</div>
<div class="cbi-value cbi-value-last">
<div class="cbi-value-field">
<input class="cbi-button cbi-button-apply" value="Search for upgrades" style="display: none" onclick="upgrade_check()" type="button" id="upgrade_button">
</div>
</div>
</div>
</form>
</fieldset>
<script type="text/javascript">
data = {};
origin = document.location.href.replace(location.pathname, "")
ubus_url = origin + "/ubus/"
function set_server() {
document.getElementById("error_box").style.display = "none";
data.url = document.getElementById("server").value;
ubus_call("uci", "set", { "config": "attendedsysupgrade", "section": "server", values: { "url": data.url } })
ubus_call("uci", "commit", { "config": "attendedsysupgrade" })
var server_button = document.getElementById("server")
server_button.type = 'button';
server_button.className = 'cbi-button cbi-button-edit';
server_button.parentElement.removeChild(document.getElementById("button_set"));
server_button.onclick = edit_server;
}
function edit_server() {
document.getElementById("server").type = 'text';
document.getElementById("server").onkeydown = function(event) {
if(event.key === 'Enter') {
set_server();
return false;
}
}
document.getElementById("server").className = '';
document.getElementById("server").onclick = null;
button_set = document.createElement("input");
button_set.type = "button";
button_set.value = "Save";
button_set.name = "button_set";
button_set.id = "button_set";
button_set.className = 'cbi-button cbi-button-edit';
button_set.style = 'background-image: url("/luci-static/resources/cbi/save.gif");'
button_set.onclick = set_server
document.getElementById("server").parentElement.appendChild(button_set);
}
function edit_packages() {
data.edit_packages = true
document.getElementById("edit_button").style.display = "none";
document.getElementById("edit_packages").value = data.packages.join("\n");
document.getElementById("edit_packages").style.display = "block";
}
// requests to the upgrade server
function server_request(request_dict, path, callback) {
request_dict.distro = data.release.distribution;
request_dict.target = data.release.target.split("\/")[0];
request_dict.subtarget = data.release.target.split("\/")[1];
var request = new XMLHttpRequest();
request.open("POST", data.url + "/" + path, true);
request.setRequestHeader("Content-type", "application/json");
request.send(JSON.stringify(request_dict));
request.onerror = function(e) {
error_box("upgrade server down")
document.getElementById("server_div").style.display = "block";
}
request.addEventListener('load', function(event) {
callback(request)
});
}
// initial setup, get system information
function setup() {
data["ubus_rpc_session"] = "<%=luci.dispatcher.context.authsession%>"
ubus_call("rpc-sys", "packagelist", {}, "packages");
ubus_call("system", "board", {}, "release");
ubus_call("system", "board", {}, "board_name");
ubus_call("system", "board", {}, "model");
ubus_call("system", "info", {}, "memory");
uci_get({ "config": "attendedsysupgrade", "section": "server", "option": "url" })
uci_get({ "config": "attendedsysupgrade", "section": "client", "option": "upgrade_packages" })
uci_get({ "config": "attendedsysupgrade", "section": "client", "option": "advanced_mode" })
uci_get({ "config": "attendedsysupgrade", "section": "client", "option": "auto_search" })
setup_ready();
}
function setup_ready() {
// checks if a async ubus calls have finished
if(ubus_counter != ubus_closed) {
setTimeout(setup_ready, 300)
} else {
if(data.auto_search == 1) {
upgrade_check();
} else {
document.getElementById("upgrade_button").style.display = "block";
document.getElementById("server_div").style.display = "block";
document.getElementById("server").value = data.url;
}
}
}
function uci_get(option) {
// simple wrapper to get a uci value store in data.<option>
ubus_call("uci", "get", option, option["option"])
}
ubus_counter = 0;
ubus_closed = 0;
function ubus_call(command, argument, params, variable) {
var request_data = {};
request_data.jsonrpc = "2.0";
request_data.id = ubus_counter;
request_data.method = "call";
request_data.params = [ data.ubus_rpc_session, command, argument, params ]
request_json = JSON.stringify(request_data)
ubus_counter++;
var request = new XMLHttpRequest();
request.open("POST", ubus_url, true);
request.setRequestHeader("Content-type", "application/json");
request.onload = function(event) {
if(request.status === 200) {
var response = JSON.parse(request.responseText)
if(!("error" in response) && "result" in response) {
if(response.result.length === 2) {
if(command === "uci") {
data[variable] = response.result[1].value
} else {
data[variable] = response.result[1][variable]
}
}
} else {
error_box("<b>Ubus call faild:</b></br>Request: " + request_json + "</br>Response: " + JSON.stringify(response))
}
ubus_closed++;
}
}
request.send(request_json);
}
function info_box(info_output, loading) {
// Shows notification if upgrade is available
// If loading is true then an "processing" animation is added
document.getElementById("info_box").style.display = "block";
var loading_image = '';
if(loading) {
loading_image = '<img src="/luci-static/resources/icons/loading.gif" alt="Loading" style="vertical-align:middle">';
}
document.getElementById("info_box").innerHTML = loading_image + info_output;
}
function error_box(error_output) {
// Shows erros in red box
document.getElementById("error_box").style.display = "block";
document.getElementById("error_box").innerHTML = error_output;
document.getElementById("info_box").style.display = "none";
}
function upgrade_check() {
// Asks server for new firmware
// If data.upgrade_packages is set to true search for new package versions as well
document.getElementById("error_box").style.display = "none";
document.getElementById("server_div").style.display = "none";
info_box("Searching for upgrades", true);
var request_dict = {}
request_dict.version = data.release.version;
request_dict.packages = data.packages;
request_dict.upgrade_packages = data.upgrade_packages
server_request(request_dict, "api/upgrade-check", upgrade_check_callback)
}
function upgrade_check_callback(request_text) {
var request_json = JSON.parse(request_text)
// create simple output to tell user whats going to be upgrade (release/packages)
var info_output = ""
if(request_json.version != undefined) {
info_output += "<h3>New firmware release available</h3>"
info_output += data.release.version + " to " + request_json.version
data.latest_version = request_json.version;
}
if(request_json.upgrades != undefined) {
info_output += "<h3>Package upgrades available</h3>"
for (upgrade in request_json.upgrades) {
info_output += "<b>" + upgrade + "</b>: " + request_json.upgrades[upgrade][1] + " to " + request_json.upgrades[upgrade][0] + "</br>"
}
}
data.packages = request_json.packages
info_box(info_output)
if(data.advanced_mode == 1) {
document.getElementById("edit_button").style.display = "block";
}
var upgrade_button = document.getElementById("upgrade_button")
upgrade_button.value = "Request firmware";
upgrade_button.style.display = "block";
upgrade_button.disabled = false;
upgrade_button.onclick = upgrade_request;
}
function upgrade_request() {
// Request the image
// Needed values
// version/release
// board_name or model (server tries to find the corrent profile)
// packages
// The rest is added by server_request()
document.getElementById("upgrade_button").disabled = true;
document.getElementById("edit_packages").style.display = "none";
document.getElementById("edit_button").style.display = "none";
document.getElementById("keep_container").style.display = "none";
var request_dict = {}
request_dict.version = data.latest_version;
request_dict.board = data.board_name
request_dict.model = data.model
if(data.edit_packages == true) {
request_dict.packages = document.getElementById("edit_packages").value.split("\n")
} else {
request_dict.packages = data.packages;
}
server_request(request_dict, "api/upgrade-request", upgrade_request_callback)
}
function upgrade_request_callback(request) {
// ready to download
var request_json = JSON.parse(request);
data.sysupgrade_url = request_json.sysupgrade;
data.checksum = request_json.checksum;
data.filesize = request_json.filesize;
info_output = "Firmware created"
if(data.advanced_mode == 1) {
info_output += '</br><a target="_blank" href="' + data.sysupgrade_url + '.log">Build log</a>'
}
info_box(info_output);
document.getElementById("keep_container").style.display = "block";
var upgrade_button = document.getElementById("upgrade_button")
upgrade_button.disabled = false;
upgrade_button.style.display = "block";
upgrade_button.value = "Flash firmware";
upgrade_button.onclick = download_image;
}
function flash_image() {
// Flash image via rpc-sys upgrade_start
info_box("Flashing firmware. Don't unpower device", true)
ubus_call("rpc-sys", "upgrade_start", { "keep": document.getElementById("keep").checked }, 'message');
ping_max = 3600; // in seconds
setTimeout(ping_ubus, 10000)
}
function ping_ubus() {
// Tries to connect to ubus. If the connection fails the device is likely still rebooting.
// If more time than ping_max passes update may failed
if(ping_max > 0) {
ping_max--;
var request = new XMLHttpRequest();
request.open("GET", ubus_url, true);
request.addEventListener('error', function(event) {
info_box("Rebooting device", true);
setTimeout(ping_ubus, 1000)
});
request.addEventListener('load', function(event) {
info_box("Success! Please reload web interface");
document.getElementById("upgrade_button").value = "reload page";
document.getElementById("upgrade_button").style.display = "block";
document.getElementById("upgrade_button").disabled = false;
document.getElementById("upgrade_button").onclick = function() { location.reload(); }
});
request.send();
} else {
error_box("Web interface could not reconnect to your device. Please reload web interface or check device manually")
}
}
function upload_image(blob) {
// Uploads received blob data to the server using cgi-io
var request = new XMLHttpRequest();
var form_data = new FormData();
form_data.append("sessionid", data.ubus_rpc_session)
form_data.append("filename", "/tmp/firmware.bin")
form_data.append("filemode", 755) // insecure?
form_data.append("filedata", blob)
request.addEventListener('load', function(event) {
request_json = JSON.parse(request.responseText)
if(data.checksum != request_json.checksum) {
error_box("Checksum missmatch! Please retry")
} else {
flash_image();
}
});
request.addEventListener('error', function(event) {
info_box("Upload of firmware failed, please retry by reloading web interface")
});
request.open('POST', origin + '/cgi-bin/cgi-upload');
request.send(form_data);
}
function download_image() {
// Download image from server once the url was received by upgrade_request
if(data.filesize > data.memory.free) {
error_box("Not enough free memory to download firmware. Please stop unneeded services on router and retry")
} else {
document.getElementById("keep_container").style.display = "none";
document.getElementById("upgrade_button").style.display = "none";
var download_request = new XMLHttpRequest();
download_request.open("GET", data.sysupgrade_url);
download_request.responseType = "arraybuffer";
download_request.onload = function () {
if (this.status === 200) {
var blob = new Blob([download_request.response], {type: "application/octet-stream"});
upload_image(blob)
}
};
info_box("Downloading firmware", true);
download_request.send();
}
}
function server_request(request_dict, path, callback) {
request_dict.distro = data.release.distribution;
request_dict.target = data.release.target.split("\/")[0];
request_dict.subtarget = data.release.target.split("\/")[1];
var request = new XMLHttpRequest();
request.open("POST", data.url + "/" + path, true);
request.setRequestHeader("Content-type", "application/json");
request.send(JSON.stringify(request_dict));
request.onerror = function(e) {
error_box("Upgrade server down or could not connect")
document.getElementById("server_div").style.display = "block";
}
request.addEventListener('load', function(event) {
request_text = request.responseText;
if (request.status === 200) {
callback(request_text)
} else if (request.status === 202) {
var imagebuilder = request.getResponseHeader("X-Imagebuilder-Status");
if(imagebuilder === "queue") {
// in queue
var queue = request.getResponseHeader("X-Build-Queue-Position");
info_box("In build queue position " + queue, true)
console.log("queued");
} else if(imagebuilder === "initialize") {
info_box("Setting up ImageBuilder", true)
console.log("Setting up imagebuilder");
} else if(imagebuilder === "building") {
info_box("Building image");
console.log("building");
} else {
info_box("Processing request");
console.log(imagebuilder)
}
setTimeout(function() { server_request(request_dict, path, callback) }, 5000)
} else if (request.status === 204) {
// no upgrades available
info_box("No upgrades available")
} else if (request.status === 400) {
// bad request
request_json = JSON.parse(request_text)
error_box(request_json.error)
} else if (request.status === 412) {
// this is a bit generic
error_box("Unsupported device, release, target, subtraget or board")
} else if (request.status === 413) {
error_box("No firmware created due to image size. Try again with less packages selected.")
} else if (request.status === 422) {
error_box("Unknown package in request")
} else if (request.status === 500) {
request_json = JSON.parse(request_text)
error_box_content = "<b>Internal server error</b></br>"
error_box_content += request_json.error
if(request_json.log != undefined) {
data.log_url = request_json.log
}
error_box(error_box_content)
} else if (request.status === 501) {
error_box("No sysupgrade file produced, may not supported by modell.")
} else if (request.status === 502) {
// python part offline
error_box("Server down for maintenance")
setTimeout(function() { server_request(request_dict, path, callback) }, 30000)
} else if (request.status === 503) {
error_box("Server overloaded")
setTimeout(function() { server_request(request_dict, path, callback) }, 30000)
}
});
}
document.onload = setup()
</script>
<%+footer%>