ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Net-Knuddels/Net/Knuddels.pm
Revision: 1.16
Committed: Thu Jan 13 18:50:36 2005 UTC (19 years, 4 months ago) by root
Branch: MAIN
Changes since 1.15: +155 -156 lines
Log Message:
*** empty log message ***

File Contents

# Content
1 =head1 NAME
2
3 Net::Knuddels - www.knuddels.de protocol implementation.
4
5 =head1 SYNOPSIS
6
7 use Net::Knuddels;
8
9 =head1 DESCRIPTION
10
11 RTSL.
12
13 =cut
14
15 package Net::Knuddels;
16
17 use Net::Knuddels::Dictionary;
18
19 use strict;
20 use utf8;
21
22 use Carp;
23 use Math::BigInt;
24
25 sub _to32($) {
26 unpack "l", pack "L", (new Math::BigInt $_[0]) & 0xffffffff
27 }
28
29 sub hash_pw($$) {
30 my ($challenge, $pw) = @_;
31
32 my $l1 = length $pw;
33 my $l2 = length $challenge;
34
35 my $k = chr ($l1 ^ ($l2 << 4));
36
37 my $l = $l1 < $l2 ? $l2 : $l1;
38
39 my $xor = substr +($pw x 100) ^ ($challenge x 100) ^ ($k x 100), 0, $l;
40
41 my ($i, $j);
42
43 --$l;
44
45 if ($l <= 17) {
46 for (0 .. $l) {
47 $i = _to32 $i * 3 + ord substr $xor, $l - $_;
48 $j = _to32 $j * 5 + ord substr $xor, $_;
49 }
50 } else {
51 for ($_ = $l; $_ >= 0; $_ -= int $_/19) {
52 $i = _to32 $i * 5 + ord substr $xor, $_;
53 $j = _to32 $j * 3 + ord substr $xor, $l - $_;
54 }
55 }
56
57 $i ^= $j;
58 _to32 (($i & 0xffffff) ^ ($i >> 24))
59 }
60
61 my $RE_dec = join "|", keys %$Net::Knuddels::Dictionary;
62
63 sub decode {
64 my $bin = unpack "b*", $_[0];
65 my $res = "";
66
67 while ($bin =~ /\G($RE_dec)/cog) {
68 my $frag = $Net::Knuddels::Dictionary->{$1};
69 $frag = chr unpack "v", pack "b*", $bin =~ /\G(.{16})/cg && $1 if $frag eq "\\\\\\";
70 $res .= $frag;
71 }
72 $bin =~ /\G(.*[^0].*)$/ and die "Net::Knuddels::Receiver: undecodable message tail '$1'";
73
74 $res
75 }
76
77 my %encode = reverse %$Net::Knuddels::Dictionary;
78
79 my $RE_enc = join "|", map quotemeta, sort { (length $b) <=> (length $a) } keys %encode;
80
81 sub encode($) {
82 my ($msg) = @_;
83
84 my $data = "";
85
86 while () {
87 $data .= $encode{$1} while $msg =~ /\G($RE_enc)/cog;
88
89 $msg =~ /\G./csog
90 or last;
91
92 $data .= $encode{"\\\\\\"} . unpack "b*", pack "v", ord $1;
93 }
94
95 pack "b*", $data
96 }
97
98 =head2 CLASS Net::Knuddels::Protocol
99
100 You B<must> call the C<destroy> method of this class when you no longer
101 use it, as circular references will keep the object alive otherwise.
102
103 =over 4
104
105 =cut
106
107 package Net::Knuddels::Protocol;
108
109 =item new
110
111 Create a new C<Net::Knuddels::Protocol> object.
112
113 =cut
114
115 sub new {
116 my $class = shift;
117
118 my %data;
119
120 my $self = bless {
121 @_
122 }, $class;
123
124 $self;
125 }
126
127 =item $protocol->feed_data ($octets)
128
129 Feed raw protocol data into the decoder.
130
131 =cut
132
133 sub feed_data($$) {
134 my ($self, $data) = @_;
135
136 # split data stream into packets
137
138 $data = "$self->{rbuf}$data";
139
140 while () {
141 1 <= length $data or last;
142 my $len = ord substr $data, 0, 1;
143
144 my $skip;
145 if ($len & 0x80) {
146 my $tail = (($len >> 5) & 3) - 1;
147 $len = ($len & 0x1f) + 1;
148
149 $tail < length $data or last;
150 $len += (ord substr $data, $_ + 1, 1) << ($_ * 8 + 5)
151 for 0 .. $tail;
152
153 $skip = 2 + $tail;
154 } else {
155 $skip = 1;
156 $len++;
157 }
158
159 $len + $skip <= length $data or last;
160 substr $data, 0, $skip, "";
161 my $msg = substr $data, 0, $len, "";
162
163 $self->feed_msg ($msg);
164 }
165
166 $self->{rbuf} = $data;
167 }
168
169 sub feed_msg($$) {
170 my ($self, $msg) = @_;
171
172 $self->feed_event (split /\0/, Net::Knuddels::decode $msg);
173 }
174
175 sub feed_event($@) {
176 my ($self, @cmd) = @_;
177
178 my $ev = $self->{cb}{ALL};
179 $_->(@cmd) for values %$ev;
180
181 unless ($self->{cb}{$cmd[0]}) {
182 my $ev = $self->{cb}{UNHANDLED};
183 $_->(@cmd) for values %$ev;
184 }
185
186 my $ev = $self->{cb}{shift @cmd};
187 $_->(@cmd) for values %$ev;
188 }
189
190 =item $msg = $protocol->encode_msg (@strings)
191
192 Join the strings with C<\0>, encode the result into a protocol packet and
193 return it.
194
195 =cut
196
197 sub encode_msg($@) {
198 my ($self, @args) = @_;
199 my $msg = Net::Knuddels::encode join "\0", @args;
200 my $len = (length $msg) - 1;
201
202 if ($len < 0x80) {
203 (chr $len) . $msg
204 } else {
205 (chr 0x80 | 0x40 | ($len & 0x1f))
206 . (chr +($len >> 5) % 0xff)
207 . (chr +($len >> 13) % 0xff)
208 . $msg
209 }
210 }
211
212 =item $protocol->register ($type => $callback)
213
214 Register a callback for events of type C<$type>, which is either the name
215 of a low-level event sent by the server (such as "k" for dialog box) or
216 the name of a generated event, such as C<login>.
217
218 =cut
219
220 sub register {
221 my ($self, $type, $cb) = @_;
222
223 $self->{cb}{$type}{$cb} = $cb;
224 }
225
226 =item $protocol->destroy
227
228 I<MUST> be called to destroy the object, otherwise it will leak (no automatic cleanup).
229
230 =cut
231
232 sub destroy {
233 my ($self) = @_;
234
235 delete $self->{cb};
236 }
237
238 =back
239
240 =head2 CLASS Net::Knuddels::Client
241
242 Implement a Knuddels client connection.
243
244 =over 4
245
246 =cut
247
248 package Net::Knuddels::Client;
249
250 sub handle_room {
251 my ($self, $room) = @_;
252
253 if ($room eq "-") {
254 if (defined $self->{only_room}) {
255 return $self->{only_room};
256 } else {
257 warn "Couldn't assign '-' room to a room!";
258 return '-';
259 }
260 } else {
261 return $room;
262 }
263 }
264
265 sub calc_user_stats {
266 my ($self, $user) = @_;
267
268 if ($user->{name} =~ s/\cJ(\d+)$//) {
269 $user->{age} = $1
270 }
271
272 if ($user->{picture} =~ m/\bmale/) {
273 $user->{gender} = 'm';
274 } elsif ($user->{picture} =~ m/female/) {
275 $user->{gender} = 'f';
276 }
277 return $user;
278 }
279
280 =item new Net::Knuddels::Client [IO::Socket::new arguments]
281
282 Create a new client connection.
283
284 =cut
285
286 use IO::Socket::INET;
287
288 sub new {
289 my ($class, @arg) = @_;
290
291 my $fh = new IO::Socket::INET @arg
292 or Carp::croak "Net::Knuddels::Client::new: $!";
293
294 my $self = bless {
295 fh => $fh,
296 proto => (new Net::Knuddels::Protocol),
297 }, $class;
298
299 syswrite $fh, "\0";
300
301 $self->register ("(" => sub {
302 $self->{login_challenge} = $_[0];
303 $self->{login_room} = $_[1];
304 $self->{proto}->feed_event ("login");
305 });
306 $self->register (r => sub {
307 $self->{proto}->feed_event (msg_priv => $self->handle_room ($_[2]), $_[0], $_[1], $_[3]);
308 });
309 $self->register (e => sub {
310 $self->{proto}->feed_event (msg_room => $self->handle_room ($_[1]), $_[0], $_[2]);
311 });
312 $self->register (l => sub {
313 my $room = $self->handle_room ($_[0]);
314 return if $room eq "-"; # things that shouln't happen
315
316 my $user = {
317 name => $_[1],
318 flag => $_[2],
319 color => $_[3],
320 picture => $_[4]
321 };
322
323 $self->calc_user_stats ($user);
324
325 my $rl = $self->{user_lists}->{lc $room}->{lc $user->{name}} = $user;
326
327 $self->{proto}->feed_event (join_room => $room, $user);
328 });
329 $self->register (w => sub {
330 my $room = $self->handle_room ($_[1]);
331 return if $room eq "-"; # things that shouln't happen
332
333 my $username = $_[0];
334
335 my $u = delete $self->{user_lists}->{lc $room}->{lc $username};
336
337 if (not defined $u) {
338 warn "User $username wasn't in room $room, trying to fix... but be careful!!!\n";
339 $u = { name => $username };
340 }
341
342 $self->{proto}->feed_event (part_room => $room, $u);
343 });
344 $self->register (a => sub {
345 # the only_room stuff is from java-code, which has naughy semantics
346 if (not defined $self->{only_room}) {
347 $self->{only_room} = $_[0];
348 } else {
349 $self->{only_room} = "-";
350 }
351
352 $self->{my_nick} = $_[1]; # i'm really _not_ shure about this
353
354 my $ri = $self->{room}->{lc $_[0]} = {
355 picture => $_[7],
356 };
357
358 $self->{proto}->feed_event (room_info => $_[0], $ri);
359 });
360 $self->register (u => sub {
361 my $room = shift;
362 my $rl = $self->{user_lists}->{lc $room} = {};
363 my $cur_u = {};
364
365 while (@_) {
366 $cur_u->{name} = shift;
367 $cur_u->{flag} = shift;
368 $cur_u->{color} = shift;
369
370 my $i = 0;
371
372 while ((my $nxt = shift) ne "-") {
373 if ($i == 0) {
374 $cur_u->{picture} = $nxt;
375 }
376 $i++;
377 }
378
379 $self->calc_user_stats ($cur_u);
380 $rl->{lc $cur_u->{name}} = $cur_u;
381 $cur_u = {};
382 }
383 $self->{proto}->feed_event (user_list => $room, $rl);
384 });
385
386 $self
387 }
388
389 =item $client->fh
390
391 Return the fh used for communications. You are responsible for calling C<<
392 $client->ready >> whenever the fh becomes ready for reading.
393
394 =cut
395
396 sub fh {
397 $_[0]->{fh}
398 }
399
400 =item $client->ready
401
402 To be called then the filehandle is ready for reading. Returns false if
403 the server closed the connection, true otherwise.
404
405 =cut
406
407 sub ready {
408 my ($self) = @_;
409
410 sysread $self->{fh}, my $buf, 8192
411 or return;
412
413 $self->{proto}->feed_data ($buf);
414
415 1;
416 }
417
418 =item $client->command ($type => @args)
419
420 Send a message of type C<$type> and the given arguments to the server.
421
422 =cut
423
424 sub command {
425 my ($self, $type, @args) = @_;
426
427 #use Dumpvalue; Dumpvalue->new (compactDump => 1, veryCompact => 1, quoteHighBit => 1, tick => '"')->dumpValue ([$type, @args]);
428
429 syswrite $self->{fh}, $self->{proto}->encode_msg ($type, @args);
430 }
431
432 =item $client->login ($url, $unknown)
433
434 Send a 't' message. The default for C<$url> is
435 C<http://www.knuddels.de/applet.html?v=86a&c=0> and C<$unknown> is C<6>.
436
437 =cut
438
439 sub login {
440 my ($self, $url, $unknown) = @_;
441
442 $self->command ("t", "V8.6a", $url || "http://www.knuddels.de/applet.html?v=86a&c=0", $unknown || 3);
443 }
444
445 =item $client->set_nick ($room, $nick, $password)
446
447 Registers the nick with the given password.
448
449 =cut
450
451 sub set_nick {
452 my ($self, $room, $nick, $password) = @_;
453
454 exists $self->{login_challenge} or Carp::croak "set_nick can only be called after a login event";
455
456 $self->command ("n", $room, $nick, Net::Knuddels::hash_pw $self->{login_challenge}, $password);
457 }
458
459 =item $client->register ($type => $cb)
460
461 See L<Net::Knuddels::Protocol::register>. The following extra events will
462 be generated by this class:
463
464 login
465 set_nick can only be called _after_ a login event has occured.
466
467 msg_room => $room, $user, $msg
468 produced when a public message is uttered :)
469
470 msg_room => $room, $src, $dst, $msg
471 personal message from $src to $dst
472
473 user_list => $room, $list
474 the userlist of a channel named $room, a elmement of the list (a user)
475 looks like:
476 {
477 name => <name>,
478 flag => <some flag i don't know what it means>,
479 color => like /\d+.\d+.\d+/,
480 age => /\d+/,
481 gender => /(f|m)/,
482 picture => <the picture file to put behind the nick>
483 }
484
485 room_info => $room, $room_info
486 some information about the $room:
487 $room_info =
488 {
489 picture => <some picturefile>
490 }
491
492 join_room => $room, $user
493 join message of $user joined the room $room
494 $user contains the user structure (see user_list).
495
496 part_room => $room, $user
497 part message of $user who left the room $room
498 $user contains the user structure (see user_list).
499 =cut
500
501 sub register {
502 my ($self, $type, $cb) = @_;
503
504 $self->{proto}->register ($type, $cb);
505 }
506
507 =back
508
509 =head1 AUTHOR
510
511 Marc Lehmann <pcg@goof.com>
512 http://home.schmorp.de/
513
514 =cut
515
516 1;
517