redstrate/kawari
1
Fork 0
mirror of https://github.com/redstrate/Kawari.git synced 2025-05-02 11:07:45 +00:00
Code Activity

Add some helpful warnings to patch server, add FFXIV_Patch as user agent

Browse source 
This is used by sqexPatch.dll, so it should be legitimate. I also made
sure the URLs actually work again!
This commit is contained in:
Joshua Goins 2025-04-22 00:14:14 -04:00
parent 0e31cc047d
commit cdfebce9f7
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/bin/kawari-patch.rs
View file

@ -10,6 +10,7 @@ use kawari::config::get_config;
use kawari::patch::Version; use kawari::patch::Version;
use kawari::{SUPPORTED_BOOT_VERSION, SUPPORTED_GAME_VERSION, get_supported_expac_versions}; use kawari::{SUPPORTED_BOOT_VERSION, SUPPORTED_GAME_VERSION, get_supported_expac_versions};
use physis::patchlist::{PatchEntry, PatchList, PatchListType}; use physis::patchlist::{PatchEntry, PatchList, PatchListType};
use reqwest::header::USER_AGENT;
fn list_patch_files(dir_path: &str) -> Vec<String> { fn list_patch_files(dir_path: &str) -> Vec<String> {
// If the dir doesn't exist, pretend there is no patch files // If the dir doesn't exist, pretend there is no patch files
@ -65,11 +66,12 @@ fn list_patch_files(dir_path: &str) -> Vec<String> {
/// Check if it's a valid patch client connecting /// Check if it's a valid patch client connecting
fn check_valid_patch_client(headers: &HeaderMap) -> bool { fn check_valid_patch_client(headers: &HeaderMap) -> bool {
let Some(user_agent) = headers.get("User-Agent") else { let Some(user_agent) = headers.get(USER_AGENT) else {
return false; return false;
}; };
user_agent == "FFXIV PATCH CLIENT" // FFXIV_Patch is used by sqexPatch.dll
user_agent == "FFXIV PATCH CLIENT" || user_agent == "FFXIV_Patch"
} }
async fn verify_session( async fn verify_session(
@ -136,6 +138,7 @@ async fn verify_boot(
Path((platform, channel, boot_version)): Path<(String, String, String)>, Path((platform, channel, boot_version)): Path<(String, String, String)>,
) -> impl IntoResponse { ) -> impl IntoResponse {
if !check_valid_patch_client(&headers) { if !check_valid_patch_client(&headers) {
tracing::warn!("Invalid patch client! {headers:#?}");
return StatusCode::INTERNAL_SERVER_ERROR.into_response(); return StatusCode::INTERNAL_SERVER_ERROR.into_response();
} }
@ -143,6 +146,7 @@ async fn verify_boot(
let config = get_config(); let config = get_config();
if !config.supports_platform(&platform) { if !config.supports_platform(&platform) {
tracing::warn!("Invalid platform! {platform}");
return StatusCode::INTERNAL_SERVER_ERROR.into_response(); return StatusCode::INTERNAL_SERVER_ERROR.into_response();
} }
@ -202,7 +206,7 @@ async fn main() {
post(verify_session), post(verify_session),
) )
.route( .route(
"/http/{platform}/{channel}/{boot_version}", "/http/{platform}/{channel}/{boot_version}/",
get(verify_boot), get(verify_boot),
); );