Merge pull request 'greenhouseCRUD' (#7) from greenhouseCRUD into dev

Reviewed-on: #7

.dockerignore

@@ -0,0 +1,25 @@
+**/.classpath
+**/.dockerignore
+**/.env
+**/.git
+**/.gitignore
+**/.project
+**/.settings
+**/.toolstarget
+**/.vs
+**/.vscode
+**/*.*proj.user
+**/*.dbmdl
+**/*.jfm
+**/bin
+**/charts
+**/docker-compose*
+**/compose*
+**/Dockerfile*
+**/node_modules
+**/npm-debug.log
+**/obj
+**/secrets.dev.yaml
+**/values.dev.yaml
+LICENSE
+README.md

.env

@@ -0,0 +1,4 @@
+POSTGRES_USER="postgres"
+POSTGRES_PASSWORD="12345"
+POSTGRES_DB="main_database"
+DB_CONNECTION_STRING="Host=postgres:5432;Database=${POSTGRES_DB};Username=${POSTGRES_USER};Password=${POSTGRES_PASSWORD}"

.vscode/launch.json

@@ -0,0 +1,35 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            // Use IntelliSense to find out which attributes exist for C# debugging
+            // Use hover for the description of the existing attributes
+            // For further information visit https://github.com/dotnet/vscode-csharp/blob/main/debugger-launchjson.md.
+            "name": ".NET Core Launch (web)",
+            "type": "coreclr",
+            "request": "launch",
+            "preLaunchTask": "build",
+            // If you have changed target frameworks, make sure to update the program path.
+            "program": "${workspaceFolder}/Cloud/bin/Debug/net6.0/Cloud.dll",
+            "args": [],
+            "cwd": "${workspaceFolder}/Cloud",
+            "stopAtEntry": false,
+            // Enable launching a web browser when ASP.NET Core starts. For more information: https://aka.ms/VSCode-CS-LaunchJson-WebBrowser
+            "serverReadyAction": {
+                "action": "openExternally",
+                "pattern": "\\bNow listening on:\\s+(https?://\\S+)"
+            },
+            "env": {
+                "ASPNETCORE_ENVIRONMENT": "Development"
+            },
+            "sourceFileMap": {
+                "/Views": "${workspaceFolder}/Views"
+            }
+        },
+        {
+            "name": ".NET Core Attach",
+            "type": "coreclr",
+            "request": "attach"
+        }
+    ]
+}

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "dotnet.defaultSolution": "Cloud.sln"
+}

.vscode/tasks.json

@@ -0,0 +1,41 @@
+{
+    "version": "2.0.0",
+    "tasks": [
+        {
+            "label": "build",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "build",
+                "${workspaceFolder}/Cloud.sln",
+                "/property:GenerateFullPaths=true",
+                "/consoleloggerparameters:NoSummary;ForceNoAlign"
+            ],
+            "problemMatcher": "$msCompile"
+        },
+        {
+            "label": "publish",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "publish",
+                "${workspaceFolder}/Cloud.sln",
+                "/property:GenerateFullPaths=true",
+                "/consoleloggerparameters:NoSummary;ForceNoAlign"
+            ],
+            "problemMatcher": "$msCompile"
+        },
+        {
+            "label": "watch",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "watch",
+                "run",
+                "--project",
+                "${workspaceFolder}/Cloud.sln"
+            ],
+            "problemMatcher": "$msCompile"
+        }
+    ]
+}

Cloud.sln

@@ -0,0 +1,22 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.0.31903.59
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cloud", "Cloud\Cloud.csproj", "{D279AAA9-D4F8-4C7B-B34D-44A7429C87AA}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{D279AAA9-D4F8-4C7B-B34D-44A7429C87AA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D279AAA9-D4F8-4C7B-B34D-44A7429C87AA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D279AAA9-D4F8-4C7B-B34D-44A7429C87AA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D279AAA9-D4F8-4C7B-B34D-44A7429C87AA}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal

Cloud/ApplicationContext.cs

@@ -0,0 +1,31 @@
+using Cloud.Models;
+using Microsoft.EntityFrameworkCore;
+
+namespace Cloud;
+public class ApplicationContext : DbContext
+{
+    public DbSet<User> Users { get; set; } = null!;
+    public DbSet<Farm> Farms { get; set; } = null!;
+    public DbSet<Greenhouse> Greenhouses { get; set; } = null!;
+
+    public ApplicationContext(DbContextOptions<ApplicationContext> options)
+        : base(options)
+    {
+    }
+
+    public ApplicationContext()
+        : base(new DbContextOptionsBuilder<ApplicationContext>()
+            .UseNpgsql("Host=localhost;Port=5438;Database=main_database;Username=postgres;Password=12345")
+            .Options)
+    {
+        Database.EnsureCreated();
+    }
+
+    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+    {
+        if (!optionsBuilder.IsConfigured)
+        {
+            optionsBuilder.UseNpgsql("Host=localhost;Port=5438;Database=main_database;Username=postgres;Password=12345");
+        }
+    }
+}

Cloud/Cloud.csproj

@@ -0,0 +1,24 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Confluent.Kafka" Version="2.6.1" />
+    <PackageReference Include="FluentValidation.AspNetCore" Version="11.3.0" />
+    <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="6.0.4" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="6.0.14" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="6.0.6">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+    <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="6.0.7" />
+    <PackageReference Include="StackExchange.Redis" Version="2.8.16" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
+    <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="6.35.0" />
+  </ItemGroup>
+
+</Project>

Cloud/Controllers/AuthController.cs

