add submodules

.gitignore

@@ -1,4 +1,14 @@
 .vs
+__pycache__
 bin
 obj
+*.vscode
+__pycache__
+.idea
+
+*/target
+
 *.png
+*.csv
+*.jpg
+*.mp4

.gitmodules

@@ -0,0 +1,6 @@
+[submodule "Spring"]
+	path = Spring
+	url = git@github.com:horakhy/springtcc.git
+[submodule "Express"]
+	path = Express
+	url = git@github.com:horakhy/tcc-express.git

.idea/.gitignore

@@ -1,8 +0,0 @@
-# Default ignored files
-/shelf/
-/workspace.xml
-# Editor-based HTTP Client requests
-/httpRequests/
-# Datasource local storage ignored files
-/dataSources/
-/dataSources.local.xml

.idea/inspectionProfiles/profiles_settings.xml

@@ -1,6 +0,0 @@
-<component name="InspectionProjectProfileManager">
-  <settings>
-    <option name="USE_PROJECT_PROFILE" value="false" />
-    <version value="1.0" />
-  </settings>
-</component>

.idea/misc.xml

@@ -1,4 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.10" project-jdk-type="Python SDK" />
-</project>

.idea/modules.xml

@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectModuleManager">
-    <modules>
-      <module fileurl="file://$PROJECT_DIR$/.idea/tcc.iml" filepath="$PROJECT_DIR$/.idea/tcc.iml" />
-    </modules>
-  </component>
-</project>

.idea/tcc.iml

@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<module type="PYTHON_MODULE" version="4">
-  <component name="NewModuleRootManager">
-    <content url="file://$MODULE_DIR$" />
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-  </component>
-</module>

.idea/vcs.xml

@@ -1,6 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="VcsDirectoryMappings">
-    <mapping directory="" vcs="Git" />
-  </component>
-</project>

ASP.NET/Controllers/ImageController.cs

@@ -15,44 +15,16 @@ namespace TCC.Controllers
             this.ImageService = imageService;
         }
 
-        [HttpPost("blur")]
-        public async Task<IActionResult> BlurImage([FromQuery] int radius)
-        {
-            MemoryStream mstream = new MemoryStream();
-            await HttpContext.Request.Body.CopyToAsync(mstream);
-            mstream.Position = 0;
-
-            var result = ImageService.BoxBlurImage(mstream, radius);
-
-            var blurredImageStream = new MemoryStream();
-            result.Write(blurredImageStream);
-            blurredImageStream.Position = 0;
-
-            return File(blurredImageStream, "image/png");
-        }
-
-        [HttpGet("load-image")]
+        [HttpGet("load-small-image")]
         public async Task<IActionResult> GetSimpleImage()
         {
-            var result = ImageService.GetSimpleImage();
-
-            var imageStream = new MemoryStream();
-            result.Write(imageStream);
-            imageStream.Position = 0;
-
-            return File(imageStream, "image/png");
+            return File(ImageService.GetSimpleImage(), "image/png");
         }
 
         [HttpGet("load-big-image")]
         public async Task<IActionResult> GetBigImage()
         {
-            var result = ImageService.GetBigImage();
-
-            var imageStream = new MemoryStream();
-            result.Write(imageStream);
-            imageStream.Position = 0;
-
-            return File(imageStream, "image/png");
+            return File(ImageService.GetBigImage(), "image/png");
         }
 
         [HttpPost("save-big-image")]
@@ -62,6 +34,9 @@ namespace TCC.Controllers
             await HttpContext.Request.Body.CopyToAsync(mstream);
             mstream.Position = 0;
 
+            ImageService.SaveImage(mstream);
+            mstream.Close();
+
             return Ok();
         }
     }

ASP.NET/Controllers/SimulationController.cs

@@ -0,0 +1,53 @@
+using Microsoft.AspNetCore.Mvc;
+using tcc_app.Models;
+
+namespace TCC.Controllers
+{
+    [ApiController]
+    [Route("simulation")]
+    public class SimulationController : ControllerBase
+    {
+        public SimulationController()
+        {
+        }
+
+        [HttpGet("harmonic-progression")]
+        public async Task<IActionResult> GetHarmonicProgression([FromQuery] int n)
+        {
+            double sum = 0;
+            for (int i = 1; i <= n; i++)
+            {
+                sum += 1.0f / i;
+            }
+
+            return Ok(sum);
+        }
+
+        [HttpPost("json")]
+        public async Task<IActionResult> PostJson([FromBody] PersonJson person)
+        {
+            return Ok(person);
+        }
+
+        [HttpPost("protobuf")]
+        public async Task<IActionResult> PostProtobuf()
+        {
+            PersonProto person;
+            byte[] response;
+            using (var stream = Request.BodyReader.AsStream())
+            {
+                person = ProtoBuf.Serializer.Deserialize<PersonProto>(stream);
+            }
+
+            using (var stream = new MemoryStream())
+            {
+                ProtoBuf.Serializer.Serialize(stream, person);
+                response = stream.ToArray();
+            }
+
+            await Response.Body.WriteAsync(response, 0, response.Length);
+            return new EmptyResult();
+        }
+    }
+
+}

ASP.NET/Controllers/StatusController.cs

@@ -11,7 +11,7 @@ namespace TCC.Controllers
         [HttpGet("ok")]
         public async Task<IActionResult> ReturnOk()
         {
-            return Ok(new { status = 200 });
+            return Ok();
         }
     }
 }

ASP.NET/Dockerfile

@@ -2,6 +2,7 @@ FROM mcr.microsoft.com/dotnet/sdk:6.0-bullseye-slim AS build-env
 WORKDIR /App
 
 # Copy everything
+RUN apt update && apt install wget -y
 COPY * .
 
 # Restore as distinct layers
@@ -10,15 +11,23 @@ RUN dotnet restore
 # Build a release
 RUN dotnet build -c Release -o out
 
+RUN cd out && \
+    wget https://files.ivanch.me/api/public/dl/a8pf5HZL/small-image.png && \
+    wget https://files.ivanch.me/api/public/dl/ZoZDck7M/big-image.png && \
+    wget https://files.ivanch.me/api/public/dl/URuFVrtX/video.mp4 && \
+    wget https://files.ivanch.me/api/public/dl/aeZqpr_F/nginx.html && \
+    rm -rf runtimes && \
+    mkdir -p ./static && \
+    mv small-image.png ./static && \
+    mv big-image.png ./static && \
+    mv video.mp4 ./static && \
+    mv nginx.html ./static
+
 # Build runtime image
 FROM mcr.microsoft.com/dotnet/aspnet:6.0-bullseye-slim
 
 WORKDIR /App
 
