blob: 5c513c7f1fa1c894790c8007bf35488d4d8a6fa8 (
plain)
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
|
import { HttpClient, HttpParams } from '@angular/common/http';
import { Injectable } from '@angular/core';
import _ from 'lodash';
import { BehaviorSubject, Observable, of, throwError } from 'rxjs';
import { mergeMap, take, tap } from 'rxjs/operators';
import { RgwDaemon } from '~/app/ceph/rgw/models/rgw-daemon';
import { cdEncode } from '~/app/shared/decorators/cd-encode';
@cdEncode
@Injectable({
providedIn: 'root'
})
export class RgwDaemonService {
private url = 'api/rgw/daemon';
private daemons = new BehaviorSubject<RgwDaemon[]>([]);
daemons$ = this.daemons.asObservable();
private selectedDaemon = new BehaviorSubject<RgwDaemon>(null);
selectedDaemon$ = this.selectedDaemon.asObservable();
constructor(private http: HttpClient) {}
list(): Observable<RgwDaemon[]> {
return this.http.get<RgwDaemon[]>(this.url).pipe(
tap((daemons: RgwDaemon[]) => {
this.daemons.next(daemons);
const selectedDaemon = this.selectedDaemon.getValue();
// Set or re-select the default daemon if the current one is not
// in the list anymore.
if (_.isEmpty(selectedDaemon) || undefined === _.find(daemons, { id: selectedDaemon.id })) {
this.selectDefaultDaemon(daemons);
}
})
);
}
get(id: string) {
return this.http.get(`${this.url}/${id}`);
}
selectDaemon(daemon: RgwDaemon) {
this.selectedDaemon.next(daemon);
}
private selectDefaultDaemon(daemons: RgwDaemon[]): RgwDaemon {
if (daemons.length === 0) {
return null;
}
for (const daemon of daemons) {
if (daemon.default) {
this.selectDaemon(daemon);
return daemon;
}
}
this.selectDaemon(daemons[0]);
return daemons[0];
}
request(next: (params: HttpParams) => Observable<any>) {
return this.selectedDaemon.pipe(
mergeMap((daemon: RgwDaemon) =>
// If there is no selected daemon, retrieve daemon list so default daemon will be selected.
_.isEmpty(daemon)
? this.list().pipe(
mergeMap((daemons) =>
_.isEmpty(daemons) ? throwError('No RGW daemons found!') : this.selectedDaemon$
)
)
: of(daemon)
),
take(1),
mergeMap((daemon: RgwDaemon) => {
let params = new HttpParams();
params = params.append('daemon_name', daemon.id);
return next(params);
})
);
}
}
|
