151 lines
3.2 KiB
Go
151 lines
3.2 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
"sync"
|
|
"time"
|
|
|
|
"envguard/internal/models"
|
|
)
|
|
|
|
var (
|
|
services = []models.Service{}
|
|
mu sync.Mutex
|
|
dataFile = "services.json"
|
|
)
|
|
|
|
func main() {
|
|
if err := loadServices(); err != nil {
|
|
log.Printf("⚠️ No se pudo cargar services.json, usando defaults: %v", err)
|
|
services = []models.Service{
|
|
{Name: "auth-service"},
|
|
{Name: "payments-api"},
|
|
{Name: "user-db"},
|
|
{Name: "notifications"},
|
|
{Name: "front-web"},
|
|
}
|
|
} else {
|
|
fmt.Printf("✅ %d servicios cargados desde disco\n", len(services))
|
|
}
|
|
|
|
http.HandleFunc("/services", handleServices)
|
|
http.HandleFunc("/lock", handleLock)
|
|
http.HandleFunc("/unlock", handleUnlock)
|
|
|
|
fmt.Println("🚦 Lock Server corriendo en :8080")
|
|
if err := http.ListenAndServe(":8080", nil); err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
}
|
|
|
|
func loadServices() error {
|
|
file, err := os.Open(dataFile)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer file.Close()
|
|
return json.NewDecoder(file).Decode(&services)
|
|
}
|
|
|
|
func saveServices() error {
|
|
file, err := os.Create(dataFile)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer file.Close()
|
|
|
|
encoder := json.NewEncoder(file)
|
|
encoder.SetIndent("", " ")
|
|
return encoder.Encode(services)
|
|
}
|
|
|
|
func handleServices(w http.ResponseWriter, r *http.Request) {
|
|
mu.Lock()
|
|
defer mu.Unlock()
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
json.NewEncoder(w).Encode(services)
|
|
}
|
|
|
|
func handleLock(w http.ResponseWriter, r *http.Request) {
|
|
if r.Method != http.MethodPost {
|
|
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
|
|
var req models.LockRequest
|
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
mu.Lock()
|
|
defer mu.Unlock()
|
|
|
|
for i := range services {
|
|
if services[i].Name == req.ServiceName {
|
|
if services[i].IsLocked {
|
|
http.Error(w, "Service already locked", http.StatusConflict)
|
|
return
|
|
}
|
|
services[i].IsLocked = true
|
|
services[i].LockedBy = req.User
|
|
services[i].LockedAt = time.Now()
|
|
|
|
if err := saveServices(); err != nil {
|
|
log.Printf("Error guardando estado: %v", err)
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
return
|
|
}
|
|
}
|
|
|
|
http.Error(w, "Service not found", http.StatusNotFound)
|
|
}
|
|
|
|
func handleUnlock(w http.ResponseWriter, r *http.Request) {
|
|
if r.Method != http.MethodPost {
|
|
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
|
|
var req models.UnlockRequest
|
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
mu.Lock()
|
|
defer mu.Unlock()
|
|
|
|
for i := range services {
|
|
if services[i].Name == req.ServiceName {
|
|
if !services[i].IsLocked {
|
|
http.Error(w, "Service is not locked", http.StatusBadRequest)
|
|
return
|
|
}
|
|
if services[i].LockedBy != req.User {
|
|
http.Error(w, "You cannot unlock a service locked by someone else", http.StatusForbidden)
|
|
return
|
|
}
|
|
services[i].IsLocked = false
|
|
services[i].LockedBy = ""
|
|
services[i].LockedAt = time.Time{}
|
|
|
|
if err := saveServices(); err != nil {
|
|
log.Printf("Error guardando estado: %v", err)
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
return
|
|
}
|
|
}
|
|
|
|
http.Error(w, "Service not found", http.StatusNotFound)
|
|
}
|