@@ -0,0 +1,104 @@
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Identity;
+using Cloud.Models;
+using Cloud.Requests;
+using Microsoft.IdentityModel.Tokens;
+using System.IdentityModel.Tokens.Jwt;
+using System.Text;
+using Microsoft.EntityFrameworkCore; 
+using Microsoft.AspNetCore.Authorization;
+using System.Security.Claims;
+
+namespace Cloud.Controllers;
+
+[ApiController]
+[Route("api/[controller]")]
+public class AuthController : ControllerBase
+{
+    private PasswordHasher<User> _passwordHasher;
+    private IConfiguration _config;
+    private ApplicationContext _context;
+
+    public AuthController(IConfiguration config, ApplicationContext context)
+    {
+        _passwordHasher = new PasswordHasher<User>();
+        _config = config;
+        _context = context;
+    }
+
+    [HttpPost("register")]
+    public async Task<IActionResult> Register([FromBody] RegisterRequest request)
+    {
+        var existUser = await _context.Users.SingleOrDefaultAsync(u => u.Email == request.Email);
+
+        if (existUser != null) {
+            return BadRequest("Пользователь с такой эл. почтой уже существует");
+        }
+
+        var user = new User
+        {
+            Name = request.Name,
+            Email = request.Email,
+            Password = _passwordHasher.HashPassword(null, request.Password)
+        };
+
+        _context.Users.Add(user);
+        await _context.SaveChangesAsync();
+
+        return Ok("Пользователь успешно зарегистрирован");
+    }
+
+    [HttpPost("login")]
+    public async Task<IActionResult> Login([FromBody] LoginRequest request)
+    {
+        var user = await _context.Users.SingleOrDefaultAsync(u => u.Email == request.Email);
+
+        if (user == null) {
+            return Unauthorized("Пользователя с такой эл. почтой не существует");
+        }
+
+        var verificationResult = _passwordHasher.VerifyHashedPassword(null, user.Password, request.Password);
+        
+        if (verificationResult == PasswordVerificationResult.Failed) {
+            return Unauthorized("Неверный пароль");
+        }
+
+        var securityKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["Jwt:Key"]));
+        var credentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256);
+
+        var claims = new[]
+        {
+            new Claim(ClaimTypes.Name, user.Email),
+        };
+
+        var Sectoken = new JwtSecurityToken(_config["Jwt:Issuer"],
+            _config["Jwt:Issuer"],
+            claims: claims,
+            expires: DateTime.Now.AddMinutes(120),
+            signingCredentials: credentials);
+
+        var token =  new JwtSecurityTokenHandler().WriteToken(Sectoken);
+
+        return Ok(token);
+    }
+
+    [Authorize]
+    [HttpGet("user")]
+    public async Task<IActionResult> GetAuthUser()
+    {
+        var userEmail = User.Identity.Name;
+
+        var user = await _context.Users.SingleOrDefaultAsync(u => u.Email == userEmail);
+
+        if (user == null) {
+            return NotFound("Пользователь не найден");
+        }
+
+        return Ok(new 
+        {
+            user.Id,
+            user.Name,
+            user.Email
+        });
+    }
+}

Cloud/Controllers/FarmController.cs

