import { ClosureComponent, Component, Children } from "mithril"; import { m } from "./components"; import config from "./config"; import filterComponent from "./filter-component"; import * as store from "./store"; import * as notifications from "./notifications"; import memoize from "../lib/common/memoize"; import putFormComponent from "./put-form-component"; import indexTableComponent from "./index-table-component"; import * as overlay from "./overlay"; import * as smartQuery from "./smart-query"; import { map, parse, stringify } from "../lib/common/expression-parser"; const PAGE_SIZE = config.ui.pageSize || 10; const memoizedParse = memoize(parse); const memoizedJsonParse = memoize(JSON.parse); const attributes: { id: string; label: string; type?: string; options?: any; }[] = [ { id: "_id", label: "Name" }, { id: "metadata.fileType", label: "Type", type: "combo", options: [ "1 Firmware Upgrade Image", "2 Web Content", "3 Vendor Configuration File", "4 Tone File", "5 Ringer File" ] }, { id: "metadata.oui", label: "OUI" }, { id: "metadata.productClass", label: "Product Class" }, { id: "metadata.version", label: "Version" } ]; const formData = { resource: "files", attributes: attributes .slice(1) // remove _id from new object form .concat([{ id: "file", label: "File", type: "file" }]) }; const unpackSmartQuery = memoize(query => { return map(query, e => { if (Array.isArray(e) && e[0] === "FUNC" && e[1] === "Q") return smartQuery.unpack("files", e[2], e[3]); return e; }); }); interface ValidationErrors { [prop: string]: string; } function putActionHandler(action, _object): Promise { return new Promise((resolve, reject) => { const object = Object.assign({}, _object); if (action === "save") { const file = object["file"] ? object["file"][0] : null; delete object["file"]; if (!file) return void resolve({ file: "File not selected" }); const id = file.name; store .resourceExists("files", id) .then(exists => { if (exists) { store.fulfill(0, Date.now()); return void resolve({ file: "File already exists" }); } const headers = Object.assign( { "Content-Type": "application/octet-stream", Accept: "application/octet-stream" }, object ); m.request({ method: "PUT", headers: headers, url: `/api/files/${encodeURIComponent(id)}`, serialize: body => body, // Identity function to prevent JSON.parse on blob data data: file }) .then(() => { notifications.push( "success", `File ${exists ? "updated" : "created"}` ); store.fulfill(0, Date.now()); resolve(); }) .catch(reject); }) .catch(reject); } else { reject(new Error("Undefined action")); } }); } const getDownloadUrl = memoize(filter => { const cols = {}; for (const attr of attributes) cols[attr.label] = attr.id; return `/api/files.csv?${m.buildQueryString({ filter: stringify(filter), columns: JSON.stringify(cols) })}`; }); export function init(args): Promise<{}> { if (!window.authorizer.hasAccess("files", 2)) { return Promise.reject( new Error("You are not authorized to view this page") ); } const sort = args.sort; const filter = args.filter; return Promise.resolve({ filter, sort }); } export const component: ClosureComponent = (): Component => { return { view: vnode => { document.title = "Files - GenieACS"; function showMore(): void { vnode.state["showCount"] = (vnode.state["showCount"] || PAGE_SIZE) + PAGE_SIZE; m.redraw(); } function onFilterChanged(filter): void { const ops = { filter }; if (vnode.attrs["sort"]) ops["sort"] = vnode.attrs["sort"]; m.route.set(m.route.get(), ops); } const sort = vnode.attrs["sort"] ? memoizedJsonParse(vnode.attrs["sort"]) : {}; const sortAttributes = {}; for (let i = 0; i < attributes.length; i++) sortAttributes[i] = sort[attributes[i].id] || 0; function onSortChange(sortAttrs): void { const _sort = Object.assign({}, sort); for (const [index, direction] of Object.entries(sortAttrs)) { // Changing the priority of columns delete _sort[attributes[index].id]; _sort[attributes[index].id] = direction; } const ops = { sort: JSON.stringify(_sort) }; if (vnode.attrs["filter"]) ops["filter"] = vnode.attrs["filter"]; m.route.set(m.route.get(), ops); } let filter = vnode.attrs["filter"] ? memoizedParse(vnode.attrs["filter"]) : true; filter = unpackSmartQuery(filter); const files = store.fetch("files", filter, { limit: vnode.state["showCount"] || PAGE_SIZE, sort: sort }); const count = store.count("files", filter); const downloadUrl = getDownloadUrl(filter); const attrs = {}; attrs["attributes"] = attributes; attrs["data"] = files.value; attrs["total"] = count.value; attrs["showMoreCallback"] = showMore; attrs["sortAttributes"] = sortAttributes; attrs["onSortChange"] = onSortChange; attrs["downloadUrl"] = downloadUrl; if (window.authorizer.hasAccess("files", 3)) { attrs["actionsCallback"] = (selected): Children => { return [ m( "button.primary", { title: "Create new file", onclick: () => { const cb = (): Children => { return m( putFormComponent, Object.assign( { actionHandler: (action, object) => { return new Promise(resolve => { putActionHandler(action, object) .then(errors => { const errorList = errors ? Object.values(errors) : []; if (errorList.length) { for (const err of errorList) notifications.push("error", err); } else { overlay.close(cb); } resolve(); }) .catch(err => { notifications.push("error", err.message); resolve(); }); }); } }, formData ) ); }; overlay.open(cb); } }, "New" ), m( "button.primary", { title: "Delete selected files", disabled: !selected.size, onclick: e => { if ( !confirm(`Deleting ${selected.size} files. Are you sure?`) ) return; e.redraw = false; e.target.disabled = true; Promise.all( Array.from(selected).map(id => store.deleteResource("files", id) ) ) .then(res => { notifications.push( "success", `${res.length} files deleted` ); store.fulfill(0, Date.now()); }) .catch(err => { notifications.push("error", err.message); store.fulfill(0, Date.now()); }); } }, "Delete" ) ]; }; } const filterAttrs = {}; filterAttrs["resource"] = "files"; filterAttrs["filter"] = vnode.attrs["filter"]; filterAttrs["onChange"] = onFilterChanged; return [ m("h1", "Listing files"), m(filterComponent, filterAttrs), m(indexTableComponent, attrs) ]; } }; };