mirror of
https://github.com/kunkundi/crossdesk.git
synced 2026-08-20 01:55:48 +08:00
Compare commits
6
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e3d15f8f9a | ||
|
|
a6e8038286 | ||
|
|
765452e3c9 | ||
|
|
7cd0d6a351 | ||
|
|
c01b52eac5 | ||
|
|
737cf9b558 |
@@ -1,6 +1,7 @@
|
|||||||
#ifndef CROSSDESK_GUI_APPLICATION_STATE_H_
|
#ifndef CROSSDESK_GUI_APPLICATION_STATE_H_
|
||||||
#define CROSSDESK_GUI_APPLICATION_STATE_H_
|
#define CROSSDESK_GUI_APPLICATION_STATE_H_
|
||||||
|
|
||||||
|
#include <atomic>
|
||||||
#include <chrono>
|
#include <chrono>
|
||||||
#include <cstdint>
|
#include <cstdint>
|
||||||
#include <memory>
|
#include <memory>
|
||||||
@@ -119,8 +120,11 @@ struct StreamWindowState {
|
|||||||
};
|
};
|
||||||
|
|
||||||
struct ServerWindowState {
|
struct ServerWindowState {
|
||||||
bool need_to_create_server_window_ = false;
|
// Transport callbacks run outside the UI thread. Keep the two lifecycle
|
||||||
bool need_to_destroy_server_window_ = false;
|
// requests atomic so a disconnect cannot be lost while the Slint timer is
|
||||||
|
// deciding whether to create or destroy the controlled-side window.
|
||||||
|
std::atomic<bool> need_to_create_server_window_{false};
|
||||||
|
std::atomic<bool> need_to_destroy_server_window_{false};
|
||||||
bool server_window_created_ = false;
|
bool server_window_created_ = false;
|
||||||
bool server_window_inited_ = false;
|
bool server_window_inited_ = false;
|
||||||
int server_window_width_default_ = 250;
|
int server_window_width_default_ = 250;
|
||||||
|
|||||||
@@ -56,7 +56,7 @@ bool HasNonEmptyEnvironmentVariable(const char* name) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
class ScopedUnsetEnvironmentVariable {
|
class ScopedUnsetEnvironmentVariable {
|
||||||
public:
|
public:
|
||||||
explicit ScopedUnsetEnvironmentVariable(const char* name) : name_(name) {
|
explicit ScopedUnsetEnvironmentVariable(const char* name) : name_(name) {
|
||||||
if (const char* value = std::getenv(name_)) {
|
if (const char* value = std::getenv(name_)) {
|
||||||
original_value_ = value;
|
original_value_ = value;
|
||||||
@@ -77,7 +77,7 @@ public:
|
|||||||
ScopedUnsetEnvironmentVariable& operator=(
|
ScopedUnsetEnvironmentVariable& operator=(
|
||||||
const ScopedUnsetEnvironmentVariable&) = delete;
|
const ScopedUnsetEnvironmentVariable&) = delete;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
const char* name_;
|
const char* name_;
|
||||||
std::optional<std::string> original_value_;
|
std::optional<std::string> original_value_;
|
||||||
};
|
};
|
||||||
@@ -101,8 +101,7 @@ private:
|
|||||||
&bytes_after, &data) == Success &&
|
&bytes_after, &data) == Success &&
|
||||||
actual_type == XA_WINDOW && actual_format == 32 && item_count == 1 &&
|
actual_type == XA_WINDOW && actual_format == 32 && item_count == 1 &&
|
||||||
data) {
|
data) {
|
||||||
const ::Window active_window =
|
const ::Window active_window = *reinterpret_cast<const ::Window*>(data);
|
||||||
*reinterpret_cast<const ::Window*>(data);
|
|
||||||
XFree(data);
|
XFree(data);
|
||||||
return active_window;
|
return active_window;
|
||||||
}
|
}
|
||||||
@@ -165,9 +164,8 @@ bool X11WindowMatches(Display* display, ::Window x11_window,
|
|||||||
int root_x = 0;
|
int root_x = 0;
|
||||||
int root_y = 0;
|
int root_y = 0;
|
||||||
::Window child = 0;
|
::Window child = 0;
|
||||||
if (!XTranslateCoordinates(display, x11_window,
|
if (!XTranslateCoordinates(display, x11_window, DefaultRootWindow(display), 0,
|
||||||
DefaultRootWindow(display), 0, 0, &root_x,
|
0, &root_x, &root_y, &child)) {
|
||||||
&root_y, &child)) {
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -269,17 +267,15 @@ std::vector<ParsedReleaseNoteBlock> ParseReleaseNotesMarkdownForSlint(
|
|||||||
size_t line_start = 0;
|
size_t line_start = 0;
|
||||||
while (line_start < markdown.size()) {
|
while (line_start < markdown.size()) {
|
||||||
const size_t newline = markdown.find('\n', line_start);
|
const size_t newline = markdown.find('\n', line_start);
|
||||||
const size_t line_end = newline == std::string_view::npos
|
const size_t line_end =
|
||||||
? markdown.size()
|
newline == std::string_view::npos ? markdown.size() : newline;
|
||||||
: newline;
|
|
||||||
std::string_view line = markdown.substr(line_start, line_end - line_start);
|
std::string_view line = markdown.substr(line_start, line_end - line_start);
|
||||||
if (!line.empty() && line.back() == '\r') {
|
if (!line.empty() && line.back() == '\r') {
|
||||||
line.remove_suffix(1);
|
line.remove_suffix(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (std::all_of(line.begin(), line.end(), [](unsigned char ch) {
|
if (std::all_of(line.begin(), line.end(),
|
||||||
return std::isspace(ch) != 0;
|
[](unsigned char ch) { return std::isspace(ch) != 0; })) {
|
||||||
})) {
|
|
||||||
section_gap = !blocks.empty();
|
section_gap = !blocks.empty();
|
||||||
if (newline == std::string_view::npos) {
|
if (newline == std::string_view::npos) {
|
||||||
break;
|
break;
|
||||||
@@ -306,11 +302,11 @@ std::vector<ParsedReleaseNoteBlock> ParseReleaseNotesMarkdownForSlint(
|
|||||||
|
|
||||||
const std::string block_markdown(line);
|
const std::string block_markdown(line);
|
||||||
ParsedReleaseNoteBlock block;
|
ParsedReleaseNoteBlock block;
|
||||||
if (const auto parsed =
|
if (const auto parsed = slint::StyledText::from_markdown(block_markdown)) {
|
||||||
slint::StyledText::from_markdown(block_markdown)) {
|
|
||||||
block.content = *parsed;
|
block.content = *parsed;
|
||||||
} else {
|
} else {
|
||||||
LOG_WARN("Failed to parse a release-note Markdown block; using plain text");
|
LOG_WARN(
|
||||||
|
"Failed to parse a release-note Markdown block; using plain text");
|
||||||
block.content = slint::StyledText::from_plain_text(block_markdown);
|
block.content = slint::StyledText::from_plain_text(block_markdown);
|
||||||
}
|
}
|
||||||
block.section_gap = section_gap;
|
block.section_gap = section_gap;
|
||||||
@@ -958,12 +954,13 @@ bool GuiApplication::InitializeSDL() {
|
|||||||
const bool video_driver_allows_x11 =
|
const bool video_driver_allows_x11 =
|
||||||
requested_video_driver == nullptr || requested_video_driver[0] == '\0' ||
|
requested_video_driver == nullptr || requested_video_driver[0] == '\0' ||
|
||||||
std::strcmp(requested_video_driver, "x11") == 0;
|
std::strcmp(requested_video_driver, "x11") == 0;
|
||||||
use_xwayland_gui_ =
|
use_xwayland_gui_ = IsWaylandSession() &&
|
||||||
IsWaylandSession() && HasNonEmptyEnvironmentVariable("DISPLAY") &&
|
HasNonEmptyEnvironmentVariable("DISPLAY") &&
|
||||||
video_driver_allows_x11;
|
video_driver_allows_x11;
|
||||||
if (use_xwayland_gui_) {
|
if (use_xwayland_gui_) {
|
||||||
setenv("SDL_VIDEODRIVER", "x11", 1);
|
setenv("SDL_VIDEODRIVER", "x11", 1);
|
||||||
LOG_INFO("Wayland session detected; using XWayland for positioned GUI "
|
LOG_INFO(
|
||||||
|
"Wayland session detected; using XWayland for positioned GUI "
|
||||||
"windows while retaining Wayland portal capture and input");
|
"windows while retaining Wayland portal capture and input");
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
@@ -1011,8 +1008,7 @@ void GuiApplication::InitializeUi() {
|
|||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
std::vector<ui::ReleaseNoteBlock> release_note_blocks;
|
std::vector<ui::ReleaseNoteBlock> release_note_blocks;
|
||||||
for (const auto& parsed :
|
for (const auto& parsed : ParseReleaseNotesMarkdownForSlint(release_notes_)) {
|
||||||
ParseReleaseNotesMarkdownForSlint(release_notes_)) {
|
|
||||||
ui::ReleaseNoteBlock block;
|
ui::ReleaseNoteBlock block;
|
||||||
block.content = parsed.content;
|
block.content = parsed.content;
|
||||||
block.section_gap = parsed.section_gap;
|
block.section_gap = parsed.section_gap;
|
||||||
@@ -1159,10 +1155,10 @@ void GuiApplication::InitializeUi() {
|
|||||||
#endif
|
#endif
|
||||||
BindStreamCallbacks();
|
BindStreamCallbacks();
|
||||||
(*ui_->stream)->show();
|
(*ui_->stream)->show();
|
||||||
PositionWindowAtCenter((*ui_->stream)->window(), ui_->main->window(),
|
PositionWindowAtCenter(
|
||||||
|
(*ui_->stream)->window(), ui_->main->window(),
|
||||||
kStreamWindowLogicalWidth,
|
kStreamWindowLogicalWidth,
|
||||||
StreamWindowLogicalHeight(
|
StreamWindowLogicalHeight((*ui_->stream)->get_custom_titlebar()));
|
||||||
(*ui_->stream)->get_custom_titlebar()));
|
|
||||||
ui_->main->hide();
|
ui_->main->hide();
|
||||||
} else if (ui_->capture_mode && ui_->capture_page == "server") {
|
} else if (ui_->capture_mode && ui_->capture_page == "server") {
|
||||||
ui_->server.emplace(ui::ServerWindow::create());
|
ui_->server.emplace(ui::ServerWindow::create());
|
||||||
@@ -2078,6 +2074,11 @@ void GuiApplication::SyncMainWindow() {
|
|||||||
}
|
}
|
||||||
model.push_back(std::move(item));
|
model.push_back(std::move(item));
|
||||||
}
|
}
|
||||||
|
// LoadThumbnail already orders connections by last update time. Keep that
|
||||||
|
// order within each presence group while placing online devices first.
|
||||||
|
std::stable_partition(
|
||||||
|
model.begin(), model.end(),
|
||||||
|
[](const ui::RecentConnection& connection) { return connection.online; });
|
||||||
ui_->recent_model->set_vector(std::move(model));
|
ui_->recent_model->set_vector(std::move(model));
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2230,8 +2231,7 @@ void GuiApplication::SyncXWaylandWindowActivation() {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (const auto process_id =
|
if (const auto process_id = X11GetWindowProcessId(display, active_window);
|
||||||
X11GetWindowProcessId(display, active_window);
|
|
||||||
process_id && *process_id != static_cast<unsigned long>(getpid())) {
|
process_id && *process_id != static_cast<unsigned long>(getpid())) {
|
||||||
ui_->main->set_window_active(false);
|
ui_->main->set_window_active(false);
|
||||||
if (ui_->stream) {
|
if (ui_->stream) {
|
||||||
@@ -2244,8 +2244,8 @@ void GuiApplication::SyncXWaylandWindowActivation() {
|
|||||||
X11WindowMatches(display, active_window, ui_->main->window()));
|
X11WindowMatches(display, active_window, ui_->main->window()));
|
||||||
if (ui_->stream) {
|
if (ui_->stream) {
|
||||||
(*ui_->stream)
|
(*ui_->stream)
|
||||||
->set_window_active(X11WindowMatches(
|
->set_window_active(
|
||||||
display, active_window, (*ui_->stream)->window()));
|
X11WindowMatches(display, active_window, (*ui_->stream)->window()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
@@ -2284,8 +2284,7 @@ void GuiApplication::SyncStreamWindow() {
|
|||||||
if (!ui_->stream) {
|
if (!ui_->stream) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
(*ui_->stream)
|
(*ui_->stream)->set_window_maximized((*ui_->stream)->window().is_maximized());
|
||||||
->set_window_maximized((*ui_->stream)->window().is_maximized());
|
|
||||||
(*ui_->stream)->set_srtp_enabled(enable_srtp_);
|
(*ui_->stream)->set_srtp_enabled(enable_srtp_);
|
||||||
#if defined(__APPLE__)
|
#if defined(__APPLE__)
|
||||||
if (ui_->stream_live_resize_configuration_attempts > 0) {
|
if (ui_->stream_live_resize_configuration_attempts > 0) {
|
||||||
@@ -2297,10 +2296,10 @@ void GuiApplication::SyncStreamWindow() {
|
|||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
if (ui_->stream_initial_position_attempts > 0) {
|
if (ui_->stream_initial_position_attempts > 0) {
|
||||||
if (PositionWindowAtCenter((*ui_->stream)->window(), ui_->main->window(),
|
if (PositionWindowAtCenter(
|
||||||
|
(*ui_->stream)->window(), ui_->main->window(),
|
||||||
kStreamWindowLogicalWidth,
|
kStreamWindowLogicalWidth,
|
||||||
StreamWindowLogicalHeight(
|
StreamWindowLogicalHeight((*ui_->stream)->get_custom_titlebar()))) {
|
||||||
(*ui_->stream)->get_custom_titlebar()))) {
|
|
||||||
--ui_->stream_initial_position_attempts;
|
--ui_->stream_initial_position_attempts;
|
||||||
} else {
|
} else {
|
||||||
ui_->stream_initial_position_attempts = 0;
|
ui_->stream_initial_position_attempts = 0;
|
||||||
@@ -2534,7 +2533,22 @@ void GuiApplication::SyncStreamWindow() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void GuiApplication::SyncServerWindow() {
|
void GuiApplication::SyncServerWindow() {
|
||||||
if (need_to_create_server_window_ && !ui_->server) {
|
// The connection map is authoritative. Lifecycle flags record callback
|
||||||
|
// intent, but callbacks for different controllers can cross each other, so
|
||||||
|
// the final decision must reflect the current connected-controller set.
|
||||||
|
need_to_create_server_window_.exchange(false, std::memory_order_acq_rel);
|
||||||
|
need_to_destroy_server_window_.exchange(false, std::memory_order_acq_rel);
|
||||||
|
bool has_connected_controller = false;
|
||||||
|
{
|
||||||
|
std::shared_lock lock(connection_status_mutex_);
|
||||||
|
has_connected_controller =
|
||||||
|
std::any_of(connection_status_.begin(), connection_status_.end(),
|
||||||
|
[](const auto& entry) {
|
||||||
|
return entry.second == ConnectionStatus::Connected;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (has_connected_controller && !ui_->server) {
|
||||||
ui_->server.emplace(ui::ServerWindow::create());
|
ui_->server.emplace(ui::ServerWindow::create());
|
||||||
RegisterFontAwesome((*ui_->server)->window());
|
RegisterFontAwesome((*ui_->server)->window());
|
||||||
(*ui_->server)->set_controllers(ui_->controller_model);
|
(*ui_->server)->set_controllers(ui_->controller_model);
|
||||||
@@ -2554,15 +2568,13 @@ void GuiApplication::SyncServerWindow() {
|
|||||||
ui_->server_initial_position_attempts = 2;
|
ui_->server_initial_position_attempts = 2;
|
||||||
server_window_created_ = true;
|
server_window_created_ = true;
|
||||||
server_window_inited_ = true;
|
server_window_inited_ = true;
|
||||||
need_to_create_server_window_ = false;
|
|
||||||
}
|
}
|
||||||
if (need_to_destroy_server_window_ && ui_->server) {
|
if (!has_connected_controller && ui_->server) {
|
||||||
(*ui_->server)->hide();
|
(*ui_->server)->hide();
|
||||||
ui_->server.reset();
|
ui_->server.reset();
|
||||||
server_window_created_ = false;
|
server_window_created_ = false;
|
||||||
server_window_inited_ = false;
|
server_window_inited_ = false;
|
||||||
ui_->server_initial_position_attempts = 0;
|
ui_->server_initial_position_attempts = 0;
|
||||||
need_to_destroy_server_window_ = false;
|
|
||||||
}
|
}
|
||||||
if (!ui_->server) {
|
if (!ui_->server) {
|
||||||
return;
|
return;
|
||||||
@@ -2863,8 +2875,7 @@ void GuiApplication::SendPointerInput(int button, int kind, float x, float y) {
|
|||||||
: 0.0f;
|
: 0.0f;
|
||||||
const float available_height =
|
const float available_height =
|
||||||
size.height / scale - titlebar_height -
|
size.height / scale - titlebar_height -
|
||||||
(fullscreen_button_pressed_
|
(fullscreen_button_pressed_ ? 0.0f
|
||||||
? 0.0f
|
|
||||||
: (ui_->tab_ids.size() > 1 ? 30.0f : 0.0f));
|
: (ui_->tab_ids.size() > 1 ? 30.0f : 0.0f));
|
||||||
float render_width = available_width;
|
float render_width = available_width;
|
||||||
float render_height = available_height;
|
float render_height = available_height;
|
||||||
@@ -2939,8 +2950,7 @@ void GuiApplication::SendScrollInput(float delta_x, float delta_y, float x,
|
|||||||
: 0.0f;
|
: 0.0f;
|
||||||
const float height =
|
const float height =
|
||||||
size.height / scale - titlebar_height -
|
size.height / scale - titlebar_height -
|
||||||
(fullscreen_button_pressed_
|
(fullscreen_button_pressed_ ? 0.0f
|
||||||
? 0.0f
|
|
||||||
: (ui_->tab_ids.size() > 1 ? 30.0f : 0.0f));
|
: (ui_->tab_ids.size() > 1 ? 30.0f : 0.0f));
|
||||||
if (width <= 0 || height <= 0) {
|
if (width <= 0 || height <= 0) {
|
||||||
return;
|
return;
|
||||||
|
|||||||
@@ -220,10 +220,8 @@ int GuiApplication::ProcessKeyboardEvent(const SDL_Event &event) {
|
|||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (event.type == SDL_EVENT_KEY_DOWN && event.key.repeat) {
|
// SDL represents key auto-repeat as additional key-down events. Forward
|
||||||
return 0;
|
// them so the fallback path has the same long-press behavior as native hooks.
|
||||||
}
|
|
||||||
|
|
||||||
const int key_code = TranslateSdlKeyboardEventToVk(event.key);
|
const int key_code = TranslateSdlKeyboardEventToVk(event.key);
|
||||||
if (key_code < 0) {
|
if (key_code < 0) {
|
||||||
return 0;
|
return 0;
|
||||||
|
|||||||
@@ -1,5 +1,3 @@
|
|||||||
#include "runtime/gui_runtime.h"
|
|
||||||
|
|
||||||
#include <algorithm>
|
#include <algorithm>
|
||||||
#include <chrono>
|
#include <chrono>
|
||||||
#include <cstring>
|
#include <cstring>
|
||||||
@@ -11,7 +9,9 @@
|
|||||||
#include <vector>
|
#include <vector>
|
||||||
|
|
||||||
#include "localization.h"
|
#include "localization.h"
|
||||||
|
#include "platform.h"
|
||||||
#include "rd_log.h"
|
#include "rd_log.h"
|
||||||
|
#include "runtime/gui_runtime.h"
|
||||||
|
|
||||||
namespace crossdesk {
|
namespace crossdesk {
|
||||||
|
|
||||||
@@ -31,7 +31,7 @@ void GuiRuntime::HandleConnectionStatusChange() {
|
|||||||
j["type"] = "recent_connections_presence";
|
j["type"] = "recent_connections_presence";
|
||||||
j["user_id"] = client_id_;
|
j["user_id"] = client_id_;
|
||||||
j["devices"] = nlohmann::json::array();
|
j["devices"] = nlohmann::json::array();
|
||||||
for (const auto &id : recent_connection_ids_) {
|
for (const auto& id : recent_connection_ids_) {
|
||||||
std::string pure_id = id;
|
std::string pure_id = id;
|
||||||
size_t pos_y = pure_id.find('Y');
|
size_t pos_y = pure_id.find('Y');
|
||||||
size_t pos_n = pure_id.find('N');
|
size_t pos_n = pure_id.find('N');
|
||||||
@@ -123,7 +123,7 @@ void GuiRuntime::HandleConnectionTimeouts() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
bool rejoin_state_changed = false;
|
bool rejoin_state_changed = false;
|
||||||
for (auto &[_, props] : remote_sessions_) {
|
for (auto& [_, props] : remote_sessions_) {
|
||||||
if (!props || !props->connection_attempt_active_.load()) {
|
if (!props || !props->connection_attempt_active_.load()) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
@@ -152,7 +152,7 @@ void GuiRuntime::HandleConnectionTimeouts() {
|
|||||||
|
|
||||||
if (rejoin_state_changed) {
|
if (rejoin_state_changed) {
|
||||||
need_to_rejoin_ = false;
|
need_to_rejoin_ = false;
|
||||||
for (const auto &[_, props] : remote_sessions_) {
|
for (const auto& [_, props] : remote_sessions_) {
|
||||||
if (props && props->rejoin_) {
|
if (props && props->rejoin_) {
|
||||||
need_to_rejoin_ = true;
|
need_to_rejoin_ = true;
|
||||||
break;
|
break;
|
||||||
@@ -161,8 +161,65 @@ void GuiRuntime::HandleConnectionTimeouts() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
int GuiRuntime::RequestSingleDevicePresence(const std::string &remote_id,
|
void GuiRuntime::HandleServerControllerDisconnected(
|
||||||
const char *password,
|
const std::string& remote_id, const char* reason) {
|
||||||
|
keyboard_.ReleaseRemotePressedKeys(remote_id, reason);
|
||||||
|
|
||||||
|
bool has_connected_controller = false;
|
||||||
|
bool has_web_controller = false;
|
||||||
|
std::string remaining_controller_id;
|
||||||
|
{
|
||||||
|
std::unique_lock lock(connection_status_mutex_);
|
||||||
|
connection_status_.erase(remote_id);
|
||||||
|
connection_host_names_.erase(remote_id);
|
||||||
|
for (const auto& [id, status] : connection_status_) {
|
||||||
|
if (status != ConnectionStatus::Connected) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
has_connected_controller = true;
|
||||||
|
has_web_controller =
|
||||||
|
has_web_controller || id.find("web") != std::string::npos;
|
||||||
|
if (remaining_controller_id.empty()) {
|
||||||
|
remaining_controller_id = id;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
show_cursor_ = has_web_controller;
|
||||||
|
if (has_connected_controller) {
|
||||||
|
remote_client_id_ = remaining_controller_id;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
need_to_create_server_window_.store(false, std::memory_order_release);
|
||||||
|
need_to_destroy_server_window_.store(true, std::memory_order_release);
|
||||||
|
is_server_mode_ = false;
|
||||||
|
#if defined(__linux__) && !defined(__APPLE__)
|
||||||
|
if (IsWaylandSession()) {
|
||||||
|
// Keep Wayland capture session warm to avoid black screen on subsequent
|
||||||
|
// reconnects.
|
||||||
|
start_screen_capturer_ = true;
|
||||||
|
LOG_INFO(
|
||||||
|
"Keeping Wayland screen capturer running after disconnect to "
|
||||||
|
"preserve reconnect stability");
|
||||||
|
} else {
|
||||||
|
start_screen_capturer_ = false;
|
||||||
|
}
|
||||||
|
#else
|
||||||
|
start_screen_capturer_ = false;
|
||||||
|
#endif
|
||||||
|
start_speaker_capturer_ = false;
|
||||||
|
start_mouse_controller_ = false;
|
||||||
|
start_keyboard_capturer_ = false;
|
||||||
|
remote_client_id_.clear();
|
||||||
|
if (audio_capture_) {
|
||||||
|
devices_.StopSpeakerCapturer();
|
||||||
|
audio_capture_ = false;
|
||||||
|
}
|
||||||
|
devices_.ResetToInitialDisplay();
|
||||||
|
}
|
||||||
|
|
||||||
|
int GuiRuntime::RequestSingleDevicePresence(const std::string& remote_id,
|
||||||
|
const char* password,
|
||||||
bool remember_password) {
|
bool remember_password) {
|
||||||
if (!signal_connected_ || !peer_) {
|
if (!signal_connected_ || !peer_) {
|
||||||
return -1;
|
return -1;
|
||||||
@@ -221,7 +278,7 @@ void GuiRuntime::CloseRemoteSession(std::shared_ptr<RemoteSession> props) {
|
|||||||
std::thread save_thread([buffer_copy, video_width, video_height, remote_id,
|
std::thread save_thread([buffer_copy, video_width, video_height, remote_id,
|
||||||
remote_host_name, password,
|
remote_host_name, password,
|
||||||
thumbnail = thumbnail_]() {
|
thumbnail = thumbnail_]() {
|
||||||
thumbnail->SaveToThumbnail((char *)buffer_copy.data(), video_width,
|
thumbnail->SaveToThumbnail((char*)buffer_copy.data(), video_width,
|
||||||
video_height, remote_id, remote_host_name,
|
video_height, remote_id, remote_host_name,
|
||||||
password);
|
password);
|
||||||
});
|
});
|
||||||
@@ -255,7 +312,7 @@ void GuiRuntime::CloseAllRemoteSessions() {
|
|||||||
|
|
||||||
{
|
{
|
||||||
// std::shared_lock lock(remote_sessions_mutex_);
|
// std::shared_lock lock(remote_sessions_mutex_);
|
||||||
for (auto &it : remote_sessions_) {
|
for (auto& it : remote_sessions_) {
|
||||||
auto props = it.second;
|
auto props = it.second;
|
||||||
CloseRemoteSession(props);
|
CloseRemoteSession(props);
|
||||||
}
|
}
|
||||||
@@ -279,7 +336,7 @@ void GuiRuntime::WaitForThumbnailSaveTasks() {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
for (auto &thread : threads_to_join) {
|
for (auto& thread : threads_to_join) {
|
||||||
if (thread.joinable()) {
|
if (thread.joinable()) {
|
||||||
thread.join();
|
thread.join();
|
||||||
}
|
}
|
||||||
@@ -300,9 +357,8 @@ void GuiRuntime::ResetRemoteSessionResources(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
std::shared_ptr<GuiRuntime::RemoteSession>
|
std::shared_ptr<GuiRuntime::RemoteSession> GuiRuntime::FindRemoteSession(
|
||||||
GuiRuntime::FindRemoteSession(
|
const std::string& remote_id) {
|
||||||
const std::string &remote_id) {
|
|
||||||
if (remote_id.empty()) {
|
if (remote_id.empty()) {
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
@@ -315,8 +371,7 @@ GuiRuntime::FindRemoteSession(
|
|||||||
return it->second;
|
return it->second;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
int GuiRuntime::ConnectTo(const std::string& remote_id, const char* password,
|
||||||
int GuiRuntime::ConnectTo(const std::string &remote_id, const char *password,
|
|
||||||
bool remember_password, bool bypass_presence_check) {
|
bool remember_password, bool bypass_presence_check) {
|
||||||
if (!bypass_presence_check && !device_presence_cache_.IsOnline(remote_id)) {
|
if (!bypass_presence_check && !device_presence_cache_.IsOnline(remote_id)) {
|
||||||
int ret =
|
int ret =
|
||||||
@@ -336,19 +391,17 @@ int GuiRuntime::ConnectTo(const std::string &remote_id, const char *password,
|
|||||||
focused_remote_id_ = remote_id;
|
focused_remote_id_ = remote_id;
|
||||||
|
|
||||||
// std::shared_lock shared_lock(remote_sessions_mutex_);
|
// std::shared_lock shared_lock(remote_sessions_mutex_);
|
||||||
bool exists =
|
bool exists = (remote_sessions_.find(remote_id) != remote_sessions_.end());
|
||||||
(remote_sessions_.find(remote_id) != remote_sessions_.end());
|
|
||||||
// shared_lock.unlock();
|
// shared_lock.unlock();
|
||||||
|
|
||||||
if (!exists) {
|
if (!exists) {
|
||||||
PeerPtr *peer_to_init = nullptr;
|
PeerPtr* peer_to_init = nullptr;
|
||||||
std::string local_id;
|
std::string local_id;
|
||||||
|
|
||||||
{
|
{
|
||||||
// std::unique_lock unique_lock(remote_sessions_mutex_);
|
// std::unique_lock unique_lock(remote_sessions_mutex_);
|
||||||
if (remote_sessions_.find(remote_id) == remote_sessions_.end()) {
|
if (remote_sessions_.find(remote_id) == remote_sessions_.end()) {
|
||||||
remote_sessions_[remote_id] =
|
remote_sessions_[remote_id] = std::make_shared<RemoteSession>();
|
||||||
std::make_shared<RemoteSession>();
|
|
||||||
auto props = remote_sessions_[remote_id];
|
auto props = remote_sessions_[remote_id];
|
||||||
props->local_id_ = "C-" + std::string(client_id_);
|
props->local_id_ = "C-" + std::string(client_id_);
|
||||||
props->remote_id_ = remote_id;
|
props->remote_id_ = remote_id;
|
||||||
@@ -371,7 +424,7 @@ int GuiRuntime::ConnectTo(const std::string &remote_id, const char *password,
|
|||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
for (const auto &display_info : devices_.display_info_list()) {
|
for (const auto& display_info : devices_.display_info_list()) {
|
||||||
AddVideoStream(props->peer_, display_info.name.c_str());
|
AddVideoStream(props->peer_, display_info.name.c_str());
|
||||||
}
|
}
|
||||||
AddAudioStream(props->peer_, props->audio_label_.c_str());
|
AddAudioStream(props->peer_, props->audio_label_.c_str());
|
||||||
|
|||||||
@@ -8,16 +8,16 @@
|
|||||||
#include "features/devices/session_device_manager.h"
|
#include "features/devices/session_device_manager.h"
|
||||||
#include "features/file_transfer/file_transfer_manager.h"
|
#include "features/file_transfer/file_transfer_manager.h"
|
||||||
#include "features/input/keyboard_controller.h"
|
#include "features/input/keyboard_controller.h"
|
||||||
|
#include "features/settings/settings_manager.h"
|
||||||
#include "runtime/gui_state.h"
|
#include "runtime/gui_state.h"
|
||||||
#include "runtime/peer_event_handler.h"
|
#include "runtime/peer_event_handler.h"
|
||||||
#include "features/settings/settings_manager.h"
|
|
||||||
|
|
||||||
namespace crossdesk {
|
namespace crossdesk {
|
||||||
|
|
||||||
// Shared GUI runtime. It owns subsystem controllers and cross-cutting session
|
// Shared GUI runtime. It owns subsystem controllers and cross-cutting session
|
||||||
// state, but no window lifecycle, ImGui view, or transport callback methods.
|
// state, but no window lifecycle, ImGui view, or transport callback methods.
|
||||||
class GuiRuntime : protected gui_detail::GuiState {
|
class GuiRuntime : protected gui_detail::GuiState {
|
||||||
protected:
|
protected:
|
||||||
using FileTransferState = gui_detail::FileTransferState;
|
using FileTransferState = gui_detail::FileTransferState;
|
||||||
using RemoteSession = gui_detail::RemoteSession;
|
using RemoteSession = gui_detail::RemoteSession;
|
||||||
|
|
||||||
@@ -32,35 +32,35 @@ protected:
|
|||||||
GuiRuntime();
|
GuiRuntime();
|
||||||
~GuiRuntime();
|
~GuiRuntime();
|
||||||
|
|
||||||
static void SdlCaptureAudioIn(void *userdata, Uint8 *stream, int len);
|
static void SdlCaptureAudioIn(void* userdata, Uint8* stream, int len);
|
||||||
static void SdlCaptureAudioOut(void *userdata, Uint8 *stream, int len);
|
static void SdlCaptureAudioOut(void* userdata, Uint8* stream, int len);
|
||||||
|
|
||||||
int CreateConnectionPeer();
|
int CreateConnectionPeer();
|
||||||
int ConnectTo(const std::string &remote_id, const char *password,
|
int ConnectTo(const std::string& remote_id, const char* password,
|
||||||
bool remember_password, bool bypass_presence_check = false);
|
bool remember_password, bool bypass_presence_check = false);
|
||||||
int RequestSingleDevicePresence(const std::string &remote_id,
|
int RequestSingleDevicePresence(const std::string& remote_id,
|
||||||
const char *password, bool remember_password);
|
const char* password, bool remember_password);
|
||||||
|
|
||||||
void UpdateLabels();
|
void UpdateLabels();
|
||||||
void HandleRecentConnections();
|
void HandleRecentConnections();
|
||||||
void HandleConnectionStatusChange();
|
void HandleConnectionStatusChange();
|
||||||
void HandlePendingPresenceProbe();
|
void HandlePendingPresenceProbe();
|
||||||
void HandleConnectionTimeouts();
|
void HandleConnectionTimeouts();
|
||||||
|
void HandleServerControllerDisconnected(const std::string& remote_id,
|
||||||
|
const char* reason);
|
||||||
void HandleWindowsServiceIntegration();
|
void HandleWindowsServiceIntegration();
|
||||||
|
|
||||||
void CloseRemoteSession(std::shared_ptr<RemoteSession> props);
|
void CloseRemoteSession(std::shared_ptr<RemoteSession> props);
|
||||||
void CloseAllRemoteSessions();
|
void CloseAllRemoteSessions();
|
||||||
void ResetRemoteSessionResources(
|
void ResetRemoteSessionResources(std::shared_ptr<RemoteSession> props);
|
||||||
std::shared_ptr<RemoteSession> props);
|
|
||||||
void WaitForThumbnailSaveTasks();
|
void WaitForThumbnailSaveTasks();
|
||||||
std::shared_ptr<RemoteSession>
|
std::shared_ptr<RemoteSession> FindRemoteSession(
|
||||||
FindRemoteSession(const std::string &remote_id);
|
const std::string& remote_id);
|
||||||
|
|
||||||
void ResetRemoteServiceStatus(RemoteSession &props);
|
void ResetRemoteServiceStatus(RemoteSession& props);
|
||||||
void ApplyRemoteServiceStatus(RemoteSession &props,
|
void ApplyRemoteServiceStatus(RemoteSession& props,
|
||||||
const ServiceStatus &status);
|
const ServiceStatus& status);
|
||||||
RemoteUnlockState
|
RemoteUnlockState GetRemoteUnlockState(const RemoteSession& props) const;
|
||||||
GetRemoteUnlockState(const RemoteSession &props) const;
|
|
||||||
#if _WIN32
|
#if _WIN32
|
||||||
void ResetLocalWindowsServiceState(bool clear_pending_sas);
|
void ResetLocalWindowsServiceState(bool clear_pending_sas);
|
||||||
#endif
|
#endif
|
||||||
@@ -82,7 +82,7 @@ protected:
|
|||||||
KeyboardController keyboard_;
|
KeyboardController keyboard_;
|
||||||
PeerEventHandler peer_events_;
|
PeerEventHandler peer_events_;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
friend class ClipboardController;
|
friend class ClipboardController;
|
||||||
friend class SessionDeviceManager;
|
friend class SessionDeviceManager;
|
||||||
friend class FileTransferManager;
|
friend class FileTransferManager;
|
||||||
|
|||||||
@@ -26,12 +26,12 @@
|
|||||||
|
|
||||||
namespace crossdesk {
|
namespace crossdesk {
|
||||||
|
|
||||||
PeerEventHandler::PeerEventHandler(GuiRuntime &owner) : owner_(owner) {}
|
PeerEventHandler::PeerEventHandler(GuiRuntime& owner) : owner_(owner) {}
|
||||||
|
|
||||||
void PeerEventHandler::OnSignalMessage(const char *message, size_t size,
|
void PeerEventHandler::OnSignalMessage(const char* message, size_t size,
|
||||||
void *user_data) {
|
void* user_data) {
|
||||||
auto *handler = static_cast<PeerEventHandler *>(user_data);
|
auto* handler = static_cast<PeerEventHandler*>(user_data);
|
||||||
GuiRuntime *runtime = handler ? &handler->owner_ : nullptr;
|
GuiRuntime* runtime = handler ? &handler->owner_ : nullptr;
|
||||||
if (!runtime || !message || size == 0) {
|
if (!runtime || !message || size == 0) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -43,7 +43,7 @@ void PeerEventHandler::OnSignalMessage(const char *message, size_t size,
|
|||||||
std::string type = j["type"].get<std::string>();
|
std::string type = j["type"].get<std::string>();
|
||||||
if (type == "presence") {
|
if (type == "presence") {
|
||||||
if (j.contains("devices") && j["devices"].is_array()) {
|
if (j.contains("devices") && j["devices"].is_array()) {
|
||||||
for (auto &dev : j["devices"]) {
|
for (auto& dev : j["devices"]) {
|
||||||
if (!dev.is_object()) {
|
if (!dev.is_object()) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
@@ -88,11 +88,10 @@ void PeerEventHandler::OnSignalMessage(const char *message, size_t size,
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void PeerEventHandler::OnSignalStatus(SignalStatus status, const char* user_id,
|
||||||
void PeerEventHandler::OnSignalStatus(SignalStatus status, const char *user_id,
|
size_t user_id_size, void* user_data) {
|
||||||
size_t user_id_size, void *user_data) {
|
auto* handler = static_cast<PeerEventHandler*>(user_data);
|
||||||
auto *handler = static_cast<PeerEventHandler *>(user_data);
|
GuiRuntime* runtime = handler ? &handler->owner_ : nullptr;
|
||||||
GuiRuntime *runtime = handler ? &handler->owner_ : nullptr;
|
|
||||||
if (!runtime) {
|
if (!runtime) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -150,13 +149,12 @@ void PeerEventHandler::OnSignalStatus(SignalStatus status, const char *user_id,
|
|||||||
}
|
}
|
||||||
|
|
||||||
void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
||||||
const char *user_id,
|
const char* user_id,
|
||||||
const size_t user_id_size,
|
const size_t user_id_size,
|
||||||
void *user_data) {
|
void* user_data) {
|
||||||
auto *handler = static_cast<PeerEventHandler *>(user_data);
|
auto* handler = static_cast<PeerEventHandler*>(user_data);
|
||||||
GuiRuntime *runtime = handler ? &handler->owner_ : nullptr;
|
GuiRuntime* runtime = handler ? &handler->owner_ : nullptr;
|
||||||
if (!runtime)
|
if (!runtime) return;
|
||||||
return;
|
|
||||||
|
|
||||||
std::string remote_id(user_id, user_id_size);
|
std::string remote_id(user_id, user_id_size);
|
||||||
std::shared_ptr<GuiRuntime::RemoteSession> props;
|
std::shared_ptr<GuiRuntime::RemoteSession> props;
|
||||||
@@ -185,28 +183,30 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
remote_action.i.display_num =
|
remote_action.i.display_num =
|
||||||
runtime->devices_.display_info_list().size();
|
runtime->devices_.display_info_list().size();
|
||||||
remote_action.i.display_list =
|
remote_action.i.display_list =
|
||||||
(char **)malloc(remote_action.i.display_num * sizeof(char *));
|
(char**)malloc(remote_action.i.display_num * sizeof(char*));
|
||||||
remote_action.i.left =
|
remote_action.i.left =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.top =
|
remote_action.i.top =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.right =
|
remote_action.i.right =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.bottom =
|
remote_action.i.bottom =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
for (int i = 0; i < remote_action.i.display_num; i++) {
|
for (int i = 0; i < remote_action.i.display_num; i++) {
|
||||||
LOG_INFO("Local display [{}:{}]", i + 1,
|
LOG_INFO("Local display [{}:{}]", i + 1,
|
||||||
runtime->devices_.display_info_list()[i].name);
|
runtime->devices_.display_info_list()[i].name);
|
||||||
remote_action.i.display_list[i] = (char *)malloc(
|
remote_action.i.display_list[i] = (char*)malloc(
|
||||||
runtime->devices_.display_info_list()[i].name.length() + 1);
|
runtime->devices_.display_info_list()[i].name.length() + 1);
|
||||||
strncpy(remote_action.i.display_list[i],
|
strncpy(remote_action.i.display_list[i],
|
||||||
runtime->devices_.display_info_list()[i].name.c_str(),
|
runtime->devices_.display_info_list()[i].name.c_str(),
|
||||||
runtime->devices_.display_info_list()[i].name.length());
|
runtime->devices_.display_info_list()[i].name.length());
|
||||||
remote_action.i.display_list
|
remote_action.i
|
||||||
[i][runtime->devices_.display_info_list()[i].name.length()] = '\0';
|
.display_list[i][runtime->devices_.display_info_list()[i]
|
||||||
|
.name.length()] = '\0';
|
||||||
remote_action.i.left[i] =
|
remote_action.i.left[i] =
|
||||||
runtime->devices_.display_info_list()[i].left;
|
runtime->devices_.display_info_list()[i].left;
|
||||||
remote_action.i.top[i] = runtime->devices_.display_info_list()[i].top;
|
remote_action.i.top[i] =
|
||||||
|
runtime->devices_.display_info_list()[i].top;
|
||||||
remote_action.i.right[i] =
|
remote_action.i.right[i] =
|
||||||
runtime->devices_.display_info_list()[i].right;
|
runtime->devices_.display_info_list()[i].right;
|
||||||
remote_action.i.bottom[i] =
|
remote_action.i.bottom[i] =
|
||||||
@@ -215,7 +215,8 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
|
|
||||||
std::string host_name = GetHostName();
|
std::string host_name = GetHostName();
|
||||||
remote_action.type = ControlType::host_infomation;
|
remote_action.type = ControlType::host_infomation;
|
||||||
memcpy(&remote_action.i.host_name, host_name.data(), host_name.size());
|
memcpy(&remote_action.i.host_name, host_name.data(),
|
||||||
|
host_name.size());
|
||||||
remote_action.i.host_name[host_name.size()] = '\0';
|
remote_action.i.host_name[host_name.size()] = '\0';
|
||||||
remote_action.i.host_name_size = host_name.size();
|
remote_action.i.host_name_size = host_name.size();
|
||||||
|
|
||||||
@@ -298,28 +299,30 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
remote_action.i.display_num =
|
remote_action.i.display_num =
|
||||||
runtime->devices_.display_info_list().size();
|
runtime->devices_.display_info_list().size();
|
||||||
remote_action.i.display_list =
|
remote_action.i.display_list =
|
||||||
(char **)malloc(remote_action.i.display_num * sizeof(char *));
|
(char**)malloc(remote_action.i.display_num * sizeof(char*));
|
||||||
remote_action.i.left =
|
remote_action.i.left =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.top =
|
remote_action.i.top =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.right =
|
remote_action.i.right =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
remote_action.i.bottom =
|
remote_action.i.bottom =
|
||||||
(int *)malloc(remote_action.i.display_num * sizeof(int));
|
(int*)malloc(remote_action.i.display_num * sizeof(int));
|
||||||
for (int i = 0; i < remote_action.i.display_num; i++) {
|
for (int i = 0; i < remote_action.i.display_num; i++) {
|
||||||
LOG_INFO("Local display [{}:{}]", i + 1,
|
LOG_INFO("Local display [{}:{}]", i + 1,
|
||||||
runtime->devices_.display_info_list()[i].name);
|
runtime->devices_.display_info_list()[i].name);
|
||||||
remote_action.i.display_list[i] = (char *)malloc(
|
remote_action.i.display_list[i] = (char*)malloc(
|
||||||
runtime->devices_.display_info_list()[i].name.length() + 1);
|
runtime->devices_.display_info_list()[i].name.length() + 1);
|
||||||
strncpy(remote_action.i.display_list[i],
|
strncpy(remote_action.i.display_list[i],
|
||||||
runtime->devices_.display_info_list()[i].name.c_str(),
|
runtime->devices_.display_info_list()[i].name.c_str(),
|
||||||
runtime->devices_.display_info_list()[i].name.length());
|
runtime->devices_.display_info_list()[i].name.length());
|
||||||
remote_action.i.display_list
|
remote_action.i
|
||||||
[i][runtime->devices_.display_info_list()[i].name.length()] = '\0';
|
.display_list[i][runtime->devices_.display_info_list()[i]
|
||||||
|
.name.length()] = '\0';
|
||||||
remote_action.i.left[i] =
|
remote_action.i.left[i] =
|
||||||
runtime->devices_.display_info_list()[i].left;
|
runtime->devices_.display_info_list()[i].left;
|
||||||
remote_action.i.top[i] = runtime->devices_.display_info_list()[i].top;
|
remote_action.i.top[i] =
|
||||||
|
runtime->devices_.display_info_list()[i].top;
|
||||||
remote_action.i.right[i] =
|
remote_action.i.right[i] =
|
||||||
runtime->devices_.display_info_list()[i].right;
|
runtime->devices_.display_info_list()[i].right;
|
||||||
remote_action.i.bottom[i] =
|
remote_action.i.bottom[i] =
|
||||||
@@ -328,17 +331,22 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
|
|
||||||
std::string host_name = GetHostName();
|
std::string host_name = GetHostName();
|
||||||
remote_action.type = ControlType::host_infomation;
|
remote_action.type = ControlType::host_infomation;
|
||||||
memcpy(&remote_action.i.host_name, host_name.data(), host_name.size());
|
memcpy(&remote_action.i.host_name, host_name.data(),
|
||||||
|
host_name.size());
|
||||||
remote_action.i.host_name[host_name.size()] = '\0';
|
remote_action.i.host_name[host_name.size()] = '\0';
|
||||||
remote_action.i.host_name_size = host_name.size();
|
remote_action.i.host_name_size = host_name.size();
|
||||||
|
|
||||||
std::string msg = remote_action.to_json();
|
std::string msg = remote_action.to_json();
|
||||||
int ret = SendReliableDataFrame(runtime->peer_, msg.data(), msg.size(),
|
int ret =
|
||||||
|
SendReliableDataFrame(runtime->peer_, msg.data(), msg.size(),
|
||||||
runtime->control_data_label_.c_str());
|
runtime->control_data_label_.c_str());
|
||||||
remote_action_codec::Free(remote_action);
|
remote_action_codec::Free(remote_action);
|
||||||
}
|
}
|
||||||
|
|
||||||
runtime->need_to_create_server_window_ = true;
|
runtime->need_to_destroy_server_window_.store(
|
||||||
|
false, std::memory_order_release);
|
||||||
|
runtime->need_to_create_server_window_.store(true,
|
||||||
|
std::memory_order_release);
|
||||||
runtime->is_server_mode_ = true;
|
runtime->is_server_mode_ = true;
|
||||||
runtime->start_screen_capturer_ = true;
|
runtime->start_screen_capturer_ = true;
|
||||||
runtime->start_speaker_capturer_ = true;
|
runtime->start_speaker_capturer_ = true;
|
||||||
@@ -347,7 +355,8 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
{
|
{
|
||||||
std::shared_lock lock(runtime->connection_status_mutex_);
|
std::shared_lock lock(runtime->connection_status_mutex_);
|
||||||
if (std::all_of(runtime->connection_status_.begin(),
|
if (std::all_of(runtime->connection_status_.begin(),
|
||||||
runtime->connection_status_.end(), [](const auto &kv) {
|
runtime->connection_status_.end(),
|
||||||
|
[](const auto& kv) {
|
||||||
return kv.first.find("web") != std::string::npos;
|
return kv.first.find("web") != std::string::npos;
|
||||||
})) {
|
})) {
|
||||||
runtime->show_cursor_ = true;
|
runtime->show_cursor_ = true;
|
||||||
@@ -359,64 +368,8 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
case ConnectionStatus::Disconnected:
|
case ConnectionStatus::Disconnected:
|
||||||
case ConnectionStatus::Failed:
|
case ConnectionStatus::Failed:
|
||||||
case ConnectionStatus::Closed: {
|
case ConnectionStatus::Closed: {
|
||||||
runtime->keyboard_.ReleaseRemotePressedKeys(remote_id,
|
runtime->HandleServerControllerDisconnected(remote_id,
|
||||||
"connection_closed");
|
"connection_closed");
|
||||||
bool all_disconnected = false;
|
|
||||||
{
|
|
||||||
std::shared_lock lock(runtime->connection_status_mutex_);
|
|
||||||
all_disconnected =
|
|
||||||
std::all_of(runtime->connection_status_.begin(),
|
|
||||||
runtime->connection_status_.end(), [](const auto &kv) {
|
|
||||||
return kv.second == ConnectionStatus::Closed ||
|
|
||||||
kv.second == ConnectionStatus::Failed ||
|
|
||||||
kv.second == ConnectionStatus::Disconnected;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
if (all_disconnected) {
|
|
||||||
runtime->need_to_destroy_server_window_ = true;
|
|
||||||
runtime->is_server_mode_ = false;
|
|
||||||
#if defined(__linux__) && !defined(__APPLE__)
|
|
||||||
if (IsWaylandSession()) {
|
|
||||||
// Keep Wayland capture session warm to avoid black screen on
|
|
||||||
// subsequent reconnects.
|
|
||||||
runtime->start_screen_capturer_ = true;
|
|
||||||
LOG_INFO("Keeping Wayland screen capturer running after "
|
|
||||||
"disconnect to preserve reconnect stability");
|
|
||||||
} else {
|
|
||||||
runtime->start_screen_capturer_ = false;
|
|
||||||
}
|
|
||||||
#else
|
|
||||||
runtime->start_screen_capturer_ = false;
|
|
||||||
#endif
|
|
||||||
runtime->start_speaker_capturer_ = false;
|
|
||||||
runtime->start_mouse_controller_ = false;
|
|
||||||
runtime->start_keyboard_capturer_ = false;
|
|
||||||
runtime->remote_client_id_ = "";
|
|
||||||
if (props)
|
|
||||||
props->connection_established_ = false;
|
|
||||||
if (runtime->audio_capture_) {
|
|
||||||
runtime->devices_.StopSpeakerCapturer();
|
|
||||||
runtime->audio_capture_ = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
{
|
|
||||||
std::unique_lock lock(runtime->connection_status_mutex_);
|
|
||||||
runtime->connection_status_.erase(remote_id);
|
|
||||||
runtime->connection_host_names_.erase(remote_id);
|
|
||||||
}
|
|
||||||
runtime->devices_.ResetToInitialDisplay();
|
|
||||||
}
|
|
||||||
|
|
||||||
{
|
|
||||||
std::shared_lock lock(runtime->connection_status_mutex_);
|
|
||||||
if (std::all_of(runtime->connection_status_.begin(),
|
|
||||||
runtime->connection_status_.end(), [](const auto &kv) {
|
|
||||||
return kv.first.find("web") == std::string::npos;
|
|
||||||
})) {
|
|
||||||
runtime->show_cursor_ = false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
default:
|
default:
|
||||||
@@ -426,18 +379,18 @@ void PeerEventHandler::OnConnectionStatus(ConnectionStatus status,
|
|||||||
}
|
}
|
||||||
|
|
||||||
void PeerEventHandler::OnNetStatusReport(
|
void PeerEventHandler::OnNetStatusReport(
|
||||||
const char *client_id, size_t client_id_size, TraversalMode mode,
|
const char* client_id, size_t client_id_size, TraversalMode mode,
|
||||||
const XNetTrafficStats *net_traffic_stats, const char *user_id,
|
const XNetTrafficStats* net_traffic_stats, const char* user_id,
|
||||||
const size_t user_id_size, void *user_data) {
|
const size_t user_id_size, void* user_data) {
|
||||||
auto *handler = static_cast<PeerEventHandler *>(user_data);
|
auto* handler = static_cast<PeerEventHandler*>(user_data);
|
||||||
GuiRuntime *runtime = handler ? &handler->owner_ : nullptr;
|
GuiRuntime* runtime = handler ? &handler->owner_ : nullptr;
|
||||||
if (!runtime) {
|
if (!runtime) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (strchr(client_id, '@') != nullptr && strchr(user_id, '-') == nullptr) {
|
if (strchr(client_id, '@') != nullptr && strchr(user_id, '-') == nullptr) {
|
||||||
std::string id, password;
|
std::string id, password;
|
||||||
const char *at_pos = strchr(client_id, '@');
|
const char* at_pos = strchr(client_id, '@');
|
||||||
if (at_pos == nullptr) {
|
if (at_pos == nullptr) {
|
||||||
id = client_id;
|
id = client_id;
|
||||||
password.clear();
|
password.clear();
|
||||||
|
|||||||
@@ -282,6 +282,7 @@ export component MainWindow inherits Window {
|
|||||||
|
|
||||||
private property <bool> menu-open: false;
|
private property <bool> menu-open: false;
|
||||||
in-out property <bool> settings-open: false;
|
in-out property <bool> settings-open: false;
|
||||||
|
private property <length> settings-scroll-y: 0px;
|
||||||
in-out property <bool> self-host-settings-open: false;
|
in-out property <bool> self-host-settings-open: false;
|
||||||
in-out property <bool> about-open: false;
|
in-out property <bool> about-open: false;
|
||||||
in-out property <bool> update-open: root.update-available;
|
in-out property <bool> update-open: root.update-available;
|
||||||
@@ -318,6 +319,13 @@ export component MainWindow inherits Window {
|
|||||||
root.height - root.titlebar-height - root.recent-tooltip-height - 8px,
|
root.height - root.titlebar-height - root.recent-tooltip-height - 8px,
|
||||||
max(8px, root.recent-tooltip-pointer-y - root.recent-tooltip-height - 8px));
|
max(8px, root.recent-tooltip-pointer-y - root.recent-tooltip-height - 8px));
|
||||||
|
|
||||||
|
changed settings-open => {
|
||||||
|
if root.settings-open {
|
||||||
|
root.settings-scroll-y = 0px;
|
||||||
|
focus-sink.focus();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
reset-remote-id => {
|
reset-remote-id => {
|
||||||
root.remote-id-input = "";
|
root.remote-id-input = "";
|
||||||
remote-id-editor.focus();
|
remote-id-editor.focus();
|
||||||
@@ -1388,9 +1396,9 @@ export component MainWindow inherits Window {
|
|||||||
TouchArea { clicked => { focus-sink.focus(); } }
|
TouchArea { clicked => { focus-sink.focus(); } }
|
||||||
DialogSurface {
|
DialogSurface {
|
||||||
x: root.compact-language ? 219px : 190px;
|
x: root.compact-language ? 219px : 190px;
|
||||||
y: 9px;
|
y: 60px;
|
||||||
width: root.compact-language ? 202px : 269px;
|
width: root.compact-language ? 202px : 269px;
|
||||||
height: 432px;
|
height: 330px;
|
||||||
border-radius: 7px;
|
border-radius: 7px;
|
||||||
|
|
||||||
Rectangle {
|
Rectangle {
|
||||||
@@ -1405,55 +1413,86 @@ export component MainWindow inherits Window {
|
|||||||
Text { x: 6px; text: UiStrings.settings; font-size: ImGuiFontStyle.base; font-weight: 600; color: #202124; vertical-alignment: center; }
|
Text { x: 6px; text: UiStrings.settings; font-size: ImGuiFontStyle.base; font-weight: 600; color: #202124; vertical-alignment: center; }
|
||||||
}
|
}
|
||||||
|
|
||||||
Text { x: 8px; y: 31px; width: root.compact-language ? 108px : 176px; height: 24px; text: UiStrings.language; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
settings-scroll := ScrollView {
|
||||||
CompactComboBox { x: root.compact-language ? 120px : 188px; y: 30px; model: ["中文", "English", "Русский"]; current-index <=> root.language-index; }
|
x: 0px;
|
||||||
Rectangle { x: 7px; y: 57px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
y: 21px;
|
||||||
|
width: parent.width;
|
||||||
|
height: 265px;
|
||||||
|
viewport-y <=> root.settings-scroll-y;
|
||||||
|
|
||||||
Text { x: 8px; y: 61px; width: root.compact-language ? 108px : 176px; height: 24px; text: UiStrings.video-quality; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
settings-content := VerticalLayout {
|
||||||
CompactComboBox { x: root.compact-language ? 120px : 188px; y: 60px; enabled: !root.settings-session-active; model: [UiStrings.quality-low, UiStrings.quality-medium, UiStrings.quality-high]; current-index <=> root.video-quality-index; }
|
// Reserve space for the overlaid vertical scrollbar.
|
||||||
Rectangle { x: 7px; y: 87px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
width: settings-scroll.width;
|
||||||
|
padding-top: 8px;
|
||||||
|
padding-bottom: 8px;
|
||||||
|
spacing: 0px;
|
||||||
|
|
||||||
Text { x: 8px; y: 91px; width: root.compact-language ? 108px : 176px; height: 24px; text: UiStrings.frame-rate; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
Rectangle {
|
||||||
CompactComboBox { x: root.compact-language ? 120px : 188px; y: 90px; enabled: !root.settings-session-active; model: ["30 fps", "60 fps"]; current-index <=> root.frame-rate-index; }
|
height: 30px;
|
||||||
Rectangle { x: 7px; y: 117px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
Text { x: 8px; y: 3px; width: root.compact-language ? 94px : 162px; height: 24px; text: UiStrings.language; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
CompactComboBox { x: root.compact-language ? 106px : 174px; y: 2px; model: ["中文", "English", "Русский"]; current-index <=> root.language-index; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 94px : 162px; height: 24px; text: UiStrings.video-quality; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
CompactComboBox { x: root.compact-language ? 106px : 174px; y: 2px; enabled: !root.settings-session-active; model: [UiStrings.quality-low, UiStrings.quality-medium, UiStrings.quality-high]; current-index <=> root.video-quality-index; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 94px : 162px; height: 24px; text: UiStrings.frame-rate; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
CompactComboBox { x: root.compact-language ? 106px : 174px; y: 2px; enabled: !root.settings-session-active; model: ["30 fps", "60 fps"]; current-index <=> root.frame-rate-index; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 94px : 162px; height: 24px; text: UiStrings.codec; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
CompactComboBox { x: root.compact-language ? 106px : 174px; y: 2px; enabled: !root.settings-session-active; model: [UiStrings.codec-h264, UiStrings.codec-av1]; current-index <=> root.codec-index; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.hardware-codec; color: root.hardware-codec-available ? #202124 : #8b8f95; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.hardware-codec-enabled; enabled: root.hardware-codec-available && !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.turn-relay; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.turn-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.srtp; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.srtp-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
CompactButton { x: 8px; y: 3px; width: root.compact-language ? 70px : 206px; text: UiStrings.self-hosted; enabled: !root.settings-session-active; clicked => { root.self-host-settings-open = true; } }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.self-hosted-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.autostart; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.autostart-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.daemon; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.daemon-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 145px : 212px; height: 24px; text: UiStrings.minimize-to-tray; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
ImGuiCheckBox { x: root.compact-language ? 157px : 224px; y: 3px; checked <=> root.minimize-to-tray-enabled; enabled: !root.settings-session-active; }
|
||||||
|
}
|
||||||
|
Rectangle {
|
||||||
|
height: 30px;
|
||||||
|
Text { x: 8px; y: 3px; width: root.compact-language ? 94px : 154px; height: 24px; text: UiStrings.file-save-path; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
|
CompactButton { x: root.compact-language ? 106px : 166px; y: 3px; width: root.compact-language ? 73px : 80px; text: root.file-save-path == "" ? UiStrings.default-desktop : root.file-save-path; enabled: !root.settings-session-active; clicked => { root.browse-save-path(); } }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
Text { x: 8px; y: 121px; width: root.compact-language ? 108px : 176px; height: 24px; text: UiStrings.codec; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
Rectangle { x: 7px; y: 286px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
||||||
CompactComboBox { x: root.compact-language ? 120px : 188px; y: 120px; enabled: !root.settings-session-active; model: [UiStrings.codec-h264, UiStrings.codec-av1]; current-index <=> root.codec-index; }
|
CompactButton { x: root.compact-language ? 63px : 89px; y: 297px; primary: true; text: UiStrings.ok; clicked => { root.save-settings(); root.settings-open = false; root.self-host-settings-open = false; } }
|
||||||
Rectangle { x: 7px; y: 147px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
CompactButton { x: root.compact-language ? 104px : 130px; y: 297px; width: root.compact-language ? 34px : 56px; text: UiStrings.cancel; clicked => { root.cancel-settings(); root.settings-open = false; root.self-host-settings-open = false; } }
|
||||||
|
|
||||||
Text { x: 8px; y: 151px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.hardware-codec; color: root.hardware-codec-available ? #202124 : #8b8f95; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 151px; checked <=> root.hardware-codec-enabled; enabled: root.hardware-codec-available && !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 177px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 181px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.turn-relay; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 181px; checked <=> root.turn-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 207px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 211px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.srtp; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 211px; checked <=> root.srtp-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 237px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
CompactButton { x: 8px; y: 241px; width: root.compact-language ? 70px : 220px; text: UiStrings.self-hosted; enabled: !root.settings-session-active; clicked => { root.self-host-settings-open = true; } }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 241px; checked <=> root.self-hosted-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 267px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 271px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.autostart; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 271px; checked <=> root.autostart-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 297px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 301px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.daemon; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 301px; checked <=> root.daemon-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 327px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 331px; width: root.compact-language ? 155px : 225px; height: 24px; text: UiStrings.minimize-to-tray; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
ImGuiCheckBox { x: root.compact-language ? 171px : 238px; y: 331px; checked <=> root.minimize-to-tray-enabled; enabled: !root.settings-session-active; }
|
|
||||||
Rectangle { x: 7px; y: 357px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
|
|
||||||
Text { x: 8px; y: 361px; width: root.compact-language ? 108px : 168px; height: 24px; text: UiStrings.file-save-path; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
|
||||||
CompactButton { x: root.compact-language ? 120px : 180px; y: 361px; width: root.compact-language ? 73px : 80px; text: root.file-save-path == "" ? UiStrings.default-desktop : root.file-save-path; enabled: !root.settings-session-active; clicked => { root.browse-save-path(); } }
|
|
||||||
|
|
||||||
CompactButton { x: root.compact-language ? 63px : 89px; y: 396px; primary: true; text: UiStrings.ok; clicked => { root.save-settings(); root.settings-open = false; root.self-host-settings-open = false; } }
|
|
||||||
CompactButton { x: root.compact-language ? 104px : 130px; y: 396px; width: root.compact-language ? 34px : 56px; text: UiStrings.cancel; clicked => { root.cancel-settings(); root.settings-open = false; root.self-host-settings-open = false; } }
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1492,7 +1531,6 @@ export component MainWindow inherits Window {
|
|||||||
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.server-host; font-size: ImGuiFontStyle.body; }
|
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.server-host; font-size: ImGuiFontStyle.body; }
|
||||||
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
||||||
}
|
}
|
||||||
Rectangle { x: 7px; y: 57px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
Text { x: 8px; y: 61px; width: root.compact-language ? 88px : 165px; height: 24px; text: UiStrings.server-port; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
Text { x: 8px; y: 61px; width: root.compact-language ? 88px : 165px; height: 24px; text: UiStrings.server-port; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
Rectangle {
|
Rectangle {
|
||||||
x: root.compact-language ? 100px : 173px;
|
x: root.compact-language ? 100px : 173px;
|
||||||
@@ -1506,7 +1544,6 @@ export component MainWindow inherits Window {
|
|||||||
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.server-port; input-type: InputType.number; font-size: ImGuiFontStyle.body; }
|
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.server-port; input-type: InputType.number; font-size: ImGuiFontStyle.body; }
|
||||||
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
||||||
}
|
}
|
||||||
Rectangle { x: 7px; y: 87px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
Text { x: 8px; y: 91px; width: root.compact-language ? 88px : 165px; height: 24px; text: UiStrings.coturn-port; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
Text { x: 8px; y: 91px; width: root.compact-language ? 88px : 165px; height: 24px; text: UiStrings.coturn-port; font-size: ImGuiFontStyle.body; overflow: elide; vertical-alignment: center; }
|
||||||
Rectangle {
|
Rectangle {
|
||||||
x: root.compact-language ? 100px : 173px;
|
x: root.compact-language ? 100px : 173px;
|
||||||
@@ -1520,7 +1557,6 @@ export component MainWindow inherits Window {
|
|||||||
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.coturn-port; input-type: InputType.number; font-size: ImGuiFontStyle.body; }
|
LineEdit { x: 1px; y: 1.5px; width: parent.width - 2px; height: parent.height - 2px; text <=> root.coturn-port; input-type: InputType.number; font-size: ImGuiFontStyle.body; }
|
||||||
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
LineEditFocusUnderlineMask { x: 5px; y: parent.height - 3px; width: parent.width - 10px; }
|
||||||
}
|
}
|
||||||
Rectangle { x: 7px; y: 117px; width: parent.width - 14px; height: 1px; background: ImGuiLineStyle.separator; }
|
|
||||||
CompactButton { x: root.compact-language ? 93px : 135px; y: 130px; primary: true; text: UiStrings.ok; clicked => { root.save-self-hosted-settings(); root.self-host-settings-open = false; } }
|
CompactButton { x: root.compact-language ? 93px : 135px; y: 130px; primary: true; text: UiStrings.ok; clicked => { root.save-self-hosted-settings(); root.self-host-settings-open = false; } }
|
||||||
CompactButton { x: root.compact-language ? 134px : 176px; y: 130px; width: root.compact-language ? 34px : 56px; text: UiStrings.cancel; clicked => { root.cancel-self-hosted-settings(); root.self-host-settings-open = false; } }
|
CompactButton { x: root.compact-language ? 134px : 176px; y: 130px; width: root.compact-language ? 34px : 56px; text: UiStrings.cancel; clicked => { root.cancel-self-hosted-settings(); root.self-host-settings-open = false; } }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -508,7 +508,10 @@ export component StreamWindow inherits Window {
|
|||||||
&& (event.kind == PointerEventKind.up
|
&& (event.kind == PointerEventKind.up
|
||||||
|| event.kind == PointerEventKind.cancel) {
|
|| event.kind == PointerEventKind.cancel) {
|
||||||
root.end-control-drag();
|
root.end-control-drag();
|
||||||
} else if !root.control-dragging {
|
// The control bar overlays the remote video. Events in
|
||||||
|
// its full rectangle (including gaps between buttons)
|
||||||
|
// are local UI input and must never reach the peer.
|
||||||
|
} else if !root.control-dragging && !over-control {
|
||||||
root.pointer-input(event.button, event.kind, self.mouse-x, self.mouse-y);
|
root.pointer-input(event.button, event.kind, self.mouse-x, self.mouse-y);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
Submodule submodules/minirtc updated: da4b0f2e9a...e6d796d7b7
@@ -19,7 +19,7 @@ std::filesystem::path FindRepoRoot() {
|
|||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
|
|
||||||
std::string ReadFile(const std::filesystem::path &path) {
|
std::string ReadFile(const std::filesystem::path& path) {
|
||||||
std::ifstream file(path, std::ios::binary);
|
std::ifstream file(path, std::ios::binary);
|
||||||
if (!file) {
|
if (!file) {
|
||||||
return {};
|
return {};
|
||||||
@@ -30,8 +30,8 @@ std::string ReadFile(const std::filesystem::path &path) {
|
|||||||
return stream.str();
|
return stream.str();
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ExpectContains(const char *name, const std::string &value,
|
bool ExpectContains(const char* name, const std::string& value,
|
||||||
const std::string &expected) {
|
const std::string& expected) {
|
||||||
if (value.find(expected) != std::string::npos) {
|
if (value.find(expected) != std::string::npos) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@@ -40,8 +40,8 @@ bool ExpectContains(const char *name, const std::string &value,
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ExpectNotContains(const char *name, const std::string &value,
|
bool ExpectNotContains(const char* name, const std::string& value,
|
||||||
const std::string &unexpected) {
|
const std::string& unexpected) {
|
||||||
if (value.find(unexpected) == std::string::npos) {
|
if (value.find(unexpected) == std::string::npos) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@@ -73,6 +73,10 @@ int main() {
|
|||||||
ReadFile(repo_root / "src/gui/runtime/remote_session.h");
|
ReadFile(repo_root / "src/gui/runtime/remote_session.h");
|
||||||
const std::string connection_runtime_cpp =
|
const std::string connection_runtime_cpp =
|
||||||
ReadFile(repo_root / "src/gui/runtime/connection_runtime.cpp");
|
ReadFile(repo_root / "src/gui/runtime/connection_runtime.cpp");
|
||||||
|
const std::string peer_event_handler_cpp =
|
||||||
|
ReadFile(repo_root / "src/gui/runtime/peer_event_handler.cpp");
|
||||||
|
const std::string application_state_h =
|
||||||
|
ReadFile(repo_root / "src/gui/application/application_state.h");
|
||||||
|
|
||||||
bool ok = true;
|
bool ok = true;
|
||||||
ok &= ExpectContains("minirtc.h", minirtc_api, "RemoteUnavailable");
|
ok &= ExpectContains("minirtc.h", minirtc_api, "RemoteUnavailable");
|
||||||
@@ -81,6 +85,11 @@ int main() {
|
|||||||
"\"Remote unavailable\"");
|
"\"Remote unavailable\"");
|
||||||
ok &= ExpectContains("peer_connection.cpp", peer_connection,
|
ok &= ExpectContains("peer_connection.cpp", peer_connection,
|
||||||
"ConnectionStatus::RemoteUnavailable");
|
"ConnectionStatus::RemoteUnavailable");
|
||||||
|
ok &= ExpectContains("peer_connection.cpp", peer_connection,
|
||||||
|
"IsCurrentPeerConnection");
|
||||||
|
ok &= ExpectContains(
|
||||||
|
"peer_connection.cpp", peer_connection,
|
||||||
|
"on_connection_status_(ConnectionStatus::Closed, remote_user_id.data()");
|
||||||
ok &= ExpectNotContains("peer_connection.cpp", peer_connection,
|
ok &= ExpectNotContains("peer_connection.cpp", peer_connection,
|
||||||
"\"Device offline\"");
|
"\"Device offline\"");
|
||||||
ok &= ExpectNotContains("peer_connection.cpp", peer_connection,
|
ok &= ExpectNotContains("peer_connection.cpp", peer_connection,
|
||||||
@@ -105,6 +114,14 @@ int main() {
|
|||||||
"kConnectionAttemptTimeout");
|
"kConnectionAttemptTimeout");
|
||||||
ok &= ExpectContains("connection_runtime.cpp", connection_runtime_cpp,
|
ok &= ExpectContains("connection_runtime.cpp", connection_runtime_cpp,
|
||||||
"connection_attempt_started_at_");
|
"connection_attempt_started_at_");
|
||||||
|
ok &= ExpectContains("connection_runtime.cpp", connection_runtime_cpp,
|
||||||
|
"HandleServerControllerDisconnected");
|
||||||
|
ok &= ExpectContains("peer_event_handler.cpp", peer_event_handler_cpp,
|
||||||
|
"HandleServerControllerDisconnected(remote_id");
|
||||||
|
ok &= ExpectNotContains("connection_runtime.cpp", connection_runtime_cpp,
|
||||||
|
"ControllerHeartbeat");
|
||||||
|
ok &= ExpectContains("application_state.h", application_state_h,
|
||||||
|
"std::atomic<bool> need_to_destroy_server_window_");
|
||||||
|
|
||||||
return ok ? 0 : 1;
|
return ok ? 0 : 1;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ std::filesystem::path FindRepoRoot() {
|
|||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
|
|
||||||
std::string ReadFile(const std::filesystem::path &path) {
|
std::string ReadFile(const std::filesystem::path& path) {
|
||||||
std::ifstream file(path, std::ios::binary);
|
std::ifstream file(path, std::ios::binary);
|
||||||
if (!file) {
|
if (!file) {
|
||||||
return {};
|
return {};
|
||||||
@@ -28,8 +28,8 @@ std::string ReadFile(const std::filesystem::path &path) {
|
|||||||
return stream.str();
|
return stream.str();
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ExpectContains(const char *name, const std::string &value,
|
bool ExpectContains(const char* name, const std::string& value,
|
||||||
const std::string &expected) {
|
const std::string& expected) {
|
||||||
if (value.find(expected) != std::string::npos) {
|
if (value.find(expected) != std::string::npos) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@@ -37,8 +37,8 @@ bool ExpectContains(const char *name, const std::string &value,
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ExpectNotContains(const char *name, const std::string &value,
|
bool ExpectNotContains(const char* name, const std::string& value,
|
||||||
const std::string &unexpected) {
|
const std::string& unexpected) {
|
||||||
if (value.find(unexpected) == std::string::npos) {
|
if (value.find(unexpected) == std::string::npos) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@@ -46,8 +46,8 @@ bool ExpectNotContains(const char *name, const std::string &value,
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ExpectContainsAtLeast(const char *name, const std::string &value,
|
bool ExpectContainsAtLeast(const char* name, const std::string& value,
|
||||||
const std::string &expected, size_t min_count) {
|
const std::string& expected, size_t min_count) {
|
||||||
size_t count = 0;
|
size_t count = 0;
|
||||||
size_t pos = 0;
|
size_t pos = 0;
|
||||||
while ((pos = value.find(expected, pos)) != std::string::npos) {
|
while ((pos = value.find(expected, pos)) != std::string::npos) {
|
||||||
@@ -84,14 +84,16 @@ int main() {
|
|||||||
"root.shortcut-menu-open = false;");
|
"root.shortcut-menu-open = false;");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"if root.display-menu-open: Rectangle");
|
"if root.display-menu-open: Rectangle");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &=
|
||||||
"display-touch.has-hover");
|
ExpectContains("stream_window.slint", stream, "display-touch.has-hover");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"root.switch-display(index)");
|
"root.switch-display(index)");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"if root.shortcut-menu-open: Rectangle");
|
"if root.shortcut-menu-open: Rectangle");
|
||||||
|
ok &=
|
||||||
|
ExpectContains("stream_window.slint", stream, "shortcut-touch.has-hover");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"shortcut-touch.has-hover");
|
"} else if !root.control-dragging && !over-control {");
|
||||||
|
|
||||||
ok &= ExpectContains("common.slint", common,
|
ok &= ExpectContains("common.slint", common,
|
||||||
"if touch.has-hover && root.tooltip != \"\": Rectangle");
|
"if touch.has-hover && root.tooltip != \"\": Rectangle");
|
||||||
@@ -100,32 +102,38 @@ int main() {
|
|||||||
"tooltip: StreamStrings.select-display");
|
"tooltip: StreamStrings.select-display");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"tooltip: StreamStrings.send-shortcut");
|
"tooltip: StreamStrings.send-shortcut");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &=
|
||||||
"root.mouse-control-enabled ? StreamStrings.release-mouse : StreamStrings.control-mouse");
|
ExpectContains("stream_window.slint", stream,
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
"root.mouse-control-enabled ? StreamStrings.release-mouse "
|
||||||
|
": StreamStrings.control-mouse");
|
||||||
|
ok &= ExpectContains(
|
||||||
|
"stream_window.slint", stream,
|
||||||
"root.audio-enabled ? StreamStrings.mute : StreamStrings.audio");
|
"root.audio-enabled ? StreamStrings.mute : StreamStrings.audio");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"tooltip: StreamStrings.select-file");
|
"tooltip: StreamStrings.select-file");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"root.stats-visible ? StreamStrings.hide-stats : StreamStrings.show-stats");
|
"root.stats-visible ? StreamStrings.hide-stats : "
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
"StreamStrings.show-stats");
|
||||||
"root.fullscreen-enabled ? StreamStrings.exit-fullscreen : StreamStrings.fullscreen");
|
ok &=
|
||||||
|
ExpectContains("stream_window.slint", stream,
|
||||||
|
"root.fullscreen-enabled ? StreamStrings.exit-fullscreen "
|
||||||
|
": StreamStrings.fullscreen");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"tooltip: StreamStrings.disconnect");
|
"tooltip: StreamStrings.disconnect");
|
||||||
ok &= ExpectContains("stream_window.slint", stream,
|
ok &= ExpectContains("stream_window.slint", stream,
|
||||||
"root.control-expanded ? StreamStrings.collapse-control : StreamStrings.expand-control");
|
"root.control-expanded ? StreamStrings.collapse-control "
|
||||||
|
": StreamStrings.expand-control");
|
||||||
|
|
||||||
ok &= ExpectContains("gui_application.cpp", application,
|
ok &=
|
||||||
"set_select_display(");
|
ExpectContains("gui_application.cpp", application, "set_select_display(");
|
||||||
ok &= ExpectContains("gui_application.cpp", application,
|
ok &= ExpectContains("gui_application.cpp", application, "set_show_stats(");
|
||||||
"set_show_stats(");
|
ok &=
|
||||||
ok &= ExpectContains("gui_application.cpp", application,
|
ExpectContains("gui_application.cpp", application, "set_expand_control(");
|
||||||
"set_expand_control(");
|
|
||||||
ok &= ExpectContains("gui_application.cpp", application,
|
ok &= ExpectContains("gui_application.cpp", application,
|
||||||
"set_collapse_control(");
|
"set_collapse_control(");
|
||||||
ok &= ExpectContains("gui_application.cpp", application,
|
ok &= ExpectContains("gui_application.cpp", application,
|
||||||
"(*ui_->stream)->global<ui::StreamStrings>()");
|
"(*ui_->stream)->global<ui::StreamStrings>()");
|
||||||
ok &= ExpectNotContains("gui_application.cpp", application,
|
ok &=
|
||||||
"#include <imgui");
|
ExpectNotContains("gui_application.cpp", application, "#include <imgui");
|
||||||
return ok ? 0 : 1;
|
return ok ? 0 : 1;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -90,6 +90,20 @@ int main() {
|
|||||||
window->set_about_open(true);
|
window->set_about_open(true);
|
||||||
assert(window->get_settings_open());
|
assert(window->get_settings_open());
|
||||||
assert(window->get_about_open());
|
assert(window->get_about_open());
|
||||||
|
if (const char *snapshot_path =
|
||||||
|
std::getenv("CROSSDESK_SETTINGS_UI_SNAPSHOT")) {
|
||||||
|
window->set_about_open(false);
|
||||||
|
window->set_connection_dialog_open(false);
|
||||||
|
window->show();
|
||||||
|
const bool snapshot_written =
|
||||||
|
WriteWindowSnapshot(window->window(), snapshot_path);
|
||||||
|
window->hide();
|
||||||
|
if (!snapshot_written) {
|
||||||
|
return 6;
|
||||||
|
}
|
||||||
|
window->set_connection_dialog_open(true);
|
||||||
|
window->set_about_open(true);
|
||||||
|
}
|
||||||
window->set_remote_id_input("987654321");
|
window->set_remote_id_input("987654321");
|
||||||
window->invoke_reset_remote_id();
|
window->invoke_reset_remote_id();
|
||||||
assert(std::string(window->get_remote_id_input()).empty());
|
assert(std::string(window->get_remote_id_input()).empty());
|
||||||
|
|||||||
Reference in New Issue
Block a user