package main import ( "encoding/csv" "fmt" "log" "os" "os/exec" "os/signal" "path/filepath" "strconv" "strings" "syscall" "time" "system-altrak/internal/config" "system-altrak/internal/middleware" "system-altrak/internal/service" "system-altrak/pkg/utils" "github.com/gofiber/fiber/v2" ) func getProcessNameByPID(pid string) string { output, err := exec.Command("tasklist", "/FI", "PID eq "+pid, "/FO", "CSV", "/NH").Output() if err != nil { return "" } line := strings.TrimSpace(string(output)) if line == "" || strings.HasPrefix(strings.ToUpper(line), "INFO:") { return "" } r := csv.NewReader(strings.NewReader(line)) record, err := r.Read() if err != nil || len(record) == 0 { return "" } return strings.ToLower(strings.TrimSpace(record[0])) } func buildCleanupAllowedProcesses() map[string]struct{} { allowed := map[string]struct{}{ "go.exe": {}, "server.exe": {}, "system-altrak.exe": {}, } if exe := strings.ToLower(filepath.Base(os.Args[0])); exe != "" { allowed[exe] = struct{}{} } return allowed } func cleanupPort(port string, allowedProcesses map[string]struct{}) { // Proactively clean the configured port in development without killing unrelated processes. cmd := exec.Command("cmd", "/C", "netstat -ano | findstr :"+port) output, err := cmd.Output() if err == nil && len(strings.TrimSpace(string(output))) > 0 { seenPIDs := make(map[string]struct{}) lines := strings.Split(string(output), "\n") for _, line := range lines { if strings.Contains(line, "LISTENING") { fields := strings.Fields(line) if len(fields) > 4 { pid := fields[len(fields)-1] if pid != "0" { if _, exists := seenPIDs[pid]; exists { continue } seenPIDs[pid] = struct{}{} pidInt, convErr := strconv.Atoi(pid) if convErr == nil && pidInt == os.Getpid() { continue } processName := getProcessNameByPID(pid) if processName == "" { log.Printf("[startup] Found PID %s on port %s, but process name could not be resolved; skipping", pid, port) continue } if _, ok := allowedProcesses[processName]; !ok { log.Printf("[startup] Port %s is used by %s (PID %s); skip auto-kill for non-allowlisted process", port, processName, pid) continue } log.Printf("[startup] Reclaiming port %s from %s (PID %s)", port, processName, pid) if killErr := exec.Command("taskkill", "/PID", pid, "/T").Run(); killErr != nil { log.Printf("[startup] Graceful taskkill failed for PID %s, forcing stop: %v", pid, killErr) if forceErr := exec.Command("taskkill", "/F", "/PID", pid, "/T").Run(); forceErr != nil { log.Printf("[startup] Force stop failed for PID %s: %v", pid, forceErr) continue } } time.Sleep(500 * time.Millisecond) } } } } } } func main() { // ── 1. Bootstrap ───────────────────────────────────────────────────────── utils.InitLogger() cfg := config.LoadConfig() middleware.SetCSRFSecret(cfg.CSRFSecret) // Bersihkan port secara proaktif di development (hindari port conflict) if cfg.AutoKillPortOnStartup && cfg.Environment != "production" { cleanupPort(cfg.AppPort, buildCleanupAllowedProcesses()) } // ── 2. Database & Token Blacklist ───────────────────────────────────────── db := config.InitDB(cfg) config.SeedDB(db, cfg) utils.SetTokenBlacklist(service.NewDBTokenBlacklist(db)) // ── 3. Dependency Injection — inisialisasi semua modul di routes.go ─────── handlers, services := initHandlers(db, cfg) // ── 4. Setup Fiber App ──────────────────────────────────────────────────── appConfig, err := buildFiberConfig(cfg) if err != nil { log.Fatal(err) } app := fiber.New(appConfig) // ── 5. Global Middleware ────────────────────────────────────────────────── registerMiddlewares(app, cfg) // ── 6. Routes ───────────────────────────────────────────────────────────── registerRoutes(app, cfg, db, handlers, services) log.Printf("[startup] ✅ Operational Intelligence Hub siap pada port %s (mode: %s)", cfg.AppPort, cfg.Environment) // ── 7. Graceful Shutdown ────────────────────────────────────────────────── // Tangkap sinyal OS (SIGTERM dari Docker/systemd, SIGINT dari Ctrl+C). // Server menyelesaikan request aktif (PDF/import) sebelum benar-benar berhenti. quit := make(chan os.Signal, 1) signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) serverErr := make(chan error, 1) go func() { if err := app.Listen(":" + cfg.AppPort); err != nil { serverErr <- err } }() select { case err := <-serverErr: log.Fatalf("[startup] Server error: %v", err) case sig := <-quit: log.Printf("[shutdown] Menerima sinyal %v — memulai graceful shutdown...", sig) } shutdownTimeout := 30 * time.Second log.Printf("[shutdown] Menunggu request aktif selesai (timeout: %v)...", shutdownTimeout) if err := app.ShutdownWithTimeout(shutdownTimeout); err != nil { log.Printf("[shutdown] Timeout saat shutdown: %v", err) } services.scheduler.Stop() log.Println("[shutdown] ✅ Server berhenti dengan bersih.") } func buildFiberConfig(cfg *config.Config) (fiber.Config, error) { if cfg == nil { return fiber.Config{}, fmt.Errorf("config is nil") } proxyHeader := strings.TrimSpace(cfg.ProxyHeader) if proxyHeader == "" { proxyHeader = fiber.HeaderXForwardedFor } trustedProxies := buildTrustedProxies(cfg) if cfg.TrustProxy && len(trustedProxies) == 0 && !cfg.TrustProxyUnixSocket { return fiber.Config{}, fmt.Errorf("TRUST_PROXY is enabled but no trusted proxies are configured") } return fiber.Config{ ErrorHandler: middleware.GlobalErrorHandler, EnableTrustedProxyCheck: cfg.TrustProxy, TrustedProxies: trustedProxies, ProxyHeader: proxyHeader, EnableIPValidation: cfg.EnableIPValidation || cfg.TrustProxy, BodyLimit: 100 * 1024 * 1024, // 100MB limit for large Excel imports ReadTimeout: 60 * time.Second, WriteTimeout: 60 * time.Second, IdleTimeout: 120 * time.Second, }, nil } func buildTrustedProxies(cfg *config.Config) []string { if cfg == nil { return nil } trustedProxies := make([]string, 0, len(cfg.TrustProxyProxies)+8) trustedProxies = append(trustedProxies, cfg.TrustProxyProxies...) if cfg.TrustProxyLoopback { trustedProxies = append(trustedProxies, "127.0.0.0/8", "::1/128") } if cfg.TrustProxyLinkLocal { trustedProxies = append(trustedProxies, "169.254.0.0/16", "fe80::/10") } if cfg.TrustProxyPrivate { trustedProxies = append(trustedProxies, "10.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "fc00::/7") } return trustedProxies } func getBeautifulFrontendErrorPage() string { return ` Menghubungkan ke Next.js Frontend...
SAS
PT. Altrak 1978
Menghubungkan Frontend...

Layanan Belum Siap

Backend server Go berjalan sukses, namun Next.js Frontend server (:3000) belum diaktifkan atau sedang memproses inisialisasi awal.

Cara Menjalankan Frontend:
1
Buka terminal baru di sistem Anda.
2
Masuk ke direktori web-client: cd web-client
3
Jalankan server pengembangan: npm run dev
Mencoba menghubungkan kembali secara otomatis setiap 5 detik...
` }