polka.go

package main

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

	"github.com/google/uuid"
	"github.com/mdmdj/bootdev-chirpy/internal/auth"
)

type polkaWebhooksRequest struct {
	Event string `json:"event"`
	Data  struct {
		UserID string `json:"user_id"`
	} `json:"data"`
}

func polkaWebhooksRoute(w http.ResponseWriter, r *http.Request) {
	requestParams := polkaWebhooksRequest{}

	decoder := json.NewDecoder(r.Body)
	err := decoder.Decode(&requestParams)
	if err != nil {
		log.Printf("polkaWebhooksRoute Error decoding polkaWebhooksRequest parameters: %s", err)
		respondWithError(w, http.StatusBadRequest, "400 Bad Request")
		return
	}

	apiKey, err := auth.GetAPIKey(r.Header)
	if err != nil {
		log.Printf("polkaWebhooksRoute error getting API Key: %s", err)
		respondWithError(w, http.StatusUnauthorized, "401 Unauthorized")
		return
	}

	if apiKey != cfg.polkaKey {
		log.Printf("polkaWebhooksRoute error bad API Key: %s", apiKey)
		respondWithError(w, http.StatusUnauthorized, "401 Unauthorized")
		return
	}

	if requestParams.Event != "user.upgraded" {
		log.Printf("polkaWebhooksRoute skipping unknown event: %s", requestParams.Event)
		w.WriteHeader(http.StatusNoContent)
		return
	}

	userID := requestParams.Data.UserID
	userUUID, err := uuid.Parse(userID)

	if userID == "" || err != nil {
		log.Printf("polkaWebhooksRoute error with data, bad ID: %s", userID)
		respondWithError(w, http.StatusBadRequest, "400 Invalid Data")
		return
	}

	_, err = cfg.db.UpdateUserChirpyRedEnable(r.Context(), userUUID)
	if err != nil {
		log.Printf("polkaWebhooksRoute error with UpdateUserChirpyRedEnable: %s %s", userID, err)
		respondWithError(w, http.StatusNotFound, "404 User Not Found")
	}

	w.WriteHeader(http.StatusNoContent)
}