Renamed staff to employees

apps/dafa-web/src/app/services/api/employee.service.ts

@@ -0,0 +1,69 @@
+import { HttpClient } from '@angular/common/http';
+import { Injectable } from '@angular/core';
+import { environment } from '@dafa-environment';
+import { Employee, EmployeeDetail } from '@dafa-models/employee.model';
+import { SortBy } from '@dafa-models/sort-by.model';
+import { sort } from '@dafa-utils/sort.util';
+import { BehaviorSubject, combineLatest, Observable, throwError } from 'rxjs';
+import { catchError, map } from 'rxjs/operators';
+
+function filterEmployees(employees: Employee[], searchFilter: string): Employee[] {
+  return employees.filter(person => {
+    const searchValueExistsInName = person.fullName.toLowerCase().includes(searchFilter.toLowerCase());
+
+    return searchValueExistsInName;
+  });
+}
+
+@Injectable({
+  providedIn: 'root',
+})
+export class EmployeeService {
+  private _employeesApiUrl = `${environment.apiBase}/employees`;
+  private _allEmployees$: Observable<Employee[]> = this.httpClient.get<Employee[]>(this._employeesApiUrl, {
+    params: { _embed: 'participants' },
+  });
+
+  private _employeesSortBy$ = new BehaviorSubject<SortBy | null>({ key: 'fullName', reverse: false });
+  public employeesSortBy$: Observable<SortBy> = this._employeesSortBy$.asObservable();
+  private _searchFilter$ = new BehaviorSubject<string>('');
+  public searchFilter$: Observable<string> = this._searchFilter$.asObservable();
+
+  private _filteredEmployees$: Observable<Employee[]> = combineLatest([this._allEmployees$, this._searchFilter$]).pipe(
+    map(([employees, searchFilter]) => filterEmployees(employees, searchFilter))
+  );
+
+  public filteredEmployees$: Observable<Employee[]> = combineLatest([
+    this._filteredEmployees$,
+    this._employeesSortBy$,
+  ]).pipe(
+    map(([employees, sortBy]) => {
+      return sortBy ? sort(employees, sortBy) : employees;
+    })
+  );
+
+  constructor(private httpClient: HttpClient) {}
+
+  public getDetailedEmployeeData(id: string): Observable<Employee> {
+    return this.httpClient.get<Employee>(`${this._employeesApiUrl}/${id}`, { params: { _embed: 'participants' } });
+  }
+
+  public setSearchFilter(value: string) {
+    this._searchFilter$.next(value);
+  }
+
+  public setEmployeesSortKey(key: keyof Employee) {
+    const currentSortBy = this._employeesSortBy$.getValue();
+    const reverse = currentSortBy?.key === key ? !currentSortBy.reverse : false;
+    this._employeesSortBy$.next({ key, reverse });
+  }
+
+  public createAccount(employeesData: EmployeeDetail): Observable<string> {
+    return this.httpClient.post<EmployeeDetail>(this._employeesApiUrl, employeesData).pipe(
+      map(data => data.id),
+      catchError(error => {
+        return throwError(error);
+      })
+    );
+  }
+}