@@ -0,0 +1,128 @@
+using Cloud.Models;
+using Cloud.Requests;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
+
+namespace Cloud.Controllers
+{
+    [Authorize]
+    [ApiController]
+    [Route("api/user")]
+    public class FarmController : ControllerBase
+    {
+        private IConfiguration _config;
+        private ApplicationContext _context;
+
+        public FarmController(IConfiguration config, ApplicationContext context)
+        {
+            _config = config;
+            _context = context;
+        }
+
+        [HttpGet("{userId}/farm")]
+        public async Task<ActionResult<List<Farm>>> Index(int userId)
+        {
+            try
+            {
+                List<Farm> farms = await
+                   _context.Farms.Where(x => x.UserId == userId).AsNoTracking().ToListAsync();
+                if (!farms.Any())
+                    return NotFound("Farms is not found");
+
+                return Ok(farms);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpGet("{userId}/farm/{farmId}")]
+        public async Task<ActionResult<Farm>> Show(int userId, int farmId)
+        {
+            try
+            {
+                Farm? farm = await
+                   _context.Farms.FirstOrDefaultAsync(x => x.UserId == userId && x.Id == farmId);
+
+                if (farm == null)
+                    return NotFound("Farm is not found");
+
+                return Ok(farm);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpPost("{userId}/farm")]
+        public async Task<ActionResult<Farm>> Create([FromBody] FarmRequest farmRequest, int userId)
+        {
+            try
+            {
+                var farm = new Farm
+                {
+                    Name = farmRequest.Name,
+                    UserId = userId,
+                    RaspberryIP = farmRequest.RaspberryIP,
+                };
+
+                Farm? farmCreated = _context.Farms.Add(farm).Entity;
+                await _context.SaveChangesAsync();
+
+                return Ok(farmCreated);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpPut("{userId}/farm/{farmId}")]
+        public async Task<ActionResult<Farm>> Update([FromBody] FarmRequest farmRequest, int userId, int farmId)
+        {
+            try
+            {
+                Farm? farm = await _context.Farms.FirstOrDefaultAsync(x => x.Id == farmId && x.UserId == userId);
+
+                if (farm == null)
+                    return NotFound("Farm is not found");
+
+                farm.Name = farmRequest.Name;
+                farm.RaspberryIP = farmRequest.RaspberryIP;
+
+                _context.Farms.Update(farm);
+                await _context.SaveChangesAsync();
+
+                return Ok(farm);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpDelete("{userId}/farm/{farmId}")]
+        public async Task<ActionResult> Delete(int userId, int farmId)
+        {
+            try
+            {
+                Farm? farm = await _context.Farms.FirstOrDefaultAsync(x => x.Id == farmId && x.UserId == userId);
+
+                if (farm == null)
+                    return NotFound("Farm is not found");
+
+                _context.Farms.Remove(farm);
+                await _context.SaveChangesAsync();
+
+                return Ok("Farm deleted successfully");
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+    }
+}

Cloud/Controllers/GreengouseController.cs

@@ -0,0 +1,160 @@
+using Cloud.Models;
+using Cloud.Requests;
+using Cloud.Services.Broker;
+using Cloud.Services.Broker.Support;
+using Cloud.Services.Domain;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Cloud.Controllers
+{
+    [ApiController]
+    [Route("api/farm/{farmId}/greenhouse")]
+    public class GreenhouseController : ControllerBase 
+    {
+        private readonly IGreenhouseService _greenhouseService;
+        public GreenhouseController(IGreenhouseService greenhouseService) 
+        {
+            _greenhouseService = greenhouseService;
+        }
+
+        /// <summary>
+        /// Возвращает текущую информацию о всех теплицах пользователя
+        /// </summary>
+        /// <param name="farmId"></param>
+        /// <returns></returns>
+        [HttpGet]
+        public async Task<ActionResult<List<GreenhouseInfo>>> GetAll(int farmId) 
+        {
+            try
+            {
+                var greenhouses = _greenhouseService.GetAll(farmId);
+                if (greenhouses == null) return NotFound("Greenhouses is not found");
+                return Ok(greenhouses);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        /// <summary>
+        /// Возвращает текущую информацию о конкретной теплице
+        /// </summary>
+        /// <param name="farmId"></param>
+        /// <param name="greenhouseId"></param>
+        /// <returns></returns>
+        [HttpGet("{greenhouseId}")]
+        public async Task<ActionResult<GreenhouseInfo>> Get(int farmId, int greenhouseId) 
+        {
+            try
+            {
+                var greenhouses = _greenhouseService.GetGreenhouseInfo(greenhouseId, farmId);
+                return Ok(greenhouses);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        /// <summary>
+        /// Возвращает сохраненные данные для автоматизации теплицы
+        /// </summary>
+        /// <param name="farmId"></param>
+        /// <param name="greenhouseId"></param>
+        /// <returns></returns>
+        [HttpGet("{greenhouseId}/settings")]
+        public async Task<ActionResult<Greenhouse>> GetGreenhouse(int farmId, int greenhouseId) 
+        {
+            try 
+            {
+                var greenhouse = await _greenhouseService.GetGreenhouse(greenhouseId);
+                if (greenhouse == null) return NotFound("Greenhouses is not found");
+                return Ok(greenhouse);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        /// <summary>
+        /// Сохраняет в базе данных API данные для автоматизации теплицы
+        /// </summary>
+        /// <param name="farmId"></param>
+        /// <param name="greenhouse"></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult<Greenhouse>> SaveToDatabase(int farmId, GreenhouseRequest greenhouse) 
+        {
+            try
+            {
+                var greenhouseEntity = new Greenhouse() 
+                { 
+                    RecomendedTemperature = greenhouse.RecomendedTemperature,
+                    WateringMode = greenhouse.WateringMode,
+                    HeatingMode = greenhouse.HeatingMode
+                };
+
+                var result = await _greenhouseService.Create(greenhouseEntity);
+                return Ok(result);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+            
+        }
+
+        
+        /// <summary>
+        /// Обновляет в базе данных API данные для автоматизации теплицы
+        /// </summary>
+        /// <param name="farmId">ID фермы</param>
+        /// <param name="greenhouseId">ID теплицы</param>
+        /// <param name="greenhouse">Данные для обновления</param>
+        /// <returns>Обновленный объект Greenhouse</returns>
+        [HttpPut("{greenhouseId}/settings")]
+        public async Task<ActionResult<Greenhouse>> Update(int farmId, int greenhouseId, GreenhouseRequest greenhouse) 
+        {
+            try
+            {
+                var greenhouseEntity = new Greenhouse()
+                {
+                    Id = greenhouseId,
+                    FarmId = farmId,
+                    WateringMode = greenhouse.WateringMode,
+                    HeatingMode = greenhouse.HeatingMode,
+                    RecomendedTemperature = greenhouse.RecomendedTemperature
+                };
+
+                var result = await _greenhouseService.Update(greenhouseEntity);
+                return Ok(result);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        /// <summary>
+        /// Удаляет из базы данных API запись настроек автоматизации теплицы
+        /// </summary>
+        /// <param name="farmId"></param>
+        /// <param name="greenhouseId"></param>
+        /// <returns></returns>
+        [HttpDelete("{greenhouseId}")]
+        public async Task<ActionResult> Delete(int farmId, int greenhouseId) 
+        {
+            try
+            {
+                _ = await _greenhouseService.Delete(greenhouseId);
+                return Ok();
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+    }
+}

Cloud/Controllers/ValveController.cs

@@ -0,0 +1,43 @@
+using Cloud.Requests;
+using Cloud.Services;
+using Cloud.Services.Broker;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using System.ComponentModel.DataAnnotations;
+using System.Text.Json;
+
+namespace Cloud.Controllers
+{
+	[Authorize]
+	[ApiController]
+	[Route("api")]
+	public class ValveController : ControllerBase
+	{
+		//Контроллер вентиля
+
+		private readonly IBrokerService _kafkaService;
+
+		public ValveController(IBrokerService kafkaService)
+		{
+			_kafkaService = kafkaService;
+		}
+
+		[HttpPost("farm/{farmId}/greenhouse/{ghId}/watering")]
+		public async Task<IActionResult> interactValve([FromBody] ValveRequest request, int farmId, int ghId)
+		{
+			var kafkaRequest = new
+			{
+				FarmId = farmId,
+				GreenHouseId = ghId,
+				SomeAction = request.Action,
+			};
+
+			var message = JsonSerializer.Serialize(kafkaRequest);
+			return Ok(kafkaRequest);
+			
+			/*await _kafkaService.ProduceAsync("ValvesHeatersRequest", message);
+
+			return Ok($"Valve status is {request.Action}");*/
+		}
+	}
+}

Cloud/Dockerfile

@@ -0,0 +1,30 @@
+FROM mcr.microsoft.com/dotnet/aspnet:6.0 AS base
+WORKDIR /app
+EXPOSE 5124
+
+ENV ASPNETCORE_URLS=http://+:5124
+
+# Creates a non-root user with an explicit UID and adds permission to access the /app folder
+# For more info, please refer to https://aka.ms/vscode-docker-dotnet-configure-containers
+RUN adduser -u 5678 --disabled-password --gecos "" appuser && chown -R appuser /app
+USER appuser
+
+FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build
+ARG configuration=Development
+WORKDIR /src
+COPY ["Cloud.csproj", "."]
+RUN dotnet restore "./Cloud.csproj"
+COPY . .
+WORKDIR "/src/."
+RUN dotnet build "./Cloud.csproj" -c $configuration -o /app/build
+
+FROM build AS publish
+ARG configuration=Development
+RUN dotnet publish "./Cloud.csproj" -c $configuration -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+
+ENTRYPOINT ["dotnet", "Cloud.dll"]
+

Cloud/Enums/ValveEnum.cs

@@ -0,0 +1,9 @@
+namespace Cloud.Enums
+{
+	public enum ValveEnum
+	{
+		Open,
+		Close,
+		Auto
+	}
+}

Cloud/Middlewares/DatabaseMiddleware.cs

@@ -0,0 +1,30 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace Cloud.Middlewares;
+
+public static class DatabaseMiddleware
+{
+    public static void AddDbConnectionService(this IServiceCollection services)
+    {
+        string connectionString = Environment.GetEnvironmentVariable("DB_CONNECTION_STRING") 
+            ?? "Host=localhost;Port=5438;Database=main_database;Username=postgres;Password=12345";
+
+        services.AddDbContext<ApplicationContext>(options =>
+            options.UseNpgsql(connectionString));
+
+    }
+    public static void MigrateDb(this IApplicationBuilder app)
+    {
+        try 
+        {
+            using var scope = app.ApplicationServices.CreateScope();
+            var context = scope.ServiceProvider.GetRequiredService<ApplicationContext>();
+            
+            context.Database.Migrate();
+        }
+        catch (Exception ex) 
+        {
+            Console.WriteLine(ex.Message);
+        }
+    }
+}

Cloud/Migrations/20241027220558_CreateUsersTable.Designer.cs

@@ -0,0 +1,53 @@
+// <auto-generated />
+using Cloud;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+	[DbContext(typeof(ApplicationContext))]
+	[Migration("20241027220558_CreateUsersTable")]
+	partial class CreateUsersTable
+	{
+		protected override void BuildTargetModel(ModelBuilder modelBuilder)
+		{
+#pragma warning disable 612, 618
+			modelBuilder
+				.HasAnnotation("ProductVersion", "6.0.14")
+				.HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+			NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+			modelBuilder.Entity("Cloud.Models.User", b =>
+			{
+				b.Property<int>("Id")
+					.ValueGeneratedOnAdd()
+					.HasColumnType("integer");
+
+				NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+				b.Property<string>("Email")
+					.IsRequired()
+					.HasColumnType("text");
+
+				b.Property<string>("Name")
+					.IsRequired()
+					.HasColumnType("text");
+
+				b.Property<string>("Password")
+					.IsRequired()
+					.HasColumnType("text");
+
+				b.HasKey("Id");
+
+				b.ToTable("Users");
+			});
+#pragma warning restore 612, 618
+		}
+	}
+}

Cloud/Migrations/20241027220558_CreateUsersTable.cs

@@ -0,0 +1,34 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+	public partial class CreateUsersTable : Migration
+	{
+		protected override void Up(MigrationBuilder migrationBuilder)
+		{
+			migrationBuilder.CreateTable(
+				name: "Users",
+				columns: table => new
+				{
+					Id = table.Column<int>(type: "integer", nullable: false)
+						.Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+					Name = table.Column<string>(type: "text", nullable: false),
+					Email = table.Column<string>(type: "text", nullable: false),
+					Password = table.Column<string>(type: "text", nullable: false)
+				},
+				constraints: table =>
+				{
+					table.PrimaryKey("PK_Users", x => x.Id);
+				});
+		}
+
+		protected override void Down(MigrationBuilder migrationBuilder)
+		{
+			migrationBuilder.DropTable(
+				name: "Users");
+		}
+	}
+}

Cloud/Migrations/20241028192806_CreateFarmsTable.Designer.cs

@@ -0,0 +1,95 @@
+// <auto-generated />
+using Cloud;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+    [DbContext(typeof(ApplicationContext))]
+    [Migration("20241028192806_CreateFarmsTable")]
+    partial class CreateFarmsTable
+    {
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "6.0.14")
+                .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("RaspberryMacAddr")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("Farms");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Email")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Password")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Users");
+                });
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.HasOne("Cloud.Models.User", "User")
+                        .WithMany("Farms")
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Navigation("Farms");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

Cloud/Migrations/20241028192806_CreateFarmsTable.cs

@@ -0,0 +1,45 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+    public partial class CreateFarmsTable : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.CreateTable(
+                name: "Farms",
+                columns: table => new
+                {
+                    Id = table.Column<int>(type: "integer", nullable: false)
+                        .Annotation("Npgsql:ValueGenerationStrategy", NpgsqlValueGenerationStrategy.IdentityByDefaultColumn),
+                    Name = table.Column<string>(type: "text", nullable: false),
+                    UserId = table.Column<int>(type: "integer", nullable: false),
+                    RaspberryMacAddr = table.Column<string>(type: "text", nullable: false)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_Farms", x => x.Id);
+                    table.ForeignKey(
+                        name: "FK_Farms_Users_UserId",
+                        column: x => x.UserId,
+                        principalTable: "Users",
+                        principalColumn: "Id",
+                        onDelete: ReferentialAction.Cascade);
+                });
+
+            migrationBuilder.CreateIndex(
+                name: "IX_Farms_UserId",
+                table: "Farms",
+                column: "UserId");
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropTable(
+                name: "Farms");
+        }
+    }
+}

Cloud/Migrations/20241030111034_front.Designer.cs

@@ -0,0 +1,95 @@
+// <auto-generated />
+using Cloud;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+    [DbContext(typeof(ApplicationContext))]
+    [Migration("20241030111034_front")]
+    partial class front
+    {
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "6.0.14")
+                .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("RaspberryMacAddr")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("Farms");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Email")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Password")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Users");
+                });
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.HasOne("Cloud.Models.User", "User")
+                        .WithMany("Farms")
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Navigation("Farms");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

Cloud/Migrations/20241030111034_front.cs

@@ -0,0 +1,19 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+    public partial class front : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+
+        }
+    }
+}

Cloud/Migrations/ApplicationContextModelSnapshot.cs

@@ -0,0 +1,93 @@
+// <auto-generated />
+using Cloud;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+
+#nullable disable
+
+namespace Cloud.Migrations
+{
+    [DbContext(typeof(ApplicationContext))]
+    partial class ApplicationContextModelSnapshot : ModelSnapshot
+    {
+        protected override void BuildModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "6.0.14")
+                .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("RaspberryMacAddr")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("Farms");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("Email")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<string>("Password")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Users");
+                });
+
+            modelBuilder.Entity("Cloud.Models.Farm", b =>
+                {
+                    b.HasOne("Cloud.Models.User", "User")
+                        .WithMany("Farms")
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
+
+            modelBuilder.Entity("Cloud.Models.User", b =>
+                {
+                    b.Navigation("Farms");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

Cloud/Models/Farm.cs

@@ -0,0 +1,12 @@
+namespace Cloud.Models
+{
+    public class Farm
+    {
+        public int Id { get; set; }
+        public string Name { get; set; }
+        public int UserId { get; set; }
+        public User? User { get; set; }
+        public string RaspberryIP { get; set; }
+        List<Greenhouse> Greenhouses { get; set; } = new();
+    }
+}

Cloud/Models/Greenhouse.cs

@@ -0,0 +1,14 @@
+using Cloud.Models.Support;
+
+namespace Cloud.Models
+{
+    public class Greenhouse
+    {
+        public int Id { get; set; }
+        public int RecomendedTemperature { get; set; }
+        public WateringMode WateringMode { get; set; }
+        public HeatingMode HeatingMode { get; set; }
+        public int FarmId { get; set; }
+        public Farm? Farm { get; set; }
+    }
+}

Cloud/Models/Support/HeatingMode.cs

@@ -0,0 +1,8 @@
+namespace Cloud.Models.Support 
+{
+    public enum HeatingMode 
+    {
+        Manual,
+        Auto
+    }
+}

Cloud/Models/Support/WateringMode.cs

@@ -0,0 +1,8 @@
+namespace Cloud.Models.Support 
+{
+    public enum WateringMode 
+    {
+        Manual,
+        Auto
+    }
+}

Cloud/Models/User.cs

@@ -0,0 +1,13 @@
+namespace Cloud.Models;
+public class User
+{
+    public int Id { get; set; }
+
+    public string Name { get; set; }
+
+    public string Email  { get; set; }
+
+    public string Password  { get; set; }
+
+    public List<Farm> Farms { get; set; } = new();
+}

Cloud/Program.cs

@@ -0,0 +1,133 @@
+using Cloud;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.AspNetCore.Authentication.JwtBearer;
+using Microsoft.IdentityModel.Tokens;
+using System.Text;
+using FluentValidation;
+using FluentValidation.AspNetCore;
+using Cloud.Validation;
+using StackExchange.Redis;
+using Cloud.Services.Broker.Implement.Kafka;
+using Cloud.Services.Broker;
+using Cloud.Services;
+using Cloud.Services.Domain.Implement;
+using Cloud.Services.Domain;
+using Cloud.Services.Cache;
+using Cloud.Support;
+using System.Text.RegularExpressions;
+using Cloud.Middlewares;
+
+var builder = WebApplication.CreateBuilder(args);
+
+// Add services to the container.
+builder.Services.AddSingleton<IBrokerService, KafkaService>();
+builder.Services.AddTransient<IGreenhouseService, GreenhouseService>();
+
+//Redis configuration
+string redisUrl = Environment.GetEnvironmentVariable("REDIS_URL") ?? "localhost:6379";
+builder.Services.AddSingleton<IConnectionMultiplexer>(sp =>
+{
+    var configuration = ConfigurationOptions.Parse(redisUrl);
+    return ConnectionMultiplexer.Connect(configuration);
+});
+builder.Services.AddSingleton<IRedisCacheService, RedisCacheService>();
+
+//Jwt configuration
+var jwtIssuer = builder.Configuration.GetSection("Jwt:Issuer").Get<string>();
+var jwtKey = builder.Configuration.GetSection("Jwt:Key").Get<string>();
+
+builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme)
+ .AddJwtBearer(options =>
+ {
+     options.TokenValidationParameters = new TokenValidationParameters
+     {
+         ValidateIssuer = true,
+         ValidateAudience = true,
+         ValidateLifetime = true,
+         ValidateIssuerSigningKey = true,
+         ValidIssuer = jwtIssuer,
+         ValidAudience = jwtIssuer,
+         IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(jwtKey))
+     };
+ });
+// Настройка подключения к БД
+builder.Services.AddDbConnectionService();
+// Настройка CORS
+string frontUrl = Environment.GetEnvironmentVariable("FRONT_URL") ?? "http://localhost:3000";
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("AllowFrontendLocalhost", builder =>
+    {
+        builder.WithOrigins(frontUrl) // фронтенд
+               .AllowAnyHeader()
+               .AllowAnyMethod();
+    });
+});
+
+builder.Services.AddControllers();
+builder.Services.AddFluentValidationAutoValidation();
+builder.Services.AddFluentValidationClientsideAdapters();
+builder.Services.AddValidatorsFromAssemblyContaining<LoginValidator>();
+builder.Services.AddValidatorsFromAssemblyContaining<RegisterValidator>();
+builder.Services.AddValidatorsFromAssemblyContaining<FarmValidator>();
+builder.Services.AddValidatorsFromAssemblyContaining<ValveValidator>();
+
+// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
+builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddSwaggerGen(c =>
+{
+    c.SwaggerDoc("v1", new Microsoft.OpenApi.Models.OpenApiInfo { Title = "Cloud API", Version = "v1" });
+    
+    c.AddSecurityDefinition("Bearer", new Microsoft.OpenApi.Models.OpenApiSecurityScheme
+    {
+        Description = "Введите ваш Bearer токен",
+        Name = "Authorization",
+        In = Microsoft.OpenApi.Models.ParameterLocation.Header,
+        Type = Microsoft.OpenApi.Models.SecuritySchemeType.ApiKey
+    });
+
+    c.AddSecurityRequirement(new Microsoft.OpenApi.Models.OpenApiSecurityRequirement
+    {
+        {
+            new Microsoft.OpenApi.Models.OpenApiSecurityScheme
+            {
+                Reference = new Microsoft.OpenApi.Models.OpenApiReference
+                {
+                    Type = Microsoft.OpenApi.Models.ReferenceType.SecurityScheme,
+                    Id = "Bearer"
+                }
+            },
+            new string[] {}
+        }
+    });
+});
+
+var app = builder.Build();
+
+// Configure the HTTP request pipeline.
+if (app.Environment.IsDevelopment())
+{
+    Console.WriteLine("Swagger enabled");
+    app.UseSwagger();
+    app.UseSwaggerUI(c =>
+    {
+        c.SwaggerEndpoint("/swagger/v1/swagger.json", "Cloud API V1");
+        c.RoutePrefix = string.Empty;
+    });
+}
+
+app.UseHttpsRedirection();
+
+// Включение CORS
+app.UseCors("AllowFrontendLocalhost");
+
+// Применение миграций
+app.MigrateDb();
+
+app.UseAuthentication();
+
+app.UseAuthorization();
+
+app.MapControllers();
+
+app.Run();

Cloud/Properties/launchSettings.json

@@ -0,0 +1,31 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:43967",
+      "sslPort": 44304
+    }
+  },
+  "profiles": {
+    "Cloud": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "https://localhost:7113;http://localhost:5124",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

Cloud/Requests/FarmRequest.cs

@@ -0,0 +1,8 @@
+namespace Cloud.Requests
+{
+    public class FarmRequest
+    {
+        public string Name { get; set; }
+        public string RaspberryIP { get; set; }
+    }
+}

Cloud/Requests/GreenhouseRequest.cs

@@ -0,0 +1,11 @@
+using Cloud.Models.Support;
+
+namespace Cloud.Requests
+{
+    public class GreenhouseRequest 
+    {
+        public int RecomendedTemperature { get; set; }
+        public WateringMode WateringMode { get; set; }
+        public HeatingMode HeatingMode { get; set; }
+    }
+}

Cloud/Requests/LoginRequest.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Cloud.Requests;
+
+public class LoginRequest
+{
+    public string Email  { get; set; }
+
+    public string Password  { get; set; }   
+}

Cloud/Requests/RegisterRequest.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Cloud.Requests;
+
+public class RegisterRequest
+{
+    public string Name { get; set; }
+
+    public string Email  { get; set; }
+
+    public string Password  { get; set; }   
+}

Cloud/Requests/ValveRequest.cs

@@ -0,0 +1,7 @@
+namespace Cloud.Requests
+{
+	public class ValveRequest
+	{
+		public string Action { get; set; }
+	}
+}

Cloud/Services/Broker/IBrokerConsumer.cs

@@ -0,0 +1,9 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerConsumer 
+    {
+        IEnumerable<T>? WaitMessages<T>(string topic) where T : IBrokerResponse;
+    }
+}

