Http,Network,Services.Utitlity: rename FSharpUtil

Renamed FSharpUtil module to AsyncUtil.
nblockchain · Jan 18, 2023 · abcbe43 · abcbe43
1 parent 35d2ec5
commit abcbe43
Show file tree

Hide file tree

Showing 7 changed files with 16 additions and 18 deletions.
diff --git a/NOnion/Http/TorHttpClient.fs b/NOnion/Http/TorHttpClient.fs
@@ -51,7 +51,7 @@ type TorHttpClient(stream: TorStream, host: string) =
 
             do!
                 ReceiveAll memStream
-                |> FSharpUtil.WithTimeout Constants.HttpGetResponseTimeout
+                |> AsyncUtil.WithTimeout Constants.HttpGetResponseTimeout
 
             let httpResponse = memStream.ToArray()
 
@@ -145,7 +145,7 @@ type TorHttpClient(stream: TorStream, host: string) =
 
             do!
                 ReceiveAll memStream
-                |> FSharpUtil.WithTimeout Constants.HttpPostResponseTimeout
+                |> AsyncUtil.WithTimeout Constants.HttpPostResponseTimeout
 
             let httpResponse = memStream.ToArray()
 

diff --git a/NOnion/NOnion.fsproj b/NOnion/NOnion.fsproj
@@ -18,7 +18,7 @@
     <Compile Include="RelayIntroduceStatus.fs" />
     <Compile Include="Exceptions.fs" />
     <Compile Include="HandshakeType.fs" />
-    <Compile Include="Utility\FSharpUtil.fs" />
+    <Compile Include="Utility\AsyncUtil.fs" />
     <Compile Include="Utility\ResultUtil.fs" />
     <Compile Include="Utility\MailboxUtil.fs" />
     <Compile Include="Utility\StreamUtil.fs" />

diff --git a/NOnion/Network/TorCircuit.fs b/NOnion/Network/TorCircuit.fs
@@ -1113,7 +1113,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
         }
 
     member __.Extend(nodeDetail: CircuitNodeDetail) =
@@ -1130,7 +1130,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
         }
 
     member __.RegisterAsIntroductionPoint
@@ -1156,7 +1156,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
         }
 
     member __.RegisterAsRendezvousPoint(cookie: array<byte>) =
@@ -1177,7 +1177,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
         }
 
     member self.ExtendAsync nodeDetail =
@@ -1203,7 +1203,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
         }
 
     member __.WaitingForRendezvousJoin
@@ -1231,7 +1231,7 @@ and TorCircuit
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitRendezvousTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitRendezvousTimeout
 
         }
 

diff --git a/NOnion/Network/TorGuard.fs b/NOnion/Network/TorGuard.fs
@@ -120,7 +120,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
                     do!
                         client.ConnectAsync(ipEndpoint.Address, ipEndpoint.Port)
                         |> Async.AwaitTask
-                        |> FSharpUtil.WithTimeout
+                        |> AsyncUtil.WithTimeout
                             Constants.GuardConnectionTimeout
                 }
 
@@ -148,7 +148,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
                     false
                 )
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+                |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
 
             do!
                 ExceptionUtil.RunGuardJobWithExceptionHandling<unit>(
@@ -391,7 +391,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
             TorLogger.Log "TorGuard: finished handshake process"
         //TODO: do security checks on handshake data
         }
-        |> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
+        |> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
 
     member internal __.RegisterCircuit(circuit: ITorCircuit) : uint16 =
         let rec createCircuitId(retry: int) =

diff --git a/NOnion/Network/TorStream.fs b/NOnion/Network/TorStream.fs
@@ -460,7 +460,7 @@ type TorStream(circuit: TorCircuit) =
                 completionTaskRes
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.StreamCreationTimeout
+                |> AsyncUtil.WithTimeout Constants.StreamCreationTimeout
         }
 
     member self.ConnectToDirectory() =
@@ -480,7 +480,7 @@ type TorStream(circuit: TorCircuit) =
                 completionTaskResult
                 |> UnwrapResult
                 |> Async.AwaitTask
-                |> FSharpUtil.WithTimeout Constants.StreamCreationTimeout
+                |> AsyncUtil.WithTimeout Constants.StreamCreationTimeout
         }
 
     member self.ConnectToDirectoryAsync() =

diff --git a/NOnion/Services/TorServiceHost.fs b/NOnion/Services/TorServiceHost.fs
@@ -247,7 +247,7 @@ type TorServiceHost
                     introEncPubKey
 
             do!
-                FSharpUtil.Retry<NOnionException>
+                AsyncUtil.Retry<NOnionException>
                     connectToRendezvousJob
                     maxRendezvousConnectRetryCount
 

diff --git a/NOnion/Utility/FSharpUtil.fs → NOnion/Utility/AsyncUtil.fs b/NOnion/Utility/FSharpUtil.fs → NOnion/Utility/AsyncUtil.fs
@@ -1,14 +1,12 @@
 namespace NOnion.Utility
 
 open System
-open System.Runtime.ExceptionServices
 
-open FSharpx.Collections
 open Fsdk
 
 open NOnion
 
-module FSharpUtil =
+module AsyncUtil =
     let WithTimeout (timeSpan: TimeSpan) (job: Async<'R>) : Async<'R> =
         async {
             let! result = FSharpUtil.WithTimeout timeSpan job