main.go

package main

import (
	"encoding/json"
	"log"
	"net/http"

	"github.com/eser/sanitizer-svc/email"
)

type SanitizeResponse struct {
	IsValid      bool   `json:"isValid"`
	Sanitized    string `json:"sanitized"`
	IsDisposable bool   `json:"isDisposable"`
}

func sanitizeHandler(disposableList map[string]struct{}) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		// Only allow GET requests
		if r.Method != http.MethodGet {
			http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
			return
		}

		// Get email from query parameters
		emailParam := r.URL.Query().Get("email")
		if emailParam == "" {
			http.Error(w, "Email parameter is required", http.StatusBadRequest)
			return
		}

		isValid := email.Validate(emailParam)
		var sanitized string
		var isDisposable bool

		if isValid {
			sanitized = email.Sanitize(emailParam)

			isDisposable = email.IsDisposable(disposableList, sanitized)
		}

		response := SanitizeResponse{
			IsValid:      isValid,
			Sanitized:    sanitized,
			IsDisposable: isDisposable,
		}

		// Set content type header
		w.Header().Set("Content-Type", "application/json")

		// Encode and send response
		if err := json.NewEncoder(w).Encode(response); err != nil {
			http.Error(w, "Error encoding response", http.StatusInternalServerError)
			return
		}
	}
}

func main() {
	disposableList, err := email.LoadDisposableList("disposable_email_blocklist.conf")
	if err != nil {
		log.Fatal(err)
	}

	// Create a new ServeMux
	mux := http.NewServeMux()

	// Register routes
	mux.HandleFunc("/sanitize", sanitizeHandler(disposableList))

	// Start server
	log.Println("Server starting on :8080")
	if err := http.ListenAndServe(":8080", mux); err != nil {
		log.Fatal(err)
	}
}