-RUN wget https://files.ivanch.me/api/public/dl/QFCLgtrG/simpleimage.png && \
-    wget https://files.ivanch.me/api/public/dl/E0VLgWbx/bigimage.png && \
-    rm -rf runtimes
-
 COPY --from=build-env /App/out .
 
 ENTRYPOINT ["dotnet", "/App/TCC.APP.dll"]

ASP.NET/ImageHelper.cs

@@ -1,16 +0,0 @@
-using ImageMagick;
-
-namespace tcc_app
-{
-    public static class ImageHelper
-    {
-        public static MagickImage SimpleImage;
-        public static MagickImage BigImage;
-
-        static ImageHelper()
-        {
-            SimpleImage = new MagickImage("simpleimage.png");
-            BigImage = new MagickImage("bigimage.png");
-        }
-    }
-}

ASP.NET/Models/PersonJson.cs

@@ -0,0 +1,12 @@
+namespace tcc_app.Models
+{
+    public class PersonJson
+    {
+        public string Name { get; set; }
+        public int Age { get; set; }
+        public List<string> Friends { get; set; }
+        public string Email { get; set; }
+        public string Phone { get; set; }
+    }
+
+}

ASP.NET/Models/PersonProto.cs

@@ -0,0 +1,24 @@
+using ProtoBuf;
+
+namespace tcc_app.Models
+{
+    [ProtoContract()]
+    public class PersonProto
+    {
+        [ProtoMember(1)]
+        public string Name { get; set; }
+
+        [ProtoMember(2)]
+        public int Age { get; set; }
+
+        [ProtoMember(3)]
+        public List<string> Friends { get; set; }
+
+        [ProtoMember(4)]
+        public string Email { get; set; }
+
+        [ProtoMember(5)]
+        public string Phone { get; set; }
+    }
+
+}

ASP.NET/Program.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.Server.Kestrel.Core;
+using Microsoft.Extensions.FileProviders;
 using TCC.Services;
 
 namespace TCC
@@ -18,9 +19,13 @@ namespace TCC
                 options.Limits.MaxRequestBodySize = int.MaxValue; // if don't set default value is: 30 MB
             });
 
-
             var app = builder.Build();
 
+            app.UseStaticFiles(new StaticFileOptions
+            {
+                FileProvider = new PhysicalFileProvider(Path.Combine(builder.Environment.ContentRootPath, "static")),
+                RequestPath = "/static"
+            });
             app.MapControllers();
 
             app.Run();

ASP.NET/Properties/launchSettings.json

@@ -14,7 +14,7 @@
       "dotnetRunMessages": true,
       "launchBrowser": false,
       "launchUrl": "weatherforecast",
-      "applicationUrl": "http://0.0.0.0:5100",
+      "applicationUrl": "http://0.0.0.0:9090",
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"
       }

ASP.NET/Services/ImageService.cs

@@ -1,60 +1,9 @@
-using ImageMagick;
-using tcc_app;
-
-namespace TCC.Services
+namespace TCC.Services
 {
     public class ImageService
     {
         public ImageService() { }
 
-        public MagickImage BoxBlurImage(Stream imageStream, int radius)
-        {
-            var image = new MagickImage(imageStream);
-            var blurredImage = new MagickImage(image);
-
-            blurredImage = BoxBlurImageSeparable(image, blurredImage, radius, 0);
-            blurredImage = BoxBlurImageSeparable(image, blurredImage, 0, radius);
-            return blurredImage;
-        }
-
-        private MagickImage BoxBlurImageSeparable(MagickImage image, MagickImage blurredImage, int radiusX, int radiusY)
-        {
-            var pixels = image.GetPixels();
-            var blurredPixels = blurredImage.GetPixelsUnsafe();
-
-            foreach (var pixel in pixels)
-            {
-                int x = pixel.X,
-                    y = pixel.Y;
-
-                long rTotal = 0, gTotal = 0, bTotal = 0;
-                int pixelCount = 0;
-                for (int offsetY = -radiusY; offsetY <= radiusY; offsetY++)
-                {
-                    for (int offsetX = -radiusX; offsetX <= radiusX; offsetX++)
-                    {
-                        int newX = x + offsetX;
-                        int newY = y + offsetY;
-
-                        if (newX >= 0 && newX < image.Width && newY >= 0 && newY < image.Height)
-                        {
-                            var pixelColor = pixels[newX, newY];
-                            rTotal += pixelColor.GetChannel(0);
-                            gTotal += pixelColor.GetChannel(1);
-                            bTotal += pixelColor.GetChannel(2);
-                            pixelCount++;
-                        }
-                    }
-                }
-
-                blurredPixels[x, y].SetChannel(0, Convert.ToUInt16(rTotal / pixelCount));
-                blurredPixels[x, y].SetChannel(1, Convert.ToUInt16(gTotal / pixelCount));
-                blurredPixels[x, y].SetChannel(2, Convert.ToUInt16(bTotal / pixelCount));
-            }
-
-            return blurredImage;
-        }
-
         public void SaveImage(Stream fileStream)
         {
             var file = File.Create("image.png");
@@ -62,14 +11,14 @@ namespace TCC.Services
             file.Close();
         }
 
-        public MagickImage GetSimpleImage()
+        public byte[] GetSimpleImage()
         {
-            return ImageHelper.SimpleImage;
+            return File.ReadAllBytes("static/small-image.png");
         }
 
-        public MagickImage GetBigImage()
+        public byte[] GetBigImage()
         {
-            return ImageHelper.BigImage;
+            return File.ReadAllBytes("static/big-image.png");
         }
     }
 }

ASP.NET/TCC.APP.csproj

@@ -11,8 +11,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Magick.NET-Q16-AnyCPU" Version="13.2.0" />
-    <PackageReference Include="Magick.NET.Core" Version="13.2.0" />
+    <PackageReference Include="protobuf-net" Version="3.2.26" />
   </ItemGroup>
 
   <ItemGroup>

ASP.NET/static/nginx.html

@@ -0,0 +1,33 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Welcome to nginx!</title>
+    <style>
+        html {
+            color-scheme: light dark;
+        }
+
+        body {
+            width: 35em;
+            margin: 0 auto;
+            font-family: Tahoma, Verdana, Arial, sans-serif;
+        }
+    </style>
+</head>
+<body>
+    <h1>Welcome to nginx!</h1>
+    <p>
+        If you see this page, the nginx web server is successfully installed and
+        working. Further configuration is required.
+    </p>
+
+    <p>
+        For online documentation and support please refer to
+        <a href="http://nginx.org/">nginx.org</a>.<br />
+        Commercial support is available at
+        <a href="http://nginx.com/">nginx.com</a>.
+    </p>
+
+    <p><em>Thank you for using nginx.</em></p>
+</body>
+</html>

