Debug/queues not existing at startup (#55)

* Fix queue name mismatch between API and LLM worker

API was sending to "project-description" while the worker polled
"project-descriptions", so messages were never delivered.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* Auto-create Azure Storage queues on startup

Azurite does not provision queues automatically. Both the API and the
LLM worker now call CreateIfNotExistsAsync at startup so the queues are
always ready without manual setup. The call is idempotent, so it is
safe against real Azure Storage in production too.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* Fix integration tests failing in CI due to QueueInitializerService

QueueInitializerService was registered as a hosted service that tries to
connect to real Azure Storage on startup, but ApiFactory only mocked the
IMessageChannel singletons — not the hosted service itself. In CI (no
Azurite), this caused all integration tests to fail at host startup.

Added InternalsVisibleTo for the test assembly so ApiFactory can remove
QueueInitializerService from the DI container by type before the test
host starts.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

---------

Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: dcl10

backend/src/SkillMatrixLlm.Api/Config/MessageQueueOptions.cs

@@ -7,7 +7,7 @@ public record MessageQueueOptions
   public string ConnectionString { get; init; } = string.Empty;
 
   /// <summary>Queue name for outbound <c>ProjectDescriptionPayload</c> messages.</summary>
-  public string ProjectDescriptionQueueName { get; init; } = "project-description";
+  public string ProjectDescriptionQueueName { get; init; } = "project-descriptions";
 
   /// <summary>Queue name for inbound <c>SkillRequirementsResult</c> messages from the LLM service.</summary>
   public string SkillRequirementsQueueName { get; init; } = "skill-requirements";

backend/src/SkillMatrixLlm.Api/Extensions/ServiceCollectionExtensions.cs

@@ -45,22 +45,23 @@ public static IServiceCollection AddEmailSender(this IServiceCollection s, IConf
   }
 
   /// <summary>
-  /// Registers <see cref="IMessageChannel{T}"/> implementations backed by Azure Queue Storage.
+  /// Registers <see cref="IMessageChannel{T}"/> implementations backed by Azure Queue Storage
+  /// and a hosted service that creates the queues on startup if they do not already exist.
   /// </summary>
   public static IServiceCollection AddMessageQueues(this IServiceCollection s, IConfiguration c)
   {
     var options = c.GetSection("MessageQueue").Get<MessageQueueOptions>() ?? new MessageQueueOptions();
 
-    // Factory delegates defer QueueClient construction until first resolve,
-    // which allows test hosts to override these registrations without triggering
-    // the QueueClient constructor (which requires a valid connection string).
+    var projectDescClient = CreateQueueClient(options.ConnectionString, options.ProjectDescriptionQueueName);
+    var skillReqClient = CreateQueueClient(options.ConnectionString, options.SkillRequirementsQueueName);
+
     s.AddSingleton<IMessageChannel<ProjectDescriptionPayload>>(_ =>
-      new AzureStorageQueueMessageChannel<ProjectDescriptionPayload>(
-        CreateQueueClient(options.ConnectionString, options.ProjectDescriptionQueueName)));
+      new AzureStorageQueueMessageChannel<ProjectDescriptionPayload>(projectDescClient));
 
     s.AddSingleton<IMessageChannel<SkillRequirementsResult>>(_ =>
-      new AzureStorageQueueMessageChannel<SkillRequirementsResult>(
-        CreateQueueClient(options.ConnectionString, options.SkillRequirementsQueueName)));
+      new AzureStorageQueueMessageChannel<SkillRequirementsResult>(skillReqClient));
+
+    s.AddHostedService(_ => new QueueInitializerService([projectDescClient, skillReqClient]));
 
     return s;
   }

backend/src/SkillMatrixLlm.Api/Services/QueueInitializerService.cs

@@ -0,0 +1,17 @@
+namespace SkillMatrixLlm.Api.Services;
+
+using Azure.Storage.Queues;
+
+/// <summary>Creates Azure Storage Queues on startup if they do not already exist.</summary>
+internal sealed class QueueInitializerService(QueueClient[] clients) : IHostedService
+{
+  /// <inheritdoc/>
+  public async Task StartAsync(CancellationToken cancellationToken)
+  {
+    foreach (var client in clients)
+      await client.CreateIfNotExistsAsync(cancellationToken: cancellationToken);
+  }
+
+  /// <inheritdoc/>
+  public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
+}

backend/src/SkillMatrixLlm.Api/SkillMatrixLlm.Api.csproj

@@ -10,6 +10,10 @@
     <UserSecretsId>6a7c2c10-7306-41a6-8b41-d1490d650476</UserSecretsId>
   </PropertyGroup>
 
+  <ItemGroup>
+    <InternalsVisibleTo Include="SkillMatrixLlm.Api.IntegrationTests" />
+  </ItemGroup>
+
   <ItemGroup>
     <!-- JWT Bearer authentication — validates Keycloak-issued tokens -->
     <PackageReference Include="Azure.Storage.Queues" Version="12.25.0" />

backend/src/SkillMatrixLlm.LlmWorker/Worker.cs

@@ -37,6 +37,10 @@ public partial class Worker(
   /// <inheritdoc />
   protected override async Task ExecuteAsync(CancellationToken stoppingToken)
   {
+    await inputQueue.CreateIfNotExistsAsync(cancellationToken: stoppingToken);
+    await outputQueue.CreateIfNotExistsAsync(cancellationToken: stoppingToken);
+    await poisonQueue.CreateIfNotExistsAsync(cancellationToken: stoppingToken);
+
     var opts = workerOptions.Value;
 
     while (!stoppingToken.IsCancellationRequested)

backend/tests/SkillMatrixLlm.Api.IntegrationTests/Fixtures/ApiFactory.cs

@@ -14,6 +14,7 @@ namespace SkillMatrixLlm.Api.Tests.Fixtures;
 using Messaging;
 using Models.Recommendations;
 using Moq;
+using Services;
 using Services.Contracts;
 
 /// <summary>
@@ -40,6 +41,10 @@ protected override void ConfigureWebHost(IWebHostBuilder builder) =>
       services.AddDbContext<AppDbContext>(o =>
         o.UseInMemoryDatabase("TestDb").UseInternalServiceProvider(inMemoryProvider));
 
+      var queueInitDescriptor = services.SingleOrDefault(d => d.ImplementationType == typeof(QueueInitializerService));
+      if (queueInitDescriptor is not null)
+        services.Remove(queueInitDescriptor);
+
       services.AddTransient(_ => Mock.Of<IEmailSender>());
       services.AddSingleton(_ => Mock.Of<IKeycloakDataSeeder>());
       services.AddSingleton(_ => Mock.Of<IMessageChannel<ProjectDescriptionPayload>>());