Барышников Влад 6513 Лаб. 3

Client.Wasm/Components/StudentCard.razor

@@ -4,10 +4,10 @@
     </CardHeader>
     <CardBody>
         <UnorderedList Unstyled>
-            <UnorderedListItem>Номер <Strong>№X "Название лабораторной"</Strong></UnorderedListItem>
-            <UnorderedListItem>Вариант <Strong>№Х "Название варианта"</Strong></UnorderedListItem>
-            <UnorderedListItem>Выполнена <Strong>Фамилией Именем 65ХХ</Strong> </UnorderedListItem>
-            <UnorderedListItem><Link To="https://puginarug.com/">Ссылка на форк</Link></UnorderedListItem>
+            <UnorderedListItem>Номер <Strong>№3 "Интеграционное тестирование"</Strong></UnorderedListItem>
+            <UnorderedListItem>Вариант <Strong>№36 "SNS, Minio"</Strong></UnorderedListItem>
+            <UnorderedListItem>Выполнена <Strong>Барышниковым Владиславом 6513</Strong> </UnorderedListItem>
+            <UnorderedListItem><Link To="https://github.com/dedrowe/cloud-development">Ссылка на форк</Link></UnorderedListItem>
         </UnorderedList>
     </CardBody>
 </Card>

Client.Wasm/wwwroot/appsettings.json

@@ -6,5 +6,5 @@
     }
   },
   "AllowedHosts": "*",
-  "BaseAddress": ""
+  "BaseAddress": "https://localhost:7200/company-employee"
 }

CloudDevelopment.sln

