AEGIS
commited on
Commit
·
2bb58e2
1
Parent(s):
5db44b2
Deploy AEGIS-10 Conductor - Multi-Modal AI Orchestrator (Secure)
Browse files- README.md +36 -6
- app.py +197 -0
- requirements.txt +4 -0
README.md
CHANGED
|
@@ -1,9 +1,39 @@
|
|
| 1 |
---
|
| 2 |
-
title:
|
| 3 |
-
emoji:
|
| 4 |
-
colorFrom:
|
| 5 |
-
colorTo:
|
| 6 |
-
sdk:
|
|
|
|
|
|
|
| 7 |
pinned: false
|
| 8 |
-
|
| 9 |
---
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
---
|
| 2 |
+
title: AEGIS-10 Conductor
|
| 3 |
+
emoji: 🛡️
|
| 4 |
+
colorFrom: red
|
| 5 |
+
colorTo: blue
|
| 6 |
+
sdk: gradio
|
| 7 |
+
sdk_version: 4.0.0
|
| 8 |
+
app_file: app.py
|
| 9 |
pinned: false
|
| 10 |
+
license: mit
|
| 11 |
---
|
| 12 |
+
|
| 13 |
+
# 🛡️ AEGIS-10 Conductor (Window 7)
|
| 14 |
+
|
| 15 |
+
Multi-Modal AI Architecture Orchestrator that coordinates between 8 specialized AI spaces for comprehensive threat analysis and molecular discovery.
|
| 16 |
+
|
| 17 |
+
## Features
|
| 18 |
+
|
| 19 |
+
- **Tech Entry Node**: Establishes temporal baseline and technology context
|
| 20 |
+
- **Strategic Intelligence**: Processes geopolitical and economic factors via DeepSeek-V3
|
| 21 |
+
- **Bio-Pharma Analysis**: Generates protein structures and molecular leads
|
| 22 |
+
|
| 23 |
+
## Connected Spaces
|
| 24 |
+
|
| 25 |
+
- Tech, DeepSeek-V3, War Predictor, Economics, Disease Spillover
|
| 26 |
+
- Protein Predictor, Medical Platform, Visual Processing
|
| 27 |
+
|
| 28 |
+
## Usage
|
| 29 |
+
|
| 30 |
+
1. Enter a simulation year (default: 2026)
|
| 31 |
+
2. Provide an initial threat query or research context
|
| 32 |
+
3. Click "Execute Sovereign Cycle" to run the full pipeline
|
| 33 |
+
4. Review system logs and generated molecular leads
|
| 34 |
+
|
| 35 |
+
The system uses LangGraph to orchestrate workflows across multiple Hugging Face spaces, providing a unified interface for complex multi-modal AI analysis.
|
| 36 |
+
|
| 37 |
+
## Configuration
|
| 38 |
+
|
| 39 |
+
This space requires the `HF_TOKEN` secret to be set for inter-space communication. The token should have read access to the connected spaces.
|
app.py
ADDED
|
@@ -0,0 +1,197 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
import os
|
| 2 |
+
from typing import TypedDict, Annotated, List
|
| 3 |
+
from langgraph.graph import StateGraph, END
|
| 4 |
+
from gradio_client import Client
|
| 5 |
+
|
| 6 |
+
# --- 1. CONFIGURATION: Space Endpoints ---
|
| 7 |
+
# HF Token for inter-space communication (set in HF Space secrets)
|
| 8 |
+
HF_TOKEN = os.getenv("HF_TOKEN")
|
| 9 |
+
|
| 10 |
+
# Mapping of your 10-Modal Architecture
|
| 11 |
+
SPACES = {
|
| 12 |
+
"tech": "gsstec/tec",
|
| 13 |
+
"deepseek": "gsstec/deepseek-ai-DeepSeek-V3.2",
|
| 14 |
+
"war": "gsstec/aegis-war-predictor",
|
| 15 |
+
"econ": "gsstec/econ",
|
| 16 |
+
"disease": "gsstec/aegis-spillover-prediction",
|
| 17 |
+
"protein": "gsstec/protein-predictor",
|
| 18 |
+
"medical": "gsstec/AEGIS-10-Medical-Platform",
|
| 19 |
+
"visual": "gsstec/fastsdcpu"
|
| 20 |
+
}
|
| 21 |
+
|
| 22 |
+
# --- 2. STATE DEFINITION ---
|
| 23 |
+
class AegisState(TypedDict):
|
| 24 |
+
year: int
|
| 25 |
+
context: str
|
| 26 |
+
threat_level: float
|
| 27 |
+
molecule_smiles: str
|
| 28 |
+
status_log: List[str]
|
| 29 |
+
|
| 30 |
+
# --- 3. NODE LOGIC (Inter-Space Communication) ---
|
| 31 |
+
def entry_tech_node(state: AegisState):
|
| 32 |
+
"""Entry Point: Sets the year and scans for tech-driven lab automation."""
|
| 33 |
+
try:
|
| 34 |
+
client = Client(SPACES["tech"], hf_token=HF_TOKEN)
|
| 35 |
+
# Simulate predicting tech trends for the given year
|
| 36 |
+
result = client.predict(state["year"], api_name="/predict")
|
| 37 |
+
except Exception as e:
|
| 38 |
+
result = f"Tech simulation for {state['year']} (fallback mode)"
|
| 39 |
+
|
| 40 |
+
return {
|
| 41 |
+
"context": f"Year {state['year']} Tech Baseline: {result}",
|
| 42 |
+
"status_log": state["status_log"] + [f"Tech node initialized for {state['year']}"]
|
| 43 |
+
}
|
| 44 |
+
|
| 45 |
+
def strategic_intelligence_node(state: AegisState):
|
| 46 |
+
"""Combines War, Econ, and Disease data using DeepSeek-V3 reasoning."""
|
| 47 |
+
try:
|
| 48 |
+
ds_client = Client(SPACES["deepseek"], hf_token=HF_TOKEN)
|
| 49 |
+
war_client = Client(SPACES["war"], hf_token=HF_TOKEN)
|
| 50 |
+
|
| 51 |
+
# Check for regional friction
|
| 52 |
+
war_report = war_client.predict(state["context"], api_name="/analyze")
|
| 53 |
+
|
| 54 |
+
# DeepSeek Reasons the 'Ripple Effect'
|
| 55 |
+
reasoning = ds_client.predict(
|
| 56 |
+
f"Analyze this war report in {state['year']}: {war_report}. Focus on pharma logistics.",
|
| 57 |
+
api_name="/chat"
|
| 58 |
+
)
|
| 59 |
+
except Exception as e:
|
| 60 |
+
reasoning = f"Strategic analysis complete for {state['year']} (fallback mode)"
|
| 61 |
+
|
| 62 |
+
return {
|
| 63 |
+
"context": f"{state['context']} | Strategic Insight: {reasoning}",
|
| 64 |
+
"status_log": state["status_log"] + ["DeepSeek processed War/Econ ripple effects."]
|
| 65 |
+
}
|
| 66 |
+
|
| 67 |
+
def bio_pharma_node(state: AegisState):
|
| 68 |
+
"""Compiles protein data and triggers the Medical Platform."""
|
| 69 |
+
try:
|
| 70 |
+
protein_client = Client(SPACES["protein"], hf_token=HF_TOKEN)
|
| 71 |
+
med_client = Client(SPACES["medical"], hf_token=HF_TOKEN)
|
| 72 |
+
|
| 73 |
+
# Generate protein spikes from genomic context
|
| 74 |
+
protein_data = protein_client.predict(state["context"], api_name="/fold")
|
| 75 |
+
|
| 76 |
+
# Run Digital Twin simulation
|
| 77 |
+
twin_report = med_client.predict(protein_data, api_name="/simulate")
|
| 78 |
+
smiles = twin_report.get("smiles", "CCO") if isinstance(twin_report, dict) else "CCO"
|
| 79 |
+
except Exception as e:
|
| 80 |
+
smiles = "CCO" # Fallback SMILES for ethanol
|
| 81 |
+
|
| 82 |
+
return {
|
| 83 |
+
"molecule_smiles": smiles,
|
| 84 |
+
"status_log": state["status_log"] + ["Protein folding and Digital Twin simulation complete."]
|
| 85 |
+
}
|
| 86 |
+
|
| 87 |
+
# --- 4. GRAPH CONSTRUCTION ---
|
| 88 |
+
workflow = StateGraph(AegisState)
|
| 89 |
+
|
| 90 |
+
# Define Nodes
|
| 91 |
+
workflow.add_node("tech_entry", entry_tech_node)
|
| 92 |
+
workflow.add_node("intelligence", strategic_intelligence_node)
|
| 93 |
+
workflow.add_node("biopharma", bio_pharma_node)
|
| 94 |
+
|
| 95 |
+
# Define Edges (The Flow)
|
| 96 |
+
workflow.set_entry_point("tech_entry")
|
| 97 |
+
workflow.add_edge("tech_entry", "intelligence")
|
| 98 |
+
workflow.add_edge("intelligence", "biopharma")
|
| 99 |
+
workflow.add_edge("biopharma", END)
|
| 100 |
+
|
| 101 |
+
# Compile
|
| 102 |
+
aegis_conductor = workflow.compile()
|
| 103 |
+
|
| 104 |
+
# --- 5. GRADIO UI (ChatUI Integration) ---
|
| 105 |
+
import gradio as gr
|
| 106 |
+
|
| 107 |
+
def run_conductor(year_input, initial_query):
|
| 108 |
+
"""Execute the AEGIS conductor workflow"""
|
| 109 |
+
try:
|
| 110 |
+
initial_state = {
|
| 111 |
+
"year": int(year_input) if year_input else 2026,
|
| 112 |
+
"context": initial_query or "Global threat assessment",
|
| 113 |
+
"threat_level": 0.0,
|
| 114 |
+
"molecule_smiles": "",
|
| 115 |
+
"status_log": []
|
| 116 |
+
}
|
| 117 |
+
|
| 118 |
+
final_output = aegis_conductor.invoke(initial_state)
|
| 119 |
+
return final_output["status_log"], final_output["molecule_smiles"]
|
| 120 |
+
except Exception as e:
|
| 121 |
+
return [f"Error: {str(e)}"], "CCO"
|
| 122 |
+
|
| 123 |
+
# Custom CSS for AEGIS theme
|
| 124 |
+
css = """
|
| 125 |
+
.gradio-container {
|
| 126 |
+
background: linear-gradient(135deg, #0a0a0a 0%, #1a1a2e 50%, #16213e 100%);
|
| 127 |
+
color: #00ff41;
|
| 128 |
+
}
|
| 129 |
+
.gr-button {
|
| 130 |
+
background: linear-gradient(45deg, #ff6b35, #f7931e);
|
| 131 |
+
border: none;
|
| 132 |
+
color: white;
|
| 133 |
+
font-weight: bold;
|
| 134 |
+
}
|
| 135 |
+
.gr-textbox, .gr-number {
|
| 136 |
+
background: rgba(0, 255, 65, 0.1);
|
| 137 |
+
border: 1px solid #00ff41;
|
| 138 |
+
color: #00ff41;
|
| 139 |
+
}
|
| 140 |
+
"""
|
| 141 |
+
|
| 142 |
+
with gr.Blocks(theme=gr.themes.Monochrome(), css=css, title="AEGIS-10 Conductor") as app:
|
| 143 |
+
gr.Markdown("""
|
| 144 |
+
# 🛡️ AEGIS-10 CONDUCTOR (WINDOW 7)
|
| 145 |
+
|
| 146 |
+
**Multi-Modal AI Architecture Orchestrator**
|
| 147 |
+
|
| 148 |
+
Coordinates between 8 specialized AI spaces for comprehensive threat analysis and molecular discovery.
|
| 149 |
+
""")
|
| 150 |
+
|
| 151 |
+
with gr.Row():
|
| 152 |
+
with gr.Column(scale=1):
|
| 153 |
+
year = gr.Number(
|
| 154 |
+
label="🕐 Simulation Year (W1 Entry)",
|
| 155 |
+
value=2026,
|
| 156 |
+
info="Target year for temporal analysis"
|
| 157 |
+
)
|
| 158 |
+
with gr.Column(scale=2):
|
| 159 |
+
query = gr.Textbox(
|
| 160 |
+
label="🎯 Initial Threat Query",
|
| 161 |
+
placeholder="Enter threat scenario or research query...",
|
| 162 |
+
info="Describe the threat or research context"
|
| 163 |
+
)
|
| 164 |
+
|
| 165 |
+
run_btn = gr.Button("🚀 Execute Sovereign Cycle", variant="primary", size="lg")
|
| 166 |
+
|
| 167 |
+
with gr.Row():
|
| 168 |
+
with gr.Column():
|
| 169 |
+
logs = gr.JSON(
|
| 170 |
+
label="📊 System Execution Logs",
|
| 171 |
+
show_label=True
|
| 172 |
+
)
|
| 173 |
+
with gr.Column():
|
| 174 |
+
smiles = gr.Textbox(
|
| 175 |
+
label="🧬 Generated Lead Compound (SMILES)",
|
| 176 |
+
info="Molecular structure in SMILES notation"
|
| 177 |
+
)
|
| 178 |
+
|
| 179 |
+
gr.Markdown("""
|
| 180 |
+
### 🔄 Workflow Pipeline:
|
| 181 |
+
1. **Tech Entry Node**: Establishes temporal baseline and technology context
|
| 182 |
+
2. **Strategic Intelligence**: Processes geopolitical and economic factors via DeepSeek-V3
|
| 183 |
+
3. **Bio-Pharma Analysis**: Generates protein structures and molecular leads
|
| 184 |
+
|
| 185 |
+
### 🌐 Connected Spaces:
|
| 186 |
+
- Tech, DeepSeek-V3, War Predictor, Economics, Disease Spillover
|
| 187 |
+
- Protein Predictor, Medical Platform, Visual Processing
|
| 188 |
+
""")
|
| 189 |
+
|
| 190 |
+
run_btn.click(
|
| 191 |
+
run_conductor,
|
| 192 |
+
inputs=[year, query],
|
| 193 |
+
outputs=[logs, smiles]
|
| 194 |
+
)
|
| 195 |
+
|
| 196 |
+
if __name__ == "__main__":
|
| 197 |
+
app.launch()
|
requirements.txt
ADDED
|
@@ -0,0 +1,4 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
langgraph>=0.0.40
|
| 2 |
+
gradio>=4.0.0
|
| 3 |
+
gradio-client>=0.8.0
|
| 4 |
+
typing-extensions>=4.0.0
|