ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/kgsueme/bin/kgsueme
Revision: 1.5
Committed: Thu May 29 01:13:32 2003 UTC (21 years ago) by pcg
Branch: MAIN
Changes since 1.4: +7 -1 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 pcg 1.1 #!/opt/bin/perl
2    
3     use PApp::Util qw(dumpval); # debug only
4    
5     use Gtk;
6     use Gtk::Gdk;
7    
8     use KGS::Protocol;
9     use KGS::Listener::Debug;
10    
11     use IO::Socket::INET;
12    
13     use Errno;
14    
15     init Gtk;
16    
17 pcg 1.3 $HACK = 1; # do NEVER enable. ;)
18    
19 pcg 1.2 our $config;
20    
21 pcg 1.1 {
22     use Storable ();
23     use Scalar::Util ();
24    
25     my $staterc = "$ENV{HOME}/.kgsueme";
26    
27     my $state = -r $staterc ? Storable::retrieve($staterc) : {};
28     my @widgets;
29    
30 pcg 1.2 $config = $state->{config} ||= {};
31    
32 pcg 1.1 # grr... more gtk+ brokenness
33     my %get = (
34     hpane_position => sub { ($_[0]->children)[0]->allocation->[2] },
35     vpane_position => sub { ($_[0]->children)[0]->allocation->[3] },
36     window_size => sub { [ @{$_[0]->allocation}[2,3] ] },
37     #window_pos => sub { die PApp::Util::dumpval [ $_[0]->get_root_origin ] },
38     clist_column_widths => sub {
39     $_[0]{column_widths};
40     },
41     );
42    
43     my %set = (
44     hpane_position => sub { $_[0]->set_position($_[1]) },
45     vpane_position => sub { $_[0]->set_position($_[1]) },
46     window_size => sub { $_[0]->set_default_size(@{$_[1]}) },
47     #window_pos => sub { $_[0]->set_uposition(@{$_[1]}) if @{$_[1]} },
48     clist_column_widths => sub {
49     my ($w, $v) = @_;
50     $v->[$_] && $w->set_column_width($_, $v->[$_]) for 0..$#$v;
51     $w->{column_widths} = $v;
52     $w->signal_connect(resize_column => sub { $v->[$_[1]] = $_[2]; });
53     },
54     );
55    
56     sub state {
57     my ($widget, $class, $instance, %attr) = @_;
58    
59     while (my ($k, $v) = each %attr) {
60     my ($set, $get) = $k =~ /=/ ? split /=/, $k : ($k, $k);
61     $v = $state->{$class}{"*"}{$get} if exists $state->{$class}{"*"}{$get};
62     $v = $state->{$class}{$instance}{$get} if exists $state->{$class}{$instance}{$get};
63     $set{$get} ? $set{$get}->($widget, $v) : $widget->set($set => $v);
64     }
65    
66     $widget = [$widget, $class, $instance, \%attr];
67     Scalar::Util::weaken $widget->[0];
68    
69     @widgets = (grep $_->[0], @widgets, $widget);
70     }
71    
72     sub save_state {
73     for (@widgets) {
74     if ($_->[0]) {
75     my ($widget, $class, $instance, $attr) = @$_;
76     while (my ($k, $v) = each %$attr) {
77     my ($set, $get) = $k =~ /=/ ? split /=/, $k : ($k, $k);
78     $v = $get{$get} ? $get{$get}->($widget) : $widget->get($get);
79    
80     $state->{$class}{"*"}{$get} = $v;
81     $state->{$class}{$instance}{$get} = $v;
82     }
83     }
84     ::status("save_state", "layout saved");
85     }
86    
87     Storable::nstore($state, $staterc);
88     }
89     }
90    
91     # make a clist unselectable
92     sub clist_autosort {
93     my $w = shift;
94     my ($c, $o) = (-1);
95     for (0..$w->columns-1) {
96     $w->signal_connect(click_column => sub {
97     if ($_[1] != $c) {
98     $c = $_[1];
99     $o = 0;
100     } else {
101     $o = !$o;
102     }
103     $w->set_sort_column($c);
104     $w->set_sort_type($o ? "descending" : "ascending");
105     $w->sort;
106     });
107     }
108    
109     }
110    
111     {
112     my $main = new kgsueme;
113    
114     my %context_id;
115    
116     sub status {
117     my ($type, $text) = @_;
118    
119     $main->{status}->pop($context_id{$type}) if $context_id{$type};
120     $main->{status}->push($context_id{$type} ||= $main->{status}->get_context_id($type), $text) if $text;
121     }
122     }
123    
124     main Gtk;
125    
126     #############################################################################
127    
128     package kgsueme;
129    
130     use base KGS::Listener;
131    
132     sub new {
133     my $self = shift;
134     $self = $self->SUPER::new(@_);
135    
136     $self->{conn} = new KGS::Protocol;
137    
138     KGS::Listener::Debug->new->listen($self->{conn}); #d# debug only :)
139    
140     $self->listen($self->{conn});
141    
142 pcg 1.4 $self->{roomlist} = new roomlist conn => $self->{conn};
143    
144 pcg 1.1 $self->{window} = new Gtk::Window 'toplevel';
145     $self->{window}->set_title('kgsueme');
146     ::state $self->{window}, "main::window", undef, window_size => [400, 100];
147     $self->{window}->signal_connect(delete_event => sub { main_quit Gtk });
148    
149     $self->{window}->add(my $vbox = new Gtk::VBox);
150    
151 pcg 1.4 $vbox->pack_start(($buttonbox = new Gtk::HButtonBox), 0, 1, 0);
152     $buttonbox->set_spacing(0);
153 pcg 1.1
154 pcg 1.2 my $button = sub {
155 pcg 1.4 $buttonbox->add(my $button = new Gtk::Button $_[0]);
156 pcg 1.2 signal_connect $button clicked => $_[1];
157     };
158 pcg 1.1
159 pcg 1.4 $button->("Login", sub { $self->login; });
160     $button->("Roomlist", sub { $self->{roomlist}->show; });
161 pcg 1.2 $button->("Save Config & Layout", sub { ::save_state });
162 pcg 1.4 $button->("Quit", sub { main_quit Gtk });
163 pcg 1.1
164     $vbox->pack_start((my $hbox = new Gtk::HBox), 0, 1, 0);
165    
166     $hbox->add(new Gtk::Label "Login");
167    
168     $hbox->add($self->{login} = new_with_max_length Gtk::Entry 12);
169 pcg 1.2 $self->{login}->set_text($::config->{login});
170 pcg 1.3
171     if ($::HACK) {
172     $self->{login}->signal_connect(activate => sub {
173     $self->{conn}{name} = $self->{login}->get_text;
174     });
175     }
176 pcg 1.1
177     $hbox->add(new Gtk::Label "Password");
178 pcg 1.2 $hbox->add($self->{password} = new Gtk::Entry);
179     $self->{password}->set_visibility(0);
180 pcg 1.1
181     $vbox->pack_start(($self->{status} = new Gtk::Statusbar), 0, 1, 0);
182    
183     $self->{window}->show_all;
184    
185     $self;
186     }
187    
188     sub login {
189     my ($self) = @_;
190    
191 pcg 1.2 $self->{conn}->disconnect;
192    
193 pcg 1.1 # initialize new socket and connection
194     my $sock = new IO::Socket::INET PeerHost => "kgs.kiseido.com", PeerPort => "2379"
195     or die;
196    
197     $sock->blocking(1);
198     $self->{conn}->handshake($sock);
199     $sock->blocking(0);
200    
201     my $input; $input = input_add Gtk::Gdk fileno $sock, "read", sub {
202     # this is dorked
203     my $buf;
204     if (0 >= sysread $sock, $buf, 16384
205     and !$!{EINTR} and !$!{EAGAIN}) {
206     input_remove Gtk::Gdk $input;
207     $self->event_disconnect;
208     }
209     $self->{conn}->feed_data($buf);
210     };
211    
212     # now login
213 pcg 1.2 $self->{conn}->login($self->{login}->get_text, $self->{password}->get_text);
214 pcg 1.1 }
215    
216     sub inject_login {
217     my ($self, $msg) = @_;
218    
219     ::status("login", "logged in as '$self->{conn}{name}' with status '$msg->{result}'");
220 pcg 1.2 $::config->{login} = $self->{conn}{name};
221 pcg 1.1
222 pcg 1.4 if ($msg->{success}) {
223 pcg 1.5 warn "hiya\n";
224 pcg 1.4 for (keys %{$::config->{rooms}}) {
225 pcg 1.5 warn "hiya $_\n";
226 pcg 1.4 $self->{roomlist}->join_room($_);
227     }
228     }
229    
230     warn PApp::Util::dumpval($::config);
231 pcg 1.1 }
232    
233     sub event_disconnect { }
234    
235     #############################################################################
236    
237     package roomlist;
238    
239     use base KGS::Listener::Roomlist;
240    
241     sub new {
242     my $self = shift;
243     $self = $self->SUPER::new(@_);
244    
245     $self->listen($self->{conn});
246    
247     $self->{window} = new Gtk::Window 'toplevel';
248     $self->{window}->set_title('KGS Rooms');
249     ::state $self->{window}, "roomlist::window", undef, window_size => [400, 200];
250    
251 pcg 1.5 $self->{window}->signal_connect(delete_event => sub { $self->{window}->hide });
252 pcg 1.1
253     $self->{window}->add(my $vbox = new Gtk::VBox);
254    
255     $vbox->pack_start((my $sw = new Gtk::ScrolledWindow), 1, 1, 0);
256     $sw->set_policy("automatic", "always");
257    
258     $sw->add($self->{roomlist} = new_with_titles Gtk::CList "Group", "Room Name", "Users", "Games", "Flags", "Channel");
259     $self->{roomlist}->set_selection_mode('multiple');
260     ::clist_autosort $self->{roomlist};
261     ::state $self->{roomlist}, "roomlist::roomlist", undef, clist_column_widths => [20, 200];
262    
263     $self->{roomlist}->signal_connect(select_row => sub {
264     my $room = $self->{roomlist}->get_row_data($_[1])
265     or return;
266     $self->{roomlist}->unselect_all;
267 pcg 1.4 $self->join_room($room->{channel});
268 pcg 1.1 });
269    
270     $self;
271     }
272    
273 pcg 1.4 sub join_room {
274     my ($self, $channel) = @_;
275    
276     $self->{room}{$channel} ||= room->new(channel => $channel, conn => $self->{conn}, users => {});
277     $self->{room}{$channel}->join;
278     }
279    
280 pcg 1.1 sub show {
281     my ($self, $msg) = @_;
282    
283     $self->msg(list_rooms => group => $_) for 0..5; # fetch all room names (should not!)
284     $self->{window}->show_all;
285     }
286    
287     sub event_update {
288     my ($self) = @_;
289    
290     $self->{event_update} ||= Gtk->timeout_add(200, sub {
291     my $l = $self->{roomlist};
292    
293     $l->freeze;
294     my $pos = $l->get_vadjustment->get_value;
295     $l->clear;
296    
297     my $row = 0;
298     for (values %{$self->{rooms}}) {
299     $l->append($_->{group}, $_->{name}, $_->{users}, $_->{games}, $_->{flags}, $_->{channel});
300     $l->set_row_data($row++, $_);
301     }
302     $l->sort;
303     $l->get_vadjustment->set_value($pos);
304     $l->thaw;
305    
306     delete $self->{event_update};
307     0;
308     });
309     }
310    
311     #############################################################################
312    
313     package room;
314    
315     use base KGS::Listener::Room;
316    
317     sub new {
318     my $self = shift;
319     $self = $self->SUPER::new(@_);
320    
321     $self->listen($self->{conn});
322    
323     $self->{window} = new Gtk::Window 'toplevel';
324     $self->{window}->set_title("KGS Room $self->{name}");
325     ::state $self->{window}, "room::window", $self->{name}, window_size => [600, 400];
326    
327     $self->{window}->signal_connect(delete_event => sub { $self->part });
328    
329     $self->{window}->add(my $hpane = new Gtk::HPaned);
330     ::state $hpane, "room::hpane", $self->{name}, hpane_position => 200;
331    
332     $hpane->add(my $vpane = new Gtk::VPaned);
333     ::state $vpane, "room::vpane", $self->{name}, vpane_position => 200;
334    
335     $vpane->add(my $sw = new Gtk::ScrolledWindow);
336     $sw->set_policy("automatic", "always");
337    
338     $sw->add($self->{gamelist} = new_with_titles Gtk::CList "T", "Black", "White", "Rules", "Notes");
339     ::clist_autosort $self->{gamelist};
340     ::state $self->{gamelist}, "room::gamelist", $self->{name}, clist_column_widths => [20, 120, 120, 120];
341    
342     $self->{gamelist}->signal_connect(select_row => sub {
343     my $game = $self->{gamelist}->get_row_data($_[1])
344     or return;
345     $self->{game}{$game->{channel}} ||= new game %$game, conn => $self->{conn};
346     $self->{game}{$game->{channel}}->join;
347     $self->{gamelist}->unselect_all;
348     });
349    
350     $vpane->add(my $vbox = new Gtk::VBox);
351    
352     $vbox->pack_start((my $sw = new Gtk::ScrolledWindow), 1, 1, 0);
353     $sw->set_policy("automatic", "always");
354    
355     $sw->add($self->{text} = new Gtk::Text);
356    
357     $vbox->pack_start(($self->{entry} = new Gtk::Entry), 0, 1, 0);
358     $self->{entry}->signal_connect(activate => sub {
359     my $text = $self->{entry}->get_text;
360     $self->say($text) if $text =~ /\S/;
361     $self->{entry}->set_text("");
362     });
363    
364     $hpane->add(my $sw = new Gtk::ScrolledWindow);
365     $sw->set_policy("automatic", "always");
366    
367     $sw->add($self->{userlist} = new_with_titles Gtk::CList "User", "Rank", "Flags");
368     ::clist_autosort $self->{userlist};
369     ::state $self->{userlist}, "room::userlist", $self->{name}, clist_column_widths => [120, 30];
370    
371     $self;
372     }
373    
374     sub event_update {
375     my ($self) = @_;
376    
377     $self->{event_update} ||= Gtk->timeout_add(200, sub {
378     my $l = $self->{userlist};
379    
380     $l->freeze;
381     my $pos = $l->get_vadjustment->get_value;
382     $l->clear;
383    
384     my $row = 0;
385     for (values %{$self->{users}}) {
386     $l->append($_->{name});
387     $l->set_row_data($row++, $_);
388     }
389     $l->sort;
390     $l->get_vadjustment->set_value($pos);
391     $l->thaw;
392    
393     delete $self->{event_update};
394     0;
395     });
396     }
397    
398     sub event_update_games {
399     my ($self) = @_;
400    
401     $self->{event_update_games} ||= Gtk->timeout_add(200, sub {
402     my $l = $self->{gamelist};
403    
404     $l->freeze;
405     my $pos = $l->get_vadjustment->get_value;
406     $l->clear;
407    
408     my $row = 0;
409     for (values %{$self->{games}}) {
410     $l->append($_->type, $_->user0, $_->user1, $_->rules, $_->notes);
411     $l->set_row_data($row++, $_);
412     }
413     $l->sort;
414     $l->get_vadjustment->set_value($pos);
415     $l->thaw;
416    
417     delete $self->{event_update_games};
418     0;
419     });
420     }
421    
422     sub join {
423     my ($self) = @_;
424     $self->SUPER::join;
425    
426     $self->{window}->show_all;
427     }
428    
429     sub part {
430     my ($self) = @_;
431     $self->SUPER::part;
432    
433 pcg 1.4 delete $::config->{rooms}{$self->{channel}};
434 pcg 1.1 $self->{window}->hide_all;
435     $self->event_update;
436     $self->event_update_games;
437 pcg 1.4 }
438    
439     sub event_join {
440     my ($self) = @_;
441     $self->SUPER::event_join;
442    
443     $::config->{rooms}{$self->{channel}} = 1;
444 pcg 1.1 }
445    
446     sub event_update_roominfo {
447     my ($self) = @_;
448    
449     $self->{text}->insert(undef, undef, undef, "$self->{owner}: $self->{description}\n\n");
450     }
451    
452     sub inject_msg_room {
453     my ($self, $msg) = @_;
454     return unless $self->{channel} == $msg->{channel};
455    
456     $self->{text}->insert(undef, undef, undef, "$msg->{name}: $msg->{message}\n");
457     }
458    
459     #############################################################################
460    
461     package game;
462    
463     use base KGS::Listener::Game;
464     use base KGS::Game;
465    
466     sub new {
467     my $self = shift;
468     $self = $self->SUPER::new(@_);
469    
470     $self->listen($self->{conn});
471    
472     $self->{window} = new Gtk::Window 'toplevel';
473     $self->{window}->set_title("KGS Game ".$self->user0." ".$self->user1);
474     ::state $self->{window}, "game::window", undef, window_size => [600, 500];
475    
476     $self->{window}->signal_connect(delete_event => sub { $self->part });
477    
478     $self->{window}->add(my $hpane = new Gtk::HPaned);
479     ::state $hpane, "game::hpane", undef, hpane_position => 500;
480    
481     $hpane->add(my $board = new Gtk::Table $self->{size}, $self->{size}, 1);
482    
483     for my $x (0 .. $self->{size} - 1) {
484     for my $y (0 .. $self->{size} - 1) {
485     my $cell = new Gtk::Label;
486     $board->attach_defaults($cell, $x, $x + 1, $y, $y + 1);
487     $self->{board}[$x][$y] = $cell;
488     }
489     }
490    
491     $hpane->add(my $vpane = new Gtk::VPaned);
492     ::state $vpane, "game", $self->{name}, vpane_position => 80;
493    
494     $vpane->add(my $sw = new Gtk::ScrolledWindow);
495     $sw->set_policy("automatic", "always");
496    
497     $sw->add($self->{userlist} = new_with_titles Gtk::CList "User", "Rank", "Flags");
498     ::clist_autosort $self->{userlist};
499     ::state $self->{userlist}, "room::userlist", $self->{name}, clist_column_widths => [120, 30];
500    
501     $vpane->add(my $vbox = new Gtk::VBox);
502    
503     $vbox->pack_start((my $sw = new Gtk::ScrolledWindow), 1, 1, 0);
504     $sw->set_policy("automatic", "always");
505    
506     $sw->add($self->{text} = new Gtk::Text);
507    
508     $vbox->pack_start(($self->{entry} = new Gtk::Entry), 0, 1, 0);
509     $self->{entry}->signal_connect(activate => sub {
510     my $text = $self->{entry}->get_text;
511     # add message
512     $self->{entry}->set_text("");
513     });
514    
515     $self;
516     }
517    
518     sub event_update {
519     my ($self) = @_;
520    
521     $self->{event_update} ||= Gtk->timeout_add(200, sub {
522     my $l = $self->{userlist};
523    
524     $l->freeze;
525     my $pos = $l->get_vadjustment->get_value;
526     $l->clear;
527    
528     my $row = 0;
529     for (values %{$self->{users}}) {
530     $l->append($_->{name});
531     $l->set_row_data($row++, $_);
532     }
533     $l->sort;
534     $l->get_vadjustment->set_value($pos);
535     $l->thaw;
536    
537     delete $self->{event_update};
538     0;
539     });
540     }
541    
542     sub join {
543     my ($self) = @_;
544     $self->SUPER::join;
545    
546     $self->{window}->show_all;
547     }
548    
549     sub part {
550     my ($self) = @_;
551     $self->SUPER::part;
552    
553     $self->{window}->hide_all;
554     $self->event_update;
555     }
556    
557     sub event_update_tree {
558     my ($self) = @_;
559    
560     for my $x (0 .. $self->{size} - 1) {
561     for my $y (0 .. $self->{size} - 1) {
562     $self->{board}[$x][$y]->set_text("");
563     }
564     }
565    
566     for (0..$self->{node}) {
567     while (my ($k, $v) = each %{$self->{tree}[$_]}) {
568     if ($k eq "move7") {
569     if ($v->[1] < 255) {
570     $self->{board}[$v->[1]][$v->[2]]->set_text(("X", "O", "-")[$v->[0]]);
571     }
572     }
573     }
574     }
575     }
576 pcg 1.5
577     package KGS::Game::Board;
578     package KGS::Game::Node;
579     package KGS::Game::Tree;
580 pcg 1.1
581     1;
582    
583    
584