mirror of
				https://github.com/RGBCube/serenity
				synced 2025-10-30 07:12:33 +00:00 
			
		
		
		
	 1a6affc64b
			
		
	
	
		1a6affc64b
		
	
	
	
	
		
			
			This ensures that new files added after the setup of the FileSystemModel are also are watched.
		
			
				
	
	
		
			906 lines
		
	
	
	
		
			28 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			906 lines
		
	
	
	
		
			28 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /*
 | |
|  * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
 | |
|  * Copyright (c) 2021, sin-ack <sin-ack@protonmail.com>
 | |
|  * Copyright (c) 2022, the SerenityOS developers.
 | |
|  *
 | |
|  * SPDX-License-Identifier: BSD-2-Clause
 | |
|  */
 | |
| 
 | |
| #include <AK/LexicalPath.h>
 | |
| #include <AK/NumberFormat.h>
 | |
| #include <AK/QuickSort.h>
 | |
| #include <AK/StringBuilder.h>
 | |
| #include <AK/Types.h>
 | |
| #include <LibCore/DirIterator.h>
 | |
| #include <LibCore/StandardPaths.h>
 | |
| #include <LibFileSystem/FileSystem.h>
 | |
| #include <LibGUI/AbstractView.h>
 | |
| #include <LibGUI/FileIconProvider.h>
 | |
| #include <LibGUI/FileSystemModel.h>
 | |
| #include <LibGUI/Painter.h>
 | |
| #include <LibGfx/Bitmap.h>
 | |
| #include <LibThreading/BackgroundAction.h>
 | |
| #include <LibThreading/MutexProtected.h>
 | |
| #include <grp.h>
 | |
| #include <pwd.h>
 | |
| #include <stdio.h>
 | |
| #include <string.h>
 | |
| #include <sys/stat.h>
 | |
| #include <unistd.h>
 | |
| 
 | |
