polka.go

package main

import (
	"chirpy/internal/auth"
	"chirpy/internal/database"
	"encoding/json"
	"errors"
	"net/http"
)

func (cfg *apiConfig) handlePolkaWebhook(w http.ResponseWriter, r *http.Request) {
	type parameters struct {
		Event string `json:"event"`
		Data  struct {
			UserId int `json:"user_id"`
		} `json:"data"`
	}
	type response struct{}

	apiKey, err := auth.GetApiKey(r.Header)
	if err != nil {
		respondWithError(w, http.StatusUnauthorized, "Couldn't find ApiKey")
		return
	}

	if apiKey != cfg.polkaKey {
		respondWithError(w, http.StatusUnauthorized, "Invalid ApiKey")
		return
	}

	decoder := json.NewDecoder(r.Body)
	params := parameters{}
	err = decoder.Decode(&params)
	if err != nil {
		respondWithError(w, http.StatusInternalServerError, "Couldn't decode parameters")
		return
	}

	switch params.Event {
	case "user.upgraded":
		_, err = cfg.DB.UpgradeUser(params.Data.UserId)
		if errors.Is(err, database.ErrNotExist) {
			respondWithError(w, http.StatusNotFound, "User doesn't exist")
			return
		}
		respondWithJSON(w, http.StatusOK, response{})
		return
	default:
		respondWithJSON(w, http.StatusOK, response{})
		return
	}
}