import { shareReplay, startWith, switchMap } from 'rxjs';
import { injectCatalogsService } from '@/core/services/catalogs.service';
import { injectWebsocketService, WSEvents } from '@/core/services/websocket.service';

export const injectEventDates = () => {
	const catalogServ = injectCatalogsService();
	return injectWebsocketService()
		.listen(WSEvents.SCHEDULE, ['schedule_print'])
		.pipe(
			startWith(true),
			switchMap(() => catalogServ.getEventDates()),
			shareReplay(1)
		);
};