--- deliantra/Deliantra-Client/DC/Protocol.pm 2007/07/12 17:56:51 1.113 +++ deliantra/Deliantra-Client/DC/Protocol.pm 2007/07/12 19:13:20 1.116 @@ -59,35 +59,42 @@ 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 resmap => $chksum, sub { + my ($meta) = @_; + + if (defined $meta) { + $self->{music_meta}{$chksum} = $self->{json_coder}->decode ($meta); + } 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, $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}); + }); + } + } } - - 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 {