Cloud/Services/Broker/IBrokerProducer.cs

@@ -0,0 +1,9 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerProducer 
+    {
+        Task ProduceAsync(string topic, Command command);
+    }
+}

Cloud/Services/Broker/IBrokerService.cs

@@ -0,0 +1,9 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerService : IBrokerProducer, IBrokerConsumer
+    {
+        void ChangeBrokerIp(string ip);
+    }
+}

Cloud/Services/Broker/Implement/Kafka/KafkaConsumer.cs

@@ -0,0 +1,93 @@
+
+using Cloud.Services.Broker.Support;
+using Confluent.Kafka;
+using System.Diagnostics;
+using System.Text.Json;
+
+namespace Cloud.Services.Broker.Implement.Kafka
+{
+    public class KafkaConsumer : IBrokerConsumer
+    {
+        private IConsumer<string, string> _consumer;
+        private readonly IConfiguration _config;
+
+        public KafkaConsumer(IConfiguration config)
+        {
+            _config = config;
+            Console.WriteLine($"KafkaConsumer created. IP:" + _config["KAFKA_URL"]);
+            ChangeBrokerIp(_config["KAFKA_URL"]);
+        }
+
+        public IEnumerable<T>? WaitMessages<T>(string topic)
+            where T : IBrokerResponse
+        {   
+            List<T> res = new();
+            List<PartitionMetadata> partitions;
+
+            using var adminClient = new AdminClientBuilder(new AdminClientConfig { BootstrapServers = _config["KAFKA_URL"] }).Build();
+            var meta = adminClient.GetMetadata(TimeSpan.FromSeconds(20));
+            var currentTopic = meta.Topics.SingleOrDefault(t => t.Topic == topic) 
+                ?? throw new Exception($"Topic {topic} not found");
+            partitions = currentTopic.Partitions;
+            
+            _consumer.Subscribe(topic);
+            foreach (var partition in partitions)
+            {
+                var topicPartition = new TopicPartition(topic, partition.PartitionId);
+                _consumer.Assign(topicPartition);
+
+                T? message = _consume<T>();
+                if (message == null) return null;
+                res.Add(message);
+                
+            }
+            _consumer.Unassign();
+            _consumer.Unsubscribe();
+            return res;
+        }
+
+        private T? _consume<T>() where T : IBrokerResponse
+        {
+            var sw = new Stopwatch();
+            sw.Start();
+            try
+            {
+                while (true)
+                {
+                    var consumeResult = _consumer.Consume(TimeSpan.FromMinutes(1));
+
+                    if (consumeResult?.Message?.Value == null)
+                    {
+                        // Предел по времени
+                        if (sw.Elapsed > TimeSpan.FromMinutes(1))
+                        {
+                            return default;
+                        }
+                        continue;
+                    }
+
+                    string jsonObj = consumeResult.Message.Value;
+                    return JsonSerializer.Deserialize<T>(jsonObj);
+
+                }
+            }
+            catch (Exception ex)
+            {
+                _consumer.Close();
+                throw;
+            }
+        }
+
+        public void ChangeBrokerIp(string ip)
+        {
+            var consumerConfig = new ConsumerConfig() 
+            {
+                BootstrapServers = ip,
+				GroupId = _config["Kafka:GroupId"],
+				AutoOffsetReset = AutoOffsetReset.Earliest,
+            };
+            _consumer?.Close();
+            _consumer = new ConsumerBuilder<string, string>(consumerConfig).Build();
+        }
+    }
+}