| namespace GUI {
 | |
| 
 | |
| ModelIndex FileSystemModel::Node::index(int column) const
 | |
| {
 | |
|     if (!m_parent)
 | |
|         return {};
 | |
|     for (size_t row = 0; row < m_parent->m_children.size(); ++row) {
 | |
|         if (m_parent->m_children[row] == this)
 | |
|             return m_model.create_index(row, column, const_cast<Node*>(this));
 | |
|     }
 | |
|     VERIFY_NOT_REACHED();
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::Node::fetch_data(DeprecatedString const& full_path, bool is_root)
 | |
| {
 | |
|     struct stat st;
 | |
|     int rc;
 | |
|     if (is_root)
 | |
|         rc = stat(full_path.characters(), &st);
 | |
|     else
 | |
|         rc = lstat(full_path.characters(), &st);
 | |
|     if (rc < 0) {
 | |
|         m_error = errno;
 | |
|         perror("stat/lstat");
 | |
|         return false;
 | |
|     }
 | |
| 
 | |
|     size = st.st_size;
 | |
|     mode = st.st_mode;
 | |
|     uid = st.st_uid;
 | |
|     gid = st.st_gid;
 | |
|     inode = st.st_ino;
 | |
|     mtime = st.st_mtime;
 | |
| 
 | |
|     if (S_ISLNK(mode)) {
 | |
|         auto sym_link_target_or_error = FileSystem::read_link(full_path);
 | |
|         if (sym_link_target_or_error.is_error())
 | |
|             perror("readlink");
 | |
|         else {
 | |
|             symlink_target = sym_link_target_or_error.release_value().to_deprecated_string();
 | |
|             if (symlink_target.is_empty())
 | |
|                 perror("readlink");
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     if (S_ISDIR(mode)) {
 | |
|         is_accessible_directory = access(full_path.characters(), R_OK | X_OK) == 0;
 | |
|     }
 | |
| 
 | |
|     return true;
 | |
| }
 | |
| 
 | |
| void FileSystemModel::Node::traverse_if_needed()
 | |
| {
 | |
|     if (m_has_traversed)
 | |
|         return;
 | |
| 
 | |
|     m_has_traversed = true;
 | |
| 
 | |
|     if (m_parent_of_root) {
 | |
|         auto root = adopt_own(*new Node(m_model));
 | |
|         root->fetch_data("/", true);
 | |
|         root->name = "/";
 | |
|         root->m_parent = this;
 | |
|         m_children.append(move(root));
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     auto full_path = this->full_path();
 | |
| 
 | |
|     if (!is_directory()) {
 | |
|         if (m_model.m_mode != DirectoriesOnly && !m_model.m_file_watcher->is_watching(full_path)) {
 | |
|             // We are not already watching this file, watch it
 | |
|             auto result = m_model.m_file_watcher->add_watch(full_path, Core::FileWatcherEvent::Type::MetadataModified);
 | |
| 
 | |
|             if (result.is_error()) {
 | |
|                 dbgln("Couldn't watch '{}': {}", full_path, result.error());
 | |
|             } else if (!result.value()) {
 | |
|                 dbgln("Couldn't watch '{}', probably already watching", full_path);
 | |
|             }
 | |
|         }
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     total_size = 0;
 | |
| 
 | |
|     Core::DirIterator di(full_path, m_model.should_show_dotfiles() ? Core::DirIterator::SkipParentAndBaseDir : Core::DirIterator::SkipDots);
 | |
|     if (di.has_error()) {
 | |
|         auto error = di.error();
 | |
|         m_error = error.code();
 | |
|         warnln("DirIterator: {}", error);
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     Vector<DeprecatedString> child_names;
 | |
|     while (di.has_next()) {
 | |
|         child_names.append(di.next_path());
 | |
|     }
 | |
|     quick_sort(child_names);
 | |
| 
 | |
|     Vector<NonnullOwnPtr<Node>> directory_children;
 | |
|     Vector<NonnullOwnPtr<Node>> file_children;
 | |
| 
 | |
|     for (auto& child_name : child_names) {
 | |
|         auto maybe_child = create_child(child_name);
 | |
|         if (!maybe_child)
 | |
|             continue;
 | |
| 
 | |
|         auto child = maybe_child.release_nonnull();
 | |
|         total_size += child->size;
 | |
|         if (S_ISDIR(child->mode)) {
 | |
|             directory_children.append(move(child));
 | |
|         } else {
 | |
|             if (!m_model.m_allowed_file_extensions.has_value()) {
 | |
|                 file_children.append(move(child));
 | |
|                 continue;
 | |
|             }
 | |
| 
 | |
|             for (auto& extension : *m_model.m_allowed_file_extensions) {
 | |
|                 if (child_name.ends_with(DeprecatedString::formatted(".{}", extension))) {
 | |
|                     file_children.append(move(child));
 | |
|                     break;
 | |
|                 }
 | |
|             }
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     m_children.extend(move(directory_children));
 | |
|     m_children.extend(move(file_children));
 | |
| 
 | |
|     if (!m_model.m_file_watcher->is_watching(full_path)) {
 | |
|         // We are not already watching this directory, watch it
 | |
|         auto result = m_model.m_file_watcher->add_watch(full_path,
 | |
|             Core::FileWatcherEvent::Type::MetadataModified
 | |
|                 | Core::FileWatcherEvent::Type::ChildCreated
 | |
|                 | Core::FileWatcherEvent::Type::ChildDeleted
 | |
|                 | Core::FileWatcherEvent::Type::Deleted);
 | |
| 
 | |
|         if (result.is_error()) {
 | |
|             dbgln("Couldn't watch '{}': {}", full_path, result.error());
 | |
|         } else if (!result.value()) {
 | |
|             dbgln("Couldn't watch '{}', probably already watching", full_path);
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::Node::can_delete_or_move() const
 | |
| {
 | |
|     if (!m_can_delete_or_move.has_value())
 | |
|         m_can_delete_or_move = FileSystem::can_delete_or_move(full_path());
 | |
|     return m_can_delete_or_move.value();
 | |
| }
 | |
| 
 | |
| OwnPtr<FileSystemModel::Node> FileSystemModel::Node::create_child(DeprecatedString const& child_name)
 | |
| {
 | |
|     DeprecatedString child_path = LexicalPath::join(full_path(), child_name).string();
 | |
|     auto child = adopt_own(*new Node(m_model));
 | |
| 
 | |
|     bool ok = child->fetch_data(child_path, false);
 | |
|     if (!ok)
 | |
|         return {};
 | |
| 
 | |
|     if (m_model.m_mode == DirectoriesOnly && !S_ISDIR(child->mode))
 | |
|         return {};
 | |
| 
 | |
|     child->name = child_name;
 | |
|     child->m_parent = this;
 | |
|     return child;
 | |
| }
 | |
| 
 | |
| void FileSystemModel::Node::reify_if_needed()
 | |
| {
 | |
|     if (mode == 0)
 | |
|         fetch_data(full_path(), m_parent == nullptr || m_parent->m_parent_of_root);
 | |
|     traverse_if_needed();
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::Node::is_symlink_to_directory() const
 | |
| {
 | |
|     if (!S_ISLNK(mode))
 | |
|         return false;
 | |
|     struct stat st;
 | |
|     if (lstat(symlink_target.characters(), &st) < 0)
 | |
|         return false;
 | |
|     return S_ISDIR(st.st_mode);
 | |
| }
 | |
| 
 | |
| DeprecatedString FileSystemModel::Node::full_path() const
 | |
| {
 | |
|     Vector<DeprecatedString, 32> lineage;
 | |
|     for (auto* ancestor = m_parent; ancestor; ancestor = ancestor->m_parent) {
 | |
|         lineage.append(ancestor->name);
 | |
|     }
 | |
|     StringBuilder builder;
 | |
|     builder.append(m_model.root_path());
 | |
|     for (int i = lineage.size() - 1; i >= 0; --i) {
 | |
|         builder.append('/');
 | |
|         builder.append(lineage[i]);
 | |
|     }
 | |
|     builder.append('/');
 | |
|     builder.append(name);
 | |
|     return LexicalPath::canonicalized_path(builder.to_deprecated_string());
 | |
| }
 | |
| 
 | |
| ModelIndex FileSystemModel::index(DeprecatedString path, int column) const
 | |
| {
 | |
|     auto node = node_for_path(move(path));
 | |
|     if (node.has_value())
 | |
|         return node->index(column);
 | |
| 
 | |
|     return {};
 | |
| }
 | |
| 
 | |
| Optional<FileSystemModel::Node const&> FileSystemModel::node_for_path(DeprecatedString const& path) const
 | |
| {
 | |
|     DeprecatedString resolved_path;
 | |
|     if (path == m_root_path)
 | |
|         resolved_path = "/";
 | |
|     else if (m_root_path.has_value() && !m_root_path->is_empty() && path.starts_with(*m_root_path))
 | |
|         resolved_path = LexicalPath::relative_path(path, *m_root_path);
 | |
|     else
 | |
|         resolved_path = path;
 | |
|     LexicalPath lexical_path(resolved_path);
 | |
| 
 | |
|     Node const* node = m_root->m_parent_of_root ? m_root->m_children.first() : m_root.ptr();
 | |
|     if (lexical_path.string() == "/")
 | |
|         return *node;
 | |
| 
 | |
|     auto& parts = lexical_path.parts_view();
 | |
|     for (size_t i = 0; i < parts.size(); ++i) {
 | |
|         auto& part = parts[i];
 | |
|         bool found = false;
 | |
|         for (auto& child : node->m_children) {
 | |
|             if (child->name == part) {
 | |
|                 const_cast<Node&>(*child).reify_if_needed();
 | |
|                 node = child;
 | |
|                 found = true;
 | |
|                 if (i == parts.size() - 1)
 | |
|                     return *node;
 | |
|                 break;
 | |
|             }
 | |
|         }
 | |
|         if (!found)
 | |
|             return {};
 | |
|     }
 | |
|     return {};
 | |
| }
 | |
| 
 | |
| DeprecatedString FileSystemModel::full_path(ModelIndex const& index) const
 | |
| {
 | |
|     auto& node = this->node(index);
 | |
|     const_cast<Node&>(node).reify_if_needed();
 | |
|     return node.full_path();
 | |
| }
 | |
| 
 | |
| FileSystemModel::FileSystemModel(Optional<DeprecatedString> root_path, Mode mode)
 | |
|     : m_root_path(root_path.map(LexicalPath::canonicalized_path))
 | |
|     , m_mode(mode)
 | |
| {
 | |
|     setpwent();
 | |
|     while (auto* passwd = getpwent())
 | |
|         m_user_names.set(passwd->pw_uid, passwd->pw_name);
 | |
|     endpwent();
 | |
| 
 | |
|     setgrent();
 | |
|     while (auto* group = getgrent())
 | |
|         m_group_names.set(group->gr_gid, group->gr_name);
 | |
|     endgrent();
 | |
| 
 | |
|     auto result = Core::FileWatcher::create();
 | |
|     if (result.is_error()) {
 | |
|         dbgln("{}", result.error());
 | |
|         VERIFY_NOT_REACHED();
 | |
|     }
 | |
| 
 | |
|     m_file_watcher = result.release_value();
 | |
|     m_file_watcher->on_change = [this](Core::FileWatcherEvent const& event) {
 | |
|         handle_file_event(event);
 | |
|     };
 | |
| 
 | |
|     invalidate();
 | |
| }
 | |
| 
 | |
| DeprecatedString FileSystemModel::name_for_uid(uid_t uid) const
 | |
| {
 | |
|     auto it = m_user_names.find(uid);
 | |
|     if (it == m_user_names.end())
 | |
|         return DeprecatedString::number(uid);
 | |
|     return (*it).value;
 | |
| }
 | |
| 
 | |
| DeprecatedString FileSystemModel::name_for_gid(gid_t gid) const
 | |
| {
 | |
|     auto it = m_group_names.find(gid);
 | |
|     if (it == m_group_names.end())
 | |
|         return DeprecatedString::number(gid);
 | |
|     return (*it).value;
 | |
| }
 | |
| 
 | |
| static DeprecatedString permission_string(mode_t mode)
 | |
| {
 | |
|     StringBuilder builder;
 | |
|     if (S_ISDIR(mode))
 | |
|         builder.append('d');
 | |
|     else if (S_ISLNK(mode))
 | |
|         builder.append('l');
 | |
|     else if (S_ISBLK(mode))
 | |
|         builder.append('b');
 | |
|     else if (S_ISCHR(mode))
 | |
|         builder.append('c');
 | |
|     else if (S_ISFIFO(mode))
 | |
|         builder.append('f');
 | |
|     else if (S_ISSOCK(mode))
 | |
|         builder.append('s');
 | |
|     else if (S_ISREG(mode))
 | |
|         builder.append('-');
 | |
|     else
 | |
|         builder.append('?');
 | |
| 
 | |
|     builder.append(mode & S_IRUSR ? 'r' : '-');
 | |
|     builder.append(mode & S_IWUSR ? 'w' : '-');
 | |
|     builder.append(mode & S_ISUID ? 's' : (mode & S_IXUSR ? 'x' : '-'));
 | |
|     builder.append(mode & S_IRGRP ? 'r' : '-');
 | |
|     builder.append(mode & S_IWGRP ? 'w' : '-');
 | |
|     builder.append(mode & S_ISGID ? 's' : (mode & S_IXGRP ? 'x' : '-'));
 | |
|     builder.append(mode & S_IROTH ? 'r' : '-');
 | |
|     builder.append(mode & S_IWOTH ? 'w' : '-');
 | |
| 
 | |
|     if (mode & S_ISVTX)
 | |
|         builder.append('t');
 | |
|     else
 | |
|         builder.append(mode & S_IXOTH ? 'x' : '-');
 | |
|     return builder.to_deprecated_string();
 | |
| }
 | |
| 
 | |
| void FileSystemModel::Node::set_selected(bool selected)
 | |
| {
 | |
|     if (m_selected == selected)
 | |
|         return;
 | |
|     m_selected = selected;
 | |
| }
 | |
| 
 | |
| void FileSystemModel::update_node_on_selection(ModelIndex const& index, bool const selected)
 | |
| {
 | |
|     Node& node = const_cast<Node&>(this->node(index));
 | |
|     node.set_selected(selected);
 | |
| }
 | |
| 
 | |
| void FileSystemModel::set_root_path(Optional<DeprecatedString> root_path)
 | |
| {
 | |
|     if (!root_path.has_value())
 | |
|         m_root_path = {};
 | |
|     else
 | |
|         m_root_path = LexicalPath::canonicalized_path(move(*root_path));
 | |
|     invalidate();
 | |
| 
 | |
|     if (m_root->has_error()) {
 | |
|         if (on_directory_change_error)
 | |
|             on_directory_change_error(m_root->error(), m_root->error_string());
 | |
|     } else if (on_complete) {
 | |
|         on_complete();
 | |
|     }
 | |
| }
 | |
| 
 | |
| void FileSystemModel::invalidate()
 | |
| {
 | |
|     m_root = adopt_own(*new Node(*this));
 | |
| 
 | |
|     if (!m_root_path.has_value())
 | |
|         m_root->m_parent_of_root = true;
 | |
| 
 | |
|     m_root->reify_if_needed();
 | |
|     for (auto const& child : m_root->m_children)
 | |
|         child->reify_if_needed();
 | |
| 
 | |
|     Model::invalidate();
 | |
| }
 | |
| 
 | |
| void FileSystemModel::handle_file_event(Core::FileWatcherEvent const& event)
 | |
| {
 | |
|     if (event.type == Core::FileWatcherEvent::Type::ChildCreated) {
 | |
|         if (node_for_path(event.event_path).has_value())
 | |
|             return;
 | |
|     } else {
 | |
|         if (!node_for_path(event.event_path).has_value())
 | |
|             return;
 | |
|     }
 | |
| 
 | |
|     switch (event.type) {
 | |
|     case Core::FileWatcherEvent::Type::ChildCreated: {
 | |
|         LexicalPath path { event.event_path };
 | |
|         auto& parts = path.parts_view();
 | |
|         StringView child_name = parts.last();
 | |
|         if (!m_should_show_dotfiles && child_name.starts_with('.'))
 | |
|             break;
 | |
| 
 | |
|         auto parent_name = path.parent().string();
 | |
|         auto parent = node_for_path(parent_name);
 | |
|         if (!parent.has_value()) {
 | |
|             dbgln("Got a ChildCreated on '{}' but that path does not exist?!", parent_name);
 | |
|             break;
 | |
|         }
 | |
| 
 | |
|         auto& mutable_parent = const_cast<Node&>(*parent);
 | |
|         auto maybe_child = mutable_parent.create_child(child_name);
 | |
|         if (!maybe_child)
 | |
|             break;
 | |
| 
 | |
|         auto child = maybe_child.release_nonnull();
 | |
|         child->reify_if_needed();
 | |
| 
 | |
|         bool const is_new_child_dir = S_ISDIR(child->mode);
 | |
|         int insert_index = 0;
 | |
|         for (auto const& other_child : mutable_parent.m_children) {
 | |
|             bool const is_other_child_dir = S_ISDIR(other_child->mode);
 | |
|             if (!is_new_child_dir && is_other_child_dir) {
 | |
|                 ++insert_index;
 | |
|                 continue;
 | |
|             }
 | |
|             if (is_new_child_dir && !is_other_child_dir)
 | |
|                 break;
 | |
| 
 | |
|             if (other_child->name.view() > child_name)
 | |
|                 break;
 | |
|             ++insert_index;
 | |
|         }
 | |
| 
 | |
|         begin_insert_rows(parent->index(0), insert_index, insert_index);
 | |
| 
 | |
|         mutable_parent.total_size += child->size;
 | |
|         mutable_parent.m_children.insert(insert_index, move(child));
 | |
| 
 | |
|         end_insert_rows();
 | |
|         break;
 | |
|     }
 | |
|     case Core::FileWatcherEvent::Type::Deleted:
 | |
|     case Core::FileWatcherEvent::Type::ChildDeleted: {
 | |
|         auto child = node_for_path(event.event_path);
 | |
|         if (!child.has_value()) {
 | |
|             dbgln("Got a ChildDeleted/Deleted on '{}' but the child does not exist?! (already gone?)", event.event_path);
 | |
|             break;
 | |
|         }
 | |
| 
 | |
|         if (&child.value() == m_root) {
 | |
|             // Root directory of the filesystem model has been removed. All items became invalid.
 | |
|             invalidate();
 | |
|             on_root_path_removed();
 | |
|             break;
 | |
|         }
 | |
| 
 | |
|         auto index = child->index(0);
 | |
|         begin_delete_rows(index.parent(), index.row(), index.row());
 | |
| 
 | |
|         Node* parent = child->m_parent;
 | |
|         parent->m_children.remove(index.row());
 | |
| 
 | |
|         end_delete_rows();
 | |
| 
 | |
|         for_each_view([&](AbstractView& view) {
 | |
|             view.selection().remove_all_matching([&](auto& selection_index) {
 | |
|                 return selection_index.internal_data() == index.internal_data();
 | |
|             });
 | |
|             if (view.cursor_index().internal_data() == index.internal_data()) {
 | |
|                 view.set_cursor({}, GUI::AbstractView::SelectionUpdate::None);
 | |
|             }
 | |
|         });
 | |
| 
 | |
|         break;
 | |
|     }
 | |
|     case Core::FileWatcherEvent::Type::MetadataModified: {
 | |
|         auto child = node_for_path(event.event_path);
 | |
|         if (!child.has_value()) {
 | |
|             dbgln("Got a MetadataModified on '{}' but the child does not exist?!", event.event_path);
 | |
|             break;
 | |
|         }
 | |
| 
 | |
|         auto& mutable_child = const_cast<Node&>(child.value());
 | |
|         mutable_child.fetch_data(mutable_child.full_path(), &mutable_child == m_root);
 | |
|         break;
 | |
|     }
 | |
|     default:
 | |
|         VERIFY_NOT_REACHED();
 | |
|     }
 | |
| 
 | |
|     did_update(UpdateFlag::DontInvalidateIndices);
 | |
| }
 | |
| 
 | |
| int FileSystemModel::row_count(ModelIndex const& index) const
 | |
| {
 | |
|     Node& node = const_cast<Node&>(this->node(index));
 | |
|     node.reify_if_needed();
 | |
|     if (node.is_directory())
 | |
|         return node.m_children.size();
 | |
|     return 0;
 | |
| }
 | |
| 
 | |
| FileSystemModel::Node const& FileSystemModel::node(ModelIndex const& index) const
 | |
| {
 | |
|     if (!index.is_valid())
 | |
|         return *m_root;
 | |
|     VERIFY(index.internal_data());
 | |
|     return *(Node*)index.internal_data();
 | |
| }
 | |
| 
 | |
| ModelIndex FileSystemModel::index(int row, int column, ModelIndex const& parent) const
 | |
| {
 | |
|     if (row < 0 || column < 0)
 | |
|         return {};
 | |
|     auto& node = this->node(parent);
 | |
|     const_cast<Node&>(node).reify_if_needed();
 | |
|     if (static_cast<size_t>(row) >= node.m_children.size())
 | |
|         return {};
 | |
|     return create_index(row, column, node.m_children[row].ptr());
 | |
| }
 | |
| 
 | |
| ModelIndex FileSystemModel::parent_index(ModelIndex const& index) const
 | |
| {
 | |
|     if (!index.is_valid())
 | |
|         return {};
 | |
|     auto& node = this->node(index);
 | |
|     if (!node.m_parent) {
 | |
|         VERIFY(&node == m_root);
 | |
|         return {};
 | |
|     }
 | |
|     return node.m_parent->index(index.column());
 | |
| }
 | |
| 
 | |
| Variant FileSystemModel::data(ModelIndex const& index, ModelRole role) const
 | |
| {
 | |
|     VERIFY(index.is_valid());
 | |
| 
 | |
|     if (role == ModelRole::TextAlignment) {
 | |
|         switch (index.column()) {
 | |
|         case Column::Icon:
 | |
|             return Gfx::TextAlignment::Center;
 | |
|         case Column::Size:
 | |
|         case Column::Inode:
 | |
|             return Gfx::TextAlignment::CenterRight;
 | |
|         case Column::Name:
 | |
|         case Column::User:
 | |
|         case Column::Group:
 | |
|         case Column::ModificationTime:
 | |
|         case Column::Permissions:
 | |
|         case Column::SymlinkTarget:
 | |
|             return Gfx::TextAlignment::CenterLeft;
 | |
|         default:
 | |
|             VERIFY_NOT_REACHED();
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     auto& node = this->node(index);
 | |
| 
 | |
|     if (role == ModelRole::Custom) {
 | |
|         // For GUI::FileSystemModel, custom role means the full path.
 | |
|         VERIFY(index.column() == Column::Name);
 | |
|         return node.full_path();
 | |
|     }
 | |
| 
 | |
|     if (role == ModelRole::MimeData) {
 | |
|         if (index.column() == Column::Name)
 | |
|             return URL::create_with_file_scheme(node.full_path()).serialize();
 | |
|         return {};
 | |
|     }
 | |
| 
 | |
|     if (role == ModelRole::Sort) {
 | |
|         switch (index.column()) {
 | |
|         case Column::Icon:
 | |
|             return node.is_directory() ? 0 : 1;
 | |
|         case Column::Name:
 | |
|             // NOTE: The children of a Node are grouped by directory-or-file and then sorted alphabetically.
 | |
|             //       Hence, the sort value for the name column is simply the index row. :^)
 | |
|             return index.row();
 | |
|         case Column::Size:
 | |
|             return (int)node.size;
 | |
|         case Column::User:
 | |
|             return name_for_uid(node.uid);
 | |
|         case Column::Group:
 | |
|             return name_for_gid(node.gid);
 | |
|         case Column::Permissions:
 | |
|             return permission_string(node.mode);
 | |
|         case Column::ModificationTime:
 | |
|             return node.mtime;
 | |
|         case Column::Inode:
 | |
|             return (int)node.inode;
 | |
|         case Column::SymlinkTarget:
 | |
|             return node.symlink_target;
 | |
|         }
 | |
|         VERIFY_NOT_REACHED();
 | |
|     }
 | |
| 
 | |
|     if (role == ModelRole::Display) {
 | |
|         switch (index.column()) {
 | |
|         case Column::Icon:
 | |
|             return icon_for(node);
 | |
|         case Column::Name:
 | |
|             return node.name;
 | |
|         case Column::Size:
 | |
|             return human_readable_size(node.size);
 | |
|         case Column::User:
 | |
|             return name_for_uid(node.uid);
 | |
|         case Column::Group:
 | |
|             return name_for_gid(node.gid);
 | |
|         case Column::Permissions:
 | |
|             return permission_string(node.mode);
 | |
|         case Column::ModificationTime:
 | |
|             return timestamp_string(node.mtime);
 | |
|         case Column::Inode:
 | |
|             return (int)node.inode;
 | |
|         case Column::SymlinkTarget:
 | |
|             return node.symlink_target;
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     if (role == ModelRole::Icon) {
 | |
|         return icon_for(node);
 | |
|     }
 | |
| 
 | |
|     if (role == ModelRole::IconOpacity) {
 | |
|         if (node.name.starts_with('.'))
 | |
|             return 0.5f;
 | |
|         return {};
 | |
|     }
 | |
| 
 | |
|     return {};
 | |
| }
 | |
| 
 | |
| Icon FileSystemModel::icon_for(Node const& node) const
 | |
| {
 | |
|     if (node.full_path() == "/")
 | |
|         return FileIconProvider::icon_for_path("/"sv);
 | |
| 
 | |
|     if (Gfx::Bitmap::is_path_a_supported_image_format(node.name)) {
 | |
|         if (!node.thumbnail) {
 | |
|             if (!const_cast<FileSystemModel*>(this)->fetch_thumbnail_for(node))
 | |
|                 return FileIconProvider::filetype_image_icon();
 | |
|         }
 | |
|         return GUI::Icon(FileIconProvider::filetype_image_icon().bitmap_for_size(16), *node.thumbnail);
 | |
|     }
 | |
| 
 | |
|     if (node.is_directory()) {
 | |
|         if (node.full_path() == Core::StandardPaths::home_directory()) {
 | |
|             if (node.is_selected())
 | |
|                 return FileIconProvider::home_directory_open_icon();
 | |
|             return FileIconProvider::home_directory_icon();
 | |
|         }
 | |
|         if (node.full_path().ends_with(".git"sv)) {
 | |
|             if (node.is_selected())
 | |
|                 return FileIconProvider::git_directory_open_icon();
 | |
|             return FileIconProvider::git_directory_icon();
 | |
|         }
 | |
|         if (node.full_path() == Core::StandardPaths::desktop_directory())
 | |
|             return FileIconProvider::desktop_directory_icon();
 | |
|         if (node.is_selected() && node.is_accessible_directory)
 | |
|             return FileIconProvider::directory_open_icon();
 | |
|     }
 | |
| 
 | |
|     return FileIconProvider::icon_for_path(node.full_path(), node.mode);
 | |
| }
 | |
| 
 | |
| using BitmapBackgroundAction = Threading::BackgroundAction<NonnullRefPtr<Gfx::Bitmap>>;
 | |
| 
 | |
| // Mutex protected thumbnail cache data shared between threads.
 | |
| struct ThumbnailCache {
 | |
|     // Null pointers indicate an image that couldn't be loaded due to errors.
 | |
|     HashMap<DeprecatedString, RefPtr<Gfx::Bitmap>> thumbnail_cache {};
 | |
|     HashMap<DeprecatedString, NonnullRefPtr<BitmapBackgroundAction>> loading_thumbnails {};
 | |
| };
 | |
| 
 | |
| static Threading::MutexProtected<ThumbnailCache> s_thumbnail_cache {};
 | |
| 
 | |
| static ErrorOr<NonnullRefPtr<Gfx::Bitmap>> render_thumbnail(StringView path)
 | |
| {
 | |
|     Gfx::IntSize thumbnail_size { 32, 32 };
 | |
|     auto bitmap = TRY(Gfx::Bitmap::load_from_file(path, 1, thumbnail_size));
 | |
|     auto thumbnail = TRY(Gfx::Bitmap::create(Gfx::BitmapFormat::BGRA8888, thumbnail_size));
 | |
| 
 | |
|     double scale = min(thumbnail_size.width() / (double)bitmap->width(), thumbnail_size.height() / (double)bitmap->height());
 | |
|     auto destination = Gfx::IntRect(0, 0, (int)(bitmap->width() * scale), (int)(bitmap->height() * scale)).centered_within(thumbnail->rect());
 | |
| 
 | |
|     Painter painter(thumbnail);
 | |
|     painter.draw_scaled_bitmap(destination, *bitmap, bitmap->rect());
 | |
|     return thumbnail;
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::fetch_thumbnail_for(Node const& node)
 | |
| {
 | |
|     auto path = node.full_path();
 | |
| 
 | |
|     // See if we already have the thumbnail we're looking for in the cache.
 | |
|     auto was_in_cache = s_thumbnail_cache.with_locked([&](auto& cache) {
 | |
|         auto it = cache.thumbnail_cache.find(path);
 | |
|         if (it != cache.thumbnail_cache.end()) {
 | |
|             // Loading was unsuccessful.
 | |
|             if (!(*it).value)
 | |
|                 return TriState::False;
 | |
|             // Loading was successful.
 | |
|             node.thumbnail = (*it).value;
 | |
|             return TriState::True;
 | |
|         }
 | |
|         // Loading is in progress.
 | |
|         if (cache.loading_thumbnails.contains(path))
 | |
|             return TriState::False;
 | |
|         return TriState::Unknown;
 | |
|     });
 | |
|     if (was_in_cache != TriState::Unknown)
 | |
|         return was_in_cache == TriState::True;
 | |
| 
 | |
|     // Otherwise, arrange to render the thumbnail in background and make it available later.
 | |
| 
 | |
|     m_thumbnail_progress_total++;
 | |
| 
 | |
|     auto weak_this = make_weak_ptr();
 | |
| 
 | |
|     auto const action = [path](auto&) {
 | |
|         return render_thumbnail(path);
 | |
|     };
 | |
|     auto const update_progress = [weak_this](bool with_success) {
 | |
|         using namespace AK::TimeLiterals;
 | |
|         if (auto strong_this = weak_this.strong_ref(); !strong_this.is_null()) {
 | |
|             strong_this->m_thumbnail_progress++;
 | |
|             if (strong_this->on_thumbnail_progress)
 | |
|                 strong_this->on_thumbnail_progress(strong_this->m_thumbnail_progress, strong_this->m_thumbnail_progress_total);
 | |
|             if (strong_this->m_thumbnail_progress == strong_this->m_thumbnail_progress_total) {
 | |
|                 strong_this->m_thumbnail_progress = 0;
 | |
|                 strong_this->m_thumbnail_progress_total = 0;
 | |
|             }
 | |
| 
 | |
|             if (with_success && (!strong_this->m_ui_update_timer.is_valid() || strong_this->m_ui_update_timer.elapsed_time() > 100_ms)) {
 | |
|                 strong_this->did_update(UpdateFlag::DontInvalidateIndices);
 | |
|                 strong_this->m_ui_update_timer.start();
 | |
|             }
 | |
|         }
 | |
|     };
 | |
| 
 | |
|     auto const on_complete = [weak_this, path, update_progress](auto thumbnail) -> ErrorOr<void> {
 | |
|         auto finished_generating_thumbnails = false;
 | |
|         s_thumbnail_cache.with_locked([path, thumbnail, &finished_generating_thumbnails](auto& cache) {
 | |
|             cache.thumbnail_cache.set(path, thumbnail);
 | |
|             cache.loading_thumbnails.remove(path);
 | |
|             finished_generating_thumbnails = cache.loading_thumbnails.is_empty();
 | |
|         });
 | |
| 
 | |
|         if (auto strong_this = weak_this.strong_ref(); finished_generating_thumbnails && !strong_this.is_null())
 | |
|             strong_this->m_ui_update_timer.reset();
 | |
| 
 | |
|         update_progress(true);
 | |
| 
 | |
|         return {};
 | |
|     };
 | |
| 
 | |
|     auto const on_error = [path, update_progress](Error error) -> void {
 | |
|         // Note: We need to defer that to avoid the function removing its last reference
 | |
|         //       i.e. trying to destroy itself, which is prohibited.
 | |
|         Core::EventLoop::current().deferred_invoke([path, error = Error::copy(error)]() mutable {
 | |
|             s_thumbnail_cache.with_locked([path, error = move(error)](auto& cache) {
 | |
|                 if (error != Error::from_errno(ECANCELED)) {
 | |
|                     cache.thumbnail_cache.set(path, nullptr);
 | |
|                     dbgln("Failed to load thumbnail for {}: {}", path, error);
 | |
|                 }
 | |
|                 cache.loading_thumbnails.remove(path);
 | |
|             });
 | |
|         });
 | |
| 
 | |
|         update_progress(false);
 | |
|     };
 | |
| 
 | |
|     s_thumbnail_cache.with_locked([path, action, on_complete, on_error](auto& cache) {
 | |
|         cache.loading_thumbnails.set(path, BitmapBackgroundAction::construct(move(action), move(on_complete), move(on_error)));
 | |
|     });
 | |
| 
 | |
|     return false;
 | |
| }
 | |
| 
 | |
| int FileSystemModel::column_count(ModelIndex const&) const
 | |
| {
 | |
|     return Column::__Count;
 | |
| }
 | |
| 
 | |
| ErrorOr<String> FileSystemModel::column_name(int column) const
 | |
| {
 | |
|     switch (column) {
 | |
|     case Column::Icon:
 | |
|         return String {};
 | |
|     case Column::Name:
 | |
|         return "Name"_string;
 | |
|     case Column::Size:
 | |
|         return "Size"_string;
 | |
|     case Column::User:
 | |
|         return "User"_string;
 | |
|     case Column::Group:
 | |
|         return "Group"_string;
 | |
|     case Column::Permissions:
 | |
|         return "Mode"_string;
 | |
|     case Column::ModificationTime:
 | |
|         return "Modified"_string;
 | |
|     case Column::Inode:
 | |
|         return "Inode"_string;
 | |
|     case Column::SymlinkTarget:
 | |
|         return "Symlink target"_string;
 | |
|     }
 | |
|     VERIFY_NOT_REACHED();
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::accepts_drag(ModelIndex const& index, Vector<String> const& mime_types) const
 | |
| {
 | |
|     if (!mime_types.contains_slow("text/uri-list"sv))
 | |
|         return false;
 | |
| 
 | |
|     if (!index.is_valid())
 | |
|         return true;
 | |
| 
 | |
|     auto& node = this->node(index);
 | |
|     return node.is_directory();
 | |
| }
 | |
| 
 | |
| void FileSystemModel::set_should_show_dotfiles(bool show)
 | |
| {
 | |
|     if (m_should_show_dotfiles == show)
 | |
|         return;
 | |
|     m_should_show_dotfiles = show;
 | |
| 
 | |
|     // FIXME: add a way to granularly update in this case.
 | |
|     invalidate();
 | |
| }
 | |
| 
 | |
| void FileSystemModel::set_allowed_file_extensions(Optional<Vector<DeprecatedString>> const& allowed_file_extensions)
 | |
| {
 | |
|     if (m_allowed_file_extensions == allowed_file_extensions)
 | |
|         return;
 | |
|     m_allowed_file_extensions = allowed_file_extensions;
 | |
| 
 | |
|     invalidate();
 | |
| }
 | |
| 
 | |
| bool FileSystemModel::is_editable(ModelIndex const& index) const
 | |
| {
 | |
|     if (!index.is_valid())
 | |
|         return false;
 | |
|     return index.column() == Column::Name;
 | |
| }
 | |
| 
 | |
| void FileSystemModel::set_data(ModelIndex const& index, Variant const& data)
 | |
| {
 | |
|     VERIFY(is_editable(index));
 | |
|     Node& node = const_cast<Node&>(this->node(index));
 | |
|     auto dirname = LexicalPath::dirname(node.full_path());
 | |
|     auto new_full_path = DeprecatedString::formatted("{}/{}", dirname, data.to_deprecated_string());
 | |
|     int rc = rename(node.full_path().characters(), new_full_path.characters());
 | |
|     if (rc < 0) {
 | |
|         if (on_rename_error)
 | |
|             on_rename_error(errno, strerror(errno));
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     if (on_rename_successful)
 | |
|         on_rename_successful(node.full_path(), new_full_path);
 | |
| }
 | |
| 
 | |
| Vector<ModelIndex> FileSystemModel::matches(StringView searching, unsigned flags, ModelIndex const& index)
 | |
| {
 | |
|     Node& node = const_cast<Node&>(this->node(index));
 | |
|     node.reify_if_needed();
 | |
|     Vector<ModelIndex> found_indices;
 | |
|     for (auto& child : node.m_children) {
 | |
|         if (string_matches(child->name, searching, flags)) {
 | |
|             const_cast<Node&>(*child).reify_if_needed();
 | |
|             found_indices.append(child->index(Column::Name));
 | |
|             if (flags & FirstMatchOnly)
 | |
|                 break;
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     return found_indices;
 | |
| }
 | |
| 
 | |
| }
 |