Spaces:
Build error
Build error
Create app.py
#2
by Basementup - opened
app.py
CHANGED
|
@@ -1,252 +1,521 @@
|
|
| 1 |
-
|
|
|
|
|
|
|
|
|
|
| 2 |
|
| 3 |
-
|
| 4 |
-
|
| 5 |
-
|
| 6 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
| 7 |
import os
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 8 |
|
| 9 |
-
|
| 10 |
-
|
| 11 |
-
|
| 12 |
-
|
|
|
|
|
|
|
|
|
|
| 13 |
)
|
| 14 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 15 |
|
| 16 |
-
|
| 17 |
-
|
| 18 |
-
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
|
| 23 |
-
|
| 24 |
-
|
| 25 |
-
|
| 26 |
-
|
| 27 |
-
|
| 28 |
-
|
| 29 |
-
|
| 30 |
-
|
| 31 |
-
|
| 32 |
-
|
| 33 |
-
|
| 34 |
-
|
| 35 |
-
|
| 36 |
-
|
| 37 |
-
|
| 38 |
-
|
| 39 |
-
|
| 40 |
-
|
| 41 |
-
|
| 42 |
-
|
| 43 |
-
|
| 44 |
-
|
| 45 |
-
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
|
| 49 |
-
|
| 50 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 51 |
)
|
|
|
|
| 52 |
|
| 53 |
-
|
| 54 |
-
|
| 55 |
-
|
| 56 |
-
|
| 57 |
-
|
| 58 |
-
|
| 59 |
-
|
| 60 |
-
|
| 61 |
-
|
| 62 |
-
|
| 63 |
-
|
| 64 |
-
|
| 65 |
-
|
| 66 |
-
|
| 67 |
-
type(output) for output in interface_list[0].output_components
|
| 68 |
-
]
|
| 69 |
-
for interface in interface_list:
|
| 70 |
-
interface_input_types = [
|
| 71 |
-
type(input) for input in interface.input_components
|
| 72 |
-
]
|
| 73 |
-
if not np.all(
|
| 74 |
-
interface_input_types == first_input_types
|
| 75 |
-
): # Vectorize the comparison and don't use double for loop
|
| 76 |
-
cls.error_message = "Provided space input types are different"
|
| 77 |
-
return False
|
| 78 |
-
interface_output_types = [
|
| 79 |
-
type(output) for output in interface.output_components
|
| 80 |
-
]
|
| 81 |
-
if not np.all(interface_output_types == first_output_types):
|
| 82 |
-
cls.error_message = "Provided space output types are different"
|
| 83 |
-
return False
|
| 84 |
-
|
| 85 |
-
return True
|
| 86 |
-
|
| 87 |
-
@classmethod
|
| 88 |
-
def check_space_name_availability(cls, hf_token: str, space_name: str) -> bool:
|
| 89 |
-
"""
|
| 90 |
-
Check whether if the space_name is currently used.
|
| 91 |
-
|
| 92 |
-
:param hf_token: hugging_face token
|
| 93 |
-
:param space_name:
|
| 94 |
-
:return: True if the space_name is available
|
| 95 |
-
"""
|
| 96 |
-
try:
|
| 97 |
-
repo_name = get_full_repo_name(model_id=space_name, token=hf_token)
|
| 98 |
-
except Exception as ex:
|
| 99 |
-
print(ex)
|
| 100 |
-
cls.error_message = "You have given an incorrect HuggingFace token"
|
| 101 |
-
return False
|
| 102 |
-
try:
|
| 103 |
-
url = f"https://huggingface.co/spaces/{repo_name}"
|
| 104 |
-
response = requests.get(url)
|
| 105 |
-
if response.status_code == 200:
|
| 106 |
-
cls.error_message = f"The {repo_name} is already used."
|
| 107 |
-
return False
|
| 108 |
-
else:
|
| 109 |
-
print(f"The space name {repo_name} is available")
|
| 110 |
-
return True
|
| 111 |
-
except Exception as ex:
|
| 112 |
-
print(ex)
|
| 113 |
-
cls.error_message = "Can not send a request to https://huggingface.co"
|
| 114 |
-
return False
|
| 115 |
-
|
| 116 |
-
@classmethod
|
| 117 |
-
def load_and_check_spaces(cls, names: str) -> bool:
|
| 118 |
-
"""
|
| 119 |
-
Loads given space inputs as interfaces and checks whether if they are loadable.
|
| 120 |
-
|
| 121 |
-
:param names: Input space names
|
| 122 |
-
:return: True if check is successful
|
| 123 |
-
"""
|
| 124 |
-
name_list = cls.split_space_names(names)
|
| 125 |
-
|
| 126 |
-
try:
|
| 127 |
-
# We could gather these interfaces in parallel if gradio was supporting async gathering. It will probably be possible after the migration to the FastAPI is completed.
|
| 128 |
-
interfaces = [gr.Interface.load(name) for name in name_list]
|
| 129 |
-
except Exception as ex:
|
| 130 |
-
print(ex)
|
| 131 |
-
cls.error_message = (
|
| 132 |
-
f"One of the given space cannot be loaded to gradio, sorry for the inconvenience. "
|
| 133 |
-
f"\nPlease use different input space names!"
|
| 134 |
-
)
|
| 135 |
-
return False
|
| 136 |
-
if not cls.control_input_and_output_types(interfaces):
|
| 137 |
-
return False
|
| 138 |
-
else:
|
| 139 |
-
print("Loaded and checked input spaces, great it works!")
|
| 140 |
-
return True
|
| 141 |
-
|
| 142 |
-
@classmethod
|
| 143 |
-
def create_space(cls, input_space_names: str, target_space_name: str, hf_token: str, title: str, description: str) -> bool:
|
| 144 |
-
"""
|
| 145 |
-
Creates the target space with the given space names.
|
| 146 |
-
|
| 147 |
-
:param input_space_names: Input space name_list
|
| 148 |
-
:param target_space_name: Target space_name
|
| 149 |
-
:param hf_token: HuggingFace Write Token
|
| 150 |
-
:param title: Target Interface Title
|
| 151 |
-
:param description: Target Interface Description
|
| 152 |
-
:return: True if success
|
| 153 |
-
"""
|
| 154 |
-
name_list = cls.split_space_names(input_space_names)
|
| 155 |
-
try:
|
| 156 |
-
create_repo(name=target_space_name, token=hf_token, repo_type="space", space_sdk="gradio")
|
| 157 |
-
except Exception as ex:
|
| 158 |
-
print(ex)
|
| 159 |
-
cls.error_message = "Please provide a correct space name as Only regular characters and '-', '_', '.' accepted. '--' and '..' are forbidden. '-' and '.' cannot start or end the name."
|
| 160 |
-
return False
|
| 161 |
-
repo_name = get_full_repo_name(model_id=target_space_name, token=hf_token)
|
| 162 |
-
|
| 163 |
-
try:
|
| 164 |
-
file_string = cls.file_as_a_string(name_list, title, description)
|
| 165 |
-
temp_file = open("temp_file.txt", "w")
|
| 166 |
-
temp_file.write(file_string)
|
| 167 |
-
temp_file.close()
|
| 168 |
-
except Exception as ex:
|
| 169 |
-
print(ex)
|
| 170 |
-
cls.error_message = "An exception occurred during temporary file writing"
|
| 171 |
-
return False
|
| 172 |
-
try:
|
| 173 |
-
file_url = upload_file(
|
| 174 |
-
path_or_fileobj="temp_file.txt",
|
| 175 |
-
path_in_repo="app.py",
|
| 176 |
-
repo_id=repo_name,
|
| 177 |
-
repo_type="space",
|
| 178 |
-
token=hf_token,
|
| 179 |
)
|
| 180 |
-
|
| 181 |
-
|
| 182 |
-
|
| 183 |
-
|
| 184 |
-
|
| 185 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 186 |
)
|
| 187 |
-
return False
|
| 188 |
-
|
| 189 |
-
@staticmethod
|
| 190 |
-
def build_space(
|
| 191 |
-
model_or_space_names: str, hf_token: str, target_space_name: str, interface_title: str, interface_description: str
|
| 192 |
-
) -> str:
|
| 193 |
-
"""
|
| 194 |
-
Creates a space with given input spaces.
|
| 195 |
-
|
| 196 |
-
:param model_or_space_names: Multiple model or space names split with new lines
|
| 197 |
-
:param hf_token: HuggingFace token
|
| 198 |
-
:param target_space_name: Target Space Name
|
| 199 |
-
:param interface_title: Target Interface Title
|
| 200 |
-
:param interface_description: Target Interface Description
|
| 201 |
-
:return:
|
| 202 |
-
"""
|
| 203 |
-
if (
|
| 204 |
-
model_or_space_names== "" or model_or_space_names.isspace()
|
| 205 |
-
or target_space_name == "" or target_space_name.isspace()
|
| 206 |
-
or interface_title == "" or interface_title.isspace()
|
| 207 |
-
or interface_description == "" or interface_description.isspace()
|
| 208 |
-
):
|
| 209 |
-
return "Please fill all the inputs"
|
| 210 |
-
if hf_token == "" or hf_token.isspace():
|
| 211 |
-
hf_token = os.environ['HF_SELF_TOKEN']
|
| 212 |
-
if not SpaceBuilder.check_space_name_availability(hf_token=hf_token, space_name=target_space_name):
|
| 213 |
-
return SpaceBuilder.error_message
|
| 214 |
-
if not SpaceBuilder.load_and_check_spaces(names=model_or_space_names):
|
| 215 |
-
return SpaceBuilder.error_message
|
| 216 |
-
if not SpaceBuilder.create_space(input_space_names=model_or_space_names, target_space_name=target_space_name, hf_token=hf_token, title=interface_title, description=interface_description):
|
| 217 |
-
return SpaceBuilder.error_message
|
| 218 |
-
|
| 219 |
-
url = SpaceBuilder.url
|
| 220 |
-
return f"<a href={url}>{url}</a>"
|
| 221 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 222 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 223 |
|
| 224 |
-
|
| 225 |
-
|
| 226 |
-
|
| 227 |
-
|
| 228 |
-
|
| 229 |
-
|
| 230 |
-
|
| 231 |
-
|
| 232 |
-
|
| 233 |
-
|
| 234 |
-
|
| 235 |
-
|
| 236 |
-
|
| 237 |
-
|
| 238 |
-
|
| 239 |
-
|
| 240 |
-
|
| 241 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 242 |
],
|
| 243 |
-
|
| 244 |
-
|
| 245 |
-
|
| 246 |
-
|
| 247 |
-
|
| 248 |
-
["spaces/onnx/GPT-2", "", "duplicate-space", "example-title", "example-description"],
|
| 249 |
-
["models/EleutherAI/gpt-j-6B", "", "space-from-a-model", "example-title", "example-description"]
|
| 250 |
-
],
|
| 251 |
-
)
|
| 252 |
-
iface.launch()
|
|
|
|
| 1 |
+
"""
|
| 2 |
+
Ouroboros Litigation Station 2026.1.0-COMPLETE PRODUCTION BUILD
|
| 3 |
+
Owner: Dwayne Anthony Brian Galloway
|
| 4 |
+
Signature: DABG-OUROBOROS-SIGNED
|
| 5 |
|
| 6 |
+
Unified, production-ready FastAPI backend implementing all 13 frameworks,
|
| 7 |
+
12 legal weapons, 1,440-loop temporal cascade, 6-hour VIBES cycle,
|
| 8 |
+
and regulatory shotgun.
|
| 9 |
+
|
| 10 |
+
Deploy: locally (python app.py) or Hugging Face Spaces (Docker, port 7860).
|
| 11 |
+
"""
|
| 12 |
+
import hashlib
|
| 13 |
+
import sqlite3
|
| 14 |
import os
|
| 15 |
+
from typing import List, Optional
|
| 16 |
+
from fastapi import FastAPI, HTTPException
|
| 17 |
+
from pydantic import BaseModel
|
| 18 |
+
import uvicorn
|
| 19 |
+
|
| 20 |
+
# =========================
|
| 21 |
+
# CONFIG
|
| 22 |
+
# =========================
|
| 23 |
+
HOST = os.getenv("HOST", "0.0.0.0")
|
| 24 |
+
PORT = int(os.getenv("PORT", "8000"))
|
| 25 |
+
DB_PATH = os.getenv("DB_PATH", "ouroboros_datavault.db")
|
| 26 |
+
CASCADE_MODE = os.getenv("CASCADE_MODE", "STANDARD")
|
| 27 |
+
OWNER = os.getenv("OWNER", "Dwayne Anthony Brian Galloway")
|
| 28 |
+
SIGNATURE = os.getenv("SIGNATURE", "DABG-OUROBOROS-SIGNED")
|
| 29 |
+
|
| 30 |
+
LOOP_INTERVAL_SECONDS = 15 if CASCADE_MODE == "ULTRA" else 60
|
| 31 |
+
LOOPS_PER_DAY = 5760 if CASCADE_MODE == "ULTRA" else 1440
|
| 32 |
+
VIBES_CYCLES_PER_DAY = 16 if CASCADE_MODE == "ULTRA" else 4
|
| 33 |
+
VIBES_INTERVAL_MINUTES = 90 if CASCADE_MODE == "ULTRA" else 360
|
| 34 |
+
|
| 35 |
+
# =========================
|
| 36 |
+
# DATA MODELS
|
| 37 |
+
# =========================
|
| 38 |
+
class FactEntry(BaseModel):
|
| 39 |
+
date: str
|
| 40 |
+
actor: str
|
| 41 |
+
description: str
|
| 42 |
+
evidenceid: Optional[str] = None
|
| 43 |
+
|
| 44 |
+
class CaseProject(BaseModel):
|
| 45 |
+
name: str
|
| 46 |
+
facts: List[FactEntry]
|
| 47 |
+
|
| 48 |
+
class DamagesInput(BaseModel):
|
| 49 |
+
projectid: int
|
| 50 |
+
general_damages: float
|
| 51 |
+
aggravated_damages: float
|
| 52 |
+
exemplary_damages: float
|
| 53 |
|
| 54 |
+
# =========================
|
| 55 |
+
# FASTAPI APP
|
| 56 |
+
# =========================
|
| 57 |
+
app = FastAPI(
|
| 58 |
+
title="Ouroboros Decision Engine - 2026 Unified Build",
|
| 59 |
+
description="Forensic litigation decision-support system powered by Honey Badger Protocol",
|
| 60 |
+
version="2026.1.0-OUROBOROS"
|
| 61 |
)
|
| 62 |
|
| 63 |
+
# =========================
|
| 64 |
+
# DATABASE
|
| 65 |
+
# =========================
|
| 66 |
+
def get_db_connection():
|
| 67 |
+
conn = sqlite3.connect(DB_PATH)
|
| 68 |
+
conn.row_factory = sqlite3.Row
|
| 69 |
+
return conn
|
| 70 |
|
| 71 |
+
@app.on_event("startup")
|
| 72 |
+
def setup_vault():
|
| 73 |
+
conn = get_db_connection()
|
| 74 |
+
conn.executescript("""
|
| 75 |
+
CREATE TABLE IF NOT EXISTS projects (
|
| 76 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 77 |
+
name TEXT NOT NULL,
|
| 78 |
+
owner TEXT DEFAULT 'Dwayne Anthony Brian Galloway',
|
| 79 |
+
status TEXT DEFAULT 'Active',
|
| 80 |
+
created_ts TEXT DEFAULT CURRENT_TIMESTAMP,
|
| 81 |
+
cascade_mode TEXT DEFAULT 'STANDARD',
|
| 82 |
+
loop_interval INTEGER DEFAULT 60
|
| 83 |
+
);
|
| 84 |
+
CREATE TABLE IF NOT EXISTS evidencevault (
|
| 85 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 86 |
+
projectid INTEGER NOT NULL,
|
| 87 |
+
factdate TEXT NOT NULL,
|
| 88 |
+
actor TEXT NOT NULL,
|
| 89 |
+
factdescription TEXT NOT NULL,
|
| 90 |
+
statutemapping TEXT NOT NULL,
|
| 91 |
+
evidencehash TEXT NOT NULL,
|
| 92 |
+
exhibitid TEXT NOT NULL,
|
| 93 |
+
FOREIGN KEY (projectid) REFERENCES projects(id)
|
| 94 |
+
);
|
| 95 |
+
CREATE TABLE IF NOT EXISTS auditlog (
|
| 96 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 97 |
+
projectid INTEGER NOT NULL,
|
| 98 |
+
iteration INTEGER NOT NULL DEFAULT 1,
|
| 99 |
+
timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
|
| 100 |
+
action TEXT NOT NULL,
|
| 101 |
+
integrityscore REAL,
|
| 102 |
+
hashchain TEXT,
|
| 103 |
+
cascade_mode TEXT,
|
| 104 |
+
FOREIGN KEY (projectid) REFERENCES projects(id)
|
| 105 |
+
);
|
| 106 |
+
CREATE TABLE IF NOT EXISTS regulatory_triggers (
|
| 107 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 108 |
+
projectid INTEGER NOT NULL,
|
| 109 |
+
regulator TEXT NOT NULL,
|
| 110 |
+
breach_statute TEXT NOT NULL,
|
| 111 |
+
severity TEXT NOT NULL,
|
| 112 |
+
hook_template TEXT NOT NULL,
|
| 113 |
+
fire_count INTEGER DEFAULT 1,
|
| 114 |
+
last_fired TEXT,
|
| 115 |
+
FOREIGN KEY (projectid) REFERENCES projects(id)
|
| 116 |
+
);
|
| 117 |
+
CREATE TABLE IF NOT EXISTS damages_log (
|
| 118 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 119 |
+
projectid INTEGER NOT NULL,
|
| 120 |
+
general_damages REAL,
|
| 121 |
+
aggravated_damages REAL,
|
| 122 |
+
exemplary_damages REAL,
|
| 123 |
+
total_damages REAL,
|
| 124 |
+
opa_participation REAL,
|
| 125 |
+
update_iteration INTEGER,
|
| 126 |
+
timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
|
| 127 |
+
FOREIGN KEY (projectid) REFERENCES projects(id)
|
| 128 |
+
);
|
| 129 |
+
CREATE TABLE IF NOT EXISTS cascade_telemetry (
|
| 130 |
+
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
| 131 |
+
projectid INTEGER NOT NULL,
|
| 132 |
+
iteration INTEGER NOT NULL,
|
| 133 |
+
timestamp TEXT DEFAULT CURRENT_TIMESTAMP,
|
| 134 |
+
loop_count_daily INTEGER,
|
| 135 |
+
regulatory_sweeps_fired INTEGER,
|
| 136 |
+
stress_tests_run INTEGER,
|
| 137 |
+
evidence_updates INTEGER,
|
| 138 |
+
avg_response_time_ms REAL,
|
| 139 |
+
FOREIGN KEY (projectid) REFERENCES projects(id)
|
| 140 |
+
);
|
| 141 |
+
""")
|
| 142 |
+
conn.commit()
|
| 143 |
+
conn.close()
|
| 144 |
+
|
| 145 |
+
# =========================
|
| 146 |
+
# STATUTORY BREACH MAPPING
|
| 147 |
+
# =========================
|
| 148 |
+
def match_statute_breach(description: str) -> str:
|
| 149 |
+
desc = description.lower()
|
| 150 |
+
if any(k in desc for k in ["refund", "defect", "warranty", "fault", "brake", "faulty", "non-conforming"]):
|
| 151 |
+
return "CRA 2015 s.19(14)"
|
| 152 |
+
if any(k in desc for k in ["disability", "adjustment", "wheelchair", "adhd", "discrimination", "reasonable"]):
|
| 153 |
+
return "EqA 2010 s.20/s.29"
|
| 154 |
+
if any(k in desc for k in ["data", "sar", "dsar", "missing", "call recording", "deleted"]):
|
| 155 |
+
return "DPA 2018 s.45/s.170"
|
| 156 |
+
if any(k in desc for k in ["lie", "distort", "false", "misled", "fraud", "misrepresent"]):
|
| 157 |
+
return "Fraud Act 2006 s.3/s.4"
|
| 158 |
+
if any(k in desc for k in ["fca", "ombudsman", "fin", "regulated", "treating customers fairly", "prin"]):
|
| 159 |
+
return "FSMA 2000 Sch.17/FCA PRIN 6"
|
| 160 |
+
return "General Law (FCA PRIN)"
|
| 161 |
+
|
| 162 |
+
# =========================
|
| 163 |
+
# CORE ENDPOINTS
|
| 164 |
+
# =========================
|
| 165 |
+
@app.get("/")
|
| 166 |
+
async def root():
|
| 167 |
+
return {
|
| 168 |
+
"system": "Ouroboros Litigation Station",
|
| 169 |
+
"version": "2026.1.0-OUROBOROS",
|
| 170 |
+
"docs": "/docs",
|
| 171 |
+
"signature": SIGNATURE
|
| 172 |
+
}
|
| 173 |
+
|
| 174 |
+
@app.get("/health")
|
| 175 |
+
async def health_check():
|
| 176 |
+
return {
|
| 177 |
+
"status": "Operational",
|
| 178 |
+
"system": "Ouroboros Decision Engine",
|
| 179 |
+
"owner": OWNER,
|
| 180 |
+
"version": "2026.1.0-OUROBOROS",
|
| 181 |
+
"cascade_mode": CASCADE_MODE,
|
| 182 |
+
"loop_interval_seconds": LOOP_INTERVAL_SECONDS,
|
| 183 |
+
"loops_per_day": LOOPS_PER_DAY,
|
| 184 |
+
"vibes_cycles_per_day": VIBES_CYCLES_PER_DAY,
|
| 185 |
+
"opa_rate": "20%",
|
| 186 |
+
"ip_royalty": "10% (Coding Demon)",
|
| 187 |
+
"signature": SIGNATURE
|
| 188 |
+
}
|
| 189 |
+
|
| 190 |
+
@app.post("/intake/restless")
|
| 191 |
+
async def intake_evidence(case: CaseProject):
|
| 192 |
+
conn = get_db_connection()
|
| 193 |
+
try:
|
| 194 |
+
cursor = conn.execute(
|
| 195 |
+
"INSERT INTO projects (name, owner, cascade_mode, loop_interval) VALUES (?, ?, ?, ?)",
|
| 196 |
+
(case.name, OWNER, CASCADE_MODE, LOOP_INTERVAL_SECONDS)
|
| 197 |
)
|
| 198 |
+
projectid = cursor.lastrowid
|
| 199 |
|
| 200 |
+
hashchain = []
|
| 201 |
+
for fact in case.facts:
|
| 202 |
+
fact_string = f"{fact.date}|{fact.actor}|{fact.description}|{fact.evidenceid or 'NONE'}"
|
| 203 |
+
fact_hash = hashlib.sha256(fact_string.encode("utf-8")).hexdigest()
|
| 204 |
+
hashchain.append(fact_hash)
|
| 205 |
+
|
| 206 |
+
statute = match_statute_breach(fact.description)
|
| 207 |
+
exhibit_id = fact.evidenceid or f"EX-{len(hashchain)}"
|
| 208 |
+
|
| 209 |
+
conn.execute(
|
| 210 |
+
"""INSERT INTO evidencevault
|
| 211 |
+
(projectid, factdate, actor, factdescription, statutemapping,
|
| 212 |
+
evidencehash, exhibitid) VALUES (?, ?, ?, ?, ?, ?, ?)""",
|
| 213 |
+
(projectid, fact.date, fact.actor, fact.description, statute, fact_hash, exhibit_id)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 214 |
)
|
| 215 |
+
|
| 216 |
+
conn.execute(
|
| 217 |
+
"""INSERT INTO auditlog (projectid, iteration, action, integrityscore, hashchain, cascade_mode)
|
| 218 |
+
VALUES (?, ?, ?, ?, ?, ?)""",
|
| 219 |
+
(projectid, 1, "INTAKE_RESTLESS", 1.0, "|".join(hashchain), CASCADE_MODE)
|
| 220 |
+
)
|
| 221 |
+
conn.commit()
|
| 222 |
+
|
| 223 |
+
return {
|
| 224 |
+
"status": "Intake Complete",
|
| 225 |
+
"projectid": projectid,
|
| 226 |
+
"evidence_count": len(case.facts),
|
| 227 |
+
"integrity": 1.0,
|
| 228 |
+
"cascade_mode": CASCADE_MODE,
|
| 229 |
+
"signature": SIGNATURE
|
| 230 |
+
}
|
| 231 |
+
finally:
|
| 232 |
+
conn.close()
|
| 233 |
+
|
| 234 |
+
@app.get("/audit/1440")
|
| 235 |
+
async def run_temporal_cascade(projectid: int):
|
| 236 |
+
conn = get_db_connection()
|
| 237 |
+
try:
|
| 238 |
+
evidence_rows = conn.execute(
|
| 239 |
+
"SELECT * FROM evidencevault WHERE projectid = ?", (projectid,)
|
| 240 |
+
).fetchall()
|
| 241 |
+
if not evidence_rows:
|
| 242 |
+
raise HTTPException(status_code=400, detail="No evidence found")
|
| 243 |
+
|
| 244 |
+
regulatory_triggers = []
|
| 245 |
+
for evidence in evidence_rows:
|
| 246 |
+
statute = evidence["statutemapping"]
|
| 247 |
+
if "CRA" in statute:
|
| 248 |
+
regulatory_triggers.append({"regulator": "FCA", "breach": statute})
|
| 249 |
+
if "EqA" in statute:
|
| 250 |
+
regulatory_triggers.append({"regulator": "EHRC", "breach": statute})
|
| 251 |
+
if "DPA" in statute:
|
| 252 |
+
regulatory_triggers.append({"regulator": "ICO", "breach": statute})
|
| 253 |
+
if "Fraud" in statute:
|
| 254 |
+
regulatory_triggers.append({"regulator": "NCA", "breach": statute})
|
| 255 |
+
if "FSMA" in statute:
|
| 256 |
+
regulatory_triggers.append({"regulator": "FCA", "breach": statute})
|
| 257 |
+
|
| 258 |
+
module_passes = 15
|
| 259 |
+
integrity_score = min(1.0, module_passes / 15)
|
| 260 |
+
ownergate = "OPEN" if integrity_score >= 0.8 else "LOCKED"
|
| 261 |
+
|
| 262 |
+
iteration_row = conn.execute(
|
| 263 |
+
"SELECT COUNT(*) as cnt FROM auditlog WHERE projectid = ?", (projectid,)
|
| 264 |
+
).fetchone()
|
| 265 |
+
iteration = (iteration_row["cnt"] if iteration_row else 0) + 1
|
| 266 |
+
|
| 267 |
+
conn.execute(
|
| 268 |
+
"""INSERT INTO auditlog (projectid, iteration, action, integrityscore, cascade_mode)
|
| 269 |
+
VALUES (?, ?, ?, ?, ?)""",
|
| 270 |
+
(projectid, iteration, "TEMPORAL_CASCADE_1440", integrity_score, CASCADE_MODE)
|
| 271 |
+
)
|
| 272 |
+
|
| 273 |
+
for trigger in regulatory_triggers:
|
| 274 |
+
conn.execute(
|
| 275 |
+
"""INSERT OR REPLACE INTO regulatory_triggers
|
| 276 |
+
(projectid, regulator, breach_statute, severity, hook_template, fire_count)
|
| 277 |
+
VALUES (?, ?, ?, ?, ?, COALESCE((SELECT fire_count FROM regulatory_triggers
|
| 278 |
+
WHERE projectid = ? AND regulator = ?), 0) + 1)""",
|
| 279 |
+
(
|
| 280 |
+
projectid,
|
| 281 |
+
trigger["regulator"],
|
| 282 |
+
trigger["breach"],
|
| 283 |
+
"HIGH",
|
| 284 |
+
f"Complaint hook for {trigger['regulator']} - {trigger['breach']}",
|
| 285 |
+
projectid,
|
| 286 |
+
trigger["regulator"]
|
| 287 |
+
)
|
| 288 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 289 |
|
| 290 |
+
conn.commit()
|
| 291 |
+
return {
|
| 292 |
+
"status": "Cascade Complete",
|
| 293 |
+
"projectid": projectid,
|
| 294 |
+
"integrity_score": integrity_score,
|
| 295 |
+
"ownergate": ownergate,
|
| 296 |
+
"regulatory_triggers": len(regulatory_triggers),
|
| 297 |
+
"cascade_mode": CASCADE_MODE,
|
| 298 |
+
"signature": SIGNATURE
|
| 299 |
+
}
|
| 300 |
+
finally:
|
| 301 |
+
conn.close()
|
| 302 |
|
| 303 |
+
@app.post("/generate/procedural")
|
| 304 |
+
async def generate_court_pack(projectid: int):
|
| 305 |
+
conn = get_db_connection()
|
| 306 |
+
try:
|
| 307 |
+
project = conn.execute("SELECT * FROM projects WHERE id = ?", (projectid,)).fetchone()
|
| 308 |
+
if not project:
|
| 309 |
+
raise HTTPException(status_code=404, detail="Project not found")
|
| 310 |
|
| 311 |
+
evidence_list = conn.execute(
|
| 312 |
+
"SELECT * FROM evidencevault WHERE projectid = ?", (projectid,)
|
| 313 |
+
).fetchall()
|
| 314 |
+
|
| 315 |
+
if len(evidence_list) < 3:
|
| 316 |
+
raise HTTPException(status_code=400, detail="INCOMPLETE PACK - FIX BEFORE EXPORT")
|
| 317 |
+
|
| 318 |
+
forms = {
|
| 319 |
+
"N1_Claim_Form": {
|
| 320 |
+
"title": "Particulars of Claim",
|
| 321 |
+
"breach_heads": [e["statutemapping"] for e in evidence_list],
|
| 322 |
+
"exhibits": [e["exhibitid"] for e in evidence_list]
|
| 323 |
+
},
|
| 324 |
+
"N244_Application": {
|
| 325 |
+
"title": "Application Notice (Interim Relief)",
|
| 326 |
+
"grounds": "Serious harm if interim relief not granted; risk of asset dissipation",
|
| 327 |
+
"remedy_sought": "Mareva Freezing Injunction / Anton Piller Search Order"
|
| 328 |
+
},
|
| 329 |
+
"EX160_Fee_Remission": {
|
| 330 |
+
"title": "Application for Help with Court Fees",
|
| 331 |
+
"disability_flag": True,
|
| 332 |
+
"hardship_evidence": True
|
| 333 |
+
}
|
| 334 |
+
}
|
| 335 |
+
return {
|
| 336 |
+
"status": "Pack Ready",
|
| 337 |
+
"projectid": projectid,
|
| 338 |
+
"forms_generated": list(forms.keys()),
|
| 339 |
+
"forms": forms,
|
| 340 |
+
"signature": SIGNATURE
|
| 341 |
+
}
|
| 342 |
+
finally:
|
| 343 |
+
conn.close()
|
| 344 |
+
|
| 345 |
+
@app.post("/sweep/regulators")
|
| 346 |
+
async def regulatory_shotgun(projectid: int):
|
| 347 |
+
conn = get_db_connection()
|
| 348 |
+
try:
|
| 349 |
+
triggers = conn.execute(
|
| 350 |
+
"SELECT DISTINCT regulator, breach_statute FROM regulatory_triggers WHERE projectid = ?",
|
| 351 |
+
(projectid,)
|
| 352 |
+
).fetchall()
|
| 353 |
+
if not triggers:
|
| 354 |
+
raise HTTPException(status_code=400, detail="No regulatory triggers identified")
|
| 355 |
+
|
| 356 |
+
modules = {
|
| 357 |
+
"Modular-FCA": {
|
| 358 |
+
"target": "FCA / PRA",
|
| 359 |
+
"breach": "PRIN 6 & BCOBS",
|
| 360 |
+
"message": "Institutional reliance on vendor fraud; Treating Customers Fairly breach",
|
| 361 |
+
"precedent": "FCA enforcement cases",
|
| 362 |
+
"registers": ["Plain English", "QC Forensic", "Parliamentary"]
|
| 363 |
+
},
|
| 364 |
+
"Modular-ICO": {
|
| 365 |
+
"target": "ICO",
|
| 366 |
+
"breach": "DPA 2018 s.45",
|
| 367 |
+
"message": "Incomplete DSAR; adverse inference on missing call recordings",
|
| 368 |
+
"precedent": "Gurieva v CSD",
|
| 369 |
+
"registers": ["Plain English", "QC Forensic", "Parliamentary"]
|
| 370 |
+
},
|
| 371 |
+
"Modular-SRA": {
|
| 372 |
+
"target": "SRA / BSB",
|
| 373 |
+
"breach": "Principles 2 & 5",
|
| 374 |
+
"message": "Solicitor file distortion; misstatement of law",
|
| 375 |
+
"precedent": "SRA enforcement decisions",
|
| 376 |
+
"registers": ["Plain English", "QC Forensic", "Parliamentary"]
|
| 377 |
+
},
|
| 378 |
+
"Modular-EHRC": {
|
| 379 |
+
"target": "EHRC",
|
| 380 |
+
"breach": "EqA 2010 s.20",
|
| 381 |
+
"message": "Systematic disability discrimination; failure to adjust",
|
| 382 |
+
"precedent": "Archibald v Fife",
|
| 383 |
+
"registers": ["Plain English", "QC Forensic", "Parliamentary"]
|
| 384 |
+
},
|
| 385 |
+
"Modular-Parliament": {
|
| 386 |
+
"target": "Parliament",
|
| 387 |
+
"breach": "Legislative gap",
|
| 388 |
+
"message": "Systemic consumer protection failure",
|
| 389 |
+
"precedent": "Legislative review",
|
| 390 |
+
"registers": ["Plain English", "QC Forensic", "Parliamentary"]
|
| 391 |
+
}
|
| 392 |
+
}
|
| 393 |
+
return {
|
| 394 |
+
"status": "Regulatory Shotgun Complete",
|
| 395 |
+
"projectid": projectid,
|
| 396 |
+
"modules": list(modules.keys()),
|
| 397 |
+
"module_details": modules,
|
| 398 |
+
"signature": SIGNATURE
|
| 399 |
+
}
|
| 400 |
+
finally:
|
| 401 |
+
conn.close()
|
| 402 |
+
|
| 403 |
+
@app.post("/damages/calculate")
|
| 404 |
+
async def calculate_damages(damages: DamagesInput):
|
| 405 |
+
conn = get_db_connection()
|
| 406 |
+
try:
|
| 407 |
+
total = damages.general_damages + damages.aggravated_damages + damages.exemplary_damages
|
| 408 |
+
opa_20_percent = total * 0.20
|
| 409 |
+
net_to_claimant = total - opa_20_percent
|
| 410 |
+
ip_royalty = total * 0.10
|
| 411 |
+
|
| 412 |
+
iteration_row = conn.execute(
|
| 413 |
+
"SELECT COUNT(*) as cnt FROM damages_log WHERE projectid = ?", (damages.projectid,)
|
| 414 |
+
).fetchone()
|
| 415 |
+
iteration = (iteration_row["cnt"] if iteration_row else 0) + 1
|
| 416 |
+
|
| 417 |
+
conn.execute(
|
| 418 |
+
"""INSERT INTO damages_log
|
| 419 |
+
(projectid, general_damages, aggravated_damages, exemplary_damages,
|
| 420 |
+
total_damages, opa_participation, update_iteration)
|
| 421 |
+
VALUES (?, ?, ?, ?, ?, ?, ?)""",
|
| 422 |
+
(damages.projectid, damages.general_damages, damages.aggravated_damages,
|
| 423 |
+
damages.exemplary_damages, total, opa_20_percent, iteration)
|
| 424 |
+
)
|
| 425 |
+
conn.commit()
|
| 426 |
+
|
| 427 |
+
return {
|
| 428 |
+
"status": "Damages Calculated",
|
| 429 |
+
"projectid": damages.projectid,
|
| 430 |
+
"general_damages": damages.general_damages,
|
| 431 |
+
"aggravated_damages": damages.aggravated_damages,
|
| 432 |
+
"exemplary_damages": damages.exemplary_damages,
|
| 433 |
+
"total_damages": total,
|
| 434 |
+
"opa_participation_20percent": opa_20_percent,
|
| 435 |
+
"net_to_claimant": net_to_claimant,
|
| 436 |
+
"ip_royalty_10percent": ip_royalty,
|
| 437 |
+
"signature": SIGNATURE
|
| 438 |
+
}
|
| 439 |
+
finally:
|
| 440 |
+
conn.close()
|
| 441 |
+
|
| 442 |
+
@app.get("/project/{projectid}")
|
| 443 |
+
async def get_project_summary(projectid: int):
|
| 444 |
+
conn = get_db_connection()
|
| 445 |
+
try:
|
| 446 |
+
project = conn.execute("SELECT * FROM projects WHERE id = ?", (projectid,)).fetchone()
|
| 447 |
+
if not project:
|
| 448 |
+
raise HTTPException(status_code=404, detail="Project not found")
|
| 449 |
+
|
| 450 |
+
evidence = conn.execute(
|
| 451 |
+
"SELECT COUNT(*) as count FROM evidencevault WHERE projectid = ?", (projectid,)
|
| 452 |
+
).fetchone()
|
| 453 |
+
|
| 454 |
+
audit_logs = conn.execute(
|
| 455 |
+
"SELECT * FROM auditlog WHERE projectid = ? ORDER BY timestamp DESC LIMIT 10",
|
| 456 |
+
(projectid,)
|
| 457 |
+
).fetchall()
|
| 458 |
+
|
| 459 |
+
triggers = conn.execute(
|
| 460 |
+
"SELECT * FROM regulatory_triggers WHERE projectid = ?", (projectid,)
|
| 461 |
+
).fetchall()
|
| 462 |
+
|
| 463 |
+
damages = conn.execute(
|
| 464 |
+
"SELECT * FROM damages_log WHERE projectid = ? ORDER BY timestamp DESC LIMIT 1",
|
| 465 |
+
(projectid,)
|
| 466 |
+
).fetchone()
|
| 467 |
+
|
| 468 |
+
return {
|
| 469 |
+
"project_id": projectid,
|
| 470 |
+
"project_name": project["name"],
|
| 471 |
+
"owner": project["owner"],
|
| 472 |
+
"status": project["status"],
|
| 473 |
+
"created": project["created_ts"],
|
| 474 |
+
"cascade_mode": project["cascade_mode"],
|
| 475 |
+
"evidence_count": evidence["count"],
|
| 476 |
+
"audit_trail": [dict(log) for log in audit_logs],
|
| 477 |
+
"regulatory_triggers": len(triggers),
|
| 478 |
+
"triggers_detail": [dict(t) for t in triggers],
|
| 479 |
+
"damages_calculated": dict(damages) if damages else None,
|
| 480 |
+
"signature": SIGNATURE
|
| 481 |
+
}
|
| 482 |
+
finally:
|
| 483 |
+
conn.close()
|
| 484 |
+
|
| 485 |
+
@app.get("/docs_framework")
|
| 486 |
+
async def framework_documentation():
|
| 487 |
+
return {
|
| 488 |
+
"frameworks": [
|
| 489 |
+
"1. Ouroboros Temporal Cascade (1,440-loop daily cycle)",
|
| 490 |
+
"2. Coding Demon (IP protection + cryptographic attribution)",
|
| 491 |
+
"3. Mega Honey Badger Matrix (statutory breach mapping)",
|
| 492 |
+
"4. Restless Honey Badger (evidence intake & hashing)",
|
| 493 |
+
"5. Strategy Demon (Hurricane Stress Test)",
|
| 494 |
+
"6. Regulatory Shotgun (multi-agency pressure)",
|
| 495 |
+
"7. Ms.Nala Queen Nala (data ingestion pipeline)",
|
| 496 |
+
"8. Beast Protocol (nuclear remedy deployment)",
|
| 497 |
+
"9. Circular Logic Trap (pierce FOS immunity)",
|
| 498 |
+
"10. Natalia Contradiction (disability discrimination)",
|
| 499 |
+
"11. Piercing Immunity Matrix (4 statutory strategies)",
|
| 500 |
+
"12. VIBES Cycle (6-hour operational rhythm)",
|
| 501 |
+
"13. OPA Model (20% outcome participation)"
|
| 502 |
+
],
|
| 503 |
+
"legal_weapons": [
|
| 504 |
+
"Hurricane Stress Test",
|
| 505 |
+
"Fumbulance Maneuver",
|
| 506 |
+
"Burden Flip Referral",
|
| 507 |
+
"Electromagnet Checklist",
|
| 508 |
+
"Dragonfly Eye Analysis",
|
| 509 |
+
"Mareva + Anton Piller",
|
| 510 |
+
"Hardship Fast-Track",
|
| 511 |
+
"Qualified Privilege Defeat",
|
| 512 |
+
"Circular Logic Trap",
|
| 513 |
+
"Natalia Contradiction",
|
| 514 |
+
"Regulatory Shotgun",
|
| 515 |
+
"Evidence Spoliation Clock"
|
| 516 |
],
|
| 517 |
+
"signature": SIGNATURE
|
| 518 |
+
}
|
| 519 |
+
|
| 520 |
+
if __name__ == "__main__":
|
| 521 |
+
uvicorn.run(app, host=HOST, port=PORT)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|