ActixAPI/.dockerignore

@@ -0,0 +1,2 @@
+Dockerfile
+target/

ActixAPI/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+name = "ActixAPI"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+actix-web = "4"
+actix-files = "0.6.2"
+qstring = "0.7.2"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1"
+futures = "0.3"
+actix-protobuf = "0.10.0"
+prost = { version = "0.12", features = ["prost-derive"] }

ActixAPI/Dockerfile

@@ -0,0 +1,23 @@
+FROM rust:latest
+
+WORKDIR /app
+
+RUN apt-get update && apt-get -y install wget && \
+    wget https://files.ivanch.me/api/public/dl/a8pf5HZL/small-image.png && \
+    wget https://files.ivanch.me/api/public/dl/ZoZDck7M/big-image.png && \
+    wget https://files.ivanch.me/api/public/dl/URuFVrtX/video.mp4 && \
+    wget https://files.ivanch.me/api/public/dl/aeZqpr_F/nginx.html
+
+COPY . .
+
+RUN cargo build --release && \
+    cp ./target/release/ActixAPI . && \
+    mv small-image.png ./static && \
+    mv big-image.png ./static && \
+    mv video.mp4 ./static && \
+    mv nginx.html ./static && \
+    ldconfig /usr/local/lib
+
+ENV LD_LIBRARY_PATH=/usr/local/lib
+
+ENTRYPOINT ["./ActixAPI"]

ActixAPI/src/main.rs

@@ -0,0 +1,111 @@
+use qstring::QString;
+use actix_web::{get, post, web, App, HttpResponse, HttpServer, Responder, HttpRequest, Result};
+use actix_files::NamedFile;
+use actix_protobuf::*;
+use prost::Message;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, PartialEq, Eq, Message)]
+pub struct PersonProtobuf {
+    #[prost(string, tag = "1")]
+    pub name: String,
+    #[prost(int32, tag = "2")]
+    pub age: i32,
+    #[prost(string, repeated, tag = "3")]
+    pub friends: Vec<String>,
+    #[prost(string, tag = "4")]
+    pub email: String,
+    #[prost(string, tag = "5")]
+    pub phone: String,
+}
+
+#[derive(Deserialize, Serialize)]
+pub struct PersonJson {
+    pub name: String,
+    pub age: i32,
+    pub friends: Vec<String>,
+    pub email: String,
+    pub phone: String,
+}
+
+#[get("/status/ok")]
+async fn hello() -> impl Responder {
+    HttpResponse::Ok()
+}
+
+async fn static_serve(req: HttpRequest) -> Result<NamedFile> {
+    let path: &str = req.path();
+    let real_path = &path[1..];
+
+    Ok(NamedFile::open(real_path)?)
+}
+
+#[get("/simulation/harmonic-progression")]
+async fn simulation_harmonic_progression(req: HttpRequest) -> impl Responder {
+    let query_str = req.query_string();
+    let qs = QString::from(query_str);
+    let radius = qs.get("n").unwrap_or("1").parse::<f64>().unwrap_or(1.0);
+
+    let mut sum = 0.0;
+    for i in 1..=radius as i32 {
+        sum += 1.0 / i as f64;
+    }
+
+    HttpResponse::Ok().body(format!("{}", sum))
+}
+
+#[post("/simulation/json")]
+async fn simulation_json(msg: web::Json<PersonJson>) -> impl Responder {
+    HttpResponse::Ok().json(web::Json(msg))
+}
+
+#[post("/simulation/protobuf")]
+async fn simulation_protobuf(msg: ProtoBuf<PersonProtobuf>) -> impl Responder {
+    HttpResponse::Ok().protobuf(msg.0)
+}
+
+#[get("/image/load-small-image")]
+async fn load_small_image() -> Result<NamedFile> {
+    let real_path = "static/small-image.png";
+
+    Ok(NamedFile::open(real_path)?)
+}
+
+#[get("/image/load-big-image")]
+async fn load_big_image() -> Result<NamedFile> {
+    let real_path = "static/big-image.png";
+
+    Ok(NamedFile::open(real_path)?)
+}
+
+#[post("/image/save-big-image")]
+async fn save_big_image(image_data: web::Bytes) -> Result<HttpResponse> {
+    // Write bytes to file
+    std::fs::write("image.png", &image_data).unwrap();
+
+    // Return the blurred image bytes
+    Ok(HttpResponse::Ok()
+        .content_type("application/json")
+        .body("{\"status\": 200}"))
+}
+
+#[actix_web::main]
+async fn main() -> std::io::Result<()> {
+    println!("Hello, world!");
+
+    HttpServer::new(|| {
+        App::new()
+            .route("/static/{filename:.*}", web::get().to(static_serve))
+            .service(hello)
+            .service(load_small_image)
+            .service(load_big_image)
+            .service(save_big_image)
+            .service(simulation_harmonic_progression)
+            .service(simulation_json)
+            .service(simulation_protobuf)
+            .app_data(web::PayloadConfig::new(1024 * 1024 * 1024))
+    })
+    .bind(("0.0.0.0", 5000))?
+    .run()
+    .await
+}

ActixAPI/static/nginx.html

@@ -0,0 +1,33 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Welcome to nginx!</title>
+    <style>
+        html {
+            color-scheme: light dark;
+        }
+
+        body {
+            width: 35em;
+            margin: 0 auto;
+            font-family: Tahoma, Verdana, Arial, sans-serif;
+        }
+    </style>
+</head>
+<body>
+    <h1>Welcome to nginx!</h1>
+    <p>
+        If you see this page, the nginx web server is successfully installed and
+        working. Further configuration is required.
+    </p>
+
+    <p>
+        For online documentation and support please refer to
+        <a href="http://nginx.org/">nginx.org</a>.<br />
+        Commercial support is available at
+        <a href="http://nginx.com/">nginx.com</a>.
+    </p>
+
+    <p><em>Thank you for using nginx.</em></p>
+</body>
+</html>

FlaskAPI/.idea/.gitignore

@@ -1,8 +0,0 @@
-# Default ignored files
-/shelf/
-/workspace.xml
-# Editor-based HTTP Client requests
-/httpRequests/
-# Datasource local storage ignored files
-/dataSources/
-/dataSources.local.xml

FlaskAPI/.idea/FlaskAPI.iml

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<module type="PYTHON_MODULE" version="4">
-  <component name="Flask">
-    <option name="enabled" value="true" />
-  </component>
-  <component name="NewModuleRootManager">
-    <content url="file://$MODULE_DIR$" />
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-  </component>
-  <component name="TemplatesService">
-    <option name="TEMPLATE_CONFIGURATION" value="Jinja2" />
-    <option name="TEMPLATE_FOLDERS">
-      <list>
-        <option value="$MODULE_DIR$/../FlaskAPI\templates" />
-      </list>
-    </option>
-  </component>
-</module>

