aleikin_artem_lab_2 is ready

.gitignore

@@ -0,0 +1,17 @@
+################################################################################
+# Данный GITIGNORE-файл был автоматически создан Microsoft(R) Visual Studio.
+################################################################################
+
+/.vs
+/aleikin_artem_lab_2/MySolution/.vs
+/aleikin_artem_lab_2/MySolution/ConsoleApp1/obj
+/aleikin_artem_lab_2/MySolution/ConsoleApp2/obj
+/dozorova_alena_lab_2/ConsoleApp2/obj
+/dozorova_alena_lab_3
+/dozorova_alena_lab_4
+/dozorova_alena_lab_5/ConsoleApp1/obj
+/dozorova_alena_lab_6/ConsoleApp1/obj
+/aleikin_artem_lab_2/.vs
+/aleikin_artem_lab_2/ConsoleApp1/obj
+/aleikin_artem_lab_2/ConsoleApp2/obj
+/aleikin_artem_lab_2/MySolution.sln

aleikin_artem_lab_2/.dockerignore

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

aleikin_artem_lab_2/ConsoleApp1/ConsoleApp1.csproj

@@ -1,14 +1,15 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
-
+
-  <PropertyGroup>
+  <PropertyGroup>
-    <OutputType>Exe</OutputType>
+    <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
+    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
+    <Nullable>enable</Nullable>
-  </PropertyGroup>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
-
+  </PropertyGroup>
-  <ItemGroup>
+
-    <PackageReference Include="BenchmarkDotNet" Version="0.14.0" />
+  <ItemGroup>
-  </ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
-
+  </ItemGroup>
-</Project>
+
+</Project>

aleikin_artem_lab_2/ConsoleApp1/ConsoleApp1.csproj.user

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>Container (Dockerfile)</ActiveDebugProfile>
+  </PropertyGroup>
+</Project>

aleikin_artem_lab_2/ConsoleApp1/Dockerfile

@@ -0,0 +1,28 @@
+# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
+
+# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
+FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
+USER app
+WORKDIR /app
+
+
+# Этот этап используется для сборки проекта службы
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["ConsoleApp1/ConsoleApp1.csproj", "ConsoleApp1/"]
+RUN dotnet restore "./ConsoleApp1/ConsoleApp1.csproj"
+COPY . .
+WORKDIR "/src/ConsoleApp1"
+RUN dotnet build "./ConsoleApp1.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./ConsoleApp1.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "ConsoleApp1.dll"]

aleikin_artem_lab_2/ConsoleApp1/Program.cs

@@ -0,0 +1,36 @@
+using System;
+using System.IO;
+
+class Program
+{
+    static void Main()
+    {
+        const string inputDir = "/var/data";
+        const string outputFile = "/var/result/data.txt";
+
+        try
+        {
+            using (var writer = new StreamWriter(outputFile))
+            {
+                var files = Directory.GetFiles(inputDir);
+                foreach (var file in files)
+                {
+                    using (var reader = new StreamReader(file))
+                    {
+                        string firstLine = reader.ReadLine();
+                        if (!string.IsNullOrEmpty(firstLine))
+                        {
+                            writer.WriteLine(firstLine);
+                        }
+                    }
+                }
+            }
+
+            Console.WriteLine($"Файл {outputFile} успешно создан.");
+        }
+        catch (Exception ex)
+        {
+            Console.WriteLine($"Ошибка: {ex.Message}");
+        }
+    }
+}

aleikin_artem_lab_2/ConsoleApp1/Properties/launchSettings.json

@@ -0,0 +1,10 @@
+{
+  "profiles": {
+    "ConsoleApp1": {
+      "commandName": "Project"
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker"
+    }
+  }
+}

aleikin_artem_lab_2/ConsoleApp2/ConsoleApp2.csproj

@@ -1,10 +1,15 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
-
+
-  <PropertyGroup>
+  <PropertyGroup>
-    <OutputType>Exe</OutputType>
+    <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
+    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
+    <Nullable>enable</Nullable>
-  </PropertyGroup>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
-
+  </PropertyGroup>
-</Project>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
+  </ItemGroup>
+
+</Project>

aleikin_artem_lab_2/ConsoleApp2/ConsoleApp2.csproj.user

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>Container (Dockerfile)</ActiveDebugProfile>
+  </PropertyGroup>
+</Project>

aleikin_artem_lab_2/ConsoleApp2/Dockerfile

@@ -0,0 +1,28 @@
+# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
+
+# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
+FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
+USER app
+WORKDIR /app
+
+
+# Этот этап используется для сборки проекта службы
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["ConsoleApp2/ConsoleApp2.csproj", "ConsoleApp2/"]
+RUN dotnet restore "./ConsoleApp2/ConsoleApp2.csproj"
+COPY . .
+WORKDIR "/src/ConsoleApp2"
+RUN dotnet build "./ConsoleApp2.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./ConsoleApp2.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "ConsoleApp2.dll"]

aleikin_artem_lab_2/ConsoleApp2/Program.cs

@@ -0,0 +1,34 @@
+using System;
+using System.IO;
+using System.Linq;
+
+class Program
+{
+    static void Main()
+    {
+        const string inputFile = "/var/result/data.txt";
+        const string outputFile = "/var/result/result.txt";
+
+        try
+        {
+            var lines = File.ReadAllLines(inputFile).Select(int.Parse).ToArray();
+
+            if (lines.Length >= 2)
+            {
+                int result = lines.First() * lines.Last();
+
+                File.WriteAllText(outputFile, result.ToString());
+
+                Console.WriteLine($"Произведение: {result}");
+            }
+            else
+            {
+                Console.WriteLine("Недостаточно данных в файле для вычисления.");
+            }
+        }
+        catch (Exception ex)
+        {
+            Console.WriteLine($"Ошибка: {ex.Message}");
+        }
+    }
+}

aleikin_artem_lab_2/ConsoleApp2/Properties/launchSettings.json

@@ -0,0 +1,10 @@
+{
+  "profiles": {
+    "ConsoleApp2": {
+      "commandName": "Project"
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker"
+    }
+  }
+}

aleikin_artem_lab_2/data/file1.txt

@@ -0,0 +1,10 @@
+25
+91
+77
+63
+45
+25
+21
+89
+6
+18

aleikin_artem_lab_2/data/file10.txt

@@ -0,0 +1,10 @@
+10
+3
+38
+9
+36
+43
+96
+31
+95
+58

