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