#include "remote.hh" #include "buffer_manager.hh" #include "buffer_utils.hh" #include "client_manager.hh" #include "command_manager.hh" #include "display_buffer.hh" #include "event_manager.hh" #include "file.hh" #include "hash_map.hh" #include "optional.hh" #include "user_interface.hh" #include #include #include #include #include #include #include namespace Kakoune { enum class MessageType : uint8_t { Unknown, Connect, Command, MenuShow, MenuSelect, MenuHide, InfoShow, InfoHide, Draw, DrawStatus, SetCursor, Refresh, SetOptions, Exit, Key, }; class MsgWriter { public: MsgWriter(RemoteBuffer& buffer, MessageType type) : m_buffer{buffer}, m_start{(uint32_t)buffer.size()} { write(type); write((uint32_t)0); // message size, to be patched on write } ~MsgWriter() noexcept(false) { uint32_t count = (uint32_t)m_buffer.size() - m_start; memcpy(m_buffer.data() + m_start + sizeof(MessageType), &count, sizeof(uint32_t)); } void write(const char* val, size_t size) { m_buffer.insert(m_buffer.end(), val, val + size); } template void write(const T& val) { write((const char*)&val, sizeof(val)); } void write(StringView str) { write(str.length()); write(str.data(), (int)str.length()); }; void write(const String& str) { write(StringView{str}); } template void write(ConstArrayView view) { write(view.size()); for (auto& val : view) write(val); } template void write(const Vector& vec) { write(ConstArrayView(vec)); } template void write(const HashMap& map) { write(map.size()); for (auto& val : map) { write(val.key); write(val.value); } } template void write(const Optional& val) { write((bool)val); if (val) write(*val); } void write(Color color) { write(color.color); if (color.color == Color::RGB) { write(color.r); write(color.g); write(color.b); } } void write(const DisplayAtom& atom) { write(atom.content()); write(atom.face); } void write(const DisplayLine& line) { write(line.atoms()); } void write(const DisplayBuffer& display_buffer) { write(display_buffer.lines()); } private: RemoteBuffer& m_buffer; uint32_t m_start; }; class MsgReader { public: void read_available(int sock) { if (m_write_pos < header_size) { m_stream.resize(header_size); read_from_socket(sock, header_size - m_write_pos); if (m_write_pos == header_size) { if (size() < header_size) throw disconnected{"invalid message received"}; m_stream.resize(size()); } } else read_from_socket(sock, size() - m_write_pos); } bool ready() const { return m_write_pos >= header_size and m_write_pos == size(); } uint32_t size() const { kak_assert(m_write_pos >= header_size); uint32_t res; memcpy(&res, m_stream.data() + sizeof(MessageType), sizeof(uint32_t)); return res; } MessageType type() const { kak_assert(m_write_pos >= header_size); return *reinterpret_cast(m_stream.data()); } void read(char* buffer, size_t size) { if (m_read_pos + size > m_stream.size()) throw disconnected{"tried to read after message end"}; memcpy(buffer, m_stream.data() + m_read_pos, size); m_read_pos += size; } template T read() { union U { T object; alignas(T) char data[sizeof(T)]; U() {} ~U() { object.~T(); } } u; read(u.data, sizeof(T)); return u.object; } template Vector read_vector() { uint32_t size = read(); Vector res; res.reserve(size); while (size--) res.push_back(read()); return res; } template HashMap read_hash_map() { uint32_t size = read(); HashMap res; res.reserve(size); while (size--) { auto key = read(); auto val = read(); res.insert({std::move(key), std::move(val)}); } return res; } template Optional read_optional() { if (not read()) return {}; return read(); } void reset() { m_stream.resize(0); m_write_pos = 0; m_read_pos = header_size; } private: void read_from_socket(int sock, size_t size) { kak_assert(m_write_pos + size <= m_stream.size()); int res = ::read(sock, m_stream.data() + m_write_pos, size); if (res <= 0) throw disconnected{format("socket read failed: {}", strerror(errno))}; m_write_pos += res; } static constexpr uint32_t header_size = sizeof(MessageType) + sizeof(uint32_t); Vector m_stream; uint32_t m_write_pos = 0; uint32_t m_read_pos = header_size; }; template<> String MsgReader::read() { ByteCount length = read(); String res; if (length > 0) { res.force_size((int)length); read(&res[0_byte], (int)length); } return res; } template<> Color MsgReader::read() { Color res; res.color = read(); if (res.color == Color::RGB) { res.r = read(); res.g = read(); res.b = read(); } return res; } template<> DisplayAtom MsgReader::read() { DisplayAtom atom(read()); atom.face = read(); return atom; } template<> DisplayLine MsgReader::read() { return DisplayLine(read_vector()); } template<> DisplayBuffer MsgReader::read() { DisplayBuffer db; db.lines() = read_vector(); return db; } class RemoteUI : public UserInterface { public: RemoteUI(int socket, DisplayCoord dimensions); ~RemoteUI() override; void menu_show(ConstArrayView choices, DisplayCoord anchor, Face fg, Face bg, MenuStyle style) override; void menu_select(int selected) override; void menu_hide() override; void info_show(StringView title, StringView content, DisplayCoord anchor, Face face, InfoStyle style) override; void info_hide() override; void draw(const DisplayBuffer& display_buffer, const Face& default_face, const Face& padding_face) override; void draw_status(const DisplayLine& status_line, const DisplayLine& mode_line, const Face& default_face) override; void set_cursor(CursorMode mode, DisplayCoord coord) override; void refresh(bool force) override; DisplayCoord dimensions() override { return m_dimensions; } void set_on_key(OnKeyCallback callback) override { m_on_key = std::move(callback); } void set_ui_options(const Options& options) override; void set_client(Client* client) { m_client = client; } Client* client() const { return m_client.get(); } void exit(int status); private: FDWatcher m_socket_watcher; MsgReader m_reader; DisplayCoord m_dimensions; OnKeyCallback m_on_key; RemoteBuffer m_send_buffer; SafePtr m_client; }; static bool send_data(int fd, RemoteBuffer& buffer) { while (not buffer.empty() and fd_writable(fd)) { int res = ::write(fd, buffer.data(), buffer.size()); if (res <= 0) throw disconnected{format("socket write failed: {}", strerror(errno))}; buffer.erase(buffer.begin(), buffer.begin() + res); } return buffer.empty(); } RemoteUI::RemoteUI(int socket, DisplayCoord dimensions) : m_socket_watcher(socket, FdEvents::Read | FdEvents::Write, [this](FDWatcher& watcher, FdEvents events, EventMode mode) { const int sock = watcher.fd(); try { if (events & FdEvents::Write and send_data(sock, m_send_buffer)) m_socket_watcher.events() &= ~FdEvents::Write; while (events & FdEvents::Read and fd_readable(sock)) { m_reader.read_available(sock); if (not m_reader.ready()) continue; if (m_reader.type() != MessageType::Key) { ClientManager::instance().remove_client(*m_client, false, -1); return; } auto key = m_reader.read(); m_reader.reset(); if (key.modifiers == Key::Modifiers::Resize) m_dimensions = key.coord(); m_on_key(key); } } catch (const disconnected& err) { write_to_debug_buffer(format("Error while transfering remote messages: {}", err.what())); ClientManager::instance().remove_client(*m_client, false, -1); } }), m_dimensions(dimensions) { write_to_debug_buffer(format("remote client connected: {}", m_socket_watcher.fd())); } RemoteUI::~RemoteUI() { // Try to send the remaining data if possible, as it might contain the desired exit status try { send_data(m_socket_watcher.fd(), m_send_buffer); } catch (disconnected&) { } write_to_debug_buffer(format("remote client disconnected: {}", m_socket_watcher.fd())); m_socket_watcher.close_fd(); } void RemoteUI::menu_show(ConstArrayView choices, DisplayCoord anchor, Face fg, Face bg, MenuStyle style) { MsgWriter msg{m_send_buffer, MessageType::MenuShow}; msg.write(choices); msg.write(anchor); msg.write(fg); msg.write(bg); msg.write(style); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::menu_select(int selected) { MsgWriter msg{m_send_buffer, MessageType::MenuSelect}; msg.write(selected); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::menu_hide() { MsgWriter msg{m_send_buffer, MessageType::MenuHide}; m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::info_show(StringView title, StringView content, DisplayCoord anchor, Face face, InfoStyle style) { MsgWriter msg{m_send_buffer, MessageType::InfoShow}; msg.write(title); msg.write(content); msg.write(anchor); msg.write(face); msg.write(style); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::info_hide() { MsgWriter msg{m_send_buffer, MessageType::InfoHide}; m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::draw(const DisplayBuffer& display_buffer, const Face& default_face, const Face& padding_face) { MsgWriter msg{m_send_buffer, MessageType::Draw}; msg.write(display_buffer); msg.write(default_face); msg.write(padding_face); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::draw_status(const DisplayLine& status_line, const DisplayLine& mode_line, const Face& default_face) { MsgWriter msg{m_send_buffer, MessageType::DrawStatus}; msg.write(status_line); msg.write(mode_line); msg.write(default_face); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::set_cursor(CursorMode mode, DisplayCoord coord) { MsgWriter msg{m_send_buffer, MessageType::SetCursor}; msg.write(mode); msg.write(coord); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::refresh(bool force) { MsgWriter msg{m_send_buffer, MessageType::Refresh}; msg.write(force); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::set_ui_options(const Options& options) { MsgWriter msg{m_send_buffer, MessageType::SetOptions}; msg.write(options); m_socket_watcher.events() |= FdEvents::Write; } void RemoteUI::exit(int status) { MsgWriter msg{m_send_buffer, MessageType::Exit}; msg.write(status); m_socket_watcher.events() |= FdEvents::Write; } static sockaddr_un session_addr(StringView session) { sockaddr_un addr; addr.sun_family = AF_UNIX; auto slash_count = std::count(session.begin(), session.end(), '/'); if (slash_count > 1) throw runtime_error{"Session names are either / or "}; else if (slash_count == 1) format_to(addr.sun_path, "{}/kakoune/{}", tmpdir(), session); else format_to(addr.sun_path, "{}/kakoune/{}/{}", tmpdir(), getpwuid(geteuid())->pw_name, session); return addr; } static int connect_to(StringView session) { int sock = socket(AF_UNIX, SOCK_STREAM, 0); fcntl(sock, F_SETFD, FD_CLOEXEC); sockaddr_un addr = session_addr(session); if (connect(sock, (sockaddr*)&addr, sizeof(addr.sun_path)) == -1) throw disconnected(format("connect to {} failed", addr.sun_path)); return sock; } bool check_session(StringView session) { int sock = socket(AF_UNIX, SOCK_STREAM, 0); auto close_sock = on_scope_end([sock]{ close(sock); }); sockaddr_un addr = session_addr(session); return connect(sock, (sockaddr*)&addr, sizeof(addr.sun_path)) != -1; } RemoteClient::RemoteClient(StringView session, std::unique_ptr&& ui, int pid, const EnvVarMap& env_vars, StringView init_command, Optional init_coord) : m_ui(std::move(ui)) { int sock = connect_to(session); { MsgWriter msg{m_send_buffer, MessageType::Connect}; msg.write(pid); msg.write(init_command); msg.write(init_coord); msg.write(m_ui->dimensions()); msg.write(env_vars); } m_ui->set_on_key([this](Key key){ MsgWriter msg(m_send_buffer, MessageType::Key); msg.write(key); m_socket_watcher->events() |= FdEvents::Write; }); MsgReader reader; m_socket_watcher.reset(new FDWatcher{sock, FdEvents::Read | FdEvents::Write, [this, reader](FDWatcher& watcher, FdEvents events, EventMode) mutable { const int sock = watcher.fd(); if (events & FdEvents::Write and send_data(sock, m_send_buffer)) m_socket_watcher->events() &= ~FdEvents::Write; while (events & FdEvents::Read and not reader.ready() and fd_readable(sock)) { reader.read_available(sock); if (not reader.ready()) continue; auto clear_reader = on_scope_end([&reader] { reader.reset(); }); switch (reader.type()) { case MessageType::MenuShow: { auto choices = reader.read_vector(); auto anchor = reader.read(); auto fg = reader.read(); auto bg = reader.read(); auto style = reader.read(); m_ui->menu_show(choices, anchor, fg, bg, style); break; } case MessageType::MenuSelect: m_ui->menu_select(reader.read()); break; case MessageType::MenuHide: m_ui->menu_hide(); break; case MessageType::InfoShow: { auto title = reader.read(); auto content = reader.read(); auto anchor = reader.read(); auto face = reader.read(); auto style = reader.read(); m_ui->info_show(title, content, anchor, face, style); break; } case MessageType::InfoHide: m_ui->info_hide(); break; case MessageType::Draw: { auto display_buffer = reader.read(); auto default_face = reader.read(); auto padding_face = reader.read(); m_ui->draw(display_buffer, default_face, padding_face); break; } case MessageType::DrawStatus: { auto status_line = reader.read(); auto mode_line = reader.read(); auto default_face = reader.read(); m_ui->draw_status(status_line, mode_line, default_face); break; } case MessageType::SetCursor: { auto mode = reader.read(); auto coord = reader.read(); m_ui->set_cursor(mode, coord); break; } case MessageType::Refresh: m_ui->refresh(reader.read()); break; case MessageType::SetOptions: m_ui->set_ui_options(reader.read_hash_map()); break; case MessageType::Exit: m_exit_status = reader.read(); m_socket_watcher->close_fd(); m_socket_watcher.reset(); return; // This lambda is now dead default: kak_assert(false); } } }}); } void send_command(StringView session, StringView command) { int sock = connect_to(session); auto close_sock = on_scope_end([sock]{ close(sock); }); RemoteBuffer buffer; { MsgWriter msg{buffer, MessageType::Command}; msg.write(command); } write(sock, {buffer.data(), buffer.data() + buffer.size()}); } // A client accepter handle a connection until it closes or a nul byte is // recieved. Everything recieved before is considered to be a command. // // * When a nul byte is recieved, the socket is handed to a new Client along // with the command. // * When the connection is closed, the command is run in an empty context. class Server::Accepter { public: Accepter(int socket) : m_socket_watcher(socket, FdEvents::Read, [this](FDWatcher&, FdEvents, EventMode mode) { if (mode == EventMode::Normal) handle_available_input(); }) {} private: void handle_available_input() { const int sock = m_socket_watcher.fd(); try { while (not m_reader.ready() and fd_readable(sock)) m_reader.read_available(sock); if (not m_reader.ready()) return; switch (m_reader.type()) { case MessageType::Connect: { auto pid = m_reader.read(); auto init_cmds = m_reader.read(); auto init_coord = m_reader.read_optional(); auto dimensions = m_reader.read(); auto env_vars = m_reader.read_hash_map(); auto* ui = new RemoteUI{sock, dimensions}; if (auto* client = ClientManager::instance().create_client( std::unique_ptr(ui), pid, std::move(env_vars), init_cmds, init_coord, [ui](int status) { ui->exit(status); })) ui->set_client(client); Server::instance().remove_accepter(this); break; } case MessageType::Command: { auto command = m_reader.read(); if (not command.empty()) try { Context context{Context::EmptyContextFlag{}}; CommandManager::instance().execute(command, context); } catch (const runtime_error& e) { write_to_debug_buffer(format("error running command '{}': {}", command, e.what())); } close(sock); Server::instance().remove_accepter(this); break; } default: write_to_debug_buffer("Invalid introduction message received"); close(sock); Server::instance().remove_accepter(this); } } catch (const disconnected& err) { write_to_debug_buffer(format("accepting connection failed: {}", err.what())); close(sock); Server::instance().remove_accepter(this); } } FDWatcher m_socket_watcher; MsgReader m_reader; }; Server::Server(String session_name) : m_session{std::move(session_name)} { if (contains(m_session, '/')) throw runtime_error{"Cannot create sessions with '/' in their name"}; int listen_sock = socket(AF_UNIX, SOCK_STREAM, 0); fcntl(listen_sock, F_SETFD, FD_CLOEXEC); sockaddr_un addr = session_addr(m_session); // set sticky bit on the shared kakoune directory make_directory(format("{}/kakoune", tmpdir()), 01777); make_directory(split_path(addr.sun_path).first, 0711); // Do not give any access to the socket to other users by default auto old_mask = umask(0077); auto restore_mask = on_scope_end([old_mask]() { umask(old_mask); }); if (bind(listen_sock, (sockaddr*) &addr, sizeof(sockaddr_un)) == -1) throw runtime_error(format("unable to bind listen socket '{}': {}", addr.sun_path, strerror(errno))); if (listen(listen_sock, 4) == -1) throw runtime_error(format("unable to listen on socket '{}': {}", addr.sun_path, strerror(errno))); auto accepter = [this](FDWatcher& watcher, FdEvents, EventMode mode) { sockaddr_un client_addr; socklen_t client_addr_len = sizeof(sockaddr_un); int sock = accept(watcher.fd(), (sockaddr*) &client_addr, &client_addr_len); if (sock == -1) throw runtime_error("accept failed"); fcntl(sock, F_SETFD, FD_CLOEXEC); m_accepters.emplace_back(new Accepter{sock}); }; m_listener.reset(new FDWatcher{listen_sock, FdEvents::Read, accepter}); } bool Server::rename_session(StringView name) { if (contains(name, '/')) throw runtime_error{"Cannot create sessions with '/' in their name"}; String old_socket_file = format("{}/kakoune/{}/{}", tmpdir(), getpwuid(geteuid())->pw_name, m_session); String new_socket_file = format("{}/kakoune/{}/{}", tmpdir(), getpwuid(geteuid())->pw_name, name); if (rename(old_socket_file.c_str(), new_socket_file.c_str()) != 0) return false; m_session = name.str(); return true; } void Server::close_session(bool do_unlink) { if (do_unlink) { String socket_file = format("{}/kakoune/{}/{}", tmpdir(), getpwuid(geteuid())->pw_name, m_session); unlink(socket_file.c_str()); } m_listener->close_fd(); m_listener.reset(); } Server::~Server() { if (m_listener) close_session(); } void Server::remove_accepter(Accepter* accepter) { auto it = find(m_accepters, accepter); kak_assert(it != m_accepters.end()); m_accepters.erase(it); } }