main.go 2.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. package main
  2. import (
  3. "context"
  4. "flag"
  5. "fmt"
  6. "log"
  7. "net/http"
  8. "os"
  9. "os/signal"
  10. "syscall"
  11. "time"
  12. "proxmox-router/internal/api"
  13. "proxmox-router/internal/dynamicrouting"
  14. "proxmox-router/internal/firewall"
  15. "proxmox-router/internal/network"
  16. "proxmox-router/internal/routing"
  17. "proxmox-router/internal/vpn"
  18. "proxmox-router/internal/web"
  19. )
  20. func main() {
  21. addr := flag.String("addr", ":8080", "HTTP service address (e.g. :8080 or :80)")
  22. metaPath := flag.String("meta", "/etc/proxmox-router/metadata.json", "Path to interface metadata storage file")
  23. flag.Parse()
  24. // Initialize components
  25. metaMgr := network.NewMetadataManager(*metaPath)
  26. netMgr := network.NewManager(metaMgr)
  27. persistMgr := network.NewPersistenceManager(netMgr)
  28. vpnMgr := vpn.NewManager()
  29. fwMgr := firewall.NewFirewallManager()
  30. routingMgr := routing.NewRoutingManager()
  31. dynRoutingMgr := dynamicrouting.NewManager("")
  32. webHandler := web.Handler()
  33. srv := api.NewServer(netMgr, persistMgr, metaMgr, vpnMgr, fwMgr, routingMgr, dynRoutingMgr, webHandler)
  34. httpServer := &http.Server{
  35. Addr: *addr,
  36. Handler: srv,
  37. ReadTimeout: 15 * time.Second,
  38. WriteTimeout: 15 * time.Second,
  39. IdleTimeout: 60 * time.Second,
  40. }
  41. // Print startup banner
  42. fmt.Println("========================================================")
  43. fmt.Println(" ⚡ Proxmox RouterOS Appliance Controller ⚡ ")
  44. fmt.Println("========================================================")
  45. fmt.Printf(" Listening on : http://0.0.0.0%s\n", *addr)
  46. fmt.Printf(" Metadata Storage : %s\n", *metaPath)
  47. fmt.Printf(" Debian Config Path : %s\n", network.DebianVlansCfgPath)
  48. if ifaces, err := netMgr.ListInterfaces(); err == nil {
  49. fmt.Printf(" Discovered Links : %d interfaces\n", len(ifaces))
  50. for _, i := range ifaces {
  51. fmt.Printf(" - %-10s (%s) [%s] MTU:%d\n", i.Name, i.Type, i.State, i.MTU)
  52. }
  53. }
  54. fmt.Println("========================================================")
  55. fmt.Println(" Web UI & API ready. Press Ctrl+C to terminate.")
  56. // Graceful shutdown handling
  57. stopChan := make(chan os.Signal, 1)
  58. signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)
  59. go func() {
  60. if err := httpServer.ListenAndServe(); err != nil && err != http.ErrServerClosed {
  61. log.Fatalf("HTTP server failed: %v", err)
  62. }
  63. }()
  64. <-stopChan
  65. fmt.Println("\nShutting down RouterOS Controller gracefully...")
  66. ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
  67. defer cancel()
  68. if err := httpServer.Shutdown(ctx); err != nil {
  69. log.Printf("Server shutdown error: %v", err)
  70. }
  71. fmt.Println("RouterOS Controller stopped.")
  72. }