Features/blob storage (#99)

* Save messages to storage. Better Cancellation support * Add Corvus.Retry to deal with TCP disconnection errors.
ais-dotnet · Mar 13, 2021 · 74d4c5e · 74d4c5e
1 parent fda5e98
commit 74d4c5e
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 2 deletions.
diff --git a/Solutions/Ais.Net.Models.Specs/Ais.Net.Models.Specs.csproj b/Solutions/Ais.Net.Models.Specs/Ais.Net.Models.Specs.csproj
@@ -20,7 +20,7 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
-    <PackageReference Include="Corvus.Testing.SpecFlow.NUnit" Version="1.3.1" />
+    <PackageReference Include="Corvus.Testing.SpecFlow.NUnit" Version="1.3.2" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\Ais.Net.Models\Ais.Net.Models.csproj" />

diff --git a/Solutions/Ais.Net.Receiver/Ais.Net.Receiver.csproj b/Solutions/Ais.Net.Receiver/Ais.Net.Receiver.csproj
@@ -21,6 +21,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Corvus.Retry" Version="1.0.1" />
     <PackageReference Include="Endjin.RecommendedPractices" Version="1.2.0">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Solutions/Ais.Net.Receiver/Receiver/ReceiverHost.cs b/Solutions/Ais.Net.Receiver/Receiver/ReceiverHost.cs
@@ -16,6 +16,10 @@ namespace Ais.Net.Receiver.Receiver
     using Ais.Net.Receiver.Configuration;
     using Ais.Net.Receiver.Parser;
 
+    using Corvus.Retry;
+    using Corvus.Retry.Policies;
+    using Corvus.Retry.Strategies;
+
     public class ReceiverHost
     {
         private readonly AisConfig configuration;
@@ -37,7 +41,17 @@ public ReceiverHost(AisConfig configuration)
 
         public IObservable<IAisMessage> Messages => this.messages;
 
-        public async Task StartAsync(CancellationToken cancellationToken = default)
+        public Task StartAsync(CancellationToken cancellationToken = default)
+        {
+            return Retriable.RetryAsync(() =>
+                        this.StartAsyncInternal(cancellationToken),
+                        cancellationToken,
+                        new Backoff(maxTries: 100, deltaBackoff: TimeSpan.FromSeconds(5)),
+                        new AnyExceptionPolicy(),
+                        false);
+        }
+
+        private async Task StartAsyncInternal(CancellationToken cancellationToken = default)
         {
             var processor = new NmeaToAisMessageTypeProcessor();
             var adapter = new NmeaLineToAisStreamAdapter(processor);