feat: Change App Name, add rust/set_foreground_window

This commit is contained in:
xkeyC 2024-04-28 21:50:36 +08:00
parent e9c494096f
commit c5549cf4c8
9 changed files with 160 additions and 39 deletions

View File

@ -23,6 +23,7 @@ import 'api/api.dart';
import 'common/helper/system_helper.dart'; import 'common/helper/system_helper.dart';
import 'common/io/rs_http.dart'; import 'common/io/rs_http.dart';
import 'common/rust/frb_generated.dart'; import 'common/rust/frb_generated.dart';
import 'common/rust/api/rs_process.dart' as rs_process;
import 'data/app_version_data.dart'; import 'data/app_version_data.dart';
import 'generated/no_l10n_strings.dart'; import 'generated/no_l10n_strings.dart';
import 'ui/home/downloader/home_downloader_ui.dart'; import 'ui/home/downloader/home_downloader_ui.dart';
@ -157,7 +158,9 @@ class AppGlobalModel extends _$AppGlobalModel {
} }
state = state.copyWith(deviceUUID: deviceUUID, appLocale: locale); state = state.copyWith(deviceUUID: deviceUUID, appLocale: locale);
} catch (e) { } catch (e) {
exit(1); await rs_process.setForegroundWindow(windowName: "SCToolBox");
dPrint("exit: db is locking ...");
exit(0);
} }
// init powershell // init powershell

View File

