Spaces:
Sleeping
Sleeping
| import logging | |
| import os | |
| import threading | |
| from bot.bootstrap_runtime import ( | |
| run_eventsub_mode, | |
| run_irc_mode, | |
| ) | |
| from bot.dashboard_server import run_server | |
| from bot.observability import observability | |
| from bot.runtime_config import ( | |
| TWITCH_CHAT_MODE, | |
| logger, | |
| ) | |
| def main() -> None: | |
| import asyncio | |
| import sys | |
| import traceback | |
| from bot.heartbeat import start_heartbeat | |
| from bot.logic import context_manager | |
| # Auditoria de Ambiente (HF Read-Only Check) | |
| try: | |
| test_file = "/app/write_test.tmp" | |
| with open(test_file, "w") as f: | |
| f.write("test") | |
| os.remove(test_file) | |
| logger.info("Environment Audit: Write permissions OK") | |
| except Exception as e: | |
| logger.warning("Environment Audit: Write permissions restricted: %s", e) | |
| # Injeta o loop principal | |
| try: | |
| loop = asyncio.get_event_loop() | |
| context_manager.set_main_loop(loop) | |
| except RuntimeError: | |
| pass | |
| def global_exception_handler(loop, context): | |
| msg = context.get("message") | |
| logger.critical("UNHANDLED ASYNC ERROR: %s", msg) | |
| logger.critical("Context: %s", context) | |
| # Não mata o processo aqui para tentarmos ver o stack trace no log do HF | |
| start_heartbeat() | |
| logger.info("Starting Dashboard Server thread...") | |
| threading.Thread(target=run_server, daemon=True).start() | |
| try: | |
| if TWITCH_CHAT_MODE == "irc": | |
| logger.info("Entering IRC Mode...") | |
| run_irc_mode() | |
| else: | |
| logger.info("Entering EventSub Mode...") | |
| run_eventsub_mode() | |
| except Exception as error: | |
| logger.critical("FATAL CRASH DETECTED") | |
| logger.critical(traceback.format_exc()) | |
| observability.record_error(category="fatal", details=str(error)) | |
| sys.exit(1) | |
| if __name__ == "__main__": | |
| main() | |