1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
import { Component, Input, NgZone, OnChanges, OnDestroy, OnInit } from '@angular/core';
import { Subscription, timer as observableTimer } from 'rxjs';
import { HostService } from '~/app/shared/api/host.service';
import { OrchestratorService } from '~/app/shared/api/orchestrator.service';
import { Icons } from '~/app/shared/enum/icons.enum';
import { OrchestratorStatus } from '~/app/shared/models/orchestrator.interface';
import { InventoryDevice } from './inventory-devices/inventory-device.model';
@Component({
selector: 'cd-inventory',
templateUrl: './inventory.component.html',
styleUrls: ['./inventory.component.scss']
})
export class InventoryComponent implements OnChanges, OnInit, OnDestroy {
// Display inventory page only for this hostname, ignore to display all.
@Input() hostname?: string;
private reloadSubscriber: Subscription;
private reloadInterval = 5000;
private firstRefresh = true;
icons = Icons;
orchStatus: OrchestratorStatus;
showDocPanel = false;
devices: Array<InventoryDevice> = [];
constructor(
private orchService: OrchestratorService,
private hostService: HostService,
private ngZone: NgZone
) {}
ngOnInit() {
this.orchService.status().subscribe((status) => {
this.orchStatus = status;
this.showDocPanel = !status.available;
if (status.available) {
// Create a timer to get cached inventory from the orchestrator.
// Do not ask the orchestrator frequently to refresh its cache data because it's expensive.
this.ngZone.runOutsideAngular(() => {
// start after first pass because the embedded table calls refresh at init.
this.reloadSubscriber = observableTimer(
this.reloadInterval,
this.reloadInterval
).subscribe(() => {
this.ngZone.run(() => {
this.getInventory(false);
});
});
});
}
});
}
ngOnDestroy() {
this.reloadSubscriber?.unsubscribe();
}
ngOnChanges() {
if (this.orchStatus?.available) {
this.devices = [];
this.getInventory(false);
}
}
getInventory(refresh: boolean) {
if (this.hostname === '') {
return;
}
this.hostService.inventoryDeviceList(this.hostname, refresh).subscribe(
(devices: InventoryDevice[]) => {
this.devices = devices;
},
() => {
this.devices = [];
}
);
}
refresh() {
// Make the first reload (triggered by table) use cached data, and
// the remaining reloads (triggered by users) ask orchestrator to refresh inventory.
this.getInventory(!this.firstRefresh);
this.firstRefresh = false;
}
}
|
