main_3.go

mux.HandleFunc("GET /consume", func(w http.ResponseWriter, r *http.Request) {
	
	ctx := context.Background()
	code := r.FormValue("code")
	state := r.FormValue("state")

	if state != "state" {
		http.Error(w, "Error, mismatched state", http.StatusBadRequest)
		return
	}

	tok, err := conf.Exchange(ctx, code)
	if err != nil {
		http.Error(w, "Error exchanging token", http.StatusInternalServerError)
		return
	}

	client := conf.Client(ctx, tok)
	res, err := client.Get("https://oauth.wiremockapi.cloud/userinfo")

	if err != nil {
		http.Error(w, "Error fetching data", http.StatusInternalServerError)
		return
	}

	defer res.Body.Close()

	// Set the content type based on the response header
	w.Header().Set("Content-Type", res.Header.Get("Content-Type"))

	// Copy the response body to the client's response writer
	_, err = io.Copy(w, res.Body)
	if err != nil {
		http.Error(w, "Error streaming data", http.StatusInternalServerError)
		return
	}
	
})