js/PostfixMailQueue.js

   1 /*global Proxmox*/
   2 Ext.define('pmg-mailq', {
   3     extend: 'Ext.data.Model',
   4     fields: [
   5         'queue_id', 'queue_name',
   6         { type: 'date',  dateFormat: 'timestamp', name: 'arrival_time'},
   7         { type: 'integer', name: 'message_size'},
   8         'sender', 'receiver', 'reason'
   9     ],
  10     idProperty: 'queue_id'
  11 });
  12
  13 Ext.define('PMG.Postfix.MailQueue', {
  14     extend: 'Ext.grid.GridPanel',
  15     alias: 'widget.pmgPostfixMailQueue',
  16
  17     nodename: undefined,
  18
  19     filter: undefined,
  20
  21     queuename: 'deferred',
  22
  23     store: {
  24         xclass: 'Ext.data.BufferedStore',
  25         model: 'pmg-mailq',
  26         remoteFilter: true,
  27         pageSize: 2000
  28     },
  29
  30     controller: {
  31
  32         xclass: 'Ext.app.ViewController',
  33
  34         init: function(view) {
  35             if (view.nodename) {
  36                 view.setNodename(view.nodename);
  37             }
  38
  39             view.delayFilterTask = new Ext.util.DelayedTask(function() {
  40                 var filter = view.lookupReference('filter').getValue();
  41
  42                 view.filter = filter;
  43                 view.updateProxy();
  44             });
  45         },
  46
  47         onChangeFilter: function(f, v) {
  48             var view = this.getView();
  49             view.delayFilterTask.delay(500);
  50         },
  51
  52         onFlush: function(button, event, rec) {
  53             var view = this.getView();
  54
  55             Proxmox.Utils.API2Request({
  56                 url: '/api2/extjs/nodes/' + view.nodename + '/postfix/queue/' +
  57                     view.queuename + '/' + rec.data.queue_id,
  58                 method: 'POST',
  59                 waitMsgTarget: view,
  60                 failure: function (response, opts) {
  61                     Ext.Msg.alert(gettext('Error'), response.htmlStatus);
  62                 }
  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             width: 150,
 145             renderer: Ext.util.Format.dateRenderer("Y-m-d H:i:s"),
 146             dataIndex: 'arrival_time'
 147         },
 148         {
 149             header: 'KByte',
 150             width: 80,
 151             dataIndex: 'message_size'
 152         },
 153         {
 154             header: gettext('Sender'),
 155             width: 200,
 156             dataIndex: 'sender'
 157         },
 158         {
 159             header: gettext('Receiver'),
 160             width: 200,
 161             dataIndex: 'receiver'
 162         },
 163         {
 164             header: gettext('Reason'),
 165             flex: 1,
 166             dataIndex: 'reason'
 167         }
 168     ],
 169
 170     pendingLoad: false,
 171
 172     updateProxy: function() {
 173         var me = this;
 174
 175         if (me.pendingLoad) {
 176             return;
 177         }
 178
 179         var proxy = {
 180             type: 'proxmox',
 181             startParam: 'start',
 182             limitParam: 'limit',
 183             url: "/api2/json/nodes/" + me.nodename + "/postfix/queue/" + me.queuename
 184         };
 185
 186         var filter = me.filter;
 187         var nodename = me.nodename;
 188         var queuename = me.queuename;
 189
 190         if (filter) { proxy.extraParams = { filter: filter }; }
 191
 192
 193         me.store.setProxy(proxy);
 194
 195         me.pendingLoad = true;
 196
 197         me.store.load(function() {
 198             me.pendingLoad = false;
 199             if (me.nodename !== nodename || me.filter !== filter || me.queuename !== queuename) {
 200                 setTimeout(function() {
 201                     me.updateProxy();
 202                 }, 100);
 203             }
 204         });
 205     },
 206
 207     setFilter: function(filter) {
 208         this.lookupReference('filter').setValue(filter);
 209     },
 210
 211     setNodename: function(nodename) {
 212         var me = this;
 213
 214         me.nodename = nodename;
 215
 216         me.updateProxy();
 217     },
 218
 219     setQueueName: function(queuename) {
 220         var me = this;
 221
 222         me.queuename = queuename;
 223
 224         me.updateProxy();
 225     }
 226
 227 });