Complete Phase 3-4: Factory extension registered, SqsConfiguration uses IntegrationManager

Co-authored-by: dandrejvv <[email protected]>

Author: Copilot

Modules/Intent.Modules.Aws.Sqs/Intent.Aws.Sqs.imodspec

@@ -58,7 +58,9 @@
     </template>
   </templates>
   <decorators></decorators>
-  <factoryExtensions></factoryExtensions>
+  <factoryExtensions>
+    <factoryExtension id="Intent.Aws.Sqs.MetadataLoaderExtension" externalReference="9a8b7c6d-5e4f-3a2b-1c0d-9e8f7a6b5c4d" />
+  </factoryExtensions>
   <moduleSettings></moduleSettings>
   <dependencies>
     <dependency id="Intent.Common" version="3.9.0" />

Modules/Intent.Modules.Aws.Sqs/Templates/SqsConfiguration/SqsConfigurationTemplatePartial.cs

@@ -15,6 +15,7 @@
 using Intent.Modules.Common.Templates;
 using Intent.Modules.Constants;
 using Intent.Modules.Eventing.Contracts.Templates;
+using Intent.Modules.Integration.IaC.Shared.AwsSqs;
 using Intent.RoslynWeaver.Attributes;
 using Intent.Templates;
 
@@ -83,22 +84,53 @@ public SqsConfigurationTemplate(IOutputTarget outputTarget, object model = null)
                             method.AddStatement($"services.AddSingleton<{this.GetTypeName(SqsMessageDispatcherTemplate.TemplateId)}>();");
                             method.AddStatement($"services.AddSingleton<{this.GetTypeName(SqsMessageDispatcherInterfaceTemplate.TemplateId)}, {this.GetTypeName(SqsMessageDispatcherTemplate.TemplateId)}>(sp => sp.GetRequiredService<{this.GetTypeName(SqsMessageDispatcherTemplate.TemplateId)}>());");
 
-                            // Configure publisher options (metadata-driven - placeholder for now)
-                            method.AddStatement("");
-                            method.AddInvocationStatement($"services.Configure<{this.GetTypeName(SqsPublisherOptionsTemplate.TemplateId)}>", inv => inv
-                                .AddArgument(new CSharpLambdaBlock("options"), arg =>
-                                {
-                                    arg.AddStatement("// Publisher options will be configured here based on metadata");
-                                    arg.AddStatement("// Example: options.AddQueue<YourMessageType>(configuration[\"Sqs:Queues:YourMessageType:QueueUrl\"]!);");
-                                }));
+                            // Get metadata from IntegrationManager
+                            var publishers = IntegrationManager.Instance.GetAggregatedPublishedSqsItems(ExecutionContext.GetApplicationConfig().Id);
+                            var subscriptions = IntegrationManager.Instance.GetAggregatedSqsSubscriptions(ExecutionContext.GetApplicationConfig().Id);
+
+                            // Configure publisher options (metadata-driven)
+                            if (publishers.Any())
+                            {
+                                method.AddStatement("");
+                                method.AddInvocationStatement($"services.Configure<{this.GetTypeName(SqsPublisherOptionsTemplate.TemplateId)}>", inv => inv
+                                    .AddArgument(new CSharpLambdaBlock("options"), arg =>
+                                    {
+                                        foreach (var publisher in publishers)
+                                        {
+                                            var messageType = publisher.GetModelTypeName(this);
+                                            var configKey = $"\"{publisher.QueueConfigurationName}:QueueUrl\"";
+                                            arg.AddStatement($"options.AddQueue<{messageType}>(configuration[{configKey}]!);");
+                                        }
+                                    }));
+                            }
 
-                            // Configure subscription options (metadata-driven - placeholder for now)
-                            method.AddInvocationStatement($"services.Configure<{this.GetTypeName(SqsSubscriptionOptionsTemplate.TemplateId)}>", inv => inv
-                                .AddArgument(new CSharpLambdaBlock("options"), arg =>
+                            // Register event handlers (metadata-driven)
+                            if (subscriptions.Any())
+                            {
+                                method.AddStatement("");
+                                foreach (var subscription in subscriptions)
                                 {
-                                    arg.AddStatement("// Subscription options will be configured here based on metadata");
-                                    arg.AddStatement("// Example: options.Add<YourMessageType, YourMessageHandler>();");
-                                }));
+                                    var handlerType = subscription.SubscriptionItem.GetSubscriberTypeName(this);
+                                    var handlerImplementation = this.GetTypeName("Intent.Eventing.Contracts.IntegrationEventHandler", subscription.EventHandlerModel);
+                                    method.AddStatement($"services.AddTransient<{handlerType}, {handlerImplementation}>();");
+                                }
+                            }
+
+                            // Configure subscription options (metadata-driven)
+                            if (subscriptions.Any())
+                            {
+                                method.AddStatement("");
+                                method.AddInvocationStatement($"services.Configure<{this.GetTypeName(SqsSubscriptionOptionsTemplate.TemplateId)}>", inv => inv
+                                    .AddArgument(new CSharpLambdaBlock("options"), arg =>
+                                    {
+                                        foreach (var subscription in subscriptions)
+                                        {
+                                            var messageType = subscription.SubscriptionItem.GetModelTypeName(this);
+                                            var handlerType = subscription.SubscriptionItem.GetSubscriberTypeName(this);
+                                            arg.AddStatement($"options.Add<{messageType}, {handlerType}>();");
+                                        }
+                                    }));
+                            }
 
                             method.AddStatement("return services;", stmt => stmt.SeparatedFromPrevious());
                         });