/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ #include "fs.h" #include "download.h" #include "upload.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include guac_rdp_fs* guac_rdp_fs_alloc(guac_client* client, const char* drive_path, int create_drive_path, int disable_download, int disable_upload) { /* Create drive path if it does not exist */ if (create_drive_path) { guac_client_log(client, GUAC_LOG_DEBUG, "%s: Creating directory \"%s\" if necessary.", __func__, drive_path); /* Log error if directory creation fails */ if (mkdir(drive_path, S_IRWXU) && errno != EEXIST) { guac_client_log(client, GUAC_LOG_ERROR, "Unable to create directory \"%s\": %s", drive_path, strerror(errno)); } } guac_rdp_fs* fs = malloc(sizeof(guac_rdp_fs)); fs->client = client; fs->drive_path = strdup(drive_path); fs->file_id_pool = guac_pool_alloc(0); fs->open_files = 0; fs->disable_download = disable_download; fs->disable_upload = disable_upload; return fs; } void guac_rdp_fs_free(guac_rdp_fs* fs) { guac_pool_free(fs->file_id_pool); free(fs->drive_path); free(fs); } guac_object* guac_rdp_fs_alloc_object(guac_rdp_fs* fs, guac_user* user) { /* Init filesystem */ guac_object* fs_object = guac_user_alloc_object(user); fs_object->get_handler = guac_rdp_download_get_handler; /* Assign handler only if uploads are not disabled. */ if (!fs->disable_upload) fs_object->put_handler = guac_rdp_upload_put_handler; fs_object->data = fs; /* Send filesystem to user */ guac_protocol_send_filesystem(user->socket, fs_object, "Shared Drive"); guac_socket_flush(user->socket); return fs_object; } void* guac_rdp_fs_expose(guac_user* user, void* data) { guac_rdp_fs* fs = (guac_rdp_fs*) data; /* No need to expose if there is no filesystem or the user has left */ if (user == NULL || fs == NULL) return NULL; /* Allocate and expose filesystem object for user */ return guac_rdp_fs_alloc_object(fs, user); } /** * Translates an absolute Windows path to an absolute path which is within the * "drive path" specified in the connection settings. No checking is performed * on the path provided, which is assumed to have already been normalized and * validated as absolute. * * @param fs * The filesystem containing the file whose path is being translated. * * @param virtual_path * The absolute path to the file on the simulated filesystem, relative to * the simulated filesystem root. * * @param real_path * The buffer in which to store the absolute path to the real file on the * local filesystem. */ static void __guac_rdp_fs_translate_path(guac_rdp_fs* fs, const char* virtual_path, char* real_path) { /* Get drive path */ char* drive_path = fs->drive_path; int i; /* Start with path from settings */ for (i=0; iclient, GUAC_LOG_DEBUG, "%s: path=\"%s\", access=0x%x, file_attributes=0x%x, " "create_disposition=0x%x, create_options=0x%x", __func__, path, access, file_attributes, create_disposition, create_options); /* If no files available, return too many open */ if (fs->open_files >= GUAC_RDP_FS_MAX_FILES) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Too many open files.", __func__, path); return GUAC_RDP_FS_ENFILE; } /* If path empty, transform to root path */ if (path[0] == '\0') path = "\\"; /* If path is relative, the file does not exist */ else if (path[0] != '\\' && path[0] != '/') { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Access denied - supplied path \"%s\" is relative.", __func__, path); return GUAC_RDP_FS_ENOENT; } /* Translate access into flags */ if (access & GENERIC_ALL) flags = O_RDWR; else if ((access & ( GENERIC_WRITE | FILE_WRITE_DATA | FILE_APPEND_DATA)) && (access & (GENERIC_READ | FILE_READ_DATA))) flags = O_RDWR; else if (access & ( GENERIC_WRITE | FILE_WRITE_DATA | FILE_APPEND_DATA)) flags = O_WRONLY; else flags = O_RDONLY; /* Normalize path, return no-such-file if invalid */ if (guac_rdp_fs_normalize_path(path, normalized_path)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Normalization of path \"%s\" failed.", __func__, path); return GUAC_RDP_FS_ENOENT; } guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Normalized path \"%s\" to \"%s\".", __func__, path, normalized_path); /* Translate normalized path to real path */ __guac_rdp_fs_translate_path(fs, normalized_path, real_path); guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Translated path \"%s\" to \"%s\".", __func__, normalized_path, real_path); switch (create_disposition) { /* Create if not exist, fail otherwise */ case FILE_CREATE: flags |= O_CREAT | O_EXCL; break; /* Open file if exists and do not overwrite, fail otherwise */ case FILE_OPEN: /* No flag necessary - default functionality of open */ break; /* Open if exists, create otherwise */ case FILE_OPEN_IF: flags |= O_CREAT; break; /* Overwrite if exists, fail otherwise */ case FILE_OVERWRITE: flags |= O_TRUNC; break; /* Overwrite if exists, create otherwise */ case FILE_OVERWRITE_IF: flags |= O_CREAT | O_TRUNC; break; /* Supersede (replace) if exists, otherwise create */ case FILE_SUPERSEDE: unlink(real_path); flags |= O_CREAT | O_TRUNC; break; /* Unrecognised disposition */ default: return GUAC_RDP_FS_ENOSYS; } /* Create directory first, if necessary */ if ((create_options & FILE_DIRECTORY_FILE) && (flags & O_CREAT)) { /* Create directory */ if (mkdir(real_path, S_IRWXU)) { if (errno != EEXIST || (flags & O_EXCL)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: mkdir() failed: %s", __func__, strerror(errno)); return guac_rdp_fs_get_errorcode(errno); } } /* Unset O_CREAT and O_EXCL as directory must exist before open() */ flags &= ~(O_CREAT | O_EXCL); } guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: native open: real_path=\"%s\", flags=0x%x", __func__, real_path, flags); /* Open file */ fd = open(real_path, flags, S_IRUSR | S_IWUSR); /* If file open failed as we're trying to write a dir, retry as read-only */ if (fd == -1 && errno == EISDIR) { flags &= ~(O_WRONLY | O_RDWR); flags |= O_RDONLY; fd = open(real_path, flags, S_IRUSR | S_IWUSR); } if (fd == -1) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: open() failed: %s", __func__, strerror(errno)); return guac_rdp_fs_get_errorcode(errno); } /* Get file ID, init file */ file_id = guac_pool_next_int(fs->file_id_pool); file = &(fs->files[file_id]); file->id = file_id; file->fd = fd; file->dir = NULL; file->dir_pattern[0] = '\0'; file->absolute_path = strdup(normalized_path); file->real_path = strdup(real_path); file->bytes_written = 0; guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Opened \"%s\" as file_id=%i", __func__, normalized_path, file_id); /* Attempt to pull file information */ if (fstat(fd, &file_stat) == 0) { /* Load size and times */ file->size = file_stat.st_size; file->ctime = WINDOWS_TIME(file_stat.st_ctime); file->mtime = WINDOWS_TIME(file_stat.st_mtime); file->atime = WINDOWS_TIME(file_stat.st_atime); /* Set type */ if (S_ISDIR(file_stat.st_mode)) file->attributes = FILE_ATTRIBUTE_DIRECTORY; else file->attributes = FILE_ATTRIBUTE_NORMAL; } /* If information cannot be retrieved, fake it */ else { /* Init information to 0, lacking any alternative */ file->size = 0; file->ctime = 0; file->mtime = 0; file->atime = 0; file->attributes = FILE_ATTRIBUTE_NORMAL; } fs->open_files++; return file_id; } int guac_rdp_fs_read(guac_rdp_fs* fs, int file_id, uint64_t offset, void* buffer, int length) { int bytes_read; guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Read from bad file_id: %i", __func__, file_id); return GUAC_RDP_FS_EINVAL; } /* Attempt read */ lseek(file->fd, offset, SEEK_SET); bytes_read = read(file->fd, buffer, length); /* Translate errno on error */ if (bytes_read < 0) return guac_rdp_fs_get_errorcode(errno); return bytes_read; } int guac_rdp_fs_write(guac_rdp_fs* fs, int file_id, uint64_t offset, void* buffer, int length) { int bytes_written; guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Write to bad file_id: %i", __func__, file_id); return GUAC_RDP_FS_EINVAL; } /* Attempt write */ lseek(file->fd, offset, SEEK_SET); bytes_written = write(file->fd, buffer, length); /* Translate errno on error */ if (bytes_written < 0) return guac_rdp_fs_get_errorcode(errno); file->bytes_written += bytes_written; return bytes_written; } int guac_rdp_fs_rename(guac_rdp_fs* fs, int file_id, const char* new_path) { char real_path[GUAC_RDP_FS_MAX_PATH]; char normalized_path[GUAC_RDP_FS_MAX_PATH]; guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Rename of bad file_id: %i", __func__, file_id); return GUAC_RDP_FS_EINVAL; } /* Normalize path, return no-such-file if invalid */ if (guac_rdp_fs_normalize_path(new_path, normalized_path)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Normalization of path \"%s\" failed.", __func__, new_path); return GUAC_RDP_FS_ENOENT; } /* Translate normalized path to real path */ __guac_rdp_fs_translate_path(fs, normalized_path, real_path); guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Renaming \"%s\" -> \"%s\"", __func__, file->real_path, real_path); /* Perform rename */ if (rename(file->real_path, real_path)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: rename() failed: \"%s\" -> \"%s\"", __func__, file->real_path, real_path); return guac_rdp_fs_get_errorcode(errno); } return 0; } int guac_rdp_fs_delete(guac_rdp_fs* fs, int file_id) { /* Get file */ guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Delete of bad file_id: %i", __func__, file_id); return GUAC_RDP_FS_EINVAL; } /* If directory, attempt removal */ if (file->attributes & FILE_ATTRIBUTE_DIRECTORY) { if (rmdir(file->real_path)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: rmdir() failed: \"%s\"", __func__, file->real_path); return guac_rdp_fs_get_errorcode(errno); } } /* Otherwise, attempt deletion */ else if (unlink(file->real_path)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: unlink() failed: \"%s\"", __func__, file->real_path); return guac_rdp_fs_get_errorcode(errno); } return 0; } int guac_rdp_fs_truncate(guac_rdp_fs* fs, int file_id, int length) { /* Get file */ guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Delete of bad file_id: %i", __func__, file_id); return GUAC_RDP_FS_EINVAL; } /* Attempt truncate */ if (ftruncate(file->fd, length)) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: ftruncate() to %i bytes failed: \"%s\"", __func__, length, file->real_path); return guac_rdp_fs_get_errorcode(errno); } return 0; } void guac_rdp_fs_close(guac_rdp_fs* fs, int file_id) { guac_rdp_fs_file* file = guac_rdp_fs_get_file(fs, file_id); if (file == NULL) { guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Ignoring close for bad file_id: %i", __func__, file_id); return; } file = &(fs->files[file_id]); guac_client_log(fs->client, GUAC_LOG_DEBUG, "%s: Closed \"%s\" (file_id=%i)", __func__, file->absolute_path, file_id); /* Close directory, if open */ if (file->dir != NULL) closedir(file->dir); /* Close file */ close(file->fd); /* Free name */ free(file->absolute_path); free(file->real_path); /* Free ID back to pool */ guac_pool_free_int(fs->file_id_pool, file_id); fs->open_files--; } const char* guac_rdp_fs_read_dir(guac_rdp_fs* fs, int file_id) { guac_rdp_fs_file* file; struct dirent* result; /* Only read if file ID is valid */ if (file_id < 0 || file_id >= GUAC_RDP_FS_MAX_FILES) return NULL; file = &(fs->files[file_id]); /* Open directory if not yet open, stop if error */ if (file->dir == NULL) { file->dir = fdopendir(file->fd); if (file->dir == NULL) return NULL; } /* Read next entry, stop if error or no more entries */ if ((result = readdir(file->dir)) == NULL) return NULL; /* Return filename */ return result->d_name; } const char* guac_rdp_fs_basename(const char* path) { for (const char* c = path; *c != '\0'; c++) { /* Reset beginning of path if a path separator is found */ if (*c == '/' || *c == '\\') path = c + 1; } /* path now points to the first character after the last path separator */ return path; } int guac_rdp_fs_normalize_path(const char* path, char* abs_path) { int path_depth = 0; const char* path_components[GUAC_RDP_MAX_PATH_DEPTH]; /* If original path is not absolute, normalization fails */ if (path[0] != '\\' && path[0] != '/') return 1; /* Create scratch copy of path excluding leading slash (we will be * replacing path separators with null terminators and referencing those * substrings directly as path components) */ char path_scratch[GUAC_RDP_FS_MAX_PATH - 1]; int length = guac_strlcpy(path_scratch, path + 1, sizeof(path_scratch)); /* Fail if provided path is too long */ if (length >= sizeof(path_scratch)) return 1; /* Locate all path components within path */ const char* current_path_component = &(path_scratch[0]); for (int i = 0; i <= length; i++) { /* If current character is a path separator, parse as component */ char c = path_scratch[i]; if (c == '/' || c == '\\' || c == '\0') { /* Terminate current component */ path_scratch[i] = '\0'; /* If component refers to parent, just move up in depth */ if (strcmp(current_path_component, "..") == 0) { if (path_depth > 0) path_depth--; } /* Otherwise, if component not current directory, add to list */ else if (strcmp(current_path_component, ".") != 0 && strcmp(current_path_component, "") != 0) { /* Fail normalization if path is too deep */ if (path_depth >= GUAC_RDP_MAX_PATH_DEPTH) return 1; path_components[path_depth++] = current_path_component; } /* Update start of next component */ current_path_component = &(path_scratch[i+1]); } /* end if separator */ /* We do not currently support named streams */ else if (c == ':') return 1; } /* end for each character */ /* Add leading slash for resulting absolute path */ abs_path[0] = '\\'; /* Append normalized components to path, separated by slashes */ guac_strljoin(abs_path + 1, path_components, path_depth, "\\", GUAC_RDP_FS_MAX_PATH - 1); return 0; } int guac_rdp_fs_convert_path(const char* parent, const char* rel_path, char* abs_path) { int length; char combined_path[GUAC_RDP_FS_MAX_PATH]; /* Copy parent path */ length = guac_strlcpy(combined_path, parent, sizeof(combined_path)); /* Add trailing slash */ length += guac_strlcpy(combined_path + length, "\\", sizeof(combined_path) - length); /* Copy remaining path */ length += guac_strlcpy(combined_path + length, rel_path, sizeof(combined_path) - length); /* Normalize into provided buffer */ return guac_rdp_fs_normalize_path(combined_path, abs_path); } guac_rdp_fs_file* guac_rdp_fs_get_file(guac_rdp_fs* fs, int file_id) { /* Validate ID */ if (file_id < 0 || file_id >= GUAC_RDP_FS_MAX_FILES) return NULL; /* Return file at given ID */ return &(fs->files[file_id]); } int guac_rdp_fs_matches(const char* filename, const char* pattern) { return fnmatch(pattern, filename, FNM_NOESCAPE) != 0; } int guac_rdp_fs_get_info(guac_rdp_fs* fs, guac_rdp_fs_info* info) { /* Read FS information */ struct statvfs fs_stat; if (statvfs(fs->drive_path, &fs_stat)) return guac_rdp_fs_get_errorcode(errno); /* Assign to structure */ info->blocks_available = fs_stat.f_bfree; info->blocks_total = fs_stat.f_blocks; info->block_size = fs_stat.f_bsize; return 0; } int guac_rdp_fs_append_filename(char* fullpath, const char* path, const char* filename) { int i; /* Disallow "." as a filename */ if (strcmp(filename, ".") == 0) return 0; /* Disallow ".." as a filename */ if (strcmp(filename, "..") == 0) return 0; /* Copy path, append trailing slash */ for (i=0; i 0 && path[i-1] != '/' && path[i-1] != '\\') fullpath[i++] = '/'; break; } /* Copy character if not end of string */ fullpath[i] = c; } /* Append filename */ for (; i