Cloud/Services/Broker/Implement/Kafka/KafkaProducer.cs

@@ -0,0 +1,38 @@
+using System.Text.Json;
+using Cloud.Services.Broker.Support;
+using Confluent.Kafka;
+
+namespace Cloud.Services.Broker.Implement.Kafka
+{
+    public class KafkaProducer : IBrokerProducer
+    {
+        private IProducer<string, string> _producer;
+		private readonly IConfiguration _config;
+
+		public KafkaProducer(IConfiguration configuration)
+		{
+			_config = configuration;
+			Console.WriteLine($"KafkaProducer created. IP:" + _config["KAFKA_URL"]);
+            ChangeBrokerIp(_config["KAFKA_URL"]);
+		}
+		public async Task ProduceAsync(string topic, Command command)
+		{
+			var commandSerialized = JsonSerializer.Serialize(command);
+            var message = new Message<string, string> { Key = Guid.NewGuid().ToString(), Value = commandSerialized };
+            
+			//Produce the Message
+			await _producer.ProduceAsync(topic, message);
+		}
+
+        public void ChangeBrokerIp(string ip)
+        {
+			var producerConfig = new ProducerConfig
+			{
+				BootstrapServers = ip
+			};
+
+			//Build the Producer
+			_producer = new ProducerBuilder<string, string>(producerConfig).Build();
+        }
+    }
+}