FlaskAPI/.idea/inspectionProfiles/profiles_settings.xml

@@ -1,6 +0,0 @@
-<component name="InspectionProjectProfileManager">
-  <settings>
-    <option name="USE_PROJECT_PROFILE" value="false" />
-    <version value="1.0" />
-  </settings>
-</component>

FlaskAPI/.idea/misc.xml

@@ -1,4 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.10 (FlaskAPI)" project-jdk-type="Python SDK" />
-</project>

FlaskAPI/.idea/modules.xml

@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectModuleManager">
-    <modules>
-      <module fileurl="file://$PROJECT_DIR$/.idea/FlaskAPI.iml" filepath="$PROJECT_DIR$/.idea/FlaskAPI.iml" />
-    </modules>
-  </component>
-</project>

FlaskAPI/.vscode/launch.json

@@ -1,17 +0,0 @@
-{
-  "version": "0.0.1",
-  "configurations": [
-    
-    {
-      "name": "Python: Flask",
-      "type": "python",
-      "request": "launch",
-      "module": "flask",
-      "env": { "FLASK_APP": "app.py", "FLASK_DEBUG": "1" },
-      "args": ["run", "--no-debugger", "--no-reload"],
-      "jinja": true,
-      "justMyCode": true
-    }
-
-  ]
-}

FlaskAPI/Dockerfile

@@ -1,45 +1,36 @@
-# syntax=docker/dockerfile:1
-
-# Comments are provided throughout this file to help you get started.
-# If you need more help, visit the Dockerfile reference guide at
-# https://docs.docker.com/engine/reference/builder/
-
 ARG PYTHON_VERSION=3.10.12
 FROM python:${PYTHON_VERSION}-slim as base
 
-# Prevents Python from writing pyc files.
 ENV PYTHONDONTWRITEBYTECODE=1
-
-# Keeps Python from buffering stdout and stderr to avoid situations where
-# the application crashes without emitting any logs due to buffering.
 ENV PYTHONUNBUFFERED=1
 
 WORKDIR /app
 
-# Copy the source code into the container.
-COPY . .
+RUN apt-get update && \
+    apt-get install -y wget unzip && \
+    wget https://github.com/protocolbuffers/protobuf/releases/download/v25.0/protoc-25.0-linux-x86_64.zip && \
+    unzip protoc-25.0-linux-x86_64.zip && \
+    mv bin/protoc /usr/local/bin/ && \
+    rm -rf protoc-25.0-linux-x86_64.zip bin include readme.txt
 
-RUN apt-get update && apt-get install -y imagemagick && apt-get install -y wget && ls
-
-RUN wget https://files.ivanch.me/api/public/dl/iFuXSNhw/small-image.png && \
-    wget https://files.ivanch.me/api/public/dl/81Bkht5C/big-image.png && \
-    wget https://files.ivanch.me/api/public/dl/nAndfAjK/video.mp4 && \
+RUN wget https://files.ivanch.me/api/public/dl/a8pf5HZL/small-image.png && \
+    wget https://files.ivanch.me/api/public/dl/ZoZDck7M/big-image.png && \
+    wget https://files.ivanch.me/api/public/dl/URuFVrtX/video.mp4 && \
+    wget https://files.ivanch.me/api/public/dl/aeZqpr_F/nginx.html && \
     rm -rf runtimes && \
     mkdir -p ./static && \
     mv small-image.png ./static && \
     mv big-image.png ./static && \
-    mv video.mp4 ./static
+    mv video.mp4 ./static && \
+    mv nginx.html ./static
+
+COPY . .
 
-# Download dependencies as a separate step to take advantage of Docker's caching.
-# Leverage a cache mount to /root/.cache/pip to speed up subsequent builds.
-# Leverage a bind mount to requirements.txt to avoid having to copy them into
-# into this layer.
 RUN --mount=type=cache,target=/root/.cache/pip \
     --mount=type=bind,source=requirements.txt,target=requirements.txt \
     python -m pip install -r requirements.txt
 
-# Expose the port that the application listens on.
 EXPOSE 5000
 
 # Run the application.
-CMD gunicorn 'app:app' --bind=0.0.0.0:5000
+CMD gunicorn 'app:app' --bind=0.0.0.0:5000 --timeout 3600

FlaskAPI/app.py

@@ -1,12 +1,14 @@
 from flask import Flask
 from controllers.status import status_blueprint
+from controllers.simulation import simulation_blueprint
 from controllers.image import image_blueprint
 
 app = Flask(__name__)
 
-if __name__ == '__main__':
-    app.run()
-
 #
 app.register_blueprint(status_blueprint)
+app.register_blueprint(simulation_blueprint)
 app.register_blueprint(image_blueprint)
+
+if __name__ == '__main__':
+    app.run()

FlaskAPI/compose.yaml

@@ -1,49 +0,0 @@
-# Comments are provided throughout this file to help you get started.
-# If you need more help, visit the Docker compose reference guide at
-# https://docs.docker.com/compose/compose-file/
-
-# Here the instructions define your application as a service called "server".
-# This service is built from the Dockerfile in the current directory.
-# You can add other services your application may depend on here, such as a
-# database or a cache. For examples, see the Awesome Compose repository:
-# https://github.com/docker/awesome-compose
-services:
-  server:
-    build:
-      context: .
-    ports:
-      - 5000:5000
-
-# The commented out section below is an example of how to define a PostgreSQL
-# database that your application can use. `depends_on` tells Docker Compose to
-# start the database before your application. The `db-data` volume persists the
-# database data between container restarts. The `db-password` secret is used
-# to set the database password. You must create `db/password.txt` and add
-# a password of your choosing to it before running `docker compose up`.
-#     depends_on:
-#       db:
-#         condition: service_healthy
-#   db:
-#     image: postgres
-#     restart: always
-#     user: postgres
-#     secrets:
-#       - db-password
-#     volumes:
-#       - db-data:/var/lib/postgresql/data
-#     environment:
-#       - POSTGRES_DB=example
-#       - POSTGRES_PASSWORD_FILE=/run/secrets/db-password
-#     expose:
-#       - 5432
-#     healthcheck:
-#       test: [ "CMD", "pg_isready" ]
-#       interval: 10s
-#       timeout: 5s
-#       retries: 5
-# volumes:
-#   db-data:
-# secrets:
-#   db-password:
-#     file: db/password.txt
-

FlaskAPI/controllers/image.py

@@ -1,28 +1,13 @@
+import io
 from services.image import ImageService
