const {
	map,
	prop,
	path,
	filter,
	find,
	indexBy,
	pickBy,
	propEq,
	values,
} = require('ramda');

const { createSelector } = require('reselect');

const { things } = require('../constants/pulse');

const storeKeyByType = map(prop('key'), indexBy(prop('type'), things));

const getPaiByTypeAndIndex = (type, index) => state => path([ storeKeyByType[type], index ], state.pulse.infos);

const getClientSinkInputs = client => state => pickBy(
	si => si.clientIndex === client.index,
	state.pulse.infos.sinkInputs,
);

const getModuleSinkInputs = module => state => pickBy(
	si => si.moduleIndex === module.index,
	state.pulse.infos.sinkInputs,
);

const getClientSourceOutputs = client => state => pickBy(
	so => so.clientIndex === client.index,
	state.pulse.infos.sourceOutputs,
);

const getModuleSourceOutputs = module => state => pickBy(
	so => so.moduleIndex === module.index,
	state.pulse.infos.sourceOutputs,
);

const getSinkSinkInputs = sink => state => pickBy(
	si => si.sinkIndex === sink.index,
	state.pulse.infos.sinkInputs,
);

const getDerivedMonitorSources = createSelector(
	state => state.pulse.infos.sources,
	sources => map(source => ({
		index: source.index,
		type: 'monitorSource',
		sinkIndex: source.monitorSourceIndex,
		sourceIndex: source.index,
	}), filter(source => source.monitorSourceIndex >= 0, sources)),
);

const getDefaultSourcePai = createSelector(
	state => state.pulse.infos.sources,
	state => state.pulse.serverInfo.defaultSourceName,
	(sources, defaultSourceName) => find(propEq('name', defaultSourceName), values(sources)),
);

const getDefaultSinkPai = createSelector(
	state => state.pulse.infos.sinks,
	state => state.pulse.serverInfo.defaultSinkName,
	(sinks, defaultSinkName) => find(propEq('name', defaultSinkName), values(sinks)),
);

const getRemoteServerByAddress = address => state => state.pulse.remoteServers[address];

module.exports = {
	getPaiByTypeAndIndex,
	getDerivedMonitorSources,

	getClientSinkInputs,
	getModuleSinkInputs,

	getClientSourceOutputs,
	getModuleSourceOutputs,

	getSinkSinkInputs,

	getDefaultSinkPai,
	getDefaultSourcePai,

	getRemoteServerByAddress,
};