import { Injectable } from '@angular/core'; import {HttpClient, HttpHeaders} from '@angular/common/http'; import {BehaviorSubject, firstValueFrom, Observable} from 'rxjs'; import {User} from '../models/User'; @Injectable({ providedIn: 'root' }) export class UsersService { private currentUser : BehaviorSubject = new BehaviorSubject(null); private apiKey: string = ""; private url = "http://localhost:8080/users" private authUrl = "http://localhost:8080/auth" private httpOptions = { headers: new HttpHeaders({ 'Content-Type': 'application/json', "jelly-api-key": this.apiKey }) }; private httpOptions2 = { headers: new HttpHeaders({ 'Content-Type': 'application/json', "jelly-api-key": this.apiKey }), responseType: "text" as "json" // don't ask me how or why this works, bc i have no clue... // see the relevant angular bug report https://github.com/angular/angular/issues/18586 }; constructor( private http: HttpClient ) {} async createUser(username:string, password:string) { await firstValueFrom(this.http.post(this.url, {username: username, password: password}, this.httpOptions)) } getUser(id: string): Observable { return this.http.get(`${this.url}/${id}`, this.httpOptions) } updateUser(id: number): Observable { return this.http.put(`${this.url}/${id}`, this.httpOptions) } deleteUser(id: number): Observable { return this.http.delete(`${this.url}/${id}`, this.httpOptions) } getCurrentUserSubject() { return this.currentUser; } getCurrentUser() { return this.currentUser.getValue() } async login(username: string, password: string) { let res = this.http.post(this.authUrl, {username: username, password: password}, this.httpOptions2); this.apiKey = await firstValueFrom(res); console.log("apikey: "+this.apiKey) let res2 = this.http.get(`${this.url}/${username}`, { headers: new HttpHeaders({ 'Content-Type': 'application/json', "jelly-api-key": this.apiKey }) }) let currentU = await firstValueFrom(res2); this.currentUser.next(currentU); // this.currentUser.subscribe(r => console.log("currentUser: "+r.username)) } }