-from static.image_helper import ImageHelper
 from flask import request, Response, Blueprint, jsonify, send_file
 
 image_blueprint = Blueprint('image_blueprint', __name__)
 image_service = ImageService()
 
-
-@image_blueprint.route('/image/blur', methods=['POST'])
-def blur_image():
-    radius = int(request.form.get('radius'))
-    image = request.files.get('file')
-
-    if radius and image:
-        return send_file(image_service.box_blur_image(image, radius),
-                         mimetype='image/jpeg',
-                         as_attachment=True,
-                         download_name='blurred_image.jpeg')
-
-    return "Bad request", 400
-
-
 @image_blueprint.route('/image/load-small-image', methods=['GET'])
 def get_simple_image():
-    return send_file(image_service.get_simple_image(),
+    return send_file(io.BytesIO(image_service.get_simple_image()),
                      mimetype='image/png',
                      as_attachment=True,
                      download_name='small-image.png')
@@ -30,7 +15,7 @@ def get_simple_image():
 
 @image_blueprint.route('/image/load-big-image', methods=['GET'])
 def get_big_image():
-    return send_file(image_service.get_big_image(),
+    return send_file(io.BytesIO(image_service.get_big_image()),
                      mimetype='image/png',
                      as_attachment=True,
                      download_name='big-image.png')
@@ -38,4 +23,6 @@ def get_big_image():
 
 @image_blueprint.route('/image/save-big-image', methods=['POST'])
 def save_image():
-    pass
+    image_service.save_image(request.get_data())
+
+    return "OK", 200

FlaskAPI/controllers/simulation.py

@@ -0,0 +1,41 @@
+from flask import request, Blueprint, jsonify
+import person_pb2
+
+simulation_blueprint = Blueprint('simulation_blueprint', __name__)
+
+class SimulationController:
+    def __init__(self):
+        pass
+
+    def harmonic_progression(self, n):
+        sum = 0
+        for i in range(1, n):
+            sum += 1/i
+
+        return sum
+
+    def return_helloworld(self):
+        return jsonify(message="Hello World!")
+
+simulation_controller = SimulationController()
+
+@simulation_blueprint.route('/simulation/harmonic-progression', methods=['GET'])
+def return_ok():
+    n = int(request.args.get('n'))
+    sum = simulation_controller.harmonic_progression(n)
+
+    return str(sum), 200
+
+@simulation_blueprint.route('/simulation/json', methods=['POST'])
+def return_helloworld():
+    data = request.json
+    return data, 200
+
+@simulation_blueprint.route('/simulation/protobuf', methods=['POST'])
+def return_protobuf():
+    bytes_data = request.data
+
+    helloworld = person_pb2.Person()
+    helloworld.ParseFromString(bytes_data)
+
+    return helloworld.SerializeToString(), 200

FlaskAPI/controllers/status.py

@@ -2,18 +2,6 @@ from flask import jsonify, Blueprint
 
 status_blueprint = Blueprint('status_blueprint', __name__)
 
-
-class StatusController:
-    def __init__(self):
-        pass
-
-    def return_ok(self):
-        return jsonify(status=200)
-
-
-status_controller = StatusController()
-
-
 @status_blueprint.route('/status/ok', methods=['GET'])
 def return_ok():
-    return jsonify(status=200)
+    return 200

FlaskAPI/person.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+message Person {
+    string name = 1;
+    int32 age = 2;
+    repeated string friends = 3;
+    string email = 4;
+    string phone = 5;
+}

FlaskAPI/person_pb2.py

@@ -0,0 +1,26 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# source: person.proto
+# Protobuf Python Version: 4.25.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0cperson.proto\"R\n\x06Person\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0b\n\x03\x61ge\x18\x02 \x01(\x05\x12\x0f\n\x07\x66riends\x18\x03 \x03(\t\x12\r\n\x05\x65mail\x18\x04 \x01(\t\x12\r\n\x05phone\x18\x05 \x01(\tb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'person_pb2', _globals)
+if _descriptor._USE_C_DESCRIPTORS == False:
+  DESCRIPTOR._options = None
+  _globals['_PERSON']._serialized_start=16
+  _globals['_PERSON']._serialized_end=98
+# @@protoc_insertion_point(module_scope)

FlaskAPI/requirements.txt

@@ -1,3 +1,3 @@
 Flask>=1.0
 gunicorn>=19.9.0
-Wand
+protobuf>=4.25.0

FlaskAPI/services/image.py

@@ -1,69 +1,18 @@
-from wand.image import Image
-
-from static.image_helper import ImageHelper
-
-
-def box_blur_image_separable(image, blurred_image, radius_x, radius_y):
-    pixels = image.get_pixels()
-    blurred_pixels = blurred_image.get_pixels()
-
-    for pixel in pixels:
-        x, y = pixel[0], pixel[1]
-
-        r_total, g_total, b_total = 0, 0, 0
-        pixel_count = 0
-        for offset_y in range(-radius_y, radius_y + 1):
-            for offset_x in range(-radius_x, radius_x + 1):
-                new_x = x + offset_x
-                new_y = y + offset_y
-
-                if 0 <= new_x < image.width and 0 <= new_y < image.height:
-                    pixel_color = pixels[new_y * image.width + new_x]
-                    r_total += pixel_color.red
-                    g_total += pixel_color.green
-                    b_total += pixel_color.blue
-                    pixel_count += 1
-
-        blurred_pixel = blurred_pixels[y * image.width + x]
-        blurred_pixel.red = int(r_total / pixel_count)
-        blurred_pixel.green = int(g_total / pixel_count)
-        blurred_pixel.blue = int(b_total / pixel_count)
-
-    return blurred_image
-
-
-def save_image(file_stream):
-    with open("image.png", "wb") as file:
-        file.write(file_stream.read())
-        file.close()
-
-
 class ImageService:
     def __init__(self):
         pass
 
-    def box_blur_image(self, img, radius):
-        temp_path = 'temp_image.png'
-        img.save(temp_path)
-
-        with Image(filename=temp_path) as img:
-            img.blur(radius, 2)
-            blurred_temp_path = 'blurred_temp_image.png'
-            img.save(filename='blurred_temp_image.png')
-            return blurred_temp_path
-
-
     def get_simple_image(self):
-        with ImageHelper.SimpleImage as img:
-            img = ImageHelper.SimpleImage
-            simple_image = 'simple_image.png'
-            img.save(filename='simple_image.png')
-            return simple_image
-
+        with open("./static/small-image.png", "rb") as file:
+            return file.read()
 
     def get_big_image(self):
-        with ImageHelper.BigImage as img:
-            img = ImageHelper.BigImage
-            big_image = 'big_image.png'
-            img.save(filename='big_image.png')
-            return big_image
+        with open("./static/big-image.png", "rb") as file:
+            return file.read()
+
+    def save_image(self, img):
+        with open("image.png", "wb") as file:
+            file.write(img)
+
+        return True
+

FlaskAPI/static/image_helper.py

@@ -1,17 +0,0 @@
-from wand.image import Image
-
-
-class ImageHelper:
-    SimpleImage = None
-    BigImage = None
-
-    @staticmethod
-    def load_images():
-        ImageHelper.SimpleImage = Image(filename="./static/small-image.png")
-        #ImageHelper.SimpleImage.save(filename="./static/small-image.png")
-
-        ImageHelper.BigImage = Image(filename="./static/big-image.png")
-        #ImageHelper.BigImage.save(filename="./static/big-image.png")
-        pass
-
-ImageHelper.load_images()

docker-compose.yml

@@ -0,0 +1,63 @@
+version: "3"
+
+services:
+  tcc-aspnet:
+    image: tcc:aspnet
+    container_name: tcc-aspnet
+    build: ./ASP.NET
+    restart: always
+    ports:
+      - "9081:80"
+    deploy:
+      resources:
+        limits:
+          cpus: '1'
+          memory: 1GB
+  tcc-flask:
+    image: tcc:flask
+    container_name: tcc-flask
+    build: ./FlaskAPI
+    restart: always
+    ports:
+      - "9082:5000"
+    deploy:
+      resources:
+        limits:
+          cpus: '1'
+          memory: 1GB
+  tcc-actix:
+    image: tcc:actix
+    container_name: tcc-actix
+    build: ./ActixAPI
+    restart: always
+    ports:
+      - "9083:5000"
+    deploy:
+      resources:
+        limits:
+          cpus: '1'
+          memory: 1GB
+  tcc-express:
+    image: tcc:express
+    container_name: tcc-express
+    build: ./Express
+    restart: always
+    ports:
+      - "9084:5000"
+    deploy:
+      resources:
+        limits:
+          cpus: '1'
+          memory: 1GB
+  tcc-spring:
+    image: tcc:spring
+    container_name: tcc-spring
+    build: ./Spring
+    restart: always
+    ports:
+      - "9085:8080"
+    deploy:
+      resources:
+        limits:
+          cpus: '1'
+          memory: 1GB

scripts/common.py

@@ -0,0 +1,49 @@
+import person_pb2
+
+person_proto = person_pb2.Person()
+person_proto.name = "John Doe"
+person_proto.age = 30
+person_proto.friends.extend(["Jane Doe", "John Smith"])
+person_proto.email = "john.doe@email.com"
+person_proto.phone = "123-456-7890"
+person_proto = person_proto.SerializeToString()
+
+person_json = {
+    "name": "John Doe",
+    "age": 30,
+    "friends": ["Jane Doe", "John Smith"],
+    "email": "john.doe@email.com",
+    "phone": "123-456-7890"
+}
+person_json = str(person_json).encode('utf-8')
+
+FRAMEWORKS = [
+    ('Actix', 'tcc-actix', 'orange'),
+    ('ASP.NET', 'tcc-aspnet', 'blue'),
+    ('Flask', 'tcc-flask', 'grey'),
+    # ('Express', 'tcc-express', 'red'),
+    # ('Spring', 'tcc-spring', 'green'),
+]
+
+ENDPOINTS = {
+    'Actix': 'http://localhost:9083',
+    'ASP.NET': 'http://localhost:9081',
+    'Flask': 'http://localhost:9082',
+    'Express': 'http://localhost:9084',
+    'Spring': 'http://localhost:9085',
+}
+
+AVG_RUNS = 5
+
+API_REQUESTS = [
+    # ('/status/ok', 'GET', range(0, 30_000, 5000), None),
+    # ('/simulation/harmonic-progression?n=100000', 'GET', range(0, 30_000, 5000), None),
+    ('/simulation/json', 'POST', range(0, 30_000, 5000), (person_json, "application/json")),
+    # ('/image/save-big-image', 'POST', range(0, 500, 50), (open('big-image.png', 'rb').read(), "image/png")),
+    # ('/image/load-small-image', 'GET', range(0, 30_000, 5000), None),
+    # ('/static/small-image.png', 'GET', range(0, 30_000, 5000), None),
+    # ('/image/load-big-image', 'GET', range(0, 500, 50), None),
+    # ('/static/big-image.png', 'GET', range(0, 500, 50), None),
+    # ('/static/nginx.html', 'GET', range(0, 30_000, 5000), None),
+    ('/simulation/protobuf', 'POST', range(0, 30_000, 5000), (person_proto.SerializeToString(), "application/protobuf")),
+]

scripts/graph.py

@@ -0,0 +1,172 @@
+import numpy as np
+import matplotlib.pyplot as plt
+from common import API_REQUESTS, FRAMEWORKS
+from pylab import plot, show, savefig, xlim, figure, \
+                ylim, legend, boxplot, setp, axes
+
+FRAMEWORKS_COLORS = [c for _, _, c in FRAMEWORKS]
+FRAMEWORKS = [f for f, _, _ in FRAMEWORKS]
+
+def setBoxColors(bp):
+    for i, box in enumerate(bp['boxes']):
+        box.set(color=FRAMEWORKS_COLORS[i])
+    for i, median in enumerate(bp['medians']):
+        # median.set(color=FRAMEWORKS_COLORS[i])
+        median.set(color='white')
+
+    for i in range(len(FRAMEWORKS)):
+        bp['whiskers'][i*2].set(color=FRAMEWORKS_COLORS[i])
+        bp['whiskers'][i*2 + 1].set(color=FRAMEWORKS_COLORS[i])
+    for i in range(len(FRAMEWORKS)):
+        bp['caps'][i*2].set(color=FRAMEWORKS_COLORS[i])
+        bp['caps'][i*2 + 1].set(color=FRAMEWORKS_COLORS[i])
+
+
+def plot_graph(x_data, y_data, title, x_label, y_label, filename, y_lim = None):
+    old_x_data = x_data
+    old_y_data = y_data
+
+    x_data = []
+    y_data = []
+
+    for i in range(len(old_x_data)):
+        if old_x_data[i] not in x_data:
+            x_data.append(old_x_data[i])
+            y_data.append([])
+            for f in range(len(FRAMEWORKS)):
+                y_data[-1].append([])
+
+        for f in range(len(FRAMEWORKS)):
+            y_data[-1][f].append(old_y_data[f][i])
+
+    fig = figure()
+    ax = axes()
+
+    all_positions = []
+
+    print(filename)
+    # print(y_data)
+    for j in range(len(x_data)):
+        positions = [len(FRAMEWORKS)*j + i + 2*j for i in range(len(FRAMEWORKS))]
+
+        bp = boxplot(y_data[j], positions = positions, widths = 0.6, showfliers=False,
+                     patch_artist=True)
+        all_positions.append(positions)
+        setBoxColors(bp)
+
+    for i in range(len(FRAMEWORKS)):
+        medians = []
+        for j in range(len(x_data)):
+            medians.append(np.median(y_data[j][i]))
+
+        positions = [all_positions[x][i] for x in range(len(x_data))]
+        plt.plot(positions, medians, color=FRAMEWORKS_COLORS[i], marker='.', linestyle='--', linewidth=0.3)
+
+    avg_positions = []
+    for positions in all_positions:
+        avg = np.average(positions)
+        avg_positions.append(avg)
+
+    ax.set_xticks(avg_positions)
+    ax.set_xticklabels([str(x) for x in x_data])
+
+    plt.title(title)
+    plt.xlabel(x_label)
+    plt.ylabel(y_label)
+
+    if y_lim:
+        plt.ylim(y_lim)
+
+    if filename.startswith('req'):
+        for i, framework in enumerate(FRAMEWORKS):
+            h, = plt.plot([], c=FRAMEWORKS_COLORS[i], label=framework, marker='.', linestyle='--')
+            # h.set_visible(False)
+
+        plt.legend()
+
+    plt.tight_layout()
+    plt.savefig(f'{filename}.png')
+
+    plt.clf()
+    plt.close('all')
+
+def get_data(filename):
+    lines = []
+    with open(filename, 'r') as f:
+        lines = f.readlines()
+
+    x = []
+    y = []
+    for line in lines:
+        line = line.strip().split(',')
+        if line:
+            x.append(int(line[0]))
+            y.append(float(line[1]))
+
+    return x, y
+
+def get_resource_data(filename):
+    lines = []
+    with open(filename, 'r') as f:
+        lines = f.readlines()
+
+    x = []
+    y = []
+    for line in lines:
+        line = line.strip().split(',')
+        if line:
+            r = [round(float(line[1])*100), round(float(line[2])*100)]
+            if r[0] > 100:
+                r[0] = 100
+
+            if r[1] > 100:
+                r[1] = 100
+
+            x.append(int(line[0])) # requests
+            y.append(r) # cpu, ram
+
+    return x, y
+
+def generate_req_graph(filename, framework_name, endpoint_name):
+    x, _ = get_data(filename)
+    y = []
+
+    for f in FRAMEWORKS:
+        newfile = filename.replace(framework_name, f)
+        _, y_data = get_data(newfile)
+
+        y.append(y_data)
+
+    graph_file = f'req_{endpoint_name.replace("/", "").replace("?", "")}'
+    plot_graph(x, y, f'Requisições atendidas por segundo - {endpoint_name}', 'Número de requisições', 'Requisições/segundo', graph_file)
+
+def generate_resource_graph(filename, framework_name, endpoint_name):
+    x, _ = get_resource_data(filename)
+
+    for resource_index, resource in enumerate(['cpu', 'ram']):
+        y = []
+
+        for f in FRAMEWORKS:
+            newfile = filename.replace(framework_name, f)
+            _, y_data = get_resource_data(newfile)
+            y.append([data[resource_index] for data in y_data])
+
+        graph_file = f'{resource}_{endpoint_name.replace("/", "").replace("?", "")}'
+        plot_graph(x, y, f'Uso de {resource.upper()} - {endpoint_name}', 'Número de requisições', f'Uso de {resource.upper()} (%)', graph_file)
+
+if __name__ == '__main__':
+    endpoints = [config[0] for config in API_REQUESTS]
+
+    for endpoint_name in endpoints:
+        framework_name = 'ASP.NET'
+        endpoint_file = endpoint_name.replace('/', '')
+
+        endpoint_name = '/' + endpoint_name.split('/')[-1]
+
+        filename = f'data/resource_ASP.NET_{endpoint_file}.csv'
+        filename = filename.replace("?", "_")
+        generate_resource_graph(filename, framework_name, endpoint_name)
+
+        filename = f'data/req_ASP.NET_{endpoint_file}.csv'
+        filename = filename.replace("?", "_")
+        generate_req_graph(filename, framework_name, endpoint_name)

scripts/init.py

@@ -0,0 +1,22 @@
+import requests
+import os
+
+def download_file(url):
+    local_filename = url.split('/')[-1]
+    with requests.get(url, stream=True) as r:
+        r.raise_for_status()
+        with open(local_filename, 'wb') as f:
+            for chunk in r.iter_content(chunk_size=8192):
+                # If you have chunk encoded response uncomment if
+                # and set chunk_size parameter to None.
+                #if chunk:
+                f.write(chunk)
+    return local_filename
+
+def init():
+    if not os.path.exists('small-image.png'):
+        download_file('https://files.ivanch.me/api/public/dl/iFuXSNhw/small-image.png')
+    if not os.path.exists('big-image.png'):
+        download_file('https://files.ivanch.me/api/public/dl/iFuXSNhw/big-image.png')
+
+init()

scripts/person.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+message Person {
+    string name = 1;
+    int32 age = 2;
+    repeated string friends = 3;
+    string email = 4;
+    string phone = 5;
+}

scripts/person_pb2.py

@@ -0,0 +1,26 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# source: person.proto
+# Protobuf Python Version: 4.25.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0cperson.proto\"R\n\x06Person\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0b\n\x03\x61ge\x18\x02 \x01(\x05\x12\x0f\n\x07\x66riends\x18\x03 \x03(\t\x12\r\n\x05\x65mail\x18\x04 \x01(\t\x12\r\n\x05phone\x18\x05 \x01(\tb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'person_pb2', _globals)
+if _descriptor._USE_C_DESCRIPTORS == False:
+  DESCRIPTOR._options = None
+  _globals['_PERSON']._serialized_start=16
+  _globals['_PERSON']._serialized_end=98
+# @@protoc_insertion_point(module_scope)

scripts/protobuftest.py

@@ -0,0 +1,31 @@
+import person_pb2
+import asyncio
+import aiohttp
+
+async def fetch(session):
+    obj = get_object()
+    # async with session.post('http://172.25.96.1:9090/simulation/protobuf', data=obj.SerializeToString(),
+    async with session.post('http://127.0.0.1:5000/simulation/protobuf', data=obj.SerializeToString(),
+        headers={"content-type": "application/protobuf"}) as resp:
+        print(resp.status)
+        data = await resp.read()
+        receiveObj = person_pb2.Person()
+        receiveObj.ParseFromString(data)
+        print(receiveObj)
+
+async def go(loop):
+    async with aiohttp.ClientSession(loop=loop) as session:
+        await fetch(session)
+
+def get_object():
+    obj = person_pb2.Person()
+    obj.name = "John Doe"
+    obj.age = 30
+    obj.friends.extend(["Jane Doe", "John Smith"])
+    obj.email = "john.doe@email.com"
+    obj.phone = "123-456-7890"
+    return obj
+
+loop = asyncio.get_event_loop()
+loop.run_until_complete(go(loop))
+loop.close()

scripts/requirements.txt

@@ -0,0 +1,4 @@
+protobuf>=4.25.0
+matplotlib
+numpy
+docker

scripts/testes.py

@@ -1,33 +1,149 @@
 import requests
+import docker
 import concurrent.futures
 import time
+import os
+from math import floor
+from init import init
+from common import FRAMEWORKS, ENDPOINTS, API_REQUESTS, AVG_RUNS
 
-URL_BASE = 'http://localhost:5100'
+init()
 
-num_requests = [1000, 5000, 10_000, 50_000, 100_000, 500_000, 1_000_000]
+THREADS = 10
+FRAMEWORK_NAME = ""
+CONTAINER_NAME = ""
+URL_BASE = 'http://localhost:9090'
 
-def send_request(session, url):
-    response = session.get(url)
-    return response.status_code
+def send_request(url, method = 'GET', data = None):
+    success = False
+    responses = {
+        2: 0, # OK
+        4: 0, # Bad Request
+        5: 0, # Server Error
+    }
+    while not success:
+        try:
+            response = None
+            if method == 'GET':
+                response = requests.get(url)
+            elif method == 'POST':
+                payload = data[0]
+                content_type = data[1]
+                response = requests.post(url, data=payload, headers={'Content-Type': content_type})
+        except:
+            continue
+        success = response.status_code == 200
+        responses[floor(response.status_code/100)] += 1
+    return responses
+
+def getFileNames(endpoint):
+    endpoint = endpoint.replace('/', '')
+
+    files = [
+        f"data/req_{FRAMEWORK_NAME}_{endpoint}.csv",
+        f"data/resource_{FRAMEWORK_NAME}_{endpoint}.csv",
+    ]
+
+    return files
+
+def record(filename, requests, reqpersec):
+    with open(filename, "a") as file:
+        file.write(f"{requests},{reqpersec}\n")
+
+def record_resource(filename, requests, cpu, ram):
+    with open(filename, "a") as file:
+        file.write(f"{requests},{cpu},{ram}\n")
+
+def run_tests(endpoint, method, num_requests, metadata):
+    files = getFileNames(endpoint)
+    for filename in files:
+        if os.path.exists(filename):
+            os.remove(filename)
 
-def main():
     for num_request in num_requests:
-        with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
-            url = f'{URL_BASE}/status/ok'
+        if num_request <= 0: continue
 
-            start_time = time.time()
+        for run in range(AVG_RUNS):
+            ok_responses = 0
+            bad_responses = 0
+            server_errors = 0
 
-            futures = []
-            with requests.Session() as session:
-                futures = [executor.submit(send_request, session, url) for _ in range(num_request)]
+            cpu, ram = 0, 0
 
-            concurrent.futures.wait(futures)
+            with concurrent.futures.ThreadPoolExecutor(max_workers=THREADS) as executor:
+                url = f'{URL_BASE}{endpoint}'
 
-            elapsed_time = time.time() - start_time
+                start_time = time.time()
 
-            successful_responses = sum(1 for future in futures if future.result() == 200)
+                futures = []
+                #with requests.Session() as session:
+                #    futures = [executor.submit(send_request, session, url) for _ in range(num_request)]
 
-        print(f"All requests completed in {elapsed_time:.2f} seconds. {elapsed_time/num_request:.4f} seconds per request. {num_request/elapsed_time:.2f} requests per second.")
-        print(f"Successful responses: {successful_responses}/{num_request}")
+                half = floor(num_request/2)
+                for i in range(num_request):
+                    futures.append(executor.submit(send_request, url, method, metadata))
 
-main()
+                    if i == half:
+                        cpu, ram = get_resource_usage()
+
+                concurrent.futures.wait(futures)
+
+                elapsed_time = time.time() - start_time
+
+                for future in futures:
+                    responses = future.result()
+                    ok_responses += responses[2]
+                    bad_responses += responses[4]
+                    server_errors += responses[5]
+
+            print(f"[#{run}] {num_request}: {elapsed_time:.2f} seconds. {elapsed_time/num_request:.4f} seconds per request. {num_request/elapsed_time:.2f} requests per second. [OK: {ok_responses}, Bad Request: {bad_responses}, Server Error: {server_errors}]]")
+
+            client = docker.from_env()
+            client.containers.get(CONTAINER_NAME).restart()
+
+            record(files[0], num_request, f"{num_request/elapsed_time:.2f}")
+            record_resource(files[1], num_request, cpu, ram)
+
+            time.sleep(3)
+
+def get_resource_usage():
+    if CONTAINER_NAME == "": return 0, 0
+
+    try:
+        client = docker.from_env()
+        stats = client.containers.get(CONTAINER_NAME).stats(stream=False)
+    except:
+        return 0, 0 # unable to get stats
+
+    return get_cpu_usage(stats), get_ram_usage(stats)
+
+def get_cpu_usage(stats):
+    UsageDelta = stats['cpu_stats']['cpu_usage']['total_usage'] - stats['precpu_stats']['cpu_usage']['total_usage']
+    SystemDelta = stats['cpu_stats']['system_cpu_usage'] - stats['precpu_stats']['system_cpu_usage']
+    len_cpu = stats['cpu_stats']['online_cpus']
+    percentage = (UsageDelta / SystemDelta) * len_cpu
+    return f"{percentage:.2f}"
+
+def get_ram_usage(stats):
+    usage = stats['memory_stats']['usage']
+    limit = stats['memory_stats']['limit']
+
+    percentage = (usage / limit)
+
+    # percent = round(percentage, 2)
+    return f"{percentage:.2f}"
+
+if __name__ == "__main__":
+    if not os.path.exists("data"):
+        os.mkdir("data")
+
+    init()
+
+    for i in range(len(FRAMEWORKS)):
+        FRAMEWORK_NAME = FRAMEWORKS[i][0]
+        CONTAINER_NAME = FRAMEWORKS[i][1]
+        URL_BASE = ENDPOINTS[FRAMEWORK_NAME]
+
+        for endpoint, method, num_requests, metadata in API_REQUESTS:
+            print(f"# {FRAMEWORK_NAME} - {endpoint}")
+            run_tests(endpoint, method, num_requests, metadata)