añadir endpoint para hacer search por centro y no solo por cedula #5

api/centers/centers.go

@@ -0,0 +1,93 @@
+package centers
+
+import (
+	"api/db"
+)
+
+type ActaInfo struct {
+	Mesa             int    `json:"mesa"`
+	VotosValidos     int    `json:"votos_validos"`
+	VotosNulos       int    `json:"votos_nulos"`
+	EdmundoGonzalez  int    `json:"edmundo_gonzalez"`
+	NicolasMaduro    int    `json:"nicolas_maduro"`
+	LuisMartinez     int    `json:"luis_martinez"`
+	JavierBertucci   int    `json:"javier_bertucci"`
+	JoseBrito        int    `json:"jose_brito"`
+	AntonioEcarri    int    `json:"antonio_ecarri"`
+	ClaudioFermin    int    `json:"claudio_fermin"`
+	DanielCeballos   int    `json:"daniel_ceballos"`
+	EnriqueMarquez   int    `json:"enrique_marquez"`
+	BenjamminRausseo int    `json:"benjammin_rausseo"`
+	URL              string `json:"url"`
+}
+
+type CenterInfo struct {
+	Centro                int        `json:"centro"`
+	Estado                string     `json:"estado"`
+	Municipio             string     `json:"municipio"`
+	Parroquia             string     `json:"parroquia"`
+	TotalValidos          int        `json:"total_validos"`
+	TotalNulos            int        `json:"total_nulos"`
+	TotalEdmundoGonzalez  int        `json:"total_edmundo_gonzalez"`
+	TotalNicolasMaduro    int        `json:"total_nicolas_maduro"`
+	TotalLuisMartinez     int        `json:"total_luis_martinez"`
+	TotalJavierBertucci   int        `json:"total_javier_bertucci"`
+	TotalJoseBrito        int        `json:"total_jose_brito"`
+	TotalAntonioEcarri    int        `json:"total_antonio_ecarri"`
+	TotalClaudioFermin    int        `json:"total_claudio_fermin"`
+	TotalDanielCeballos   int        `json:"total_daniel_ceballos"`
+	TotalEnriqueMarquez   int        `json:"total_enrique_marquez"`
+	TotalBenjamminRausseo int        `json:"total_benjammin_rausseo"`
+	Actas                 []ActaInfo `json:"actas"`
+}
+
+func GetCenterInfo(dbc *db.Client, centro int) (*CenterInfo, error) {
+	rows, err := db.GetCenterData(dbc, centro)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	var centerInfo CenterInfo
+	var actas []ActaInfo
+
+	for rows.Next() {
+		var acta ActaInfo
+		var codigoEstado, codigoMunicipio, codParroquia int
+		err := rows.Scan(
+			&codigoEstado, &centerInfo.Estado, &codigoMunicipio, &centerInfo.Municipio,
+			&codParroquia, &centerInfo.Parroquia, &acta.Mesa,
+			&acta.VotosValidos, &acta.VotosNulos, &acta.EdmundoGonzalez,
+			&acta.NicolasMaduro, &acta.LuisMartinez, &acta.JavierBertucci,
+			&acta.JoseBrito, &acta.AntonioEcarri, &acta.ClaudioFermin,
+			&acta.DanielCeballos, &acta.EnriqueMarquez, &acta.BenjamminRausseo, &acta.URL)
+		if err != nil {
+			return nil, err
+		}
+
+		// Aggregate totals in CenterInfo
+		centerInfo.TotalValidos += acta.VotosValidos
+		centerInfo.TotalNulos += acta.VotosNulos
+		centerInfo.TotalEdmundoGonzalez += acta.EdmundoGonzalez
+		centerInfo.TotalNicolasMaduro += acta.NicolasMaduro
+		centerInfo.TotalLuisMartinez += acta.LuisMartinez
+		centerInfo.TotalJavierBertucci += acta.JavierBertucci
+		centerInfo.TotalJoseBrito += acta.JoseBrito
+		centerInfo.TotalAntonioEcarri += acta.AntonioEcarri
+		centerInfo.TotalClaudioFermin += acta.ClaudioFermin
+		centerInfo.TotalDanielCeballos += acta.DanielCeballos
+		centerInfo.TotalEnriqueMarquez += acta.EnriqueMarquez
+		centerInfo.TotalBenjamminRausseo += acta.BenjamminRausseo
+
+		actas = append(actas, acta)
+	}
+
+	centerInfo.Centro = centro
+	centerInfo.Actas = actas
+
+	if err = rows.Err(); err != nil {
+		return nil, err
+	}
+
+	return &centerInfo, nil
+}

