(async function (){
const token = await client.pop('games:wait');
const {player1} = await client.hgetall('games:wait:' + token);
const accountInfo = await client.hgetall('account:' + player1);
})().catch(e){ console.error(e); }
client.pop('games:wait')
client.hgetall('games:wait:' + token)
client.hgetall('account:' + player1)
client.pop('games:wait')
.then((token) => client.hgetall('games:wait:' + token))
.then(({gameInfo: player1}) => client.hgetall('account:' + player1)
.then((accountInfo) => console.log(accountInfo))
.catch((error) => console.error(error));
exports.findOrCreate = async function findOrCreate(userID, provider){
const accountID = await client.getAsync('accounts:' + provider + ':' + userID);
if (accountID !== null) {
return client.hgetallAsync('account:' + accountID); // 1
}else{
throw 'user not found';
}
};
(async () => {
const promise = findOrCreate(1); //Возвратит promise
const users = await findOrCreate(1); //Возвратит пользователей
const users = await promise; //Возвратит пользователей, аналог предыдущей строчки
})();
const xArray = [-1, 0, 1, 2, 3, 4, 5, 11];
let xArray2 = xArray.filter((x) => {
return 0 <= x && x <= 10;
});
xArray2; // [0, 1, 2, 3, 4, 5]
const chat = io.connect(config.wssHost);
// Иначе при переподключении будут дублироваться
chat.on('connect', function() {
console.log('Connected');
});
chat.on('message', function(message){
console.log(message);
});
io.on('connection', function (socket) {
socket.on('message', function (data) {
//socket.broadcast.emit('message', data); // (1)
console.log(data);
io.sockets.emit('message', data);
});
});