chore simplifying project

projeto-gerar-horario/Microsservicos/GerarHorario-Service/GerarHorario-Service.csproj

@@ -1,29 +1,21 @@
-<Project Sdk="Microsoft.NET.Sdk.Web">
-  <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
-    <Nullable>enable</Nullable>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <RootNamespace>GerarHorario_Service</RootNamespace>
-  </PropertyGroup>
-
-
-  <ItemGroup>
-    <ProjectReference Include="..\..\GerarHorario\GerarHorario.csproj" />
-  </ItemGroup>
-
-
-  <ItemGroup>
-    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
-    <PackageReference Include="RabbitMQ.Stream.Client" Version="1.8.2" />
-  </ItemGroup>
-
-
-  <ItemGroup>
-    <Folder Include="Extensions\" />
-  </ItemGroup>
-
-
-  <ItemGroup>
-    <Compile Remove="Extensions\MiddlewareExtensions.cs" />
-  </ItemGroup>
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <RootNamespace>GerarHorario_Service</RootNamespace>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Reference Include="GerarHorario">
+      <HintPath>..\..\GerarHorario\bin\Debug\net8.0\GerarHorario.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+
+</Project>

projeto-gerar-horario/Microsservicos/GerarHorario-Service/Program.cs

@@ -1,23 +1,73 @@
-using GerarHorario_Service.Middlewares;
-
-
-Thread server = new(() =>
-{
-
-    var builder = WebApplication.CreateBuilder(args);
-    var app = builder.Build();
-
-    app.MapGet("/up", () => "up");
-
-
-
-    app.Run();
-});
-
-Thread queue = new(QueueService.ListenQueue);
-
-
-
-server.Start();
-queue.Start();
-
+using System.Text;
+using System.Text.Json;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using Sisgea.GerarHorario;
+using Sisgea.GerarHorario.Core.Dtos.Configuracoes;
+using Sisgea.GerarHorario.Core.Dtos.HorarioGerado;
+
+
+var factory = new ConnectionFactory()
+{
+    HostName = "localhost",
+    UserName = "admin",
+    Password = "admin"
+};
+
+using var connection = factory.CreateConnection();
+
+using var channel = connection.CreateModel();
+channel.QueueDeclare(
+    queue: "gerar_horario",
+    durable: true,
+    exclusive: false,
+    autoDelete: false,
+    arguments: null
+);
+
+channel.QueueDeclare(
+    queue: "horario_gerado",
+    durable: true,
+    exclusive: false,
+    autoDelete: false,
+    arguments: null
+);
+
+void publicarRespostaGerarHorario(HorarioGerado? horarioGerado = null)
+{
+    // TODO: message = JSON(horarioGerado)
+    const string message = "Hello World!";
+    var body = Encoding.UTF8.GetBytes(message);
+
+    channel.BasicPublish(exchange: string.Empty,
+        routingKey: "horario_gerado",
+        basicProperties: null,
+        body: body);
+
+    Console.WriteLine($" [x] Sent {message}");
+}
+
+Console.WriteLine(" [*] Waiting for messages.");
+
+var consumer = new EventingBasicConsumer(channel);
+consumer.Received += (model, ea) =>
+{
+    var body = ea.Body.ToArray();
+    var message = Encoding.UTF8.GetString(body);
+    Console.WriteLine($" [x] Received {message}");
+
+    var options = new JsonSerializerOptions()
+    {
+        PropertyNameCaseInsensitive = true
+    };
+
+    GerarHorarioOptions? gerarHorarioOptions = JsonSerializer.Deserialize<GerarHorarioOptions>(message, options);
+    Console.WriteLine(gerarHorarioOptions);
+
+    publicarRespostaGerarHorario();
+};
+
+channel.BasicConsume(queue: "gerar_horario",
+    autoAck: true,
+    consumer: consumer);
+