]>
Commit | Line | Data |
---|---|---|
a6c60aed DC |
1 | Ext.define('PVE.CephCreateService', { |
2 | extend: 'Proxmox.window.Edit', | |
3 | xtype: 'pveCephCreateService', | |
4 | ||
5 | showProgress: true, | |
6 | ||
7 | setNode: function(nodename) { | |
fb792310 | 8 | let me = this; |
a6c60aed | 9 | me.nodename = nodename; |
fb792310 | 10 | me.url = `/nodes/${nodename}/ceph/${me.type}/${nodename}`; |
a6c60aed DC |
11 | }, |
12 | ||
13 | method: 'POST', | |
14 | isCreate: true, | |
15 | ||
16 | items: [ | |
17 | { | |
18 | xtype: 'pveNodeSelector', | |
19 | submitValue: false, | |
20 | fieldLabel: gettext('Host'), | |
21 | selectCurNode: true, | |
22 | allowBlank: false, | |
23 | listeners: { | |
24 | change: function(f, value) { | |
fb792310 TL |
25 | let view = this.up('pveCephCreateService'); |
26 | view.setNode(value); | |
f6710aac TL |
27 | }, |
28 | }, | |
29 | }, | |
a6c60aed DC |
30 | ], |
31 | ||
8058410f | 32 | initComponent: function() { |
fb792310 | 33 | let me = this; |
a6c60aed DC |
34 | |
35 | if (!me.nodename) { | |
36 | throw "no node name specified"; | |
37 | } | |
a6c60aed DC |
38 | if (!me.type) { |
39 | throw "no type specified"; | |
40 | } | |
a6c60aed DC |
41 | me.setNode(me.nodename); |
42 | ||
43 | me.callParent(); | |
f6710aac | 44 | }, |
a6c60aed DC |
45 | }); |
46 | ||
89c04721 DC |
47 | Ext.define('PVE.node.CephServiceController', { |
48 | extend: 'Ext.app.ViewController', | |
49 | alias: 'controller.CephServiceList', | |
a6c60aed | 50 | |
999df1c2 | 51 | render_status: (value, metadata, rec) => value, |
a6c60aed | 52 | |
89c04721 DC |
53 | render_version: function(value, metadata, rec) { |
54 | if (value === undefined) { | |
55 | return ''; | |
56 | } | |
57 | let view = this.getView(); | |
58 | let host = rec.data.host, nodev = [0]; | |
59 | if (view.nodeversions[host] !== undefined) { | |
60 | nodev = view.nodeversions[host].version.parts; | |
61 | } | |
a6c60aed | 62 | |
89c04721 DC |
63 | let icon = ''; |
64 | if (PVE.Utils.compare_ceph_versions(view.maxversion, nodev) > 0) { | |
65 | icon = PVE.Utils.get_ceph_icon_html('HEALTH_UPGRADE'); | |
66 | } else if (PVE.Utils.compare_ceph_versions(nodev, value) > 0) { | |
67 | icon = PVE.Utils.get_ceph_icon_html('HEALTH_OLD'); | |
68 | } else if (view.mixedversions) { | |
69 | icon = PVE.Utils.get_ceph_icon_html('HEALTH_OK'); | |
70 | } | |
71 | return icon + value; | |
72 | }, | |
a6c60aed | 73 | |
89c04721 DC |
74 | getMaxVersions: function(store, records, success) { |
75 | if (!success || records.length < 1) { | |
76 | return; | |
77 | } | |
78 | let me = this; | |
79 | let view = me.getView(); | |
80 | ||
81 | view.nodeversions = records[0].data.node; | |
82 | view.maxversion = []; | |
83 | view.mixedversions = false; | |
84 | for (const [_nodename, data] of Object.entries(view.nodeversions)) { | |
85 | let res = PVE.Utils.compare_ceph_versions(data.version.parts, view.maxversion); | |
86 | if (res !== 0 && view.maxversion.length > 0) { | |
87 | view.mixedversions = true; | |
7d88e195 | 88 | } |
89c04721 DC |
89 | if (res > 0) { |
90 | view.maxversion = data.version.parts; | |
277d6d15 | 91 | } |
89c04721 DC |
92 | } |
93 | }, | |
277d6d15 | 94 | |
89c04721 DC |
95 | init: function(view) { |
96 | if (view.pveSelNode) { | |
97 | view.nodename = view.pveSelNode.data.node; | |
98 | } | |
99 | if (!view.nodename) { | |
100 | throw "no node name specified"; | |
101 | } | |
277d6d15 | 102 | |
89c04721 DC |
103 | if (!view.type) { |
104 | throw "no type specified"; | |
105 | } | |
277d6d15 | 106 | |
89c04721 DC |
107 | view.versionsstore = Ext.create('Proxmox.data.UpdateStore', { |
108 | autoStart: true, | |
109 | interval: 10000, | |
110 | storeid: `ceph-versions-${view.type}-list${view.nodename}`, | |
111 | proxy: { | |
112 | type: 'proxmox', | |
113 | url: "/api2/json/cluster/ceph/metadata?scope=versions", | |
114 | }, | |
115 | }); | |
116 | view.versionsstore.on('load', this.getMaxVersions, this); | |
117 | view.on('destroy', view.versionsstore.stopUpdate); | |
118 | ||
119 | view.rstore = Ext.create('Proxmox.data.UpdateStore', { | |
120 | autoStart: true, | |
121 | interval: 3000, | |
122 | storeid: `ceph-${view.type}-list${view.nodename}`, | |
123 | model: 'ceph-service-list', | |
124 | proxy: { | |
125 | type: 'proxmox', | |
126 | url: `/api2/json/nodes/${view.nodename}/ceph/${view.type}`, | |
127 | }, | |
128 | }); | |
a6c60aed | 129 | |
89c04721 DC |
130 | view.setStore(Ext.create('Proxmox.data.DiffStore', { |
131 | rstore: view.rstore, | |
132 | sorters: [{ property: 'name' }], | |
133 | })); | |
a6c60aed | 134 | |
89c04721 DC |
135 | if (view.storeLoadCallback) { |
136 | view.rstore.on('load', view.storeLoadCallback, this); | |
137 | } | |
138 | view.on('destroy', view.rstore.stopUpdate); | |
a6c60aed | 139 | |
89c04721 DC |
140 | if (view.showCephInstallMask) { |
141 | PVE.Utils.monitor_ceph_installed(view, view.rstore, view.nodename, true); | |
142 | } | |
143 | }, | |
a6c60aed | 144 | |
89c04721 DC |
145 | service_cmd: function(rec, cmd) { |
146 | let view = this.getView(); | |
147 | if (!rec.data.host) { | |
148 | Ext.Msg.alert(gettext('Error'), "entry has no host"); | |
149 | return; | |
150 | } | |
6242a600 AL |
151 | let doRequest = function() { |
152 | Proxmox.Utils.API2Request({ | |
153 | url: `/nodes/${rec.data.host}/ceph/${cmd}`, | |
154 | method: 'POST', | |
155 | params: { service: view.type + '.' + rec.data.name }, | |
156 | success: function(response, options) { | |
157 | Ext.create('Proxmox.window.TaskProgress', { | |
158 | autoShow: true, | |
159 | upid: response.result.data, | |
160 | taskDone: () => view.rstore.load(), | |
161 | }); | |
162 | }, | |
163 | failure: (response, _opts) => Ext.Msg.alert(gettext('Error'), response.htmlStatus), | |
164 | }); | |
165 | }; | |
166 | if (cmd === "stop" && ['mon', 'mds'].includes(view.type)) { | |
167 | Proxmox.Utils.API2Request({ | |
168 | url: `/nodes/${rec.data.host}/ceph/cmd-safety`, | |
169 | params: { | |
170 | service: view.type, | |
171 | id: rec.data.name, | |
172 | action: 'stop', | |
173 | }, | |
174 | method: 'GET', | |
175 | success: function({ result: { data } }) { | |
176 | let stopText = { | |
177 | mon: gettext('Stop MON'), | |
178 | mds: gettext('Stop MDS'), | |
179 | }; | |
180 | if (!data.safe) { | |
181 | Ext.Msg.show({ | |
182 | title: gettext('Warning'), | |
183 | message: data.status, | |
184 | icon: Ext.Msg.WARNING, | |
185 | buttons: Ext.Msg.OKCANCEL, | |
186 | buttonText: { ok: stopText[view.type] }, | |
187 | fn: function(selection) { | |
188 | if (selection === 'ok') { | |
189 | doRequest(); | |
190 | } | |
191 | }, | |
192 | }); | |
193 | } else { | |
194 | doRequest(); | |
195 | } | |
196 | }, | |
197 | failure: (response, _opts) => Ext.Msg.alert(gettext('Error'), response.htmlStatus), | |
198 | }); | |
199 | } else { | |
200 | doRequest(); | |
201 | } | |
89c04721 DC |
202 | }, |
203 | onChangeService: function(button) { | |
204 | let me = this; | |
205 | let record = me.getView().getSelection()[0]; | |
206 | me.service_cmd(record, button.action); | |
207 | }, | |
a6c60aed | 208 | |
89c04721 DC |
209 | showSyslog: function() { |
210 | let view = this.getView(); | |
211 | let rec = view.getSelection()[0]; | |
212 | let service = `ceph-${view.type}@${rec.data.name}`; | |
213 | Ext.create('Ext.window.Window', { | |
214 | title: `${gettext('Syslog')}: ${service}`, | |
215 | autoShow: true, | |
216 | modal: true, | |
217 | width: 800, | |
218 | height: 400, | |
219 | layout: 'fit', | |
220 | items: [{ | |
221 | xtype: 'proxmoxLogView', | |
222 | url: `/api2/extjs/nodes/${rec.data.host}/syslog?service=${encodeURIComponent(service)}`, | |
223 | log_select_timespan: 1, | |
224 | }], | |
225 | }); | |
226 | }, | |
a6c60aed | 227 | |
89c04721 DC |
228 | onCreate: function() { |
229 | let view = this.getView(); | |
230 | Ext.create('PVE.CephCreateService', { | |
231 | autoShow: true, | |
232 | nodename: view.nodename, | |
233 | subject: view.getTitle(), | |
234 | type: view.type, | |
235 | taskDone: () => view.rstore.load(), | |
236 | }); | |
237 | }, | |
238 | }); | |
a6c60aed | 239 | |
89c04721 DC |
240 | Ext.define('PVE.node.CephServiceList', { |
241 | extend: 'Ext.grid.GridPanel', | |
242 | xtype: 'pveNodeCephServiceList', | |
a6c60aed | 243 | |
89c04721 DC |
244 | onlineHelp: 'chapter_pveceph', |
245 | emptyText: gettext('No such service configured.'), | |
246 | ||
247 | stateful: true, | |
248 | ||
249 | // will be called when the store loads | |
250 | storeLoadCallback: Ext.emptyFn, | |
251 | ||
252 | // if set to true, does shows the ceph install mask if needed | |
253 | showCephInstallMask: false, | |
254 | ||
255 | controller: 'CephServiceList', | |
a6c60aed DC |
256 | |
257 | tbar: [ | |
258 | { | |
259 | xtype: 'proxmoxButton', | |
260 | text: gettext('Start'), | |
261 | iconCls: 'fa fa-play', | |
262 | action: 'start', | |
263 | disabled: true, | |
fb792310 | 264 | enableFn: rec => rec.data.state === 'stopped' || rec.data.state === 'unknown', |
f6710aac | 265 | handler: 'onChangeService', |
a6c60aed DC |
266 | }, |
267 | { | |
268 | xtype: 'proxmoxButton', | |
269 | text: gettext('Stop'), | |
270 | iconCls: 'fa fa-stop', | |
271 | action: 'stop', | |
fb792310 | 272 | enableFn: rec => rec.data.state !== 'stopped', |
a6c60aed | 273 | disabled: true, |
f6710aac | 274 | handler: 'onChangeService', |
a6c60aed DC |
275 | }, |
276 | { | |
277 | xtype: 'proxmoxButton', | |
278 | text: gettext('Restart'), | |
279 | iconCls: 'fa fa-refresh', | |
280 | action: 'restart', | |
281 | disabled: true, | |
fb792310 | 282 | enableFn: rec => rec.data.state !== 'stopped', |
f6710aac | 283 | handler: 'onChangeService', |
a6c60aed DC |
284 | }, |
285 | '-', | |
286 | { | |
287 | text: gettext('Create'), | |
288 | reference: 'createButton', | |
f6710aac | 289 | handler: 'onCreate', |
a6c60aed DC |
290 | }, |
291 | { | |
292 | text: gettext('Destroy'), | |
293 | xtype: 'proxmoxStdRemoveButton', | |
294 | getUrl: function(rec) { | |
fb792310 | 295 | let view = this.up('grid'); |
a6c60aed | 296 | if (!rec.data.host) { |
fb792310 TL |
297 | Ext.Msg.alert(gettext('Error'), "entry has no host, cannot build API url"); |
298 | return ''; | |
a6c60aed | 299 | } |
fb792310 | 300 | return `/nodes/${rec.data.host}/ceph/${view.type}/${rec.data.name}`; |
a6c60aed DC |
301 | }, |
302 | callback: function(options, success, response) { | |
fb792310 | 303 | let view = this.up('grid'); |
a6c60aed DC |
304 | if (!success) { |
305 | Ext.Msg.alert(gettext('Error'), response.htmlStatus); | |
306 | return; | |
307 | } | |
fb792310 TL |
308 | Ext.create('Proxmox.window.TaskProgress', { |
309 | autoShow: true, | |
310 | upid: response.result.data, | |
311 | taskDone: () => view.rstore.load(), | |
a6c60aed | 312 | }); |
f6710aac | 313 | }, |
6242a600 AL |
314 | handler: function(btn, event, rec) { |
315 | let me = this; | |
316 | let view = me.up('grid'); | |
317 | let doRequest = function() { | |
318 | Proxmox.button.StdRemoveButton.prototype.handler.call(me, btn, event, rec); | |
319 | }; | |
320 | if (view.type === 'mon') { | |
321 | Proxmox.Utils.API2Request({ | |
322 | url: `/nodes/${rec.data.host}/ceph/cmd-safety`, | |
323 | params: { | |
324 | service: view.type, | |
325 | id: rec.data.name, | |
326 | action: 'destroy', | |
327 | }, | |
328 | method: 'GET', | |
329 | success: function({ result: { data } }) { | |
330 | if (!data.safe) { | |
331 | Ext.Msg.show({ | |
332 | title: gettext('Warning'), | |
333 | message: data.status, | |
334 | icon: Ext.Msg.WARNING, | |
335 | buttons: Ext.Msg.OKCANCEL, | |
336 | buttonText: { ok: gettext('Destroy MON') }, | |
337 | fn: function(selection) { | |
338 | if (selection === 'ok') { | |
339 | doRequest(); | |
340 | } | |
341 | }, | |
342 | }); | |
343 | } else { | |
344 | doRequest(); | |
345 | } | |
346 | }, | |
347 | failure: (response, _opts) => Ext.Msg.alert(gettext('Error'), response.htmlStatus), | |
348 | }); | |
349 | } else { | |
350 | doRequest(); | |
351 | } | |
352 | }, | |
353 | ||
a6c60aed DC |
354 | }, |
355 | '-', | |
356 | { | |
357 | xtype: 'proxmoxButton', | |
358 | text: gettext('Syslog'), | |
359 | disabled: true, | |
f6710aac TL |
360 | handler: 'showSyslog', |
361 | }, | |
a6c60aed DC |
362 | ], |
363 | ||
364 | columns: [ | |
365 | { | |
366 | header: gettext('Name'), | |
ee099a5f | 367 | flex: 1, |
a6c60aed DC |
368 | sortable: true, |
369 | renderer: function(v) { | |
370 | return this.type + '.' + v; | |
371 | }, | |
f6710aac | 372 | dataIndex: 'name', |
a6c60aed DC |
373 | }, |
374 | { | |
375 | header: gettext('Host'), | |
ee099a5f | 376 | flex: 1, |
a6c60aed DC |
377 | sortable: true, |
378 | renderer: function(v) { | |
379 | return v || Proxmox.Utils.unknownText; | |
380 | }, | |
f6710aac | 381 | dataIndex: 'host', |
a6c60aed DC |
382 | }, |
383 | { | |
384 | header: gettext('Status'), | |
ee099a5f | 385 | flex: 1, |
a6c60aed | 386 | sortable: false, |
999df1c2 | 387 | renderer: 'render_status', |
f6710aac | 388 | dataIndex: 'state', |
a6c60aed DC |
389 | }, |
390 | { | |
391 | header: gettext('Address'), | |
ee099a5f | 392 | flex: 3, |
a6c60aed DC |
393 | sortable: true, |
394 | renderer: function(v) { | |
395 | return v || Proxmox.Utils.unknownText; | |
396 | }, | |
f6710aac | 397 | dataIndex: 'addr', |
a6c60aed DC |
398 | }, |
399 | { | |
400 | header: gettext('Version'), | |
ee099a5f | 401 | flex: 3, |
a6c60aed | 402 | sortable: true, |
277d6d15 DC |
403 | dataIndex: 'version', |
404 | renderer: 'render_version', | |
f6710aac | 405 | }, |
a6c60aed DC |
406 | ], |
407 | ||
408 | initComponent: function() { | |
fb792310 | 409 | let me = this; |
a6c60aed DC |
410 | |
411 | if (me.additionalColumns) { | |
412 | me.columns = me.columns.concat(me.additionalColumns); | |
413 | } | |
414 | ||
415 | me.callParent(); | |
f6710aac | 416 | }, |
a6c60aed DC |
417 | |
418 | }, function() { | |
a6c60aed DC |
419 | Ext.define('ceph-service-list', { |
420 | extend: 'Ext.data.Model', | |
fb792310 TL |
421 | fields: [ |
422 | 'addr', | |
423 | 'name', | |
999df1c2 | 424 | 'fs_name', |
fb792310 TL |
425 | 'rank', |
426 | 'host', | |
427 | 'quorum', | |
428 | 'state', | |
429 | 'ceph_version', | |
430 | 'ceph_version_short', | |
8058410f | 431 | { |
fb792310 TL |
432 | type: 'string', |
433 | name: 'version', | |
434 | calculate: data => PVE.Utils.parse_ceph_version(data), | |
fa8d3971 | 435 | }, |
a6c60aed | 436 | ], |
f6710aac | 437 | idProperty: 'name', |
a6c60aed DC |
438 | }); |
439 | }); | |
999df1c2 | 440 | |
8ce85523 TL |
441 | Ext.define('PVE.node.CephMDSServiceController', { |
442 | extend: 'PVE.node.CephServiceController', | |
443 | alias: 'controller.CephServiceMDSList', | |
444 | ||
445 | render_status: (value, mD, rec) => rec.data.fs_name ? `${value} (${rec.data.fs_name})` : value, | |
446 | }); | |
447 | ||
999df1c2 DC |
448 | Ext.define('PVE.node.CephMDSList', { |
449 | extend: 'PVE.node.CephServiceList', | |
450 | xtype: 'pveNodeCephMDSList', | |
451 | ||
452 | controller: { | |
8ce85523 | 453 | type: 'CephServiceMDSList', |
999df1c2 DC |
454 | }, |
455 | }); | |
456 |