aleikin_artem_lab_2/data/file11.txt

@@ -0,0 +1,10 @@
+13
+35
+38
+31
+19
+94
+94
+84
+18
+47

aleikin_artem_lab_2/data/file12.txt

@@ -0,0 +1,10 @@
+9
+32
+75
+92
+100
+85
+85
+10
+50
+54

aleikin_artem_lab_2/data/file13.txt

@@ -0,0 +1,10 @@
+83
+88
+29
+86
+87
+79
+18
+22
+76
+71

aleikin_artem_lab_2/data/file14.txt

@@ -0,0 +1,10 @@
+15
+22
+92
+91
+78
+47
+53
+98
+72
+64

aleikin_artem_lab_2/data/file15.txt

@@ -0,0 +1,10 @@
+66
+45
+83
+55
+25
+82
+95
+42
+18
+6

aleikin_artem_lab_2/data/file16.txt

@@ -0,0 +1,10 @@
+25
+71
+35
+71
+78
+51
+29
+67
+87
+33

aleikin_artem_lab_2/data/file17.txt

@@ -0,0 +1,10 @@
+93
+19
+32
+13
+75
+86
+46
+87
+39
+66

aleikin_artem_lab_2/data/file18.txt

@@ -0,0 +1,10 @@
+7
+74
+69
+75
+45
+28
+92
+9
+77
+32

aleikin_artem_lab_2/data/file19.txt

@@ -0,0 +1,10 @@
+42
+75
+67
+53
+2
+34
+57
+47
+83
+52

aleikin_artem_lab_2/data/file2.txt

@@ -0,0 +1,10 @@
+98
+62
+45
+77
+65
+45
+61
+62
+10
+76

aleikin_artem_lab_2/data/file20.txt

@@ -0,0 +1,10 @@
+41
+30
+41
+39
+62
+3
+79
+93
+56
+82

aleikin_artem_lab_2/data/file21.txt

@@ -0,0 +1,10 @@
+85
+29
+46
+36
+82
+52
+4
+14
+89
+17

aleikin_artem_lab_2/data/file22.txt

@@ -0,0 +1,10 @@
+35
+98
+38
+31
+39
+76
+5
+71
+7
+58

aleikin_artem_lab_2/data/file23.txt

@@ -0,0 +1,10 @@
+50
+93
+18
+76
+13
+62
+16
+45
+65
+25

aleikin_artem_lab_2/data/file24.txt

@@ -0,0 +1,10 @@
+98
+45
+1
+52
+14
+7
+56
+38
+7
+50

aleikin_artem_lab_2/data/file25.txt

@@ -0,0 +1,10 @@
+41
+27
+27
+24
+76
+36
+19
+87
+83
+35

aleikin_artem_lab_2/data/file26.txt

@@ -0,0 +1,10 @@
+16
+5
+95
+36
+20
+60
+79
+46
+61
+77

aleikin_artem_lab_2/data/file27.txt

@@ -0,0 +1,10 @@
+43
+23
+53
+6
+88
+27
+55
+15
+94
+36

aleikin_artem_lab_2/data/file28.txt

@@ -0,0 +1,10 @@
+62
+95
+50
+65
+13
+56
+74
+37
+99
+93

aleikin_artem_lab_2/data/file29.txt

@@ -0,0 +1,10 @@
+13
+2
+31
+49
+80
+73
+47
+61
+96
+69

aleikin_artem_lab_2/data/file3.txt

@@ -0,0 +1,10 @@
+37
+54
+100
+34
+1
+77
+55
+10
+30
+28

aleikin_artem_lab_2/data/file30.txt

@@ -0,0 +1,10 @@
+35
+17
+95
+59
+17
+98
+68
+54
+89
+56

aleikin_artem_lab_2/data/file4.txt

@@ -0,0 +1,10 @@
+38
+80
+93
+2
+61
+29
+4
+41
+83
+100

aleikin_artem_lab_2/data/file5.txt

@@ -0,0 +1,10 @@
+40
+61
+30
+92
+84
+37
+79
+81
+98
+88

aleikin_artem_lab_2/data/file6.txt

@@ -0,0 +1,10 @@
+66
+32
+27
+5
+49
+50
+44
+51
+7
+32

aleikin_artem_lab_2/data/file7.txt

@@ -0,0 +1,10 @@
+9
+46
+16
+27
+14
+78
+6
+45
+26
+99

aleikin_artem_lab_2/data/file8.txt

@@ -0,0 +1,10 @@
+48
+41
+43
+93
+91
+95
+16
+23
+91
+43

aleikin_artem_lab_2/data/file9.txt

@@ -0,0 +1,10 @@
+67
+82
+16
+87
+69
+83
+94
+59
+34
+73

aleikin_artem_lab_2/docker-compose.yml

@@ -0,0 +1,20 @@
+services:
+  app1:
+    build:
+      context: .
+      dockerfile: ConsoleApp1/Dockerfile
+    volumes:
+      - ./data:/var/data
+      - ./result:/var/result
+    container_name: app1
+
+  app2:
+    build:
+      context: .
+      dockerfile: ConsoleApp2/Dockerfile
+    volumes:
+      - ./data:/var/data
+      - ./result:/var/result
+    container_name: app2
+    depends_on:
+      - app1

aleikin_artem_lab_2/readme.md

