| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283 |
- package main
- import (
- "context"
- "flag"
- "fmt"
- "log"
- "net/http"
- "os"
- "os/signal"
- "syscall"
- "time"
- "proxmox-router/internal/api"
- "proxmox-router/internal/firewall"
- "proxmox-router/internal/network"
- "proxmox-router/internal/routing"
- "proxmox-router/internal/vpn"
- "proxmox-router/internal/web"
- )
- func main() {
- addr := flag.String("addr", ":8080", "HTTP service address (e.g. :8080 or :80)")
- metaPath := flag.String("meta", "/etc/proxmox-router/metadata.json", "Path to interface metadata storage file")
- flag.Parse()
- // Initialize components
- metaMgr := network.NewMetadataManager(*metaPath)
- netMgr := network.NewManager(metaMgr)
- persistMgr := network.NewPersistenceManager(netMgr)
- vpnMgr := vpn.NewManager()
- fwMgr := firewall.NewFirewallManager()
- routingMgr := routing.NewRoutingManager()
- webHandler := web.Handler()
- srv := api.NewServer(netMgr, persistMgr, metaMgr, vpnMgr, fwMgr, routingMgr, webHandler)
- httpServer := &http.Server{
- Addr: *addr,
- Handler: srv,
- ReadTimeout: 15 * time.Second,
- WriteTimeout: 15 * time.Second,
- IdleTimeout: 60 * time.Second,
- }
- // Print startup banner
- fmt.Println("========================================================")
- fmt.Println(" ⚡ Proxmox RouterOS Appliance Controller ⚡ ")
- fmt.Println("========================================================")
- fmt.Printf(" Listening on : http://0.0.0.0%s\n", *addr)
- fmt.Printf(" Metadata Storage : %s\n", *metaPath)
- fmt.Printf(" Debian Config Path : %s\n", network.DebianVlansCfgPath)
- if ifaces, err := netMgr.ListInterfaces(); err == nil {
- fmt.Printf(" Discovered Links : %d interfaces\n", len(ifaces))
- for _, i := range ifaces {
- fmt.Printf(" - %-10s (%s) [%s] MTU:%d\n", i.Name, i.Type, i.State, i.MTU)
- }
- }
- fmt.Println("========================================================")
- fmt.Println(" Web UI & API ready. Press Ctrl+C to terminate.")
- // Graceful shutdown handling
- stopChan := make(chan os.Signal, 1)
- signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)
- go func() {
- if err := httpServer.ListenAndServe(); err != nil && err != http.ErrServerClosed {
- log.Fatalf("HTTP server failed: %v", err)
- }
- }()
- <-stopChan
- fmt.Println("\nShutting down RouterOS Controller gracefully...")
- ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
- defer cancel()
- if err := httpServer.Shutdown(ctx); err != nil {
- log.Printf("Server shutdown error: %v", err)
- }
- fmt.Println("RouterOS Controller stopped.")
- }
|