From fcd2c3563ddf6e5db0302aa234d5ec0c09226953 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:43:51 +0000 Subject: [PATCH 1/6] feat(scaffold): add .gitignore [skip ci] --- .gitignore | 9 +++++++++ 1 file changed, 9 insertions(+) create mode 100644 .gitignore diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..e0621d9 --- /dev/null +++ b/.gitignore @@ -0,0 +1,9 @@ +__pycache__/ +*.pyc +*.pyo +.venv/ +venv/ +.env +*.egg-info/ +dist/ +.DS_Store -- 2.49.1 From 50a023bc9a2cc356efb13f5b149b8ca271f03fb4 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:43:52 +0000 Subject: [PATCH 2/6] feat(scaffold): add Dockerfile [skip ci] --- Dockerfile | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 Dockerfile diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..ec570f1 --- /dev/null +++ b/Dockerfile @@ -0,0 +1,25 @@ +# ---- Build stage (install deps) ---- +FROM python:3.12-slim AS build +WORKDIR /app + +RUN pip install --upgrade pip +COPY requirements.txt . +RUN pip install --no-cache-dir --prefix=/install -r requirements.txt + +# ---- Runtime stage ---- +FROM python:3.12-slim +WORKDIR /app + +# Non-root user +RUN addgroup --system appgroup && adduser --system --ingroup appgroup appuser +USER appuser + +COPY --from=build /install /usr/local +COPY app/ ./app/ + +EXPOSE 8000 + +HEALTHCHECK --interval=30s --timeout=5s --start-period=20s --retries=3 \ + CMD python -c "import urllib.request; urllib.request.urlopen('http://localhost:8000/health')" || exit 1 + +CMD ["opentelemetry-instrument", "uvicorn", "app.main:app", "--host", "0.0.0.0", "--port", "8000"] -- 2.49.1 From bd06afeff60da5fc26978b291f221d3778edb588 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:43:53 +0000 Subject: [PATCH 3/6] feat(scaffold): add requirements.txt [skip ci] --- requirements.txt | 9 +++++++++ 1 file changed, 9 insertions(+) create mode 100644 requirements.txt diff --git a/requirements.txt b/requirements.txt new file mode 100644 index 0000000..99cfc87 --- /dev/null +++ b/requirements.txt @@ -0,0 +1,9 @@ +fastapi==0.111.0 +uvicorn[standard]==0.29.0 +prometheus-fastapi-instrumentator==7.0.0 +opentelemetry-distro[otlp]>=0.51b0 +opentelemetry-instrumentation-fastapi>=0.51b0 +pytest>=8.0 +httpx>=0.27 +pytest-asyncio>=0.23 +pytest-cov>=5.0 -- 2.49.1 From 5952c21f9e4dc5b81a83fe6efe6ce24a90525af6 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:43:54 +0000 Subject: [PATCH 4/6] feat(scaffold): add app/__init__.py [skip ci] --- app/__init__.py | 1 + 1 file changed, 1 insertion(+) create mode 100644 app/__init__.py diff --git a/app/__init__.py b/app/__init__.py new file mode 100644 index 0000000..9fab277 --- /dev/null +++ b/app/__init__.py @@ -0,0 +1 @@ +from app.main import app # noqa: F401 — re-export for uvicorn entrypoint -- 2.49.1 From 2a2acf6673a5643dacc01c830d6277554847e969 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:43:55 +0000 Subject: [PATCH 5/6] feat(scaffold): add app/main.py [skip ci] --- app/main.py | 90 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 90 insertions(+) create mode 100644 app/main.py diff --git a/app/main.py b/app/main.py new file mode 100644 index 0000000..c9f3e01 --- /dev/null +++ b/app/main.py @@ -0,0 +1,90 @@ +from __future__ import annotations + +from threading import Lock +from typing import Optional + +from fastapi import FastAPI, HTTPException +from prometheus_fastapi_instrumentator import Instrumentator +from pydantic import BaseModel + +app = FastAPI( + title="sonar-test-pyt", + description="sonar-test-pyt", + version="0.1.0", +) + +# Expose /metrics for Prometheus scraping +Instrumentator().instrument(app).expose(app) + + +# --------------------------------------------------------------------------- +# Domain model +# --------------------------------------------------------------------------- +class ItemRequest(BaseModel): + name: str + description: str = "" + + +class Item(BaseModel): + id: int + name: str + description: str + + +# --------------------------------------------------------------------------- +# In-memory store (thread-safe) +# --------------------------------------------------------------------------- +_store: dict[int, Item] = {} +_counter = 0 +_lock = Lock() + + +def _next_id() -> int: + global _counter + with _lock: + _counter += 1 + return _counter + + +# --------------------------------------------------------------------------- +# Routes +# --------------------------------------------------------------------------- +@app.get("/health", tags=["observability"]) +def health() -> dict: + return {"status": "UP"} + + +@app.get("/api/items", response_model=list[Item], tags=["items"]) +def list_items(): + return list(_store.values()) + + +@app.post("/api/items", response_model=Item, status_code=201, tags=["items"]) +def create_item(body: ItemRequest): + item = Item(id=_next_id(), name=body.name, description=body.description) + _store[item.id] = item + return item + + +@app.get("/api/items/{item_id}", response_model=Item, tags=["items"]) +def get_item(item_id: int): + item = _store.get(item_id) + if item is None: + raise HTTPException(status_code=404, detail="Item not found") + return item + + +@app.put("/api/items/{item_id}", response_model=Item, tags=["items"]) +def update_item(item_id: int, body: ItemRequest): + item = _store.get(item_id) + if item is None: + raise HTTPException(status_code=404, detail="Item not found") + updated = Item(id=item_id, name=body.name, description=body.description) + _store[item_id] = updated + return updated + + +@app.delete("/api/items/{item_id}", tags=["items"]) +def delete_item(item_id: int): + _store.pop(item_id, None) + return {"deleted": item_id} -- 2.49.1 From a8c9d5d1eb3c78acb6b01191770fa10cafc44c71 Mon Sep 17 00:00:00 2001 From: demo-bot Date: Thu, 7 May 2026 13:44:08 +0000 Subject: [PATCH 6/6] feat(k6): add bespoke load test files --- k6/configmap.yaml | 52 ++++++++++++++++++++++++++++ k6/load-test.js | 88 +++++++++++++++++++++++++++++++++++++++++++++++ k6/testrun.yaml | 24 +++++++++++++ 3 files changed, 164 insertions(+) create mode 100644 k6/configmap.yaml create mode 100644 k6/load-test.js create mode 100644 k6/testrun.yaml diff --git a/k6/configmap.yaml b/k6/configmap.yaml new file mode 100644 index 0000000..7212dd1 --- /dev/null +++ b/k6/configmap.yaml @@ -0,0 +1,52 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: k6-test-sonar-test-pyt + namespace: dev + labels: + app: sonar-test-pyt + app.kubernetes.io/managed-by: backstage + app.kubernetes.io/component: load-testing +data: + K6_OUT: opentelemetry + K6_OTEL_GRPC_EXPORTER_INSECURE: 'true' + K6_OTEL_GRPC_EXPORTER_ENDPOINT: otel-collector.monitoring.svc.cluster.local:4317 + K6_OTEL_METRIC_PREFIX: k6_ + K6_OTEL_FLUSH_INTERVAL: '1000' + K6_OTEL_EXPORT_INTERVAL: '5000' + K6_OTEL_SERVICE_NAME: k6-sonar-test-pyt + load-test.js: "import http from 'k6/http';\nimport { check, sleep, group } from\ + \ 'k6';\n\nconst vus = parseInt(__ENV.TEST_VUS || '10');\nconst duration = __ENV.TEST_DURATION\ + \ || '30s';\nconst targetUrl = __ENV.TARGET_URL || 'http://sonar-test-pyt.dev.svc.cluster.local:8000';\n\ + \nexport const options = {\n scenarios: {\n load_test: {\n executor:\ + \ 'ramping-vus',\n startVUs: 0,\n stages: [\n { duration: '10s',\ + \ target: vus },\n { duration: duration, target: vus },\n { duration:\ + \ '5s', target: 0 },\n ],\n },\n },\n thresholds: {\n http_req_duration:\ + \ ['p(95)<500'],\n http_req_failed: ['rate<0.01'],\n },\n};\n\nhttp.setResponseCallback(http.expectedStatuses({\ + \ min: 200, max: 399 }));\n\nexport default function () {\n group('Observability\ + \ API', () => {\n const res = http.get(`${targetUrl}/health`);\n check(res,\ + \ {\n 'status is 200': (r) => r.status === 200,\n 'response time < 500ms':\ + \ (r) => r.timings.duration < 500,\n 'body contains status': (r) => r.json().status\ + \ === 'UP',\n });\n });\n\n sleep(0.5);\n\n group('Items API', () => {\n\ + \ const listRes = http.get(`${targetUrl}/api/items`);\n check(listRes, {\n\ + \ 'status is 200': (r) => r.status === 200,\n 'response time < 500ms':\ + \ (r) => r.timings.duration < 500,\n 'body is an array': (r) => Array.isArray(r.json()),\n\ + \ });\n\n const createRes = http.post(\n `${targetUrl}/api/items`,\n\ + \ JSON.stringify({ name: 'Test Item', description: 'A test item description'\ + \ }),\n { headers: { 'Content-Type': 'application/json' } }\n );\n \ + \ check(createRes, {\n 'status is 201': (r) => r.status === 201,\n 'response\ + \ time < 500ms': (r) => r.timings.duration < 500,\n 'body contains id': (r)\ + \ => r.json().id !== undefined,\n });\n\n const itemId = createRes.json().id;\n\ + \n const getRes = http.get(`${targetUrl}/api/items/${itemId}`);\n check(getRes,\ + \ {\n 'status is 200': (r) => r.status === 200,\n 'response time < 500ms':\ + \ (r) => r.timings.duration < 500,\n 'body contains correct id': (r) => r.json().id\ + \ === itemId,\n });\n\n const updateRes = http.put(\n `${targetUrl}/api/items/${itemId}`,\n\ + \ JSON.stringify({ name: 'Updated Item', description: 'Updated description'\ + \ }),\n { headers: { 'Content-Type': 'application/json' } }\n );\n \ + \ check(updateRes, {\n 'status is 200': (r) => r.status === 200,\n 'response\ + \ time < 500ms': (r) => r.timings.duration < 500,\n 'body contains updated\ + \ name': (r) => r.json().name === 'Updated Item',\n });\n\n const deleteRes\ + \ = http.del(`${targetUrl}/api/items/${itemId}`);\n check(deleteRes, {\n \ + \ 'status is 200': (r) => r.status === 200,\n 'response time < 500ms':\ + \ (r) => r.timings.duration < 500,\n 'body contains deleted id': (r) => r.json().deleted\ + \ === itemId,\n });\n });\n\n sleep(0.5);\n}" diff --git a/k6/load-test.js b/k6/load-test.js new file mode 100644 index 0000000..9611619 --- /dev/null +++ b/k6/load-test.js @@ -0,0 +1,88 @@ +import http from 'k6/http'; +import { check, sleep, group } from 'k6'; + +const vus = parseInt(__ENV.TEST_VUS || '10'); +const duration = __ENV.TEST_DURATION || '30s'; +const targetUrl = __ENV.TARGET_URL || 'http://sonar-test-pyt.dev.svc.cluster.local:8000'; + +export const options = { + scenarios: { + load_test: { + executor: 'ramping-vus', + startVUs: 0, + stages: [ + { duration: '10s', target: vus }, + { duration: duration, target: vus }, + { duration: '5s', target: 0 }, + ], + }, + }, + thresholds: { + http_req_duration: ['p(95)<500'], + http_req_failed: ['rate<0.01'], + }, +}; + +http.setResponseCallback(http.expectedStatuses({ min: 200, max: 399 })); + +export default function () { + group('Observability API', () => { + const res = http.get(`${targetUrl}/health`); + check(res, { + 'status is 200': (r) => r.status === 200, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body contains status': (r) => r.json().status === 'UP', + }); + }); + + sleep(0.5); + + group('Items API', () => { + const listRes = http.get(`${targetUrl}/api/items`); + check(listRes, { + 'status is 200': (r) => r.status === 200, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body is an array': (r) => Array.isArray(r.json()), + }); + + const createRes = http.post( + `${targetUrl}/api/items`, + JSON.stringify({ name: 'Test Item', description: 'A test item description' }), + { headers: { 'Content-Type': 'application/json' } } + ); + check(createRes, { + 'status is 201': (r) => r.status === 201, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body contains id': (r) => r.json().id !== undefined, + }); + + const itemId = createRes.json().id; + + const getRes = http.get(`${targetUrl}/api/items/${itemId}`); + check(getRes, { + 'status is 200': (r) => r.status === 200, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body contains correct id': (r) => r.json().id === itemId, + }); + + const updateRes = http.put( + `${targetUrl}/api/items/${itemId}`, + JSON.stringify({ name: 'Updated Item', description: 'Updated description' }), + { headers: { 'Content-Type': 'application/json' } } + ); + check(updateRes, { + 'status is 200': (r) => r.status === 200, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body contains updated name': (r) => r.json().name === 'Updated Item', + }); + + const deleteRes = http.del(`${targetUrl}/api/items/${itemId}`); + check(deleteRes, { + 'status is 200': (r) => r.status === 200, + 'response time < 500ms': (r) => r.timings.duration < 500, + 'body contains deleted id': (r) => r.json().deleted === itemId, + }); + }); + + sleep(0.5); +} \ No newline at end of file diff --git a/k6/testrun.yaml b/k6/testrun.yaml new file mode 100644 index 0000000..47dd185 --- /dev/null +++ b/k6/testrun.yaml @@ -0,0 +1,24 @@ +apiVersion: k6.io/v1alpha1 +kind: TestRun +metadata: + name: k6-sonar-test-pyt + namespace: dev + labels: + app: sonar-test-pyt + backstage.io/component: sonar-test-pyt + app.kubernetes.io/managed-by: backstage + app.kubernetes.io/component: load-testing +spec: + parallelism: 1 + script: + configMap: + name: k6-test-sonar-test-pyt + file: load-test.js + runner: + image: grafana/k6:latest + envFrom: + - configMapRef: + name: k6-test-sonar-test-pyt + env: + - name: K6_OTEL_SERVICE_NAME + value: k6-sonar-test-pyt -- 2.49.1