@@ -0,0 +1,97 @@
+# Лабораторная работа 2 - Разработка простейшего распределённого приложения
+## ПИбд-42 || Алейкин Артем
+
+### Описание
+В данной лабораторной работе мы изучили способы создания и развертывания простого распределённого приложения.
+Для выполнения лабораторной работы в рамках реализации первого проекта был выбран 2-ой вариант, а для второго проекта - 0-ой вариант.
+1.2: Формирует файл /var/result/data.txt из первых строк всех файлов каталога /var/data.
+2.0: Сохраняет произведение первого и последнего числа из файла /var/data/data.txt в /var/result/result.txt.
+
+### Docker-compose.yml
+```
+services:
+  app1:
+    build:
+      context: .
+      dockerfile: ConsoleApp1/Dockerfile
+    volumes:
+      - ./data:/var/data
+      - ./result:/var/result
+    container_name: app1
+
+  app2:
+    build:
+      context: .
+      dockerfile: ConsoleApp2/Dockerfile
+    volumes:
+      - ./data:/var/data
+      - ./result:/var/result
+    container_name: app2
+    depends_on:
+      - app1
+```
+
+app1:
+    build: Контейнер для app1 создается с использованием Dockerfile, расположенного в ConsoleApp1/Dockerfile.
+    volumes: Монтируются две локальные директории:
+    ./data в /var/data внутри контейнера
+    ./result в /var/result внутри контейнера
+    container_name: Контейнер будет называться app1.
+
+app2:
+    build: Контейнер для app2 создается с использованием Dockerfile, расположенного в ConsoleApp2/Dockerfile.
+    volumes: Монтируются те же локальные директории, что и для app1.
+    container_name: Контейнер будет называться app2.
+    depends_on: Контейнер app2 зависит от запуска контейнера app1, что означает, что app2 будет запускаться только после того, как контейнер app1 будет готов.
+
+
+### Шаги для запуска:
+1. Запуск Docker - Desktop
+2. Открыть консоль в папке с docker-compose.yml
+3. Ввести команду:
+```
+docket-compose up --build
+```
+
+#### В результате в папке result создаётся два текстовых документа: 
+
+data - результат работы первого проекта
+```
+25
+10
+13
+9
+83
+15
+66
+25
+93
+7
+42
+98
+41
+85
+35
+50
+98
+41
+16
+43
+62
+13
+37
+35
+38
+40
+66
+9
+48
+67
+```
+result - результат работы второго проекта
+```
+1675
+```
+
+
+Видео демонстрации работы: https://vk.com/video248424990_456239609?list=ln-jAWvJM5pgqjuzJLU1j

aleikin_artem_lab_2/result/data.txt

@@ -0,0 +1,30 @@
+25
+10
+13
+9
+83
+15
+66
+25
+93
+7
+42
+98
+41
+85
+35
+50
+98
+41
+16
+43
+62
+13
+37
+35
+38
+40
+66
+9
+48
+67

aleikin_artem_lab_2/result/result.txt

@@ -0,0 +1 @@
+1675

bazunov_andrew_lab_2/README.md

@@ -1,6 +1,11 @@
-# Распределенные вычисления и приложения Л3
+# Распределенные вычисления и приложения Л2
 ## _Автор Базунов Андрей Игревич ПИбд-42_
 
+Сервисы ( _порядок исполнения сервисов соблюден_ ):
+- 1.FileCreator - (_Создание тестовых данных_)
+- 2.FirstService - (_Выполнение 1.4 варианта задания_)
+- 3.SecondService - (_Выполнение 2.2 варианта задания_)
+
 В качестве основного языка был выбран GoLang. Для каждого сервиса был создан DOCKERFILE где были прописаны условия и действия для сборки каждого из модулей
 
 # Docker
