feat: add invalidate cache handler

Author: christophwitzko

internal/server/cache.go

@@ -57,12 +57,15 @@ func (s *Server) setInCache(ctx context.Context, k cacheKey, v any, expiration .
 	s.cache.Set(strKey, v, exp)
 }
 
-func (s *Server) invalidateByPrefix(prefix cacheKey) {
+func (s *Server) invalidateByPrefix(prefix cacheKey) int {
+	cnt := 0
 	for k := range s.cache.Items() {
 		if strings.HasPrefix(k, string(prefix)) {
 			s.cache.Delete(k)
+			cnt++
 		}
 	}
+	return cnt
 }
 
 func (s *Server) cacheMiddleware(next http.Handler) http.Handler {

internal/server/server.go

@@ -50,6 +50,15 @@ func (s *Server) indexHandler(w http.ResponseWriter, r *http.Request) {
 	})
 }
 
+func (s *Server) invalidateCacheHandler(w http.ResponseWriter, r *http.Request) {
+	prefix := cacheKey(r.URL.Query().Get("prefix"))
+	deleted := s.invalidateByPrefix(prefix)
+	s.writeJSON(w, map[string]any{
+		"prefix":  prefix,
+		"deleted": deleted,
+	})
+}
+
 func (s *Server) apiV2Routes(r chi.Router) {
 	r.Route("/plugins", func(r chi.Router) {
 		r.With(s.cacheMiddleware).Group(func(r chi.Router) {
@@ -66,6 +75,7 @@ func (s *Server) apiV2Routes(r chi.Router) {
 			r.Put("/", s.updateAllPlugins)
 			r.Put("/{plugin}", s.updatePlugin)
 			r.Put("/{plugin}/versions/{version}", s.updatePlugin)
+			r.Delete("/_cache", s.invalidateCacheHandler)
 		})
 	})
 }