X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fconsole.pl;h=50196907829e16608af9cfc0a4f95f0132efdbcb;hb=918827ec5a9023edeb2ce0140692566591af0af8;hp=12192152e827b6a0c663d684a577313555aeb90a;hpb=84e68f5fca6f33df5e2c7c801038043d339aaac2;p=spider.git diff --git a/perl/console.pl b/perl/console.pl index 12192152..50196907 100755 --- a/perl/console.pl +++ b/perl/console.pl @@ -33,6 +33,23 @@ use Curses; use Carp qw{cluck}; +use Console; + +# +# initialisation +# + +$call = ""; # the callsign being used +$conn = 0; # the connection object for the cluster +$lasttime = time; # lasttime something happened on the interface + +$connsort = "local"; +@khistory = (); +@shistory = (); +$khistpos = 0; +$spos = $pos = $lth = 0; +$inbuf = ""; + # cease communications sub cease { @@ -42,15 +59,72 @@ sub cease } endwin(); dbgclose(); -# $SIG{__WARN__} = sub {my $a = shift; cluck($a); }; - sleep(1); + print @_ if @_; exit(0); } # terminate program from signal sub sig_term { - cease(1); + cease(1, @_); +} + +# determine the colour of the line +sub setattr +{ + if ($has_colors) { + foreach my $ref (@colors) { + if ($_[0] =~ m{$$ref[0]}) { + $top->attrset($$ref[1]); + last; + } + } + } +} + +# display the top screen +sub show_screen +{ + if ($spos == @shistory - 1) { + + # if we really are scrolling thru at the end of the history + my $line = $shistory[-1]; + $top->addstr("\n") if $spos > 0; + setattr($line); + $top->addstr($line); + $top->attrset(COLOR_PAIR(0)) if $has_colors; + $spos = @shistory; + + } else { + + # anywhere else + my $p = $spos - $pages; + my $i; + $p = 0 if $p < 0; + + $top->move(0, 0); + $top->attrset(COLOR_PAIR(0)) if $has_colors; + $top->clrtobot(); + for ($i = 0; $i < $pages && $p < @shistory; $i++, $p++) { + my $line = $shistory[$p]; + $line = substr($line, 0, COLS()) if length $line > COLS(); + $top->move($i, 0); + setattr($line); + $top->addstr($line); + $top->attrset(COLOR_PAIR(0)) if $has_colors; + } + $spos = $p; + } + $top->refresh(); +} + +# add a line to the end of the top screen +sub addtotop +{ + my $inbuf = shift; + push @shistory, $inbuf; + shift @shistory if @shistory > $maxshist; + show_screen(); } # handle incoming messages @@ -64,11 +138,12 @@ sub rec_socket my ($sort, $call, $line) = $msg =~ /^(\w)(\S+)\|(.*)$/; if ($sort eq 'D') { - $top->addstr("$line\n"); + addtotop($line); } elsif ($sort eq 'Z') { # end, disconnect, go, away ..... cease(0); } } + $top->refresh(); $lasttime = time; } @@ -84,28 +159,148 @@ sub rec_stdin # $prbuf =~ s/\n/\\n/; # print "sys: $r ($prbuf)\n"; if (defined $r) { - if ($r eq "\n" || $r eq "\r") { + + if ($r eq KEY_ENTER || $r eq "\n" || $r eq "\r") { + + # save the lines + if ($inbuf) { + # check for a pling and do a search back for a command + if ($inbuf =~ /^!/o) { + my $i; + $inbuf =~ s/^!//o; + for ($i = $#khistory; $i >= 0; $i--) { + if ($khistory[$i] =~ /^$inbuf/) { + $inbuf = $khistory[$i]; + last; + } + } + if ($i < 0) { + beep(); + return; + } + } + push @khistory, $inbuf if $inbuf; + shift @khistory if @khistory > $maxkhist; + $khistpos = @khistory; + $bot->move(0,0); + $bot->clrtoeol(); + $bot->addstr(substr($inbuf, 0, COLS)); + } + + # add it to the monitor window + addtotop($inbuf) if $inbuf; + + # send it to the cluster $inbuf = " " unless $inbuf; - $conn->send_later("I|$call|$inbuf"); + $conn->send_later("I$call|$inbuf"); $inbuf = ""; + $pos = $lth = 0; + } elsif ($r eq KEY_UP || $r eq "\020") { + if ($khistpos > 0) { + --$khistpos; + $inbuf = $khistory[$khistpos]; + $pos = $lth = length $inbuf; + } else { + beep(); + } + } elsif ($r eq KEY_DOWN || $r eq "\016") { + if ($khistpos < @khistory - 1) { + ++$khistpos; + $inbuf = $khistory[$khistpos]; + $pos = $lth = length $inbuf; + } else { + beep(); + } + } elsif ($r eq KEY_PPAGE || $r eq "\032") { + if ($spos > 0) { + $spos -= $pages; + $spos = 0 if $spos < 0; + show_screen(); + } else { + beep(); + } + } elsif ($r eq KEY_NPAGE || $r eq "\026") { + if ($spos < @shistory - 1) { + $spos += $pages; + $spos = @shistory if $spos > @shistory; + show_screen(); + } else { + beep(); + } + } elsif ($r eq KEY_LEFT || $r eq "\002") { + if ($pos > 0) { + --$pos; + } else { + beep(); + } + } elsif ($r eq KEY_RIGHT || $r eq "\006") { + if ($pos < $lth) { + ++$pos; + } else { + beep(); + } + } elsif ($r eq KEY_HOME || $r eq "\001") { + $pos = 0; + } elsif ($r eq KEY_END || $r eq "\005") { + $pos = $lth; + } elsif ($r eq KEY_BACKSPACE || $r eq "\010") { + if ($pos > 0) { + my $a = substr($inbuf, 0, $pos-1); + my $b = substr($inbuf, $pos) if $pos < $lth; + $b = "" unless $b; + + $inbuf = $a . $b; + --$lth; + --$pos; + } else { + beep(); + } + } elsif ($r eq KEY_DC || $r eq "\004") { + if ($pos < $lth) { + my $a = substr($inbuf, 0, $pos); + my $b = substr($inbuf, $pos+1) if $pos < $lth; + $b = "" unless $b; + + $inbuf = $a . $b; + --$lth; + } else { + beep(); + } + } elsif ($r ge ' ' && $r le '~') { + # move the top screen back to the bottom if you type something + if ($spos < @shistory - 1) { + $spos = @shistory; + show_screen(); + } + + # insert the character into the keyboard buffer + if ($pos < $lth) { + my $a = substr($inbuf, 0, $pos); + my $b = substr($inbuf, $pos); + $inbuf = $a . $r . $b; + } else { + $inbuf .= $r; + } + $pos++; + $lth++; + } elsif ($r eq "\014" || $r eq "\022") { +# curscr()->refresh(); + return; + } elsif ($r eq "\013") { + $inbuf = substr($inbuf, 0, $pos); + $lth = length $inbuf; } else { - $inbuf .= $r; + beep(); } + $bot->move(1, 0); + $bot->clrtobot(); + $bot->addstr($inbuf); } + $bot->move(1, $pos); $bot->refresh(); } -# -# initialisation -# - -$call = ""; # the callsign being used -$conn = 0; # the connection object for the cluster -$lasttime = time; # lasttime something happened on the interface - -$connsort = "local"; - # # deal with args # @@ -138,7 +333,21 @@ $SIG{'TERM'} = \&sig_term; $SIG{'HUP'} = 'IGNORE'; $scr = new Curses; -cbreak(); +raw(); +noecho(); +$has_colors = has_colors(); + +if ($has_colors) { + start_color(); + init_pair(0, $foreground, $background); + init_pair(1, COLOR_RED, $background); + init_pair(2, COLOR_YELLOW, $background); + init_pair(3, COLOR_GREEN, $background); + init_pair(4, COLOR_CYAN, $background); + init_pair(5, COLOR_BLUE, $background); + init_pair(6, COLOR_MAGENTA, $background); +} + $top = $scr->subwin(LINES()-4, COLS, 0, 0); $top->intrflush(0); $top->scrollok(1); @@ -147,13 +356,16 @@ $bot = $scr->subwin(3, COLS, LINES()-3, 0); $bot->intrflush(0); $bot->scrollok(1); $bot->keypad(1); +$bot->move(1,0); $scr->refresh(); -$pages = LINES()-6; +$SIG{__DIE__} = \&sig_term; + +$pages = LINES()-4; $conn->send_now("A$call|$connsort"); -$conn->send_now("I|$call|set/page $pages"); -$conn->send_now("I|$call|set/nobeep"); +$conn->send_now("I$call|set/page $maxshist"); +$conn->send_now("I$call|set/nobeep"); Msg->set_event_handler(\*STDIN, "read" => \&rec_stdin);