Skip to content

Commit 68db613

Browse files
ethangreen-devethangreen-dev
committed
run cargo fmt
1 parent 627913b commit 68db613

36 files changed

+337
-297
lines changed

‎src/cli.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ pub enum ExternSubcommand {
7676
/// Use the `list` command to query the list of imported and supported games.
7777
#[clap(long)]
7878
game_id: String,
79-
}
79+
},
8080
}
8181

8282
#[derive(Subcommand, Debug)]

‎src/error.rs

+6-4
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
use std::path::{Path, PathBuf};
22

3-
use crate::server::ServerError;
4-
use crate::ts::error::ApiError;
5-
63
use crate::game::error::GameError;
74
use crate::package::error::PackageError;
85
use crate::project::error::ProjectError;
6+
use crate::server::ServerError;
7+
use crate::ts::error::ApiError;
98

109
#[derive(Debug, thiserror::Error)]
1110
#[repr(u32)]
@@ -82,7 +81,10 @@ impl From<std::io::Error> for Error {
8281

8382
impl From<reqwest::Error> for Error {
8483
fn from(value: reqwest::Error) -> Self {
85-
Self::Api(ApiError::BadRequest { source: value, response_body: None })
84+
Self::Api(ApiError::BadRequest {
85+
source: value,
86+
response_body: None,
87+
})
8688
}
8789
}
8890

‎src/game/error.rs

+4-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,10 @@ pub enum GameError {
1313
NotFound(String, String),
1414

1515
#[error("Could not find any of '{possible_names:?}' in base directory: '{base_path}'.")]
16-
ExeNotFound { possible_names: Vec<String>, base_path: PathBuf},
16+
ExeNotFound {
17+
possible_names: Vec<String>,
18+
base_path: PathBuf,
19+
},
1720

1821
#[error("The Steam library could not be automatically found.")]
1922
SteamDirNotFound,

‎src/game/import/ea.rs

+4-5
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,10 @@ impl GameImporter for EaImporter {
3535
.custom_exe
3636
.clone()
3737
.or_else(|| super::find_game_exe(&r2mm.exe_names, &game_dir))
38-
.ok_or_else(|| {
39-
GameError::ExeNotFound {
40-
possible_names: r2mm.exe_names.clone(),
41-
base_path: game_dir.clone(),
42-
}})?;
38+
.ok_or_else(|| GameError::ExeNotFound {
39+
possible_names: r2mm.exe_names.clone(),
40+
base_path: game_dir.clone(),
41+
})?;
4342
let dist = ActiveDistribution {
4443
dist: GameDefPlatform::Origin {
4544
identifier: self.ident.to_string(),

‎src/game/import/egs.rs

+5-6
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ use std::path::PathBuf;
44
use serde::{Deserialize, Serialize};
55

66
use super::{GameImporter, ImportBase};
7-
use crate::error::{IoError, Error};
7+
use crate::error::{Error, IoError};
88
use crate::game::error::GameError;
99
use crate::game::registry::{ActiveDistribution, GameData};
1010
use crate::ts::v1::models::ecosystem::GameDefPlatform;
@@ -81,11 +81,10 @@ impl GameImporter for EgsImporter {
8181
.custom_exe
8282
.clone()
8383
.or_else(|| super::find_game_exe(&r2mm.exe_names, &game_dir))
84-
.ok_or_else(|| {
85-
GameError::ExeNotFound {
86-
possible_names: r2mm.exe_names.clone(),
87-
base_path: game_dir.clone(),
88-
}})?;
84+
.ok_or_else(|| GameError::ExeNotFound {
85+
possible_names: r2mm.exe_names.clone(),
86+
base_path: game_dir.clone(),
87+
})?;
8988
let dist = ActiveDistribution {
9089
dist: GameDefPlatform::Other,
9190
game_dir: game_dir.to_path_buf(),

‎src/game/import/gamepass.rs

+4-5
Original file line numberDiff line numberDiff line change
@@ -49,11 +49,10 @@ impl GameImporter for GamepassImporter {
4949
.custom_exe
5050
.clone()
5151
.or_else(|| super::find_game_exe(&r2mm.exe_names, &game_dir))
52-
.ok_or_else(|| {
53-
GameError::ExeNotFound {
54-
possible_names: r2mm.exe_names.clone(),
55-
base_path: game_dir.clone(),
56-
}})?;
52+
.ok_or_else(|| GameError::ExeNotFound {
53+
possible_names: r2mm.exe_names.clone(),
54+
base_path: game_dir.clone(),
55+
})?;
5756
let dist = ActiveDistribution {
5857
dist: GameDefPlatform::GamePass {
5958
identifier: self.ident.to_string(),

‎src/game/import/mod.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use crate::game::import::ea::EaImporter;
1414
use crate::game::import::egs::EgsImporter;
1515
use crate::game::import::gamepass::GamepassImporter;
1616
use crate::game::import::steam::SteamImporter;
17-
use crate::ts::v1::models::ecosystem::{ GameDef, GameDefPlatform };
17+
use crate::ts::v1::models::ecosystem::{GameDef, GameDefPlatform};
1818

1919
pub trait GameImporter {
2020
fn construct(self: Box<Self>, base: ImportBase) -> Result<GameData, Error>;

‎src/game/import/nodrm.rs

+4-3
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
use std::path::{Path, PathBuf};
22

3+
use super::{GameImporter, ImportBase};
34
use crate::error::{Error, IoError};
45
use crate::game::error::GameError;
5-
use super::{GameImporter, ImportBase};
66
use crate::game::registry::{ActiveDistribution, GameData};
77
use crate::ts::v1::models::ecosystem::GameDefPlatform;
88

@@ -33,8 +33,9 @@ impl GameImporter for NoDrmImporter {
3333
.custom_exe
3434
.clone()
3535
.or_else(|| super::find_game_exe(&r2mm.exe_names, &self.game_dir))
36-
.ok_or_else(|| {
37-
GameError::ExeNotFound { possible_names: r2mm.exe_names.clone(), base_path: self.game_dir.clone() }
36+
.ok_or_else(|| GameError::ExeNotFound {
37+
possible_names: r2mm.exe_names.clone(),
38+
base_path: self.game_dir.clone(),
3839
})?;
3940
let dist = ActiveDistribution {
4041
dist: GameDefPlatform::Other,

‎src/game/import/steam.rs

+7-8
Original file line numberDiff line numberDiff line change
@@ -40,9 +40,9 @@ impl GameImporter for SteamImporter {
4040
.as_ref()
4141
.map_or_else(SteamDir::locate, |x| SteamDir::from_dir(x))
4242
.map_err(|e: steamlocate::Error| match e {
43-
steamlocate::Error::InvalidSteamDir(_) => {
44-
GameError::SteamDirBadPath(self.steam_dir.as_ref().unwrap().to_path_buf())
45-
}
43+
steamlocate::Error::InvalidSteamDir(_) => GameError::SteamDirBadPath(
44+
self.steam_dir.as_ref().unwrap().to_path_buf(),
45+
),
4646
steamlocate::Error::FailedLocate(_) => GameError::SteamDirNotFound,
4747
_ => unreachable!(),
4848
})?;
@@ -75,11 +75,10 @@ impl GameImporter for SteamImporter {
7575
.iter()
7676
.map(|x| app_dir.join(x))
7777
.find(|x| x.is_file())
78-
.ok_or_else(|| {
79-
GameError::ExeNotFound {
80-
possible_names: r2mm.exe_names.clone(),
81-
base_path: app_dir.clone(),
82-
}})?;
78+
.ok_or_else(|| GameError::ExeNotFound {
79+
possible_names: r2mm.exe_names.clone(),
80+
base_path: app_dir.clone(),
81+
})?;
8382

8483
let dist = ActiveDistribution {
8584
dist: GameDefPlatform::Steam {

‎src/game/mod.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
pub mod ecosystem;
2+
pub mod error;
23
pub mod import;
34
pub mod proc;
45
pub mod registry;
5-
pub mod error;

‎src/game/proc.rs

+26-25
Original file line numberDiff line numberDiff line change
@@ -1,43 +1,44 @@
1-
use std::{ffi::OsStr, path::{Path, PathBuf}};
2-
use sysinfo::{
3-
Pid,
4-
ProcessExt,
5-
System,
6-
SystemExt
1+
use std::{
2+
ffi::OsStr,
3+
path::{Path, PathBuf},
74
};
85

6+
use sysinfo::{Pid, ProcessExt, System, SystemExt};
7+
98
use crate::error::Error;
109

1110
pub fn get_pid_files(dir: &Path) -> Result<Vec<PathBuf>, Error> {
12-
let ext = OsStr::new("pid");
13-
let files = dir
14-
.read_dir()?
15-
.filter_map(|x| x.ok())
16-
.filter(|x| x.path().extension() == Some(ext))
17-
.map(|x| x.path())
18-
.collect();
19-
20-
Ok(files)
11+
let ext = OsStr::new("pid");
12+
let files = dir
13+
.read_dir()?
14+
.filter_map(|x| x.ok())
15+
.filter(|x| x.path().extension() == Some(ext))
16+
.map(|x| x.path())
17+
.collect();
18+
19+
Ok(files)
2120
}
2221

2322
pub fn is_running(pid: usize) -> bool {
24-
let mut system = System::new();
25-
system.refresh_processes();
23+
let mut system = System::new();
24+
system.refresh_processes();
2625

27-
system.process(Pid::from(pid)).is_some()
26+
system.process(Pid::from(pid)).is_some()
2827
}
2928

3029
pub fn kill(pid: usize) {
31-
let mut system = System::new();
32-
system.refresh_processes();
30+
let mut system = System::new();
31+
system.refresh_processes();
3332

34-
let proc = system.process(Pid::from(pid)).expect("Expected a running process.");
35-
proc.kill();
33+
let proc = system
34+
.process(Pid::from(pid))
35+
.expect("Expected a running process.");
36+
proc.kill();
3637
}
3738

3839
pub fn get_name(pid: usize) -> Option<String> {
39-
let system = System::new();
40-
let proc = system.process(Pid::from(pid))?;
40+
let system = System::new();
41+
let proc = system.process(Pid::from(pid))?;
4142

42-
Some(proc.name().to_string())
43+
Some(proc.name().to_string())
4344
}

‎src/main.rs

+7-5
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ use clap::Parser;
77
use cli::{ExternSubcommand, InitSubcommand};
88
use colored::Colorize;
99
use directories::BaseDirs;
10-
use error::{IoError, Error};
10+
use error::{Error, IoError};
1111
use game::import::GameImporter;
1212
use once_cell::sync::Lazy;
1313
use project::error::ProjectError;
@@ -353,7 +353,7 @@ async fn main() -> Result<(), Error> {
353353
Ok(())
354354
}
355355
},
356-
Commands::Server { project_path }=> {
356+
Commands::Server { project_path } => {
357357
let read = io::stdin();
358358
let write = io::stdout();
359359
server::spawn(read, write, &project_path).await?;
@@ -365,10 +365,12 @@ async fn main() -> Result<(), Error> {
365365
match command {
366366
ExternSubcommand::GameData { game_id } => {
367367
let base = ImportBase::new(&game_id).await?;
368-
let game_data = import::select_importer(&base)?
369-
.construct(base)?;
368+
let game_data = import::select_importer(&base)?.construct(base)?;
370369

371-
println!("{}", serde_json::to_string_pretty(&game_data.active_distribution)?);
370+
println!(
371+
"{}",
372+
serde_json::to_string_pretty(&game_data.active_distribution)?
373+
);
372374
}
373375
}
374376

‎src/package/cache.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ use std::path::PathBuf;
33

44
use once_cell::sync::Lazy;
55

6-
use crate::error::{IoResultToTcli, Error};
6+
use crate::error::{Error, IoResultToTcli};
77
use crate::ts::package_reference::PackageReference;
88
use crate::util::TempFile;
99
use crate::TCLI_HOME;

‎src/package/index.rs

+9-5
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,12 @@ use serde::{Deserialize, Serialize};
1212
use tokio::fs::OpenOptions;
1313
use tokio::io::AsyncWriteExt;
1414

15-
use crate::util::file;
16-
use crate::error::{IoError, Error};
15+
use crate::error::{Error, IoError};
1716
use crate::ts::experimental;
1817
use crate::ts::experimental::index::PackageIndexEntry;
1918
use crate::ts::package_reference::PackageReference;
2019
use crate::ts::version::Version;
20+
use crate::util::file;
2121

2222
#[derive(Serialize, Deserialize)]
2323
struct IndexHeader {
@@ -117,7 +117,8 @@ impl PackageIndex {
117117
inner.name,
118118
Version::from_str(inner.version_number).unwrap(),
119119
)
120-
}.unwrap();
120+
}
121+
.unwrap();
121122

122123
let entry = LookupTableEntry {
123124
start,
@@ -134,7 +135,7 @@ impl PackageIndex {
134135

135136
let header_path = index_dir.join("header.json");
136137
let header = IndexHeader {
137-
update_time: experimental::index::get_index_update_time().await?
138+
update_time: experimental::index::get_index_update_time().await?,
138139
};
139140
fs::write(header_path, serde_json::to_string_pretty(&header)?)?;
140141

@@ -192,7 +193,10 @@ impl PackageIndex {
192193
}
193194

194195
/// Get a package which matches the given package reference.
195-
pub fn get_package(&self, reference: impl Borrow<PackageReference>) -> Option<PackageIndexEntry> {
196+
pub fn get_package(
197+
&self,
198+
reference: impl Borrow<PackageReference>,
199+
) -> Option<PackageIndexEntry> {
196200
let entry_idx = self.strict_lookup.get(&reference.borrow().to_string())?;
197201
let entry = self.lookup.get(*entry_idx)?;
198202

‎src/package/install/api.rs

+4-4
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,10 @@ use std::path::PathBuf;
22

33
use serde::{Deserialize, Serialize};
44

5-
use crate::ts::version::Version;
65
use crate::ts::package_reference::PackageReference;
6+
use crate::ts::version::Version;
77

8-
/// This is the minimum support
8+
/// This is the minimum support
99
pub static PROTOCOL_VERSION: Version = Version {
1010
major: 1,
1111
minor: 0,
@@ -75,9 +75,9 @@ pub enum Response {
7575
post_hook_context: Option<String>,
7676
},
7777
StartGame {
78-
pid: u32,
78+
pid: u32,
7979
},
8080
Error {
8181
message: String,
82-
}
82+
},
8383
}

0 commit comments

Comments
 (0)