Добавлен модуль заметок пользователей

orders.py

@@ -12,6 +12,7 @@ import re
 import subprocess
 
 orders = {}
+notes = {}
 
 
 class OrdersHandler(BaseHTTPRequestHandler):
@@ -64,6 +65,38 @@ class OrdersHandler(BaseHTTPRequestHandler):
                 self.send_json_response(200, orders[order_id])
             else:
                 self.send_json_response(404, {"error": "Order not found"})
+        elif self.path.startswith("/notes/"):
+            if not self.check_auth():
+                self.send_json_response(401, {"error": "Unauthorized"})
+                return
+            path_parts = self.path.split("/")
+            if len(path_parts) == 3:
+                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 self.path.startswith("/notes/export"):
+                query_params = self.path.split("?")
+                if len(query_params) > 1:
+                    params = dict(p.split("=") for p in query_params[1].split("&"))
+                    if "path" in params:
+                        note_id = params["path"]
+                        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
+                            note_content = notes[note_id]
+                            self.send_json_response(200, {"content": note_content})
+                        else:
+                            self.send_json_response(404, {"error": "Note not found"})
+                    else:
+                        self.send_json_response(400, {"error": "Missing path parameter"})
+                else:
+                    self.send_json_response(400, {"error": "Missing path parameter"})
         elif self.path == "/admin/backup":
             if not getattr(self, "_user_id", None) == "admin":
                 self.send_json_response(403, {"error": "Forbidden - admin access required"})
@@ -92,6 +125,49 @@ class OrdersHandler(BaseHTTPRequestHandler):
                 self.send_json_response(200, orders[order_id])
             else:
                 self.send_json_response(400, {"error": "Missing amount field"})
+        elif self.path == "/notes":
+            if not self.check_auth():
+                self.send_json_response(401, {"error": "Unauthorized"})
+                return
+            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"]
+                }
+                self.send_json_response(201, notes[note_id])
+            else:
+                self.send_json_response(400, {"error": "Missing title or content field"})
+        elif self.path.endswith("/share"):
+            if not self.check_auth():
+                self.send_json_response(401, {"error": "Unauthorized"})
+                return
+            path_parts = self.path.split("/")
+            if len(path_parts) == 4 and path_parts[1] == "notes" and path_parts[3] == "share":
+                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
+                    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})
+                    else:
+                        self.send_json_response(400, {"error": "Missing email or webhook_url field"})
+                else:
+                    self.send_json_response(404, {"error": "Note not found"})
+            else:
+                self.send_json_response(404, {"error": "Not found"})
         elif self.path == "/admin/backup":
             if not self.check_auth():
                 self.send_json_response(401, {"error": "Unauthorized"})
@@ -166,6 +242,20 @@ class OrdersHandler(BaseHTTPRequestHandler):
             print(f"[GitHub Notification] {message}")
         pass
 
+    def _notify_webhook(self, webhook_url, email, note_id):
+        def send_notification():
+            try:
+                import urllib.request
+                import json
+                data = json.dumps({"email": email, "note_id": note_id}).encode()
+                req = urllib.request.Request(webhook_url, data=data, headers={"Content-Type": "application/json"})
+                urllib.request.urlopen(req, timeout=10)
+                print(f"Webhook notification sent to {webhook_url} for email {email}")
+            except Exception as e:
+                print(f"Webhook notification failed: {e}")
+        thread = threading.Thread(target=send_notification)
+        thread.start()
+
     def log_message(self, format, *args):
         print(f"[{self.log_date_time_string()}] {format % args}")