/* * Copyright (C) 2013 Glyptodon LLC * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. */ #include "config.h" #include "buffer.h" #include "common.h" #include "display.h" #include "guac_clipboard.h" #include "guac_cursor.h" #include "guac_display.h" #include "packet.h" #include "scrollbar.h" #include "terminal.h" #include "terminal_handlers.h" #include "types.h" #include "typescript.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include /** * Sets the given range of columns to the given character. */ static void __guac_terminal_set_columns(guac_terminal* terminal, int row, int start_column, int end_column, guac_terminal_char* character) { guac_terminal_display_set_columns(terminal->term_display, row + terminal->scroll_offset, start_column, end_column, character); guac_terminal_buffer_set_columns(terminal->buffer, row, start_column, end_column, character); } /** * Enforces a character break at the given edge, ensuring that the left side * of the edge is the final column of a character, and the right side of the * edge is the initial column of a DIFFERENT character. * * For a character in a column N, the left edge number is N, and the right * edge is N+1. */ static void __guac_terminal_force_break(guac_terminal* terminal, int row, int edge) { guac_terminal_buffer_row* buffer_row = guac_terminal_buffer_get_row(terminal->buffer, row, 0); /* Ensure character to left of edge is unbroken */ if (edge > 0) { int end_column = edge - 1; int start_column = end_column; guac_terminal_char* start_char = &(buffer_row->characters[start_column]); /* Determine start column */ while (start_column > 0 && start_char->value == GUAC_CHAR_CONTINUATION) { start_char--; start_column--; } /* Advance to start of broken character if necessary */ if (start_char->value != GUAC_CHAR_CONTINUATION && start_char->width < end_column - start_column + 1) { start_column += start_char->width; start_char += start_char->width; } /* Clear character if broken */ if (start_char->value == GUAC_CHAR_CONTINUATION || start_char->width != end_column - start_column + 1) { guac_terminal_char cleared_char; cleared_char.value = ' '; cleared_char.attributes = start_char->attributes; cleared_char.width = 1; __guac_terminal_set_columns(terminal, row, start_column, end_column, &cleared_char); } } /* Ensure character to right of edge is unbroken */ if (edge >= 0 && edge < buffer_row->length) { int start_column = edge; int end_column = start_column; guac_terminal_char* start_char = &(buffer_row->characters[start_column]); guac_terminal_char* end_char = &(buffer_row->characters[end_column]); /* Determine end column */ while (end_column+1 < buffer_row->length && (end_char+1)->value == GUAC_CHAR_CONTINUATION) { end_char++; end_column++; } /* Advance to start of broken character if necessary */ if (start_char->value != GUAC_CHAR_CONTINUATION && start_char->width < end_column - start_column + 1) { start_column += start_char->width; start_char += start_char->width; } /* Clear character if broken */ if (start_char->value == GUAC_CHAR_CONTINUATION || start_char->width != end_column - start_column + 1) { guac_terminal_char cleared_char; cleared_char.value = ' '; cleared_char.attributes = start_char->attributes; cleared_char.width = 1; __guac_terminal_set_columns(terminal, row, start_column, end_column, &cleared_char); } } } void guac_terminal_reset(guac_terminal* term) { int row; /* Set current state */ term->char_handler = guac_terminal_echo; term->active_char_set = 0; term->char_mapping[0] = term->char_mapping[1] = NULL; /* Reset cursor location */ term->cursor_row = term->visible_cursor_row = term->saved_cursor_row = 0; term->cursor_col = term->visible_cursor_col = term->saved_cursor_col = 0; /* Clear scrollback, buffer, and scroll region */ term->buffer->top = 0; term->buffer->length = 0; term->scroll_start = 0; term->scroll_end = term->term_height - 1; term->scroll_offset = 0; /* Reset scrollbar bounds */ guac_terminal_scrollbar_set_bounds(term->scrollbar, term->term_height - term->buffer->length, 0); guac_terminal_scrollbar_set_value(term->scrollbar, -term->scroll_offset); /* Reset flags */ term->text_selected = false; term->application_cursor_keys = false; term->automatic_carriage_return = false; term->insert_mode = false; /* Reset tabs */ term->tab_interval = 8; memset(term->custom_tabs, 0, sizeof(term->custom_tabs)); /* Clear terminal */ for (row=0; rowterm_height; row++) guac_terminal_set_columns(term, row, 0, term->term_width, &(term->default_char)); } /** * Paints or repaints the background of the terminal display. This painting * occurs beneath the actual terminal and scrollbar layers, and thus will not * overwrite any text or other content currently on the screen. This is only * necessary to paint over parts of the terminal background which may otherwise * be transparent (the default layer background). * * @param terminal * The terminal whose background should be painted or repainted. * * @param width * The width of the background to draw, in pixels. * * @param height * The height of the background to draw, in pixels. */ static void guac_terminal_paint_background(guac_terminal* terminal, int width, int height) { guac_terminal_display* display = terminal->term_display; guac_client* client = display->client; guac_socket* socket = client->socket; /* Get background color */ const guac_terminal_color* color = &guac_terminal_palette[display->default_background]; /* Paint background color */ guac_protocol_send_rect(socket, GUAC_DEFAULT_LAYER, 0, 0, width, height); guac_protocol_send_cfill(socket, GUAC_COMP_OVER, GUAC_DEFAULT_LAYER, color->red, color->green, color->blue, 0xFF); } /** * Automatically and continuously renders frames of terminal data while the * associated guac_client is running. * * @param data * A pointer to the guac_terminal that should be continuously rendered * while its associated guac_client is running. * * @return * Always NULL. */ void* guac_terminal_thread(void* data) { guac_terminal* terminal = (guac_terminal*) data; guac_client* client = terminal->client; /* Render frames only while client is running */ while (client->state == GUAC_CLIENT_RUNNING) { /* Stop rendering if an error occurs */ if (guac_terminal_render_frame(terminal)) break; /* Signal end of frame */ guac_client_end_frame(client); guac_socket_flush(client->socket); } /* The client has stopped or an error has occurred */ return NULL; } guac_terminal* guac_terminal_create(guac_client* client, const char* font_name, int font_size, int dpi, int width, int height, const char* color_scheme) { int default_foreground; int default_background; /* Default to "gray-black" color scheme if no scheme provided */ if (color_scheme == NULL || color_scheme[0] == '\0') { default_foreground = GUAC_TERMINAL_COLOR_GRAY; default_background = GUAC_TERMINAL_COLOR_BLACK; } /* Otherwise, parse color scheme */ else if (strcmp(color_scheme, GUAC_TERMINAL_SCHEME_GRAY_BLACK) == 0) { default_foreground = GUAC_TERMINAL_COLOR_GRAY; default_background = GUAC_TERMINAL_COLOR_BLACK; } else if (strcmp(color_scheme, GUAC_TERMINAL_SCHEME_BLACK_WHITE) == 0) { default_foreground = GUAC_TERMINAL_COLOR_BLACK; default_background = GUAC_TERMINAL_COLOR_WHITE; } else if (strcmp(color_scheme, GUAC_TERMINAL_SCHEME_GREEN_BLACK) == 0) { default_foreground = GUAC_TERMINAL_COLOR_DARK_GREEN; default_background = GUAC_TERMINAL_COLOR_BLACK; } else if (strcmp(color_scheme, GUAC_TERMINAL_SCHEME_WHITE_BLACK) == 0) { default_foreground = GUAC_TERMINAL_COLOR_WHITE; default_background = GUAC_TERMINAL_COLOR_BLACK; } /* If invalid, default to "gray-black" */ else { guac_client_log(client, GUAC_LOG_WARNING, "Invalid color scheme: \"%s\". Defaulting to \"gray-black\".", color_scheme); default_foreground = GUAC_TERMINAL_COLOR_GRAY; default_background = GUAC_TERMINAL_COLOR_BLACK; } /* Build default character using default colors */ guac_terminal_char default_char = { .value = 0, .attributes = { .foreground = default_foreground, .background = default_background, .bold = false, .reverse = false, .underscore = false }, .width = 1 }; /* Calculate available display area */ int available_width = width - GUAC_TERMINAL_SCROLLBAR_WIDTH; if (available_width < 0) available_width = 0; guac_terminal* term = malloc(sizeof(guac_terminal)); term->client = client; term->display = guac_common_display_alloc(client, width, height); term->upload_path_handler = NULL; term->file_download_handler = NULL; /* Init buffer */ term->buffer = guac_terminal_buffer_alloc(1000, &default_char); /* Init display */ term->term_display = guac_terminal_display_alloc(client, font_name, font_size, dpi, default_char.attributes.foreground, default_char.attributes.background); /* Fail if display init failed */ if (term->term_display == NULL) { guac_client_log(client, GUAC_LOG_DEBUG, "Display initialization failed"); free(term); return NULL; } /* Init terminal state */ term->current_attributes = default_char.attributes; term->default_char = default_char; term->term_width = available_width / term->term_display->char_width; term->term_height = height / term->term_display->char_height; /* Open STDOUT pipe */ if (pipe(term->stdout_pipe_fd)) { guac_error = GUAC_STATUS_SEE_ERRNO; guac_error_message = "Unable to open pipe for STDOUT"; free(term); return NULL; } /* Open STDIN pipe */ if (pipe(term->stdin_pipe_fd)) { guac_error = GUAC_STATUS_SEE_ERRNO; guac_error_message = "Unable to open pipe for STDIN"; free(term); return NULL; } /* Init pipe stream (output to display by default) */ term->pipe_stream = NULL; /* No typescript by default */ term->typescript = NULL; /* Init terminal lock */ pthread_mutex_init(&(term->lock), NULL); /* Size display */ guac_terminal_paint_background(term, width, height); guac_terminal_display_resize(term->term_display, term->term_width, term->term_height); /* Allocate scrollbar */ term->scrollbar = guac_terminal_scrollbar_alloc(client, GUAC_DEFAULT_LAYER, width, height, term->term_height); /* Associate scrollbar with this terminal */ term->scrollbar->data = term; term->scrollbar->scroll_handler = guac_terminal_scroll_handler; /* Init terminal */ guac_terminal_reset(term); term->mod_alt = term->mod_ctrl = term->mod_shift = 0; /* Initialize mouse cursor */ term->current_cursor = GUAC_TERMINAL_CURSOR_BLANK; guac_common_cursor_set_blank(term->display->cursor); /* Allocate clipboard */ term->clipboard = guac_common_clipboard_alloc(GUAC_TERMINAL_CLIPBOARD_MAX_LENGTH); /* Start terminal thread */ if (pthread_create(&(term->thread), NULL, guac_terminal_thread, (void*) term)) { guac_terminal_free(term); return NULL; } return term; } void guac_terminal_free(guac_terminal* term) { /* Close terminal output pipe */ close(term->stdout_pipe_fd[1]); close(term->stdout_pipe_fd[0]); /* Close user input pipe */ close(term->stdin_pipe_fd[1]); close(term->stdin_pipe_fd[0]); /* Wait for render thread to finish */ pthread_join(term->thread, NULL); /* Close and flush any open pipe stream */ guac_terminal_pipe_stream_close(term); /* Close and flush any active typescript */ guac_terminal_typescript_free(term->typescript); /* Free display */ guac_terminal_display_free(term->term_display); /* Free buffer */ guac_terminal_buffer_free(term->buffer); /* Free clipboard */ guac_common_clipboard_free(term->clipboard); /* Free scrollbar */ guac_terminal_scrollbar_free(term->scrollbar); /* Free the terminal itself */ free(term); } /** * Waits for data to become available on the given file descriptor. * * @param fd * The file descriptor to wait on. * * @param msec_timeout * The maximum amount of time to wait, in milliseconds. * * @return * A positive if data is available, zero if the timeout has elapsed without * data becoming available, or negative if an error occurred. */ static int guac_terminal_wait_for_data(int fd, int msec_timeout) { /* Build fd_set */ fd_set fds; FD_ZERO(&fds); FD_SET(fd, &fds); /* Split millisecond timeout into seconds and microseconds */ struct timeval timeout = { .tv_sec = msec_timeout / 1000, .tv_usec = (msec_timeout % 1000) * 1000 }; /* Wait for data */ return select(fd+1, &fds, NULL, NULL, &timeout); } int guac_terminal_render_frame(guac_terminal* terminal) { guac_client* client = terminal->client; char buffer[GUAC_TERMINAL_PACKET_SIZE]; int wait_result; int fd = terminal->stdout_pipe_fd[0]; /* Wait for data to be available */ wait_result = guac_terminal_wait_for_data(fd, 1000); if (wait_result > 0) { guac_terminal_lock(terminal); guac_timestamp frame_start = guac_timestamp_current(); do { guac_timestamp frame_end; int frame_remaining; int bytes_read; /* Read data, write to terminal */ if ((bytes_read = guac_terminal_packet_read(fd, buffer, sizeof(buffer))) > 0) { if (guac_terminal_write(terminal, buffer, bytes_read)) { guac_client_abort(client, GUAC_PROTOCOL_STATUS_SERVER_ERROR, "Error writing data"); guac_terminal_unlock(terminal); return 1; } } /* Notify on error */ if (bytes_read < 0) { guac_client_abort(client, GUAC_PROTOCOL_STATUS_SERVER_ERROR, "Error reading data"); guac_terminal_unlock(terminal); return 1; } /* Calculate time remaining in frame */ frame_end = guac_timestamp_current(); frame_remaining = frame_start + GUAC_TERMINAL_FRAME_DURATION - frame_end; /* Wait again if frame remaining */ if (frame_remaining > 0) wait_result = guac_terminal_wait_for_data(fd, GUAC_TERMINAL_FRAME_TIMEOUT); else break; } while (wait_result > 0); /* Flush terminal */ guac_terminal_flush(terminal); guac_terminal_unlock(terminal); } /* Notify of any errors */ if (wait_result < 0) { guac_client_abort(client, GUAC_PROTOCOL_STATUS_SERVER_ERROR, "Error waiting for data"); return 1; } return 0; } int guac_terminal_read_stdin(guac_terminal* terminal, char* c, int size) { int stdin_fd = terminal->stdin_pipe_fd[0]; return read(stdin_fd, c, size); } int guac_terminal_write_stdout(guac_terminal* terminal, const char* c, int size) { /* Write maximally-sized packets until only one packet remains */ while (size > GUAC_TERMINAL_PACKET_SIZE) { /* Write maximally-sized packet */ if (guac_terminal_packet_write(terminal->stdout_pipe_fd[1], c, GUAC_TERMINAL_PACKET_SIZE) < 0) return -1; /* Advance to next packet */ c += GUAC_TERMINAL_PACKET_SIZE; size -= GUAC_TERMINAL_PACKET_SIZE; } return guac_terminal_packet_write(terminal->stdout_pipe_fd[1], c, size); } int guac_terminal_notify(guac_terminal* terminal) { return guac_terminal_packet_write(terminal->stdout_pipe_fd[1], NULL, 0); } int guac_terminal_printf(guac_terminal* terminal, const char* format, ...) { int written; va_list ap; char buffer[1024]; /* Print to buffer */ va_start(ap, format); written = vsnprintf(buffer, sizeof(buffer)-1, format, ap); va_end(ap); if (written < 0) return written; /* Write to STDOUT */ return guac_terminal_write_stdout(terminal, buffer, written); } char* guac_terminal_prompt(guac_terminal* terminal, const char* title, bool echo) { char buffer[1024]; int pos; char in_byte; /* Print title */ guac_terminal_printf(terminal, "%s", title); /* Read bytes until newline */ pos = 0; while (guac_terminal_read_stdin(terminal, &in_byte, 1) == 1) { /* Backspace */ if (in_byte == 0x7F) { if (pos > 0) { guac_terminal_printf(terminal, "\b \b"); pos--; } } /* CR (end of input */ else if (in_byte == 0x0D) { guac_terminal_printf(terminal, "\r\n"); break; } /* Otherwise, store byte if there is room */ else if (pos < sizeof(buffer) - 1) { /* Store character, update buffers */ buffer[pos++] = in_byte; /* Print character if echoing */ if (echo) guac_terminal_printf(terminal, "%c", in_byte); else guac_terminal_printf(terminal, "*"); } /* Ignore all other input */ } /* Terminate string */ buffer[pos] = 0; /* Return newly-allocated string containing result */ return strdup(buffer); } int guac_terminal_set(guac_terminal* term, int row, int col, int codepoint) { int width; /* Build character with current attributes */ guac_terminal_char guac_char; guac_char.value = codepoint; guac_char.attributes = term->current_attributes; width = wcwidth(codepoint); if (width < 0) width = 1; guac_char.width = width; guac_terminal_set_columns(term, row, col, col + width - 1, &guac_char); return 0; } void guac_terminal_commit_cursor(guac_terminal* term) { guac_terminal_char* guac_char; guac_terminal_buffer_row* old_row; guac_terminal_buffer_row* new_row; /* If no change, done */ if (term->visible_cursor_row == term->cursor_row && term->visible_cursor_col == term->cursor_col) return; /* Get old and new rows with cursor */ new_row = guac_terminal_buffer_get_row(term->buffer, term->cursor_row, term->cursor_col+1); old_row = guac_terminal_buffer_get_row(term->buffer, term->visible_cursor_row, term->visible_cursor_col+1); /* Clear cursor */ guac_char = &(old_row->characters[term->visible_cursor_col]); guac_char->attributes.cursor = false; guac_terminal_display_set_columns(term->term_display, term->visible_cursor_row + term->scroll_offset, term->visible_cursor_col, term->visible_cursor_col, guac_char); /* Set cursor */ guac_char = &(new_row->characters[term->cursor_col]); guac_char->attributes.cursor = true; guac_terminal_display_set_columns(term->term_display, term->cursor_row + term->scroll_offset, term->cursor_col, term->cursor_col, guac_char); term->visible_cursor_row = term->cursor_row; term->visible_cursor_col = term->cursor_col; return; } int guac_terminal_write(guac_terminal* term, const char* c, int size) { while (size > 0) { /* Read and advance to next character */ char current = *(c++); size--; /* Write character to typescript, if any */ if (term->typescript != NULL) guac_terminal_typescript_write(term->typescript, current); /* Handle character and its meaning */ term->char_handler(term, current); } return 0; } int guac_terminal_scroll_up(guac_terminal* term, int start_row, int end_row, int amount) { /* If scrolling entire display, update scroll offset */ if (start_row == 0 && end_row == term->term_height - 1) { /* Scroll up visibly */ guac_terminal_display_copy_rows(term->term_display, start_row + amount, end_row, -amount); /* Advance by scroll amount */ term->buffer->top += amount; if (term->buffer->top >= term->buffer->available) term->buffer->top -= term->buffer->available; term->buffer->length += amount; if (term->buffer->length > term->buffer->available) term->buffer->length = term->buffer->available; /* Reset scrollbar bounds */ guac_terminal_scrollbar_set_bounds(term->scrollbar, term->term_height - term->buffer->length, 0); /* Update cursor location if within region */ if (term->visible_cursor_row >= start_row && term->visible_cursor_row <= end_row) term->visible_cursor_row -= amount; } /* Otherwise, just copy row data upwards */ else guac_terminal_copy_rows(term, start_row + amount, end_row, -amount); /* Clear new area */ guac_terminal_clear_range(term, end_row - amount + 1, 0, end_row, term->term_width - 1); return 0; } int guac_terminal_scroll_down(guac_terminal* term, int start_row, int end_row, int amount) { guac_terminal_copy_rows(term, start_row, end_row - amount, amount); /* Clear new area */ guac_terminal_clear_range(term, start_row, 0, start_row + amount - 1, term->term_width - 1); return 0; } int guac_terminal_clear_columns(guac_terminal* term, int row, int start_col, int end_col) { /* Build space */ guac_terminal_char blank; blank.value = 0; blank.attributes = term->current_attributes; blank.width = 1; /* Clear */ guac_terminal_set_columns(term, row, start_col, end_col, &blank); return 0; } int guac_terminal_clear_range(guac_terminal* term, int start_row, int start_col, int end_row, int end_col) { /* If not at far left, must clear sub-region to far right */ if (start_col > 0) { /* Clear from start_col to far right */ guac_terminal_clear_columns(term, start_row, start_col, term->term_width - 1); /* One less row to clear */ start_row++; } /* If not at far right, must clear sub-region to far left */ if (end_col < term->term_width - 1) { /* Clear from far left to end_col */ guac_terminal_clear_columns(term, end_row, 0, end_col); /* One less row to clear */ end_row--; } /* Remaining region now guaranteed rectangular. Clear, if possible */ if (start_row <= end_row) { int row; for (row=start_row; row<=end_row; row++) { /* Clear entire row */ guac_terminal_clear_columns(term, row, 0, term->term_width - 1); } } return 0; } void guac_terminal_scroll_display_down(guac_terminal* terminal, int scroll_amount) { int start_row, end_row; int dest_row; int row, column; /* Limit scroll amount by size of scrollback buffer */ if (scroll_amount > terminal->scroll_offset) scroll_amount = terminal->scroll_offset; /* If not scrolling at all, don't bother trying */ if (scroll_amount <= 0) return; /* Shift screen up */ if (terminal->term_height > scroll_amount) guac_terminal_display_copy_rows(terminal->term_display, scroll_amount, terminal->term_height - 1, -scroll_amount); /* Advance by scroll amount */ terminal->scroll_offset -= scroll_amount; guac_terminal_scrollbar_set_value(terminal->scrollbar, -terminal->scroll_offset); /* Get row range */ end_row = terminal->term_height - terminal->scroll_offset - 1; start_row = end_row - scroll_amount + 1; dest_row = terminal->term_height - scroll_amount; /* Draw new rows from scrollback */ for (row=start_row; row<=end_row; row++) { /* Get row from scrollback */ guac_terminal_buffer_row* buffer_row = guac_terminal_buffer_get_row(terminal->buffer, row, 0); /* Clear row */ guac_terminal_display_set_columns(terminal->term_display, dest_row, 0, terminal->term_display->width, &(terminal->default_char)); /* Draw row */ guac_terminal_char* current = buffer_row->characters; for (column=0; columnlength; column++) { /* Only draw if not blank */ if (guac_terminal_has_glyph(current->value)) guac_terminal_display_set_columns(terminal->term_display, dest_row, column, column, current); current++; } /* Next row */ dest_row++; } guac_terminal_notify(terminal); } void guac_terminal_scroll_display_up(guac_terminal* terminal, int scroll_amount) { int start_row, end_row; int dest_row; int row, column; /* Limit scroll amount by size of scrollback buffer */ if (terminal->scroll_offset + scroll_amount > terminal->buffer->length - terminal->term_height) scroll_amount = terminal->buffer->length - terminal->scroll_offset - terminal->term_height; /* If not scrolling at all, don't bother trying */ if (scroll_amount <= 0) return; /* Shift screen down */ if (terminal->term_height > scroll_amount) guac_terminal_display_copy_rows(terminal->term_display, 0, terminal->term_height - scroll_amount - 1, scroll_amount); /* Advance by scroll amount */ terminal->scroll_offset += scroll_amount; guac_terminal_scrollbar_set_value(terminal->scrollbar, -terminal->scroll_offset); /* Get row range */ start_row = -terminal->scroll_offset; end_row = start_row + scroll_amount - 1; dest_row = 0; /* Draw new rows from scrollback */ for (row=start_row; row<=end_row; row++) { /* Get row from scrollback */ guac_terminal_buffer_row* buffer_row = guac_terminal_buffer_get_row(terminal->buffer, row, 0); /* Clear row */ guac_terminal_display_set_columns(terminal->term_display, dest_row, 0, terminal->term_display->width, &(terminal->default_char)); /* Draw row */ guac_terminal_char* current = buffer_row->characters; for (column=0; columnlength; column++) { /* Only draw if not blank */ if (guac_terminal_has_glyph(current->value)) guac_terminal_display_set_columns(terminal->term_display, dest_row, column, column, current); current++; } /* Next row */ dest_row++; } guac_terminal_notify(terminal); } void guac_terminal_select_redraw(guac_terminal* terminal) { int start_row = terminal->selection_start_row + terminal->scroll_offset; int start_column = terminal->selection_start_column; int end_row = terminal->selection_end_row + terminal->scroll_offset; int end_column = terminal->selection_end_column; /* Update start/end columns to include character width */ if (start_row > end_row || (start_row == end_row && start_column > end_column)) start_column += terminal->selection_start_width - 1; else end_column += terminal->selection_end_width - 1; guac_terminal_display_select(terminal->term_display, start_row, start_column, end_row, end_column); } /** * Locates the beginning of the character at the given row and column, updating * the column to the starting column of that character. The width, if available, * is returned. If the character has no defined width, 1 is returned. */ static int __guac_terminal_find_char(guac_terminal* terminal, int row, int* column) { int start_column = *column; guac_terminal_buffer_row* buffer_row = guac_terminal_buffer_get_row(terminal->buffer, row, 0); if (start_column < buffer_row->length) { /* Find beginning of character */ guac_terminal_char* start_char = &(buffer_row->characters[start_column]); while (start_column > 0 && start_char->value == GUAC_CHAR_CONTINUATION) { start_char--; start_column--; } /* Use width, if available */ if (start_char->value != GUAC_CHAR_CONTINUATION) { *column = start_column; return start_char->width; } } /* Default to one column wide */ return 1; } void guac_terminal_select_start(guac_terminal* terminal, int row, int column) { int width = __guac_terminal_find_char(terminal, row, &column); terminal->selection_start_row = terminal->selection_end_row = row; terminal->selection_start_column = terminal->selection_end_column = column; terminal->selection_start_width = terminal->selection_end_width = width; terminal->text_selected = true; guac_terminal_select_redraw(terminal); } void guac_terminal_select_update(guac_terminal* terminal, int row, int column) { /* Only update if selection has changed */ if (row != terminal->selection_end_row || column < terminal->selection_end_column || column >= terminal->selection_end_column + terminal->selection_end_width) { int width = __guac_terminal_find_char(terminal, row, &column); terminal->selection_end_row = row; terminal->selection_end_column = column; terminal->selection_end_width = width; guac_terminal_select_redraw(terminal); } } int __guac_terminal_buffer_string(guac_terminal_buffer_row* row, int start, int end, char* string) { int length = 0; int i; for (i=start; i<=end; i++) { int codepoint = row->characters[i].value; /* If not null (blank), add to string */ if (codepoint != 0 && codepoint != GUAC_CHAR_CONTINUATION) { int bytes = guac_terminal_encode_utf8(codepoint, string); string += bytes; length += bytes; } } return length; } void guac_terminal_select_end(guac_terminal* terminal, char* string) { /* Deselect */ terminal->text_selected = false; guac_terminal_display_commit_select(terminal->term_display); guac_terminal_buffer_row* buffer_row; int row; int start_row, start_col; int end_row, end_col; /* Ensure proper ordering of start and end coords */ if (terminal->selection_start_row < terminal->selection_end_row || (terminal->selection_start_row == terminal->selection_end_row && terminal->selection_start_column < terminal->selection_end_column)) { start_row = terminal->selection_start_row; start_col = terminal->selection_start_column; end_row = terminal->selection_end_row; end_col = terminal->selection_end_column + terminal->selection_end_width - 1; } else { end_row = terminal->selection_start_row; end_col = terminal->selection_start_column + terminal->selection_start_width - 1; start_row = terminal->selection_end_row; start_col = terminal->selection_end_column; } /* If only one row, simply copy */ buffer_row = guac_terminal_buffer_get_row(terminal->buffer, start_row, 0); if (end_row == start_row) { if (buffer_row->length - 1 < end_col) end_col = buffer_row->length - 1; string += __guac_terminal_buffer_string(buffer_row, start_col, end_col, string); } /* Otherwise, copy multiple rows */ else { /* Store first row */ string += __guac_terminal_buffer_string(buffer_row, start_col, buffer_row->length - 1, string); /* Store all middle rows */ for (row=start_row+1; rowbuffer, row, 0); *(string++) = '\n'; string += __guac_terminal_buffer_string(buffer_row, 0, buffer_row->length - 1, string); } /* Store last row */ buffer_row = guac_terminal_buffer_get_row(terminal->buffer, end_row, 0); if (buffer_row->length - 1 < end_col) end_col = buffer_row->length - 1; *(string++) = '\n'; string += __guac_terminal_buffer_string(buffer_row, 0, end_col, string); } /* Null terminator */ *string = 0; } void guac_terminal_copy_columns(guac_terminal* terminal, int row, int start_column, int end_column, int offset) { guac_terminal_display_copy_columns(terminal->term_display, row + terminal->scroll_offset, start_column, end_column, offset); guac_terminal_buffer_copy_columns(terminal->buffer, row, start_column, end_column, offset); /* Update cursor location if within region */ if (row == terminal->visible_cursor_row && terminal->visible_cursor_col >= start_column && terminal->visible_cursor_col <= end_column) terminal->visible_cursor_col += offset; /* Force breaks around destination region */ __guac_terminal_force_break(terminal, row, start_column + offset); __guac_terminal_force_break(terminal, row, end_column + offset + 1); } void guac_terminal_copy_rows(guac_terminal* terminal, int start_row, int end_row, int offset) { guac_terminal_display_copy_rows(terminal->term_display, start_row + terminal->scroll_offset, end_row + terminal->scroll_offset, offset); guac_terminal_buffer_copy_rows(terminal->buffer, start_row, end_row, offset); /* Update cursor location if within region */ if (terminal->visible_cursor_row >= start_row && terminal->visible_cursor_row <= end_row) terminal->visible_cursor_row += offset; } void guac_terminal_set_columns(guac_terminal* terminal, int row, int start_column, int end_column, guac_terminal_char* character) { __guac_terminal_set_columns(terminal, row, start_column, end_column, character); /* If visible cursor in current row, preserve state */ if (row == terminal->visible_cursor_row && terminal->visible_cursor_col >= start_column && terminal->visible_cursor_col <= end_column) { /* Create copy of character with cursor attribute set */ guac_terminal_char cursor_character = *character; cursor_character.attributes.cursor = true; __guac_terminal_set_columns(terminal, row, terminal->visible_cursor_col, terminal->visible_cursor_col, &cursor_character); } /* Force breaks around destination region */ __guac_terminal_force_break(terminal, row, start_column); __guac_terminal_force_break(terminal, row, end_column + 1); } static void __guac_terminal_redraw_rect(guac_terminal* term, int start_row, int start_col, int end_row, int end_col) { int row, col; /* Redraw region */ for (row=start_row; row<=end_row; row++) { guac_terminal_buffer_row* buffer_row = guac_terminal_buffer_get_row(term->buffer, row - term->scroll_offset, 0); /* Clear row */ guac_terminal_display_set_columns(term->term_display, row, start_col, end_col, &(term->default_char)); /* Copy characters */ for (col=start_col; col <= end_col && col < buffer_row->length; col++) { /* Only redraw if not blank */ guac_terminal_char* c = &(buffer_row->characters[col]); if (guac_terminal_has_glyph(c->value)) guac_terminal_display_set_columns(term->term_display, row, col, col, c); } } } /** * Internal terminal resize routine. Accepts width/height in CHARACTERS * (not pixels like the public function). */ static void __guac_terminal_resize(guac_terminal* term, int width, int height) { /* If height is decreasing, shift display up */ if (height < term->term_height) { int shift_amount; /* Get number of rows actually occupying terminal space */ int used_height = term->buffer->length; if (used_height > term->term_height) used_height = term->term_height; shift_amount = used_height - height; /* If the new terminal bottom covers N rows, shift up N rows */ if (shift_amount > 0) { guac_terminal_display_copy_rows(term->term_display, shift_amount, term->term_display->height - 1, -shift_amount); /* Update buffer top and cursor row based on shift */ term->buffer->top += shift_amount; term->cursor_row -= shift_amount; term->visible_cursor_row -= shift_amount; /* Redraw characters within old region */ __guac_terminal_redraw_rect(term, height - shift_amount, 0, height-1, width-1); } } /* Resize display */ guac_terminal_display_flush(term->term_display); guac_terminal_display_resize(term->term_display, width, height); /* Reraw any characters on right if widening */ if (width > term->term_width) __guac_terminal_redraw_rect(term, 0, term->term_width-1, height-1, width-1); /* If height is increasing, shift display down */ if (height > term->term_height) { /* If undisplayed rows exist in the buffer, shift them into view */ if (term->term_height < term->buffer->length) { /* If the new terminal bottom reveals N rows, shift down N rows */ int shift_amount = height - term->term_height; /* The maximum amount we can shift is the number of undisplayed rows */ int max_shift = term->buffer->length - term->term_height; if (shift_amount > max_shift) shift_amount = max_shift; /* Update buffer top and cursor row based on shift */ term->buffer->top -= shift_amount; term->cursor_row += shift_amount; term->visible_cursor_row += shift_amount; /* If scrolled enough, use scroll to fulfill entire resize */ if (term->scroll_offset >= shift_amount) { term->scroll_offset -= shift_amount; guac_terminal_scrollbar_set_value(term->scrollbar, -term->scroll_offset); /* Draw characters from scroll at bottom */ __guac_terminal_redraw_rect(term, term->term_height, 0, term->term_height + shift_amount - 1, width-1); } /* Otherwise, fulfill with as much scroll as possible */ else { /* Draw characters from scroll at bottom */ __guac_terminal_redraw_rect(term, term->term_height, 0, term->term_height + term->scroll_offset - 1, width-1); /* Update shift_amount and scroll based on new rows */ shift_amount -= term->scroll_offset; term->scroll_offset = 0; guac_terminal_scrollbar_set_value(term->scrollbar, -term->scroll_offset); /* If anything remains, move screen as necessary */ if (shift_amount > 0) { guac_terminal_display_copy_rows(term->term_display, 0, term->term_display->height - shift_amount - 1, shift_amount); /* Draw characters at top from scroll */ __guac_terminal_redraw_rect(term, 0, 0, shift_amount - 1, width-1); } } } /* end if undisplayed rows exist */ } /* Keep cursor on screen */ if (term->cursor_row < 0) term->cursor_row = 0; if (term->cursor_row >= height) term->cursor_row = height-1; if (term->cursor_col < 0) term->cursor_col = 0; if (term->cursor_col >= width) term->cursor_col = width-1; /* Commit new dimensions */ term->term_width = width; term->term_height = height; } int guac_terminal_resize(guac_terminal* terminal, int width, int height) { guac_terminal_display* display = terminal->term_display; guac_client* client = display->client; /* Acquire exclusive access to terminal */ guac_terminal_lock(terminal); /* Calculate available display area */ int available_width = width - GUAC_TERMINAL_SCROLLBAR_WIDTH; if (available_width < 0) available_width = 0; /* Calculate dimensions */ int rows = height / display->char_height; int columns = available_width / display->char_width; /* Resize default layer to given pixel dimensions */ guac_common_surface_resize(terminal->display->default_surface, width, height); guac_terminal_paint_background(terminal, width, height); /* Notify scrollbar of resize */ guac_terminal_scrollbar_parent_resized(terminal->scrollbar, width, height, rows); guac_terminal_scrollbar_set_bounds(terminal->scrollbar, rows - terminal->buffer->length, 0); /* Resize terminal if row/column dimensions have changed */ if (columns != terminal->term_width || rows != terminal->term_height) { guac_client_log(client, GUAC_LOG_DEBUG, "Resizing terminal to %ix%i", rows, columns); /* Resize terminal */ __guac_terminal_resize(terminal, columns, rows); /* Reset scroll region */ terminal->scroll_end = rows - 1; } /* Release terminal */ guac_terminal_unlock(terminal); guac_terminal_notify(terminal); return 0; } void guac_terminal_flush(guac_terminal* terminal) { /* Flush typescript if in use */ if (terminal->typescript != NULL) guac_terminal_typescript_flush(terminal->typescript); /* Flush display state */ guac_terminal_commit_cursor(terminal); guac_terminal_display_flush(terminal->term_display); guac_terminal_scrollbar_flush(terminal->scrollbar); } void guac_terminal_lock(guac_terminal* terminal) { pthread_mutex_lock(&(terminal->lock)); } void guac_terminal_unlock(guac_terminal* terminal) { pthread_mutex_unlock(&(terminal->lock)); } int guac_terminal_send_data(guac_terminal* term, const char* data, int length) { return guac_terminal_write_all(term->stdin_pipe_fd[1], data, length); } int guac_terminal_send_string(guac_terminal* term, const char* data) { return guac_terminal_write_all(term->stdin_pipe_fd[1], data, strlen(data)); } static int __guac_terminal_send_key(guac_terminal* term, int keysym, int pressed) { /* Hide mouse cursor if not already hidden */ if (term->current_cursor != GUAC_TERMINAL_CURSOR_BLANK) { term->current_cursor = GUAC_TERMINAL_CURSOR_BLANK; guac_common_cursor_set_blank(term->display->cursor); guac_terminal_notify(term); } /* Track modifiers */ if (keysym == 0xFFE3) term->mod_ctrl = pressed; else if (keysym == 0xFFE9) term->mod_alt = pressed; else if (keysym == 0xFFE1) term->mod_shift = pressed; /* If key pressed */ else if (pressed) { /* Ctrl+Shift+V shortcut for paste */ if (keysym == 'V' && term->mod_ctrl) return guac_terminal_send_data(term, term->clipboard->buffer, term->clipboard->length); /* Shift+PgUp / Shift+PgDown shortcuts for scrolling */ if (term->mod_shift) { /* Page up */ if (keysym == 0xFF55) { guac_terminal_scroll_display_up(term, term->term_height); return 0; } /* Page down */ if (keysym == 0xFF56) { guac_terminal_scroll_display_down(term, term->term_height); return 0; } } /* Reset scroll */ if (term->scroll_offset != 0) guac_terminal_scroll_display_down(term, term->scroll_offset); /* If alt being held, also send escape character */ if (term->mod_alt) return guac_terminal_send_string(term, "\x1B"); /* Translate Ctrl+letter to control code */ if (term->mod_ctrl) { char data; /* Keysyms for '@' through '_' are all conveniently in C0 order */ if (keysym >= '@' && keysym <= '_') data = (char) (keysym - '@'); /* Handle lowercase as well */ else if (keysym >= 'a' && keysym <= 'z') data = (char) (keysym - 'a' + 1); /* Ctrl+? is DEL (0x7f) */ else if (keysym == '?') data = 0x7F; /* Map Ctrl+2 to same result as Ctrl+@ */ else if (keysym == '2') data = 0x00; /* Map Ctrl+3 through Ctrl-7 to the remaining C0 characters such that Ctrl+6 is the same as Ctrl+^ */ else if (keysym >= '3' && keysym <= '7') data = (char) (keysym - '3' + 0x1B); /* Otherwise ignore */ else return 0; return guac_terminal_send_data(term, &data, 1); } /* Translate Unicode to UTF-8 */ else if ((keysym >= 0x00 && keysym <= 0xFF) || ((keysym & 0xFFFF0000) == 0x01000000)) { int length; char data[5]; length = guac_terminal_encode_utf8(keysym & 0xFFFF, data); return guac_terminal_send_data(term, data, length); } /* Non-printable keys */ else { if (keysym == 0xFF08) return guac_terminal_send_string(term, "\x7F"); /* Backspace */ if (keysym == 0xFF09) return guac_terminal_send_string(term, "\x09"); /* Tab */ if (keysym == 0xFF0D) return guac_terminal_send_string(term, "\x0D"); /* Enter */ if (keysym == 0xFF1B) return guac_terminal_send_string(term, "\x1B"); /* Esc */ if (keysym == 0xFF50) return guac_terminal_send_string(term, "\x1B[1~"); /* Home */ /* Arrow keys w/ application cursor */ if (term->application_cursor_keys) { if (keysym == 0xFF51) return guac_terminal_send_string(term, "\x1BOD"); /* Left */ if (keysym == 0xFF52) return guac_terminal_send_string(term, "\x1BOA"); /* Up */ if (keysym == 0xFF53) return guac_terminal_send_string(term, "\x1BOC"); /* Right */ if (keysym == 0xFF54) return guac_terminal_send_string(term, "\x1BOB"); /* Down */ } else { if (keysym == 0xFF51) return guac_terminal_send_string(term, "\x1B[D"); /* Left */ if (keysym == 0xFF52) return guac_terminal_send_string(term, "\x1B[A"); /* Up */ if (keysym == 0xFF53) return guac_terminal_send_string(term, "\x1B[C"); /* Right */ if (keysym == 0xFF54) return guac_terminal_send_string(term, "\x1B[B"); /* Down */ } if (keysym == 0xFF55) return guac_terminal_send_string(term, "\x1B[5~"); /* Page up */ if (keysym == 0xFF56) return guac_terminal_send_string(term, "\x1B[6~"); /* Page down */ if (keysym == 0xFF57) return guac_terminal_send_string(term, "\x1B[4~"); /* End */ if (keysym == 0xFF63) return guac_terminal_send_string(term, "\x1B[2~"); /* Insert */ if (keysym == 0xFFBE) return guac_terminal_send_string(term, "\x1B[[A"); /* F1 */ if (keysym == 0xFFBF) return guac_terminal_send_string(term, "\x1B[[B"); /* F2 */ if (keysym == 0xFFC0) return guac_terminal_send_string(term, "\x1B[[C"); /* F3 */ if (keysym == 0xFFC1) return guac_terminal_send_string(term, "\x1B[[D"); /* F4 */ if (keysym == 0xFFC2) return guac_terminal_send_string(term, "\x1B[[E"); /* F5 */ if (keysym == 0xFFC3) return guac_terminal_send_string(term, "\x1B[17~"); /* F6 */ if (keysym == 0xFFC4) return guac_terminal_send_string(term, "\x1B[18~"); /* F7 */ if (keysym == 0xFFC5) return guac_terminal_send_string(term, "\x1B[19~"); /* F8 */ if (keysym == 0xFFC6) return guac_terminal_send_string(term, "\x1B[20~"); /* F9 */ if (keysym == 0xFFC7) return guac_terminal_send_string(term, "\x1B[21~"); /* F10 */ if (keysym == 0xFFC8) return guac_terminal_send_string(term, "\x1B[22~"); /* F11 */ if (keysym == 0xFFC9) return guac_terminal_send_string(term, "\x1B[23~"); /* F12 */ if (keysym == 0xFFFF) return guac_terminal_send_string(term, "\x1B[3~"); /* Delete */ /* Ignore unknown keys */ guac_client_log(term->client, GUAC_LOG_DEBUG, "Ignoring unknown keysym: 0x%X", keysym); } } return 0; } int guac_terminal_send_key(guac_terminal* term, int keysym, int pressed) { int result; guac_terminal_lock(term); result = __guac_terminal_send_key(term, keysym, pressed); guac_terminal_unlock(term); return result; } static int __guac_terminal_send_mouse(guac_terminal* term, guac_user* user, int x, int y, int mask) { guac_client* client = term->client; guac_socket* socket = client->socket; /* Determine which buttons were just released and pressed */ int released_mask = term->mouse_mask & ~mask; int pressed_mask = ~term->mouse_mask & mask; /* Store current mouse location */ guac_common_cursor_move(term->display->cursor, user, x, y); /* Notify scrollbar, do not handle anything handled by scrollbar */ if (guac_terminal_scrollbar_handle_mouse(term->scrollbar, x, y, mask)) { /* Set pointer cursor if mouse is over scrollbar */ if (term->current_cursor != GUAC_TERMINAL_CURSOR_POINTER) { term->current_cursor = GUAC_TERMINAL_CURSOR_POINTER; guac_common_cursor_set_pointer(term->display->cursor); guac_terminal_notify(term); } guac_terminal_notify(term); return 0; } term->mouse_mask = mask; /* Show mouse cursor if not already shown */ if (term->current_cursor != GUAC_TERMINAL_CURSOR_IBAR) { term->current_cursor = GUAC_TERMINAL_CURSOR_IBAR; guac_common_cursor_set_ibar(term->display->cursor); guac_terminal_notify(term); } /* Paste contents of clipboard on right or middle mouse button up */ if ((released_mask & GUAC_CLIENT_MOUSE_RIGHT) || (released_mask & GUAC_CLIENT_MOUSE_MIDDLE)) return guac_terminal_send_data(term, term->clipboard->buffer, term->clipboard->length); /* If text selected, change state based on left mouse mouse button */ if (term->text_selected) { /* If mouse button released, stop selection */ if (released_mask & GUAC_CLIENT_MOUSE_LEFT) { int selected_length; /* End selection and get selected text */ int selectable_size = term->term_width * term->term_height * sizeof(char); char* string = malloc(selectable_size); guac_terminal_select_end(term, string); selected_length = strnlen(string, selectable_size); /* Store new data */ guac_common_clipboard_reset(term->clipboard, "text/plain"); guac_common_clipboard_append(term->clipboard, string, selected_length); free(string); /* Send data */ guac_common_clipboard_send(term->clipboard, client); guac_socket_flush(socket); } /* Otherwise, just update */ else guac_terminal_select_update(term, y / term->term_display->char_height - term->scroll_offset, x / term->term_display->char_width); } /* Otherwise, if mouse button pressed AND moved, start selection */ else if (!(pressed_mask & GUAC_CLIENT_MOUSE_LEFT) && mask & GUAC_CLIENT_MOUSE_LEFT) guac_terminal_select_start(term, y / term->term_display->char_height - term->scroll_offset, x / term->term_display->char_width); /* Scroll up if wheel moved up */ if (released_mask & GUAC_CLIENT_MOUSE_SCROLL_UP) guac_terminal_scroll_display_up(term, GUAC_TERMINAL_WHEEL_SCROLL_AMOUNT); /* Scroll down if wheel moved down */ if (released_mask & GUAC_CLIENT_MOUSE_SCROLL_DOWN) guac_terminal_scroll_display_down(term, GUAC_TERMINAL_WHEEL_SCROLL_AMOUNT); return 0; } int guac_terminal_send_mouse(guac_terminal* term, guac_user* user, int x, int y, int mask) { int result; guac_terminal_lock(term); result = __guac_terminal_send_mouse(term, user, x, y, mask); guac_terminal_unlock(term); return result; } void guac_terminal_scroll_handler(guac_terminal_scrollbar* scrollbar, int value) { guac_terminal* terminal = (guac_terminal*) scrollbar->data; /* Calculate change in scroll offset */ int delta = -value - terminal->scroll_offset; /* Update terminal based on change in scroll offset */ if (delta < 0) guac_terminal_scroll_display_down(terminal, -delta); else if (delta > 0) guac_terminal_scroll_display_up(terminal, delta); /* Update scrollbar value */ guac_terminal_scrollbar_set_value(scrollbar, value); } void guac_terminal_clipboard_reset(guac_terminal* term, const char* mimetype) { guac_common_clipboard_reset(term->clipboard, mimetype); } void guac_terminal_clipboard_append(guac_terminal* term, const void* data, int length) { guac_common_clipboard_append(term->clipboard, data, length); } int guac_terminal_sendf(guac_terminal* term, const char* format, ...) { int written; va_list ap; char buffer[1024]; /* Print to buffer */ va_start(ap, format); written = vsnprintf(buffer, sizeof(buffer)-1, format, ap); va_end(ap); if (written < 0) return written; /* Write to STDIN */ return guac_terminal_write_all(term->stdin_pipe_fd[1], buffer, written); } void guac_terminal_set_tab(guac_terminal* term, int column) { int i; /* Search for available space, set if available */ for (i=0; icustom_tabs[i] == 0) { term->custom_tabs[i] = column+1; break; } } } void guac_terminal_unset_tab(guac_terminal* term, int column) { int i; /* Search for given tab, unset if found */ for (i=0; icustom_tabs[i] == column+1) { term->custom_tabs[i] = 0; break; } } } void guac_terminal_clear_tabs(guac_terminal* term) { term->tab_interval = 0; memset(term->custom_tabs, 0, sizeof(term->custom_tabs)); } int guac_terminal_next_tab(guac_terminal* term, int column) { int i; /* Determine tab stop from interval */ int tabstop; if (term->tab_interval != 0) tabstop = (column / term->tab_interval + 1) * term->tab_interval; else tabstop = term->term_width - 1; /* Walk custom tabs, trying to find an earlier occurrence */ for (i=0; icustom_tabs[i] - 1; if (custom_tabstop != -1 && custom_tabstop > column && custom_tabstop < tabstop) tabstop = custom_tabstop; } return tabstop; } void guac_terminal_pipe_stream_open(guac_terminal* term, const char* name) { guac_client* client = term->client; guac_socket* socket = client->socket; /* Close existing stream, if any */ guac_terminal_pipe_stream_close(term); /* Allocate and assign new pipe stream */ term->pipe_stream = guac_client_alloc_stream(client); term->pipe_buffer_length = 0; /* Open new pipe stream */ guac_protocol_send_pipe(socket, term->pipe_stream, "text/plain", name); /* Log redirect at debug level */ guac_client_log(client, GUAC_LOG_DEBUG, "Terminal output now redirected to pipe '%s'.", name); } void guac_terminal_pipe_stream_write(guac_terminal* term, char c) { /* Append byte to buffer only if pipe is open */ if (term->pipe_stream != NULL) { /* Flush buffer if no space is available */ if (term->pipe_buffer_length == sizeof(term->pipe_buffer)) guac_terminal_pipe_stream_flush(term); /* Append single byte to buffer */ term->pipe_buffer[term->pipe_buffer_length++] = c; } } void guac_terminal_pipe_stream_flush(guac_terminal* term) { guac_client* client = term->client; guac_socket* socket = client->socket; guac_stream* pipe_stream = term->pipe_stream; /* Write blob if data exists in buffer */ if (pipe_stream != NULL && term->pipe_buffer_length > 0) { guac_protocol_send_blob(socket, pipe_stream, term->pipe_buffer, term->pipe_buffer_length); term->pipe_buffer_length = 0; } } void guac_terminal_pipe_stream_close(guac_terminal* term) { guac_client* client = term->client; guac_socket* socket = client->socket; guac_stream* pipe_stream = term->pipe_stream; /* Close any existing pipe */ if (pipe_stream != NULL) { /* Write end of stream */ guac_terminal_pipe_stream_flush(term); guac_protocol_send_end(socket, pipe_stream); /* Destroy stream */ guac_client_free_stream(client, pipe_stream); term->pipe_stream = NULL; /* Log redirect at debug level */ guac_client_log(client, GUAC_LOG_DEBUG, "Terminal output now redirected to display."); } } int guac_terminal_create_typescript(guac_terminal* term, const char* path, const char* name, int create_path) { /* Create typescript */ term->typescript = guac_terminal_typescript_alloc(path, name, create_path); /* Log failure */ if (term->typescript == NULL) { guac_client_log(term->client, GUAC_LOG_ERROR, "Creation of typescript failed: %s", strerror(errno)); return 1; } /* If typescript was successfully created, log filenames */ guac_client_log(term->client, GUAC_LOG_INFO, "Typescript of terminal session will be saved to \"%s\". " "Timing file is \"%s\".", term->typescript->data_filename, term->typescript->timing_filename); /* Typescript creation succeeded */ return 0; } void guac_terminal_add_user(guac_terminal* term, guac_user* user, guac_socket* socket) { /* Synchronize display state with new user */ guac_common_display_dup(term->display, user, socket); guac_terminal_scrollbar_dup(term->scrollbar, user, socket); }