Commit 47aa249a authored by nanahira's avatar nanahira

Merge branch 'mc'

parents 1b89d7b4 09cdcc3f
...@@ -2215,6 +2215,9 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)-> ...@@ -2215,6 +2215,9 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)->
_async.auto({ _async.auto({
match_permit: (done) -> match_permit: (done) ->
if client.closed
done()
return
if(!settings.modules.arena_mode.check_permit) if(!settings.modules.arena_mode.check_permit)
done(null, null) done(null, null)
return return
...@@ -2230,7 +2233,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)-> ...@@ -2230,7 +2233,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)->
done(null, null) done(null, null)
return return
if !error and body if !error and body
done(null, boddy) done(null, body)
else else
log.warn("Match permit request error", error) log.warn("Match permit request error", error)
match_permit_callback(null, null) match_permit_callback(null, null)
...@@ -2238,6 +2241,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)-> ...@@ -2238,6 +2241,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)->
return return
get_user: (done) -> get_user: (done) ->
if client.closed if client.closed
done()
return return
if id = users_cache[client.name] if id = users_cache[client.name]
secret = id % 65535 + 1 secret = id % 65535 + 1
...@@ -2249,6 +2253,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)-> ...@@ -2249,6 +2253,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)->
original: decrypted_buffer, original: decrypted_buffer,
decrypted: decrypted_buffer decrypted: decrypted_buffer
}) })
return
#TODO: query database directly, like preload. #TODO: query database directly, like preload.
request request
...@@ -2283,13 +2288,14 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)-> ...@@ -2283,13 +2288,14 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server, datas)->
decrypted: decrypted_buffer decrypted: decrypted_buffer
}) })
return return
return
}, (err, data) -> }, (err, data) ->
if(client.closed) if(client.closed)
return return
if(err) if(err)
ygopro.stoc_die(client, err) ygopro.stoc_die(client, err)
return return
create_room_with_action(data.get_user.original, data.get_user.decrypted, match_permit) create_room_with_action(data.get_user.original, data.get_user.decrypted, data.match_permit)
) )
......
...@@ -2808,6 +2808,10 @@ ...@@ -2808,6 +2808,10 @@
}; };
_async.auto({ _async.auto({
match_permit: function(done) { match_permit: function(done) {
if (client.closed) {
done();
return;
}
if (!settings.modules.arena_mode.check_permit) { if (!settings.modules.arena_mode.check_permit) {
done(null, null); done(null, null);
return; return;
...@@ -2826,7 +2830,7 @@ ...@@ -2826,7 +2830,7 @@
return; return;
} }
if (!error && body) { if (!error && body) {
done(null, boddy); done(null, body);
} else { } else {
log.warn("Match permit request error", error); log.warn("Match permit request error", error);
match_permit_callback(null, null); match_permit_callback(null, null);
...@@ -2836,6 +2840,7 @@ ...@@ -2836,6 +2840,7 @@
get_user: function(done) { get_user: function(done) {
var decrypted_buffer, i, id, len2, m, ref3, secret; var decrypted_buffer, i, id, len2, m, ref3, secret;
if (client.closed) { if (client.closed) {
done();
return; return;
} }
if (id = users_cache[client.name]) { if (id = users_cache[client.name]) {
...@@ -2851,6 +2856,7 @@ ...@@ -2851,6 +2856,7 @@
original: decrypted_buffer, original: decrypted_buffer,
decrypted: decrypted_buffer decrypted: decrypted_buffer
}); });
return;
} }
} }
request({ request({
...@@ -2885,7 +2891,7 @@ ...@@ -2885,7 +2891,7 @@
done('${invalid_password_checksum}'); done('${invalid_password_checksum}');
return; return;
} }
return done(null, { done(null, {
original: buffer, original: buffer,
decrypted: decrypted_buffer decrypted: decrypted_buffer
}); });
...@@ -2899,7 +2905,7 @@ ...@@ -2899,7 +2905,7 @@
ygopro.stoc_die(client, err); ygopro.stoc_die(client, err);
return; return;
} }
return create_room_with_action(data.get_user.original, data.get_user.decrypted, match_permit); return create_room_with_action(data.get_user.original, data.get_user.decrypted, data.match_permit);
}); });
} else if (settings.modules.challonge.enabled) { } else if (settings.modules.challonge.enabled) {
pre_room = ROOM_find_by_name(info.pass); pre_room = ROOM_find_by_name(info.pass);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment