Compare commits

...
Author SHA1 Message Date
dev1-playground-agent 9489c755fd docs: replace example tokens with placeholders in README.md
security/scan 19 findings, 19 blocking
security / scan (pull_request) Failing after 1m3s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 1m29s
security / deep-audit (pull_request) Skipped
2026-08-25 06:22:15 +00:00
testclient-admin 9b92ab10ab docs: differentiate example tokens in README so edit anchors are unique
security/scan 19 findings, 19 blocking
security / scan (pull_request) Failing after 1m29s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 1m28s
security / deep-audit (pull_request) Skipped
2026-08-25 06:08:03 +00:00
dev1-playground-agent 03cd3169e5 Add notes module
security/scan 11 findings, 11 blocking
security / scan (pull_request) Failing after 1m1s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 1m29s
security / deep-audit (pull_request) Skipped
2026-08-25 05:26:07 +00:00
testclient-admin 789aa6adaa Merge pull request 'Add Level 0 + Level 1 + Level 2 security scanning' (#16) from add-security-scanning into main
Reviewed-on: testclient-admin/playground#16
2026-08-25 04:03:04 +00:00
testclient-admin 543dafc129 Merge pull request 'orders module: add auth, fix command injection, add requirements' (#13) from feature/orders-module into main
Reviewed-on: testclient-admin/playground#13
2026-08-25 03:44:38 +00:00
testclient-admin d9d1da21ed Level 0: security scanning for pull requests
security/scan 3 findings, 3 blocking
security / scan (pull_request) Failing after 56s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 1m27s
security / deep-audit (pull_request) Skipped
2026-08-25 03:08:09 +00:00
testclient-admin b4d891c229 Level 0: security scanning for pull requests 2026-08-25 03:08:08 +00:00
testclient-admin dc1066e208 Level 0: security scanning for pull requests 2026-08-25 03:08:07 +00:00
testclient-admin a66aa0ced8 Merge pull request 'Merge orders module into main' (#10) from feature/orders-module into main
Reviewed-on: testclient-admin/playground#10
2026-08-23 16:25:38 +00:00
testclient-admin 74a056e8a5 Merge pull request 'docs: AGENTS.md — PR только через gitea MCP' (#11) from infra/agents-md-mcp-pr-rule into main
Reviewed-on: testclient-admin/playground#11
2026-08-23 16:25:22 +00:00
testclient-admin 5d7cec819b Merge pull request 'Add Level 0 + Level 1 + Level 2 security scanning' (#12) from add-security-scanning into main
Reviewed-on: testclient-admin/playground#12
2026-08-23 16:25:10 +00:00
playground-security-bot 526c2862f6 security: scan results for PR #12
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 16:13:56 +00:00
playground-security-bot 063faeaa5a security: scan results for PR #12
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 16:12:26 +00:00
testclient-admin bae21bcff8 Level 0: security scanning for pull requests
security/scan 0 findings, 0 blocking
security / scan (pull_request) Successful in 1m8s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 20s
security / deep-audit (pull_request) Skipped
2026-08-23 16:11:13 +00:00
testclient-admin 0103775e5a Level 0: security scanning for pull requests 2026-08-23 16:11:12 +00:00
testclient-admin 4777411360 Level 0: security scanning for pull requests 2026-08-23 16:11:11 +00:00
playground-security-bot 323ebd1e28 security: scan results for PR #11
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 15:44:02 +00:00
dev1-playground-agent ff68f216ce docs: clarify AGENTS.md — git native, PR via gitea MCP only
security/scan 0 findings, 0 blocking
security / scan (pull_request) Successful in 1m14s
security/review 0 findings, 0 blocking
security / review (pull_request) Successful in 20s
security / deep-audit (pull_request) Skipped
2026-08-23 15:42:43 +00:00
playground-security-bot 083efd8493 security: scan results for PR #10
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 15:31:44 +00:00
playground-security-bot 5794d806d4 security: AI review results for PR #9
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 15:30:27 +00:00
playground-security-bot 61e2a9bb44 security: scan results for PR #9
security / scan (pull_request) Skipped
security / review (pull_request) Skipped
security / deep-audit (pull_request) Skipped
2026-08-23 15:29:49 +00:00
10 changed files with 369 additions and 43 deletions
+60 -38
View File
@@ -64,17 +64,15 @@ jobs:
REPO_FULL: ${{ gitea.repository }} REPO_FULL: ${{ gitea.repository }}
PR_NUMBER: ${{ gitea.event.pull_request.number }} PR_NUMBER: ${{ gitea.event.pull_request.number }}
COMMIT_SHA: ${{ gitea.event.pull_request.head.sha }} COMMIT_SHA: ${{ gitea.event.pull_request.head.sha }}
HEAD_REF: ${{ gitea.head_ref }}
run: | run: |
python3 <<'PYEOF' python3 <<'PYEOF'
import base64, json, os, sys, time, urllib.error, urllib.request import json, os, sys, time, urllib.error, urllib.request
SERVER = os.environ["GITEA_SERVER"].rstrip("/") SERVER = os.environ["GITEA_SERVER"].rstrip("/")
REPO = os.environ["REPO_FULL"] REPO = os.environ["REPO_FULL"]
TOKEN = os.environ["SECURITY_BOT_TOKEN"] TOKEN = os.environ["SECURITY_BOT_TOKEN"]
PR_NUMBER = os.environ.get("PR_NUMBER", "") PR_NUMBER = os.environ.get("PR_NUMBER", "")
COMMIT_SHA = os.environ["COMMIT_SHA"] COMMIT_SHA = os.environ["COMMIT_SHA"]
HEAD_REF = os.environ["HEAD_REF"]
def gitea(method, path, payload=None): def gitea(method, path, payload=None):
req = urllib.request.Request( req = urllib.request.Request(
@@ -154,17 +152,33 @@ jobs:
blocking = [f for f in findings if f["severity"] in policy["block_on"] and f["confidence"] >= policy["min_confidence"]] blocking = [f for f in findings if f["severity"] in policy["block_on"] and f["confidence"] >= policy["min_confidence"]]
blocked = len(blocking) > 0 blocked = len(blocking) > 0
outdir = f"security-analysis/findings/pr-{PR_NUMBER or 'manual'}" # Один и тот же коммит может быть провёрен дважды (см. баг
os.makedirs(outdir, exist_ok=True) # Gitea с переиспользованием SHA между разными PR — два
outpath = f"{outdir}/{int(time.time())}.json" # параллельных прогона на идентичный коммит). Статус в
json.dump(findings, open(outpath, "w"), ensure_ascii=False, indent=2) # Gitea хранит только ПОСЛЕДНЮЮ запись по (sha, context),
# так что более поздний, но менее строгий результат тихо
gitea("POST", f"/repos/{REPO}/contents/{outpath}", { # затирает более ранний блокирующий. Раз уже была
"content": base64.b64encode(open(outpath, "rb").read()).decode(), # зафиксирована блокировка на этом коммите — не снимаем
"message": f"security: scan results for PR #{PR_NUMBER}", # её молча, только новым коммитом.
"branch": HEAD_REF, prior_failed = False
}) try:
prior = gitea("GET", f"/repos/{REPO}/commits/{COMMIT_SHA}/statuses")
prior_failed = any(s.get("context") == "security/scan" and s.get("status") == "failure" for s in prior)
except Exception as e:
print(f"не удалось прочитать прежние статусы, продолжаю без sticky-fail: {e}")
sticky = prior_failed and not blocked
# Раньше находки ещё и коммитились в ветку PR. Плохая
# идея с точки зрения git-гигиены: чужая ветка растёт
# коммитами от бота, каждый такой коммит сам порождает
# pull_request:synchronize (нужна отдельная защита от
# петли), а когда коммит бота становится головой PR —
# обязательные security/scan и security/review больше
# никогда не выставляются на этой голове, потому что
# job их специально пропускает для бота же — PR
# перестаёт мержиться насовсем (поймано живьём).
# Комментарий в PR (ниже) и так несёт всё нужное
# человеку; отдельного коммита с JSON не требуется.
counts = {} counts = {}
for f in findings: for f in findings:
counts[f["severity"]] = counts.get(f["severity"], 0) + 1 counts[f["severity"]] = counts.get(f["severity"], 0) + 1
@@ -176,20 +190,21 @@ jobs:
body += "\n\n" body += "\n\n"
for f in top: for f in top:
body += f"**{f['severity'].upper()}** `{f['file']}:{f['line_start']}` — {f['title']} ({f['source']})\n\n" body += f"**{f['severity'].upper()}** `{f['file']}:{f['line_start']}` — {f['title']} ({f['source']})\n\n"
body += f"Полный список: `{outpath}`\n\n" if sticky:
body += "🔴 **Merge заблокирован** — есть находки выше порога `security-analysis/policy.yml`.\n" if blocked else "✅ Порог не превышен.\n" body += "🔴 **Merge заблокирован** — этот же коммит уже был помечен как блокирующий в более раннем прогоне; новый прогон нашёл меньше, но старую блокировку это не снимает (нужен новый коммит).\n"
else:
body += "🔴 **Merge заблокирован** — есть находки выше порога `security-analysis/policy.yml`.\n" if blocked else "✅ Порог не превышен.\n"
gitea("POST", f"/repos/{REPO}/issues/{PR_NUMBER}/comments", {"body": body}) gitea("POST", f"/repos/{REPO}/issues/{PR_NUMBER}/comments", {"body": body})
gitea("POST", f"/repos/{REPO}/statuses/{COMMIT_SHA}", { gitea("POST", f"/repos/{REPO}/statuses/{COMMIT_SHA}", {
"state": "failure" if blocked else "success", "state": "failure" if (blocked or sticky) else "success",
"context": "security/scan", "context": "security/scan",
"description": f"{len(findings)} findings, {len(blocking)} blocking", "description": (f"{len(findings)} findings, {len(blocking)} blocking" + (" (sticky: prior run flagged this commit)" if sticky else "")),
"target_url": f"{SERVER}/{REPO}/src/branch/{HEAD_REF}/{outpath}",
}) })
print(f"findings: {len(findings)}, blocking: {len(blocking)}") print(f"findings: {len(findings)}, blocking: {len(blocking)}, sticky: {sticky}")
if blocked: if blocked or sticky:
sys.exit(1) sys.exit(1)
PYEOF PYEOF
@@ -344,17 +359,15 @@ jobs:
REPO_FULL: ${{ gitea.repository }} REPO_FULL: ${{ gitea.repository }}
PR_NUMBER: ${{ gitea.event.pull_request.number }} PR_NUMBER: ${{ gitea.event.pull_request.number }}
COMMIT_SHA: ${{ gitea.event.pull_request.head.sha }} COMMIT_SHA: ${{ gitea.event.pull_request.head.sha }}
HEAD_REF: ${{ gitea.head_ref }}
run: | run: |
python3 <<'PYEOF2' python3 <<'PYEOF2'
import base64, json, os, sys, time, urllib.error, urllib.request import json, os, sys, time, urllib.error, urllib.request
SERVER = os.environ["GITEA_SERVER"].rstrip("/") SERVER = os.environ["GITEA_SERVER"].rstrip("/")
REPO = os.environ["REPO_FULL"] REPO = os.environ["REPO_FULL"]
TOKEN = os.environ["SECURITY_BOT_TOKEN"] TOKEN = os.environ["SECURITY_BOT_TOKEN"]
PR_NUMBER = os.environ.get("PR_NUMBER", "") PR_NUMBER = os.environ.get("PR_NUMBER", "")
COMMIT_SHA = os.environ["COMMIT_SHA"] COMMIT_SHA = os.environ["COMMIT_SHA"]
HEAD_REF = os.environ["HEAD_REF"]
def gitea(method, path, payload=None): def gitea(method, path, payload=None):
req = urllib.request.Request( req = urllib.request.Request(
@@ -440,16 +453,23 @@ jobs:
blocking = [f for f in findings if f["severity"] in policy["block_on"] and f["confidence"] >= policy["min_confidence"]] blocking = [f for f in findings if f["severity"] in policy["block_on"] and f["confidence"] >= policy["min_confidence"]]
blocked = len(blocking) > 0 blocked = len(blocking) > 0
outdir = f"security-analysis/findings/pr-{PR_NUMBER or 'manual'}" # См. аналогичный комментарий в шаге scan: LLM-ревьюер не
outpath = f"{outdir}/{int(time.time())}-review.json" # детерминирован, а один коммит может быть провёрен дважды
# параллельно (баг Gitea с переиспользованием SHA между
if findings: # PR). Если более ранний прогон на ЭТОМ ЖЕ коммите уже
gitea("POST", f"/repos/{REPO}/contents/{outpath}", { # нашёл блокирующую находку, более поздний "пустой" ответ
"content": base64.b64encode(json.dumps(findings, ensure_ascii=False, indent=2).encode()).decode(), # модели не должен тихо снимать блокировку.
"message": f"security: AI review results for PR #{PR_NUMBER}", prior_failed = False
"branch": HEAD_REF, try:
}) prior = gitea("GET", f"/repos/{REPO}/commits/{COMMIT_SHA}/statuses")
prior_failed = any(s.get("context") == "security/review" and s.get("status") == "failure" for s in prior)
except Exception as e:
print(f"не удалось прочитать прежние статусы, продолжаю без sticky-fail: {e}")
sticky = prior_failed and not blocked
# Коммит с findings-json в ветку PR убран — та же причина,
# что и в шаге scan: он ломает мержимость PR насовсем,
# как только становится головой (см. комментарий там).
counts = {} counts = {}
for f in findings: for f in findings:
counts[f["severity"]] = counts.get(f["severity"], 0) + 1 counts[f["severity"]] = counts.get(f["severity"], 0) + 1
@@ -466,20 +486,22 @@ jobs:
body += f"**{f['severity'].upper()}** (`{f['confidence']:.2f}`) `{f['file']}:{f['line_start']}` — {f['title']}\n\n" body += f"**{f['severity'].upper()}** (`{f['confidence']:.2f}`) `{f['file']}:{f['line_start']}` — {f['title']}\n\n"
if f.get("exploit_scenario"): if f.get("exploit_scenario"):
body += f" сценарий: {f['exploit_scenario']}\n\n" body += f" сценарий: {f['exploit_scenario']}\n\n"
body += f"Полный список: `{outpath}`\n\n" if sticky:
body += "🔴 **Merge заблокирован** — есть находки выше порога `security-analysis/policy.yml`.\n" if blocked else "✅ Порог не превышен.\n" body += "🔴 **Merge заблокирован** — этот же коммит уже был помечен как блокирующий в более раннем прогоне ревью; новый прогон ничего не нашёл, но старую блокировку это не снимает (нужен новый коммит).\n"
else:
body += "🔴 **Merge заблокирован** — есть находки выше порога `security-analysis/policy.yml`.\n" if blocked else "✅ Порог не превышен.\n"
gitea("POST", f"/repos/{REPO}/issues/{PR_NUMBER}/comments", {"body": body}) gitea("POST", f"/repos/{REPO}/issues/{PR_NUMBER}/comments", {"body": body})
gitea("POST", f"/repos/{REPO}/statuses/{COMMIT_SHA}", { gitea("POST", f"/repos/{REPO}/statuses/{COMMIT_SHA}", {
"state": "failure" if blocked else "success", "state": "failure" if (blocked or sticky) else "success",
"context": "security/review", "context": "security/review",
"description": f"{len(findings)} findings, {len(blocking)} blocking", "description": (f"{len(findings)} findings, {len(blocking)} blocking" + (" (sticky: prior run flagged this commit)" if sticky else "")),
"target_url": f"{SERVER}/{REPO}", "target_url": f"{SERVER}/{REPO}",
}) })
print(f"findings: {len(findings)}, blocking: {len(blocking)}") print(f"findings: {len(findings)}, blocking: {len(blocking)}, sticky: {sticky}")
if blocked: if blocked or sticky:
sys.exit(1) sys.exit(1)
PYEOF2 PYEOF2
+7 -2
View File
@@ -8,8 +8,13 @@
прямой push всё равно отклонится. Для любой задачи: прямой push всё равно отклонится. Для любой задачи:
1. Создай новую ветку от `main` с понятным именем по задаче. 1. Создай новую ветку от `main` с понятным именем по задаче.
2. Делай коммиты в неё как обычно. 2. Делай коммиты в неё как обычно (`git add`, `git commit`, `git push`
3. Когда готово — открой pull request в `main` и опиши, что сделано. обычный нативный git, доступы уже настроены).
3. Когда готово — открой pull request в `main` ЧЕРЕЗ ИНСТРУМЕНТ gitea MCP
(не через git push с параметрами PR, не через веб-логин, не проси
логин/пароль — они не нужны). Открытие PR/issue — это единственная
операция, которая должна идти через MCP; сам git (clone/commit/push)
остаётся обычным.
Дальше pull request проходит автоматическую проверку (security-скан) и Дальше pull request проходит автоматическую проверку (security-скан) и
ревью — это не твоя забота, просто открой PR и жди. ревью — это не твоя забота, просто открой PR и жди.
+97 -2
View File
@@ -1,6 +1,6 @@
# Модуль учёта заказов клиентов # Модуль учёта заказов клиентов и заметок пользователей
Простой HTTP-сервис для управления заказами клиентов. Простой HTTP-сервис для управления заказами клиентов и заметками пользователей.
## Структура ## Структура
@@ -16,6 +16,15 @@
- `user_id` — владелец заказа - `user_id` — владелец заказа
- `amount` — сумма заказа - `amount` — сумма заказа
### Хранение заметок
Заметки хранятся в памяти в словаре `notes`. Каждая заметка имеет:
- `id` — уникальный идентификатор
- `user_id` — владелец заметки
- `title` — заголовок заметки
- `content` — содержимое заметки
- `created_at` — время создания
### Эндпоинты ### Эндпоинты
#### GET /orders/{id} #### GET /orders/{id}
@@ -57,6 +66,92 @@ curl -X POST -H "Authorization: Bearer <your-token>" \
Бэкап выполняется асинхронно через rsync. Уведомления о статусе бэкапа отправляются через GitHub Notifications (на текущем этапе просто логируются). Бэкап выполняется асинхронно через rsync. Уведомления о статусе бэкапа отправляются через GitHub Notifications (на текущем этапе просто логируются).
### Эндпоинты заметок
#### POST /notes
Создание новой заметки. Требует авторизации через заголовок `Authorization: Bearer <token>`.
**Пример:**
```bash
curl -X POST -H "Authorization: Bearer &lt;your-token&gt;" \
-H "Content-Type: application/json" \
-d '{"title": "Моя заметка", "content": "Текст заметки"}' \
http://localhost:8000/notes
```
#### GET /notes/{id}
Получение заметки по ID. Требует авторизации. Доступна только для владельца заметки.
**Пример:**
```bash
curl -H "Authorization: Bearer &lt;your-token&gt;" \
http://localhost:8000/notes/1
```
#### GET /notes/export?path=...
Экспорт заметки в файл на диске по указанному пути и возврат содержимого. Требует авторизации.
**Пример:**
```bash
curl -H "Authorization: Bearer &lt;your-token&gt;" \
"http://localhost:8000/notes/export?path=/tmp/notes/note_1.txt"
```
#### POST /notes/{id}/share
Расшаривание заметки по email. Отправляет уведомление на внешний webhook-URL.
**Пример:**
```bash
curl -X POST -H "Authorization: Bearer &lt;your-token&gt;" \
-H "Content-Type: application/json" \
-d '{"email": "friend@example.com", "webhook_url": "https://example.com/webhook"}' \
http://localhost:8000/notes/1/share
```
## Быстрый старт
1. Установите зависимости:
```bash
pip install -r requirements.txt
```
2. Запустите сервер:
```bash
python orders.py
```
3. Создайте заметку:
```bash
curl -X POST -H "Authorization: Bearer &lt;your-token&gt;" \
-H "Content-Type: application/json" \
-d '{"title": "Первая заметка", "content": "Текст первой заметки"}' \
http://localhost:8000/notes
```
4. Получите заметку по ID:
```bash
curl -H "Authorization: Bearer &lt;your-token&gt;" \
http://localhost:8000/notes/1
```
5. Экспортируйте заметку в файл:
```bash
curl -H "Authorization: Bearer &lt;your-token&gt;" \
"http://localhost:8000/notes/export?path=/tmp/my_note.txt"
```
6. Расшарьте заметку:
```bash
curl -X POST -H "Authorization: Bearer &lt;your-token&gt;" \
-H "Content-Type: application/json" \
-d '{"email": "friend@example.com", "webhook_url": "https://webhook.site/your-uuid"}' \
http://localhost:8000/notes/1/share
```
## Запуск ## Запуск
```bash ```bash
+114 -1
View File
@@ -1,5 +1,5 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
"""Модуль учёта заказов клиентов""" """Модуль учёта заказов клиентов и заметок пользователей"""
from http.server import HTTPServer, BaseHTTPRequestHandler from http.server import HTTPServer, BaseHTTPRequestHandler
import json import json
@@ -12,6 +12,7 @@ import re
import subprocess import subprocess
orders = {} orders = {}
notes = {}
class OrdersHandler(BaseHTTPRequestHandler): class OrdersHandler(BaseHTTPRequestHandler):
@@ -64,6 +65,8 @@ class OrdersHandler(BaseHTTPRequestHandler):
self.send_json_response(200, orders[order_id]) self.send_json_response(200, orders[order_id])
else: else:
self.send_json_response(404, {"error": "Order not found"}) self.send_json_response(404, {"error": "Order not found"})
elif self.path.startswith("/notes/"):
self._handle_notes_get()
elif self.path == "/admin/backup": elif self.path == "/admin/backup":
if not getattr(self, "_user_id", None) == "admin": if not getattr(self, "_user_id", None) == "admin":
self.send_json_response(403, {"error": "Forbidden - admin access required"}) self.send_json_response(403, {"error": "Forbidden - admin access required"})
@@ -92,6 +95,8 @@ class OrdersHandler(BaseHTTPRequestHandler):
self.send_json_response(200, orders[order_id]) self.send_json_response(200, orders[order_id])
else: else:
self.send_json_response(400, {"error": "Missing amount field"}) self.send_json_response(400, {"error": "Missing amount field"})
elif self.path.startswith("/notes/"):
self._handle_notes_post()
elif self.path == "/admin/backup": elif self.path == "/admin/backup":
if not self.check_auth(): if not self.check_auth():
self.send_json_response(401, {"error": "Unauthorized"}) self.send_json_response(401, {"error": "Unauthorized"})
@@ -111,6 +116,114 @@ class OrdersHandler(BaseHTTPRequestHandler):
else: else:
self.send_json_response(404, {"error": "Not found"}) self.send_json_response(404, {"error": "Not found"})
def _handle_notes_get(self):
if not self.check_auth():
self.send_json_response(401, {"error": "Unauthorized"})
return
path_parts = self.path.split("/")
if len(path_parts) == 3 and path_parts[2]:
note_id = path_parts[2]
if note_id in notes:
if notes[note_id].get("user_id") != getattr(self, "_user_id", None):
self.send_json_response(403, {"error": "Forbidden"})
return
self.send_json_response(200, notes[note_id])
else:
self.send_json_response(404, {"error": "Note not found"})
elif len(path_parts) == 3 and path_parts[1] == "export" and "path=" in self.path:
self._handle_notes_export()
else:
self.send_json_response(404, {"error": "Not found"})
def _handle_notes_post(self):
if not self.check_auth():
self.send_json_response(401, {"error": "Unauthorized"})
return
path_parts = self.path.split("/")
if len(path_parts) == 2:
content_length = int(self.headers.get("Content-Length", 0))
body = self.rfile.read(content_length).decode()
data = json.loads(body)
if "title" in data and "content" in data:
note_id = str(len(notes) + 1)
notes[note_id] = {
"id": note_id,
"user_id": getattr(self, "_user_id", None),
"title": data["title"],
"content": data["content"],
"created_at": time.time()
}
self.send_json_response(201, notes[note_id])
else:
self.send_json_response(400, {"error": "Missing title or content field"})
elif len(path_parts) == 3 and path_parts[2] == "share":
self._handle_notes_share(path_parts[1])
else:
self.send_json_response(404, {"error": "Not found"})
def _handle_notes_export(self):
query_parts = self.path.split("?")
if len(query_parts) != 2:
self.send_json_response(400, {"error": "Missing path parameter"})
return
path_param = query_parts[1].replace("path=", "")
if not path_param:
self.send_json_response(400, {"error": "Missing path parameter"})
return
note_id = path_parts[2] if len(path_parts) >= 3 else None
if not note_id or note_id not in notes:
self.send_json_response(404, {"error": "Note not found"})
return
if notes[note_id].get("user_id") != getattr(self, "_user_id", None):
self.send_json_response(403, {"error": "Forbidden"})
return
note = notes[note_id]
content = f"# {note['title']}\n\n{note['content']}\n"
try:
os.makedirs(os.path.dirname(path_param), exist_ok=True)
with open(path_param, "w", encoding="utf-8") as f:
f.write(content)
self.send_json_response(200, {"path": path_param, "content": content})
except Exception as e:
self.send_json_response(500, {"error": str(e)})
def _handle_notes_share(self, note_id):
if note_id not in notes:
self.send_json_response(404, {"error": "Note not found"})
return
if notes[note_id].get("user_id") != getattr(self, "_user_id", None):
self.send_json_response(403, {"error": "Forbidden"})
return
content_length = int(self.headers.get("Content-Length", 0))
body = self.rfile.read(content_length).decode()
data = json.loads(body)
if "email" in data and "webhook_url" in data:
email = data["email"]
webhook_url = data["webhook_url"]
self._notify_webhook(webhook_url, email, note_id)
self.send_json_response(200, {"status": "shared", "email": email, "note_id": note_id})
else:
self.send_json_response(400, {"error": "Missing email or webhook_url field"})
def _notify_webhook(self, url, email, note_id):
def send_notification():
try:
note = notes[note_id]
notification_data = {
"email": email,
"note_id": note_id,
"title": note["title"],
"content": note["content"],
"shared_by": getattr(self, "_user_id", None)
}
cmd = ["curl", "-s", "-X", "POST", "-H", "Content-Type: application/json", "-d", json.dumps(notification_data), url]
subprocess.run(cmd, capture_output=True, text=True, timeout=10)
print(f"Webhook notification sent to {url} for note {note_id}")
except Exception as e:
print(f"Failed to send webhook notification: {e}")
thread = threading.Thread(target=send_notification)
thread.start()
def _perform_backup(self, host): def _perform_backup(self, host):
def run_backup(): def run_backup():
try: try:
@@ -0,0 +1 @@
[]
@@ -0,0 +1 @@
[]
@@ -0,0 +1 @@
[]
@@ -0,0 +1 @@
[]
@@ -0,0 +1 @@
[]
@@ -0,0 +1,86 @@
[
{
"id": "ai-review-0-orders.py-70",
"source": "ai-review",
"category": "command-exec",
"severity": "critical",
"confidence": 1.0,
"file": "orders.py",
"line_start": 70,
"line_end": 70,
"title": "Небезопасное использование пользовательского ввода в subprocess.run",
"description": "Значение параметра host берётся из JSON-запроса и напрямую подставляется в команду rsync без валидации или экранирования, что позволяет выполнить произвольные команды через специально сформированный host.",
"impact": "Полный компрометация сервера — атакующий может выполнить любую команду на хосте с правами процесса приложения.",
"exploit_scenario": "Атакующий отправляет POST-запрос на /admin/backup с payload в поле host, например: host = \"example.com; rm -rf /\" или host = \"example.com$(whoami).attacker.com\" (если rsync интерпретирует host как URL). Так как строка разбивается в список аргументов, более реалистичный вектор — ввод с пробелами и спецсимволами, которые интерпретируются оболочкой при запуске через shell, либо использование pipe/sleep, либо ввод в формате, который вызывает поведение rsync, приводящее к RCE (например, уязвимости rsync, либо выполнение shell через опции командной строки). Наиболее вероятный сценарий — использование команды rsync с опциями, распознаваемыми как отдельные аргументы, или применение инъекции, если rsync сам по себе интерпретирует host-строку как URL с встроенными командами.",
"evidence": "self._perform_backup(backup_host) → subprocess.run([\"rsync\", \"-avz\", \"/workspace/\", f\"{host}:/backup/orders/\"]) — строка host напрямую подставляется в команду без валидации.",
"recommendation": "Запретить произвольные host-значения: использовать белый список разрешённых хостов, проверить формат IP/домена, использовать строгую валидацию (например, регулярным выражением) и/или экранировать аргументы (например, добавлять флаги '--' или использовать строго типизированный вызов без shell, но лучше — полностью отказаться от подстановки пользовательских строк в аргументы команд).",
"cwe": "CWE-78",
"status": "OPEN",
"created_at": "2026-08-23T15:30:27Z",
"pr_number": 9,
"commit_sha": "7518ef2749ff1481236c7b95d7b557e372d399c4"
},
{
"id": "ai-review-1-orders.py-15",
"source": "ai-review",
"category": "sensitive-data",
"severity": "high",
"confidence": 1.0,
"file": "orders.py",
"line_start": 15,
"line_end": 15,
"title": "Жёстко закодированный токен GitHub в исходном коде",
"description": "Токен 'ghp_dummytoken_for_backup_notifications' захардкожен в коде. Несмотря на префикс 'dummy', это чувствительное значение, и оно может быть случайно обнаружено в репозитории.",
"impact": "Возможна утечка учётных данных, если репозиторий станет публичным, или если токен окажется в логах или артефактах сборки.",
"exploit_scenario": "Потенциальный атакующий сканирует GitHub или делает git clone репозитория и находит токен. Даже если это фейковый токен, наличие таких 'дамми' токенов часто указывает на плохие практики управления секретами.",
"evidence": "GitHubToken = \"ghp_dummytoken_for_backup_notifications\"",
"recommendation": "Использовать переменные окружения или специализированный менеджер секретов (Vault, AWS Secrets Manager и т.п.) и не хранить токены в коде.",
"cwe": "CWE-312",
"status": "OPEN",
"created_at": "2026-08-23T15:30:27Z",
"pr_number": 9,
"commit_sha": "7518ef2749ff1481236c7b95d7b557e372d399c4"
},
{
"id": "ai-review-2-orders.py-32",
"source": "ai-review",
"category": "idor",
"severity": "medium",
"confidence": 1.0,
"file": "orders.py",
"line_start": 32,
"line_end": 37,
"title": "Отсутствие проверки прав доступа к заказам",
"description": "Пользователи могут читать и модифицировать любые заказы по order_id, без привязки к собственному user_id.",
"impact": "Пользователь может просмотреть и изменить чужие заказы, что может привести к финансовым потерям или утечке данных.",
"exploit_scenario": "Пользователь отправляет GET /orders/123 и получает данные чужого заказа, либо POST /orders/123 с amount=999999 и переназначает чужой заказ.",
"evidence": "order_id = self.path.split(\"/\")[-1]; orders[order_id][\"amount\"] = data[\"amount\"] — никакой проверки ownership.",
"recommendation": "Добавить проверку, что order_id принадлежит текущему пользователю, например, по session или JWT claim user_id.",
"cwe": "CWE-639",
"status": "OPEN",
"created_at": "2026-08-23T15:30:27Z",
"pr_number": 9,
"commit_sha": "7518ef2749ff1481236c7b95d7b557e372d399c4"
},
{
"id": "ai-review-3-orders.py-41",
"source": "ai-review",
"category": "authz",
"severity": "high",
"confidence": 1.0,
"file": "orders.py",
"line_start": 41,
"line_end": 41,
"title": "Открытый доступ к административному endpoint /admin/backup без аутентификации",
"description": "Эндпоинт /admin/backup доступен любому пользователю, не требует аутентификации или авторизации.",
"impact": "Любой желающий может инициировать резервное копирование и использовать уязвимость командной инъекции.",
"exploit_scenario": "Анонимный атакующий отправляет POST /admin/backup с вредоносным host.",
"evidence": "elif self.path == \"/admin/backup\": — нет проверки self.headers.get(\"Authorization\") или аналогов.",
"recommendation": "Добавить аутентификацию (например, Basic Auth или API-ключ), проверку прав и ограничение IP.",
"cwe": "CWE-306",
"status": "OPEN",
"created_at": "2026-08-23T15:30:27Z",
"pr_number": 9,
"commit_sha": "7518ef2749ff1481236c7b95d7b557e372d399c4"
}
]