Cloud/Services/Broker/Implement/Kafka/KafkaService.cs

@@ -0,0 +1,30 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker.Implement.Kafka
+{
+    public class KafkaService : IBrokerService
+    {
+        private readonly KafkaProducer _producer;
+        private readonly KafkaConsumer _consumer;
+
+        public KafkaService(IConfiguration configuration) 
+        {
+            _producer = new KafkaProducer(configuration);
+            _consumer = new KafkaConsumer(configuration);
+        }
+
+        public IEnumerable<T>? WaitMessages<T>(string topic) 
+            where T : IBrokerResponse
+            => _consumer.WaitMessages<T>(topic);
+
+
+        public async Task ProduceAsync(string topic, Command command)
+            => await _producer.ProduceAsync("commands", command);
+
+        public void ChangeBrokerIp(string ip)
+        {
+            _consumer.ChangeBrokerIp(ip);
+            _producer.ChangeBrokerIp(ip);
+        }
+    }
+}

Cloud/Services/Broker/Support/Command.cs

@@ -0,0 +1,10 @@
+using System.Text.Json;
+
+namespace Cloud.Services.Broker.Support
+{
+    public class Command
+    {
+        public Guid GreenhouseId { get; set; }
+        public string CommandName { get; set; } = null!;
+    }
+}

Cloud/Services/Broker/Support/CommandResult.cs

@@ -0,0 +1,9 @@
+namespace Cloud.Services.Broker.Support
+{
+    public class CommandResult : IBrokerResponse
+    {
+        public int CommandId { get; set; }
+        public int GreenhouseId { get; set; }
+        public string ResultMessage { get; set; } = string.Empty;
+    }
+}

Cloud/Services/Broker/Support/GreenhouseInfo.cs

@@ -0,0 +1,12 @@
+namespace Cloud.Services.Broker.Support
+{
+    public class GreenhouseInfo : IBrokerResponse
+    {
+        public int Id { get; set; }
+        public int PercentWater { get; set; }
+        public int SoilTemperature { get; set; }
+        public bool PumpStatus { get; set; }
+        public bool HeatingStatus { get; set; }
+        public bool AutoWateringStatus { get; set; }
+    }
+}

