- $web_socket->blocking(0);
- $select->add($web_socket);
-
- while(my @ready = $select->can_read) {
- foreach my $fh (@ready) {
- if ($fh == $web_socket) {
- my $nr = $wb_socket_read_available_bytes->();
- my ($payload, $req_close) = $parse_web_socket_frame->(\$wsbuf);
- print "GOT: $payload\n" if defined($payload);
- last if $req_close;
- last if !$nr; # eos
- } else {
- die "internal error - unknown handle";
+ eval {
+ $SIG{TERM} = $SIG{INT} = $SIG{KILL} = sub { die "received interrupt\n"; };
+
+ PVE::PTY::cfmakeraw($raw_termios);
+ PVE::PTY::tcsetattr(*STDIN, $raw_termios);
+
+ # And set it to non-blocking so we can every char with IO::Select.
+ STDIN->blocking(0);
+
+ $web_socket->blocking(1);
+ $select->add($web_socket);
+ my $input_fh = fileno(STDIN);
+ $select->add($input_fh);
+
+ my $ctrl_a_pressed_before = 0;
+
+ while (1) {
+ while(my @ready = $select->can_read(3)) {
+ foreach my $fh (@ready) {
+
+ if ($fh == $web_socket) {
+ # Read from WebSocket
+
+ my $nr = $wb_socket_read_available_bytes->();
+ if (!defined($nr)) {
+ die "web socket read error $!\n";
+ } elsif ($nr == 0) {
+ return; # EOF
+ } else {
+ my ($payload, $req_close) = $parse_web_socket_frame->(\$wsbuf);
+ if ($payload) {
+ syswrite(\*STDOUT, $payload);
+ }
+ return if $req_close;
+ }
+
+ } elsif ($fh == $input_fh) {
+ # Read from STDIN
+
+ my $nr = read(\*STDIN, my $buff, 4096);
+ return if !$nr; # EOF or error
+
+ my $char = ord($buff);
+
+ # check for CTRL-a-q
+ return if $ctrl_a_pressed_before == 1 && $char == hex("0x71");
+
+ $ctrl_a_pressed_before = ($char == hex("0x01") && $ctrl_a_pressed_before == 0) ? 1 : 0;
+
+ my $frame = $create_websockt_frame->("0:" . $nr . ":" . $buff);
+ syswrite($web_socket, $frame);
+ }
+ }