mounts.service.ts

import { Injectable } from '@angular/core';
import { Subject, Observable, combineLatest } from 'rxjs';
import {
	ListMountsFlow,
	IRcloneServer,
	MountMountFlowParamsNode,
	MountMountFlow,
	MountMountFlowInNode,
	MountUnmountFlow,
	MountUnmountFlowInNode,
	MountUnmountFlowParamsNode,
	MountUnmountAllFlow,
} from '../../@dataflow/rclone';
import { CombErr } from '../../@dataflow/core';
import { ConnectionService } from '../connection.service';

@Injectable({
	providedIn: 'root',
})
export class MountsService {
	private listTrigger = new Subject<number>();
	list$: ListMountsFlow;

	private addTrigger = new Subject<MountMountFlowParamsNode>();
	add$: MountMountFlow;

	private unmountTrigger = new Subject<MountUnmountFlowParamsNode>();
	unmount$: MountUnmountFlow;

	private unmountAllTrigger = new Subject<number>();
	unmountAll$: MountUnmountAllFlow;

	constructor(private connectService: ConnectionService) {
		const outer = this;
		this.list$ = new (class extends ListMountsFlow {
			public prerequest$: Observable<CombErr<IRcloneServer>> = combineLatest(
				[outer.listTrigger, outer.connectService.listCmd$.verify(this.cmd)],
				(_, node) => node
			);
		})();
		this.list$.deploy();
		this.add$ = new (class extends MountMountFlow {
			public prerequest$: Observable<CombErr<MountMountFlowInNode>> = combineLatest(
				[outer.addTrigger, outer.connectService.listCmd$.verify(this.cmd)],
				(params, cmdNode) => [{ ...cmdNode[0], ...params }, cmdNode[1]]
			);
		})();
		this.add$.deploy();
		this.add$.getOutput().subscribe(node => {
			if (node[1].length !== 0) return;
			this.refreshList();
		});

		this.unmount$ = new (class extends MountUnmountFlow {
			public prerequest$: Observable<CombErr<MountUnmountFlowInNode>> = combineLatest(
				[outer.unmountTrigger, outer.connectService.listCmd$.verify(this.cmd)],
				(params, cmdNode) => [{ ...cmdNode[0], ...params }, cmdNode[1]]
			);
		})();
		this.unmount$.deploy();
		this.unmount$.getOutput().subscribe(node => {
			if (node[1].length !== 0) return;
			this.refreshList();
		});

		this.unmountAll$ = new (class extends MountUnmountAllFlow {
			public prerequest$: Observable<CombErr<IRcloneServer>> = combineLatest(
				[outer.unmountAllTrigger, outer.connectService.listCmd$.verify(this.cmd)],
				(_, node) => node
			);
		})();
		this.unmountAll$.deploy();
		this.unmountAll$.getOutput().subscribe(node => {
			if (node[1].length !== 0) return;
			this.refreshList();
		});
	}
	refreshList() {
		this.list$.clearCache();
		this.listTrigger.next(1);
	}

	mount(params: MountMountFlowParamsNode) {
		this.addTrigger.next(params);
	}

	unmount(params: MountUnmountFlowParamsNode) {
		this.unmountTrigger.next(params);
	}

	unmountAll() {
		this.unmountAllTrigger.next(1);
	}
}