Cloud/Services/Broker/Support/IBrokerResponse.cs

@@ -0,0 +1,6 @@
+namespace Cloud.Services.Broker.Support
+{
+    public interface IBrokerResponse 
+    {
+    }
+}

Cloud/Services/Cache/IRedisCacheService.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Cloud.Services.Cache
+{
+    public interface IRedisCacheService
+    {
+        Task SetCacheAsync<T>(string key, T value, TimeSpan? expiry = null);
+        Task<T?> GetCacheAsync<T>(string key);
+    }
+}

Cloud/Services/Cache/RedisCacheService.cs

@@ -0,0 +1,37 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using StackExchange.Redis;
+using System.Text.Json;
+
+namespace Cloud.Services.Cache
+{
+    public class RedisCacheService : IRedisCacheService
+    {
+        private readonly IConnectionMultiplexer _connectionMultiplexer;
+
+        public RedisCacheService(IConnectionMultiplexer connectionMultiplexer)
+        {
+            _connectionMultiplexer = connectionMultiplexer;
+        }
+
+        public async Task SetCacheAsync<T>(string key, T value, TimeSpan? expiry = null)
+        {
+            var database = _connectionMultiplexer.GetDatabase();
+            var serializedValue = JsonSerializer.Serialize(value);
+            await database.StringSetAsync(key, serializedValue, expiry);
+        }
+
+        public async Task<T?> GetCacheAsync<T>(string key)
+        {
+            var database = _connectionMultiplexer.GetDatabase();
+            var value = await database.StringGetAsync(key);
+
+            if (value.IsNullOrEmpty)
+                return default;
+
+            return JsonSerializer.Deserialize<T>(value);
+        }
+    }
+}

Cloud/Services/Domain/IGreenhouseService.cs

@@ -0,0 +1,45 @@
+using Cloud.Models;
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Domain;
+
+public interface IGreenhouseService
+{
+    /// <summary>
+    /// Возвращает текущую информацию о конкретной теплице из брокера
+    /// </summary>
+    /// <param name="id">ID теплицы</param>
+    /// <param name="farmId">ID фермы, то есть брокера</param>
+    /// <returns>Текущие данные о теплице от менеджера теплицы</returns>
+    public Task<GreenhouseInfo?> GetGreenhouseInfo(int id, int farmId);
+    /// <summary>
+    /// Возвращает сохраненные данные для автоматизации теплицы из базы данных
+    /// </summary>
+    /// <param name="id">ID теплицы</param>
+    /// <returns>Данные для автоматизации теплицы</returns>
+    public Task<Greenhouse?> GetGreenhouse(int id);
+    /// <summary>
+    /// Возвращает список данных о всех теплицах пользователя из брокера
+    /// </summary>
+    /// <param name="farmId">ID фермы</param>
+    /// <returns>Список текущих данных о теплицах</returns>
+    public Task<IEnumerable<GreenhouseInfo>?> GetAll(int farmId);
+    /// <summary>
+    /// Сохраняет данные об автоматизации теплицы в базу данных
+    /// </summary>
+    /// <param name="greenhouse">Данные автоматизации теплицы</param>
+    /// <returns>Созданную сущность из базы данных</returns>
+    public Task<Greenhouse> Create(Greenhouse greenhouse);
+    /// <summary>
+    /// Обновляет данные автоматизации теплицы в базе данных
+    /// </summary>
+    /// <param name="greenhouse">Новая информация об автоматизации теплицы</param>
+    /// <returns>Обновленную сущность из базы данных</returns>
+    public Task<Greenhouse> Update(Greenhouse greenhouse);
+    /// <summary>
+    /// Удаляет данные об автоматизации теплицы из базы данных
+    /// </summary>
+    /// <param name="id">ID данных автоматизации теплицы</param>
+    /// <returns>Возвращает удаленную сущность</returns>
+    public Task<Greenhouse> Delete(int id);
+}

Cloud/Services/Domain/Implement/GreenhouseService.cs

@@ -0,0 +1,67 @@
+using Cloud.Models;
+using Cloud.Services.Broker;
+using Cloud.Services.Broker.Support;
+using Microsoft.EntityFrameworkCore;
+
+namespace Cloud.Services.Domain.Implement;
+
+public class GreenhouseService : IGreenhouseService
+{
+    private readonly IBrokerService _brokerService;
+    private readonly ApplicationContext _context;
+
+    public GreenhouseService(IBrokerService brokerService, ApplicationContext context)
+    {
+        _context = context;
+        _brokerService = brokerService;
+    }
+
+    public async Task<Greenhouse> Create(Greenhouse greenhouse)
+    {
+        var res = await _context.Greenhouses.AddAsync(greenhouse);
+        await _context.SaveChangesAsync();
+        return res.Entity;
+    }
+
+    public async Task<Greenhouse> Delete(int id)
+    {
+        var greenhouse = await _context.Greenhouses.FirstOrDefaultAsync(x => x.Id == id);
+
+        _context.Greenhouses.Remove(greenhouse);
+        await _context.SaveChangesAsync();
+        return greenhouse;
+    }
+
+
+    public async Task<Greenhouse?> GetGreenhouse(int id)
+    {
+        return await _context.Greenhouses.FirstOrDefaultAsync(x => x.Id == id);
+    }
+
+    public async Task<Greenhouse> Update(Greenhouse greenhouse)
+    {
+        var res = _context.Greenhouses.Update(greenhouse);
+        await _context.SaveChangesAsync();
+        return res.Entity;
+    }
+
+    public async Task<IEnumerable<GreenhouseInfo>?> GetAll(int farmId)
+    {
+        // await _changeBrokerIp(farmId);
+        return _brokerService.WaitMessages<GreenhouseInfo>("data");
+    }
+    
+    public async Task<GreenhouseInfo?> GetGreenhouseInfo(int id, int farmId)
+    {
+        // await _changeBrokerIp(farmId);
+        var infos = _brokerService.WaitMessages<GreenhouseInfo>("data");
+        return infos?.FirstOrDefault(x => x.Id == id);
+    }
+
+    private async Task _changeBrokerIp(int farmId)
+    {
+        var farm = await _context.Farms.FirstOrDefaultAsync(x => x.Id == farmId);
+        _brokerService.ChangeBrokerIp(farm.RaspberryIP);
+
+    }
+}

Cloud/Support/NetworkSupport.cs