@ -23,6 +23,10 @@ Stream<RsProcessStreamData> start(
Future<void> write({required int rsPid, required String data, dynamic hint}) => Future<void> write({required int rsPid, required String data, dynamic hint}) =>
RustLib.instance.api.write(rsPid: rsPid, data: data, hint: hint); RustLib.instance.api.write(rsPid: rsPid, data: data, hint: hint);
Future<bool> setForegroundWindow({required String windowName, dynamic hint}) =>
RustLib.instance.api
.setForegroundWindow(windowName: windowName, hint: hint);
class RsProcessStreamData { class RsProcessStreamData {
final RsProcessStreamDataType dataType; final RsProcessStreamDataType dataType;
final String data; final String data;

View File

@ -57,7 +57,7 @@ class RustLib extends BaseEntrypoint<RustLibApi, RustLibApiImpl, RustLibWire> {
String get codegenVersion => '2.0.0-dev.32'; String get codegenVersion => '2.0.0-dev.32';
@override @override
int get rustContentHash => 1067953400; int get rustContentHash => -1186168522;
static const kDefaultExternalLibraryLoaderConfig = static const kDefaultExternalLibraryLoaderConfig =
ExternalLibraryLoaderConfig( ExternalLibraryLoaderConfig(
@ -90,6 +90,8 @@ abstract class RustLibApi extends BaseApi {
String? appId, String? appId,
dynamic hint}); dynamic hint});
Future<bool> setForegroundWindow({required String windowName, dynamic hint});
Stream<RsProcessStreamData> start( Stream<RsProcessStreamData> start(
{required String executable, {required String executable,
required List<String> arguments, required List<String> arguments,
@ -241,6 +243,29 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
argNames: ["summary", "body", "appName", "appId"], argNames: ["summary", "body", "appName", "appId"],
); );
@override
Future<bool> setForegroundWindow({required String windowName, dynamic hint}) {
return handler.executeNormal(NormalTask(
callFfi: (port_) {
var arg0 = cst_encode_String(windowName);
return wire.wire_set_foreground_window(port_, arg0);
},
codec: DcoCodec(
decodeSuccessData: dco_decode_bool,
decodeErrorData: dco_decode_AnyhowException,
),
constMeta: kSetForegroundWindowConstMeta,
argValues: [windowName],
apiImpl: this,
hint: hint,
));
}
TaskConstMeta get kSetForegroundWindowConstMeta => const TaskConstMeta(
debugName: "set_foreground_window",
argNames: ["windowName"],
);
@override @override
Stream<RsProcessStreamData> start( Stream<RsProcessStreamData> start(
{required String executable, {required String executable,
@ -323,6 +348,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
return raw as String; return raw as String;
} }
@protected
bool dco_decode_bool(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as bool;
}
@protected @protected
int dco_decode_box_autoadd_u_64(dynamic raw) { int dco_decode_box_autoadd_u_64(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs // Codec=Dco (DartCObject based), see doc to use other codecs
@ -498,6 +529,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
return utf8.decoder.convert(inner); return utf8.decoder.convert(inner);
} }
@protected
bool sse_decode_bool(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getUint8() != 0;
}
@protected @protected
int sse_decode_box_autoadd_u_64(SseDeserializer deserializer) { int sse_decode_box_autoadd_u_64(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Sse (Serialization based), see doc to use other codecs
@ -679,9 +716,9 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
} }
@protected @protected
bool sse_decode_bool(SseDeserializer deserializer) { bool cst_encode_bool(bool raw) {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Cst (C-struct based), see doc to use other codecs
return deserializer.buffer.getUint8() != 0; return raw;
} }
@protected @protected
@ -765,6 +802,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
sse_encode_list_prim_u_8_strict(utf8.encoder.convert(self), serializer); sse_encode_list_prim_u_8_strict(utf8.encoder.convert(self), serializer);
} }
@protected
void sse_encode_bool(bool self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putUint8(self ? 1 : 0);
}
@protected @protected
void sse_encode_box_autoadd_u_64(int self, SseSerializer serializer) { void sse_encode_box_autoadd_u_64(int self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Sse (Serialization based), see doc to use other codecs
@ -924,10 +967,4 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
void sse_encode_unit(void self, SseSerializer serializer) { void sse_encode_unit(void self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Sse (Serialization based), see doc to use other codecs
} }
@protected
void sse_encode_bool(bool self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putUint8(self ? 1 : 0);
}
} }

View File

@ -34,6 +34,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
@protected @protected
String dco_decode_String(dynamic raw); String dco_decode_String(dynamic raw);
@protected
bool dco_decode_bool(dynamic raw);
@protected @protected
int dco_decode_box_autoadd_u_64(dynamic raw); int dco_decode_box_autoadd_u_64(dynamic raw);
@ -109,6 +112,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
@protected @protected
String sse_decode_String(SseDeserializer deserializer); String sse_decode_String(SseDeserializer deserializer);
@protected
bool sse_decode_bool(SseDeserializer deserializer);
@protected @protected
int sse_decode_box_autoadd_u_64(SseDeserializer deserializer); int sse_decode_box_autoadd_u_64(SseDeserializer deserializer);
@ -174,9 +180,6 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
@protected @protected
void sse_decode_unit(SseDeserializer deserializer); void sse_decode_unit(SseDeserializer deserializer);
@protected
bool sse_decode_bool(SseDeserializer deserializer);
@protected @protected
ffi.Pointer<wire_cst_list_prim_u_8_strict> cst_encode_AnyhowException( ffi.Pointer<wire_cst_list_prim_u_8_strict> cst_encode_AnyhowException(
AnyhowException raw) { AnyhowException raw) {
@ -306,6 +309,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
wireObj.data = cst_encode_opt_list_prim_u_8_strict(apiObj.data); wireObj.data = cst_encode_opt_list_prim_u_8_strict(apiObj.data);
} }
@protected
bool cst_encode_bool(bool raw);
@protected @protected
int cst_encode_i_32(int raw); int cst_encode_i_32(int raw);
@ -345,6 +351,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
@protected @protected
void sse_encode_String(String self, SseSerializer serializer); void sse_encode_String(String self, SseSerializer serializer);
@protected
void sse_encode_bool(bool self, SseSerializer serializer);
@protected @protected
void sse_encode_box_autoadd_u_64(int self, SseSerializer serializer); void sse_encode_box_autoadd_u_64(int self, SseSerializer serializer);
@ -412,9 +421,6 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
@protected @protected
void sse_encode_unit(void self, SseSerializer serializer); void sse_encode_unit(void self, SseSerializer serializer);
@protected
void sse_encode_bool(bool self, SseSerializer serializer);
} }
// Section: wire_class // Section: wire_class
@ -582,6 +588,25 @@ class RustLibWire implements BaseWire {
ffi.Pointer<wire_cst_list_prim_u_8_strict>, ffi.Pointer<wire_cst_list_prim_u_8_strict>,
ffi.Pointer<wire_cst_list_prim_u_8_strict>)>(); ffi.Pointer<wire_cst_list_prim_u_8_strict>)>();
void wire_set_foreground_window(
int port_,
ffi.Pointer<wire_cst_list_prim_u_8_strict> window_name,
) {
return _wire_set_foreground_window(
port_,
window_name,
);
}
late final _wire_set_foreground_windowPtr = _lookup<
ffi.NativeFunction<
ffi.Void Function(
ffi.Int64, ffi.Pointer<wire_cst_list_prim_u_8_strict>)>>(
'frbgen_starcitizen_doctor_wire_set_foreground_window');
late final _wire_set_foreground_window =
_wire_set_foreground_windowPtr.asFunction<
void Function(int, ffi.Pointer<wire_cst_list_prim_u_8_strict>)>();
void wire_start( void wire_start(
int port_, int port_,
ffi.Pointer<wire_cst_list_prim_u_8_strict> executable, ffi.Pointer<wire_cst_list_prim_u_8_strict> executable,

View File

@ -22,4 +22,5 @@ anyhow = "1.0"
win32job = "2" win32job = "2"
lazy_static = "1.4" lazy_static = "1.4"
scopeguard = "1.2" scopeguard = "1.2"
notify-rust = "4" notify-rust = "4"
windows = { version = "0.56.0", features = ["Win32_System_Services", "Win32_UI_WindowsAndMessaging"] }

View File

@ -1,7 +1,7 @@
use std::collections::HashMap; use std::collections::HashMap;
use std::sync::Arc; use std::sync::Arc;
use async_std::task::block_on;
use async_std::task::block_on;
use lazy_static::lazy_static; use lazy_static::lazy_static;
use scopeguard::defer; use scopeguard::defer;
use tokio::io::AsyncBufReadExt; use tokio::io::AsyncBufReadExt;
@ -9,6 +9,9 @@ use tokio::io::AsyncWriteExt;
use tokio::io::BufReader; use tokio::io::BufReader;
use tokio::process::ChildStdin; use tokio::process::ChildStdin;
use tokio::sync::Mutex; use tokio::sync::Mutex;
use windows::core::{HSTRING, PCWSTR};
use windows::Win32::Foundation::HWND;
use windows::Win32::UI::WindowsAndMessaging;
use crate::frb_generated::StreamSink; use crate::frb_generated::StreamSink;
@ -35,9 +38,9 @@ lazy_static! {
} }
pub async fn start( pub async fn start(
executable: String, executable: &str,
arguments: Vec<String>, arguments: Vec<String>,
working_directory: String, working_directory: &str,
stream_sink: StreamSink<RsProcessStreamData>, stream_sink: StreamSink<RsProcessStreamData>,
) { ) {
let stream_sink_arc = Arc::from(stream_sink); let stream_sink_arc = Arc::from(stream_sink);
@ -161,3 +164,17 @@ async fn _process_output<R>(
stream_sink.add(message).unwrap(); stream_sink.add(message).unwrap();
} }
} }
pub fn set_foreground_window(window_name: &str) -> anyhow::Result<bool> {
let window_name_p: PCWSTR = PCWSTR(HSTRING::from(window_name).as_ptr());
let h = unsafe { WindowsAndMessaging::FindWindowW(PCWSTR::null(), window_name_p) };
if h == HWND::default() {
return Ok(false);
}
let sr = unsafe { WindowsAndMessaging::ShowWindow(h, WindowsAndMessaging::SW_RESTORE) };
if !sr.as_bool() {
return Ok(false);
}
let r = unsafe { WindowsAndMessaging::SetForegroundWindow(h) };
Ok(r.as_bool())
}

View File

@ -215,6 +215,14 @@ pub extern "C" fn frbgen_starcitizen_doctor_wire_send_notify(
wire_send_notify_impl(port_, summary, body, app_name, app_id) wire_send_notify_impl(port_, summary, body, app_name, app_id)
} }
#[no_mangle]
pub extern "C" fn frbgen_starcitizen_doctor_wire_set_foreground_window(
port_: i64,
window_name: *mut wire_cst_list_prim_u_8_strict,
) {
wire_set_foreground_window_impl(port_, window_name)
}
#[no_mangle] #[no_mangle]
pub extern "C" fn frbgen_starcitizen_doctor_wire_start( pub extern "C" fn frbgen_starcitizen_doctor_wire_start(
port_: i64, port_: i64,

View File

@ -31,7 +31,7 @@ flutter_rust_bridge::frb_generated_boilerplate!(
default_rust_auto_opaque = RustAutoOpaqueNom, default_rust_auto_opaque = RustAutoOpaqueNom,
); );
pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_VERSION: &str = "2.0.0-dev.32"; pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_VERSION: &str = "2.0.0-dev.32";
pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_CONTENT_HASH: i32 = 1067953400; pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_CONTENT_HASH: i32 = -1186168522;
// Section: executor // Section: executor
@ -170,6 +170,26 @@ fn wire_send_notify_impl(
}, },
) )
} }
fn wire_set_foreground_window_impl(
port_: flutter_rust_bridge::for_generated::MessagePort,
window_name: impl CstDecode<String>,
) {
FLUTTER_RUST_BRIDGE_HANDLER.wrap_normal::<flutter_rust_bridge::for_generated::DcoCodec, _, _>(
flutter_rust_bridge::for_generated::TaskInfo {
debug_name: "set_foreground_window",
port: Some(port_),
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
},
move || {
let api_window_name = window_name.cst_decode();
move |context| {
transform_result_dco((move || {
crate::api::rs_process::set_foreground_window(&api_window_name)
})())
}
},
)
}
fn wire_start_impl( fn wire_start_impl(
port_: flutter_rust_bridge::for_generated::MessagePort, port_: flutter_rust_bridge::for_generated::MessagePort,
executable: impl CstDecode<String>, executable: impl CstDecode<String>,
@ -198,9 +218,9 @@ fn wire_start_impl(
(move || async move { (move || async move {
Result::<_, ()>::Ok( Result::<_, ()>::Ok(
crate::api::rs_process::start( crate::api::rs_process::start(
api_executable, &api_executable,
api_arguments, api_arguments,
api_working_directory, &api_working_directory,
api_stream_sink, api_stream_sink,
) )
.await, .await,
@ -242,6 +262,12 @@ fn wire_write_impl(
// Section: dart2rust // Section: dart2rust
impl CstDecode<bool> for bool {
// Codec=Cst (C-struct based), see doc to use other codecs
fn cst_decode(self) -> bool {
self
}
}
impl CstDecode<i32> for i32 { impl CstDecode<i32> for i32 {
// Codec=Cst (C-struct based), see doc to use other codecs // Codec=Cst (C-struct based), see doc to use other codecs
fn cst_decode(self) -> i32 { fn cst_decode(self) -> i32 {
@ -350,6 +376,13 @@ impl SseDecode for String {
} }
} }
impl SseDecode for bool {
// Codec=Sse (Serialization based), see doc to use other codecs
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
deserializer.cursor.read_u8().unwrap() != 0
}
}
impl SseDecode for i32 { impl SseDecode for i32 {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Sse (Serialization based), see doc to use other codecs
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
@ -566,13 +599,6 @@ impl SseDecode for () {
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {} fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {}
} }
impl SseDecode for bool {
// Codec=Sse (Serialization based), see doc to use other codecs
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
deserializer.cursor.read_u8().unwrap() != 0
}
}
fn pde_ffi_dispatcher_primary_impl( fn pde_ffi_dispatcher_primary_impl(
func_id: i32, func_id: i32,
port: flutter_rust_bridge::for_generated::MessagePort, port: flutter_rust_bridge::for_generated::MessagePort,
@ -754,6 +780,13 @@ impl SseEncode for String {
} }
} }
impl SseEncode for bool {
// Codec=Sse (Serialization based), see doc to use other codecs
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
serializer.cursor.write_u8(self as _).unwrap();
}
}
impl SseEncode for i32 { impl SseEncode for i32 {
// Codec=Sse (Serialization based), see doc to use other codecs // Codec=Sse (Serialization based), see doc to use other codecs
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
@ -954,13 +987,6 @@ impl SseEncode for () {
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {} fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
} }
impl SseEncode for bool {
// Codec=Sse (Serialization based), see doc to use other codecs
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
serializer.cursor.write_u8(self as _).unwrap();
}
}
#[cfg(not(target_family = "wasm"))] #[cfg(not(target_family = "wasm"))]
#[path = "frb_generated.io.rs"] #[path = "frb_generated.io.rs"]
mod io; mod io;

View File

@ -27,7 +27,7 @@ int APIENTRY wWinMain(_In_ HINSTANCE instance, _In_opt_ HINSTANCE prev,
FlutterWindow window(project); FlutterWindow window(project);
Win32Window::Point origin(0, 0); Win32Window::Point origin(0, 0);
Win32Window::Size size(1280, 720); Win32Window::Size size(1280, 720);
if (!window.Create(L"starcitizen_doctor", origin, size)) { if (!window.Create(L"SCToolBox", origin, size)) {
return EXIT_FAILURE; return EXIT_FAILURE;
} }
window.SetQuitOnClose(true); window.SetQuitOnClose(true);