feat: Add more code

cmd/serve.go

@@ -23,7 +23,9 @@ import (
 	backend "github.com/dadav/gorge/internal/backend"
 	config "github.com/dadav/gorge/internal/config"
 	log "github.com/dadav/gorge/internal/log"
+	middleware "github.com/dadav/gorge/internal/middleware"
 	openapi "github.com/dadav/gorge/pkg/gen/v3/openapi"
+	"github.com/go-chi/chi/v5"
 	"github.com/spf13/cobra"
 )
 
@@ -53,15 +55,20 @@ to quickly create a Cobra application.`,
 			releaseService := v3.NewReleaseOperationsApi()
 			searchFilterService := v3.NewSearchFilterOperationsApi()
 			userService := v3.NewUserOperationsApi()
+
+			r := chi.NewRouter()
+			r.Use(middleware.RequireUserAgent)
 			handler := openapi.NewRouter(
 				openapi.NewModuleOperationsAPIController(moduleService),
 				openapi.NewReleaseOperationsAPIController(releaseService),
 				openapi.NewSearchFilterOperationsAPIController(searchFilterService),
 				openapi.NewUserOperationsAPIController(userService),
 			)
 
+			r.Mount("/", handler)
+
 			log.Log.Infof("Listen on %s:%d", config.Bind, config.Port)
-			log.Log.Panic(http.ListenAndServe(fmt.Sprintf("%s:%d", config.Bind, config.Port), handler))
+			log.Log.Panic(http.ListenAndServe(fmt.Sprintf("%s:%d", config.Bind, config.Port), r))
 		} else {
 			log.Log.Panicf("%s version not supported", config.ApiVersion)
 		}

internal/api/v3/module.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"slices"
 	"strings"
 
 	"github.com/dadav/gorge/internal/backend"
@@ -94,12 +95,53 @@ func (s *ModuleOperationsApi) GetModules(ctx context.Context, limit int32, offse
 	allModules := backend.ConfiguredBackend.GetAllModules()
 
 	for _, m := range allModules {
-		if query != "" && (strings.Contains(m.Slug, query) || strings.Contains(m.Owner.Slug, query)) {
-			filtered = append(filtered, *m)
-			continue
+		var filterMatched, filterSet bool
+		if query != "" {
+			filterSet = true
+			filterMatched = strings.Contains(m.Slug, query) || strings.Contains(m.Owner.Slug, query)
+		}
+
+		if tag != "" {
+			filterSet = true
+			filterMatched = slices.Contains(m.CurrentRelease.Tags, tag)
+		}
+
+		if owner != "" {
+			filterSet = true
+			filterMatched = m.Owner.Username == owner
+		}
+
+		if withTasks {
+			filterSet = true
+			filterMatched = len(m.CurrentRelease.Tasks) > 0
+		}
+
+		if withPlans {
+			filterSet = true
+			filterMatched = len(m.CurrentRelease.Plans) > 0
+		}
+
+		if withPdk {
+			filterSet = true
+			filterMatched = m.CurrentRelease.Pdk
+		}
+
+		if premium {
+			filterSet = true
+			filterMatched = m.Premium
+		}
+
+		if excludePremium {
+			filterSet = true
+			filterMatched = !m.Premium
+		}
+
+		if len(endorsements) > 0 {
+			filterSet = true
+			filterMatched = m.Endorsement != nil && slices.Contains(endorsements, *m.Endorsement)
 		}
 
-		if query == "" && tag == "" && owner == "" {
+		if !filterSet || filterMatched {
 			filtered = append(filtered, *m)
 		}
 	}
@@ -126,7 +168,7 @@ func (s *ModuleOperationsApi) GetModules(ctx context.Context, limit int32, offse
 
 	return gen.Response(http.StatusOK, gen.GetModules200Response{
 		Pagination: gen.GetModules200ResponsePagination{
-			Limit:   20,
+			Limit:   limit,
 			Offset:  offset,
 			First:   &firstInf,
 			Current: &currentInf,

internal/middleware/useragent.go

@@ -0,0 +1,33 @@
+package middleware
+
+import (
+	"encoding/json"
+	"net/http"
+)
+
+type UserAgentNotSetResponse struct {
+	Message string   `json:"message,omitempty"`
+	Errors  []string `json:"errors,omitempty"`
+}
+
+func RequireUserAgent(next http.Handler) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		userAgent := r.Header.Get("User-Agent")
+		if userAgent == "" {
+			errorResponse := UserAgentNotSetResponse{
+				Message: "User-Agent header is missing",
+				Errors:  []string{"User-Agent must have some value"},
+			}
+			jsonError, err := json.Marshal(errorResponse)
+			if err != nil {
+				http.Error(w, "Internal Server Error", http.StatusInternalServerError)
+				return
+			}
+			w.Header().Set("Content-Type", "application/json")
+			w.WriteHeader(http.StatusBadRequest)
+			w.Write(jsonError)
+			return
+		}
+		next.ServeHTTP(w, r)
+	})
+}