src/window/TaskViewer.js

   1 Ext.define('Proxmox.window.TaskProgress', {
   2     extend: 'Ext.window.Window',
   3     alias: 'widget.proxmoxTaskProgress',
   4
   5     taskDone: Ext.emptyFn,
   6
   7     initComponent: function() {
   8         let me = this;
   9
  10         if (!me.upid) {
  11             throw "no task specified";
  12         }
  13
  14         let task = Proxmox.Utils.parse_task_upid(me.upid);
  15
  16         let statstore = Ext.create('Proxmox.data.ObjectStore', {
  17             url: "/api2/json/nodes/" + task.node + "/tasks/" + me.upid + "/status",
  18             interval: 1000,
  19             rows: {
  20                 status: { defaultValue: 'unknown' },
  21                 exitstatus: { defaultValue: 'unknown' },
  22             },
  23         });
  24
  25         me.on('destroy', statstore.stopUpdate);
  26
  27         let getObjectValue = function(key, defaultValue) {
  28             let rec = statstore.getById(key);
  29             if (rec) {
  30                 return rec.data.value;
  31             }
  32             return defaultValue;
  33         };
  34
  35         let pbar = Ext.create('Ext.ProgressBar', { text: 'running...' });
  36
  37         me.mon(statstore, 'load', function() {
  38             let status = getObjectValue('status');
  39             if (status === 'stopped') {
  40                 let exitstatus = getObjectValue('exitstatus');
  41                 if (exitstatus === 'OK') {
  42                     pbar.reset();
  43                     pbar.updateText("Done!");
  44                     Ext.Function.defer(me.close, 1000, me);
  45                 } else {
  46                     me.close();
  47                     Ext.Msg.alert('Task failed', exitstatus);
  48                 }
  49                 me.taskDone(exitstatus === 'OK');
  50             }
  51         });
  52
  53         let descr = Proxmox.Utils.format_task_description(task.type, task.id);
  54
  55         Ext.apply(me, {
  56             title: gettext('Task') + ': ' + descr,
  57             width: 300,
  58             layout: 'auto',
  59             modal: true,
  60             bodyPadding: 5,
  61             items: pbar,
  62             buttons: [
  63                 {
  64                     text: gettext('Details'),
  65                     handler: function() {
  66                         let win = Ext.create('Proxmox.window.TaskViewer', {
  67                             taskDone: me.taskDone,
  68                             upid: me.upid,
  69                         });
  70                         win.show();
  71                         me.close();
  72                     },
  73                 },
  74             ],
  75         });
  76
  77         me.callParent();
  78
  79         statstore.startUpdate();
  80
  81         pbar.wait();
  82     },
  83 });
  84
  85 // fixme: how can we avoid those lint errors?
  86
  87 Ext.define('Proxmox.window.TaskViewer', {
  88     extend: 'Ext.window.Window',
  89     alias: 'widget.proxmoxTaskViewer',
  90
  91     extraTitle: '', // string to prepend after the generic task title
  92
  93     taskDone: Ext.emptyFn,
  94
  95     initComponent: function() {
  96         let me = this;
  97
  98         if (!me.upid) {
  99             throw "no task specified";
 100         }
 101
 102         let task = Proxmox.Utils.parse_task_upid(me.upid);
 103
 104         let statgrid;
 105
 106         let rows = {
 107             status: {
 108                 header: gettext('Status'),
 109                 defaultValue: 'unknown',
 110                 renderer: function(value) {
 111                     if (value !== 'stopped') {
 112                         return value;
 113                     }
 114                     let es = statgrid.getObjectValue('exitstatus');
 115                     if (es) {
 116                         return value + ': ' + es;
 117                     }
 118                     return 'unknown';
 119                 },
 120             },
 121             exitstatus: {
 122                 visible: false,
 123             },
 124             type: {
 125                 header: gettext('Task type'),
 126                 required: true,
 127             },
 128             user: {
 129                 header: gettext('User name'),
 130                 renderer: Ext.String.htmlEncode,
 131                 required: true,
 132             },
 133             node: {
 134                 header: gettext('Node'),
 135                 required: true,
 136             },
 137             pid: {
 138                 header: gettext('Process ID'),
 139                 required: true,
 140             },
 141             task_id: {
 142                 header: gettext('Task ID'),
 143             },
 144             starttime: {
 145                 header: gettext('Start Time'),
 146                 required: true,
 147                 renderer: Proxmox.Utils.render_timestamp,
 148             },
 149             upid: {
 150                 header: gettext('Unique task ID'),
 151                 renderer: Ext.String.htmlEncode,
 152             },
 153         };
 154
 155         if (me.endtime) {
 156             if (typeof me.endtime === 'object') {
 157                 // convert to epoch
 158                 me.endtime = parseInt(me.endtime.getTime()/1000, 10);
 159             }
 160             rows.endtime = {
 161                 header: gettext('End Time'),
 162                 required: true,
 163                 renderer: function() {
 164                     return Proxmox.Utils.render_timestamp(me.endtime);
 165                 },
 166             };
 167         }
 168
 169         rows.duration = {
 170             header: gettext('Duration'),
 171             required: true,
 172             renderer: function() {
 173                 let starttime = statgrid.getObjectValue('starttime');
 174                 let endtime = me.endtime || Date.now()/1000;
 175                 let duration = endtime - starttime;
 176                 return Proxmox.Utils.format_duration_human(duration);
 177             },
 178         };
 179
 180         let statstore = Ext.create('Proxmox.data.ObjectStore', {
 181             url: "/api2/json/nodes/" + task.node + "/tasks/" + me.upid + "/status",
 182             interval: 1000,
 183             rows: rows,
 184         });
 185
 186         me.on('destroy', statstore.stopUpdate);
 187
 188         let stop_task = function() {
 189             Proxmox.Utils.API2Request({
 190                 url: "/nodes/" + task.node + "/tasks/" + me.upid,
 191                 waitMsgTarget: me,
 192                 method: 'DELETE',
 193                 failure: function(response, opts) {
 194                     Ext.Msg.alert(gettext('Error'), response.htmlStatus);
 195                 },
 196             });
 197         };
 198
 199         let stop_btn1 = new Ext.Button({
 200             text: gettext('Stop'),
 201             disabled: true,
 202             handler: stop_task,
 203         });
 204
 205         let stop_btn2 = new Ext.Button({
 206             text: gettext('Stop'),
 207             disabled: true,
 208             handler: stop_task,
 209         });
 210
 211         statgrid = Ext.create('Proxmox.grid.ObjectGrid', {
 212             title: gettext('Status'),
 213             layout: 'fit',
 214             tbar: [stop_btn1],
 215             rstore: statstore,
 216             rows: rows,
 217             border: false,
 218         });
 219
 220         let logView = Ext.create('Proxmox.panel.LogView', {
 221             title: gettext('Output'),
 222             tbar: [stop_btn2],
 223             border: false,
 224             url: "/api2/extjs/nodes/" + task.node + "/tasks/" + me.upid + "/log",
 225         });
 226
 227         me.mon(statstore, 'load', function() {
 228             let status = statgrid.getObjectValue('status');
 229
 230             if (status === 'stopped') {
 231                 logView.scrollToEnd = false;
 232                 logView.requestUpdate();
 233                 statstore.stopUpdate();
 234                 me.taskDone(statgrid.getObjectValue('exitstatus') === 'OK');
 235             }
 236
 237             stop_btn1.setDisabled(status !== 'running');
 238             stop_btn2.setDisabled(status !== 'running');
 239         });
 240
 241         statstore.startUpdate();
 242
 243         Ext.apply(me, {
 244             title: "Task viewer: " + task.desc + me.extraTitle,
 245             width: 800,
 246             height: 400,
 247             layout: 'fit',
 248             modal: true,
 249             items: [{
 250                 xtype: 'tabpanel',
 251                 region: 'center',
 252                 items: [logView, statgrid],
 253             }],
 254         });
 255
 256         me.callParent();
 257
 258         logView.fireEvent('show', logView);
 259     },
 260 });
 261