api/centers/handler.go

@@ -0,0 +1,66 @@
+package centers
+
+import (
+	"api/db"
+	"database/sql"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"log/slog"
+	"net/http"
+	"strconv"
+)
+
+type ResponseErr struct {
+	Error string `json:"error"`
+}
+
+func Handler(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+
+	centroStr := r.URL.Query().Get("centro")
+	if centroStr == "" {
+		writeErr(w, "<none>", "missing required param 'centro'", http.StatusBadRequest)
+		return
+	}
+
+	centro, err := strconv.Atoi(centroStr)
+	if err != nil {
+		writeErr(w, centroStr, "invalid 'centro' parameter", http.StatusBadRequest)
+		return
+	}
+
+	dbc, err := db.New()
+	if err != nil {
+		writeErr(w, centroStr, "database connection error", http.StatusInternalServerError)
+		return
+	}
+	defer dbc.Close()
+
+	centerInfo, err := GetCenterInfo(dbc, centro)
+	if err != nil {
+		if errors.Is(err, sql.ErrNoRows) {
+			writeErr(w, centroStr, "no data found for the given centro", http.StatusNotFound)
+		} else {
+			writeErr(w, centroStr, err.Error(), http.StatusInternalServerError)
+		}
+		return
+	}
+
+	jsonResponse, err := json.Marshal(centerInfo)
+	if err != nil {
+		writeErr(w, centroStr, "error encoding response", http.StatusInternalServerError)
+		return
+	}
+
+	slog.Info(fmt.Sprintf("successful request for centro %s", centroStr))
+	w.WriteHeader(http.StatusOK)
+	w.Write(jsonResponse)
+}
+
+func writeErr(w http.ResponseWriter, centro string, msg string, code int) {
+	slog.Error(fmt.Sprintf("failed request for centro %s: %s", centro, msg))
+	resp, _ := json.Marshal(ResponseErr{Error: msg})
+	w.WriteHeader(code)
+	w.Write(resp)
+}

api/centers/retry.go

@@ -0,0 +1,25 @@
+package centers
+
+import (
+	"fmt"
+	"log/slog"
+	"time"
+)
+
+func retry[T any](f func() (*T, error), n int, delayMillis int) (*T, error) {
+	attempts := 0
+	for {
+		t, e := f()
+		if e != nil {
+			if attempts < n {
+				attempts++
+				slog.Info(fmt.Sprintf("failed on attempt %d. sleeping and retrying", attempts))
+				time.Sleep(time.Duration(delayMillis) * time.Millisecond)
+				continue
+			} else {
+				return nil, e
+			}
+		}
+		return t, nil
+	}
+}

api/cmd/store_results_MCM/main.go

@@ -0,0 +1,25 @@
+package main
+
+import (
+	"api/db"
+	"log"
+)
+
+func main() {
+	dbc, err := db.New()
+	if err != nil {
+		log.Fatalf("Failed to connect to database: %v", err)
+	}
+	defer dbc.Close()
+
+	err = dbc.InitTablesMCM()
+	if err != nil {
+		log.Fatalf("Failed to initialize tables: %v", err)
+	}
+
+	// Import data into the 'actas_mcm' table
+	err = dbc.ImportCSVForMariaCorina()
+	if err != nil {
+		log.Fatalf("Failed to import data: %v", err)
+	}
+}