--- deliantra/Deliantra-Client/DC/Protocol.pm 2007/07/12 17:56:51 1.113 +++ deliantra/Deliantra-Client/DC/Protocol.pm 2007/07/19 16:44:14 1.123 @@ -59,35 +59,49 @@ my @songs; # request music from server if appropriate - my $pri = -100; - for my $face (@$faces) { - if (defined (my $chksum = $ev->{chksum}{$face})) { + if (my $faces = $ev->{faces}) { + for (@$faces) { + my ($face, $pri, $chksum) = @$_; utf8::downgrade $chksum; $chksum = unpack "H*", $chksum; $self->{music_map}{$face} = $chksum; - ::message ({ markup => "starting to download song #$face, check your output-rate setting if your connection gets laggy." }); - $self->ask_face ($face, $pri, undef, sub { - my $num = $_[0]; - my $len = length $_[1]; - my ($meta, $data) = unpack "(w/a*)*", $_[1]; - - CFPlus::DB::write_file $chksum, $data, sub { }; - CFPlus::DB::put resmap => $chksum => $meta, sub { }; - - $self->{music_meta}{$chksum} = $self->{json_coder}->decode ($meta); - ::message ({ markup => "downloaded song #$face, size $len octets" }); - - &::audio_music_set ($self->{songs}); - }); + # check if already cached + CFPlus::DB::get "res-metadata" => $chksum, sub { + my ($meta_json) = @_; + my $path = CFPlus::DB::path_of_res $chksum; + + if (defined $meta_json) { + my $meta = $self->{json_coder}->decode ($meta_json); + $meta->{path} = $path; + $self->{music_meta}{$chksum} = $meta; + &::audio_music_set ($self->{songs}); + } else { + ::message ({ markup => "starting to download song #$face/$pri, check your output-rate setting if your connection gets laggy." }); + $self->ask_face ($face, -100 - $pri, undef, sub { + my $len = length $_[1]; + my ($meta_json, $data) = unpack "(w/a*)*", $_[1]; + + CFPlus::DB::write_file $path, $data, sub { + CFPlus::DB::put "res-metadata" => $chksum => $meta_json, sub { + my $meta = $self->{json_coder}->decode ($meta_json); + $meta->{path} = $path; + $self->{music_meta}{$chksum} = $meta; + + ::message ({ markup => "downloaded song #$face, size $len octets" }); + &::audio_music_set ($self->{songs}); + }; + }; + }); + } + } } - - push @songs, $self->{music_map}{$face}; - --$pri; } - &::audio_music_set ($self->{songs} = \@songs); + if (my $play = $ev->{play}) { + &::audio_music_set ($self->{songs} = [map $self->{music_map}{$_}, @$play]); + } }); $self->connect_ext (event_capabilities => sub { @@ -113,6 +127,7 @@ $self->{widget}{$_[0]} }); + # widgetset new $self->connect_ext (ws_n => sub { my ($arg) = @_; @@ -121,6 +136,7 @@ }; }); + # widgetset destroy $self->connect_ext (ws_d => sub { my ($arg) = @_; @@ -131,6 +147,7 @@ for values %{$ws->{w}}; }); + # widgetset destroy $self->connect_ext (ws_c => sub { my ($arg) = @_; @@ -170,6 +187,7 @@ } }); + # widget call $self->connect_ext (w_c => sub { my ($arg) = @_; @@ -186,6 +204,7 @@ } }); + # widget set $self->connect_ext (w_s => sub { my ($arg) = @_; @@ -195,6 +214,7 @@ $w->{$arg->{name}} = $arg->{value}; }); + # widget get $self->connect_ext (w_g => sub { my ($arg) = @_; @@ -204,6 +224,7 @@ $self->send_exti_msg (w_r => rid => $arg->{rid}, res => [$w->{$arg->{name}}]); }); + # destroy widgets on logout $self->{on_stop_game_guard} = $self->{map_widget}{root}->connect (stop_game => sub { for my $ws (values %{delete $self->{widgetset} || {}}) { $_->destroy @@ -754,12 +775,28 @@ sub set_texture { my ($self, $id, $data) = @_; + return unless $self->{map}; + $self->{texture}[$id] = my $tex = new_from_image CFPlus::Texture $data, minify => 1, mipmap => 1; $self->{map}->set_texture ($id, @$tex{qw(name w h s t)}, @{$tex->{minified}}); $self->{map_widget}->update; + + $_->() for @{(delete $self->{face_cb}{$id}) || []}; +} + +sub connect_face_update { + my ($self, $id, $cb) = @_; + + push @{$self->{face_cb}{$id}}, $cb; + + CFPlus::guard { + @{$self->{face_cb}{$id}} + = grep $_ != $cb, + @{$self->{face_cb}{$id}}; + } } sub sound_play {