from core.database import SchedulerDatabase
from datetime import datetime
import json

db = SchedulerDatabase()

# Cerca job DataHub
print("=== JOB DATAHUB ===")
jobs = db.get_all_jobs()
datahub_jobs = [j for j in jobs if 'datahub' in j['name'].lower()]
for job in datahub_jobs:
    print(f"\nJob ID: {job['id']}")
    print(f"Nome: {job['name']}")
    print(f"Schedule Type: {job['schedule_type']}")
    print(f"Schedule Config: {job['schedule_config']}")
    print(f"Enabled: {job['enabled']}")

# Cerca schedule DataHub
print("\n\n=== SCHEDULE DATAHUB ===")
schedules = db.get_all_schedules()
datahub_schedules = [s for s in schedules if 'datahub' in s.get('name', '').lower()]
for sched in datahub_schedules:
    print(f"\nSchedule ID: {sched['id']}")
    print(f"Nome: {sched['name']}")
    print(f"Target Type: {sched['target_type']}")
    print(f"Target ID: {sched['target_id']}")
    print(f"Schedule Type: {sched['schedule_type']}")
    print(f"Schedule Config: {sched['schedule_config']}")
    print(f"Enabled: {sched['enabled']}")

# Esecuzioni DataHub oggi
print("\n\n=== ESECUZIONI DATAHUB OGGI ===")
today = datetime.now().date()
execs = db.get_recent_executions(limit=100)
today_execs = [e for e in execs if e.get('start_time') and str(today) in str(e['start_time']) and 'datahub' in e.get('schedule_name', '').lower()]

for ex in today_execs[:10]:
    print(f"\nExecution ID: {ex['id']}")
    print(f"Schedule: {ex.get('schedule_name', 'N/A')}")
    print(f"Start Time: {ex['start_time']}")
    print(f"Status: {ex['status']}")
    print(f"Triggered By: {ex.get('triggered_by', 'N/A')}")