subject fini

This commit is contained in:
Hedi 2022-03-21 18:19:25 +01:00
parent 8b00bb2ba3
commit 62ae357403
3 changed files with 53 additions and 20 deletions

View File

@ -1,4 +1,4 @@
<table class="table"> <table class="table" *ngIf="subCollection$ | async as collection">
<thead class="thead-dark"> <thead class="thead-dark">
<tr> <tr>
<th scope="col">Id</th> <th scope="col">Id</th>
@ -14,16 +14,16 @@
</tr> </tr>
</thead> </thead>
<tbody> <tbody>
<tr *ngFor="let products of listData"> <tr *ngFor="let products of collection">
<th scope="row">{{products.product_id}}</th> <th scope="row">{{products.id}}</th>
<td>{{products.product_name}}</td> <td>{{products.name}}</td>
<td>{{products.product_price}}</td> <td>{{products.price}}</td>
<td>{{products.product_qty}}</td> <td>{{products.quantity}}</td>
<td>{{products.product_instock}}</td> <td>{{products.instock}}</td>
<td>{{products.product_breadcrumb_label}}</td> <!-- <td>{{products.Catégorie.}}</td> -->
<td>{{products.product_rating}}</td> <td>{{products.rating}}</td>
<td><a class="bi-pencil-square" routerLink="../modifier"></a></td> <td><a class="bi-pencil-square" routerLink="../modifier"></a></td>
<td class="bi-trash-fill" style="color: red; cursor: pointer;" (click)="onClickDelete(products.product_id)"></td> <td class="bi-trash-fill" style="color: red; cursor: pointer;" (click)="onClickDelete(5)"></td>
</tr> </tr>
</tbody> </tbody>
</table> </table>

View File

@ -1,4 +1,6 @@
import { Component, OnInit } from '@angular/core'; import { Component, OnInit } from '@angular/core';
import { Subject } from 'rxjs';
import { Plant } from '../../models/plant';
import { AdminService } from '../../services/admin.service'; import { AdminService } from '../../services/admin.service';
@Component({ @Component({
@ -8,15 +10,22 @@ import { AdminService } from '../../services/admin.service';
}) })
export class PageTableauComponent implements OnInit { export class PageTableauComponent implements OnInit {
public listData!: any[]; public listData!: any[];
constructor(private adminService: AdminService) { } public subCollection$: Subject<Plant[]>;
constructor(private adminService: AdminService) {
this.subCollection$ = this.adminService.subCollection$;
this.adminService.refreshCollection();
this.adminService.subCollection$.subscribe((data: Plant[]) => console.log("après mapping", data))
}
ngOnInit(): void { ngOnInit(): void {
this.listData = []; // this.listData = [];
this.adminService.getData().subscribe( // this.adminService.getData().subscribe(
(listPlant: any[]) => { // (listPlant: any[]) => {
this.listData = listPlant; // this.listData = listPlant;
this.listData.length = 9; // this.listData.length = 9;
}) // })
} }
onClickDelete(id: number){ onClickDelete(id: number){

View File

@ -1,19 +1,43 @@
import { HttpClient } from '@angular/common/http'; import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core'; import { Injectable } from '@angular/core';
import { Observable } from 'rxjs'; import { map, Observable, Subject } from 'rxjs';
import { environment } from 'src/environments/environment'; import { environment } from 'src/environments/environment';
import { Plant } from '../models/plant';
@Injectable({ @Injectable({
providedIn: 'root' providedIn: 'root'
}) })
export class AdminService { export class AdminService {
public collection$!: Observable<Plant[]>;
public subCollection$ = new Subject<Plant[]>();
apiUrl: string; apiUrl: string;
public plantCollection!: Plant[];
constructor(private httpClient: HttpClient) { constructor(private httpClient: HttpClient) {
this.apiUrl = environment.apiUrl; this.apiUrl = environment.apiUrl;
this.collection$ = this.httpClient.get<Plant[]>(`${this.apiUrl}/list_products`).pipe(
// Ici on modifie l'objet que transporte notre Observable grâce à l'opérateur map()
map((tabObj: any[]) => {
//console.log("avant mapping: ", tabObj);
// Ici grâce à la méthode .map() on transforme tout les objet json du tableau en instance de notre classe Plant()
return tabObj.map((obj: any) => {
return new Plant(obj.product_name, obj.product_price,obj.product_quantity,obj.product_instock,obj.product_breadcrumb_label,obj.product_image_source,obj.product_rating,obj.id);
})
}));
//this.collection$ = this.httpClient.get<Plant[]>(`${this.apiUrl}/list_products`);
//console.log(this.collection$);
} }
getData(): Observable<any[]> { public refreshCollection(): void {
return this.httpClient.get<any[]>(`${this.apiUrl}/list_products`); // On se sert de notre flux de donnée type observable froid
this.collection$.subscribe((listPlant: Plant[]) => {
this.plantCollection = [...listPlant];
// Utiliser un observable chaud (subject) pour nexter nos données recues de notre observable froid
this.subCollection$.next(listPlant);
})
} }
// getData(): Observable<any[]> {
// return this.httpClient.get<any[]>(`${this.apiUrl}/list_products`);
// }
} }