Merge pull request 'fix' (#9) from master into dev

Reviewed-on: #9

.deploy/deploy-dev.yaml

@@ -6,7 +6,6 @@ services:
     image: mathwave/sprint-repo:configurator
     networks:
       - configurator-development
-      - monitoring
     environment:
       MONGO_HOST: "mongo.develop.sprinthub.ru"
       MONGO_PASSWORD: $MONGO_PASSWORD_DEV
@@ -21,5 +20,3 @@ services:
 networks:
   configurator-development:
     external: true
-  monitoring:
-    external: true

.deploy/deploy-prod.yaml

@@ -6,7 +6,6 @@ services:
     image: mathwave/sprint-repo:configurator
     networks:
       - configurator
-      - monitoring
     environment:
       MONGO_HOST: "mongo.sprinthub.ru"
       MONGO_PASSWORD: $MONGO_PASSWORD_PROD
@@ -21,5 +20,3 @@ services:
 networks:
   configurator:
     external: true
-  monitoring:
-    external: true

app/middlewares/metrics.py

@@ -1,14 +0,0 @@
-import datetime
-import zoneinfo
-from fastapi import Request, Response
-from starlette.middleware.base import BaseHTTPMiddleware
-
-from app.utils.monitoring import monitoring
-
-class MetricsMiddleware(BaseHTTPMiddleware):
-    async def dispatch(self, request: Request, call_next):
-        start = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
-        response: Response = await call_next(request)
-        end = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
-        monitoring.send_metric(start, end, request.url.path, response.status_code, request.method)
-        return response

app/routers/configs.py

@@ -13,7 +13,7 @@ class RequestPostBody(pydantic.BaseModel):
 
 class RequestPutBody(pydantic.BaseModel):
     id: str
-    value: dict|list
+    value: dict
 
 
 class RequestDeleteBody(pydantic.BaseModel):
@@ -23,7 +23,7 @@ class RequestDeleteBody(pydantic.BaseModel):
 class Config(pydantic.BaseModel):
     id: str
     name: str
-    value: dict|list
+    value: dict
 
 
 router = fastapi.APIRouter()

app/routers/experiments.py

@@ -1,4 +1,3 @@
-import bson
 import fastapi
 import pydantic
 
@@ -38,14 +37,14 @@ async def post(body: RequestPostBody):
 
 @router.put('/api/v1/experiments', status_code=fastapi.status.HTTP_202_ACCEPTED, responses={404: {'description': 'Not found'}})
 async def put(body: RequestPutBody):
-    changed = await experiments.update(id=bson.ObjectId(body.id), enabled=body.enabled, condition=body.condition)
+    changed = await experiments.update(id=body.id, enabled=body.enabled, condition=body.condition)
     if not changed:
         raise fastapi.HTTPException(404)
     
 
 @router.delete('/api/v1/experiments', status_code=fastapi.status.HTTP_202_ACCEPTED, responses={404: {'description': 'Not found'}})
 async def delete(body: RequestDeleteBody):
-    changed = await experiments.delete(id=bson.ObjectId(body.id))
+    changed = await experiments.delete(id=body.id)
     if not changed:
         raise fastapi.HTTPException(404)
 

app/routers/fetch.py

@@ -20,7 +20,7 @@ class PlatformStaff(pydantic.BaseModel):
 
 
 class ResponseBody(pydantic.BaseModel):
-    configs: dict[str, dict|list]
+    configs: dict[str, dict]
     experiments: dict[str, ExperimentData]
     platform_staff: PlatformStaff
 

app/storage/mongo/configs.py

@@ -12,7 +12,7 @@ class Config(pydantic.BaseModel):
     name: str
     project: str
     stage: str
-    value: dict|list
+    value: dict
     _id: bson.ObjectId|None = None
 
 
@@ -21,7 +21,7 @@ async def create(config: Config) -> str:
     return result.inserted_id
 
 
-async def update_data(id: bson.ObjectId, value: dict|list) -> bool:
+async def update_data(id: bson.ObjectId, value: dict) -> bool:
     result = await collection.update_one({'_id': id}, {'$set': {'value': value}})
     return result.modified_count != 0
 

app/utils/monitoring.py

@@ -1,25 +0,0 @@
-from concurrent.futures import ThreadPoolExecutor
-import datetime
-import requests
-
-
-class Monitroing:
-    def __init__(self):
-        self.executor = ThreadPoolExecutor(max_workers=1)
-
-    def send_metric(self, start: datetime.datetime, end: datetime.datetime, endpoint: str, status_code: int, method: str):
-        def send():
-            requests.post(f'http://monitoring:1237/api/v1/metrics/endpoint', json={
-                'timestamp': start.strftime("%Y-%m-%dT%H:%M:%S") + "Z",
-                'service': 'configurator',
-                'endpoint': endpoint,
-                'status_code': status_code,
-                'response_time': (end - start).microseconds // 1000,
-                'method': method,
-                'environment': 'production',
-            })
-        
-        self.executor.submit(send)
-
-
-monitoring = Monitroing()

main.py

@@ -1,7 +1,6 @@
 import fastapi
 import uvicorn
 
-from app.middlewares.metrics import MetricsMiddleware
 from app.routers import experiments
 from app.routers import configs
 from app.routers import staff
@@ -11,7 +10,6 @@ from app.storage import mongo
 
 
 app = fastapi.FastAPI()
-app.add_middleware(MetricsMiddleware)
 
 app.include_router(experiments.router)
 app.include_router(configs.router)

requirements.txt

@@ -1,8 +1,6 @@
 annotated-types==0.7.0
 anyio==4.6.2.post1
 APScheduler==3.10.4
-certifi==2025.6.15
-charset-normalizer==3.4.2
 click==8.1.7
 dnspython==2.7.0
 fastapi==0.115.4
@@ -14,11 +12,9 @@ pydantic_core==2.23.4
 pymongo==4.9.2
 pytz==2024.2
 redis==5.2.0
-requests==2.32.4
 six==1.16.0
 sniffio==1.3.1
 starlette==0.41.2
 typing_extensions==4.12.2
 tzlocal==5.2
-urllib3==2.4.0
 uvicorn==0.32.0