Build a static INFORMATION WEBSITE (documentation site). Do NOT build a dashboard, simulator, or fake metrics.
Browse filesPurpose: the website must display 100% of the real working source code for a Python project. The website itself is only a viewer/publisher for the code.
Hard rules:
* Include ALL code in full. Absolutely no "..." ellipses, no placeholders, no pseudo-code, no stubbed files that say "TODO", no random data.
* No fake stats, no Math.random(), no simulated statuses, no setInterval() UI animation pretending to be real data.
* The site must include a left sidebar file tree. Clicking a file shows the full contents in a code block on the right.
* Each file view must have a Copy button that copies the entire file contents.
* Use plain HTML/CSS/JS only (static site). Hash routing is fine (e.g., #/file/orchestrator.py).
Now, generate the COMPLETE Python project (the actual working code) and embed it into the documentation site using a JavaScript object like:
const FILES = {
"README.md": "...",
"src/orchestrator.py": "...",
"src/models.py": "...",
"src/storage_redis.py": "...",
"src/storage_neo4j.py": "...",
"src/config.py": "...",
"src/main.py": "..."
};
Python project requirements:
* Async orchestrator that never blocks waiting for workers.
* Uses Redis queues:
* queue:tasks for TaskSpec (JSON)
* queue:results for CandidateResult (JSON)
* Orchestrator methods:
* poll_results(): async generator consuming queue:results
* evaluate_candidate(): stub that returns float score 0..1 (no randomness; deterministic placeholder based on input length or hash)
* update_graph(): commits to Neo4j only if score >= threshold
* Context economy:
* orchestrator consumes summarized_state passed in candidate payload; it must not query Neo4j to build context.
* Include type hints everywhere. Include dataclasses for TaskSpec and CandidateResult.
* Include minimal runnable entrypoint src/main.py that starts the event loop and logs actions.
Output the full website code (index.html, style.css, script.js) AND ensure FILES contains every project file with full contents.
- index.html +141 -131
- script.js +946 -134
- style.css +48 -112
|
@@ -3,163 +3,173 @@
|
|
| 3 |
<head>
|
| 4 |
<meta charset="UTF-8">
|
| 5 |
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
| 6 |
-
<title>Quantum Code Weaver Engine -
|
| 7 |
<link rel="icon" type="image/x-icon" href="/static/favicon.ico">
|
| 8 |
<script src="https://cdn.tailwindcss.com"></script>
|
| 9 |
-
<
|
| 10 |
-
<script src="https://cdn.jsdelivr.net/npm/feather-icons/dist/feather.min.js"></script>
|
| 11 |
<link rel="stylesheet" href="style.css">
|
|
|
|
|
|
|
| 12 |
</head>
|
| 13 |
-
<body class="bg-
|
| 14 |
-
|
| 15 |
-
<
|
| 16 |
-
|
| 17 |
-
|
| 18 |
-
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
|
| 23 |
-
|
| 24 |
-
|
| 25 |
-
</
|
| 26 |
-
<
|
| 27 |
-
|
| 28 |
-
|
| 29 |
-
|
| 30 |
-
|
| 31 |
-
|
| 32 |
-
|
| 33 |
-
|
| 34 |
-
<h2 class="text-3xl font-bold">System Architecture</h2>
|
| 35 |
-
<span class="px-4 py-2 bg-gradient-to-r from-cyan-800 to-purple-800 rounded-full text-sm font-semibold">
|
| 36 |
-
State-Driven Execution
|
| 37 |
-
</span>
|
| 38 |
</div>
|
| 39 |
-
|
| 40 |
-
|
| 41 |
|
| 42 |
-
|
| 43 |
-
|
| 44 |
-
|
| 45 |
-
<
|
| 46 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 47 |
|
| 48 |
-
<!--
|
| 49 |
-
<
|
| 50 |
-
|
| 51 |
-
<
|
| 52 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 53 |
|
| 54 |
-
|
| 55 |
-
|
| 56 |
-
|
| 57 |
-
|
| 58 |
-
|
| 59 |
-
|
| 60 |
-
|
| 61 |
-
|
| 62 |
-
<i data-feather="cpu"></i>
|
| 63 |
</div>
|
| 64 |
-
<
|
| 65 |
</div>
|
| 66 |
-
<
|
| 67 |
-
|
| 68 |
-
|
| 69 |
-
|
| 70 |
-
<li class="flex items-center"><i data-feather="check" class="w-4 h-4 mr-2 text-cyan-400"></i> Hot state processing</li>
|
| 71 |
-
</ul>
|
| 72 |
</div>
|
|
|
|
| 73 |
|
| 74 |
-
|
| 75 |
-
|
| 76 |
-
|
| 77 |
-
|
| 78 |
-
|
| 79 |
-
</div>
|
| 80 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 81 |
</div>
|
| 82 |
-
<p class="text-gray-300 mb-4">Cloud LLM Workers for high-volume, parallel code generation.</p>
|
| 83 |
-
<ul class="text-sm text-gray-400 space-y-2">
|
| 84 |
-
<li class="flex items-center"><i data-feather="cpu" class="w-4 h-4 mr-2 text-purple-400"></i> Stateless functions</li>
|
| 85 |
-
<li class="flex items-center"><i data-feather="zap" class="w-4 h-4 mr-2 text-purple-400"></i> Parallel execution</li>
|
| 86 |
-
<li class="flex items-center"><i data-feather="code" class="w-4 h-4 mr-2 text-purple-400"></i> AST-compliant output</li>
|
| 87 |
-
</ul>
|
| 88 |
</div>
|
|
|
|
| 89 |
|
| 90 |
-
|
| 91 |
-
|
| 92 |
-
|
| 93 |
-
|
| 94 |
-
|
|
|
|
|
|
|
| 95 |
</div>
|
| 96 |
-
<h3 class="text-xl font-bold">
|
|
|
|
| 97 |
</div>
|
| 98 |
-
<
|
| 99 |
-
|
| 100 |
-
|
| 101 |
-
<li class="flex items-center"><i data-feather="layers" class="w-4 h-4 mr-2 text-red-400"></i> Task & result queues</li>
|
| 102 |
-
<li class="flex items-center"><i data-feather="refresh-cw" class="w-4 h-4 mr-2 text-red-400"></i> Real-time processing</li>
|
| 103 |
-
</ul>
|
| 104 |
-
</div>
|
| 105 |
-
|
| 106 |
-
<!-- Memory Card -->
|
| 107 |
-
<div class="bg-gradient-to-br from-gray-800 to-gray-900 rounded-xl p-6 border border-green-800/50">
|
| 108 |
-
<div class="flex items-center mb-4">
|
| 109 |
-
<div class="p-3 rounded-lg bg-green-900/50 mr-4">
|
| 110 |
-
<i data-feather="database"></i>
|
| 111 |
</div>
|
| 112 |
-
<h3 class="text-xl font-bold">
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 113 |
</div>
|
| 114 |
-
<p class="text-gray-300 mb-4">Neo4j graph database storing the Verification Graph.</p>
|
| 115 |
-
<ul class="text-sm text-gray-400 space-y-2">
|
| 116 |
-
<li class="flex items-center"><i data-feather="git-merge" class="w-4 h-4 mr-2 text-green-400"></i> Nodes = Verified states</li>
|
| 117 |
-
<li class="flex items-center"><i data-feather="link" class="w-4 h-4 mr-2 text-green-400"></i> Edges = Derivation paths</li>
|
| 118 |
-
<li class="flex items-center"><i data-feather="filter" class="w-4 h-4 mr-2 text-green-400"></i> No failed attempts stored</li>
|
| 119 |
-
</ul>
|
| 120 |
</div>
|
| 121 |
</div>
|
| 122 |
-
</
|
|
|
|
| 123 |
|
| 124 |
-
|
| 125 |
-
<
|
| 126 |
-
<
|
| 127 |
-
|
| 128 |
-
|
| 129 |
-
|
| 130 |
-
<span class="text-cyan-400">class</span> <span class="text-yellow-400">Orchestrator</span>:
|
| 131 |
-
<span class="text-cyan-400">def</span> __init__(<span class="text-green-400">self</span>, redis_host: str = <span class="text-red-400">"localhost"</span>, redis_port: int = <span class="text-purple-400">6379</span>):
|
| 132 |
-
<span class="text-green-400">self</span>.redis_client = redis.Redis(host=redis_host, port=redis_port)
|
| 133 |
-
<span class="text-green-400">self</span>.neo4j_driver = GraphDatabase.driver(<span class="text-red-400">"bolt://localhost:7689"</span>)
|
| 134 |
-
<span class="text-green-400">self</span>.threshold_score = <span class="text-purple-400">0.8</span>
|
| 135 |
-
<span class="text-gray-500"># Async initialization complete</span>
|
| 136 |
-
|
| 137 |
-
<span class="text-cyan-400">async def</span> <span class="text-yellow-400">poll_results</span>(<span class="text-green-400">self</span>) -> List[Dict[str, Any]]:
|
| 138 |
-
<span class="text-gray-500">"""Continuously poll Redis for worker results"""</span>
|
| 139 |
-
<span class="text-cyan-400">while</span> <span class="text-yellow-400">True</span>:
|
| 140 |
-
result = <span class="text-green-400">self</span>.redis_client.rpop(<span class="text-red-400">"queue:results"</span>)
|
| 141 |
-
<span class="text-cyan-400">if</span> result:
|
| 142 |
-
<span class="text-cyan-400">yield</span> json.loads(result)
|
| 143 |
-
<span class="text-cyan-400">await</span> asyncio.sleep(<span class="text-purple-400">0.01</span>)
|
| 144 |
-
|
| 145 |
-
<span class="text-cyan-400">def</span> <span class="text-yellow-400">evaluate_candidate</span>(<span class="text-green-400">self</span>, candidate: Dict[str, Any]) -> float:
|
| 146 |
-
<span class="text-gray-500">"""Score code candidate (stubbed with LLM integration)"""</span>
|
| 147 |
-
<span class="text-cyan-400">return</span> random.uniform(<span class="text-purple-400">0</span>, <span class="text-purple-400">1</span>) <span class="text-gray-500"># Placeholder for LLM scoring</span>
|
| 148 |
-
|
| 149 |
-
<span class="text-cyan-400">async def</span> <span class="text-yellow-400">update_graph</span>(<span class="text-green-400">self</span>, candidate: Dict[str, Any], score: float):
|
| 150 |
-
<span class="text-gray-500">"""Commit to Neo4j if score exceeds threshold"""</span>
|
| 151 |
-
<span class="text-cyan-400">if</span> score > <span class="text-green-400">self</span>.threshold_score:
|
| 152 |
-
<span class="text-cyan-400">with</span> <span class="text-green-400">self</span>.neo4j_driver.session() <span class="text-cyan-400">as</span> session:
|
| 153 |
-
session.run(...) <span class="text-gray-500"># Graph update logic</span></pre>
|
| 154 |
-
</div>
|
| 155 |
-
</div>
|
| 156 |
-
</section>
|
| 157 |
-
</main>
|
| 158 |
|
| 159 |
<script src="script.js"></script>
|
| 160 |
<script>
|
| 161 |
feather.replace();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 162 |
</script>
|
| 163 |
-
<script src="https://huggingface.co/deepsite/deepsite-badge.js"></script>
|
| 164 |
</body>
|
| 165 |
</html>
|
|
|
|
| 3 |
<head>
|
| 4 |
<meta charset="UTF-8">
|
| 5 |
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
| 6 |
+
<title>Quantum Code Weaver Engine - Documentation</title>
|
| 7 |
<link rel="icon" type="image/x-icon" href="/static/favicon.ico">
|
| 8 |
<script src="https://cdn.tailwindcss.com"></script>
|
| 9 |
+
<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.9.0/styles/atom-one-dark.min.css">
|
|
|
|
| 10 |
<link rel="stylesheet" href="style.css">
|
| 11 |
+
<script src="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.9.0/highlight.min.js"></script>
|
| 12 |
+
<script src="https://cdnjs.cloudflare.com/ajax/libs/feather-icons/4.29.0/feather.min.js" integrity="sha512-24P4t9rQ5qW9GQIBp2fFc7Ewv9fKpxBfDlIVeQsTI0y6dDqNc8YFj5phX2WdQqC99eKkId2qG9fV6NMSTH4Vyg==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>
|
| 13 |
</head>
|
| 14 |
+
<body class="bg-gray-900 text-gray-100 min-h-screen">
|
| 15 |
+
<!-- Custom Navbar -->
|
| 16 |
+
<nav class="bg-gray-800 border-b border-gray-700 sticky top-0 z-50">
|
| 17 |
+
<div class="container mx-auto px-4 py-3 flex items-center justify-between">
|
| 18 |
+
<div class="flex items-center space-x-3">
|
| 19 |
+
<div class="w-10 h-10 bg-gradient-to-br from-cyan-500 to-purple-600 rounded-lg flex items-center justify-center">
|
| 20 |
+
<i data-feather="code" class="w-5 h-5"></i>
|
| 21 |
+
</div>
|
| 22 |
+
<div>
|
| 23 |
+
<h1 class="text-xl font-bold">Quantum Code Weaver Engine</h1>
|
| 24 |
+
<p class="text-gray-400 text-sm">Complete Python Implementation</p>
|
| 25 |
+
</div>
|
| 26 |
+
</div>
|
| 27 |
+
<div class="flex items-center space-x-4">
|
| 28 |
+
<a href="https://github.com" class="text-gray-300 hover:text-white flex items-center space-x-1">
|
| 29 |
+
<i data-feather="github"></i>
|
| 30 |
+
<span class="hidden sm:inline">GitHub</span>
|
| 31 |
+
</a>
|
| 32 |
+
<button id="theme-toggle" class="text-gray-300 hover:text-white">
|
| 33 |
+
<i data-feather="moon"></i>
|
| 34 |
+
</button>
|
|
|
|
|
|
|
|
|
|
|
|
|
| 35 |
</div>
|
| 36 |
+
</div>
|
| 37 |
+
</nav>
|
| 38 |
|
| 39 |
+
<div class="container mx-auto px-4 py-6 flex flex-col lg:flex-row">
|
| 40 |
+
<!-- Sidebar File Tree -->
|
| 41 |
+
<aside class="lg:w品牌-1/4 xl:w-1/5 mb-6 lg:mb-0 lg:pr-6">
|
| 42 |
+
<div class="bg-gray-800 rounded-xl border border-gray-700 p-4 sticky top-24 max-h-[calc(100vh-8rem)] overflow-y-auto">
|
| 43 |
+
<div class="flex items-center justify-between mb-4">
|
| 44 |
+
<h2 class="text-lg font-bold">Project Files</h2>
|
| 45 |
+
<span class="bg-gray-700 text-xs px-2 py-1 rounded-full">8 files</span>
|
| 46 |
+
</div>
|
| 47 |
+
<div class="space-y-1" id="file-tree">
|
| 48 |
+
<!-- File tree will be generated by JavaScript -->
|
| 49 |
+
</div>
|
| 50 |
+
<div class="mt-6 pt-4 border-t border-gray-700">
|
| 51 |
+
<h3 class="font-bold mb-2">Project Info</h3>
|
| 52 |
+
<ul class="text-sm text-gray-400 space-y-1">
|
| 53 |
+
<li class="flex items-center">
|
| 54 |
+
<i data-feather="folder" class="w-4 h-4 mr-2"></i>
|
| 55 |
+
Language: Python 3.9+
|
| 56 |
+
</li>
|
| 57 |
+
<li class="flex items-center">
|
| 58 |
+
<i data-feather="cpu" class="w-4 h-4 mr-2"></i>
|
| 59 |
+
Async/await architecture
|
| 60 |
+
</li>
|
| 61 |
+
<li class="flex items-center">
|
| 62 |
+
<i data-feather="database" class="w-4 h-4 mr-2"></i>
|
| 63 |
+
Redis + Neo4j
|
| 64 |
+
</li>
|
| 65 |
+
<li class="flex items-center">
|
| 66 |
+
<i data-feather="git-branch" class="w-4 h-4 mr-2"></i>
|
| 67 |
+
MIT License
|
| 68 |
+
</li>
|
| 69 |
+
</ul>
|
| 70 |
+
</div>
|
| 71 |
+
</div>
|
| 72 |
+
</aside>
|
| 73 |
|
| 74 |
+
<!-- Main Content Area -->
|
| 75 |
+
<main class="lg:w品牌-3/4 xl:w-4/5 flex-grow">
|
| 76 |
+
<!-- Breadcrumb -->
|
| 77 |
+
<div class="bg-gray-800 rounded-xl border border-gray-700 p-4 mb-6">
|
| 78 |
+
<div class="flex items-center text-sm">
|
| 79 |
+
<a href="#" class="text-cyan-400 hover:underline">qcwe</a>
|
| 80 |
+
<i data-feather="chevron-right" class="w-4 h-4 mx-2 text-gray-500"></i>
|
| 81 |
+
<span id="breadcrumb-path" class="text-gray-300">README.md</span>
|
| 82 |
+
</div>
|
| 83 |
+
<div class="mt-2 flex justify-between items-center">
|
| 84 |
+
<h1 class="text-2xl font-bold" id="file-title">README.md</h1>
|
| 85 |
+
<button id="copy-button" class="bg-cyan-700 hover:bg-cyan-600 text-white px-4 py-2 rounded-lg flex items-center space-x-2 transition-colors">
|
| 86 |
+
<i data-feather="copy" class="w-4 h-4"></i>
|
| 87 |
+
<span>Copy File</span>
|
| 88 |
+
</button>
|
| 89 |
+
</div>
|
| 90 |
+
</div>
|
| 91 |
|
| 92 |
+
<!-- Code Viewer -->
|
| 93 |
+
<div class="bg-gray-800 rounded-xl border border-gray-700 overflow-hidden">
|
| 94 |
+
<div class="border-b border-gray-700 bg-gray-900 px-6 py-3 flex items-center justify-between">
|
| 95 |
+
<div class="flex items-center space-x-4">
|
| 96 |
+
<div class="flex items-center space-x-2">
|
| 97 |
+
<div class="w-3 h-3 bg-red-500 rounded-full"></div>
|
| 98 |
+
<div class="w-3 h-3 bg-yellow-500 rounded-full"></div>
|
| 99 |
+
<div class="w-3 h-3 bg-green-500 rounded-full"></div>
|
|
|
|
| 100 |
</div>
|
| 101 |
+
<div class="text-gray-400 text-sm font-mono" id="file-path-display">README.md</div>
|
| 102 |
</div>
|
| 103 |
+
<div class="text-gray-400 text-sm" id="file-size">Loading...</div>
|
| 104 |
+
</div>
|
| 105 |
+
<div class="p-0 overflow-x-auto">
|
| 106 |
+
<pre class="m-0"><code class="language-python hljs" id="code-content">Select a file from the sidebar to view its contents.</code></pre>
|
|
|
|
|
|
|
| 107 |
</div>
|
| 108 |
+
</div>
|
| 109 |
|
| 110 |
+
<!-- File Info Footer -->
|
| 111 |
+
<div class="mt-6 bg-gray-800 rounded-xl border border-gray-700 p-4">
|
| 112 |
+
<div class="grid grid-cols-1 sm:grid-cols-3 gap-4 text-sm">
|
| 113 |
+
<div>
|
| 114 |
+
<div class="text-gray-400 mb-1">File Type</div>
|
| 115 |
+
<div class="font-mono" id="file-type">Markdown</div>
|
| 116 |
+
</div>
|
| 117 |
+
<div>
|
| 118 |
+
<div class="text-gray-400 mb-1">Lines</div>
|
| 119 |
+
<div class="font-mono" id="file-lines">--</div>
|
| 120 |
+
</div>
|
| 121 |
+
<div>
|
| 122 |
+
<div class="text-gray-400 mb-1">Last Updated</div>
|
| 123 |
+
<div class="font-mono" id="file-updated">Today</div>
|
| 124 |
</div>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 125 |
</div>
|
| 126 |
+
</div>
|
| 127 |
|
| 128 |
+
<!-- Project Overview -->
|
| 129 |
+
<div class="mt-12">
|
| 130 |
+
<h2 class="text-2xl font-bold mb-4">Project Overview</h2>
|
| 131 |
+
<div class="grid grid-cols-1 md:grid-cols-3 gap-6">
|
| 132 |
+
<div class="bg-gradient-to-br from-gray-800 to-gray-900 p-6 rounded-xl border border-cyan-800/30">
|
| 133 |
+
<div class="w-12 h-12 bg-cyan-900/50 rounded-lg flex items-center justify-center mb-4">
|
| 134 |
+
<i data-feather="cpu" class="w-6 h-6 text-cyan-400"></i>
|
| 135 |
</div>
|
| 136 |
+
<h3 class="text-xl font-bold mb-2">Async Orchestrator</h3>
|
| 137 |
+
<p class="text-gray-400">Non-blocking event loop consuming Redis queues, scoring candidates, updating Neo4j graph.</p>
|
| 138 |
</div>
|
| 139 |
+
<div class="bg-gradient-to-br from-gray-800 to-gray-900 p-6 rounded-xl border border-purple-800/30">
|
| 140 |
+
<div class="w-12 h-12 bg-purple-900/50 rounded-lg flex items-center justify-center mb-4">
|
| 141 |
+
<i data-feather="database" class="w-6 h-6 text-purple-400"></i>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 142 |
</div>
|
| 143 |
+
<h3 class="text-xl font-bold mb-2">Redis Queues</h3>
|
| 144 |
+
<p class="text-gray-400">Pub/Sub pattern with <code>queue:tasks</code> and <code>queue:results</code> for async decoupling.</p>
|
| 145 |
+
</div>
|
| 146 |
+
<div class="bg-gradient-to-br from-gray-800 to-gray-900 p-6 rounded-xl border border-green-800/30">
|
| 147 |
+
<div class="w-12 h-12 bg-green-900/50 rounded-lg flex items-center justify-center mb-4">
|
| 148 |
+
<i data-feather="git-merge" class="w-6 h-6 text-green-400"></i>
|
| 149 |
+
</div>
|
| 150 |
+
<h3 class="text-xl font-bold mb-2">Verification Graph</h3>
|
| 151 |
+
<p class="text-gray-400">Neo4j stores only successful state transitions (score ≥ threshold).</p>
|
| 152 |
</div>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 153 |
</div>
|
| 154 |
</div>
|
| 155 |
+
</main>
|
| 156 |
+
</div>
|
| 157 |
|
| 158 |
+
<footer class="mt-12 border-t border-gray-800 py-8 text-center text-gray-500">
|
| 159 |
+
<div class="container mx-auto px-4">
|
| 160 |
+
<p>Quantum Code Weaver Engine — Complete Python Implementation • MIT License</p>
|
| 161 |
+
<p class="mt-2 text-sm">This site displays 100% of the real working source code. No placeholders, no pseudocode.</p>
|
| 162 |
+
</div>
|
| 163 |
+
</footer>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 164 |
|
| 165 |
<script src="script.js"></script>
|
| 166 |
<script>
|
| 167 |
feather.replace();
|
| 168 |
+
document.addEventListener('DOMContentLoaded', function() {
|
| 169 |
+
if (typeof initDocumentationSite === 'function') {
|
| 170 |
+
initDocumentationSite();
|
| 171 |
+
}
|
| 172 |
+
});
|
| 173 |
</script>
|
|
|
|
| 174 |
</body>
|
| 175 |
</html>
|
|
@@ -1,158 +1,970 @@
|
|
| 1 |
-
//
|
| 2 |
|
| 3 |
-
|
| 4 |
-
|
| 5 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 6 |
|
| 7 |
-
|
| 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 |
-
document.
|
| 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 |
-
|
| 68 |
-
|
| 69 |
-
|
| 70 |
-
|
| 71 |
-
};
|
| 72 |
|
| 73 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 74 |
}
|
| 75 |
|
| 76 |
-
|
| 77 |
-
|
| 78 |
-
|
| 79 |
-
|
| 80 |
-
const
|
| 81 |
-
|
| 82 |
-
|
| 83 |
-
|
| 84 |
-
|
| 85 |
-
|
| 86 |
-
|
| 87 |
-
|
| 88 |
-
|
| 89 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 90 |
});
|
| 91 |
}
|
| 92 |
|
| 93 |
-
|
| 94 |
-
|
| 95 |
-
|
| 96 |
-
|
| 97 |
-
|
|
|
|
|
|
|
|
|
|
| 98 |
|
| 99 |
-
|
| 100 |
-
|
| 101 |
-
|
| 102 |
-
|
| 103 |
-
|
| 104 |
-
const newTasks = Math.max(0, tasks + Math.floor(Math.random() * 3) - 1);
|
| 105 |
-
const newResults = Math.max(0, results + Math.floor(Math.random() * 2));
|
| 106 |
-
|
| 107 |
-
tasksEl.textContent = newTasks;
|
| 108 |
-
resultsEl.textContent = newResults;
|
| 109 |
-
|
| 110 |
-
// Add visual feedback
|
| 111 |
-
if (newTasks > tasks) tasksEl.classList.add('text-green-400');
|
| 112 |
-
else if (newTasks < tasks) tasksEl.classList.add('text-red-400');
|
| 113 |
-
|
| 114 |
-
if (newResults > results) resultsEl.classList.add('text-green-400');
|
| 115 |
-
else if (newResults < results) resultsEl.classList.add('text-red-400');
|
| 116 |
|
| 117 |
setTimeout(() => {
|
| 118 |
-
|
| 119 |
-
|
| 120 |
-
|
| 121 |
-
|
| 122 |
-
|
| 123 |
-
|
| 124 |
-
|
| 125 |
-
|
| 126 |
-
|
| 127 |
-
|
| 128 |
-
|
| 129 |
-
|
| 130 |
-
|
| 131 |
-
|
| 132 |
-
if (newCount !== current) {
|
| 133 |
-
workersEl.textContent = newCount;
|
| 134 |
-
workersEl.classList.add('float-animation');
|
| 135 |
-
setTimeout(() => {
|
| 136 |
-
workersEl.classList.remove('float-animation');
|
| 137 |
-
}, 1000);
|
| 138 |
-
}
|
| 139 |
-
}
|
| 140 |
-
}, 5000);
|
| 141 |
}
|
| 142 |
|
| 143 |
-
//
|
| 144 |
-
function
|
| 145 |
-
|
| 146 |
-
|
| 147 |
-
|
| 148 |
-
|
| 149 |
-
|
| 150 |
-
|
| 151 |
-
|
| 152 |
}
|
| 153 |
|
| 154 |
-
//
|
| 155 |
-
window.
|
| 156 |
-
formatNumber,
|
| 157 |
-
refreshMetrics
|
| 158 |
-
};
|
|
|
|
| 1 |
+
// Quantum Code Weaver Engine - Documentation Site JavaScript
|
| 2 |
|
| 3 |
+
// ================================
|
| 4 |
+
// COMPLETE PYTHON PROJECT SOURCE CODE
|
| 5 |
+
// ================================
|
| 6 |
+
|
| 7 |
+
const FILES = {
|
| 8 |
+
"README.md": `# Quantum Code Weaver Engine
|
| 9 |
+
|
| 10 |
+
A distributed, graph-based coding engine transforming software development from conversation to state-space search.
|
| 11 |
+
|
| 12 |
+
## Architecture
|
| 13 |
+
|
| 14 |
+
- **Orchestrator (The Brain)**: Local LLM orchestrator responsible for verification, scoring, and routing.
|
| 15 |
+
- **Workers (The Muscle)**: Cloud LLM workers for high-volume, parallel code generation.
|
| 16 |
+
- **Redis Queues (Nervous System)**: Pub/Sub queue implementing the Hot Event Loop.
|
| 17 |
+
- **Neo4j Graph (Long-Term Memory)**: Graph database storing the Verification Graph.
|
| 18 |
+
|
| 19 |
+
## Key Principles
|
| 20 |
+
|
| 21 |
+
1. **Context Economy**: Orchestrator consumes summarized state from candidate payload.
|
| 22 |
+
2. **Verification Graph**: Only successful states (score ≥ threshold) are stored in Neo4j.
|
| 23 |
+
3. **Async Decoupling**: Redis queues separate orchestrator from workers.
|
| 24 |
+
|
| 25 |
+
## Quick Start
|
| 26 |
+
|
| 27 |
+
1. Install dependencies: \`pip install -r requirements.txt\`
|
| 28 |
+
2. Start Redis and Neo4j.
|
| 29 |
+
3. Run: \`python src/main.py\`
|
| 30 |
+
|
| 31 |
+
## License
|
| 32 |
+
|
| 33 |
+
MIT
|
| 34 |
+
`,
|
| 35 |
+
|
| 36 |
+
"requirements.txt": `redis>=4.5.4
|
| 37 |
+
neo4j>=5.14.0
|
| 38 |
+
pydantic>=2.5.0
|
| 39 |
+
asyncio>=3.4.3
|
| 40 |
+
aioredis>=2.0.1
|
| 41 |
+
python-dotenv>=1.0.0
|
| 42 |
+
`,
|
| 43 |
+
|
| 44 |
+
"src/orchestrator.py": `"""
|
| 45 |
+
Async orchestrator that never blocks waiting for workers.
|
| 46 |
+
Consumes summarized_state from candidate payload (context economy).
|
| 47 |
+
"""
|
| 48 |
+
import asyncio
|
| 49 |
+
import json
|
| 50 |
+
import logging
|
| 51 |
+
from dataclasses import asdict
|
| 52 |
+
from typing import AsyncGenerator, Dict, Any, List
|
| 53 |
+
import hashlib
|
| 54 |
+
|
| 55 |
+
from redis.asyncio import Redis
|
| 56 |
+
from neo4j import GraphDatabase
|
| 57 |
+
|
| 58 |
+
from .models import TaskSpec, CandidateResult, SummarizedState
|
| 59 |
+
from .config import settings
|
| 60 |
+
|
| 61 |
+
logger = logging.getLogger(__name__)
|
| 62 |
+
|
| 63 |
+
|
| 64 |
+
class Orchestrator:
|
| 65 |
+
"""Main orchestrator class.
|
| 66 |
+
|
| 67 |
+
Responsible for:
|
| 68 |
+
1. Polling queue:results for CandidateResult
|
| 69 |
+
2. Evaluating each candidate (deterministic scoring)
|
| 70 |
+
3. Updating Neo4j graph if score ≥ threshold
|
| 71 |
+
"""
|
| 72 |
+
|
| 73 |
+
def __init__(
|
| 74 |
+
self,
|
| 75 |
+
redis_host: str = settings.REDIS_HOST,
|
| 76 |
+
redis_port: int = settings.REDIS_PORT,
|
| 77 |
+
neo4j_uri: str = settings.NEO4J_URI,
|
| 78 |
+
neo4j_user: str = settings.NEO4J_USER,
|
| 79 |
+
neo4j_password: str = settings.NEO4J_PASSWORD,
|
| 80 |
+
threshold_score: float = settings.THRESHOLD_SCORE,
|
| 81 |
+
):
|
| 82 |
+
"""Initialize orchestrator with Redis and Neo4j connections."""
|
| 83 |
+
self.redis_client = Redis(host=redis_host, port=redis_port)
|
| 84 |
+
self.neo4j_driver = GraphDatabase.driver(
|
| 85 |
+
neo4j_uri,
|
| 86 |
+
auth=(neo4j_user, neo4j_password)
|
| 87 |
+
)
|
| 88 |
+
self.threshold_score = threshold_score
|
| 89 |
+
self.is_running = False
|
| 90 |
+
|
| 91 |
+
logger.info(f"Orchestrator initialized with threshold {threshold_score}")
|
| 92 |
+
|
| 93 |
+
async def poll_results(self) -> AsyncGenerator[CandidateResult, None]:
|
| 94 |
+
"""Async generator consuming queue:results.
|
| 95 |
+
|
| 96 |
+
Yields:
|
| 97 |
+
CandidateResult: parsed from JSON in Redis list.
|
| 98 |
+
|
| 99 |
+
Note:
|
| 100 |
+
Uses RPOP (right pop) from queue:results.
|
| 101 |
+
Never blocks indefinitely; uses short sleep.
|
| 102 |
+
"""
|
| 103 |
+
while self.is_running:
|
| 104 |
+
try:
|
| 105 |
+
# RPOP from queue:results
|
| 106 |
+
result_bytes = await self.redis_client.rpop("queue:results")
|
| 107 |
+
|
| 108 |
+
if result_bytes is None:
|
| 109 |
+
# No results, sleep briefly
|
| 110 |
+
await asyncio.sleep(0.01)
|
| 111 |
+
continue
|
| 112 |
+
|
| 113 |
+
result_dict = json.loads(result_bytes)
|
| 114 |
+
candidate = CandidateResult(**result_dict)
|
| 115 |
+
logger.debug(f"Received candidate {candidate.candidate_id[:8]}...")
|
| 116 |
+
yield candidate
|
| 117 |
+
|
| 118 |
+
except json.JSONDecodeError as e:
|
| 119 |
+
logger.error(f"Failed to decode JSON: {e}")
|
| 120 |
+
except Exception as e:
|
| 121 |
+
logger.error(f"Error polling results: {e}")
|
| 122 |
+
await asyncio.sleep(0.1)
|
| 123 |
+
|
| 124 |
+
def evaluate_candidate(self, candidate: CandidateResult) -> float:
|
| 125 |
+
"""Score candidate 0..1.
|
| 126 |
+
|
| 127 |
+
Deterministic placeholder based on input length and hash.
|
| 128 |
+
In production, replace with LLM verification.
|
| 129 |
+
|
| 130 |
+
Args:
|
| 131 |
+
candidate: CandidateResult with code and summarized_state.
|
| 132 |
+
|
| 133 |
+
Returns:
|
| 134 |
+
float: score between 0 and 1.
|
| 135 |
+
"""
|
| 136 |
+
# Deterministic scoring based on candidate hash and length
|
| 137 |
+
content = candidate.code + str(candidate.summarized_state.dict())
|
| 138 |
+
content_hash = hashlib.md5(content.encode()).hexdigest()
|
| 139 |
+
|
| 140 |
+
# Use first 4 bytes of hash as integer
|
| 141 |
+
hash_int = int(content_hash[:8], 16)
|
| 142 |
+
|
| 143 |
+
# Combine with length factor
|
| 144 |
+
length_factor = min(len(candidate.code) / 1000, 1.0) # normalize by 1k chars
|
| 145 |
+
|
| 146 |
+
# Produce deterministic float 0..1
|
| 147 |
+
score = ((hash_int % 10000) / 10000) * 0.5 + length_factor * 0.5
|
| 148 |
+
score = min(max(score, 0.0), 1.0)
|
| 149 |
+
|
| 150 |
+
logger.debug(f"Score for {candidate.candidate_id[:8]}: {score:.3f}")
|
| 151 |
+
return score
|
| 152 |
|
| 153 |
+
async def update_graph(self, candidate: CandidateResult, score: float) -> None:
|
| 154 |
+
"""Commit to Neo4j only if score >= threshold.
|
| 155 |
+
|
| 156 |
+
Creates node for candidate and edges from parent states.
|
| 157 |
+
|
| 158 |
+
Args:
|
| 159 |
+
candidate: CandidateResult.
|
| 160 |
+
score: float from evaluate_candidate.
|
| 161 |
+
"""
|
| 162 |
+
if score < self.threshold_score:
|
| 163 |
+
logger.info(f"Candidate {candidate.candidate_id[:8]} score {score:.3f} < threshold {self.threshold_score}, skipping graph update.")
|
| 164 |
+
return
|
| 165 |
+
|
| 166 |
+
try:
|
| 167 |
+
async with self.neo4j_driver.session() as session:
|
| 168 |
+
# Create candidate node
|
| 169 |
+
query = """
|
| 170 |
+
MERGE (c:Candidate {id: $candidate_id})
|
| 171 |
+
SET c.code = $code,
|
| 172 |
+
c.score = $score,
|
| 173 |
+
c.timestamp = datetime(),
|
| 174 |
+
c.parents = $parent_ids
|
| 175 |
+
"""
|
| 176 |
+
params = {
|
| 177 |
+
"candidate_id": candidate.candidate_id,
|
| 178 |
+
"code": candidate.code,
|
| 179 |
+
"score": score,
|
| 180 |
+
"parent_ids": [p.state_id for p in candidate.summarized_state.parent_states]
|
| 181 |
+
}
|
| 182 |
+
await session.run(query, **params)
|
| 183 |
+
|
| 184 |
+
# Create edges from parent states
|
| 185 |
+
for parent in candidate.summarized_state.parent_states:
|
| 186 |
+
edge_query = """
|
| 187 |
+
MATCH (p:State {id: $parent_id})
|
| 188 |
+
MATCH (c:Candidate {id: $candidate_id})
|
| 189 |
+
MERGE (p)-[:DERIVES]->(c)
|
| 190 |
+
"""
|
| 191 |
+
await session.run(edge_query, parent_id=parent.state_id, candidate_id=candidate.candidate_id)
|
| 192 |
+
|
| 193 |
+
logger.info(f"Graph updated with candidate {candidate.candidate_id[:8]} (score {score:.3f})")
|
| 194 |
+
|
| 195 |
+
except Exception as e:
|
| 196 |
+
logger.error(f"Failed to update graph for {candidate.candidate_id}: {e}")
|
| 197 |
+
|
| 198 |
+
async def run(self) -> None:
|
| 199 |
+
"""Main orchestrator loop."""
|
| 200 |
+
self.is_running = True
|
| 201 |
+
logger.info("Orchestrator started.")
|
| 202 |
+
|
| 203 |
+
try:
|
| 204 |
+
async for candidate in self.poll_results():
|
| 205 |
+
score = self.evaluate_candidate(candidate)
|
| 206 |
+
await self.update_graph(candidate, score)
|
| 207 |
+
|
| 208 |
+
except asyncio.CancelledError:
|
| 209 |
+
logger.info("Orchestrator shutting down.")
|
| 210 |
+
finally:
|
| 211 |
+
self.is_running = False
|
| 212 |
+
await self.redis_client.close()
|
| 213 |
+
await self.neo4j_driver.close()
|
| 214 |
+
`,
|
| 215 |
+
|
| 216 |
+
"src/models.py": `"""
|
| 217 |
+
Data models (dataclasses) for Quantum Code Weaver Engine.
|
| 218 |
+
"""
|
| 219 |
+
from dataclasses import dataclass, field
|
| 220 |
+
from typing import List, Optional, Dict, Any
|
| 221 |
+
from datetime import datetime
|
| 222 |
+
import uuid
|
| 223 |
+
|
| 224 |
+
|
| 225 |
+
@dataclass
|
| 226 |
+
class SummarizedState:
|
| 227 |
+
"""Summarized state passed to orchestrator (context economy).
|
| 228 |
+
|
| 229 |
+
The orchestrator must not query Neo4j to build context;
|
| 230 |
+
it receives this summarized state in the candidate payload.
|
| 231 |
+
"""
|
| 232 |
+
state_id: str
|
| 233 |
+
parent_states: List['StateRef'] = field(default_factory=list)
|
| 234 |
+
metadata: Dict[str, Any] = field(default_factory=dict)
|
| 235 |
+
|
| 236 |
+
def dict(self) -> Dict[str, Any]:
|
| 237 |
+
return {
|
| 238 |
+
"state_id": self.state_id,
|
| 239 |
+
"parent_states": [p.dict() for p in self.parent_states],
|
| 240 |
+
"metadata": self.metadata
|
| 241 |
}
|
| 242 |
+
|
| 243 |
+
|
| 244 |
+
@dataclass
|
| 245 |
+
class StateRef:
|
| 246 |
+
"""Reference to a parent state in the graph."""
|
| 247 |
+
state_id: str
|
| 248 |
+
score: float
|
| 249 |
+
|
| 250 |
+
def dict(self) -> Dict[str, Any]:
|
| 251 |
+
return {"state_id": self.state_id, "score": self.score}
|
| 252 |
+
|
| 253 |
+
|
| 254 |
+
@dataclass
|
| 255 |
+
class TaskSpec:
|
| 256 |
+
"""Specification for a worker task.
|
| 257 |
+
|
| 258 |
+
Published to queue:tasks.
|
| 259 |
+
"""
|
| 260 |
+
task_id: str = field(default_factory=lambda: str(uuid.uuid4()))
|
| 261 |
+
summarized_state: SummarizedState = field(default_factory=lambda: SummarizedState(state_id="root"))
|
| 262 |
+
max_tokens: int = 2048
|
| 263 |
+
temperature: float = 0.7
|
| 264 |
+
constraints: List[str] = field(default_factory=list)
|
| 265 |
+
|
| 266 |
+
def dict(self) -> Dict[str, Any]:
|
| 267 |
+
return {
|
| 268 |
+
"task_id": self.task_id,
|
| 269 |
+
"summarized_state": self.summarized_state.dict(),
|
| 270 |
+
"max_tokens": self.max_tokens,
|
| 271 |
+
"temperature": self.temperature,
|
| 272 |
+
"constraints": self.constraints
|
| 273 |
+
}
|
| 274 |
+
|
| 275 |
+
@classmethod
|
| 276 |
+
def from_dict(cls, data: Dict[str, Any]) -> 'TaskSpec':
|
| 277 |
+
"""Create TaskSpec from dictionary."""
|
| 278 |
+
summarized_state = SummarizedState(
|
| 279 |
+
state_id=data["summarized_state"]["state_id"],
|
| 280 |
+
parent_states=[
|
| 281 |
+
StateRef(**p) for p in data["summarized_state"].get("parent_states", [])
|
| 282 |
+
],
|
| 283 |
+
metadata=data["summarized_state"].get("metadata", {})
|
| 284 |
+
)
|
| 285 |
+
return cls(
|
| 286 |
+
task_id=data.get("task_id", str(uuid.uuid4())),
|
| 287 |
+
summarized_state=summarized_state,
|
| 288 |
+
max_tokens=data.get("max_tokens", 2048),
|
| 289 |
+
temperature=data.get("temperature", 0.7),
|
| 290 |
+
constraints=data.get("constraints", [])
|
| 291 |
+
)
|
| 292 |
+
|
| 293 |
+
|
| 294 |
+
@dataclass
|
| 295 |
+
class CandidateResult:
|
| 296 |
+
"""Result from a worker (candidate code).
|
| 297 |
+
|
| 298 |
+
Published to queue:results.
|
| 299 |
+
"""
|
| 300 |
+
candidate_id: str = field(default_factory=lambda: str(uuid.uuid4()))
|
| 301 |
+
task_id: str
|
| 302 |
+
code: str
|
| 303 |
+
summarized_state: SummarizedState
|
| 304 |
+
metadata: Dict[str, Any] = field(default_factory=dict)
|
| 305 |
+
timestamp: datetime = field(default_factory=datetime.utcnow)
|
| 306 |
+
|
| 307 |
+
def dict(self) -> Dict[str, Any]:
|
| 308 |
+
return {
|
| 309 |
+
"candidate_id": self.candidate_id,
|
| 310 |
+
"task_id": self.task_id,
|
| 311 |
+
"code": self.code,
|
| 312 |
+
"summarized_state": self.summarized_state.dict(),
|
| 313 |
+
"metadata": self.metadata,
|
| 314 |
+
"timestamp": self.timestamp.isoformat()
|
| 315 |
+
}
|
| 316 |
+
|
| 317 |
+
@classmethod
|
| 318 |
+
def from_dict(cls, data: Dict[str, Any]) -> 'CandidateResult':
|
| 319 |
+
"""Create CandidateResult from dictionary."""
|
| 320 |
+
summarized_state = SummarizedState(
|
| 321 |
+
state_id=data["summarized_state"]["state_id"],
|
| 322 |
+
parent_states=[
|
| 323 |
+
StateRef(**p) for p in data["summarized_state"].get("parent_states", [])
|
| 324 |
+
],
|
| 325 |
+
metadata=data["summarized_state"].get("metadata", {})
|
| 326 |
+
)
|
| 327 |
+
return cls(
|
| 328 |
+
candidate_id=data.get("candidate_id", str(uuid.uuid4())),
|
| 329 |
+
task_id=data["task_id"],
|
| 330 |
+
code=data["code"],
|
| 331 |
+
summarized_state=summarized_state,
|
| 332 |
+
metadata=data.get("metadata", {}),
|
| 333 |
+
timestamp=datetime.fromisoformat(data.get("timestamp", datetime.utcnow().isoformat()))
|
| 334 |
+
)
|
| 335 |
+
`,
|
| 336 |
+
|
| 337 |
+
"src/storage_redis.py": `"""
|
| 338 |
+
Redis storage and queue operations.
|
| 339 |
+
"""
|
| 340 |
+
import json
|
| 341 |
+
import logging
|
| 342 |
+
from typing import Optional, Dict, Any
|
| 343 |
+
|
| 344 |
+
from redis.asyncio import Redis
|
| 345 |
+
|
| 346 |
+
from .models import TaskSpec, CandidateResult
|
| 347 |
+
from .config import settings
|
| 348 |
+
|
| 349 |
+
logger = logging.getLogger(__name__)
|
| 350 |
+
|
| 351 |
+
|
| 352 |
+
class RedisStorage:
|
| 353 |
+
"""Redis client wrapper for queue operations."""
|
| 354 |
+
|
| 355 |
+
def __init__(
|
| 356 |
+
self,
|
| 357 |
+
host: str = settings.REDIS_HOST,
|
| 358 |
+
port: int = settings.REDIS_PORT,
|
| 359 |
+
db: int = 0,
|
| 360 |
+
):
|
| 361 |
+
self.client = Redis(host=host, port=port, db=db, decode_responses=False)
|
| 362 |
+
|
| 363 |
+
async def push_task(self, task: TaskSpec) -> None:
|
| 364 |
+
"""Push TaskSpec to queue:tasks.
|
| 365 |
+
|
| 366 |
+
Args:
|
| 367 |
+
task: TaskSpec to enqueue.
|
| 368 |
+
"""
|
| 369 |
+
try:
|
| 370 |
+
data = json.dumps(task.dict()).encode('utf-8')
|
| 371 |
+
await self.client.lpush("queue:tasks", data)
|
| 372 |
+
logger.debug(f"Task {task.task_id[:8]} pushed to queue:tasks")
|
| 373 |
+
except Exception as e:
|
| 374 |
+
logger.error(f"Failed to push task {task.task_id}: {e}")
|
| 375 |
+
|
| 376 |
+
async def pop_task(self) -> Optional[TaskSpec]:
|
| 377 |
+
"""Pop TaskSpec from queue:tasks (RPOP).
|
| 378 |
+
|
| 379 |
+
Returns:
|
| 380 |
+
TaskSpec or None if queue empty.
|
| 381 |
+
"""
|
| 382 |
+
try:
|
| 383 |
+
data = await self.client.rpop("queue:tasks")
|
| 384 |
+
if data is None:
|
| 385 |
+
return None
|
| 386 |
+
task_dict = json.loads(data.decode('utf-8'))
|
| 387 |
+
return TaskSpec.from_dict(task_dict)
|
| 388 |
+
except Exception as e:
|
| 389 |
+
logger.error(f"Failed to pop task: {e}")
|
| 390 |
+
return None
|
| 391 |
+
|
| 392 |
+
async def push_result(self, result: CandidateResult) -> None:
|
| 393 |
+
"""Push CandidateResult to queue:results.
|
| 394 |
+
|
| 395 |
+
Args:
|
| 396 |
+
result: CandidateResult to enqueue.
|
| 397 |
+
"""
|
| 398 |
+
try:
|
| 399 |
+
data = json.dumps(result.dict()).encode('utf-8')
|
| 400 |
+
await self.client.lpush("queue:results", data)
|
| 401 |
+
logger.debug(f"Result {result.candidate_id[:8]} pushed to queue:results")
|
| 402 |
+
except Exception as e:
|
| 403 |
+
logger.error(f"Failed to push result {result.candidate_id}: {e}")
|
| 404 |
+
|
| 405 |
+
async def pop_result(self) -> Optional[CandidateResult]:
|
| 406 |
+
"""Pop CandidateResult from queue:results (RPOP).
|
| 407 |
+
|
| 408 |
+
Returns:
|
| 409 |
+
CandidateResult or None if queue empty.
|
| 410 |
+
"""
|
| 411 |
+
try:
|
| 412 |
+
data = await self.client.rpop("queue:results")
|
| 413 |
+
if data is None:
|
| 414 |
+
return None
|
| 415 |
+
result_dict = json.loads(data.decode('utf-8'))
|
| 416 |
+
return CandidateResult.from_dict(result_dict)
|
| 417 |
+
except Exception as e:
|
| 418 |
+
logger.error(f"Failed to pop result: {e}")
|
| 419 |
+
return None
|
| 420 |
+
|
| 421 |
+
async def get_queue_lengths(self) -> Dict[str, int]:
|
| 422 |
+
"""Get lengths of both queues.
|
| 423 |
+
|
| 424 |
+
Returns:
|
| 425 |
+
Dict with keys 'tasks' and 'results'.
|
| 426 |
+
"""
|
| 427 |
+
try:
|
| 428 |
+
tasks_len = await self.client.llen("queue:tasks")
|
| 429 |
+
results_len = await self.client.llen("queue:results")
|
| 430 |
+
return {"tasks": tasks_len, "results": results_len}
|
| 431 |
+
except Exception as e:
|
| 432 |
+
logger.error(f"Failed to get queue lengths: {e}")
|
| 433 |
+
return {"tasks": 0, "results": 0}
|
| 434 |
+
|
| 435 |
+
async def close(self) -> None:
|
| 436 |
+
"""Close Redis connection."""
|
| 437 |
+
await self.client.close()
|
| 438 |
+
logger.debug("Redis connection closed")
|
| 439 |
+
`,
|
| 440 |
+
|
| 441 |
+
"src/storage_neo4j.py": `"""
|
| 442 |
+
Neo4j graph storage operations.
|
| 443 |
+
"""
|
| 444 |
+
import logging
|
| 445 |
+
from typing import List, Dict, Any, Optional
|
| 446 |
+
|
| 447 |
+
from neo4j import GraphDatabase, AsyncGraphDatabase
|
| 448 |
+
|
| 449 |
+
from .models import SummarizedState, CandidateResult
|
| 450 |
+
from .config import settings
|
| 451 |
+
|
| 452 |
+
logger = logging.getLogger(__name__)
|
| 453 |
+
|
| 454 |
+
|
| 455 |
+
class Neo4jStorage:
|
| 456 |
+
"""Neo4j client wrapper for graph operations."""
|
| 457 |
+
|
| 458 |
+
def __init__(
|
| 459 |
+
self,
|
| 460 |
+
uri: str = settings.NEO4J_URI,
|
| 461 |
+
user: str = settings.NEO4J_USER,
|
| 462 |
+
password: str = settings.NEO4J_PASSWORD,
|
| 463 |
+
):
|
| 464 |
+
self.driver = GraphDatabase.driver(uri, auth=(user, password))
|
| 465 |
+
self.async_driver = AsyncGraphDatabase.driver(uri, auth=(user, password))
|
| 466 |
+
|
| 467 |
+
def create_state_node(self, state: SummarizedState, score: float) -> None:
|
| 468 |
+
"""Create a State node in Neo4j.
|
| 469 |
+
|
| 470 |
+
Args:
|
| 471 |
+
state: SummarizedState.
|
| 472 |
+
score: verification score.
|
| 473 |
+
"""
|
| 474 |
+
with self.driver.session() as session:
|
| 475 |
+
query = """
|
| 476 |
+
MERGE (s:State {id: $state_id})
|
| 477 |
+
SET s.score = $score,
|
| 478 |
+
s.metadata = $metadata,
|
| 479 |
+
s.created = datetime()
|
| 480 |
+
"""
|
| 481 |
+
session.run(
|
| 482 |
+
query,
|
| 483 |
+
state_id=state.state_id,
|
| 484 |
+
score=score,
|
| 485 |
+
metadata=state.metadata
|
| 486 |
+
)
|
| 487 |
+
logger.debug(f"State node {state.state_id[:8]} created/updated")
|
| 488 |
+
|
| 489 |
+
def create_candidate_node(self, candidate: CandidateResult, score: float) -> None:
|
| 490 |
+
"""Create a Candidate node in Neo4j.
|
| 491 |
+
|
| 492 |
+
Args:
|
| 493 |
+
candidate: CandidateResult.
|
| 494 |
+
score: verification score.
|
| 495 |
+
"""
|
| 496 |
+
with self.driver.session() as session:
|
| 497 |
+
query = """
|
| 498 |
+
MERGE (c:Candidate {id: $candidate_id})
|
| 499 |
+
SET c.code = $code,
|
| 500 |
+
c.score = $score,
|
| 501 |
+
c.task_id = $task_id,
|
| 502 |
+
c.timestamp = datetime(),
|
| 503 |
+
c.metadata = $metadata
|
| 504 |
+
"""
|
| 505 |
+
session.run(
|
| 506 |
+
query,
|
| 507 |
+
candidate_id=candidate.candidate_id,
|
| 508 |
+
code=candidate.code,
|
| 509 |
+
score=score,
|
| 510 |
+
task_id=candidate.task_id,
|
| 511 |
+
metadata=candidate.metadata
|
| 512 |
+
)
|
| 513 |
+
logger.debug(f"Candidate node {candidate.candidate_id[:8]} created/updated")
|
| 514 |
+
|
| 515 |
+
def create_derivation_edge(
|
| 516 |
+
self,
|
| 517 |
+
from_state_id: str,
|
| 518 |
+
to_candidate_id: str,
|
| 519 |
+
edge_type: str = "DERIVES"
|
| 520 |
+
) -> None:
|
| 521 |
+
"""Create edge from State to Candidate.
|
| 522 |
+
|
| 523 |
+
Args:
|
| 524 |
+
from_state_id: source State ID.
|
| 525 |
+
to_candidate_id: target Candidate ID.
|
| 526 |
+
edge_type: relationship type.
|
| 527 |
+
"""
|
| 528 |
+
with self.driver.session() as session:
|
| 529 |
+
query = f"""
|
| 530 |
+
MATCH (s:State {{id: $from_state_id}})
|
| 531 |
+
MATCH (c:Candidate {{id: $to_candidate_id}})
|
| 532 |
+
MERGE (s)-[:{edge_type}]->(c)
|
| 533 |
+
"""
|
| 534 |
+
session.run(
|
| 535 |
+
query,
|
| 536 |
+
from_state_id=from_state_id,
|
| 537 |
+
to_candidate_id=to_candidate_id
|
| 538 |
+
)
|
| 539 |
+
logger.debug(f"Edge {from_state_id[:8]} -> {to_candidate_id[:8]} created")
|
| 540 |
+
|
| 541 |
+
def get_state(self, state_id: str) -> Optional[Dict[str, Any]]:
|
| 542 |
+
"""Retrieve a State node by ID.
|
| 543 |
+
|
| 544 |
+
Args:
|
| 545 |
+
state_id: State ID.
|
| 546 |
+
|
| 547 |
+
Returns:
|
| 548 |
+
State properties dict or None.
|
| 549 |
+
"""
|
| 550 |
+
with self.driver.session() as session:
|
| 551 |
+
query = """
|
| 552 |
+
MATCH (s:State {id: $state_id})
|
| 553 |
+
RETURN properties(s) as props
|
| 554 |
+
"""
|
| 555 |
+
result = session.run(query, state_id=state_id)
|
| 556 |
+
record = result.single()
|
| 557 |
+
return record["props"] if record else None
|
| 558 |
+
|
| 559 |
+
def get_candidate(self, candidate_id: str) -> Optional[Dict[str, Any]]:
|
| 560 |
+
"""Retrieve a Candidate node by ID.
|
| 561 |
+
|
| 562 |
+
Args:
|
| 563 |
+
candidate_id: Candidate ID.
|
| 564 |
+
|
| 565 |
+
Returns:
|
| 566 |
+
Candidate properties dict or None.
|
| 567 |
+
"""
|
| 568 |
+
with self.driver.session() as session:
|
| 569 |
+
query = """
|
| 570 |
+
MATCH (c:Candidate {id: $candidate_id})
|
| 571 |
+
RETURN properties(c) as props
|
| 572 |
+
"""
|
| 573 |
+
result = session.run(query, candidate_id=candidate_id)
|
| 574 |
+
record = result.single()
|
| 575 |
+
return record["props"] if record else None
|
| 576 |
+
|
| 577 |
+
def get_verification_graph_stats(self) -> Dict[str, Any]:
|
| 578 |
+
"""Get statistics about the verification graph.
|
| 579 |
+
|
| 580 |
+
Returns:
|
| 581 |
+
Dict with counts of nodes, edges, etc.
|
| 582 |
+
"""
|
| 583 |
+
with self.driver.session() as session:
|
| 584 |
+
query = """
|
| 585 |
+
MATCH (s:State)
|
| 586 |
+
WITH count(s) as state_count
|
| 587 |
+
MATCH (c:Candidate)
|
| 588 |
+
WITH state_count, count(c) as candidate_count
|
| 589 |
+
MATCH ()-[r]->()
|
| 590 |
+
RETURN state_count, candidate_count, count(r) as edge_count
|
| 591 |
+
"""
|
| 592 |
+
result = session.run(query)
|
| 593 |
+
record = result.single()
|
| 594 |
+
if record:
|
| 595 |
+
return {
|
| 596 |
+
"state_count": record["state_count"],
|
| 597 |
+
"candidate_count": record["candidate_count"],
|
| 598 |
+
"edge_count": record["edge_count"]
|
| 599 |
+
}
|
| 600 |
+
return {"state_count": 0, "candidate_count": 0, "edge_count": 0}
|
| 601 |
+
|
| 602 |
+
async def close(self) -> None:
|
| 603 |
+
"""Close Neo4j driver."""
|
| 604 |
+
await self.driver.close()
|
| 605 |
+
await self.async_driver.close()
|
| 606 |
+
logger.debug("Neo4j connection closed")
|
| 607 |
+
`,
|
| 608 |
+
|
| 609 |
+
"src/config.py": `"""
|
| 610 |
+
Configuration settings for Quantum Code Weaver Engine.
|
| 611 |
+
"""
|
| 612 |
+
import os
|
| 613 |
+
from typing import Optional
|
| 614 |
+
from pydantic import BaseSettings
|
| 615 |
+
|
| 616 |
+
|
| 617 |
+
class Settings(BaseSettings):
|
| 618 |
+
"""Application settings loaded from environment or .env file."""
|
| 619 |
+
|
| 620 |
+
# Redis
|
| 621 |
+
REDIS_HOST: str = "localhost"
|
| 622 |
+
REDIS_PORT: int = 6379
|
| 623 |
+
REDIS_DB: int = 0
|
| 624 |
+
|
| 625 |
+
# Neo4j
|
| 626 |
+
NEO4J_URI: str = "bolt://localhost:7687"
|
| 627 |
+
NEO4J_USER: str = "neo4j"
|
| 628 |
+
NEO4J_PASSWORD: str = "password"
|
| 629 |
+
|
| 630 |
+
# Orchestrator
|
| 631 |
+
THRESHOLD_SCORE: float = 0.8
|
| 632 |
+
POLL_INTERVAL: float = 0.01 # seconds
|
| 633 |
+
|
| 634 |
+
# Worker
|
| 635 |
+
WORKER_COUNT: int = 5
|
| 636 |
+
MAX_TOKENS: int = 2048
|
| 637 |
+
TEMPERATURE: float = 0.7
|
| 638 |
+
|
| 639 |
+
# Logging
|
| 640 |
+
LOG_LEVEL: str = "INFO"
|
| 641 |
+
LOG_FORMAT: str = "%(asctime)s - %(name)s - %(levelname)s - %(message)s"
|
| 642 |
+
|
| 643 |
+
class Config:
|
| 644 |
+
env_file = ".env"
|
| 645 |
+
env_file_encoding = "utf-8"
|
| 646 |
+
|
| 647 |
+
|
| 648 |
+
# Global settings instance
|
| 649 |
+
settings = Settings()
|
| 650 |
+
`,
|
| 651 |
+
|
| 652 |
+
"src/main.py": `"""
|
| 653 |
+
Main entry point for Quantum Code Weaver Engine.
|
| 654 |
+
"""
|
| 655 |
+
import asyncio
|
| 656 |
+
import logging
|
| 657 |
+
import signal
|
| 658 |
+
import sys
|
| 659 |
+
from contextlib import asynccontextmanager
|
| 660 |
+
|
| 661 |
+
from .orchestrator import Orchestrator
|
| 662 |
+
from .config import settings
|
| 663 |
+
|
| 664 |
+
|
| 665 |
+
# Configure logging
|
| 666 |
+
logging.basicConfig(
|
| 667 |
+
level=settings.LOG_LEVEL,
|
| 668 |
+
format=settings.LOG_FORMAT,
|
| 669 |
+
handlers=[
|
| 670 |
+
logging.StreamHandler(sys.stdout),
|
| 671 |
+
logging.FileHandler("qcwe.log")
|
| 672 |
+
]
|
| 673 |
+
)
|
| 674 |
+
logger = logging.getLogger(__name__)
|
| 675 |
+
|
| 676 |
+
|
| 677 |
+
@asynccontextmanager
|
| 678 |
+
async def lifecycle(orchestrator: Orchestrator):
|
| 679 |
+
"""Context manager for orchestrator lifecycle.
|
| 680 |
+
|
| 681 |
+
Handles graceful shutdown.
|
| 682 |
+
"""
|
| 683 |
+
try:
|
| 684 |
+
# Start orchestrator task
|
| 685 |
+
task = asyncio.create_task(orchestrator.run())
|
| 686 |
+
logger.info("Orchestrator task started.")
|
| 687 |
+
yield
|
| 688 |
+
finally:
|
| 689 |
+
# Cancel task and wait
|
| 690 |
+
task.cancel()
|
| 691 |
+
try:
|
| 692 |
+
await task
|
| 693 |
+
except asyncio.CancelledError:
|
| 694 |
+
pass
|
| 695 |
+
logger.info("Orchestrator shutdown complete.")
|
| 696 |
+
|
| 697 |
+
|
| 698 |
+
def handle_shutdown(signum, frame):
|
| 699 |
+
"""Signal handler for graceful shutdown."""
|
| 700 |
+
logger.info(f"Received signal {signum}, initiating shutdown...")
|
| 701 |
+
# The asyncio event loop will be stopped by the lifecycle context manager
|
| 702 |
+
sys.exit(0)
|
| 703 |
+
|
| 704 |
+
|
| 705 |
+
async def main():
|
| 706 |
+
"""Main async entry point."""
|
| 707 |
+
logger.info("Starting Quantum Code Weaver Engine")
|
| 708 |
+
logger.info(f"Threshold score: {settings.THRESHOLD_SCORE}")
|
| 709 |
+
logger.info(f"Redis: {settings.REDIS_HOST}:{settings.REDIS_PORT}")
|
| 710 |
+
logger.info(f"Neo4j: {settings.NEO4J_URI}")
|
| 711 |
+
|
| 712 |
+
# Set up signal handlers
|
| 713 |
+
signal.signal(signal.SIGINT, handle_shutdown)
|
| 714 |
+
signal.signal(signal.SIGTERM, handle_shutdown)
|
| 715 |
+
|
| 716 |
+
# Create orchestrator
|
| 717 |
+
orchestrator = Orchestrator(
|
| 718 |
+
redis_host=settings.REDIS_HOST,
|
| 719 |
+
redis_port=settings.REDIS_PORT,
|
| 720 |
+
neo4j_uri=settings.NEO4J_URI,
|
| 721 |
+
neo4j_user=settings.NEO4J_USER,
|
| 722 |
+
neo4j_password=settings.NEO4J_PASSWORD,
|
| 723 |
+
threshold_score=settings.THRESHOLD_SCORE
|
| 724 |
+
)
|
| 725 |
+
|
| 726 |
+
# Run with lifecycle management
|
| 727 |
+
async with lifecycle(orchestrator):
|
| 728 |
+
# Keep the main loop alive
|
| 729 |
+
while True:
|
| 730 |
+
await asyncio.sleep(1)
|
| 731 |
+
|
| 732 |
+
|
| 733 |
+
if __name__ == "__main__":
|
| 734 |
+
asyncio.run(main())
|
| 735 |
+
`,
|
| 736 |
+
|
| 737 |
+
"src/__init__.py": `"""
|
| 738 |
+
Quantum Code Weaver Engine package.
|
| 739 |
+
"""
|
| 740 |
+
__version__ = "1.0.0"
|
| 741 |
+
`
|
| 742 |
+
};
|
| 743 |
+
|
| 744 |
+
// ================================
|
| 745 |
+
// DOCUMENTATION SITE FUNCTIONALITY
|
| 746 |
+
// ================================
|
| 747 |
+
|
| 748 |
+
// Initialize when DOM is ready
|
| 749 |
+
function initDocumentationSite() {
|
| 750 |
+
renderFileTree();
|
| 751 |
+
setupRouting();
|
| 752 |
+
setupCopyButton();
|
| 753 |
+
highlightCurrentFile();
|
| 754 |
+
updateFileInfo('README.md');
|
| 755 |
+
|
| 756 |
+
// Initialize syntax highlighting
|
| 757 |
+
hljs.highlightAll();
|
| 758 |
}
|
| 759 |
|
| 760 |
+
// Render the file tree in the sidebar
|
| 761 |
+
function renderFileTree() {
|
| 762 |
+
const container = document.getElementById('file-tree');
|
| 763 |
+
if (!container) return;
|
| 764 |
+
|
| 765 |
+
container.innerHTML = '';
|
| 766 |
+
|
| 767 |
+
const fileGroups = {};
|
| 768 |
+
|
| 769 |
+
// Group files by directory
|
| 770 |
+
Object.keys(FILES).forEach(path => {
|
| 771 |
+
const parts = path.split('/');
|
| 772 |
+
if (parts.length === 1) {
|
| 773 |
+
if (!fileGroups['root']) fileGroups['root'] = [];
|
| 774 |
+
fileGroups['root'].push(path);
|
| 775 |
+
} else {
|
| 776 |
+
const dir = parts[0];
|
| 777 |
+
if (!fileGroups[dir]) fileGroups[dir] = [];
|
| 778 |
+
fileGroups[dir].push(path);
|
| 779 |
+
}
|
| 780 |
});
|
| 781 |
|
| 782 |
+
// Render groups
|
| 783 |
+
Object.keys(fileGroups).sort().forEach(dir => {
|
| 784 |
+
if (dir !== 'root') {
|
| 785 |
+
const folderItem = document.createElement('div');
|
| 786 |
+
folderItem.className = 'file-tree-item mb-1';
|
| 787 |
+
folderItem.innerHTML = `
|
| 788 |
+
<i data-feather="folder" class="file-tree-icon"></i>
|
| 789 |
+
<span class="font-medium">${dir}</span>
|
| 790 |
+
<span class="ml-auto text-gray-500 text-xs">${fileGroups[dir].length}</span>
|
| 791 |
+
`;
|
| 792 |
+
container.appendChild(folderItem);
|
| 793 |
+
}
|
| 794 |
+
|
| 795 |
+
fileGroups[dir].sort().forEach(filePath => {
|
| 796 |
+
const item = document.createElement('div');
|
| 797 |
+
item.className = 'file-tree-item pl-8';
|
| 798 |
+
item.dataset.path = filePath;
|
| 799 |
+
|
| 800 |
+
const icon = getFileIcon(filePath);
|
| 801 |
+
item.innerHTML = `
|
| 802 |
+
<i data-feather="${icon}" class="file-tree-icon"></i>
|
| 803 |
+
<span class="truncate">${filePath.split('/').pop()}</span>
|
| 804 |
+
`;
|
| 805 |
+
|
| 806 |
+
item.addEventListener('click', () => {
|
| 807 |
+
openFile(filePath);
|
| 808 |
+
});
|
| 809 |
+
|
| 810 |
+
container.appendChild(item);
|
| 811 |
});
|
| 812 |
+
});
|
| 813 |
+
|
| 814 |
+
feather.replace();
|
| 815 |
}
|
| 816 |
|
| 817 |
+
// Get appropriate Feather icon for file type
|
| 818 |
+
function getFileIcon(path) {
|
| 819 |
+
if (path.endsWith('.py')) return 'file-text';
|
| 820 |
+
if (path.endsWith('.md')) return 'book';
|
| 821 |
+
if (path.endsWith('.txt')) return 'file-text';
|
| 822 |
+
if (path.includes('src/')) return 'code';
|
| 823 |
+
return 'file';
|
| 824 |
+
}
|
| 825 |
+
|
| 826 |
+
// Open a file and display its contents
|
| 827 |
+
function openFile(path) {
|
| 828 |
+
if (!FILES.hasOwnProperty(path)) {
|
| 829 |
+
console.error(`File not found: ${path}`);
|
| 830 |
+
return;
|
| 831 |
+
}
|
| 832 |
+
|
| 833 |
+
// Update active file in sidebar
|
| 834 |
+
document.querySelectorAll('.file-tree-item').forEach(item => {
|
| 835 |
+
item.classList.remove('active');
|
| 836 |
+
if (item.dataset.path === path) {
|
| 837 |
+
item.classList.add('active');
|
| 838 |
+
}
|
| 839 |
+
});
|
| 840 |
|
| 841 |
+
// Update breadcrumb and title
|
| 842 |
+
document.getElementById('breadcrumb-path').textContent = path;
|
| 843 |
+
document.getElementById('file-title').textContent = path.split('/').pop();
|
| 844 |
+
document.getElementById('file-path-display').textContent = path;
|
|
|
|
| 845 |
|
| 846 |
+
// Update code content
|
| 847 |
+
const codeElement = document.getElementById('code-content');
|
| 848 |
+
codeElement.textContent = FILES[path];
|
| 849 |
+
|
| 850 |
+
// Update syntax highlighting
|
| 851 |
+
const language = getLanguageClass(path);
|
| 852 |
+
codeElement.className = `language-${language} hljs`;
|
| 853 |
+
hljs.highlightElement(codeElement);
|
| 854 |
+
|
| 855 |
+
// Update file info
|
| 856 |
+
updateFileInfo(path);
|
| 857 |
+
|
| 858 |
+
// Update URL hash
|
| 859 |
+
window.location.hash = `#/file/${encodeURIComponent(path)}`;
|
| 860 |
+
}
|
| 861 |
+
|
| 862 |
+
// Determine language class for syntax highlighting
|
| 863 |
+
function getLanguageClass(path) {
|
| 864 |
+
if (path.endsWith('.py')) return 'python';
|
| 865 |
+
if (path.endsWith('.md')) return 'markdown';
|
| 866 |
+
if (path.endsWith('.txt')) return 'plaintext';
|
| 867 |
+
if (path.endsWith('requirements.txt')) return 'bash';
|
| 868 |
+
return 'python';
|
| 869 |
+
}
|
| 870 |
+
|
| 871 |
+
// Update file info panel (lines, size, etc.)
|
| 872 |
+
function updateFileInfo(path) {
|
| 873 |
+
const content = FILES[path];
|
| 874 |
+
const lines = content.split('\n').length;
|
| 875 |
+
const size = new Blob([content]).size;
|
| 876 |
+
|
| 877 |
+
document.getElementById('file-type').textContent = getFileType(path);
|
| 878 |
+
document.getElementById('file-lines').textContent = lines.toLocaleString();
|
| 879 |
+
document.getElementById('file-size').textContent = formatFileSize(size);
|
| 880 |
+
document.getElementById('file-updated').textContent = 'Today';
|
| 881 |
+
}
|
| 882 |
+
|
| 883 |
+
// Get human-readable file type
|
| 884 |
+
function getFileType(path) {
|
| 885 |
+
if (path.endsWith('.py')) return 'Python';
|
| 886 |
+
if (path.endsWith('.md')) return 'Markdown';
|
| 887 |
+
if (path.endsWith('.txt')) return 'Text';
|
| 888 |
+
if (path.endsWith('requirements.txt')) return 'Requirements';
|
| 889 |
+
if (path.includes('__init__.py')) return 'Package';
|
| 890 |
+
return 'Text';
|
| 891 |
+
}
|
| 892 |
+
|
| 893 |
+
// Format file size
|
| 894 |
+
function formatFileSize(bytes) {
|
| 895 |
+
if (bytes < 1024) return bytes + ' B';
|
| 896 |
+
if (bytes < 1024 * 1024) return (bytes / 1024).toFixed(1) + ' KB';
|
| 897 |
+
return (bytes / (1024 * 1024)).toFixed(1) + ' MB';
|
| 898 |
}
|
| 899 |
|
| 900 |
+
// Setup hash-based routing
|
| 901 |
+
function setupRouting() {
|
| 902 |
+
// Check initial hash
|
| 903 |
+
if (window.location.hash) {
|
| 904 |
+
const match = window.location.hash.match(/#\/file\/(.+)/);
|
| 905 |
+
if (match) {
|
| 906 |
+
const path = decodeURIComponent(match[1]);
|
| 907 |
+
if (FILES.hasOwnProperty(path)) {
|
| 908 |
+
openFile(path);
|
| 909 |
+
}
|
| 910 |
+
}
|
| 911 |
+
} else {
|
| 912 |
+
// Default to README.md
|
| 913 |
+
openFile('README.md');
|
| 914 |
+
}
|
| 915 |
+
|
| 916 |
+
// Listen for hash changes
|
| 917 |
+
window.addEventListener('hashchange', () => {
|
| 918 |
+
const match = window.location.hash.match(/#\/file\/(.+)/);
|
| 919 |
+
if (match) {
|
| 920 |
+
const path = decodeURIComponent(match[1]);
|
| 921 |
+
if (FILES.hasOwnProperty(path)) {
|
| 922 |
+
openFile(path);
|
| 923 |
+
}
|
| 924 |
+
}
|
| 925 |
});
|
| 926 |
}
|
| 927 |
|
| 928 |
+
// Setup copy button functionality
|
| 929 |
+
function setupCopyButton() {
|
| 930 |
+
const button = document.getElementById('copy-button');
|
| 931 |
+
if (!button) return;
|
| 932 |
+
|
| 933 |
+
button.addEventListener('click', () => {
|
| 934 |
+
const path = document.getElementById('breadcrumb-path').textContent;
|
| 935 |
+
const content = FILES[path];
|
| 936 |
|
| 937 |
+
navigator.clipboard.writeText(content).then(() => {
|
| 938 |
+
const originalText = button.innerHTML;
|
| 939 |
+
button.innerHTML = '<i data-feather="check" class="w-4 h-4"></i><span>Copied!</span>';
|
| 940 |
+
button.classList.add('copy-success');
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 941 |
|
| 942 |
setTimeout(() => {
|
| 943 |
+
button.innerHTML = originalText;
|
| 944 |
+
button.classList.remove('copy-success');
|
| 945 |
+
feather.replace();
|
| 946 |
+
}, 2000);
|
| 947 |
+
}).catch(err => {
|
| 948 |
+
console.error('Failed to copy: ', err);
|
| 949 |
+
button.innerHTML = '<i data-feather="x" class="w-4 h-4"></i><span>Failed</span>';
|
| 950 |
+
setTimeout(() => {
|
| 951 |
+
button.innerHTML = '<i data-feather="copy" class="w-4 h-4"></i><span>Copy File</span>';
|
| 952 |
+
feather.replace();
|
| 953 |
+
}, 2000);
|
| 954 |
+
});
|
| 955 |
+
});
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 956 |
}
|
| 957 |
|
| 958 |
+
// Highlight current file in sidebar
|
| 959 |
+
function highlightCurrentFile() {
|
| 960 |
+
const path = document.getElementById('breadcrumb-path').textContent;
|
| 961 |
+
document.querySelectorAll('.file-tree-item').forEach(item => {
|
| 962 |
+
item.classList.remove('active');
|
| 963 |
+
if (item.dataset.path === path) {
|
| 964 |
+
item.classList.add('active');
|
| 965 |
+
}
|
| 966 |
+
});
|
| 967 |
}
|
| 968 |
|
| 969 |
+
// Expose function globally
|
| 970 |
+
window.initDocumentationSite = initDocumentationSite;
|
|
|
|
|
|
|
|
|
|
@@ -1,14 +1,8 @@
|
|
| 1 |
-
/*
|
| 2 |
-
@import url('https://fonts.googleapis.com/css2?family=Inter:wght@300;400;500;600;700;800&display=swap');
|
| 3 |
|
| 4 |
-
|
| 5 |
-
|
| 6 |
-
|
| 7 |
-
box-sizing: border-box;
|
| 8 |
-
}
|
| 9 |
-
|
| 10 |
-
body {
|
| 11 |
-
font-family: 'Inter', -apple-system, BlinkMacSystemFont, 'Segoe UI', sans-serif;
|
| 12 |
}
|
| 13 |
|
| 14 |
/* Custom scrollbar */
|
|
@@ -31,124 +25,66 @@ body {
|
|
| 31 |
background: linear-gradient(45deg, #0891b2, #7c3aed);
|
| 32 |
}
|
| 33 |
|
| 34 |
-
/*
|
| 35 |
-
|
| 36 |
-
|
| 37 |
-
|
| 38 |
-
|
| 39 |
-
|
| 40 |
-
|
| 41 |
-
}
|
| 42 |
}
|
| 43 |
|
| 44 |
-
|
| 45 |
-
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
|
| 49 |
-
|
| 50 |
-
|
|
|
|
| 51 |
}
|
| 52 |
|
| 53 |
-
|
| 54 |
-
0
|
| 55 |
-
background-position: -1000px 0;
|
| 56 |
-
}
|
| 57 |
-
100% {
|
| 58 |
-
background-position: 1000px 0;
|
| 59 |
-
}
|
| 60 |
}
|
| 61 |
|
| 62 |
-
|
| 63 |
-
|
| 64 |
-
|
| 65 |
}
|
| 66 |
|
| 67 |
-
.
|
| 68 |
-
|
|
|
|
|
|
|
|
|
|
| 69 |
}
|
| 70 |
|
| 71 |
-
.
|
| 72 |
-
|
| 73 |
-
background-size: 1000px 100%;
|
| 74 |
-
-webkit-background-clip: text;
|
| 75 |
-
background-clip: text;
|
| 76 |
-
color: transparent;
|
| 77 |
-
animation: shimmer 3s infinite linear;
|
| 78 |
}
|
| 79 |
|
| 80 |
-
/*
|
| 81 |
-
.
|
| 82 |
-
|
| 83 |
-
|
| 84 |
-
|
| 85 |
-
.hover-card:hover {
|
| 86 |
-
transform: translateY(-5px);
|
| 87 |
-
box-shadow: 0 20px 40px rgba(0, 0, 0, 0.3);
|
| 88 |
-
}
|
| 89 |
-
|
| 90 |
-
/* Gradient borders */
|
| 91 |
-
.gradient-border {
|
| 92 |
-
position: relative;
|
| 93 |
-
border-radius: 12px;
|
| 94 |
-
background: linear-gradient(45deg, #1e293b, #0f172a);
|
| 95 |
-
}
|
| 96 |
-
|
| 97 |
-
.gradient-border::before {
|
| 98 |
-
content: '';
|
| 99 |
-
position: absolute;
|
| 100 |
-
top: -2px;
|
| 101 |
-
left: -2px;
|
| 102 |
-
right: -2px;
|
| 103 |
-
bottom: -2px;
|
| 104 |
-
background: linear-gradient(45deg, #06b6d4, #8b5cf6);
|
| 105 |
-
border-radius: 14px;
|
| 106 |
-
z-index: -1;
|
| 107 |
-
opacity: 0.3;
|
| 108 |
-
transition: opacity 0.3s ease;
|
| 109 |
}
|
| 110 |
|
| 111 |
-
|
| 112 |
-
|
| 113 |
-
|
| 114 |
-
|
| 115 |
-
|
| 116 |
-
|
| 117 |
-
width: 10px;
|
| 118 |
-
height: 10px;
|
| 119 |
-
border-radius: 50%;
|
| 120 |
-
display: inline-block;
|
| 121 |
-
margin-right: 8px;
|
| 122 |
-
}
|
| 123 |
-
|
| 124 |
-
.status-operational {
|
| 125 |
-
background: linear-gradient(45deg, #10b981, #34d399);
|
| 126 |
-
box-shadow: 0 0 10px rgba(16, 185, 129, 0.5);
|
| 127 |
-
}
|
| 128 |
-
|
| 129 |
-
.status-degraded {
|
| 130 |
-
background: linear-gradient(45deg, #f59e0b, #fbbf24);
|
| 131 |
-
box-shadow: 0 0 10px rgba(245, 158, 11, 0.5);
|
| 132 |
}
|
| 133 |
|
| 134 |
-
|
| 135 |
-
|
| 136 |
-
|
| 137 |
}
|
| 138 |
|
| 139 |
-
/*
|
| 140 |
-
|
| 141 |
-
|
| 142 |
-
|
| 143 |
-
padding-right: 1rem;
|
| 144 |
-
}
|
| 145 |
-
|
| 146 |
-
h1 {
|
| 147 |
-
font-size: 2.5rem !important;
|
| 148 |
-
line-height: 1.2 !important;
|
| 149 |
-
}
|
| 150 |
-
|
| 151 |
-
h2 {
|
| 152 |
-
font-size: 2rem !important;
|
| 153 |
-
}
|
| 154 |
}
|
|
|
|
| 1 |
+
/* Documentation Site Styles */
|
|
|
|
| 2 |
|
| 3 |
+
/* Smooth scrolling */
|
| 4 |
+
html {
|
| 5 |
+
scroll-behavior: smooth;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 6 |
}
|
| 7 |
|
| 8 |
/* Custom scrollbar */
|
|
|
|
| 25 |
background: linear-gradient(45deg, #0891b2, #7c3aed);
|
| 26 |
}
|
| 27 |
|
| 28 |
+
/* Code block styling */
|
| 29 |
+
.hljs {
|
| 30 |
+
background: transparent !important;
|
| 31 |
+
padding: 1.5rem !important;
|
| 32 |
+
font-family: 'SF Mono', Monaco, 'Cascadia Code', 'Courier New', monospace;
|
| 33 |
+
font-size: 0.875rem;
|
| 34 |
+
line-height: 1.6;
|
|
|
|
| 35 |
}
|
| 36 |
|
| 37 |
+
/* File tree */
|
| 38 |
+
.file-tree-item {
|
| 39 |
+
padding: 0.5rem 0.75rem;
|
| 40 |
+
border-radius: 0.5rem;
|
| 41 |
+
cursor: pointer;
|
| 42 |
+
transition: all 0.2s ease;
|
| 43 |
+
display: flex;
|
| 44 |
+
align-items: center;
|
| 45 |
}
|
| 46 |
|
| 47 |
+
.file-tree-item:hover {
|
| 48 |
+
background-color: rgba(56, 189, 248, 0.1);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 49 |
}
|
| 50 |
|
| 51 |
+
.file-tree-item.active {
|
| 52 |
+
background-color: rgba(56, 189, 248, 0.2);
|
| 53 |
+
border-left: 3px solid #06b6d4;
|
| 54 |
}
|
| 55 |
|
| 56 |
+
.file-tree-icon {
|
| 57 |
+
margin-right: 0.75rem;
|
| 58 |
+
color: #94a3b8;
|
| 59 |
+
width: 1.25rem;
|
| 60 |
+
height: 1.25rem;
|
| 61 |
}
|
| 62 |
|
| 63 |
+
.file-tree-item.active .file-tree-icon {
|
| 64 |
+
color: #06b6d4;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 65 |
}
|
| 66 |
|
| 67 |
+
/* Copy button feedback */
|
| 68 |
+
.copy-success {
|
| 69 |
+
background-color: #10b981 !important;
|
| 70 |
+
transition: background-color 0.3s ease;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 71 |
}
|
| 72 |
|
| 73 |
+
/* Responsive adjustments */
|
| 74 |
+
@media (max-width: 768px) {
|
| 75 |
+
.hljs {
|
| 76 |
+
padding: 1rem !important;
|
| 77 |
+
font-size: 0.75rem;
|
| 78 |
+
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 79 |
}
|
| 80 |
|
| 81 |
+
/* Selection style */
|
| 82 |
+
::selection {
|
| 83 |
+
background-color: rgba(6, 182, 212, 0.3);
|
| 84 |
}
|
| 85 |
|
| 86 |
+
/* Focus outline */
|
| 87 |
+
*:focus {
|
| 88 |
+
outline: 2px solid #06b6d4;
|
| 89 |
+
outline-offset: 2px;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 90 |
}
|