130 lines
3.0 KiB
JavaScript
130 lines
3.0 KiB
JavaScript
|
|
const Bluebird = require('bluebird');
|
|
|
|
const PAClient = require('@futpib/paclient');
|
|
|
|
const { handleActions } = require('redux-actions');
|
|
|
|
const { pulse: pulseActions } = require('../actions');
|
|
|
|
const { things } = require('../constants/pulse');
|
|
|
|
function getFnFromType(type) {
|
|
let fn;
|
|
switch (type) {
|
|
case 'sink':
|
|
case 'card':
|
|
case 'source':
|
|
fn = type;
|
|
break;
|
|
case 'sinkInput':
|
|
case 'sourceOutput':
|
|
case 'client':
|
|
case 'module':
|
|
fn = `${type}ByIndex`;
|
|
break;
|
|
default:
|
|
throw new Error('Unexpected type: ' + type);
|
|
}
|
|
return 'get' + fn[0].toUpperCase() + fn.slice(1);
|
|
}
|
|
|
|
module.exports = store => {
|
|
const pa = new PAClient();
|
|
|
|
const getInfo = (type, index) => pa[getFnFromType(type)](index, (err, info) => {
|
|
if (err) {
|
|
if (err.message === 'No such entity') {
|
|
console.warn(err.message, type, index);
|
|
return;
|
|
}
|
|
throw err;
|
|
}
|
|
info.type = info.type || type;
|
|
store.dispatch(pulseActions.info(info));
|
|
});
|
|
|
|
pa
|
|
.on('ready', () => {
|
|
store.dispatch(pulseActions.ready());
|
|
pa.subscribe('all');
|
|
things.forEach(({ method, type }) => {
|
|
pa[method]((err, infos) => {
|
|
if (err) {
|
|
throw err;
|
|
}
|
|
infos.forEach(info => {
|
|
const { index } = info;
|
|
info.type = info.type || type;
|
|
store.dispatch(pulseActions.new({ type, index }));
|
|
store.dispatch(pulseActions.info(info));
|
|
});
|
|
});
|
|
});
|
|
})
|
|
.on('close', () => {
|
|
store.dispatch(pulseActions.close());
|
|
reconnect();
|
|
})
|
|
.on('new', (type, index) => {
|
|
store.dispatch(pulseActions.new({ type, index }));
|
|
getInfo(type, index);
|
|
})
|
|
.on('change', (type, index) => {
|
|
store.dispatch(pulseActions.change({ type, index }));
|
|
getInfo(type, index);
|
|
})
|
|
.on('remove', (type, index) => {
|
|
store.dispatch(pulseActions.remove({ type, index }));
|
|
})
|
|
.on('error', error => {
|
|
console.error(error);
|
|
});
|
|
|
|
const reconnect = () => new Bluebird((resolve, reject) => {
|
|
pa.once('ready', resolve);
|
|
pa.once('error', reject);
|
|
pa.connect();
|
|
}).catch(error => {
|
|
if (error.message === 'Unable to connect to PulseAudio server') {
|
|
return Bluebird.delay(5000).then(reconnect);
|
|
}
|
|
throw error;
|
|
});
|
|
|
|
reconnect();
|
|
|
|
const rethrow = error => {
|
|
if (error) {
|
|
throw error;
|
|
}
|
|
};
|
|
|
|
const handlePulseActions = handleActions({
|
|
[pulseActions.moveSinkInput]: (state, { payload: { sinkInputIndex, destSinkIndex } }) => {
|
|
pa.moveSinkInput(sinkInputIndex, destSinkIndex, rethrow);
|
|
return state;
|
|
},
|
|
[pulseActions.moveSourceOutput]: (state, { payload: { sourceOutputIndex, destSourceIndex } }) => {
|
|
pa.moveSourceOutput(sourceOutputIndex, destSourceIndex, rethrow);
|
|
return state;
|
|
},
|
|
[pulseActions.killClientByIndex]: (state, { payload: { clientIndex } }) => {
|
|
pa.killClientByIndex(clientIndex, rethrow);
|
|
return state;
|
|
},
|
|
[pulseActions.unloadModuleByIndex]: (state, { payload: { moduleIndex } }) => {
|
|
pa.unloadModuleByIndex(moduleIndex, rethrow);
|
|
return state;
|
|
},
|
|
}, null);
|
|
|
|
return next => action => {
|
|
const ret = next(action);
|
|
|
|
handlePulseActions(null, action);
|
|
|
|
return ret;
|
|
};
|
|
};
|