import { Pipe, PipeTransform } from '@angular/core';
import { StreamModel, ParticipantAbstractModel } from '../models/participant.model';

@Pipe({ name: 'streams' })
export class ParticipantStreamsPipe implements PipeTransform {
	constructor() {}

	transform(participants: ParticipantAbstractModel[] | ParticipantAbstractModel): StreamModel[] {
		let streams: StreamModel[] = [];
		if(participants && Object.keys(participants).length > 0){
			if (Array.isArray(participants)) {
				participants.forEach((p) => {
					streams = streams.concat(p.getAvailableConnections());
				});
			} else {

				streams = participants.getAvailableConnections();
			}
		}
		return streams;
	}
}

/**
 * @internal
 */
@Pipe({ name: 'streamTypesEnabled' })
export class StreamTypesEnabledPipe implements PipeTransform {
	constructor() {}

	transform(participant: ParticipantAbstractModel): string {
		const activeStreams = participant?.getConnectionTypesActive().toString();
		return `(${activeStreams.replace(',', ', ')})`;
	}
}