Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 034bb3eb63 | |||
| 06a50880b7 | |||
| c66b57f9cb | |||
| ba30f84f49 | |||
| 81935daaf5 | |||
| d2260ac797 | |||
| ca6f39a3e8 | |||
| 5eb5bd426a | |||
| 08af3ed38d | |||
| cc5060d317 | |||
| c51e51c9c2 | |||
| f0ec9169c4 |
60
HISTORY.md
60
HISTORY.md
@@ -5,10 +5,70 @@ Changelog
|
|||||||
(unreleased)
|
(unreleased)
|
||||||
------------
|
------------
|
||||||
|
|
||||||
|
Fix
|
||||||
|
~~~
|
||||||
|
- Some cleanup, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
|
||||||
|
0.3.4 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
|
||||||
|
Fix
|
||||||
|
~~~
|
||||||
|
- Fix database init, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
Other
|
||||||
|
~~~~~
|
||||||
|
|
||||||
|
|
||||||
|
0.3.3 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
|
||||||
|
Fix
|
||||||
|
~~~
|
||||||
|
- Fix runtime errors, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
Other
|
||||||
|
~~~~~
|
||||||
|
|
||||||
|
|
||||||
|
0.3.2 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
|
||||||
|
Fix
|
||||||
|
~~~
|
||||||
|
- Add back DB init endpoints, ref NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
Other
|
||||||
|
~~~~~
|
||||||
|
|
||||||
|
|
||||||
|
0.3.1 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
|
||||||
|
Fix
|
||||||
|
~~~
|
||||||
|
- Fix broken Docker build, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
Other
|
||||||
|
~~~~~
|
||||||
|
|
||||||
|
|
||||||
|
0.3.0 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
- Feat: dashboard via NiceGUI, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
|
||||||
|
0.2.2 (2026-04-04)
|
||||||
|
------------------
|
||||||
|
|
||||||
Fix
|
Fix
|
||||||
~~~
|
~~~
|
||||||
- Add missing jijna2 reference, refs NOISSUE. [Simon Diesenreiter]
|
- Add missing jijna2 reference, refs NOISSUE. [Simon Diesenreiter]
|
||||||
|
|
||||||
|
Other
|
||||||
|
~~~~~
|
||||||
|
|
||||||
|
|
||||||
0.2.1 (2026-04-04)
|
0.2.1 (2026-04-04)
|
||||||
------------------
|
------------------
|
||||||
|
|||||||
@@ -0,0 +1 @@
|
|||||||
|
{"dark_mode":false}
|
||||||
@@ -0,0 +1 @@
|
|||||||
|
{"dark_mode":false}
|
||||||
28
ai_software_factory/Makefile
Normal file
28
ai_software_factory/Makefile
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
.PHONY: help run-api run-frontend run-tests init-db clean
|
||||||
|
|
||||||
|
help:
|
||||||
|
@echo "Available targets:"
|
||||||
|
@echo " make run-api - Run FastAPI app with NiceGUI frontend (default)"
|
||||||
|
@echo " make run-tests - Run pytest tests"
|
||||||
|
@echo " make init-db - Initialize database"
|
||||||
|
@echo " make clean - Remove container volumes"
|
||||||
|
@echo " make rebuild - Rebuild and run container"
|
||||||
|
|
||||||
|
run-api:
|
||||||
|
@echo "Starting FastAPI app with NiceGUI frontend..."
|
||||||
|
@bash start.sh dev
|
||||||
|
|
||||||
|
run-frontend:
|
||||||
|
@echo "NiceGUI is now integrated with FastAPI - use 'make run-api' to start everything together"
|
||||||
|
|
||||||
|
run-tests:
|
||||||
|
pytest -v
|
||||||
|
|
||||||
|
init-db:
|
||||||
|
@python -c "from main import app; from database import init_db; init_db()"
|
||||||
|
|
||||||
|
clean:
|
||||||
|
@echo "Cleaning up..."
|
||||||
|
@docker-compose down -v
|
||||||
|
|
||||||
|
rebuild: clean run-api
|
||||||
@@ -1 +1 @@
|
|||||||
0.2.2
|
0.3.5
|
||||||
|
|||||||
208
ai_software_factory/dashboard_ui.py
Normal file
208
ai_software_factory/dashboard_ui.py
Normal file
@@ -0,0 +1,208 @@
|
|||||||
|
"""NiceGUI dashboard for AI Software Factory with real-time database data."""
|
||||||
|
|
||||||
|
from nicegui import ui
|
||||||
|
from database import get_db, get_engine, init_db, get_db_sync
|
||||||
|
from models import ProjectHistory, ProjectLog, AuditTrail, UserAction, SystemLog, AgentAction
|
||||||
|
from datetime import datetime
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
def create_dashboard():
|
||||||
|
"""Create and configure the NiceGUI dashboard with real-time data from database."""
|
||||||
|
|
||||||
|
# Get database session directly for NiceGUI (not a FastAPI dependency)
|
||||||
|
db_session = get_db_sync()
|
||||||
|
|
||||||
|
if db_session is None:
|
||||||
|
ui.label('Database session could not be created. Check configuration and restart the server.')
|
||||||
|
return
|
||||||
|
|
||||||
|
try:
|
||||||
|
# Wrap database queries to handle missing tables gracefully
|
||||||
|
try:
|
||||||
|
# Fetch current project
|
||||||
|
current_project = db_session.query(ProjectHistory).order_by(ProjectHistory.created_at.desc()).first()
|
||||||
|
|
||||||
|
# Fetch recent audit trail entries
|
||||||
|
recent_audits = db_session.query(AuditTrail).order_by(AuditTrail.created_at.desc()).limit(10).all()
|
||||||
|
|
||||||
|
# Fetch recent project history entries
|
||||||
|
recent_projects = db_session.query(ProjectHistory).order_by(ProjectHistory.created_at.desc()).limit(5).all()
|
||||||
|
|
||||||
|
# Fetch recent system logs
|
||||||
|
recent_logs = db_session.query(SystemLog).order_by(SystemLog.created_at.desc()).limit(5).all()
|
||||||
|
except Exception as e:
|
||||||
|
# Handle missing tables or other database errors
|
||||||
|
ui.label(f'Database error: {str(e)}. Please run POST /init-db or ensure the database is initialized.')
|
||||||
|
return
|
||||||
|
|
||||||
|
# Create main card
|
||||||
|
with ui.card().classes('w-full max-w-6xl mx-auto').props('elevated').style('max-width: 1200px; margin: 0 auto;') as main_card:
|
||||||
|
# Header section
|
||||||
|
with ui.row().classes('items-center gap-4 mb-6').style('padding: 20px; background: linear-gradient(135deg, #667eea 0%, #764ba2 100%); border-radius: 12px; color: white;') as header_row:
|
||||||
|
title = ui.label('AI Software Factory').style('font-size: 28px; font-weight: bold; margin: 0;')
|
||||||
|
subtitle = ui.label('Real-time Dashboard & Audit Trail Display').style('font-size: 14px; opacity: 0.9; margin-top: 5px;')
|
||||||
|
|
||||||
|
# Stats grid
|
||||||
|
with ui.grid(columns=4).props('gutter=1').style('margin-top: 15px;') as stats_grid:
|
||||||
|
# Current Project
|
||||||
|
with ui.column().classes('text-center').style('background: rgba(255, 255, 255, 0.1); padding: 15px; border-radius: 8px;') as card1:
|
||||||
|
ui.label('Current Project').style('font-size: 12px; text-transform: uppercase; opacity: 0.8;')
|
||||||
|
project_name = current_project.project_name if current_project else 'No active project'
|
||||||
|
ui.label(project_name).style('font-size: 20px; font-weight: bold; margin-top: 5px;')
|
||||||
|
|
||||||
|
# Active Projects count
|
||||||
|
with ui.column().classes('text-center').style('background: rgba(255, 255, 255, 0.1); padding: 15px; border-radius: 8px;') as card2:
|
||||||
|
ui.label('Active Projects').style('font-size: 12px; text-transform: uppercase; opacity: 0.8;')
|
||||||
|
active_count = len(recent_projects)
|
||||||
|
ui.label(str(active_count)).style('font-size: 20px; font-weight: bold; margin-top: 5px; color: #00ff88;')
|
||||||
|
|
||||||
|
# Code Generated (calculated from history entries)
|
||||||
|
with ui.column().classes('text-center').style('background: rgba(255, 255, 255, 0.1); padding: 15px; border-radius: 8px;') as card3:
|
||||||
|
ui.label('Code Generated').style('font-size: 12px; text-transform: uppercase; opacity: 0.8;')
|
||||||
|
# Count .py files from history
|
||||||
|
code_count = sum(1 for p in recent_projects if 'Generated' in p.message)
|
||||||
|
code_size = sum(p.progress for p in recent_projects) if recent_projects else 0
|
||||||
|
ui.label(f'{code_count} files ({code_size}% total)').style('font-size: 20px; font-weight: bold; margin-top: 5px; color: #ffd93d;')
|
||||||
|
|
||||||
|
# Status
|
||||||
|
with ui.column().classes('text-center').style('background: rgba(255, 255, 255, 0.1); padding: 15px; border-radius: 8px;') as card4:
|
||||||
|
ui.label('Status').style('font-size: 12px; text-transform: uppercase; opacity: 0.8;')
|
||||||
|
status = current_project.status if current_project else 'No active project'
|
||||||
|
ui.label(status).style('font-size: 20px; font-weight: bold; margin-top: 5px; color: #00d4ff;')
|
||||||
|
|
||||||
|
# Separator
|
||||||
|
ui.separator(style='margin: 15px 0; color: rgba(255, 255, 255, 0.3);')
|
||||||
|
|
||||||
|
# Current Status Panel
|
||||||
|
with ui.column().style('background: rgba(255, 255, 255, 0.08); padding: 20px; border-radius: 12px; margin-bottom: 15px;') as status_panel:
|
||||||
|
ui.label('📊 Current Status').style('font-size: 18px; font-weight: bold; color: #4fc3f7; margin-bottom: 10px;')
|
||||||
|
|
||||||
|
with ui.row().classes('items-center gap-4').style('margin-top: 10px;') as progress_row:
|
||||||
|
if current_project:
|
||||||
|
ui.label('Progress:').style('color: #bdbdbd;')
|
||||||
|
ui.label(str(current_project.progress) + '%').style('color: #4fc3f7; font-weight: bold;')
|
||||||
|
ui.label('').style('color: #bdbdbd;')
|
||||||
|
else:
|
||||||
|
ui.label('No active project').style('color: #bdbdbd;')
|
||||||
|
|
||||||
|
if current_project:
|
||||||
|
ui.label(current_project.message).style('color: #888; margin-top: 8px; font-size: 13px;')
|
||||||
|
ui.label('Last update: ' + current_project.updated_at.strftime('%H:%M:%S')).style('color: #bdbdbd; font-size: 12px; margin-top: 5px;')
|
||||||
|
else:
|
||||||
|
ui.label('Waiting for a new project...').style('color: #888; margin-top: 8px; font-size: 13px;')
|
||||||
|
|
||||||
|
# Separator
|
||||||
|
ui.separator(style='margin: 15px 0; color: rgba(255, 255, 255, 0.3);')
|
||||||
|
|
||||||
|
# Active Projects Section
|
||||||
|
with ui.column().style('background: rgba(255, 255, 255, 0.08); padding: 20px; border-radius: 12px; margin-bottom: 15px;') as projects_section:
|
||||||
|
ui.label('📁 Active Projects').style('font-size: 18px; font-weight: bold; color: #81c784; margin-bottom: 10px;')
|
||||||
|
|
||||||
|
with ui.row().style('gap: 10px;') as projects_list:
|
||||||
|
for i, project in enumerate(recent_projects[:3], 1):
|
||||||
|
with ui.card().props('elevated rounded').style('background: rgba(0, 255, 136, 0.15); border: 1px solid rgba(0, 255, 136, 0.4);') as project_item:
|
||||||
|
ui.label(str(i + len(recent_projects)) + '. ' + project.project_name).style('font-size: 16px; font-weight: bold; color: white;')
|
||||||
|
ui.label('• Agent: Orchestrator').style('font-size: 12px; color: #bdbdbd;')
|
||||||
|
ui.label('• Status: ' + project.status).style('font-size: 11px; color: #81c784; margin-top: 3px;')
|
||||||
|
if not recent_projects:
|
||||||
|
ui.label('No active projects yet.').style('font-size: 14px; color: #bdbdbd;')
|
||||||
|
|
||||||
|
# Separator
|
||||||
|
ui.separator(style='margin: 15px 0; color: rgba(255, 255, 255, 0.3);')
|
||||||
|
|
||||||
|
# Audit Trail Section
|
||||||
|
with ui.column().style('background: rgba(255, 255, 255, 0.08); padding: 20px; border-radius: 12px; margin-bottom: 15px;') as audit_section:
|
||||||
|
ui.label('📜 Audit Trail').style('font-size: 18px; font-weight: bold; color: #ffe082; margin-bottom: 10px;')
|
||||||
|
|
||||||
|
with ui.data_table(
|
||||||
|
headers=['Timestamp', 'Component', 'Action', 'Level'],
|
||||||
|
columns=[
|
||||||
|
{'name': 'Timestamp', 'field': 'created_at', 'width': '180px'},
|
||||||
|
{'name': 'Component', 'field': 'component', 'width': '150px'},
|
||||||
|
{'name': 'Action', 'field': 'action', 'width': '250px'},
|
||||||
|
{'name': 'Level', 'field': 'log_level', 'width': '100px'},
|
||||||
|
],
|
||||||
|
row_height=36,
|
||||||
|
) as table:
|
||||||
|
# Populate table with audit trail data
|
||||||
|
audit_rows = []
|
||||||
|
for audit in recent_audits:
|
||||||
|
status = 'Success' if audit.log_level.upper() in ['INFO', 'SUCCESS'] else audit.log_level.upper()
|
||||||
|
audit_rows.append({
|
||||||
|
'created_at': audit.created_at.strftime('%Y-%m-%d %H:%M:%S'),
|
||||||
|
'component': audit.component or 'System',
|
||||||
|
'action': audit.action or audit.message[:50],
|
||||||
|
'log_level': status[:15],
|
||||||
|
})
|
||||||
|
table.rows = audit_rows
|
||||||
|
|
||||||
|
if not recent_audits:
|
||||||
|
ui.label('No audit trail entries yet.').style('font-size: 12px; color: #bdbdbd;')
|
||||||
|
|
||||||
|
# Separator
|
||||||
|
ui.separator(style='margin: 15px 0; color: rgba(255, 255, 255, 0.3);')
|
||||||
|
|
||||||
|
# System Logs Section
|
||||||
|
with ui.column().style('background: rgba(255, 255, 255, 0.08); padding: 20px; border-radius: 12px;') as logs_section:
|
||||||
|
ui.label('⚙️ System Logs').style('font-size: 18px; font-weight: bold; color: #ff8a80; margin-bottom: 10px;')
|
||||||
|
|
||||||
|
with ui.data_table(
|
||||||
|
headers=['Component', 'Level', 'Message'],
|
||||||
|
columns=[
|
||||||
|
{'name': 'Component', 'field': 'component', 'width': '150px'},
|
||||||
|
{'name': 'Level', 'field': 'log_level', 'width': '100px'},
|
||||||
|
{'name': 'Message', 'field': 'log_message', 'width': '450px'},
|
||||||
|
],
|
||||||
|
row_height=32,
|
||||||
|
) as logs_table:
|
||||||
|
logs_table.rows = [
|
||||||
|
{
|
||||||
|
'component': log.component,
|
||||||
|
'log_level': log.log_level,
|
||||||
|
'log_message': log.log_message[:50] + '...' if len(log.log_message) > 50 else log.log_message
|
||||||
|
}
|
||||||
|
for log in recent_logs
|
||||||
|
]
|
||||||
|
|
||||||
|
if not recent_logs:
|
||||||
|
ui.label('No system logs yet.').style('font-size: 12px; color: #bdbdbd;')
|
||||||
|
|
||||||
|
# Separator
|
||||||
|
ui.separator(style='margin: 15px 0; color: rgba(255, 255, 255, 0.3);')
|
||||||
|
|
||||||
|
# API Endpoints Section
|
||||||
|
with ui.expansion_group('🔗 Available API Endpoints', default_open=True).props('dense') as api_section:
|
||||||
|
with ui.column().style('font-size: 12px; color: #78909c;') as endpoint_list:
|
||||||
|
endpoints = [
|
||||||
|
['/ (root)', 'Dashboard'],
|
||||||
|
['/generate', 'Generate new software (POST)'],
|
||||||
|
['/health', 'Health check'],
|
||||||
|
['/projects', 'List all projects'],
|
||||||
|
['/status/{project_id}', 'Get project status'],
|
||||||
|
['/audit/projects', 'Get project audit data'],
|
||||||
|
['/audit/logs', 'Get system logs'],
|
||||||
|
['/audit/trail', 'Get audit trail'],
|
||||||
|
['/audit/actions', 'Get user actions'],
|
||||||
|
['/audit/history', 'Get project history'],
|
||||||
|
['/audit/prompts', 'Get prompts'],
|
||||||
|
['/audit/changes', 'Get code changes'],
|
||||||
|
['/init-db', 'Initialize database (POST)'],
|
||||||
|
]
|
||||||
|
for endpoint, desc in endpoints:
|
||||||
|
ui.label(f'• {endpoint:<30} {desc}')
|
||||||
|
finally:
|
||||||
|
db_session.close()
|
||||||
|
|
||||||
|
|
||||||
|
def run_app(port=None, reload=False, browser=True, storage_secret=None):
|
||||||
|
"""Run the NiceGUI app."""
|
||||||
|
ui.run(title='AI Software Factory Dashboard', port=port, reload=reload, browser=browser, storage_secret=storage_secret)
|
||||||
|
|
||||||
|
|
||||||
|
# Create and run the app
|
||||||
|
if __name__ in {'__main__', '__console__'}:
|
||||||
|
create_dashboard()
|
||||||
|
run_app()
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
"""Database connection and session management."""
|
"""Database connection and session management."""
|
||||||
|
|
||||||
from sqlalchemy import create_engine, event
|
from sqlalchemy import create_engine, text
|
||||||
from sqlalchemy.orm import sessionmaker, Session
|
from sqlalchemy.orm import sessionmaker, Session
|
||||||
from config import settings
|
from config import settings
|
||||||
from models import Base
|
from models import Base
|
||||||
@@ -66,20 +66,6 @@ def get_session() -> Session:
|
|||||||
return session_factory
|
return session_factory
|
||||||
|
|
||||||
|
|
||||||
def init_db() -> None:
|
|
||||||
"""Initialize database tables."""
|
|
||||||
engine = get_engine()
|
|
||||||
Base.metadata.create_all(bind=engine)
|
|
||||||
print("Database tables created successfully.")
|
|
||||||
|
|
||||||
|
|
||||||
def drop_db() -> None:
|
|
||||||
"""Drop all database tables (use with caution!)."""
|
|
||||||
engine = get_engine()
|
|
||||||
Base.metadata.drop_all(bind=engine)
|
|
||||||
print("Database tables dropped successfully.")
|
|
||||||
|
|
||||||
|
|
||||||
def get_db() -> Session:
|
def get_db() -> Session:
|
||||||
"""Dependency for FastAPI routes that need database access."""
|
"""Dependency for FastAPI routes that need database access."""
|
||||||
engine = get_engine()
|
engine = get_engine()
|
||||||
@@ -92,12 +78,102 @@ def get_db() -> Session:
|
|||||||
session.close()
|
session.close()
|
||||||
|
|
||||||
|
|
||||||
|
def get_db_sync() -> Session:
|
||||||
|
"""Get a database session directly (for non-FastAPI/NiceGUI usage)."""
|
||||||
|
engine = get_engine()
|
||||||
|
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
|
||||||
|
session = SessionLocal()
|
||||||
|
return session
|
||||||
|
|
||||||
|
|
||||||
def get_db_session() -> Session:
|
def get_db_session() -> Session:
|
||||||
"""Get a database session directly (for non-FastAPI usage)."""
|
"""Get a database session directly (for non-FastAPI usage)."""
|
||||||
session = next(get_session())
|
session = next(get_session())
|
||||||
return session
|
return session
|
||||||
|
|
||||||
|
|
||||||
|
def init_db() -> dict:
|
||||||
|
"""Initialize database tables and database if needed."""
|
||||||
|
if settings.USE_SQLITE:
|
||||||
|
# SQLite - auto-creates file and tables
|
||||||
|
engine = get_engine()
|
||||||
|
try:
|
||||||
|
Base.metadata.create_all(bind=engine)
|
||||||
|
print("SQLite database tables created successfully.")
|
||||||
|
return {'status': 'success', 'message': 'SQLite database initialized.'}
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error initializing SQLite database: {str(e)}")
|
||||||
|
return {'status': 'error', 'message': f'Error: {str(e)}'}
|
||||||
|
else:
|
||||||
|
# PostgreSQL
|
||||||
|
db_url = settings.POSTGRES_URL or settings.database_url
|
||||||
|
db_name = db_url.split('/')[-1] if '/' in db_url else 'ai_software_factory'
|
||||||
|
|
||||||
|
try:
|
||||||
|
# Create engine to check/create database
|
||||||
|
engine = create_engine(db_url)
|
||||||
|
|
||||||
|
# Try to create database if it doesn't exist
|
||||||
|
try:
|
||||||
|
with engine.connect() as conn:
|
||||||
|
# Check if database exists
|
||||||
|
result = conn.execute(text(f"SELECT 1 FROM {db_name} WHERE 1=0"))
|
||||||
|
# If no error, database exists
|
||||||
|
conn.commit()
|
||||||
|
print(f"PostgreSQL database '{db_name}' already exists.")
|
||||||
|
except Exception as e:
|
||||||
|
# Database doesn't exist or has different error - try to create it
|
||||||
|
error_msg = str(e).lower()
|
||||||
|
# Only create if it's a relation does not exist error or similar
|
||||||
|
if "does not exist" in error_msg or "database" in error_msg:
|
||||||
|
try:
|
||||||
|
conn = engine.connect()
|
||||||
|
conn.execute(text(f"CREATE DATABASE {db_name}"))
|
||||||
|
conn.commit()
|
||||||
|
print(f"PostgreSQL database '{db_name}' created.")
|
||||||
|
except Exception as db_error:
|
||||||
|
print(f"Could not create database: {str(db_error)}")
|
||||||
|
# Try to connect anyway - maybe using existing db name
|
||||||
|
engine = create_engine(db_url.replace(f'/{db_name}', '/postgres'))
|
||||||
|
with engine.connect() as conn:
|
||||||
|
# Just create tables in postgres database for now
|
||||||
|
print(f"Using existing 'postgres' database.")
|
||||||
|
|
||||||
|
# Create tables
|
||||||
|
Base.metadata.create_all(bind=engine)
|
||||||
|
print(f"PostgreSQL database '{db_name}' tables created successfully.")
|
||||||
|
return {'status': 'success', 'message': f'PostgreSQL database "{db_name}" initialized.'}
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error initializing PostgreSQL database: {str(e)}")
|
||||||
|
return {'status': 'error', 'message': f'Error: {str(e)}'}
|
||||||
|
|
||||||
|
|
||||||
|
def drop_db() -> dict:
|
||||||
|
"""Drop all database tables (use with caution!)."""
|
||||||
|
if settings.USE_SQLITE:
|
||||||
|
engine = get_engine()
|
||||||
|
try:
|
||||||
|
Base.metadata.drop_all(bind=engine)
|
||||||
|
print("SQLite database tables dropped successfully.")
|
||||||
|
return {'status': 'success', 'message': 'SQLite tables dropped.'}
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error dropping SQLite tables: {str(e)}")
|
||||||
|
return {'status': 'error', 'message': str(e)}
|
||||||
|
else:
|
||||||
|
db_url = settings.POSTGRES_URL or settings.database_url
|
||||||
|
db_name = db_url.split('/')[-1] if '/' in db_url else 'ai_software_factory'
|
||||||
|
|
||||||
|
try:
|
||||||
|
engine = create_engine(db_url)
|
||||||
|
Base.metadata.drop_all(bind=engine)
|
||||||
|
print(f"PostgreSQL database '{db_name}' tables dropped successfully.")
|
||||||
|
return {'status': 'success', 'message': f'PostgreSQL "{db_name}" tables dropped.'}
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error dropping PostgreSQL tables: {str(e)}")
|
||||||
|
return {'status': 'error', 'message': str(e)}
|
||||||
|
|
||||||
|
|
||||||
def create_migration_script() -> str:
|
def create_migration_script() -> str:
|
||||||
"""Generate a migration script for database schema changes."""
|
"""Generate a migration script for database schema changes."""
|
||||||
return '''-- Migration script for AI Software Factory database
|
return '''-- Migration script for AI Software Factory database
|
||||||
|
|||||||
32
ai_software_factory/frontend.py
Normal file
32
ai_software_factory/frontend.py
Normal file
@@ -0,0 +1,32 @@
|
|||||||
|
"""Frontend module for NiceGUI with FastAPI integration.
|
||||||
|
|
||||||
|
This module provides the NiceGUI frontend that can be initialized with a FastAPI app.
|
||||||
|
The dashboard shown is from dashboard_ui.py with real-time database data.
|
||||||
|
"""
|
||||||
|
|
||||||
|
from fastapi import FastAPI
|
||||||
|
|
||||||
|
from nicegui import app, ui
|
||||||
|
from dashboard_ui import create_dashboard
|
||||||
|
|
||||||
|
|
||||||
|
def init(fastapi_app: FastAPI, storage_secret: str = 'Secr2t!') -> None:
|
||||||
|
"""Initialize the NiceGUI frontend with the FastAPI app.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
fastapi_app: The FastAPI application instance.
|
||||||
|
storage_secret: Optional secret for persistent user storage.
|
||||||
|
"""
|
||||||
|
|
||||||
|
@ui.page('/show')
|
||||||
|
def show():
|
||||||
|
create_dashboard()
|
||||||
|
|
||||||
|
# NOTE dark mode will be persistent for each user across tabs and server restarts
|
||||||
|
ui.dark_mode().bind_value(app.storage.user, 'dark_mode')
|
||||||
|
ui.checkbox('dark mode').bind_value(app.storage.user, 'dark_mode')
|
||||||
|
|
||||||
|
ui.run_with(
|
||||||
|
fastapi_app,
|
||||||
|
storage_secret=storage_secret, # NOTE setting a secret is optional but allows for persistent storage per user
|
||||||
|
)
|
||||||
File diff suppressed because it is too large
Load Diff
@@ -1,10 +1,10 @@
|
|||||||
fastapi==0.109.0
|
fastapi>=0.135.3
|
||||||
uvicorn[standard]==0.27.0
|
uvicorn[standard]==0.27.0
|
||||||
sqlalchemy==2.0.25
|
sqlalchemy==2.0.25
|
||||||
psycopg2-binary==2.9.9
|
psycopg2-binary==2.9.9
|
||||||
pydantic==2.5.3
|
pydantic==2.12.5
|
||||||
pydantic-settings==2.1.0
|
pydantic-settings==2.1.0
|
||||||
python-multipart==0.0.6
|
python-multipart==0.0.22
|
||||||
aiofiles==23.2.1
|
aiofiles==23.2.1
|
||||||
python-telegram-bot==20.7
|
python-telegram-bot==20.7
|
||||||
requests==2.31.0
|
requests==2.31.0
|
||||||
@@ -15,4 +15,4 @@ isort==5.13.2
|
|||||||
flake8==6.1.0
|
flake8==6.1.0
|
||||||
mypy==1.7.1
|
mypy==1.7.1
|
||||||
httpx==0.25.2
|
httpx==0.25.2
|
||||||
jinja2==3.1.3
|
nicegui==3.9.0
|
||||||
17
ai_software_factory/start.sh
Normal file
17
ai_software_factory/start.sh
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
|
# use path of this example as working directory; enables starting this script from anywhere
|
||||||
|
cd "$(dirname "$0")"
|
||||||
|
|
||||||
|
if [ "$1" = "prod" ]; then
|
||||||
|
echo "Starting Uvicorn server in production mode..."
|
||||||
|
# we also use a single worker in production mode so socket.io connections are always handled by the same worker
|
||||||
|
uvicorn main:app --workers 1 --log-level info --port 80
|
||||||
|
elif [ "$1" = "dev" ]; then
|
||||||
|
echo "Starting Uvicorn server in development mode..."
|
||||||
|
# reload implies workers = 1
|
||||||
|
uvicorn main:app --reload --log-level debug --port 8000
|
||||||
|
else
|
||||||
|
echo "Invalid parameter. Use 'prod' or 'dev'."
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
@@ -1,385 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
||||||
<title>AI Software Factory Dashboard</title>
|
|
||||||
<style>
|
|
||||||
* {
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
box-sizing: border-box;
|
|
||||||
}
|
|
||||||
|
|
||||||
body {
|
|
||||||
font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
|
|
||||||
background: linear-gradient(135deg, #1a1a2e 0%, #16213e 100%);
|
|
||||||
min-height: 100vh;
|
|
||||||
color: #fff;
|
|
||||||
padding: 20px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.dashboard {
|
|
||||||
max-width: 1200px;
|
|
||||||
margin: 0 auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
.header {
|
|
||||||
text-align: center;
|
|
||||||
padding: 30px;
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.header h1 {
|
|
||||||
font-size: 2.5em;
|
|
||||||
margin-bottom: 10px;
|
|
||||||
background: linear-gradient(90deg, #00d4ff, #00ff88);
|
|
||||||
-webkit-background-clip: text;
|
|
||||||
-webkit-text-fill-color: transparent;
|
|
||||||
background-clip: text;
|
|
||||||
}
|
|
||||||
|
|
||||||
.header p {
|
|
||||||
color: #888;
|
|
||||||
font-size: 1.1em;
|
|
||||||
}
|
|
||||||
|
|
||||||
.stats-grid {
|
|
||||||
display: grid;
|
|
||||||
grid-template-columns: repeat(auto-fit, minmax(250px, 1fr));
|
|
||||||
gap: 20px;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.stat-card {
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
padding: 25px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.stat-card h3 {
|
|
||||||
font-size: 0.9em;
|
|
||||||
color: #888;
|
|
||||||
margin-bottom: 10px;
|
|
||||||
text-transform: uppercase;
|
|
||||||
letter-spacing: 1px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.stat-card .value {
|
|
||||||
font-size: 2.5em;
|
|
||||||
font-weight: bold;
|
|
||||||
color: #00d4ff;
|
|
||||||
}
|
|
||||||
|
|
||||||
.stat-card.project .value { color: #00ff88; }
|
|
||||||
.stat-card.active .value { color: #ff6b6b; }
|
|
||||||
.stat-card.code .value { color: #ffd93d; }
|
|
||||||
|
|
||||||
.status-panel {
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
padding: 25px;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-panel h2 {
|
|
||||||
font-size: 1.3em;
|
|
||||||
margin-bottom: 15px;
|
|
||||||
color: #00d4ff;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-bar {
|
|
||||||
height: 20px;
|
|
||||||
background: #2a2a4a;
|
|
||||||
border-radius: 10px;
|
|
||||||
overflow: hidden;
|
|
||||||
margin-bottom: 10px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-fill {
|
|
||||||
height: 100%;
|
|
||||||
background: linear-gradient(90deg, #00d4ff, #00ff88);
|
|
||||||
border-radius: 10px;
|
|
||||||
transition: width 0.5s ease;
|
|
||||||
}
|
|
||||||
|
|
||||||
.message {
|
|
||||||
padding: 10px;
|
|
||||||
background: rgba(0, 212, 255, 0.1);
|
|
||||||
border-radius: 8px;
|
|
||||||
border-left: 4px solid #00d4ff;
|
|
||||||
}
|
|
||||||
|
|
||||||
.projects-section {
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
padding: 25px;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.projects-section h2 {
|
|
||||||
font-size: 1.3em;
|
|
||||||
margin-bottom: 15px;
|
|
||||||
color: #00ff88;
|
|
||||||
}
|
|
||||||
|
|
||||||
.projects-list {
|
|
||||||
display: flex;
|
|
||||||
flex-wrap: wrap;
|
|
||||||
gap: 15px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.project-item {
|
|
||||||
background: rgba(0, 255, 136, 0.1);
|
|
||||||
padding: 15px 20px;
|
|
||||||
border-radius: 10px;
|
|
||||||
border: 1px solid rgba(0, 255, 136, 0.3);
|
|
||||||
font-size: 0.9em;
|
|
||||||
}
|
|
||||||
|
|
||||||
.project-item.active {
|
|
||||||
background: rgba(255, 107, 107, 0.1);
|
|
||||||
border-color: rgba(255, 107, 107, 0.3);
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-section {
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
padding: 25px;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-section h2 {
|
|
||||||
font-size: 1.3em;
|
|
||||||
margin-bottom: 15px;
|
|
||||||
color: #ffd93d;
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-table {
|
|
||||||
width: 100%;
|
|
||||||
border-collapse: collapse;
|
|
||||||
margin-top: 10px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-table th, .audit-table td {
|
|
||||||
padding: 12px;
|
|
||||||
text-align: left;
|
|
||||||
border-bottom: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-table th {
|
|
||||||
color: #888;
|
|
||||||
font-weight: 600;
|
|
||||||
font-size: 0.85em;
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-table td {
|
|
||||||
font-size: 0.9em;
|
|
||||||
}
|
|
||||||
|
|
||||||
.audit-table .timestamp {
|
|
||||||
color: #666;
|
|
||||||
font-size: 0.8em;
|
|
||||||
}
|
|
||||||
|
|
||||||
.actions-panel {
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
border-radius: 15px;
|
|
||||||
padding: 25px;
|
|
||||||
border: 1px solid rgba(255, 255, 255, 0.1);
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.actions-panel h2 {
|
|
||||||
font-size: 1.3em;
|
|
||||||
margin-bottom: 15px;
|
|
||||||
color: #ff6b6b;
|
|
||||||
}
|
|
||||||
|
|
||||||
.actions-panel p {
|
|
||||||
color: #888;
|
|
||||||
margin-bottom: 20px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.loading {
|
|
||||||
text-align: center;
|
|
||||||
padding: 50px;
|
|
||||||
color: #888;
|
|
||||||
}
|
|
||||||
|
|
||||||
@media (max-width: 768px) {
|
|
||||||
.stats-grid {
|
|
||||||
grid-template-columns: 1fr;
|
|
||||||
}
|
|
||||||
|
|
||||||
.projects-list {
|
|
||||||
flex-direction: column;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="dashboard">
|
|
||||||
<div class="header">
|
|
||||||
<h1>🚀 AI Software Factory</h1>
|
|
||||||
<p>Real-time Dashboard & Audit Trail Display</p>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="stats-grid">
|
|
||||||
<div class="stat-card project">
|
|
||||||
<h3>Current Project</h3>
|
|
||||||
<div class="value" id="project-name">Loading...</div>
|
|
||||||
</div>
|
|
||||||
<div class="stat-card active">
|
|
||||||
<h3>Active Projects</h3>
|
|
||||||
<div class="value" id="active-projects">0</div>
|
|
||||||
</div>
|
|
||||||
<div class="stat-card code">
|
|
||||||
<h3>Total Projects</h3>
|
|
||||||
<div class="value" id="total-projects">0</div>
|
|
||||||
</div>
|
|
||||||
<div class="stat-card">
|
|
||||||
<h3>Status</h3>
|
|
||||||
<div class="value" id="status-value">Loading...</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="status-panel">
|
|
||||||
<h2>📊 Current Status</h2>
|
|
||||||
<div class="status-bar">
|
|
||||||
<div class="status-fill" id="status-fill" style="width: 0%"></div>
|
|
||||||
</div>
|
|
||||||
<div class="message" id="status-message">Loading...</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="projects-section">
|
|
||||||
<h2>📁 Active Projects</h2>
|
|
||||||
<div class="projects-list" id="projects-list">
|
|
||||||
<div class="loading">Loading projects...</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="audit-section">
|
|
||||||
<h2>📜 Audit Trail</h2>
|
|
||||||
<table class="audit-table">
|
|
||||||
<thead>
|
|
||||||
<tr>
|
|
||||||
<th>Timestamp</th>
|
|
||||||
<th>Agent</th>
|
|
||||||
<th>Action</th>
|
|
||||||
<th>Status</th>
|
|
||||||
</tr>
|
|
||||||
</thead>
|
|
||||||
<tbody id="audit-trail-body">
|
|
||||||
<tr>
|
|
||||||
<td class="timestamp">Loading...</td>
|
|
||||||
<td>-</td>
|
|
||||||
<td>-</td>
|
|
||||||
<td>-</td>
|
|
||||||
</tr>
|
|
||||||
</tbody>
|
|
||||||
</table>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="actions-panel">
|
|
||||||
<h2>⚙️ System Actions</h2>
|
|
||||||
<p id="actions-message">Dashboard is rendering successfully.</p>
|
|
||||||
<p style="color: #888; font-size: 0.9em;">This dashboard is powered by the AI Software Factory and displays real-time status updates, audit trails, and project information.</p>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<script>
|
|
||||||
// Fetch data from API
|
|
||||||
async function loadDashboardData() {
|
|
||||||
try {
|
|
||||||
// Load projects
|
|
||||||
const projectsResponse = await fetch('/projects');
|
|
||||||
const projectsData = await projectsResponse.json();
|
|
||||||
updateProjects(projectsData.projects);
|
|
||||||
|
|
||||||
// Get latest active project
|
|
||||||
const activeProject = projectsData.projects.find(p => p.status === 'RUNNING' || p.status === 'IN_PROGRESS');
|
|
||||||
|
|
||||||
if (activeProject) {
|
|
||||||
document.getElementById('project-name').textContent = activeProject.project_name || activeProject.project_id;
|
|
||||||
updateStatusPanel(activeProject);
|
|
||||||
|
|
||||||
// Load audit trail for this project
|
|
||||||
const auditResponse = await fetch(`/audit/trail?limit=10`);
|
|
||||||
const auditData = await auditResponse.json();
|
|
||||||
updateAuditTrail(auditData.audit_trail);
|
|
||||||
} else {
|
|
||||||
// No active project, show all projects
|
|
||||||
document.getElementById('projects-list').innerHTML = projectsData.projects.map(p =>
|
|
||||||
`<div class="project-item ${p.status === 'RUNNING' || p.status === 'IN_PROGRESS' ? 'active' : ''}">
|
|
||||||
<strong>${p.project_name || p.project_id}</strong> • ${p.status} • ${p.progress || 0}%
|
|
||||||
</div>`
|
|
||||||
).join('');
|
|
||||||
}
|
|
||||||
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error loading dashboard data:', error);
|
|
||||||
document.getElementById('status-message').innerHTML =
|
|
||||||
`<strong>Error:</strong> Failed to load dashboard data. Please check the console for details.`;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function updateProjects(projects) {
|
|
||||||
const activeProjects = projects.filter(p => p.status === 'RUNNING' || p.status === 'IN_PROGRESS' || p.status === 'COMPLETED').length;
|
|
||||||
document.getElementById('active-projects').textContent = activeProjects;
|
|
||||||
document.getElementById('total-projects').textContent = projects.length;
|
|
||||||
}
|
|
||||||
|
|
||||||
function updateStatusPanel(project) {
|
|
||||||
const progress = project.progress || 0;
|
|
||||||
document.getElementById('status-fill').style.width = progress + '%';
|
|
||||||
document.getElementById('status-message').innerHTML =
|
|
||||||
`<strong>${project.message || 'Project running...'}</strong><br>` +
|
|
||||||
`<span style="color: #888;">Progress: ${progress}%</span>`;
|
|
||||||
document.getElementById('status-value').textContent = project.status;
|
|
||||||
}
|
|
||||||
|
|
||||||
function updateAuditTrail(auditEntries) {
|
|
||||||
if (auditEntries.length === 0) {
|
|
||||||
document.getElementById('audit-trail-body').innerHTML =
|
|
||||||
`<tr><td colspan="4" style="text-align: center; color: #888;">No audit entries yet</td></tr>`;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const formattedEntries = auditEntries.map(entry => ({
|
|
||||||
...entry,
|
|
||||||
timestamp: entry.timestamp ? new Date(entry.timestamp).toLocaleString() : '-'
|
|
||||||
}));
|
|
||||||
|
|
||||||
document.getElementById('audit-trail-body').innerHTML = formattedEntries.map(entry => `
|
|
||||||
<tr>
|
|
||||||
<td class="timestamp">${entry.timestamp}</td>
|
|
||||||
<td>${entry.actor || '-'}</td>
|
|
||||||
<td>${entry.action || entry.details || '-'}</td>
|
|
||||||
<td style="color: ${getStatusColor(entry.action_type || entry.status)};">${entry.action_type || entry.status || '-'}</td>
|
|
||||||
</tr>
|
|
||||||
`).join('');
|
|
||||||
}
|
|
||||||
|
|
||||||
function getStatusColor(status) {
|
|
||||||
if (!status) return '#888';
|
|
||||||
const upper = status.toUpperCase();
|
|
||||||
if (['SUCCESS', 'COMPLETED', 'FINISHED'].includes(upper)) return '#00ff88';
|
|
||||||
if (['IN_PROGRESS', 'RUNNING', 'PENDING'].includes(upper)) return '#00d4ff';
|
|
||||||
if (['ERROR', 'FAILED', 'FAILED'].includes(upper)) return '#ff6b6b';
|
|
||||||
return '#888';
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load data when dashboard is ready
|
|
||||||
loadDashboardData();
|
|
||||||
</script>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
Reference in New Issue
Block a user