@@ -0,0 +1,26 @@
+namespace Cloud.Support;
+
+public static class NetworkSupport
+{
+    public static async Task CheckConnectionAsync(string address)
+    {
+        using var client = new HttpClient();
+        try
+        {
+            var response = await client.GetAsync(address);
+
+            if (response.IsSuccessStatusCode)
+            {
+                Console.WriteLine($"Соединение успешно проверено. Статус-код: {response.StatusCode}");
+            }
+            else
+            {
+                Console.WriteLine($"Соединение не удалось проверить. Статус-код: {response.StatusCode}. URL: {address}");
+            }
+        }
+        catch (HttpRequestException ex)
+        {
+            Console.WriteLine($"Ошибка при проверке соединения: {ex.Message}. URL: {address}");
+        }
+    }
+}

Cloud/Validation/FarmValidator.cs

@@ -0,0 +1,18 @@
+using Cloud.Requests;
+using FluentValidation;
+
+namespace Cloud.Validation
+{
+    public class FarmValidator : AbstractValidator<FarmRequest>
+    {
+        public FarmValidator()
+        {
+            RuleFor(request => request.RaspberryIP)
+                .NotEmpty().WithMessage("IP address can't be empty")
+                .Matches(@"^((25[0-5]|(2[0-4]|1\d|[1-9]|)\d)\.?\b){4}$").WithMessage("IP address is not valid");
+
+            RuleFor(request => request.Name)
+                .NotEmpty().WithMessage("Name can't be empty");
+        }
+    }
+}

Cloud/Validation/LoginValidator.cs

@@ -0,0 +1,18 @@
+using Cloud.Requests;
+using FluentValidation;
+
+namespace Cloud.Validation;
+
+public class LoginValidator : AbstractValidator<LoginRequest>
+{
+    public LoginValidator()
+    {
+        RuleFor(request => request.Email)
+            .NotEmpty().WithMessage("Email обязателен для заполнения")
+            .EmailAddress().WithMessage("Некорректный формат Email");
+
+        RuleFor(request => request.Password)
+            .NotEmpty().WithMessage("Пароль обязателен для заполнения")
+            .MinimumLength(8).WithMessage("Пароль должен быть не менее 8 символов");
+    }
+}

Cloud/Validation/RegisterValidator.cs

@@ -0,0 +1,22 @@
+using Cloud.Requests;
+using FluentValidation;
+
+namespace Cloud.Validation;
+
+public class RegisterValidator : AbstractValidator<RegisterRequest>
+{
+    public RegisterValidator()
+    {
+        RuleFor(user => user.Name)
+            .NotEmpty().WithMessage("Имя обязательно для заполнения")
+            .MaximumLength(50).WithMessage("Имя должно быть не более 50 символов");
+
+        RuleFor(user => user.Email)
+            .NotEmpty().WithMessage("Email обязателен для заполнения")
+            .EmailAddress().WithMessage("Некорректный формат Email");
+
+        RuleFor(user => user.Password)
+            .NotEmpty().WithMessage("Пароль обязателен для заполнения")
+            .MinimumLength(8).WithMessage("Пароль должен быть не менее 8 символов");
+    }
+}

Cloud/Validation/ValveValidator.cs

@@ -0,0 +1,16 @@
+using Cloud.Enums;
+using Cloud.Requests;
+using FluentValidation;
+
+namespace Cloud.Validation
+{
+	public class ValveValidator : AbstractValidator<ValveRequest>
+	{
+		public ValveValidator() {
+
+			RuleFor(request => request.Action)
+				.NotEmpty().WithMessage("Action can't be empty").
+				IsEnumName(typeof (ValveEnum)).WithMessage("Action is not correct");
+		}
+	}
+}

Cloud/appsettings.Development.json

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

Cloud/appsettings.json

@@ -0,0 +1,17 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "Kafka": {
+    "BootstrapServers": "localhost:9092",
+    "GroupId": "ValvesHeaters"
+  },
+  "AllowedHosts": "*",
+  "Jwt": {
+    "Key": "m7TyhE20s0dVtUDAr9EnFdPZnAG8maxgBTaiW5j6kO6RQhWDAGxYmXyu0suDnE0o",
+    "Issuer": "localhost"
+  }
+}

docker-compose.yml

@@ -8,6 +8,46 @@ networks:
           gateway: "192.168.2.1"
 
 services:
+  cloud:
+    networks:
+      - vpn
+    build: ./Cloud/
+    ports:
+      - "5124:5124"
+    environment:
+      ASPNETCORE_ENVIRONMENT: Development
+      DB_CONNECTION_STRING: ${DB_CONNECTION_STRING}
+      REDDIS_URL: redis:6379
+      KAFKA_URL: kafka:29092
+      # Добавить, когда будет фронт!
+      # FRONT_URL: front:3000
+    depends_on:
+      - postgres
+      - redis
+  postgres:
+    image: postgres:14
+    container_name: cucumber_database
+    environment:
+      POSTGRES_USER: ${POSTGRES_USER}
+      POSTGRES_PASSWORD: ${POSTGRES_PASSWORD}
+      POSTGRES_DB: ${POSTGRES_DB}
+    ports:
+      - "5438:5432"
+    volumes:
+      - postgres_data:/var/lib/postgresql/data
+  redis:
+    image: 'redis:latest'
+    ports:
+      - '6379:6379'
+    volumes:
+      - 'cloud-redis:/data'
+    healthcheck:
+      test:
+        - CMD
+        - redis-cli
+        - ping
+      retries: 3
+      timeout: 5s
   zookeeper:
     networks:
       - vpn
@@ -17,7 +57,6 @@ services:
       ZOOKEEPER_TICK_TIME: 2000
     ports:
       - 2181:2181
-
   kafka:
     networks:
       vpn:
@@ -26,10 +65,8 @@ services:
     ports:
       - 9092:9092
       - 9997:9997
-
     expose:
       - 29092:29092
-
     environment:
       KAFKA_BROKER_ID: 1
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
@@ -43,7 +80,6 @@ services:
       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
     depends_on:
       - zookeeper
-
   init-kafka:
     networks:
       - vpn
@@ -64,7 +100,6 @@ services:
       echo -e 'Successfully created the following topics:'
       kafka-topics --bootstrap-server kafka:29092 --list
       "
-
   kafka-ui:
     networks:
       - vpn
@@ -78,7 +113,6 @@ services:
       KAFKA_CLUSTERS_0_NAME: local
       KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:29092
       KAFKA_CLUSTERS_0_METRICS_PORT: 9997
-
   manager:
     networks:
       - vpn
@@ -91,7 +125,6 @@ services:
       - kafka
     expose:
       - 20002
-
   detector:
     networks:
       - vpn
@@ -102,4 +135,9 @@ services:
       MANAGER_URL: http://manager:20002
     depends_on:
       - manager
-    
+
+volumes:
+  postgres_data:
+    driver: local
+  cloud-redis:
+    driver: local