Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-01-23 02:35:49 +00:00
Code Issues Projects Releases Wiki Activity

chore(distribute) rm apply

Browse source
This commit is contained in:
coderaiser 2018-10-02 13:11:51 +03:00
parent 9c2ed05bab
commit 331952a8f5
2 changed files with 22 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

6
server/distribute/export.js
View file

@ -45,7 +45,11 @@ module.exports = (socket) => {
const prefix = config('prefix');
const distributePrefix = `${prefix}/distribute`;
const onError = squad(logWraped(exportStr), getMessage);
const onError = squad(
logWraped(exportStr),
getMessage,
);
const onConnectError = squad(logWraped(exportStr), getDescription);
socket.of(distributePrefix)

29
server/distribute/import.js
View file

@ -61,8 +61,6 @@ const emitAuth = wraptile((importUrl, socket) => {
socket.emit('auth', config('importToken'));
});
const apply = (fn, args) => fn.apply(null, args);
module.exports = (options, fn) => {
fn = fn || options;
@ -92,30 +90,30 @@ module.exports = (options, fn) => {
const statusStore = fullstore();
const statusStoreWraped = wraptile(statusStore);
const onConfig = apply(squad, [
const onConfig = squad(
close,
logWraped(importStr, `config received from ${colorUrl}`),
statusStoreWraped('received'),
forEachKey(config),
]);
);
const onError = apply(squad, [
const onError = squad(
superFn('error'),
logWraped(importStr),
addUrl(colorUrl),
getMessage,
]);
);
const onConnectError = apply(squad, [
const onConnectError = squad(
superFn('connect_error'),
logWraped(importStr),
addUrl(colorUrl),
getDescription,
]);
);
const onConnect = emitAuth(importUrl, socket);
const onAccept = logWraped(importStr,`${connectedStr} to ${colorUrl}`);
const onDisconnect = apply(squad, [
const onDisconnect = squad(
done(fn, statusStore),
logWraped(importStr, `${disconnectedStr} from ${colorUrl}`),
rmListeners(socket, {
@ -123,10 +121,17 @@ module.exports = (options, fn) => {
onConnect,
onConfig,
}),
]);
);
const onChange = squad(logWraped(importStr), config);
const onReject = squad(superFn('reject'), logWraped(importStr, tokenRejectedStr));
const onChange = squad(
logWraped(importStr),
config,
);
const onReject = squad(
superFn('reject'),
logWraped(importStr, tokenRejectedStr),
);
socket.on('connect', onConnect);
socket.on('accept', onAccept);