add route to reflect requestbody (#1)

* add route to reflect requestbody

* handle req body more generically

* unmarshal to interface

Author: anuraagnalluri

cmd/server/main.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/gorilla/mux"
 	"github.com/speakeasy-api/speakeasy-auth-test-service/internal/auth"
+	"github.com/speakeasy-api/speakeasy-auth-test-service/internal/requestbody"
 )
 
 func main() {
@@ -14,6 +15,7 @@ func main() {
 		_, _ = w.Write([]byte("pong"))
 	}).Methods(http.MethodGet)
 	r.HandleFunc("/auth", auth.HandleAuth).Methods(http.MethodPost)
+	r.HandleFunc("/requestbody", requestbody.HandleRequestBody).Methods(http.MethodPost)
 
 	log.Println("Listening on :8080")
 	if err := http.ListenAndServe(":8080", r); err != nil {

internal/auth/service.go

@@ -2,9 +2,8 @@ package auth
 
 import (
 	"encoding/json"
-	"errors"
+	"github.com/speakeasy-api/speakeasy-auth-test-service/internal/utils"
 	"io"
-	"log"
 	"net/http"
 
 	"github.com/speakeasy-api/speakeasy-auth-test-service/pkg/models"
@@ -13,39 +12,18 @@ import (
 func HandleAuth(w http.ResponseWriter, r *http.Request) {
 	body, err := io.ReadAll(r.Body)
 	if err != nil {
-		handleError(w, err)
+		utils.HandleError(w, err)
 		return
 	}
 
 	var req models.AuthRequest
 	if err := json.Unmarshal(body, &req); err != nil {
-		handleError(w, err)
+		utils.HandleError(w, err)
 		return
 	}
 
 	if err := checkAuth(req, r); err != nil {
-		handleError(w, err)
+		utils.HandleError(w, err)
 		return
 	}
 }
-
-func handleError(w http.ResponseWriter, err error) {
-	log.Println(err)
-
-	data, marshalErr := json.Marshal(models.ErrorResponse{
-		Error: models.ErrorMessage{
-			Message: err.Error(),
-		},
-	})
-	if marshalErr != nil {
-		w.WriteHeader(http.StatusInternalServerError)
-		return
-	}
-
-	if errors.Is(err, authError) {
-		w.WriteHeader(http.StatusUnauthorized)
-	} else {
-		w.WriteHeader(http.StatusInternalServerError)
-	}
-	_, _ = w.Write(data)
-}

internal/requestbody/service.go

@@ -0,0 +1,28 @@
+package requestbody
+
+import (
+	"encoding/json"
+	"github.com/speakeasy-api/speakeasy-auth-test-service/internal/utils"
+	"io"
+	"net/http"
+)
+
+func HandleRequestBody(w http.ResponseWriter, r *http.Request) {
+	body, err := io.ReadAll(r.Body)
+	if err != nil {
+		utils.HandleError(w, err)
+		return
+	}
+
+	var req interface{}
+	if err := json.Unmarshal(body, &req); err != nil {
+		utils.HandleError(w, err)
+		return
+	}
+
+	w.Header().Set("Content-Type", "application/json; charset=UTF-8")
+
+	if err := json.NewEncoder(w).Encode(req); err != nil {
+		utils.HandleError(w, err)
+	}
+}

internal/utils/utils.go

@@ -0,0 +1,32 @@
+package utils
+
+import (
+	"encoding/json"
+	"errors"
+	"github.com/speakeasy-api/speakeasy-auth-test-service/pkg/models"
+	"log"
+	"net/http"
+)
+
+var authError = errors.New("invalid auth")
+
+func HandleError(w http.ResponseWriter, err error) {
+	log.Println(err)
+
+	data, marshalErr := json.Marshal(models.ErrorResponse{
+		Error: models.ErrorMessage{
+			Message: err.Error(),
+		},
+	})
+	if marshalErr != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		return
+	}
+
+	if errors.Is(err, authError) {
+		w.WriteHeader(http.StatusUnauthorized)
+	} else {
+		w.WriteHeader(http.StatusInternalServerError)
+	}
+	_, _ = w.Write(data)
+}