@@ -5,6 +5,18 @@ VisualStudioVersion = 17.14.36811.4
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Client.Wasm", "Client.Wasm\Client.Wasm.csproj", "{AE7EEA74-2FE0-136F-D797-854FD87E022A}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.Generator", "CompanyEmployee.Generator\CompanyEmployee.Generator.csproj", "{76AE3AB2-7AF9-4BAA-BE4F-1FDEE3D052AA}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.AppHost", "CompanyEmployee.AppHost\CompanyEmployee.AppHost.csproj", "{11A4C40B-7996-4885-88E1-FA478E8AC6B6}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.ServiceDefaults", "CompanyEmployee.ServiceDefaults\CompanyEmployee.ServiceDefaults.csproj", "{DF70F3CE-6CD9-4334-AB24-0A2BBBD081E8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.ApiGateway", "CompanyEmployee.ApiGateway\CompanyEmployee.ApiGateway.csproj", "{00432BCA-E982-451B-9D3F-648FE20FF285}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.EventSink", "CompanyEmployee.EventSink\CompanyEmployee.EventSink.csproj", "{6EF5D762-90CB-48CA-8D24-1AC90560660F}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CompanyEmployee.Tests", "CompanyEmployee.Tests\CompanyEmployee.Tests.csproj", "{28BC6A02-0734-45B8-89E9-EE44E9927921}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -15,6 +27,30 @@ Global
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{76AE3AB2-7AF9-4BAA-BE4F-1FDEE3D052AA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{76AE3AB2-7AF9-4BAA-BE4F-1FDEE3D052AA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{76AE3AB2-7AF9-4BAA-BE4F-1FDEE3D052AA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{76AE3AB2-7AF9-4BAA-BE4F-1FDEE3D052AA}.Release|Any CPU.Build.0 = Release|Any CPU
+		{11A4C40B-7996-4885-88E1-FA478E8AC6B6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{11A4C40B-7996-4885-88E1-FA478E8AC6B6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{11A4C40B-7996-4885-88E1-FA478E8AC6B6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{11A4C40B-7996-4885-88E1-FA478E8AC6B6}.Release|Any CPU.Build.0 = Release|Any CPU
+		{DF70F3CE-6CD9-4334-AB24-0A2BBBD081E8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{DF70F3CE-6CD9-4334-AB24-0A2BBBD081E8}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{DF70F3CE-6CD9-4334-AB24-0A2BBBD081E8}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{DF70F3CE-6CD9-4334-AB24-0A2BBBD081E8}.Release|Any CPU.Build.0 = Release|Any CPU
+		{00432BCA-E982-451B-9D3F-648FE20FF285}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{00432BCA-E982-451B-9D3F-648FE20FF285}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{00432BCA-E982-451B-9D3F-648FE20FF285}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{00432BCA-E982-451B-9D3F-648FE20FF285}.Release|Any CPU.Build.0 = Release|Any CPU
+		{6EF5D762-90CB-48CA-8D24-1AC90560660F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6EF5D762-90CB-48CA-8D24-1AC90560660F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6EF5D762-90CB-48CA-8D24-1AC90560660F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6EF5D762-90CB-48CA-8D24-1AC90560660F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{28BC6A02-0734-45B8-89E9-EE44E9927921}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{28BC6A02-0734-45B8-89E9-EE44E9927921}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{28BC6A02-0734-45B8-89E9-EE44E9927921}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{28BC6A02-0734-45B8-89E9-EE44E9927921}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

CompanyEmployee.ApiGateway/CompanyEmployee.ApiGateway.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+    <PropertyGroup>
+        <TargetFramework>net8.0</TargetFramework>
+        <Nullable>enable</Nullable>
+        <ImplicitUsings>enable</ImplicitUsings>
+    </PropertyGroup>
+
+    <ItemGroup>
+      <PackageReference Include="Ocelot" Version="24.1.0" />
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\CompanyEmployee.ServiceDefaults\CompanyEmployee.ServiceDefaults.csproj" />
+    </ItemGroup>
+
+</Project>

CompanyEmployee.ApiGateway/Program.cs

@@ -0,0 +1,38 @@
+using CompanyEmployee.ApiGateway;
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("wasm", policy =>
+        policy.SetIsOriginAllowed(origin =>
+            {
+                try
+                {
+                    var uri = new Uri(origin);
+                    return uri.Host == "localhost";
+                }
+                catch
+                {
+                    return false;
+                }
+            })
+            .WithMethods("GET")
+            .AllowAnyHeader());
+});
+
+builder.Configuration.AddJsonFile("ocelotSettings.json", optional: false, reloadOnChange: true);
+
+builder.Services.AddOcelot(builder.Configuration).AddCustomLoadBalancer((serviceProvider, _, discoveryProvider) => 
+    new QueryBasedLoadBalancer(discoveryProvider.GetAsync, 
+        serviceProvider.GetRequiredService<ILogger<QueryBasedLoadBalancer>>()));
+
+var app = builder.Build();
+
+app.UseCors("wasm");
+
+await app.UseOcelot();
+
+await app.RunAsync();

CompanyEmployee.ApiGateway/Properties/launchSettings.json

@@ -0,0 +1,38 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:23345",
+      "sslPort": 44320
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:5080",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:7236;http://localhost:5080",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

CompanyEmployee.ApiGateway/QueryBasedLoadBalancer.cs

@@ -0,0 +1,63 @@
+using Ocelot.DownstreamRouteFinder.Finder;
+using Ocelot.LoadBalancer.Interfaces;
+using Ocelot.Responses;
+using Ocelot.Values;
+
+namespace CompanyEmployee.ApiGateway;
+
+/// <summary>
+/// Класс для балансировкик нагрузки с использованием параметра запроса.
+/// </summary>
+/// <param name="services">Функция, возвращающая список downstream-сервисов</param>
+/// <param name="logger">Логгер</param>
+public class QueryBasedLoadBalancer(Func<Task<List<Service>>> services, ILogger<QueryBasedLoadBalancer> logger) 
+    : ILoadBalancer
+{
+
+    public string Type => nameof(QueryBasedLoadBalancer);
+
+    /// <summary>
+    /// Метод для выбора downstream-сервиса на основании параметра запроса.
+    /// Для выбора используется id из запроса. От него вычисляется остаток от деления на количество downstream-сервисов.
+    /// После этого выбирается реплика с соответствующим номером.
+    /// Если из запроса не удалось прочитать id, то используется случайный downstream-сервис.
+    /// </summary>
+    /// <param name="context">Контекст http-запроса</param>
+    /// <returns>OkResponse с адресос выбранного сервиса, если получилось выбрать downstream-сервис, или
+    /// ErrorResponse, если определить downstream-сервис не удалось
+    /// </returns>
+    public async Task<Response<ServiceHostAndPort>> LeaseAsync(HttpContext context)
+    {
+        var availableServices = await services.Invoke();
+        if (availableServices.Count == 0)
+        {
+            logger.LogError("No services available");
+            return new ErrorResponse<ServiceHostAndPort>(
+                new UnableToFindDownstreamRouteError(context.Request.Path.Value, context.Request.Method));
+        }
+
+        var idStr = context.Request.Query["id"].FirstOrDefault("error");
+        if (!int.TryParse(idStr, out var index))
+        {
+            logger.LogWarning($"Could not parse id: {idStr}, random replica will be selected", idStr);
+            index = Random.Shared.Next(availableServices.Count);
+        }
+
+        index %= availableServices.Count;
+        if (index < 0)
+        {
+            index += availableServices.Count;
+        }
+
+        logger.LogInformation($"Using replica with index: {index}", index);
+
+        return new OkResponse<ServiceHostAndPort>(availableServices[index].HostAndPort);
+    }
+
+    /// <summary>
+    /// Метод предназначен для уведомления о завершении запроса к downstream-сервису.
+    /// В query based балансировке не используется.
+    /// </summary>
+    /// <param name="hostAndPort">Адрес downstream-сервиса</param>
+    public void Release(ServiceHostAndPort hostAndPort) { }
+}

CompanyEmployee.ApiGateway/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

CompanyEmployee.ApiGateway/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

CompanyEmployee.ApiGateway/ocelotSettings.json

@@ -0,0 +1,20 @@
+{
+  "Routes": [
+    {
+      "DownstreamPathTemplate": "/company-employee",
+      "DownstreamScheme": "https",
+      "DownstreamHostAndPorts": [
+        { "Host": "localhost", "Port": 7301 },
+        { "Host": "localhost", "Port": 7302 },
+        { "Host": "localhost", "Port": 7303 },
+        { "Host": "localhost", "Port": 7304 },
+        { "Host": "localhost", "Port": 7305 }
+      ],
+      "UpstreamPathTemplate": "/company-employee",
+      "UpstreamHttpMethod": [ "GET" ],
+      "LoadBalancerOptions": {
+        "Type": "QueryBasedLoadBalancer"
+      }
+    }
+  ]
+}

CompanyEmployee.AppHost/AppHost.cs

@@ -0,0 +1,66 @@
+using Amazon;
+using Aspire.Hosting.LocalStack.Container;
+
+var builder = DistributedApplication.CreateBuilder(args);
+
+var cache = builder.AddRedis("cache")
+    .WithRedisInsight(containerName: "redis-insight");
+
+var gateway = builder.AddProject<Projects.CompanyEmployee_ApiGateway>("api-gateway")
+    .WithEndpoint("https", e => e.Port = 7200)
+    .WithExternalHttpEndpoints();
+
+var awsConfig = builder.AddAWSSDKConfig()
+    .WithProfile("default")
+    .WithRegion(RegionEndpoint.EUCentral1);
+
+var localstack = builder
+    .AddLocalStack("localstack", awsConfig: awsConfig, configureContainer: container =>
+    {
+        container.Lifetime = ContainerLifetime.Session;
+        container.DebugLevel = 1;
+        container.LogLevel = LocalStackLogLevel.Debug;
+        container.Port = 4566;
+        container.AdditionalEnvironmentVariables
+            .Add("DEBUG", "1");
+        container.AdditionalEnvironmentVariables
+            .Add("SNS_CERT_URL_HOST", "sns.eu-central-1.amazonaws.com");
+    });
+
+var awsResources = builder
+    .AddAWSCloudFormationTemplate("resources", "CloudFormation/company-employee-template-sns.yaml", "company-employee")
+    .WithReference(awsConfig);
+
+const int startGeneratorPort = 7301;
+for (var i = 0; i < 5; ++i)
+{
+    var generator = builder.AddProject<Projects.CompanyEmployee_Generator>($"generator-{i}")
+        .WithEndpoint("https", e => e.Port = startGeneratorPort + i)
+        .WithReference(cache)
+        .WithReference(awsResources)
+        .WithEnvironment("Settings__MessageBroker", "SNS")
+        .WaitFor(cache)
+        .WaitFor(awsResources);
+
+    gateway.WaitFor(generator);
+}
+
+var minio = builder.AddMinioContainer("minio");
+
+var eventSink = builder.AddProject<Projects.CompanyEmployee_EventSink>("event-sink")
+    .WithReference(awsResources)
+    .WithEnvironment("Settings__MessageBroker", "SNS")
+    .WithEnvironment("Settings__S3Hosting", "Minio")
+    .WithEnvironment("AWS__Resources__SNSUrl", "http://host.docker.internal:5225/api/sns")
+    .WithEnvironment("AWS__Resources__MinioBucketName", "company-employee-bucket")
+    .WithReference(minio)
+    .WaitFor(minio)
+    .WaitFor(awsResources);
+
+var client = builder.AddProject<Projects.Client_Wasm>("client")
+    .WithReference(gateway)
+    .WaitFor(gateway);
+
+builder.UseLocalStack(localstack);
+
+builder.Build().Run();

CompanyEmployee.AppHost/CompanyEmployee.AppHost.csproj

@@ -0,0 +1,33 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <Sdk Name="Aspire.AppHost.Sdk" Version="9.5.0" />
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net8.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <UserSecretsId>9511602b-1df2-46c9-8aeb-4a3bacf565a2</UserSecretsId>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Aspire.Hosting.AppHost" Version="9.5.0" />
+        <PackageReference Include="Aspire.Hosting.Redis" Version="9.5.0" />
+        <PackageReference Include="CommunityToolkit.Aspire.Hosting.Minio" Version="9.9.0" />
+        <PackageReference Include="LocalStack.Aspire.Hosting" Version="9.5.3" />
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\Client.Wasm\Client.Wasm.csproj" />
+      <ProjectReference Include="..\CompanyEmployee.ApiGateway\CompanyEmployee.ApiGateway.csproj" />
+      <ProjectReference Include="..\CompanyEmployee.EventSink\CompanyEmployee.EventSink.csproj" />
+      <ProjectReference Include="..\CompanyEmployee.Generator\CompanyEmployee.Generator.csproj" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <None Update="CloudFormation\company-employee-template-sns.yaml">
+            <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+        </None>
+    </ItemGroup>
+
+</Project>