From e97ad7f1028aa931ca6af2de88d37676d7ef61d8 Mon Sep 17 00:00:00 2001 From: Quaternions <krakow20@gmail.com> Date: Tue, 18 Mar 2025 13:40:23 -0700 Subject: [PATCH] use words --- src/main.rs | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/main.rs b/src/main.rs index dd411dd..4adb587 100644 --- a/src/main.rs +++ b/src/main.rs @@ -187,10 +187,10 @@ enum ScriptUploadError{ AllowedMap(GetMapError), ReplaceMap(GetMapError), BlockedSet(std::io::Error), - GOC(GOCError), - GOCPolicyReplace(GOCError), - GOCPolicyAllowed(GOCError), - GOCPolicyBlocked(GOCError), + GetOrCreate(GOCError), + GetOrCreatePolicyReplace(GOCError), + GetOrCreatePolicyAllowed(GOCError), + GetOrCreatePolicyBlocked(GOCError), } fn read_dir_stream(dir:tokio::fs::ReadDir)->impl futures::stream::Stream<Item=std::io::Result<tokio::fs::DirEntry>>{ @@ -356,7 +356,7 @@ async fn upload_scripts(config:UploadConfig)->Result<(),ScriptUploadError>{ Ok((source,script_id)) }) .buffer_unordered(REMOTE_CONCURRENCY) - .try_collect().await.map_err(ScriptUploadError::GOC)?; + .try_collect().await.map_err(ScriptUploadError::GetOrCreate)?; // get or create policy for each script in each category // @@ -371,7 +371,7 @@ async fn upload_scripts(config:UploadConfig)->Result<(),ScriptUploadError>{ ToScriptID:script_ids[allowed_map[id].as_str()], Policy:submissions_api::types::Policy::Replace, } - ).await.map_err(ScriptUploadError::GOCPolicyReplace) + ).await.map_err(ScriptUploadError::GetOrCreatePolicyReplace) }); // allowed @@ -385,7 +385,7 @@ async fn upload_scripts(config:UploadConfig)->Result<(),ScriptUploadError>{ ToScriptID:script_ids[source.as_str()], Policy:submissions_api::types::Policy::Allowed, } - ).await.map_err(ScriptUploadError::GOCPolicyAllowed) + ).await.map_err(ScriptUploadError::GetOrCreatePolicyAllowed) }); // blocked @@ -399,7 +399,7 @@ async fn upload_scripts(config:UploadConfig)->Result<(),ScriptUploadError>{ ToScriptID:script_ids[source.as_str()], Policy:submissions_api::types::Policy::Blocked, } - ).await.map_err(ScriptUploadError::GOCPolicyBlocked) + ).await.map_err(ScriptUploadError::GetOrCreatePolicyBlocked) }); // run futures