daemonise
This commit is contained in:
parent
5b19c92bfc
commit
af060b8d40
|
|
@ -1,12 +1,10 @@
|
|||
use clap::{Parser, Subcommand};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use std::{io::BufRead, path::PathBuf};
|
||||
use std::{path::PathBuf, time::Duration};
|
||||
use teslatte::{
|
||||
auth::{AccessToken, RefreshToken},
|
||||
vehicles::{ActuateTrunk, SetChargingAmps},
|
||||
FleetApi, FleetVehicleApi,
|
||||
};
|
||||
use tokio::try_join;
|
||||
|
||||
use crate::{config::Config, errors::*};
|
||||
|
||||
|
|
@ -25,54 +23,9 @@ struct Args {
|
|||
#[derive(Subcommand, Debug, Clone)]
|
||||
enum Commands {
|
||||
/// Run charge controller server
|
||||
Watch {
|
||||
#[clap(long)]
|
||||
flash: bool,
|
||||
},
|
||||
/// Run charge controller server
|
||||
SetChargeRate {
|
||||
#[clap(long)]
|
||||
amps: usize,
|
||||
},
|
||||
Watch,
|
||||
/// Print the default config file
|
||||
GenerateConfig,
|
||||
/// Start charging
|
||||
StartCharge,
|
||||
/// Stop charging
|
||||
StopCharge,
|
||||
/// Toggle boot
|
||||
ToggleBoot,
|
||||
/// Open charger door
|
||||
ChargerOpen,
|
||||
/// Close charger door
|
||||
ChargerClose,
|
||||
}
|
||||
|
||||
#[allow(unused)]
|
||||
fn press_y_to_continue() -> bool {
|
||||
println!("Continue? [y/N]");
|
||||
let mut line = String::new();
|
||||
let stdin = std::io::stdin();
|
||||
stdin.lock().read_line(&mut line).unwrap();
|
||||
if line.to_uppercase() == "Y\n" {
|
||||
true
|
||||
} else {
|
||||
println!("Exiting now!");
|
||||
false
|
||||
}
|
||||
}
|
||||
|
||||
fn loop_prompt() -> bool {
|
||||
println!("Again? [Y/n]");
|
||||
let mut line = String::new();
|
||||
let stdin = std::io::stdin();
|
||||
stdin.lock().read_line(&mut line).unwrap();
|
||||
if line.to_uppercase() == "N\n" {
|
||||
println!("Exiting now!");
|
||||
false
|
||||
} else {
|
||||
true
|
||||
}
|
||||
}
|
||||
|
||||
#[tokio::main]
|
||||
|
|
@ -80,92 +33,36 @@ async fn main() {
|
|||
let args = Args::parse();
|
||||
let auth_path = args.config_dir.join("auth");
|
||||
// let config_path = args.config_dir.join("config");
|
||||
match get_auth(auth_path).await {
|
||||
Ok(api) => {
|
||||
let products = api.products().await;
|
||||
|
||||
if let Ok(res) = products {
|
||||
if let Some(teslatte::products::Product::Vehicle(vehicle)) = res.first() {
|
||||
api.wake_up(&vehicle.vin).await.unwrap();
|
||||
|
||||
match match args.command {
|
||||
Commands::GenerateConfig => {
|
||||
println!(
|
||||
"{}",
|
||||
ron::ser::to_string_pretty(&Config::default(), Default::default())
|
||||
.unwrap()
|
||||
);
|
||||
Ok(MaybePostResponse::None)
|
||||
}
|
||||
Commands::Watch { flash } => {
|
||||
if flash {
|
||||
println!("{vehicle:#?}");
|
||||
match try_join!(
|
||||
api.honk_horn(&vehicle.vin),
|
||||
api.flash_lights(&vehicle.vin)
|
||||
) {
|
||||
match args.command {
|
||||
Commands::GenerateConfig => {
|
||||
println!(
|
||||
"{}",
|
||||
ron::ser::to_string_pretty(&Config::default(), Default::default()).unwrap()
|
||||
);
|
||||
}
|
||||
Commands::Watch => match get_auth(auth_path).await {
|
||||
Ok(api) => {
|
||||
let products = api.products().await;
|
||||
match products {
|
||||
Ok(res) => match res.first() {
|
||||
Some(teslatte::products::Product::Vehicle(vehicle)) => {
|
||||
api.wake_up(&vehicle.vin).await.unwrap();
|
||||
loop {
|
||||
match api.flash_lights(&vehicle.vin).await {
|
||||
Ok(_r) => println!("flashed"),
|
||||
Err(e) => println!("error: {e:#?}"),
|
||||
}
|
||||
|
||||
while loop_prompt() {
|
||||
match try_join!(
|
||||
api.honk_horn(&vehicle.vin),
|
||||
api.flash_lights(&vehicle.vin)
|
||||
) {
|
||||
Ok(_r) => println!("honked"),
|
||||
Err(e) => println!("error: {e:#?}"),
|
||||
}
|
||||
}
|
||||
std::thread::sleep(Duration::from_secs(10));
|
||||
}
|
||||
Ok(MaybePostResponse::None)
|
||||
}
|
||||
Commands::SetChargeRate { amps } => api
|
||||
.set_charging_amps(
|
||||
&vehicle.vin,
|
||||
&SetChargingAmps {
|
||||
charging_amps: amps as i64,
|
||||
},
|
||||
)
|
||||
.await
|
||||
.map(|v| v.into()),
|
||||
Commands::StartCharge => {
|
||||
api.charge_start(&vehicle.vin).await.map(|v| v.into())
|
||||
}
|
||||
Commands::StopCharge => {
|
||||
api.charge_stop(&vehicle.vin).await.map(|v| v.into())
|
||||
}
|
||||
|
||||
Commands::ToggleBoot => api
|
||||
.actuate_trunk(
|
||||
&vehicle.vin,
|
||||
&ActuateTrunk {
|
||||
which_trunk: teslatte::vehicles::Trunk::rear,
|
||||
},
|
||||
)
|
||||
.await
|
||||
.map(|v| v.into()),
|
||||
|
||||
Commands::ChargerOpen => api
|
||||
.charge_port_door_open(&vehicle.vin)
|
||||
.await
|
||||
.map(|v| v.into()),
|
||||
|
||||
Commands::ChargerClose => api
|
||||
.charge_port_door_close(&vehicle.vin)
|
||||
.await
|
||||
.map(|v| v.into()),
|
||||
} {
|
||||
Ok(MaybePostResponse::PostResponse(response)) => {
|
||||
println!("post response: {response:#?}")
|
||||
}
|
||||
Ok(_) => {}
|
||||
Err(error) => println!("teslatte error: {error:#?}"),
|
||||
}
|
||||
_ => println!("No first item"),
|
||||
},
|
||||
Err(e) => println!("Error getting products: {e:#?}"),
|
||||
}
|
||||
}
|
||||
}
|
||||
Err(e) => println!("{}", e.error_string()),
|
||||
Err(e) => println!("{}", e.error_string()),
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in a new issue