@@ -22,4 +27,4 @@ docker-compose up -d --build
 docker-compose down
 ```
 
-[Демонстрация работы](https://vk.com/video/@viltskaa?z=video236673313_456239577%2Fpl_236673313_-2)
+[Демонстрация работы](https://vk.com/video236673313_456239575)

bazunov_andrew_lab_3/PersonApp/.env

@@ -1,4 +0,0 @@
-PORT=8080
-TASK_APP_URL=http://task-app:8000
-TIMEOUT=15
-DATABASE=./database.db

bazunov_andrew_lab_3/PersonApp/Dockerfile

@@ -1,14 +0,0 @@
-FROM golang:1.23
-
-WORKDIR /app
-
-COPY go.mod go.sum ./
-RUN go mod download
-
-COPY . .
-
-RUN go build -o /bin/PersonApp
-
-EXPOSE 8080
-
-CMD ["/bin/PersonApp"]

bazunov_andrew_lab_3/PersonApp/go.mod

@@ -1,10 +0,0 @@
-module PersonApp
-
-go 1.23.1
-
-require (
-	github.com/gorilla/mux v1.8.1
-	github.com/mattn/go-sqlite3 v1.14.24
-)
-
-require github.com/joho/godotenv v1.5.1 // indirect

bazunov_andrew_lab_3/PersonApp/go.sum

@@ -1,6 +0,0 @@
-github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
-github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
-github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
-github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
-github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
-github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

bazunov_andrew_lab_3/PersonApp/handlers/handlers.go

@@ -1,157 +0,0 @@
-package handlers
-
-import (
-	"PersonApp/httpClient"
-	"PersonApp/models"
-	"PersonApp/repository"
-	"encoding/json"
-	"fmt"
-	"github.com/gorilla/mux"
-	"net/http"
-	"strconv"
-)
-
-func InitRoutes(r *mux.Router, rep repository.PersonRepository, cln httpClient.Client) {
-	r.HandleFunc("/", GetPersons(rep, cln)).Methods("GET")
-	r.HandleFunc("/{id:[0-9]+}", GetPersonById(rep, cln)).Methods("GET")
-	r.HandleFunc("/", CreatePerson(rep)).Methods("POST")
-	r.HandleFunc("/{id:[0-9]+}", UpdatePerson(rep)).Methods("PUT")
-	r.HandleFunc("/{id:[0-9]+}", DeletePerson(rep)).Methods("DELETE")
-}
-
-func GetPersons(rep repository.PersonRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		fmt.Println("GET PERSONS")
-
-		persons, err := rep.GetAllPersons()
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		for i := 0; i < len(persons); i++ {
-			tasks, _ := cln.GetPersonTasks(persons[i].Id)
-			persons[i].Tasks = tasks
-		}
-
-		err = json.NewEncoder(w).Encode(persons)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func GetPersonById(rep repository.PersonRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := rep.GetPersonById(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		tasks, err := cln.GetPersonTasks(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		} else {
-			person.Tasks = tasks
-		}
-
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func CreatePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		var person *models.Person
-
-		err := json.NewDecoder(r.Body).Decode(&person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err = rep.CreatePerson(*person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusCreated)
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func UpdatePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		var person *models.Person
-		err = json.NewDecoder(r.Body).Decode(&person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err = rep.UpdatePerson(models.Person{
-			Id:    id,
-			Name:  person.Name,
-			Tasks: nil,
-		})
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusAccepted)
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-		}
-	}
-}
-
-func DeletePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = rep.DeletePerson(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusOK)
-	}
-}

bazunov_andrew_lab_3/PersonApp/httpClient/client.go

@@ -1,72 +0,0 @@
-package httpClient
-
-import (
-	"PersonApp/models"
-	"encoding/json"
-	"fmt"
-	"io"
-	"net/http"
-	"time"
-)
-
-type Client interface {
-	GetPersonTasks(id int) ([]models.Task, error)
-	TestConnection() (bool, error)
-}
-
-type client struct {
-	BaseUrl string
-	Timeout time.Duration
-}
-
-func (c *client) TestConnection() (bool, error) {
-	client := &http.Client{Timeout: c.Timeout}
-	url := fmt.Sprintf("%s/", c.BaseUrl)
-	resp, err := client.Get(url)
-
-	if err != nil {
-		return false, err
-	}
-
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-			return
-		}
-	}(resp.Body)
-
-	if resp.StatusCode != http.StatusOK {
-		return false, fmt.Errorf("bad status code: %d", resp.StatusCode)
-	}
-	return true, nil
-}
-
-func (c *client) GetPersonTasks(id int) ([]models.Task, error) {
-	client := &http.Client{Timeout: c.Timeout * time.Second}
-	url := fmt.Sprintf("%s/f/%d", c.BaseUrl, id)
-
-	resp, err := client.Get(url)
-	if err != nil {
-		return nil, err
-	}
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-
-		}
-	}(resp.Body)
-
-	body, _ := io.ReadAll(resp.Body)
-
-	var tasks []models.Task
-	if err := json.Unmarshal(body, &tasks); err != nil {
-		fmt.Printf("Unmarshal error: %s", err)
-		return []models.Task{}, err
-	}
-
-	return tasks, nil
-}
-
-func NewClient(baseUrl string, timeout time.Duration) Client {
-	return &client{BaseUrl: baseUrl, Timeout: timeout}
-}

bazunov_andrew_lab_3/PersonApp/httpTests/test.http

@@ -1,34 +0,0 @@
-GET http://localhost/person-app/
-Accept: application/json
-
-###
-
-GET http://localhost/person-app/1
-Accept: application/json
-
-###
-
-POST http://localhost/person-app/
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST3"
-}
-
-###
-
-PUT http://localhost/person-app/3
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST11"
-}
-
-###
-
-DELETE http://localhost/person-app/3
-Accept: application/json
-
-###

bazunov_andrew_lab_3/PersonApp/main.go

@@ -1,47 +0,0 @@
-package main
-
-import (
-	"PersonApp/handlers"
-	"PersonApp/httpClient"
-	"PersonApp/repository"
-	"PersonApp/storage"
-	"github.com/gorilla/mux"
-	"github.com/joho/godotenv"
-	"net/http"
-	"os"
-	"strconv"
-	"time"
-)
-
-func main() {
-	err := godotenv.Load(".env")
-	if err != nil {
-		panic("Error loading .env file")
-	}
-
-	url := os.Getenv("TASK_APP_URL")
-	port := os.Getenv("PORT")
-	databasePath := os.Getenv("DATABASE")
-	timeout, err := strconv.Atoi(os.Getenv("TIMEOUT"))
-
-	if err != nil {
-		panic("Error converting timeout to int")
-	}
-
-	database, err := storage.Init(databasePath)
-	if err != nil {
-		panic(err)
-	}
-
-	cln := httpClient.NewClient(url, time.Duration(timeout))
-	rep := repository.NewPersonRepository(database)
-	router := mux.NewRouter()
-	handlers.InitRoutes(router, rep, cln)
-
-	err = http.ListenAndServe(":"+port, router)
-	if err != nil {
-		panic(err)
-	}
-
-	storage.Close(database)
-}

bazunov_andrew_lab_3/PersonApp/models/models.go

@@ -1,24 +0,0 @@
-package models
-
-type Person struct {
-	Id    int    `json:"id"`
-	Name  string `json:"name"`
-	Tasks []Task `json:"tasks"`
-}
-
-type PersonCreate struct {
-	Name string `json:"name"`
-}
-
-type Task struct {
-	Id       int    `json:"id"`
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}
-
-type TaskCreate struct {
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}

bazunov_andrew_lab_3/PersonApp/repository/personRepository.go

@@ -1,99 +0,0 @@
-package repository
-
-import (
-	"PersonApp/models"
-	"database/sql"
-)
-
-type PersonRepository interface {
-	GetAllPersons() ([]models.Person, error)
-	GetPersonById(id int) (*models.Person, error)
-	CreatePerson(person models.Person) (*models.Person, error)
-	UpdatePerson(person models.Person) (*models.Person, error)
-	DeletePerson(id int) error
-}
-
-type personRepository struct {
-	DB *sql.DB
-}
-
-func NewPersonRepository(db *sql.DB) PersonRepository {
-	return &personRepository{DB: db}
-}
-
-func (pr *personRepository) GetAllPersons() ([]models.Person, error) {
-	rows, err := pr.DB.Query("select * from Persons")
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var persons []models.Person
-
-	for rows.Next() {
-		p := models.Person{}
-		err := rows.Scan(&p.Id, &p.Name)
-		if err != nil {
-			panic(err)
-		}
-
-		persons = append(persons, p)
-	}
-
-	return persons, err
-}
-
-func (pr *personRepository) GetPersonById(id int) (*models.Person, error) {
-	row := pr.DB.QueryRow("select * from Persons where id=?", id)
-
-	person := models.Person{}
-	err := row.Scan(&person.Id, &person.Name)
-	if err != nil {
-		return nil, err
-	}
-
-	return &person, err
-}
-
-func (pr *personRepository) CreatePerson(p models.Person) (*models.Person, error) {
-	res, err := pr.DB.Exec("INSERT INTO Persons (name) values (?)", p.Name)
-
-	if err != nil {
-		return nil, err
-	}
-
-	if res == nil {
-		return nil, nil
-	}
-
-	return &p, err
-}
-
-func (pr *personRepository) UpdatePerson(p models.Person) (*models.Person, error) {
-	res, err := pr.DB.Exec("UPDATE Persons SET name = ? WHERE id = ?", p.Name, p.Id)
-
-	if err != nil {
-		return nil, err
-	}
-
-	if res == nil {
-		return nil, nil
-	}
-
-	return &p, err
-}
-
-func (pr *personRepository) DeletePerson(id int) error {
-	_, err := pr.DB.Exec("DELETE FROM Persons WHERE id = ?", id)
-
-	if err != nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/PersonApp/storage/db.go

@@ -1,36 +0,0 @@
-package storage
-
-import (
-	"database/sql"
-	_ "github.com/mattn/go-sqlite3"
-)
-
-func Init(databasePath string) (*sql.DB, error) {
-	db, err := sql.Open("sqlite3", databasePath)
-
-	if err != nil || db == nil {
-		return nil, err
-	}
-
-	if err := createTableIfNotExists(db); err != nil {
-		return nil, err
-	}
-
-	return db, nil
-}
-
-func Close(db *sql.DB) {
-	err := db.Close()
-	if err != nil {
-		return
-	}
-}
-
-func createTableIfNotExists(db *sql.DB) error {
-	if result, err := db.Exec(
-		"CREATE TABLE IF NOT EXISTS `Persons`(Id integer primary key autoincrement, Name text not null);",
-	); err != nil || result == nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/TaskApp/.env

@@ -1,4 +0,0 @@
-PORT=8000
-PERSON_APP_URL=http://person-app:8080
-TIMEOUT=15
-DATABASE=./database.db

bazunov_andrew_lab_3/TaskApp/Dockerfile

@@ -1,14 +0,0 @@
-FROM golang:1.23
-
-WORKDIR /app
-
-COPY go.mod go.sum ./
-RUN go mod download
-
-COPY . .
-
-RUN go build -o /bin/TaskApp
-
-EXPOSE 8000
-
-CMD ["/bin/TaskApp"]

bazunov_andrew_lab_3/TaskApp/go.mod

@@ -1,10 +0,0 @@
-module TaskApp
-
-go 1.23.1
-
-require (
-	github.com/gorilla/mux v1.8.1
-	github.com/mattn/go-sqlite3 v1.14.24
-)
-
-require github.com/joho/godotenv v1.5.1

bazunov_andrew_lab_3/TaskApp/go.sum

@@ -1,6 +0,0 @@
-github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
-github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
-github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
-github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
-github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
-github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

bazunov_andrew_lab_3/TaskApp/handlers/handlers.go

@@ -1,177 +0,0 @@
-package handlers
-
-import (
-	"TaskApp/httpClient"
-	"TaskApp/models"
-	"TaskApp/repository"
-	"encoding/json"
-	"fmt"
-	"github.com/gorilla/mux"
-	"net/http"
-	"strconv"
-)
-
-func InitRoutes(r *mux.Router, rep repository.TaskRepository, cln httpClient.Client) {
-	r.HandleFunc("/", GetTasks(rep)).Methods("GET")
-	r.HandleFunc("/{id:[0-9]+}", GetTaskById(rep)).Methods("GET")
-	r.HandleFunc("/", CreateTask(rep, cln)).Methods("POST")
-	r.HandleFunc("/{id:[0-9]+}", UpdateTask(rep)).Methods("PUT")
-	r.HandleFunc("/{id:[0-9]+}", DeleteTask(rep)).Methods("DELETE")
-	r.HandleFunc("/f/{id:[0-9]+}", GetPersonTasks(rep)).Methods("GET")
-}
-
-func GetTasks(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		tasks, err := rep.GetAllTasks()
-		if err != nil {
-			w.WriteHeader(http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(tasks)
-		if err != nil {
-			w.WriteHeader(http.StatusInternalServerError)
-		}
-	}
-}
-
-func GetTaskById(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := rep.GetTaskById(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func GetPersonTasks(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		tasks, err := rep.GetUserTasks(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(tasks)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func CreateTask(rep repository.TaskRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		var task *models.TaskCreate
-
-		err := json.NewDecoder(r.Body).Decode(&task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		if &task.Name == nil || &task.PersonId == nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := cln.GetPerson(task.PersonId)
-
-		if err != nil {
-			fmt.Println(err)
-			http.Error(w, "Connection to PersonApp is confused.", http.StatusInternalServerError)
-			return
-		}
-
-		if person == nil {
-			http.Error(w, fmt.Sprintf("Person with id=%d is't founded.", person.Id), http.StatusBadGateway)
-			return
-		}
-
-		newTask, err := rep.CreateTask(*task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusCreated)
-		err = json.NewEncoder(w).Encode(newTask)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func UpdateTask(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		var task *models.TaskCreate
-
-		err = json.NewDecoder(r.Body).Decode(&task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		newTask, err := rep.UpdateTask(models.Task{Id: id, Name: task.Name, Date: task.Date})
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-		err = json.NewEncoder(w).Encode(newTask)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-		}
-	}
-}
-
-func DeleteTask(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		err = rep.DeleteTask(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-		w.WriteHeader(http.StatusOK)
-	}
-}

bazunov_andrew_lab_3/TaskApp/httpClient/client.go

@@ -1,73 +0,0 @@
-package httpClient
-
-import (
-	"TaskApp/models"
-	"encoding/json"
-	"fmt"
-	"io"
-	"log"
-	"net/http"
-	"time"
-)
-
-type Client interface {
-	GetPerson(id int) (*models.Person, error)
-	TestConnection() (bool, error)
-}
-
-type client struct {
-	BaseUrl string
-	Timeout time.Duration
-}
-
-func (c *client) TestConnection() (bool, error) {
-	client := &http.Client{Timeout: c.Timeout}
-	url := fmt.Sprintf("%s/", c.BaseUrl)
-	resp, err := client.Get(url)
-
-	if err != nil {
-		return false, err
-	}
-
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-			return
-		}
-	}(resp.Body)
-
-	if resp.StatusCode != http.StatusOK {
-		return false, fmt.Errorf("bad status code: %d", resp.StatusCode)
-	}
-	return true, nil
-}
-
-func (c *client) GetPerson(id int) (*models.Person, error) {
-	client := &http.Client{Timeout: c.Timeout * time.Second}
-	url := fmt.Sprintf("%s/%d", c.BaseUrl, id)
-
-	resp, err := client.Get(url)
-	if err != nil {
-		return nil, err
-	}
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-
-		}
-	}(resp.Body)
-
-	body, _ := io.ReadAll(resp.Body)
-
-	var person models.Person
-	if err := json.Unmarshal(body, &person); err != nil {
-		log.Printf("Unmarshal error: %s", err)
-		return nil, err
-	}
-
-	return &person, nil
-}
-
-func NewClient(baseUrl string, timeout time.Duration) Client {
-	return &client{BaseUrl: baseUrl, Timeout: timeout}
-}

bazunov_andrew_lab_3/TaskApp/httpTests/tests.http

@@ -1,37 +0,0 @@
-GET http://localhost/task-app/
-Accept: application/json
-
-###
-
-GET http://localhost/task-app/4
-Accept: application/json
-
-###
-
-POST http://localhost/task-app/
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST2",
-  "person_id": 1,
-  "date": "19.02.2202"
-}
-
-###
-
-PUT http://localhost/task-app/4
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST5",
-  "date": "19.02.2202"
-}
-
-###
-
-DELETE http://localhost/task-app/4
-Accept: application/json
-
-###

bazunov_andrew_lab_3/TaskApp/main.go

@@ -1,47 +0,0 @@
-package main
-
-import (
-	"TaskApp/handlers"
-	"TaskApp/httpClient"
-	"TaskApp/repository"
-	"TaskApp/storage"
-	"github.com/gorilla/mux"
-	"github.com/joho/godotenv"
-	"net/http"
-	"os"
-	"strconv"
-	"time"
-)
-
-func main() {
-	err := godotenv.Load(".env")
-	if err != nil {
-		panic("Error loading .env file")
-	}
-
-	url := os.Getenv("PERSON_APP_URL")
-	port := os.Getenv("PORT")
-	databasePath := os.Getenv("DATABASE")
-	timeout, err := strconv.Atoi(os.Getenv("TIMEOUT"))
-
-	if err != nil {
-		panic("Error converting timeout to int")
-	}
-
-	database, err := storage.Init(databasePath)
-	if err != nil {
-		panic(err)
-	}
-
-	cln := httpClient.NewClient(url, time.Duration(timeout))
-	rep := repository.NewTaskRepository(database)
-	router := mux.NewRouter()
-	handlers.InitRoutes(router, rep, cln)
-
-	err = http.ListenAndServe(":"+port, router)
-	if err != nil {
-		panic(err)
-	}
-
-	storage.Close(database)
-}

bazunov_andrew_lab_3/TaskApp/models/models.go

@@ -1,24 +0,0 @@
-package models
-
-type Person struct {
-	Id    int    `json:"id"`
-	Name  string `json:"name"`
-	Tasks []Task `json:"tasks"`
-}
-
-type PersonCreate struct {
-	Name string `json:"name"`
-}
-
-type Task struct {
-	Id       int    `json:"id"`
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}
-
-type TaskCreate struct {
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}

bazunov_andrew_lab_3/TaskApp/repository/taskRepository.go

@@ -1,121 +0,0 @@
-package repository
-
-import (
-	"TaskApp/models"
-	"database/sql"
-)
-
-type TaskRepository interface {
-	GetAllTasks() ([]models.Task, error)
-	GetTaskById(id int) (*models.Task, error)
-	GetUserTasks(id int) ([]models.Task, error)
-	CreateTask(task models.TaskCreate) (*models.Task, error)
-	UpdateTask(task models.Task) (*models.Task, error)
-	DeleteTask(id int) error
-}
-
-type taskRepository struct {
-	DB *sql.DB
-}
-
-func (t taskRepository) GetUserTasks(id int) ([]models.Task, error) {
-	rows, err := t.DB.Query("select * from Tasks where PersonId = ?", id)
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var tasks []models.Task
-
-	for rows.Next() {
-		p := models.Task{}
-		err := rows.Scan(&p.Id, &p.Name, &p.PersonId, &p.Date)
-		if err != nil {
-			panic(err)
-		}
-
-		tasks = append(tasks, p)
-	}
-
-	return tasks, err
-}
-
-func (t taskRepository) GetAllTasks() ([]models.Task, error) {
-	rows, err := t.DB.Query("select * from Tasks")
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var tasks []models.Task
-
-	for rows.Next() {
-		p := models.Task{}
-		err := rows.Scan(&p.Id, &p.Name, &p.PersonId, &p.Date)
-		if err != nil {
-			panic(err)
-		}
-
-		tasks = append(tasks, p)
-	}
-
-	return tasks, err
-}
-
-func (t taskRepository) GetTaskById(id int) (*models.Task, error) {
-	row := t.DB.QueryRow("select * from Tasks where id=?", id)
-
-	task := models.Task{}
-	err := row.Scan(&task.Id, &task.Name, &task.PersonId, &task.Date)
-	if err != nil {
-		return nil, err
-	}
-
-	return &task, err
-}
-
-func (t taskRepository) CreateTask(task models.TaskCreate) (*models.Task, error) {
-	_, err := t.DB.Exec("INSERT INTO Tasks(Name, PersonId, Date) VALUES (?, ?, ?)", task.Name, task.PersonId, task.Date)
-	if err != nil {
-		return nil, err
-	}
-
-	return &models.Task{
-		Id:       0,
-		PersonId: task.PersonId,
-		Name:     task.Name,
-		Date:     task.Date,
-	}, err
-}
-
-func (t taskRepository) UpdateTask(task models.Task) (*models.Task, error) {
-	_, err := t.DB.Exec("UPDATE Tasks SET name = ?, date = ? WHERE id = ?", task.Name, task.Date, task.Id)
-	if err != nil {
-		return nil, err
-	}
-	return &task, err
-}
-
-func (t taskRepository) DeleteTask(id int) error {
-	_, err := t.DB.Exec("DELETE FROM Tasks WHERE id = ?", id)
-	if err != nil {
-		return err
-	}
-	return nil
-}
-
-func NewTaskRepository(db *sql.DB) TaskRepository {
-	return &taskRepository{DB: db}
-}

bazunov_andrew_lab_3/TaskApp/storage/db.go

@@ -1,36 +0,0 @@
-package storage
-
-import (
-	"database/sql"
-	_ "github.com/mattn/go-sqlite3"
-)
-
-func Init(databasePath string) (*sql.DB, error) {
-	db, err := sql.Open("sqlite3", databasePath)
-
-	if err != nil || db == nil {
-		return nil, err
-	}
-
-	if err := createTableIfNotExists(db); err != nil {
-		return nil, err
-	}
-
-	return db, nil
-}
-
-func Close(db *sql.DB) {
-	err := db.Close()
-	if err != nil {
-		return
-	}
-}
-
-func createTableIfNotExists(db *sql.DB) error {
-	if result, err := db.Exec(
-		"CREATE TABLE IF NOT EXISTS `Tasks`(Id integer primary key autoincrement, Name text not null, PersonId integer not null, Date text not null);",
-	); err != nil || result == nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/docker-compose.yaml

@@ -1,34 +0,0 @@
-services:
-  person-app:
-    build:
-      context: ./PersonApp
-      dockerfile: Dockerfile
-    networks:
-      - network
-    ports:
-      - "8080:8080"
-
-  task-app:
-    build:
-      context: ./TaskApp
-      dockerfile: Dockerfile
-    networks:
-      - network
-    ports:
-      - "8000:8000"
-
-  nginx:
-    image: nginx
-    ports:
-      - "80:80"
-    volumes:
-      - ./nginx.conf:/etc/nginx/nginx.conf
-    networks:
-      - network
-    depends_on:
-      - person-app
-      - task-app
-
-networks:
-  network:
-    driver: bridge

bazunov_andrew_lab_3/nginx.conf

@@ -1,59 +0,0 @@
-events {
-    worker_connections 1024;
-}
-
-http {
-    server {
-        listen 80;
-        server_name localhost;
-
-        location /person-app/ {
-            proxy_pass http://person-app:8080/;
-            proxy_set_header Host $host;
-            proxy_set_header X-Real-IP $remote_addr;
-            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-            proxy_set_header X-Forwarded-Proto $scheme;
-            add_header 'Access-Control-Allow-Origin' '*';
-            add_header 'Access-Control-Allow-Methods' 'GET, POST, OPTIONS';
-            add_header 'Access-Control-Allow-Headers' 'Origin, Content-Type, Accept, Authorization';
-
-        }
-
-        location /task-app/ {
-            proxy_pass http://task-app:8000/;
-            proxy_set_header Host $host;
-            proxy_set_header X-Real-IP $remote_addr;
-            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-            proxy_set_header X-Forwarded-Proto $scheme;
-            add_header 'Access-Control-Allow-Origin' '*';
-            add_header 'Access-Control-Allow-Methods' 'GET, POST, OPTIONS';
-            add_header 'Access-Control-Allow-Headers' 'Origin, Content-Type, Accept, Authorization';
-        }
-
-        # Прокси для Swagger (Stream-сервис)
-        #location /stream-service/swagger/ {
-        #    proxy_pass http://stream-service:8000/swagger/;
-        #    proxy_set_header Host $host;
-        #    proxy_set_header X-Real-IP $remote_addr;
-        #    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-        #    proxy_set_header X-Forwarded-Proto $scheme;
-        #}
-
-        # Прокси для Swagger (Message-сервис)
-        #location /message-service/swagger/ {
-        #    proxy_pass http://message-service:8080/swagger/;
-        #    proxy_set_header Host $host;
-        #    proxy_set_header X-Real-IP $remote_addr;
-        #    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-        #    proxy_set_header X-Forwarded-Proto $scheme;
-        #}
-
-        #location /stream-service/doc.json {
-        #    proxy_pass http://stream-service:8000/doc.json;
-        #}
-
-        #location /message-service/doc.json {
-        #    proxy_pass http://message-service:8080/doc.json;
-        #}
-    }
-}

bazunov_andrew_lab_4/README.md

@@ -1,34 +0,0 @@
-# Лабораторная работа №4: Работа с брокером сообщений (RabbitMQ)
-
-## Цель
-
-Изучение проектирования приложений с использованием брокера сообщений RabbitMQ.
-
----
-
-## Задачи
-
-> 1. **Установить RabbitMQ**  
-     Установите RabbitMQ на локальный компьютер (или используйте Docker).
->- [Скачивание RabbitMQ](https://www.rabbitmq.com/download.html)
->- [Релизы RabbitMQ](https://github.com/rabbitmq/rabbitmq-server/releases/)
->- **Пройти уроки RabbitMQ**
->- Сделайте скриншоты, показывающие запуск `producer` и `consumer` и передачу сообщений.
-
----
-## Первый урок
-> ![img.png](static/img1.png)
-
----
-## Второй урок
->![img.png](static/img2.png)
->![img_1.png](static/img3.png)
-
----
-## Третий урок
-> ![img.png](static/img4.png)
-
----
-## Задача
->![img.png](static/img5.png)
-> ![img.png](static/img.png)

bazunov_andrew_lab_4/docker-compose.yaml

@@ -1,17 +0,0 @@
-version: "3.2"
-services:
-  rabbitmq:
-    image: rabbitmq:3-management-alpine
-    container_name: 'rabbitmq'
-    ports:
-        - "5672:5672"
-        - "15672:15672"
-    volumes:
-        - ~/.docker-conf/rabbitmq/data/:/var/lib/rabbitmq/
-        - ~/.docker-conf/rabbitmq/log/:/var/log/rabbitmq
-    networks:
-        - rabbitmq_go_net
-
-networks:
-  rabbitmq_go_net:
-    driver: bridge

bazunov_andrew_lab_4/example/vk_author.py

@@ -1,47 +0,0 @@
-from datetime import datetime
-import random
-import threading
-
-import pika
-import sys
-
-_alphabet = [chr(i) for i in range(97, 123)]
-
-
-def run_every_n_seconds(seconds, action, *args):
-    threading.Timer(seconds, run_every_n_seconds, [seconds, action] + list(args)).start()
-    action(*args)
-
-
-def generate_message():
-    now = datetime.now()
-    current_time = now.strftime("%H:%M:%S")
-    return f"[{current_time}] " + "".join(random.choices(_alphabet, k=random.randint(1, 10)))
-
-
-def send_message(channel_local):
-    message = generate_message()
-    channel_local.basic_publish(
-        exchange='vk_messages',
-        routing_key='vk_messages',
-        body=message,
-        properties=pika.BasicProperties(
-            delivery_mode=pika.DeliveryMode.Persistent
-        ))
-    print(f"[vkAuthor] Sent {message}")
-
-
-def main(conn: pika.BlockingConnection):
-    channel = conn.channel()
-    channel.exchange_declare(exchange='vk_messages', exchange_type='fanout')
-    run_every_n_seconds(1, send_message, channel)
-
-
-if __name__ == '__main__':
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-
-    try:
-        main(connection)
-    except KeyboardInterrupt:
-        connection.close()
-        sys.exit(0)

bazunov_andrew_lab_4/example/vk_reader.py

@@ -1,44 +0,0 @@
-import sys
-from datetime import datetime
-
-import pika
-
-_QUEUE_NAME = "vk_messages_queue"
-_EXCHANGE_NAME = "vk_messages"
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.exchange_declare(
-        exchange=_EXCHANGE_NAME,
-        exchange_type='fanout'
-    )
-
-    channel.queue_declare(queue=_QUEUE_NAME, exclusive=True)
-    channel.queue_bind(exchange=_EXCHANGE_NAME, queue=_QUEUE_NAME)
-
-    def callback(ch, method, properties, body):
-        now = datetime.now()
-        current_time = now.strftime("%H:%M:%S")
-
-        print(f"[vkReader] Received [{str(body)}] in [{current_time}]")
-        ch.basic_ack(delivery_tag=method.delivery_tag)
-
-    channel.basic_consume(
-        queue=_QUEUE_NAME,
-        on_message_callback=callback,
-        auto_ack=False
-    )
-
-    print('[*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/example/vk_slow_reader.py

@@ -1,47 +0,0 @@
-import time
-import random
-from datetime import datetime
-
-import pika
-import sys
-
-_QUEUE_NAME = "vk_messages_queue_slow"
-_EXCHANGE_NAME = "vk_messages"
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.exchange_declare(
-        exchange=_EXCHANGE_NAME,
-        exchange_type='fanout'
-    )
-    channel.queue_declare(queue=_QUEUE_NAME, exclusive=True)
-    channel.queue_bind(exchange=_EXCHANGE_NAME, queue=_QUEUE_NAME)
-
-    def callback(ch, method, properties, body):
-        now = datetime.now()
-        current_time = now.strftime("%H:%M:%S")
-
-        print(f"[vkSlowReader] Received [{str(body)}] in [{current_time}]")
-        read_time = random.randint(2, 5)
-        time.sleep(read_time)
-        ch.basic_ack(delivery_tag=method.delivery_tag)
-
-    channel.basic_consume(
-        queue=_QUEUE_NAME,
-        on_message_callback=callback,
-        auto_ack=False
-    )
-
-    print('[*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/first/receive.py

@@ -1,25 +0,0 @@
-import pika
-import sys
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.queue_declare(queue='hello')
-
-    def callback(ch, method, properties, body):
-        print(f" [x] Received {body}")
-
-    channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
-
-    print(' [*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/first/send.py

@@ -1,11 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='hello')
-
-channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
-print(" [x] Sent 'Hello World!'")
-connection.close()

bazunov_andrew_lab_4/second/new_task.py

@@ -1,19 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-
-message = ' '.join(sys.argv[1:]) or "Hello World!"
-channel.basic_publish(
-    exchange='',
-    routing_key='task_queue',
-    body=message,
-    properties=pika.BasicProperties(
-        delivery_mode=pika.DeliveryMode.Persistent
-    ))
-print(f" [x] Sent {message}")
-connection.close()

bazunov_andrew_lab_4/second/worker.py

@@ -1,22 +0,0 @@
-import pika
-import time
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-print(' [*] Waiting for messages. To exit press CTRL+C')
-
-
-def callback(ch, method, properties, body):
-    print(f" [x] Received {body.decode()}")
-    time.sleep(body.count(b'.'))
-    print(" [x] Done")
-    ch.basic_ack(delivery_tag=method.delivery_tag)
-
-
-channel.basic_qos(prefetch_count=1)
-channel.basic_consume(queue='task_queue', on_message_callback=callback)
-
-channel.start_consuming()

bazunov_andrew_lab_4/third/emit_log.py

@@ -1,13 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-message = ' '.join(sys.argv[1:]) or "info: Hello World!"
-channel.basic_publish(exchange='logs', routing_key='', body=message)
-print(f" [x] Sent {message}")
-connection.close()

bazunov_andrew_lab_4/third/receive_logs.py

@@ -1,24 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-result = channel.queue_declare(queue='', exclusive=True)
-queue_name = result.method.queue
-
-channel.queue_bind(exchange='logs', queue=queue_name)
-
-print(' [*] Waiting for logs. To exit press CTRL+C')
-
-
-def callback(ch, method, properties, body):
-    print(f" [x] {body}")
-
-
-channel.basic_consume(
-    queue=queue_name, on_message_callback=callback, auto_ack=True)
-
-channel.start_consuming()

kadyrov_aydar_lab_4/Consumer_1.py

@@ -1,30 +0,0 @@
-import pika
-import time
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 1 получил сообщение: {body.decode()}')
-
-    # Время задержки по условию
-    time.sleep(2)
-
-    print('Consumer 1 закончил обработку')
-
-
-def consume_events_1():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer1_queue')
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer1_queue')
-
-    channel.basic_consume(queue='consumer1_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 1 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_1()

kadyrov_aydar_lab_4/Consumer_2.py

@@ -1,28 +0,0 @@
-import pika
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 2 получил сообщение: {body.decode()}')
-
-    # Обработка "нон-стопом"
-    print('Consumer 2 закончил обработку')
-
-
-def consume_events_2():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer2_queue')
-
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer2_queue')
-
-    channel.basic_consume(queue='consumer2_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 2 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_2()

kadyrov_aydar_lab_4/README.md

@@ -1,56 +0,0 @@
-### Лабораторная работа №4 - Работа с брокером сообщений
-
-#### Задание
-
-1. Установить брокер сообщений RabbitMQ.
-2. Пройти уроки 1, 2 и 3 из RabbitMQ Tutorials на любом языке программирования.
-3. Продемонстрировать работу брокера сообщений.
-
-#### Описание работы программы:
-
-- **Класс Publisher** успешно осуществляет отправку сообщений своим клиентам.
-  
-- **Класс Consumer1** принимает и обрабатывает сообщения с задержкой в 3 секунды, что можно заметить на видео.
-
-- **Класс Consumer2** мгновенно принимает и обрабатывает сообщения.
-
-#### Уроки
-
-1. lesson_1
-
-![lesson_1.png](lesson_1.png)
-
-2. lesson_2
-
-![lesson_2.png](lesson_2.png)
-
-3. lesson_3
-
-![lesson_3.png](lesson_3.png)
-
-## Работа с RabbitMQ Management UI
-
-![img_3.png](img_3.png)
-
-## Показания очереди queue_1 при одном запущенном экземпляре Consumer_1
-
-![img.png](img.png)
-
-## Показания очереди queue_2
-
-![img_1.png](img_1.png)
-
-## Показания очереди queue_1 при двух запущенных экземплярах Consumer_1
-![img_2.png](img_2.png)
-
-## Показания очереди queue_1 при трех запущенных экземплярах Consumer_1
-
-![img_4.png](img_4.png)
-
-## Диспетчер задач
-
-![img_5.png](img_5.png)
-
-## Видео 
-
-https://vk.com/video64471408_456239207?list=ln-HGhG4o92uxLaxnsLRj