@@ -229,12 +229,11 @@ pub struct LeaseContent {
229229
230230#[ cfg( test) ]
231231mod test {
232- use std:: fs:: { write, File } ;
233232 use std:: process;
234233 use std:: time:: Duration ;
235234
236235 use assert_matches:: assert_matches;
237- use tempfile :: TempDir ;
236+ use pretty_assertions :: assert_eq ;
238237
239238 use super :: * ;
240239
@@ -244,10 +243,9 @@ mod test {
244243 lease_expiry : Duration :: from_secs ( 60 ) ,
245244 renewal_interval : Duration :: from_secs ( 10 ) ,
246245 } ;
247- let tmp = TempDir :: new ( ) . unwrap ( ) ;
248- let transport = & Transport :: local ( tmp. path ( ) ) ;
246+ let transport = & Transport :: temp ( ) ;
249247 let lease = Lease :: acquire ( transport, & options) . unwrap ( ) ;
250- assert ! ( tmp . path ( ) . join ( "LEASE" ) . exists ( ) ) ;
248+ assert ! ( transport . is_file ( LEASE_FILENAME ) . unwrap ( ) ) ;
251249 let orig_lease_taken = lease. content . acquired ;
252250
253251 let peeked = Lease :: peek ( transport) . unwrap ( ) ;
@@ -270,7 +268,7 @@ mod test {
270268 }
271269
272270 lease. release ( ) . unwrap ( ) ;
273- assert ! ( !tmp . path ( ) . join ( "LEASE" ) . exists ( ) ) ;
271+ assert ! ( !transport . is_file ( "LEASE" ) . unwrap ( ) ) ;
274272 }
275273
276274 #[ test]
@@ -279,10 +277,9 @@ mod test {
279277 lease_expiry : Duration :: from_secs ( 60 ) ,
280278 renewal_interval : Duration :: from_secs ( 10 ) ,
281279 } ;
282- let tmp = TempDir :: new ( ) . unwrap ( ) ;
283- let transport = Transport :: local ( tmp. path ( ) ) ;
280+ let transport = Transport :: temp ( ) ;
284281 let lease = Lease :: acquire ( & transport, & options) . unwrap ( ) ;
285- assert ! ( tmp . path ( ) . join ( "LEASE" ) . exists ( ) ) ;
282+ assert ! ( transport . is_file ( LEASE_FILENAME ) . unwrap ( ) ) ;
286283
287284 transport. remove_file ( LEASE_FILENAME ) . unwrap ( ) ;
288285
@@ -296,15 +293,14 @@ mod test {
296293 lease_expiry : Duration :: from_secs ( 60 ) ,
297294 renewal_interval : Duration :: from_secs ( 10 ) ,
298295 } ;
299- let tmp = TempDir :: new ( ) . unwrap ( ) ;
300- let transport = Transport :: local ( tmp. path ( ) ) ;
296+ let transport = Transport :: temp ( ) ;
301297 let lease1 = Lease :: acquire ( & transport, & options) . unwrap ( ) ;
302- assert ! ( tmp . path ( ) . join ( "LEASE" ) . exists ( ) ) ;
298+ assert ! ( transport . is_file ( "LEASE" ) . unwrap ( ) ) ;
303299
304300 // Delete the lease to make it easy to steal.
305301 transport. remove_file ( LEASE_FILENAME ) . unwrap ( ) ;
306302 let lease2 = Lease :: acquire ( & transport, & options) . unwrap ( ) ;
307- assert ! ( tmp . path ( ) . join ( "LEASE" ) . exists ( ) ) ;
303+ assert ! ( transport . is_file ( "LEASE" ) . unwrap ( ) ) ;
308304
309305 // Renewal through the first handle should now fail.
310306 let result = lease1. renew ( ) ;
@@ -316,11 +312,11 @@ mod test {
316312
317313 #[ test]
318314 fn peek_fixed_lease_content ( ) {
319- let tmp = TempDir :: new ( ) . unwrap ( ) ;
320- let transport = & Transport :: local ( tmp . path ( ) ) ;
321- write (
322- tmp . path ( ) . join ( "LEASE" ) ,
323- r #"
315+ let transport = & Transport :: temp ( ) ;
316+ transport
317+ . write (
318+ "LEASE" ,
319+ br #"
324320 {
325321 "host": "somehost",
326322 "pid": 1234,
@@ -329,8 +325,9 @@ mod test {
329325 "expiry": "2021-01-01T12:35:56Z",
330326 "nonce": 12345
331327 }"# ,
332- )
333- . unwrap ( ) ;
328+ WriteMode :: CreateNew ,
329+ )
330+ . unwrap ( ) ;
334331 let state = Lease :: peek ( transport) . unwrap ( ) ;
335332 dbg ! ( & state) ;
336333 match state {
@@ -353,9 +350,8 @@ mod test {
353350 /// after it was last written.
354351 #[ test]
355352 fn peek_corrupt_empty_lease ( ) {
356- let tmp = TempDir :: new ( ) . unwrap ( ) ;
357- let transport = & Transport :: local ( tmp. path ( ) ) ;
358- File :: create ( tmp. path ( ) . join ( "LEASE" ) ) . unwrap ( ) ;
353+ let transport = & Transport :: temp ( ) ;
354+ transport. write ( "LEASE" , b"" , WriteMode :: CreateNew ) . unwrap ( ) ;
359355 let state = Lease :: peek ( transport) . unwrap ( ) ;
360356 match state {
361357 LeaseState :: Corrupt ( mtime) => {
0 commit comments