51 lines
1.9 KiB
TypeScript
51 lines
1.9 KiB
TypeScript
import {Injectable, inject} from '@angular/core';
|
|
import {Observable} from 'rxjs';
|
|
import {DbService} from '../../../services/db.service';
|
|
import {Show} from './show';
|
|
import {map, shareReplay} from 'rxjs/operators';
|
|
import {orderBy, QueryConstraint, Timestamp, where} from 'firebase/firestore';
|
|
|
|
@Injectable({
|
|
providedIn: 'root',
|
|
})
|
|
export class ShowDataService {
|
|
private dbService = inject(DbService);
|
|
|
|
private collection = 'shows';
|
|
public list$: Observable<Show[]> = this.dbService.col$<Show>(this.collection).pipe(
|
|
// server-side ordering cuts client work and keeps stable order across subscribers
|
|
map(shows => [...shows].sort((a, b) => a.date.toMillis() - b.date.toMillis())),
|
|
shareReplay({
|
|
bufferSize: 1,
|
|
refCount: true,
|
|
})
|
|
);
|
|
|
|
public listRaw$ = () => this.dbService.col$<Show>(this.collection);
|
|
|
|
public listPublicSince$(lastMonths: number): Observable<Show[]> {
|
|
const queryConstraints: QueryConstraint[] = [where('published', '==', true), orderBy('date', 'desc')];
|
|
|
|
if (lastMonths < 99999) {
|
|
const startDate = new Date();
|
|
startDate.setHours(0, 0, 0, 0);
|
|
startDate.setDate(startDate.getDate() - lastMonths * 30);
|
|
const startTimestamp = Timestamp.fromDate(startDate);
|
|
queryConstraints.splice(1, 0, where('date', '>=', startTimestamp));
|
|
}
|
|
|
|
return this.dbService.col$<Show>(this.collection, queryConstraints).pipe(
|
|
map(shows => shows.filter(show => !show.archived)),
|
|
shareReplay({
|
|
bufferSize: 1,
|
|
refCount: true,
|
|
})
|
|
);
|
|
}
|
|
|
|
public read$ = (showId: string): Observable<Show | null> => this.dbService.doc$(`${this.collection}/${showId}`);
|
|
|
|
public update = async (showId: string, data: Partial<Show>): Promise<void> => await this.dbService.doc(`${this.collection}/${showId}`).update(data);
|
|
public add = async (data: Partial<Show>): Promise<string> => (await this.dbService.col(this.collection).add(data)).id;
|
|
}
|