22// Licensed under the MIT License.
33
44use anyhow:: { Context , Result } ;
5+ use base64:: Engine ;
56use bytes:: Buf ;
67use reqwest:: { Client , Url } ;
78use reqwest_retry:: SendRetry ;
@@ -11,6 +12,8 @@ use uuid::Uuid;
1112
1213pub const EMPTY_QUEUE_DELAY : Duration = Duration :: from_secs ( 10 ) ;
1314
15+ const BASE64 : base64:: engine:: GeneralPurpose = base64:: engine:: general_purpose:: STANDARD ;
16+
1417// <QueueMessagesList>
1518// <QueueMessage>
1619// <MessageId>7d35e47d-f58e-42da-ba4a-9e6ac7e1214d</MessageId>
@@ -49,7 +52,7 @@ pub struct AzureQueueMessageSend {
4952
5053impl AzureQueueMessage {
5154 pub fn parse < T > ( & self , parser : impl FnOnce ( & [ u8 ] ) -> Result < T > ) -> Result < T > {
52- let decoded = base64 :: decode ( & self . message_text ) ?;
55+ let decoded = BASE64 . decode ( & self . message_text ) ?;
5356 parser ( & decoded)
5457 }
5558
@@ -70,7 +73,7 @@ impl AzureQueueMessage {
7073 . error_for_status ( )
7174 . context ( "AzureQueueMessage.claim status body" ) ?;
7275 }
73- let decoded = base64 :: decode ( self . message_text ) ?;
76+ let decoded = BASE64 . decode ( self . message_text ) ?;
7477 let value: T = serde_json:: from_slice ( & decoded) ?;
7578 Ok ( value)
7679 }
@@ -96,7 +99,7 @@ impl AzureQueueMessage {
9699 }
97100
98101 pub fn get < T : DeserializeOwned > ( & self ) -> Result < T > {
99- let decoded = base64 :: decode ( & self . message_text ) ?;
102+ let decoded = BASE64 . decode ( & self . message_text ) ?;
100103 let value = serde_json:: from_slice ( & decoded) ?;
101104 Ok ( value)
102105 }
@@ -132,7 +135,7 @@ impl AzureQueueClient {
132135 pub async fn enqueue ( & self , data : impl Serialize ) -> Result < ( ) > {
133136 let serialized = serde_json:: to_string ( & data) . unwrap ( ) ;
134137 let body = quick_xml:: se:: to_string ( & AzureQueueMessageSend {
135- message_text : base64 :: encode ( & serialized) ,
138+ message_text : BASE64 . encode ( & serialized) ,
136139 } )
137140 . context ( "serializing queue message" ) ?;
138141
0 commit comments