From 41552d26ec4e0d76ef9746f8424376f05d2218df Mon Sep 17 00:00:00 2001
From: master <>
Date: Mon, 29 Dec 2025 17:06:22 +0200
Subject: [PATCH] Fix nullable fields in Astra connector for test compatibility

Make SourceFetchService and RawDocumentStorage fields nullable to allow
testing with null values, matching constructor parameter signatures.

Tests now: 14 passed, 0 failed
---
 .../StellaOps.Concelier.Connector.Astra/AstraConnector.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/Concelier/__Connectors/StellaOps.Concelier.Connector.Astra/AstraConnector.cs b/src/Concelier/__Connectors/StellaOps.Concelier.Connector.Astra/AstraConnector.cs
index 3b67915be..26fce2244 100644
--- a/src/Concelier/__Connectors/StellaOps.Concelier.Connector.Astra/AstraConnector.cs
+++ b/src/Concelier/__Connectors/StellaOps.Concelier.Connector.Astra/AstraConnector.cs
@@ -41,8 +41,8 @@ namespace StellaOps.Concelier.Connector.Astra;
 /// </summary>
 public sealed class AstraConnector : IFeedConnector
 {
-    private readonly SourceFetchService _fetchService;
-    private readonly RawDocumentStorage _rawDocumentStorage;
+    private readonly SourceFetchService? _fetchService;
+    private readonly RawDocumentStorage? _rawDocumentStorage;
     private readonly IDocumentStore _documentStore;
     private readonly IDtoStore _dtoStore;
     private readonly IAdvisoryStore _advisoryStore;
@@ -63,8 +63,8 @@ public sealed class AstraConnector : IFeedConnector
         ILogger<AstraConnector> logger)
     {
         // fetchService and rawDocumentStorage are nullable for testing stub implementations
-        _fetchService = fetchService!;
-        _rawDocumentStorage = rawDocumentStorage!;
+        _fetchService = fetchService;
+        _rawDocumentStorage = rawDocumentStorage;
         _documentStore = documentStore ?? throw new ArgumentNullException(nameof(documentStore));
         _dtoStore = dtoStore ?? throw new ArgumentNullException(nameof(dtoStore));
         _advisoryStore = advisoryStore ?? throw new ArgumentNullException(nameof(advisoryStore));