main.go

package main

import (
	"fmt"
	"log"
	"net"
	"os/exec"
	"runtime"
	"time"

	"github.com/user/fastlogscan/internal/analyzer"
	"github.com/user/fastlogscan/internal/logcollector"
	"github.com/user/fastlogscan/internal/models"
	"github.com/user/fastlogscan/internal/osdetector"
	"github.com/user/fastlogscan/internal/server"
)

func main() {
	fmt.Println("========================================")
	fmt.Println("       FastLogScan - Avvio...")
	fmt.Println("========================================")

	// 1. Rileva OS
	osInfo, err := osdetector.Detect()
	if err != nil {
		log.Fatalf("Errore rilevamento OS: %v", err)
	}
	fmt.Printf("OS rilevato: %s %s (%s)\n", osInfo.Name, osInfo.Version, osInfo.Arch)

	// 2. Colleziona log
	collector := logcollector.NewForOS(runtime.GOOS)
	fmt.Printf("Utilizzo collector: %s\n", collector.Name())

	logs, err := collector.Collect()
	if err != nil {
		log.Printf("Attenzione: alcuni log non sono stati raccolti: %v", err)
	}

	if len(logs) == 0 {
		fmt.Println("Nessun log trovato. Caricamento dati di esempio...")
		logs = generateSampleLogs(osInfo.Name)
	} else {
		fmt.Printf("Log raccolti: %d\n", len(logs))
	}

	// 3. Calcola statistiche
	counts := map[string]int{
		"Informativo": 0,
		"Basso":       0,
		"Medio":       0,
		"Alto":        0,
	}
	catMap := make(map[string]bool)
	srcMap := make(map[string]bool)

	for i := range logs {
		counts[logs[i].Severity.String()]++
		catMap[logs[i].Category] = true
		srcMap[logs[i].Source] = true
	}

	var categories, sources []string
	for c := range catMap {
		categories = append(categories, c)
	}
	for s := range srcMap {
		sources = append(sources, s)
	}

	data := &models.DashboardData{
		OS:             osInfo.Name,
		TotalLogs:      len(logs),
		SeverityCounts: counts,
		Logs:           logs,
		Categories:     categories,
		Sources:        sources,
	}

	// 4. Trova porta libera e avvia server
	port := findFreePort()
	srv := server.New(data, port)

	// Apri browser automaticamente
	go func() {
		time.Sleep(900 * time.Millisecond)
		url := fmt.Sprintf("http://localhost:%d", port)
		openBrowser(url)
	}()

	fmt.Printf("\nAvvio dashboard su http://localhost:%d\n", port)
	fmt.Println("Premi CTRL+C per uscire.")
	if err := srv.Start(); err != nil {
		log.Fatalf("Errore server: %v", err)
	}
}

func findFreePort() int {
	listener, err := net.Listen("tcp", ":0")
	if err != nil {
		return 8080
	}
	defer listener.Close()
	return listener.Addr().(*net.TCPAddr).Port
}

func openBrowser(url string) {
	var cmd string
	var args []string

	switch runtime.GOOS {
	case "windows":
		cmd = "rundll32"
		args = []string{"url.dll,FileProtocolHandler", url}
	case "darwin":
		cmd = "open"
		args = []string{url}
	default:
		cmd = "xdg-open"
		args = []string{url}
	}

	exec.Command(cmd, args...).Start()
}

func generateSampleLogs(osName string) []models.LogEntry {
	return []models.LogEntry{
		analyzer.Analyze("demo", "System initialized successfully at 2024-01-15 08:00:00", "boot", osName),
		analyzer.Analyze("demo", "Warning: high memory usage detected (85%) on process chrome.exe", "system", osName),
		analyzer.Analyze("demo", "Error: connection to database failed after 3 retries", "application", osName),
		analyzer.Analyze("demo", "Critical: disk failure predicted on /dev/sda - backup immediately", "hardware", osName),
		analyzer.Analyze("demo", "User authentication succeeded for admin from 192.168.1.5", "security", osName),
		analyzer.Analyze("demo", "Deprecated API call from module legacy.py: use v2 instead", "application", osName),
		analyzer.Analyze("demo", "Service nginx restarted successfully", "services", osName),
		analyzer.Analyze("demo", "Fatal: kernel panic - not syncing: VFS unable to mount root fs", "kernel", osName),
		analyzer.Analyze("demo", "Timeout while connecting to external API gateway", "network", osName),
		analyzer.Analyze("demo", "Notice: scheduled maintenance window starts at 02:00", "maintenance", osName),
	}
}