X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXCommandmode.pm;h=6b62f58a820f02d1215f7b7decd1054300ad0ec0;hb=be587fd8dade028c10545ffff4be13b0a18f3f91;hp=80a31ed517a6829d91c4cf5ae034478403cf711f;hpb=5f2487385b59dbe88dc763fa9c26fe5a9b4a6b30;p=spider.git diff --git a/perl/DXCommandmode.pm b/perl/DXCommandmode.pm index 80a31ed5..6b62f58a 100644 --- a/perl/DXCommandmode.pm +++ b/perl/DXCommandmode.pm @@ -87,7 +87,9 @@ sub start my $name = $user->{name}; # log it - my $host = $self->{conn}->{peerhost} || "unknown"; + my $host = $self->{conn}->{peerhost}; + $host ||= "AGW Port #$self->{conn}->{agwport}" if exists $self->{conn}->{agwport}; + $host ||= "unknown"; Log('DXCommand', "$call connected from $host"); $self->{name} = $name ? $name : $call; @@ -129,7 +131,12 @@ sub start # decide which motd to send - my $motd = "${main::motd}_nor" unless $self->{registered}; + my $motd; + unless ($self->{registered}) { + $motd = "${main::motd}_nor_$self->{lang}"; + $motd = "${main::motd}_nor" unless -e $motd; + } + $motd = "${main::motd}_$self->{lang}" unless $motd && -e $motd; $motd = $main::motd unless $motd && -e $motd; $self->send_file($motd) if -e $motd; @@ -428,6 +435,8 @@ sub run_cmd if ($cmd) { # strip out // on command only $cmd =~ s|//|/|g; + $cmd =~ s|^/||g; # no leading / either + $cmd =~ s|[^-\w/]||g; # and no funny characters either my ($path, $fcmd); @@ -443,7 +452,7 @@ sub run_cmd # first expand out the entry to a command ($path, $fcmd) = search($main::localcmd, $cmd, "pl"); - ($path, $fcmd) = search($main::cmd, $cmd, "pl") if !$path || !$fcmd; + ($path, $fcmd) = search($main::cmd, $cmd, "pl") unless $path && $fcmd; if ($path && $cmd) { dbg("path: $cmd cmd: $fcmd") if isdbg('command'); @@ -489,7 +498,7 @@ sub run_cmd sub process { my $t = time; - my @dxchan = DXChannel->get_all(); + my @dxchan = DXChannel::get_all(); my $dxchan; foreach $dxchan (@dxchan) { @@ -577,7 +586,7 @@ sub broadcast my $pkg = shift; # ignored my $s = shift; # the line to be rebroadcast - foreach my $dxchan (DXChannel->get_all()) { + foreach my $dxchan (DXChannel::get_all()) { next unless $dxchan->{sort} eq 'U'; # only interested in user channels next if grep $dxchan == $_, @_; $dxchan->send($s); # send it @@ -587,7 +596,7 @@ sub broadcast # gimme all the users sub get_all { - return grep {$_->{sort} eq 'U'} DXChannel->get_all(); + return grep {$_->{sort} eq 'U'} DXChannel::get_all(); } # run a script for this user @@ -625,40 +634,42 @@ sub search my @parts = split '/', $short_cmd; my $dirfn; my $curdir = $path; - my $p; - my $i; - my @lparts; - for ($i = 0; $i < @parts; $i++) { - my $p = $parts[$i]; - opendir(D, $curdir) or confess "can't open $curdir $!"; - my @ls = readdir D; - closedir D; - my $l; - foreach $l (sort @ls) { - next if $l =~ /^\./; - if ($i < $#parts) { # we are dealing with directories - if ((-d "$curdir/$l") && $p eq substr($l, 0, length $p)) { - dbg("got dir: $curdir/$l\n") if isdbg('command'); - $dirfn .= "$l/"; - $curdir .= "/$l"; - last; - } - } else { # we are dealing with commands - @lparts = split /\./, $l; - next if $lparts[$#lparts] ne $suffix; # only look for .$suffix files - if ($p eq substr($l, 0, length $p)) { - pop @lparts; # remove the suffix - $l = join '.', @lparts; - # chop $dirfn; # remove trailing / - $dirfn = "" unless $dirfn; - $cmd_cache{$short_cmd} = join(',', ($path, "$dirfn$l")); # cache it - dbg("got path: $path cmd: $dirfn$l\n") if isdbg('command'); - return ($path, "$dirfn$l"); - } - } - } - } + while (my $p = shift @parts) { + opendir(D, $curdir) or confess "can't open $curdir $!"; + my @ls = readdir D; + closedir D; + + # if this isn't the last part + if (@parts) { + my $found; + foreach my $l (sort @ls) { + next if $l =~ /^\./; + if ((-d "$curdir/$l") && $p eq substr($l, 0, length $p)) { + dbg("got dir: $curdir/$l\n") if isdbg('command'); + $dirfn .= "$l/"; + $curdir .= "/$l"; + $found++; + last; + } + } + # only proceed if we find the directory asked for + return () unless $found; + } else { + foreach my $l (sort @ls) { + next if $l =~ /^\./; + next unless $l =~ /\.$suffix$/; + if ($p eq substr($l, 0, length $p)) { + $l =~ s/\.$suffix$//; + $dirfn = "" unless $dirfn; + $cmd_cache{$short_cmd} = join(',', ($path, "$dirfn$l")); # cache it + dbg("got path: $path cmd: $dirfn$l\n") if isdbg('command'); + return ($path, "$dirfn$l"); + } + } + } + } + return (); } @@ -909,7 +920,7 @@ sub wwv return unless $self->{wwv}; if ($self->{wwvfilter}) { - ($filter, $hops) = $self->{wwvfilter}->it(@_ ); + ($filter, $hops) = $self->{wwvfilter}->it(@_[7..$#_] ); return unless $filter; } @@ -942,7 +953,7 @@ sub broadcast_debug { my $s = shift; # the line to be rebroadcast - foreach my $dxchan (DXChannel->get_all) { + foreach my $dxchan (DXChannel::get_all) { next unless $dxchan->{enhanced} && $dxchan->{senddbg}; $dxchan->send_later('L', $s); }