]> git.proxmox.com Git - proxmox-widget-toolkit.git/blobdiff - src/Utils.js
Utils: refactor updateColumns from pve-manager
[proxmox-widget-toolkit.git] / src / Utils.js
index 0691d4085d2e79b209b3243de35ed2a7a1f1cd34..adff5f4886fe03f9a5510eac18319b91ed021946 100644 (file)
@@ -5,13 +5,6 @@ if (!Ext.isDefined(Proxmox.Setup.auth_cookie_name)) {
     throw "Proxmox library not initialized";
 }
 
-// avoid errors related to Accessible Rich Internet Applications
-// (access for people with disabilities)
-// TODO reenable after all components are upgraded
-Ext.enableAria = false;
-Ext.enableAriaButtons = false;
-Ext.enableAriaPanels = false;
-
 // avoid errors when running without development tools
 if (!Ext.isDefined(Ext.global.console)) {
     let console = {
@@ -55,6 +48,7 @@ utilities: {
     noneText: gettext('none'),
     NoneText: gettext('None'),
     errorText: gettext('Error'),
+    warningsText: gettext('Warnings'),
     unknownText: gettext('Unknown'),
     defaultText: gettext('Default'),
     daysText: gettext('days'),
@@ -74,6 +68,7 @@ utilities: {
        zh_CN: 'Chinese (Simplified)',
        zh_TW: 'Chinese (Traditional)',
        da: 'Danish',
+       nl: 'Dutch',
        en: 'English',
        eu: 'Euskera (Basque)',
        fr: 'French',
@@ -81,6 +76,7 @@ utilities: {
        he: 'Hebrew',
        it: 'Italian',
        ja: 'Japanese',
+       kr: 'Korean',
        nb: 'Norwegian (Bokmal)',
        nn: 'Norwegian (Nynorsk)',
        fa: 'Persian (Farsi)',
@@ -448,6 +444,17 @@ utilities: {
        Ext.Ajax.request(newopts);
     },
 
+    // can be useful for catching displaying errors from the API, e.g.:
+    // Proxmox.Async.api2({
+    //     ...
+    // }).catch(Proxmox.Utils.alertResponseFailure);
+    alertResponseFailure: (response) => {
+       Ext.Msg.alert(
+           gettext('Error'),
+           response.htmlStatus || response.result.message,
+       );
+    },
+
     checked_command: function(orig_cmd) {
        Proxmox.Utils.API2Request(
            {
@@ -459,7 +466,7 @@ utilities: {
                success: function(response, opts) {
                    let res = response.result;
                    if (res === null || res === undefined || !res || res
-                       .data.status !== 'Active') {
+                       .data.status.toLowerCase() !== 'active') {
                        Ext.Msg.show({
                            title: gettext('No valid subscription'),
                            icon: Ext.Msg.WARNING,
@@ -560,93 +567,15 @@ utilities: {
     },
 
     task_desc_table: {
-       acmenewcert: ['SRV', gettext('Order Certificate')],
-       acmeregister: ['ACME Account', gettext('Register')],
-       acmedeactivate: ['ACME Account', gettext('Deactivate')],
-       acmeupdate: ['ACME Account', gettext('Update')],
-       acmerefresh: ['ACME Account', gettext('Refresh')],
-       acmerenew: ['SRV', gettext('Renew Certificate')],
-       acmerevoke: ['SRV', gettext('Revoke Certificate')],
-       'auth-realm-sync': [gettext('Realm'), gettext('Sync')],
-       'auth-realm-sync-test': [gettext('Realm'), gettext('Sync Preview')],
-       'move_volume': ['CT', gettext('Move Volume')],
-       clustercreate: ['', gettext('Create Cluster')],
-       clusterjoin: ['', gettext('Join Cluster')],
+       aptupdate: ['', gettext('Update package database')],
        diskinit: ['Disk', gettext('Initialize Disk with GPT')],
-       vncproxy: ['VM/CT', gettext('Console')],
-       spiceproxy: ['VM/CT', gettext('Console') + ' (Spice)'],
-       vncshell: ['', gettext('Shell')],
        spiceshell: ['', gettext('Shell') + ' (Spice)'],
-       qmsnapshot: ['VM', gettext('Snapshot')],
-       qmrollback: ['VM', gettext('Rollback')],
-       qmdelsnapshot: ['VM', gettext('Delete Snapshot')],
-       qmcreate: ['VM', gettext('Create')],
-       qmrestore: ['VM', gettext('Restore')],
-       qmdestroy: ['VM', gettext('Destroy')],
-       qmigrate: ['VM', gettext('Migrate')],
-       qmclone: ['VM', gettext('Clone')],
-       qmmove: ['VM', gettext('Move disk')],
-       qmtemplate: ['VM', gettext('Convert to template')],
-       qmstart: ['VM', gettext('Start')],
-       qmstop: ['VM', gettext('Stop')],
-       qmreset: ['VM', gettext('Reset')],
-       qmshutdown: ['VM', gettext('Shutdown')],
-       qmreboot: ['VM', gettext('Reboot')],
-       qmsuspend: ['VM', gettext('Hibernate')],
-       qmpause: ['VM', gettext('Pause')],
-       qmresume: ['VM', gettext('Resume')],
-       qmconfig: ['VM', gettext('Configure')],
-       vzsnapshot: ['CT', gettext('Snapshot')],
-       vzrollback: ['CT', gettext('Rollback')],
-       vzdelsnapshot: ['CT', gettext('Delete Snapshot')],
-       vzcreate: ['CT', gettext('Create')],
-       vzrestore: ['CT', gettext('Restore')],
-       vzdestroy: ['CT', gettext('Destroy')],
-       vzmigrate: ['CT', gettext('Migrate')],
-       vzclone: ['CT', gettext('Clone')],
-       vztemplate: ['CT', gettext('Convert to template')],
-       vzstart: ['CT', gettext('Start')],
-       vzstop: ['CT', gettext('Stop')],
-       vzmount: ['CT', gettext('Mount')],
-       vzumount: ['CT', gettext('Unmount')],
-       vzshutdown: ['CT', gettext('Shutdown')],
-       vzreboot: ['CT', gettext('Reboot')],
-       vzsuspend: ['CT', gettext('Suspend')],
-       vzresume: ['CT', gettext('Resume')],
-       push_file: ['CT', gettext('Push file')],
-       pull_file: ['CT', gettext('Pull file')],
-       hamigrate: ['HA', gettext('Migrate')],
-       hastart: ['HA', gettext('Start')],
-       hastop: ['HA', gettext('Stop')],
-       hashutdown: ['HA', gettext('Shutdown')],
+       srvreload: ['SRV', gettext('Reload')],
+       srvrestart: ['SRV', gettext('Restart')],
        srvstart: ['SRV', gettext('Start')],
        srvstop: ['SRV', gettext('Stop')],
-       srvrestart: ['SRV', gettext('Restart')],
-       srvreload: ['SRV', gettext('Reload')],
-       cephcreatemgr: ['Ceph Manager', gettext('Create')],
-       cephdestroymgr: ['Ceph Manager', gettext('Destroy')],
-       cephcreatemon: ['Ceph Monitor', gettext('Create')],
-       cephdestroymon: ['Ceph Monitor', gettext('Destroy')],
-       cephcreateosd: ['Ceph OSD', gettext('Create')],
-       cephdestroyosd: ['Ceph OSD', gettext('Destroy')],
-       cephcreatepool: ['Ceph Pool', gettext('Create')],
-       cephdestroypool: ['Ceph Pool', gettext('Destroy')],
-       cephfscreate: ['CephFS', gettext('Create')],
-       cephcreatemds: ['Ceph Metadata Server', gettext('Create')],
-       cephdestroymds: ['Ceph Metadata Server', gettext('Destroy')],
-       imgcopy: ['', gettext('Copy data')],
-       imgdel: ['', gettext('Erase data')],
-       unknownimgdel: ['', gettext('Destroy image from unknown guest')],
-       download: ['', gettext('Download')],
-       vzdump: (type, id) => id ? `VM/CT ${id} - ${gettext('Backup')}` : gettext('Backup Job'),
-       aptupdate: ['', gettext('Update package database')],
-       startall: ['', gettext('Start all VMs and Containers')],
-       stopall: ['', gettext('Stop all VMs and Containers')],
-       migrateall: ['', gettext('Migrate all VMs and Containers')],
-       dircreate: [gettext('Directory Storage'), gettext('Create')],
-       lvmcreate: [gettext('LVM Storage'), gettext('Create')],
-       lvmthincreate: [gettext('LVM-Thin Storage'), gettext('Create')],
-       zfscreate: [gettext('ZFS Storage'), gettext('Create')],
+       termproxy: ['', gettext('Console') + ' (xterm.js)'],
+       vncshell: ['', gettext('Shell')],
     },
 
     // to add or change existing for product specific ones
@@ -708,6 +637,65 @@ utilities: {
        return Proxmox.Utils.format_duration_long(uptime);
     },
 
+    systemd_unescape: function(string_value) {
+       const charcode_0 = '0'.charCodeAt(0);
+       const charcode_9 = '9'.charCodeAt(0);
+       const charcode_A = 'A'.charCodeAt(0);
+       const charcode_F = 'F'.charCodeAt(0);
+       const charcode_a = 'a'.charCodeAt(0);
+       const charcode_f = 'f'.charCodeAt(0);
+       const charcode_x = 'x'.charCodeAt(0);
+       const charcode_minus = '-'.charCodeAt(0);
+       const charcode_slash = '/'.charCodeAt(0);
+       const charcode_backslash = '\\'.charCodeAt(0);
+
+       let parse_hex_digit = function(d) {
+           if (d >= charcode_0 && d <= charcode_9) {
+               return d - charcode_0;
+           }
+           if (d >= charcode_A && d <= charcode_F) {
+               return d - charcode_A + 10;
+           }
+           if (d >= charcode_a && d <= charcode_f) {
+               return d - charcode_a + 10;
+           }
+           throw "got invalid hex digit";
+       };
+
+       let value = new TextEncoder().encode(string_value);
+       let result = new Uint8Array(value.length);
+
+       let i = 0;
+       let result_len = 0;
+
+       while (i < value.length) {
+           let c0 = value[i];
+           if (c0 === charcode_minus) {
+               result.set([charcode_slash], result_len);
+               result_len += 1;
+               i += 1;
+               continue;
+           }
+           if ((i + 4) < value.length) {
+               let c1 = value[i+1];
+               if (c0 === charcode_backslash && c1 === charcode_x) {
+                   let h1 = parse_hex_digit(value[i+2]);
+                   let h0 = parse_hex_digit(value[i+3]);
+                   let ord = h1*16+h0;
+                   result.set([ord], result_len);
+                   result_len += 1;
+                   i += 4;
+                   continue;
+               }
+           }
+           result.set([c0], result_len);
+           result_len += 1;
+           i += 1;
+       }
+
+       return new TextDecoder().decode(result.slice(0, result.len));
+    },
+
     parse_task_upid: function(upid) {
        let task = {};
 
@@ -723,7 +711,7 @@ utilities: {
        }
        task.starttime = parseInt(res[6], 16);
        task.type = res[7];
-       task.id = res[8];
+       task.id = Proxmox.Utils.systemd_unescape(res[8]);
        task.user = res[9];
 
        task.desc = Proxmox.Utils.format_task_description(task.type, task.id);
@@ -801,11 +789,11 @@ utilities: {
        }
        // try to normalize - and _ separators, to support asciidoc and sphinx
        // references at the same time.
-       let section_minus_normalized = section.replace(/_/, '-');
+       let section_minus_normalized = section.replace(/_/g, '-');
        if (helpMap[section_minus_normalized]) {
            return helpMap[section_minus_normalized];
        }
-       let section_underscore_normalized = section.replace(/-/, '_');
+       let section_underscore_normalized = section.replace(/-/g, '_');
        return helpMap[section_underscore_normalized];
     },
 
@@ -833,6 +821,275 @@ utilities: {
        }
     },
 
+    render_optional_url: function(value) {
+       if (value && value.match(/^https?:\/\//) !== null) {
+           return '<a target="_blank" href="' + value + '">' + value + '</a>';
+       }
+       return value;
+    },
+
+    render_san: function(value) {
+       var names = [];
+       if (Ext.isArray(value)) {
+           value.forEach(function(val) {
+               if (!Ext.isNumber(val)) {
+                   names.push(val);
+               }
+           });
+           return names.join('<br>');
+       }
+       return value;
+    },
+
+    render_usage: function(val) {
+       return (val*100).toFixed(2) + '%';
+    },
+
+    render_cpu_usage: function(val, max) {
+       return Ext.String.format(gettext('{0}% of {1}') +
+           ' ' + gettext('CPU(s)'), (val*100).toFixed(2), max);
+    },
+
+    render_size_usage: function(val, max) {
+       if (max === 0) {
+           return gettext('N/A');
+       }
+       return (val*100/max).toFixed(2) + '% (' +
+           Ext.String.format(gettext('{0} of {1}'),
+           Proxmox.Utils.render_size(val), Proxmox.Utils.render_size(max)) + ')';
+    },
+
+    render_cpu: function(value, metaData, record, rowIndex, colIndex, store) {
+       if (!(record.data.uptime && Ext.isNumeric(value))) {
+           return '';
+       }
+
+       var maxcpu = record.data.maxcpu || 1;
+
+       if (!Ext.isNumeric(maxcpu) && maxcpu >= 1) {
+           return '';
+       }
+
+       var per = value * 100;
+
+       return per.toFixed(1) + '% of ' + maxcpu.toString() + (maxcpu > 1 ? 'CPUs' : 'CPU');
+    },
+
+    render_size: function(value, metaData, record, rowIndex, colIndex, store) {
+       if (!Ext.isNumeric(value)) {
+           return '';
+       }
+
+       return Proxmox.Utils.format_size(value);
+    },
+
+    render_cpu_model: function(cpuinfo) {
+       return cpuinfo.cpus + " x " + cpuinfo.model + " (" +
+           cpuinfo.sockets.toString() + " " +
+           (cpuinfo.sockets > 1
+               ? gettext('Sockets')
+               : gettext('Socket')
+           ) + ")";
+    },
+
+    /* this is different for nodes */
+    render_node_cpu_usage: function(value, record) {
+       return Proxmox.Utils.render_cpu_usage(value, record.cpus);
+    },
+
+    render_node_size_usage: function(record) {
+       return Proxmox.Utils.render_size_usage(record.used, record.total);
+    },
+
+    loadTextFromFile: function(file, callback, maxBytes) {
+       let maxSize = maxBytes || 8192;
+       if (file.size > maxSize) {
+           Ext.Msg.alert(gettext('Error'), gettext("Invalid file size: ") + file.size);
+           return;
+       }
+       let reader = new FileReader();
+       reader.onload = evt => callback(evt.target.result);
+       reader.readAsText(file);
+    },
+
+    parsePropertyString: function(value, defaultKey) {
+       var res = {},
+           error;
+
+       if (typeof value !== 'string' || value === '') {
+           return res;
+       }
+
+       Ext.Array.each(value.split(','), function(p) {
+           var kv = p.split('=', 2);
+           if (Ext.isDefined(kv[1])) {
+               res[kv[0]] = kv[1];
+           } else if (Ext.isDefined(defaultKey)) {
+               if (Ext.isDefined(res[defaultKey])) {
+                   error = 'defaultKey may be only defined once in propertyString';
+                   return false; // break
+               }
+               res[defaultKey] = kv[0];
+           } else {
+               error = 'invalid propertyString, not a key=value pair and no defaultKey defined';
+               return false; // break
+           }
+           return true;
+       });
+
+       if (error !== undefined) {
+           console.error(error);
+           return undefined;
+       }
+
+       return res;
+    },
+
+    printPropertyString: function(data, defaultKey) {
+       var stringparts = [],
+           gotDefaultKeyVal = false,
+           defaultKeyVal;
+
+       Ext.Object.each(data, function(key, value) {
+           if (defaultKey !== undefined && key === defaultKey) {
+               gotDefaultKeyVal = true;
+               defaultKeyVal = value;
+           } else if (Ext.isArray(value)) {
+               stringparts.push(key + '=' + value.join(';'));
+           } else if (value !== '') {
+               stringparts.push(key + '=' + value);
+           }
+       });
+
+       stringparts = stringparts.sort();
+       if (gotDefaultKeyVal) {
+           stringparts.unshift(defaultKeyVal);
+       }
+
+       return stringparts.join(',');
+    },
+
+    acmedomain_count: 5,
+
+    parseACMEPluginData: function(data) {
+       let res = {};
+       let extradata = [];
+       data.split('\n').forEach((line) => {
+           // capture everything after the first = as value
+           let [key, value] = line.split('=');
+           if (value !== undefined) {
+               res[key] = value;
+           } else {
+               extradata.push(line);
+           }
+       });
+       return [res, extradata];
+    },
+
+    delete_if_default: function(values, fieldname, default_val, create) {
+       if (values[fieldname] === '' || values[fieldname] === default_val) {
+           if (!create) {
+               if (values.delete) {
+                   if (Ext.isArray(values.delete)) {
+                       values.delete.push(fieldname);
+                   } else {
+                       values.delete += ',' + fieldname;
+                   }
+               } else {
+                   values.delete = fieldname;
+               }
+           }
+
+           delete values[fieldname];
+       }
+    },
+
+    printACME: function(value) {
+       if (Ext.isArray(value.domains)) {
+           value.domains = value.domains.join(';');
+       }
+       return Proxmox.Utils.printPropertyString(value);
+    },
+
+    parseACME: function(value) {
+       if (!value) {
+           return {};
+       }
+
+       var res = {};
+       var error;
+
+       Ext.Array.each(value.split(','), function(p) {
+           var kv = p.split('=', 2);
+           if (Ext.isDefined(kv[1])) {
+               res[kv[0]] = kv[1];
+           } else {
+               error = 'Failed to parse key-value pair: '+p;
+               return false;
+           }
+           return true;
+       });
+
+       if (error !== undefined) {
+           console.error(error);
+           return undefined;
+       }
+
+       if (res.domains !== undefined) {
+           res.domains = res.domains.split(/;/);
+       }
+
+       return res;
+    },
+
+    add_domain_to_acme: function(acme, domain) {
+       if (acme.domains === undefined) {
+           acme.domains = [domain];
+       } else {
+           acme.domains.push(domain);
+           acme.domains = acme.domains.filter((value, index, self) => self.indexOf(value) === index);
+       }
+       return acme;
+    },
+
+    remove_domain_from_acme: function(acme, domain) {
+       if (acme.domains !== undefined) {
+           acme.domains = acme.domains.filter(
+               (value, index, self) => self.indexOf(value) === index && value !== domain,
+           );
+       }
+       return acme;
+    },
+
+    updateColumns: function(container) {
+       let mode = Ext.state.Manager.get('summarycolumns') || 'auto';
+       let factor;
+       if (mode !== 'auto') {
+           factor = parseInt(mode, 10);
+           if (Number.isNaN(factor)) {
+               factor = 1;
+           }
+       } else {
+           factor = container.getSize().width < 1400 ? 1 : 2;
+       }
+
+       if (container.oldFactor === factor) {
+           return;
+       }
+
+       let items = container.query('>'); // direct childs
+       factor = Math.min(factor, items.length);
+       container.oldFactor = factor;
+
+       items.forEach((item) => {
+           item.columnWidth = 1 / factor;
+       });
+
+       // we have to update the layout twice, since the first layout change
+       // can trigger the scrollbar which reduces the amount of space left
+       container.updateLayout();
+       container.updateLayout();
+    },
 },
 
     singleton: true,
@@ -872,13 +1129,33 @@ utilities: {
        me.IP64_match = new RegExp("^(?:" + IPV6_REGEXP + "|" + IPV4_REGEXP + ")$");
        me.IP64_cidr_match = new RegExp("^(?:" + IPV6_REGEXP + "/" + IPV6_CIDR_MASK + ")|(?:" + IPV4_REGEXP + "/" + IPV4_CIDR_MASK + ")$");
 
-       let DnsName_REGEXP = "(?:(([a-zA-Z0-9]([a-zA-Z0-9\\-]*[a-zA-Z0-9])?)\\.)*([A-Za-z0-9]([A-Za-z0-9\\-]*[A-Za-z0-9])?))";
+       let DnsName_REGEXP = "(?:(?:(?:[a-zA-Z0-9](?:[a-zA-Z0-9\\-]*[a-zA-Z0-9])?)\\.)*(?:[A-Za-z0-9](?:[A-Za-z0-9\\-]*[A-Za-z0-9])?))";
        me.DnsName_match = new RegExp("^" + DnsName_REGEXP + "$");
 
-       me.HostPort_match = new RegExp("^(" + IPV4_REGEXP + "|" + DnsName_REGEXP + ")(:\\d+)?$");
-       me.HostPortBrackets_match = new RegExp("^\\[(?:" + IPV6_REGEXP + "|" + IPV4_REGEXP + "|" + DnsName_REGEXP + ")\\](:\\d+)?$");
-       me.IP6_dotnotation_match = new RegExp("^" + IPV6_REGEXP + "(\\.\\d+)?$");
-       me.Vlan_match = /^vlan(\\d+)/;
-       me.VlanInterface_match = /(\\w+)\\.(\\d+)/;
+       me.HostPort_match = new RegExp("^(" + IPV4_REGEXP + "|" + DnsName_REGEXP + ")(?::(\\d+))?$");
+       me.HostPortBrackets_match = new RegExp("^\\[(" + IPV6_REGEXP + "|" + IPV4_REGEXP + "|" + DnsName_REGEXP + ")\\](?::(\\d+))?$");
+       me.IP6_dotnotation_match = new RegExp("^(" + IPV6_REGEXP + ")(?:\\.(\\d+))?$");
+       me.Vlan_match = /^vlan(\d+)/;
+       me.VlanInterface_match = /(\w+)\.(\d+)/;
+    },
+});
+
+Ext.define('Proxmox.Async', {
+    singleton: true,
+
+    // Returns a Promise resolving to the result of an `API2Request` or rejecting to the error
+    // repsonse on failure
+    api2: function(reqOpts) {
+       return new Promise((resolve, reject) => {
+           delete reqOpts.callback; // not allowed in this api
+           reqOpts.success = response => resolve(response);
+           reqOpts.failure = response => reject(response);
+           Proxmox.Utils.API2Request(reqOpts);
+       });
+    },
+
+    // Delay for a number of milliseconds.
+    sleep: function(millis) {
+       return new Promise((resolve, _reject) => setTimeout(resolve, millis));
     },
 });