ank/cruisecontrol
1
Fork 0
Code Issues Activity

run auto (it crashes)

Browse source
This commit is contained in:
Andy Killorin 2025-03-27 19:45:47 -04:00
parent 1e1a82830b
commit 9a68f43e5d
Signed by: ank
GPG key ID: 23F9463ECB67FE8C
1 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
interface/src/main.rs
View file

@ -100,8 +100,10 @@ fn main() -> Result<()> {
let spawner = executor.handle().clone(); let spawner = executor.handle().clone();
let auto_allowed_ = auto_allowed.clone(); let auto_allowed_ = auto_allowed.clone();
let interface_ = interface.clone();
thread::spawn(move || { thread::spawn(move || {
spawner.block_on(async { spawner.block_on(async {
let log_toasts = toast_sender.clone(); let log_toasts = toast_sender.clone();
tokio::spawn(async move { tokio::spawn(async move {
if let Err(e) = combat_logger(combatlog, directories.data_dir()).await { if let Err(e) = combat_logger(combatlog, directories.data_dir()).await {
@ -110,7 +112,7 @@ fn main() -> Result<()> {
}); });
loop { loop {
if let Err(e) = connect(toast_sender.clone(), notes.resubscribe(), data_sender.clone(), logging_sender.clone(), auto_telem_sender.clone(), auto_allowed_.clone(), interface.clone()).await { if let Err(e) = connect(toast_sender.clone(), notes.resubscribe(), data_sender.clone(), logging_sender.clone(), auto_telem_sender.clone(), auto_allowed_.clone(), interface_.clone()).await {
if let Err(_) = toast_sender.send(Toast::new().text(format!("{e:?}")).kind(ToastKind::Error)).await { if let Err(_) = toast_sender.send(Toast::new().text(format!("{e:?}")).kind(ToastKind::Error)).await {
break; break;
}; };
@ -120,6 +122,15 @@ fn main() -> Result<()> {
}); });
let interface_ = interface.clone();
let spawner = executor.handle().clone();
thread::spawn(move || {
spawner.block_on(async {
let _stoppie = auto.run(interface_).await.unwrap();
println!("auto ended");
});
});
println!("launching gui"); println!("launching gui");
let (_conf_sender, conf) = watch::channel(CONFIGS); let (_conf_sender, conf) = watch::channel(CONFIGS);
gui(gui_data, toasts, executor, conf, storage.clone(), auto_allowed, auto_enabled).unwrap(); gui(gui_data, toasts, executor, conf, storage.clone(), auto_allowed, auto_enabled).unwrap();