ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/ext/login.ext
Revision: 1.117
Committed: Fri Feb 3 03:01:44 2012 UTC (12 years, 3 months ago) by root
Branch: MAIN
Changes since 1.116: +1 -1 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.102 #! perl # mandatory depends=highscore
2 root 1.1
3     # login handling
4    
5     use Fcntl;
6     use Coro::AIO;
7 root 1.53
8 root 1.117 CONF MAX_DISCONNECT_TIME = 3600;
9 root 1.64
10 root 1.9 # paranoia function to overwrite a string-in-place
11     sub nuke_str {
12     substr $_[0], 0, (length $_[0]), "x" x length $_[0]
13     }
14 root 1.1
15     sub query {
16     my ($ns, $flags, $text) = @_;
17    
18 root 1.94 $ns->query ($flags, $text, Coro::rouse_cb);
19     Coro::rouse_wait
20 root 1.1 }
21    
22     sub can_cleanup {
23 root 1.19 my ($pl, $mtime) = @_;
24 root 1.1
25     my $age = time - $mtime;
26 root 1.19 my $level = $pl->ob->level;
27 root 1.1
28     ($level <= 3 && $age > 7 * 86400) # 7 days for level 0..3
29     || ($level <= 9 && $age > 90 * 86400) # 3 months for level 4..9
30     || ($level <= 20 && $age > 180 * 86400) # 6 months for level 10..20
31     || $age > 700 * 86400 # 2 years for everybody else
32     }
33    
34     sub check_playing {
35     my ($ns, $user) = @_;
36    
37 root 1.11 return unless cf::player::find_active $user;
38 root 1.1
39     $ns->send_drawinfo (
40     "That player is already logged in on this server. "
41     . "If you want to create a new player, choose another name. "
42 root 1.59 . "If you have already a registered, make sure nobody "
43     . "else is using your account at this time. If you lost your connection "
44 root 1.1 . "then the server will likely timeout within a minute. If you still "
45     . "cannot log-in after a minute, you are still logged in. Make sure "
46     . "you do not have another client running. If you use windows, reboot, "
47     . "this will fix anything.",
48     cf::NDI_RED
49     );
50    
51     1
52     }
53    
54 root 1.79 sub safe_spot($) {
55     my ($pl) = @_;
56    
57     my $ob = $pl->ob;
58 root 1.76
59 root 1.79 my $m = $ob->map
60     or return;
61     my $x = $ob->x;
62     my $y = $ob->y;
63    
64 root 1.113 # never happens normally, but helps when shell users make mistakes
65 root 1.116 $m->linkable
66 root 1.113 or return 1;
67    
68 root 1.79 # return 0;#d#
69     # warn join ":", $m->at ($x, $y);#d#
70     # warn "FOO$m { ".scalar ($m->at ($x, $y))." }\n";
71     # return 0;
72 root 1.78
73 root 1.76 scalar grep $_->type == cf::SAVEBED, $m->at ($x, $y)
74     }
75    
76 root 1.48 sub enter_map {
77 root 1.11 my ($pl) = @_;
78    
79 root 1.62 my $ob = $pl->ob;
80    
81 root 1.48 my ($map, $x, $y)
82 root 1.62 = $ob->{_link_pos}
83     ? @{delete $ob->{_link_pos}}
84     : ($pl->maplevel, $ob->x, $ob->y);
85 root 1.48
86 root 1.62 $ob->enter_link;
87 root 1.48
88 root 1.77 my $m = cf::map::find $map;
89     my $time = delete $pl->{unclean_save};
90    
91 root 1.79 if ($time && $m) {
92 root 1.77 if ($time < $m->{instantiate_time}) {
93     # the map was reset in the meantime
94     my $age = $cf::RUNTIME - $time;
95    
96 root 1.107 cf::info $ob->name, " map reset after logout, logout age $age (>= $MAX_DISCONNECT_TIME)\n";#d#
97 root 1.77
98     if ($age >= $MAX_DISCONNECT_TIME) {
99     $ob->message (
100     "You didn't use a bed to reality to leave this realm, leaving your body in great danger. "
101     . "Unfortunately, nobody was near to help you when the monsters arrived to eat you. "
102     . "Maybe you can find comfort in the thought that your body was quite satisfying in taste... "
103     . "H<You disconnected too long without having used a savebed.>",
104     cf::NDI_RED
105     );
106     # kill them.
107     # reminds me of the famous badness 10000 syndrome...
108     $ob->stats->hp (-10000); #] if they survive this they deserved to live
109 root 1.86 my $killer = cf::arch::get "killer_login"; $pl->killer ($killer); $killer->destroy;
110 root 1.48 } else {
111 root 1.81 ($map, $x, $y) = $pl->savebed;
112    
113 root 1.64 $ob->message (
114 root 1.77 "You didn't use a bed to reality to leave this realm, leaving your body in great danger. "
115     . "Fortunately, some friendly dwellers found you, checked your passport, and brought you to safety. "
116     . "Better use a savebed next time, much worse things could have happened... "
117     . "H<You disconnected without having used a savebed. When you do that for too long, you might die.>",
118 root 1.48 cf::NDI_RED
119     );
120     }
121 root 1.77 } else {
122     $ob->message (
123     "You didn't use a bed to reality to leave this realm. This is very dangerous, "
124     . "as lots of things could happen when you leave by other means, such as cave-ins, "
125     . "or monsters suddenly snapping your body. Better use a savebed next time. "
126     . "H<Always apply a bed of reality to disconnect from the server.>",
127     cf::NDI_RED
128     );
129 root 1.48 }
130 root 1.11 }
131 root 1.48
132 root 1.100 $ob->goto ($map, $x, $y);
133 root 1.11 }
134    
135 root 1.110 sub encode_password($) {
136     # crypt $_[0],
137     # join '',
138     # ('.', '/', 0..9, 'A'..'Z', 'a'..'z')[(cf::rndm 64), (cf::rndm 64)]
139     "!" . unpack "H*", $_[0]
140     }
141    
142     sub compare_password($$) {
143     my ($pass, $token) = @_;
144    
145     if ($token =~ /\!(.*)/) {
146     return $pass eq pack "H*", $1;
147     } else {
148     return $token eq crypt $pass, $token;
149     }
150 elmex 1.106 }
151    
152 root 1.111 # delete a player directory
153 root 1.1 sub nuke_playerdir {
154     my ($user) = @_;
155    
156 root 1.111 my $lock = cf::lock_acquire "ext::login::nuke_playerdir";
157    
158 root 1.71 my $temp = "$PLAYERDIR/~$Coro::current~deleting~";
159 root 1.111 aio_rename "$PLAYERDIR/$user", $temp;
160     IO::AIO::aio_rmtree $temp;
161 root 1.1 }
162    
163 root 1.60 cf::client->attach (on_addme => sub {
164 root 1.1 my ($ns) = @_;
165    
166 root 1.32 $ns->pl and return $ns->destroy;
167 root 1.1
168 root 1.10 $ns->async (sub {
169 root 1.72 $Coro::current->{desc} = "addme init";
170    
171 root 1.1 my ($user, $pass);
172    
173     $ns->send_packet ("addme_success");
174    
175     for (;;) {
176     $ns->send_drawinfo (
177     "Please enter your username now. If you are a new user, "
178     . "make one up that describes your character best. "
179     . "Only letters and digits are allowed, though.",
180     cf::NDI_BLUE
181     );
182    
183     # read username
184     while () {
185 root 1.89 $user = query $ns, 0, "What is your name? (login names are case-sensitive)\n:";
186 root 1.3
187     if ($cf::LOGIN_LOCK{$user}) {
188     $ns->send_drawinfo (
189     "That username is currently used in another login session. "
190     . "Chose another, or wait till the other session has ended.",
191     cf::NDI_RED
192     );
193 root 1.92 } elsif ($user =~ /^[a-zA-Z0-9][a-zA-Z0-9\-_]{2,19}\z/) {
194 root 1.3 last;
195     } else {
196     $ns->send_drawinfo (
197     "Your username contains illegal characters "
198     . "(only a-z, A-Z and 0-9 are allowed), "
199 root 1.92 . "or is not between 3 and 20 characters in length.",
200 root 1.3 cf::NDI_RED
201     );
202     }
203 root 1.61 Coro::Timer::sleep 0.4;
204 root 1.1 }
205    
206     check_playing $ns, $user and next;
207    
208 root 1.72 $Coro::current->{desc} = "addme($user) pass";
209    
210 root 1.1 $ns->send_drawinfo (
211     "Welcome $user, please enter your password now. "
212     . "New users should now choose a password. "
213     . "Anything your client lets you enter is fine.",
214     cf::NDI_BLUE
215     );
216    
217     # read password
218     while () {
219     $pass = query $ns, cf::CS_QUERY_HIDEINPUT, "What is your password?\n:";
220     last if $pass =~ /.../;
221     $ns->send_drawinfo (
222     "Try to use at least three characters as your password please, "
223     . "that cannot be too much to ask for :)",
224     cf::NDI_RED
225     );
226 root 1.61 Coro::Timer::sleep 0.4;
227 root 1.1 }
228    
229 root 1.3 # lock this username for the remainder of this login session
230     if ($cf::LOGIN_LOCK{$user}) {
231     $ns->send_drawinfo (
232     "That username is currently used in another login session. "
233     . "Chose another, or wait till the other session has ended.",
234     cf::NDI_RED
235     );
236     next;
237     }
238     local $cf::LOGIN_LOCK{$user} = 1;
239    
240     check_playing $ns, $user and next;
241    
242 root 1.72 $Coro::current->{desc} = "addme($user) check";
243    
244 root 1.1 # try to read the user file and check the password
245 root 1.19 if (my $pl = cf::player::find $user) {
246     aio_stat $pl->path and next;
247     my $mtime = (stat _)[9];
248 root 1.110 my $token = $pl->password;
249 root 1.1
250 root 1.110 if ($cf::CFG{ext_login_nocheck} or compare_password $pass, $token) {
251     $pl->password (encode_password $pass); # make sure we store the new encoding #d#
252 root 1.9 nuke_str $pass;
253 root 1.1 # password matches, wonderful
254 root 1.11 my $pl = cf::player::find $user or next;
255 root 1.1 $pl->connect ($ns);
256 root 1.48 enter_map $pl;
257 root 1.1 last;
258 root 1.19 } elsif (can_cleanup $pl, $mtime) {
259 root 1.1 Coro::Timer::sleep 1;
260    
261     $ns->send_drawinfo (
262 root 1.3 "Player exists, but password does not match. If this is your account, "
263     . "please try again. If not, you can now decide to take over this account "
264 root 1.1 . "because it has not been in-use for some time.",
265     cf::NDI_RED
266     );
267    
268 root 1.9 #TODO: nuke_str
269 root 1.1 (query $ns, cf::CS_QUERY_SINGLECHAR, "Delete existing account and create a new one (Y/N)?") =~ /^[yY]/
270     or next;
271    
272     # check if the file hasn't changed
273 root 1.11 aio_stat cf::player::path $user and next;
274 root 1.1 $mtime == (stat _)[9] or next;
275    
276 root 1.19 $pl->quit_character;
277 root 1.1
278     # fall through to creation
279     } else {
280 root 1.9 nuke_str $pass;
281    
282 root 1.1 Coro::Timer::sleep 1;
283    
284     $ns->send_drawinfo (
285     "Wrong username or password. Please try again "
286     . "(check for Numlock and other semi-obvious error sources).",
287     cf::NDI_RED
288     );
289     next;
290     }
291 root 1.37 } else {
292     # unable to load the playerfile:
293 root 1.114 # check whether the player dir exists, which means the file is corrupted or
294 root 1.37 # something very similar.
295     if (!aio_stat cf::player::playerdir $user) {
296     $ns->send_drawinfo (
297     "Unable to retrieve this player. It might be a locked or broken account. "
298     . "If this is your account, ask a dungeon master for assistance. "
299     . "Otherwise choose a different login name.",
300     cf::NDI_RED
301     );
302     next;
303     }
304 root 1.1 }
305    
306     # the rest of this function is character creation
307 root 1.72 $Coro::current->{desc} = "addme($user) chargen";
308 root 1.1
309 root 1.3 # just to make sure nothing is left over
310 root 1.111 # normally, nothing is there.
311 root 1.1 nuke_playerdir $user;
312    
313 root 1.3 my $pass2 = query $ns, cf::CS_QUERY_HIDEINPUT, "Please type your password again.";
314    
315     if ($pass2 ne $pass) {
316 root 1.9 nuke_str $pass;
317     nuke_str $pass2;
318 root 1.3 $ns->send_drawinfo (
319     "The passwords do not match, please try again.",
320     cf::NDI_RED
321     );
322 root 1.61 Coro::Timer::sleep 0.5;
323 root 1.3 next;
324     }
325    
326 root 1.9 nuke_str $pass2;
327    
328 root 1.11 my $pl = cf::player::new $user;
329 elmex 1.106 $pl->password (encode_password $pass);
330 root 1.9 nuke_str $pass;
331 root 1.1 $pl->connect ($ns);
332 root 1.48 my $ob = $pl->ob;
333 root 1.3
334 root 1.48 $ob->goto ($pl->maplevel, $ob->x, $ob->y);
335 root 1.1
336     while () {
337     $ob->update_stats;
338     $pl->save_stats;
339    
340     my $res = query $ns, cf::CS_QUERY_SINGLECHAR,
341     "[y] to roll new stats [n] to use stats\n[1-7] [1-7] to swap stats.\nRoll again (y/n/1-7)?";
342    
343     if ($res =~ /^[Nn]/) {
344     last;
345     } elsif ($res > 0 && $res <= 7) {
346     my $swap = query $ns, cf::CS_QUERY_SINGLECHAR, "Swap stat with (will not roll new stats) [1-7]?";
347    
348     if ($swap > 0 && $swap <= 7) {
349     $ob->swap_stats ($res - 1, $swap - 1);
350     }
351     } else {
352     $ob->roll_stats;
353     }
354 root 1.61
355 root 1.87 Coro::Timer::sleep 0.05;
356 root 1.1 }
357    
358     $ob->set_animation (2);
359     $ob->add_statbonus;
360    
361 root 1.45 while () {
362 root 1.67 $ns->send_msg ("chargen-race-title", ucfirst $pl->title, -1);
363 root 1.45 my $msg = $ob->msg;
364 root 1.46 $msg =~ s/(?<=\S)\n(?=\S)/ /g;
365 root 1.67 $ns->send_msg ("chargen-race-description", $msg, cf::NDI_BLUE);
366 root 1.45
367     my $res = query $ns, cf::CS_QUERY_SINGLECHAR,
368     "Now choose a character.\nPress any key to change outlook.\nPress `d' when you're pleased.\n";
369    
370     last if $res =~ /[dD]/;
371    
372     $pl->chargen_race_next;
373 root 1.103 Coro::Timer::sleep 0.05;
374 root 1.45 }
375    
376 root 1.85 # create the playerdir, if necessary, as chargen_race_done did it before
377     # presumably because of unique maps
378     aio_mkdir playerdir $pl, 0770;
379 root 1.45 $pl->chargen_race_done;
380 root 1.1
381 root 1.55 while () {
382     my $res = query $ns, cf::CS_QUERY_SINGLECHAR,
383     "Now choose a gender.\nPress 'f' to become female, and 'm' to become male.\n";
384    
385     if ($res =~ /^[fF]/) {
386     $pl->gender (1);
387     last;
388     } elsif ($res =~ /^[mM]/) {
389     $pl->gender (0);
390     last;
391     }
392 root 1.103 Coro::Timer::sleep 0.05;
393 root 1.55 }
394    
395 root 1.75 $ob->reply (undef, "Welcome to Deliantra!");
396 root 1.55
397 elmex 1.93 # XXX: Workaround for delayed client ext protocol handshake
398     $pl->esrv_new_player;
399    
400 root 1.45 delete $pl->{deny_save};
401 root 1.1
402     last;
403     }
404 root 1.101
405     if (0 < Coro::AIO::aio_load "$cf::CONFDIR/motd", my $motd) {
406     $ns->send_msg ("c/motd" => $motd, cf::NDI_CLEAR);
407     }
408 root 1.1 });
409 root 1.60 });
410 root 1.1
411 elmex 1.106 cf::register_command password => sub {
412     my ($pl, $arg) = @_;
413    
414 elmex 1.112 unless ($pl->flag (cf::FLAG_WIZ)) {
415     $pl->message (
416     "The password can currently only changed by a DM.",
417     cf::NDI_UNIQUE | cf::NDI_REPLY);
418     return;
419     }
420    
421 elmex 1.106 my (@args) = split /\s+/, $arg;
422 elmex 1.112 my ($player, $new_pw) = @args;
423 elmex 1.106
424     if ($pl->flag (cf::FLAG_WIZ) && $player eq '') {
425     $pl->message (
426     "Usage: password <player> [<new password>]",
427     cf::NDI_UNIQUE | cf::NDI_REPLY);
428     return;
429     }
430    
431 elmex 1.112 if ($new_pw eq '') {
432     $new_pw =
433     join '',
434     map { ('.', '/', 0..9, 'A'..'Z', 'a'..'z')[(cf::rndm 64)] }
435     1..9;
436     }
437 elmex 1.106
438 elmex 1.112 cf::async {
439     my $plc = cf::player::find $player;
440     if ($plc) {
441     $plc->password (encode_password $new_pw);
442 elmex 1.106 $pl->message (
443 elmex 1.112 "Ok, changed password of '$player' to '$new_pw'!",
444 elmex 1.106 cf::NDI_UNIQUE | cf::NDI_RED | cf::NDI_REPLY);
445     } else {
446     $pl->message (
447 elmex 1.112 "Fail! Couldn't set password for '$player', "
448     . "he doesn't seem to exist!",
449 elmex 1.106 cf::NDI_UNIQUE | cf::NDI_RED | cf::NDI_REPLY);
450     }
451 elmex 1.112 };
452 elmex 1.106 };
453    
454 root 1.12 cf::register_command quit => sub {
455     my ($ob, $arg) = @_;
456    
457 root 1.95 $ob->send_msg (undef,
458     "Quitting will delete your character PERMANENTLY: It will be gone forever and any progress will be lost. "
459     . "If you are sure you want to do this, then use the quit_character command instead of quit.",
460     cf::NDI_UNIQUE | cf::NDI_RED | cf::NDI_REPLY);
461 root 1.12 };
462    
463     cf::register_command quit_character => sub {
464     my ($ob, $arg) = @_;
465    
466     my $pl = $ob->contr;
467    
468     $pl->ns->query (cf::CS_QUERY_SINGLECHAR, "Do you want to PERMANENTLY delete your character and all associated data (y/n)?", sub {
469     if ($_[0] !~ /^[yY]/) {
470 root 1.95 $ob->send_msg (undef, "Ok, not not quitting then.", cf::NDI_UNIQUE | cf::NDI_RED | cf::NDI_REPLY);
471 root 1.12 } else {
472 root 1.95 $ob->send_msg (undef, "Ok, quitting, hope to see you again.", cf::NDI_UNIQUE | cf::NDI_RED | cf::NDI_REPLY);
473 root 1.105 cf::async {
474     $pl->quit_character;
475     };
476 root 1.12 }
477     });
478     };
479 root 1.11
480 root 1.1 cf::object->attach (
481     type => cf::SAVEBED,
482     on_apply => sub {
483     my ($bed, $ob) = @_;
484    
485     return cf::override 0 unless $ob->type == cf::PLAYER;
486    
487 root 1.15 my $pl = $ob->contr;
488 root 1.11
489 root 1.1 # update respawn position
490 root 1.11 $pl->savebed ($bed->map->path, $bed->x, $bed->y);
491 root 1.1
492 root 1.111 cf::async {
493     my $killer = cf::arch::get "killer_logout"; $pl->killer ($killer); $killer->destroy;
494     ext::highscore::check $ob;
495    
496     $pl->save;
497 root 1.1
498 root 1.111 $ob->send_msg ($cf::SAY_CHANNEL => "In the future, you will wake up here when you die.", cf::NDI_DEF | cf::NDI_REPLY);
499 root 1.1
500 root 1.115 my $ns = $pl->ns
501     or return;
502    
503     $ns->query (cf::CS_QUERY_SINGLECHAR, "Do you want to continue playing (y/n)?", sub {
504 root 1.111 if ($_[0] !~ /^[yY]/) {
505     $pl->invoke (cf::EVENT_PLAYER_LOGOUT, 1);
506     $pl->deactivate;
507     $pl->ns->destroy;
508     }
509     });
510     };
511 root 1.1 },
512     );
513    
514 root 1.8 cf::player->attach (
515     on_login => sub {
516     my ($pl) = @_;
517     my $name = $pl->ob->name;
518    
519     $_->ob->message ("$name has entered the game.", cf::NDI_DK_ORANGE | cf::NDI_UNIQUE) for cf::player::list;
520     },
521     on_logout => sub {
522     my ($pl, $cleanly) = @_;
523     my $name = $pl->ob->name;
524    
525     if ($cleanly) {
526     $_->ob->message ("$name left the game.", cf::NDI_DK_ORANGE | cf::NDI_UNIQUE) for cf::player::list;
527     } else {
528     $_->ob->message ("$name uncerimoniously disconnected.", cf::NDI_DK_ORANGE | cf::NDI_UNIQUE) for cf::player::list;
529 root 1.79 $pl->{unclean_save} = $cf::RUNTIME
530     unless safe_spot $pl;
531 root 1.8 }
532     },
533     );
534