more tests

src/ProjectOrigin.Chronicler.Server/DatabaseScripts/1.sql

@@ -16,10 +16,13 @@ CREATE TABLE read_blocks (
 CREATE OR REPLACE FUNCTION insert_read_block()
 RETURNS TRIGGER AS $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM read_blocks WHERE registry_name = NEW.registry_name) THEN
+    PERFORM 1 FROM read_blocks WHERE registry_name = NEW.registry_name;
+
+    IF NOT FOUND THEN
         INSERT INTO read_blocks (registry_name, block_height, read_at)
         VALUES (NEW.registry_name, -1, NOW());
     END IF;
+
     RETURN NEW;
 END;
 $$ LANGUAGE plpgsql;

src/ProjectOrigin.Chronicler.Server/Exceptions/RegistryNotKnownException.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace ProjectOrigin.Chronicler.Server.Exceptions
+{
+    public class RegistryNotKnownException : Exception
+    {
+        public RegistryNotKnownException(string registryName)
+            : base($"Registry {registryName} is not known")
+        {
+        }
+    }
+}

src/ProjectOrigin.Chronicler.Server/RegistryService.cs

@@ -1,18 +1,20 @@
 
 using System.Collections.Concurrent;
+using System.Collections.Generic;
 using System.Linq;
 using System.Net.Http;
 using System.Threading.Tasks;
 using Grpc.Net.Client;
 using Microsoft.Extensions.Options;
+using ProjectOrigin.Chronicler.Server.Exceptions;
 using ProjectOrigin.Chronicler.Server.Options;
 using static ProjectOrigin.Registry.V1.RegistryService;
 
 namespace ProjectOrigin.Chronicler.Server;
 
 public class RegistryService : IRegistryService
 {
-    ConcurrentDictionary<string, GrpcChannel> _registries = new ConcurrentDictionary<string, GrpcChannel>();
+    private readonly ConcurrentDictionary<string, GrpcChannel> _registries = new ConcurrentDictionary<string, GrpcChannel>();
     private readonly IOptionsMonitor<NetworkOptions> _optionsMonitor;
 
     public RegistryService(IOptionsMonitor<NetworkOptions> optionsMonitor)
@@ -38,7 +40,6 @@ public RegistryService(IOptionsMonitor<NetworkOptions> optionsMonitor)
                 }
             }
         });
-
     }
 
     private RegistryServiceClient CreateClient(string registryName)
@@ -48,7 +49,7 @@ private RegistryServiceClient CreateClient(string registryName)
             (name) =>
             {
                 if (!_optionsMonitor.CurrentValue.RegistryUrls.TryGetValue(name, out var address))
-                    throw new System.Exception($"Registry {name} not found in configuration");
+                    throw new RegistryNotKnownException($"Registry {name} not found in configuration");
 
                 return GrpcChannel.ForAddress(address, new GrpcChannelOptions
                 {

src/ProjectOrigin.Chronicler.Server/UriOptionsLoader/UriOptionsLoaderService.cs

@@ -112,7 +112,7 @@ private async Task<TOption> LoadFromHttp(CancellationToken stoppingToken)
         var response = await httpClient.GetAsync(_originOptions.ConfigurationUri, stoppingToken);
         response.EnsureSuccessStatusCode();
 
-        return await response.Content.ReadFromJsonAsync<TOption>()
+        return await response.Content.ReadFromJsonAsync<TOption>(stoppingToken)
             ?? throw new JsonException("Failed to read options from response.");
     }