js/PostfixMailQueue.js

   1 Ext.define('pmg-mailq', {
   2     extend: 'Ext.data.Model',
   3     fields: [
   4         'queue_id', 'queue_name',
   5         { type: 'date', dateFormat: 'timestamp', name: 'arrival_time' },
   6         { type: 'integer', name: 'message_size' },
   7         'sender', 'receiver', 'reason',
   8     ],
   9     idProperty: 'queue_id',
  10 });
  11
  12 Ext.define('PMG.Postfix.MailQueue', {
  13     extend: 'Ext.grid.GridPanel',
  14     alias: 'widget.pmgPostfixMailQueue',
  15
  16     nodename: undefined,
  17
  18     filter: undefined,
  19
  20     queuename: 'deferred',
  21
  22     store: {
  23         xclass: 'Ext.data.BufferedStore',
  24         model: 'pmg-mailq',
  25         remoteFilter: true,
  26         remoteSort: true,
  27         sorters: 'arrival_time',
  28         pageSize: 2000,
  29     },
  30
  31     controller: {
  32
  33         xclass: 'Ext.app.ViewController',
  34
  35         init: function(view) {
  36             if (view.nodename) {
  37                 view.setNodename(view.nodename);
  38             }
  39
  40             view.delayFilterTask = new Ext.util.DelayedTask(function() {
  41                 var filter = view.lookupReference('filter').getValue();
  42
  43                 view.filter = filter;
  44                 view.updateProxy();
  45             });
  46         },
  47
  48         onChangeFilter: function(f, v) {
  49             var view = this.getView();
  50             view.delayFilterTask.delay(500);
  51         },
  52
  53         onFlush: function(button, event, rec) {
  54             var view = this.getView();
  55
  56             Proxmox.Utils.API2Request({
  57                 url: '/api2/extjs/nodes/' + view.nodename + '/postfix/queue/' +
  58                     view.queuename + '/' + rec.data.queue_id,
  59                 method: 'POST',
  60                 waitMsgTarget: view,
  61                 failure: function(response, opts) {
  62                     Ext.Msg.alert(gettext('Error'), response.htmlStatus);
  63                 },
  64             });
  65         },
  66
  67         onRemove: function(button, event, rec) {
  68             var view = this.getView();
  69
  70             Proxmox.Utils.API2Request({
  71                 url: '/api2/extjs/nodes/' + view.nodename + '/postfix/queue/' +
  72                     view.queuename + '/' + rec.data.queue_id,
  73                 method: 'DELETE',
  74                 waitMsgTarget: view,
  75                 success: function(response, opts) {
  76                     view.selModel.deselectAll();
  77                     view.store.load();
  78                 },
  79                 failure: function(response, opts) {
  80                     Ext.Msg.alert(gettext('Error'), response.htmlStatus);
  81                 },
  82             });
  83         },
  84
  85         onHeaders: function(button, event, rec) {
  86             var view = this.getView();
  87
  88             var url = '/api2/extjs/nodes/' + view.nodename + '/postfix/queue/' +
  89                 view.queuename + '/' + rec.data.queue_id;
  90
  91             var win = Ext.create('PMG.ViewMailHeaders', {
  92                 title: view.title + ' : ' + rec.data.queue_id,
  93                 url: url,
  94             });
  95             win.show();
  96         },
  97
  98         control: {
  99             '#': {
 100                 activate: function() {
 101                     this.view.updateProxy(); // reload
 102                 },
 103                 itemdblclick: function(grid, rec, item, index, event) {
 104                     this.onHeaders(grid, event, rec);
 105                 },
 106             },
 107             'field[reference=filter]': {
 108                 change: 'onChangeFilter',
 109             },
 110         },
 111     },
 112
 113     tbar: [
 114         {
 115             xtype: 'proxmoxButton',
 116             disabled: true,
 117             text: gettext('Headers'),
 118             handler: 'onHeaders',
 119         },
 120         {
 121             xtype: 'proxmoxButton',
 122             disabled: true,
 123             text: gettext('Flush'),
 124             handler: 'onFlush',
 125         },
 126         {
 127             xtype: 'proxmoxStdRemoveButton',
 128             handler: 'onRemove',
 129         },
 130         {
 131             xtype: 'label',
 132             html: gettext('Filter') + ':',
 133         },
 134         {
 135             xtype: 'textfield',
 136             width: 300,
 137             reference: 'filter',
 138         },
 139     ],
 140
 141     columns: [
 142         {
 143             header: gettext('Time'),
 144             flex: 2,
 145             renderer: Ext.util.Format.dateRenderer("Y-m-d H:i:s"),
 146             dataIndex: 'arrival_time',
 147         },
 148         {
 149             header: 'Size',
 150             renderer: Proxmox.Utils.format_size,
 151             flex: 1,
 152             dataIndex: 'message_size',
 153         },
 154         {
 155             header: gettext('Sender'),
 156             flex: 2,
 157             dataIndex: 'sender',
 158         },
 159         {
 160             header: gettext('Receiver'),
 161             flex: 2,
 162             dataIndex: 'receiver',
 163         },
 164         {
 165             header: gettext('Reason'),
 166             flex: 8,
 167             dataIndex: 'reason',
 168         },
 169     ],
 170
 171     pendingLoad: false,
 172
 173     updateProxy: function() {
 174         let me = this;
 175
 176         if (me.pendingLoad) {
 177             return;
 178         }
 179
 180         let proxy = {
 181             type: 'proxmox',
 182             startParam: 'start',
 183             limitParam: 'limit',
 184             sortParam: 'sortfield',
 185             directionParam: 'sortdir',
 186             simpleSortMode: true,
 187             url: "/api2/json/nodes/" + me.nodename + "/postfix/queue/" + me.queuename,
 188         };
 189
 190         let filter = me.filter;
 191         if (filter) {
 192             proxy.extraParams = { filter: filter };
 193         }
 194
 195         me.store.setProxy(proxy);
 196
 197         let nodename = me.nodename;
 198         let queuename = me.queuename;
 199         me.pendingLoad = true;
 200         me.store.load(function() {
 201             me.pendingLoad = false;
 202             if (me.nodename !== nodename || me.filter !== filter || me.queuename !== queuename) {
 203                 setTimeout(function() {
 204                     me.updateProxy();
 205                 }, 100);
 206             }
 207         });
 208     },
 209
 210     setFilter: function(filter) {
 211         this.lookupReference('filter').setValue(filter);
 212     },
 213
 214     setNodename: function(nodename) {
 215         let me = this;
 216         if (nodename === me.nodename) {
 217             return; // nothing to do
 218         }
 219         me.nodename = nodename;
 220
 221         me.updateProxy();
 222     },
 223
 224     setQueueName: function(queuename) {
 225         var me = this;
 226
 227         me.queuename = queuename;
 228
 229         me.updateProxy();
 230     },
 231
 232 });