From 33534728c8c767fcab05e1295f72aabfe08ca71d Mon Sep 17 00:00:00 2001
From: Vincent Boutour <bob@vibioh.fr>
Date: Thu, 29 Dec 2022 12:42:14 +0100
Subject: [PATCH] feat(search): Adding basic saved search crud

Signed-off-by: Vincent Boutour <bob@vibioh.fr>
---
 README.md                                     |   2 +
 cmd/fibr/config.go                            |   3 +
 cmd/fibr/fibr.go                              |   3 +-
 cmd/fibr/templates/files.html                 |  21 ++++
 .../templates/saved-search-folder-modal.html  |  19 ----
 cmd/fibr/templates/saved-search-modal.html    |  39 +++++++
 cmd/fibr/templates/search.html                |   6 +-
 pkg/crud/create.go                            |  39 +++++++
 pkg/crud/delete.go                            |  30 ++++-
 pkg/crud/get.go                               |   6 +-
 pkg/crud/list.go                              |  35 ++++--
 pkg/crud/post.go                              |  11 +-
 pkg/provider/search.go                        |  11 ++
 pkg/search/crud.go                            | 107 ++++++++++++++++++
 pkg/search/search.go                          |  61 +++++++++-
 pkg/share/amqp.go                             |   4 +-
 pkg/share/crud.go                             |   7 +-
 pkg/share/share.go                            |  14 +--
 pkg/webhook/amqp.go                           |   4 +-
 pkg/webhook/crud.go                           |   4 +-
 pkg/webhook/event.go                          |   4 +-
 pkg/webhook/webhook.go                        |  10 +-
 22 files changed, 373 insertions(+), 67 deletions(-)
 delete mode 100644 cmd/fibr/templates/saved-search-folder-modal.html
 create mode 100644 cmd/fibr/templates/saved-search-modal.html
 create mode 100644 pkg/provider/search.go
 create mode 100644 pkg/search/crud.go

diff --git a/README.md b/README.md
index 3b54f5f7..27dc21c8 100644
--- a/README.md
+++ b/README.md
@@ -368,6 +368,8 @@ Usage of fibr:
         [redis] Redis Username, if any {FIBR_REDIS_USERNAME}
   -sanitizeOnStart
         [crud] Sanitize name on start {FIBR_SANITIZE_ON_START}
+  -searchAmqpExclusiveRoutingKey string
+        [search] AMQP Routing Key for exclusive lock on default exchange {FIBR_SEARCH_AMQP_EXCLUSIVE_ROUTING_KEY} (default "fibr.semaphore.search")
   -shareAmqpExchange string
         [share] AMQP Exchange Name {FIBR_SHARE_AMQP_EXCHANGE} (default "fibr.shares")
   -shareAmqpExclusiveRoutingKey string
diff --git a/cmd/fibr/config.go b/cmd/fibr/config.go
index 73513b96..b3007ca1 100644
--- a/cmd/fibr/config.go
+++ b/cmd/fibr/config.go
@@ -9,6 +9,7 @@ import (
 	basicMemory "github.com/ViBiOh/auth/v2/pkg/store/memory"
 	"github.com/ViBiOh/fibr/pkg/crud"
 	"github.com/ViBiOh/fibr/pkg/exif"
+	"github.com/ViBiOh/fibr/pkg/search"
 	"github.com/ViBiOh/fibr/pkg/share"
 	"github.com/ViBiOh/fibr/pkg/storage"
 	"github.com/ViBiOh/fibr/pkg/thumbnail"
@@ -51,6 +52,7 @@ type configuration struct {
 	amqpShare     amqphandler.Config
 	amqpWebhook   amqphandler.Config
 	redis         redis.Config
+	search        search.Config
 	disableAuth   *bool
 }
 
@@ -82,6 +84,7 @@ func newConfig() (configuration, error) {
 		amqpShare:     amqphandler.Flags(fs, "amqpShare", flags.NewOverride("Exchange", "fibr.shares"), flags.NewOverride("Queue", "fibr.share-"+generateIdentityName()), flags.NewOverride("RoutingKey", "share"), flags.NewOverride("Exclusive", true), flags.NewOverride("RetryInterval", time.Duration(0))),
 		amqpWebhook:   amqphandler.Flags(fs, "amqpWebhook", flags.NewOverride("Exchange", "fibr.webhooks"), flags.NewOverride("Queue", "fibr.webhook-"+generateIdentityName()), flags.NewOverride("RoutingKey", "webhook"), flags.NewOverride("Exclusive", true), flags.NewOverride("RetryInterval", time.Duration(0))),
 		redis:         redis.Flags(fs, "redis", flags.NewOverride("Address", "")),
+		search:        search.Flags(fs, "search"),
 		disableAuth:   flags.Bool(fs, "", "auth", "NoAuth", "Disable basic authentification", false, nil),
 	}, fs.Parse(os.Args[1:])
 }
diff --git a/cmd/fibr/fibr.go b/cmd/fibr/fibr.go
index fe9d0594..86186483 100644
--- a/cmd/fibr/fibr.go
+++ b/cmd/fibr/fibr.go
@@ -114,7 +114,8 @@ func main() {
 	amqpWebhookApp, err := amqphandler.New(config.amqpWebhook, client.amqp, client.tracer.GetTracer("amqp_handler_webhook"), webhookApp.AMQPHandler)
 	logger.Fatal(err)
 
-	searchApp := search.New(filteredStorage, thumbnailApp, exifApp, client.tracer.GetTracer("search"))
+	searchApp, err := search.New(config.search, filteredStorage, thumbnailApp, exifApp, client.amqp, client.tracer.GetTracer("search"))
+	logger.Fatal(err)
 
 	crudApp, err := crud.New(config.crud, storageApp, filteredStorage, rendererApp, shareApp, webhookApp, thumbnailApp, exifApp, searchApp, eventBus.Push, client.amqp, client.tracer.GetTracer("crud"))
 	logger.Fatal(err)
diff --git a/cmd/fibr/templates/files.html b/cmd/fibr/templates/files.html
index 3c1b8662..949999d0 100644
--- a/cmd/fibr/templates/files.html
+++ b/cmd/fibr/templates/files.html
@@ -31,6 +31,12 @@
     {{ template "webhook-list" . }}
   {{ end }}
 
+  {{ range .SavedSearches }}
+    {{ if $root.Request.CanEdit }}
+      {{ template "delete-saved-search-modal" . }}
+    {{ end }}
+  {{ end }}
+
   {{ range .Files }}
     {{ if $root.Request.CanEdit }}
       {{ template "edit-modal" . }}
@@ -205,6 +211,21 @@
     </div>
 
     <ul id="files" class="no-margin no-padding">
+      {{ range .SavedSearches }}
+        <li class="file relative padding-half">
+          <a class="filelink center ellipsis" href="?{{ raw .Query }}" title="{{ .Name }}">
+            <img class="icon {{ if eq $root.Request.Display "grid" }}icon-large{{ end }}" src="{{ url "/svg/folder-search?fill=aliceblue" }}" alt="Saved Search">
+            <span class="filename ellipsis {{ if eq $root.Request.Display "list" }}padding-left{{ end }}">{{ .Name }}</span>
+
+            {{ if $root.Request.CanEdit }}
+              <a href="#delete-saved-search-modal-{{ .ID }}" class="button button-icon file-delete" title="Delete">
+                <img class="icon icon-square" src="{{ url "/svg/times?fill=crimson" }}" alt="Delete">
+              </a>
+            {{ end }}
+          </a>
+        </li>
+      {{ end }}
+
       {{ range .Files }}
         <li class="file relative {{ if not .HasThumbnail }}padding-half{{ end }}">
           <a class="filelink center ellipsis" href="{{ .URL }}{{ if .IsDir }}?d={{ $root.Request.LayoutPath ($root.Request.AbsoluteURL .URL) }}{{ else }}?browser{{ end }}" title="{{ .Name }}">
diff --git a/cmd/fibr/templates/saved-search-folder-modal.html b/cmd/fibr/templates/saved-search-folder-modal.html
deleted file mode 100644
index 10b66a27..00000000
--- a/cmd/fibr/templates/saved-search-folder-modal.html
+++ /dev/null
@@ -1,19 +0,0 @@
-{{ define "saved-search-folder-modal" }}
-  <div id="create-saved-search" class="modal saved-search-folder-modal">
-    <div class="modal-content">
-      <h2 class="header">Create new saved-search</h2>
-
-      <form method="post" action="#">
-        <input type="hidden" name="type" value="saved-search-folder" />
-        <input type="hidden" name="method" value="PUT" />
-
-        <p class="padding no-margin">
-          <label for="name" class="block">Name</label>
-          <input id="name" class="full" type="text" name="name" />
-        </p>
-
-        {{ template "form_buttons" "Create" }}
-      </form>
-    </div>
-  </div>
-{{ end }}
diff --git a/cmd/fibr/templates/saved-search-modal.html b/cmd/fibr/templates/saved-search-modal.html
new file mode 100644
index 00000000..6be6c5c7
--- /dev/null
+++ b/cmd/fibr/templates/saved-search-modal.html
@@ -0,0 +1,39 @@
+{{ define "create-saved-search-modal" }}
+  <div id="create-saved-search" class="modal saved-search-modal">
+    <div class="modal-content">
+      <h2 class="header">Create new saved-search</h2>
+
+      <form method="post" action="#">
+        <input type="hidden" name="type" value="saved-search" />
+        <input type="hidden" name="method" value="PUT" />
+
+        <p class="padding no-margin">
+          <label for="name" class="block">Name</label>
+          <input id="name" class="full" type="text" name="name" />
+        </p>
+
+        {{ template "form_buttons" "Create" }}
+      </form>
+    </div>
+  </div>
+{{ end }}
+
+{{ define "delete-saved-search-modal" }}
+  <div id="delete-saved-search-modal-{{ .ID }}" class="modal delete-modal">
+    <div class="modal-content">
+      <h2 class="header">Confirmation</h2>
+
+      <form method="post" action="#">
+        <input type="hidden" name="type" value="saved-search" />
+        <input type="hidden" name="method" value="DELETE" />
+        <input type="hidden" name="name" value="{{ .Name }}" />
+
+        <p class="padding no-margin center">
+          Are you sure you want to delete <strong>{{ .Name }}</strong>?
+        </p>
+
+        {{ template "form_buttons" "Confirm" }}
+      </form>
+    </div>
+  </div>
+{{ end }}
diff --git a/cmd/fibr/templates/search.html b/cmd/fibr/templates/search.html
index d762cb86..54dbac59 100644
--- a/cmd/fibr/templates/search.html
+++ b/cmd/fibr/templates/search.html
@@ -11,12 +11,12 @@
       overflow: auto;
     }
 
-    .saved-search-folder-modal:target {
+    .saved-search-modal:target {
       display: flex;
       z-index: 5;
     }
 
-    .saved-search-folder-modal:target ~ .content {
+    .saved-search-modal:target ~ .content {
       pointer-events: none;
     }
 
@@ -61,7 +61,7 @@
   {{ template "items-style" . }}
 
   {{ if .Request.CanEdit }}
-    {{ template "saved-search-folder-modal" }}
+    {{ template "create-saved-search-modal" }}
   {{ end }}
 
   {{ if .HasMap }}
diff --git a/pkg/crud/create.go b/pkg/crud/create.go
index 445f66f2..7511cb58 100644
--- a/pkg/crud/create.go
+++ b/pkg/crud/create.go
@@ -9,6 +9,7 @@ import (
 	"github.com/ViBiOh/fibr/pkg/provider"
 	"github.com/ViBiOh/httputils/v4/pkg/model"
 	"github.com/ViBiOh/httputils/v4/pkg/renderer"
+	"github.com/ViBiOh/httputils/v4/pkg/sha"
 )
 
 func (a App) Create(w http.ResponseWriter, r *http.Request, request provider.Request) {
@@ -38,3 +39,41 @@ func (a App) Create(w http.ResponseWriter, r *http.Request, request provider.Req
 
 	a.rendererApp.Redirect(w, r, fmt.Sprintf("%s/?d=%s", name, request.Display), renderer.NewSuccessMessage("Directory %s successfully created", path.Base(pathname)))
 }
+
+func (a App) CreateSavedSearch(w http.ResponseWriter, r *http.Request, request provider.Request) {
+	if !request.CanEdit {
+		a.error(w, r, request, model.WrapForbidden(ErrNotAuthorized))
+		return
+	}
+
+	name, err := checkFormName(r, "name")
+	if err != nil && !errors.Is(err, ErrEmptyName) {
+		a.error(w, r, request, err)
+		return
+	}
+
+	name, err = provider.SanitizeName(name, false)
+	if err != nil {
+		a.error(w, r, request, model.WrapInternal(err))
+		return
+	}
+
+	ctx := r.Context()
+
+	item, err := a.storageApp.Info(ctx, request.Filepath())
+	if err != nil {
+		a.error(w, r, request, model.WrapNotFound(err))
+		return
+	}
+
+	if err = a.searchApp.Update(ctx, item, provider.Search{
+		ID:    sha.New(name),
+		Name:  name,
+		Query: r.URL.RawQuery,
+	}); err != nil {
+		a.error(w, r, request, fmt.Errorf("update: %w", err))
+		return
+	}
+
+	a.rendererApp.Redirect(w, r, fmt.Sprintf("?%s", r.URL.RawQuery), renderer.NewSuccessMessage("Saved search %s successfully created", name))
+}
diff --git a/pkg/crud/delete.go b/pkg/crud/delete.go
index 3e292b87..787b87c9 100644
--- a/pkg/crud/delete.go
+++ b/pkg/crud/delete.go
@@ -11,7 +11,6 @@ import (
 	"github.com/ViBiOh/httputils/v4/pkg/tracer"
 )
 
-// Delete given path from filesystem
 func (a App) Delete(w http.ResponseWriter, r *http.Request, request provider.Request) {
 	if !request.CanEdit {
 		a.error(w, r, request, model.WrapForbidden(ErrNotAuthorized))
@@ -52,3 +51,32 @@ func (a App) Delete(w http.ResponseWriter, r *http.Request, request provider.Req
 
 	a.rendererApp.Redirect(w, r, fmt.Sprintf("?d=%s", request.Display), renderer.NewSuccessMessage("%s successfully deleted", info.Name))
 }
+
+// Delete given path from filesystem
+func (a App) DeleteSavedSearch(w http.ResponseWriter, r *http.Request, request provider.Request) {
+	if !request.CanEdit {
+		a.error(w, r, request, model.WrapForbidden(ErrNotAuthorized))
+		return
+	}
+
+	name, err := checkFormName(r, "name")
+	if err != nil && !errors.Is(err, ErrEmptyName) {
+		a.error(w, r, request, err)
+		return
+	}
+
+	ctx := r.Context()
+
+	item, err := a.storageApp.Info(ctx, request.Filepath())
+	if err != nil {
+		a.error(w, r, request, model.WrapNotFound(err))
+		return
+	}
+
+	if err = a.searchApp.Delete(ctx, item, name); err != nil {
+		a.error(w, r, request, err)
+		return
+	}
+
+	a.rendererApp.Redirect(w, r, fmt.Sprintf("?d=%s", request.Display), renderer.NewSuccessMessage("%s successfully deleted", name))
+}
diff --git a/pkg/crud/get.go b/pkg/crud/get.go
index 59502bd7..ba8ea98b 100644
--- a/pkg/crud/get.go
+++ b/pkg/crud/get.go
@@ -35,7 +35,7 @@ func (a App) getWithMessage(w http.ResponseWriter, r *http.Request, request prov
 
 	if err != nil && absto.IsNotExist(err) && provider.StreamExtensions[filepath.Ext(pathname)] {
 		if request.Share.File {
-			// URL with /<share_id>/segment.ts will be the pas `/path/of/shared/file/segment.ts`, so we need to remove two directories before appending segment
+			// URL with /<share_id>/segment.ts will be the path `/path/of/shared/file/segment.ts`, so we need to remove two directories before appending segment
 			pathname = provider.Dirname(path.Dir(path.Dir(pathname))) + path.Base(pathname)
 		}
 
@@ -44,10 +44,10 @@ func (a App) getWithMessage(w http.ResponseWriter, r *http.Request, request prov
 
 	if err != nil {
 		if absto.IsNotExist(err) {
-			return errorReturn(request, model.WrapNotFound(err))
+			err = model.WrapNotFound(err)
 		}
 
-		return errorReturn(request, model.WrapNotFound(err))
+		return errorReturn(request, err)
 	}
 
 	if item.IsDir && !strings.HasSuffix(r.URL.Path, "/") {
diff --git a/pkg/crud/list.go b/pkg/crud/list.go
index fc96ff37..611ebfce 100644
--- a/pkg/crud/list.go
+++ b/pkg/crud/list.go
@@ -64,6 +64,20 @@ func (a App) list(ctx context.Context, request provider.Request, message rendere
 		}
 	}()
 
+	var savedSearches map[string]provider.Search
+	savedSearchDone := make(chan struct{})
+	go func() {
+		defer close(savedSearchDone)
+
+		var err error
+
+		savedSearches, err = a.searchApp.List(ctx, item)
+		if err != nil {
+			listLogger(item.Pathname).Error("list saved searches: %s", err)
+			return
+		}
+	}()
+
 	wg.Wait()
 
 	items := make([]provider.RenderItem, len(files))
@@ -79,16 +93,19 @@ func (a App) list(ctx context.Context, request provider.Request, message rendere
 	<-thumbnailDone
 	hasThumbnail, hasStory, cover := a.enrichThumbnail(ctx, directoryAggregate, items, thumbnails)
 
+	<-savedSearchDone
+
 	content := map[string]any{
-		"Paths":        getPathParts(request),
-		"Files":        items,
-		"Cover":        cover,
-		"Request":      request,
-		"Message":      message,
-		"HasMap":       len(directoryAggregate.Location),
-		"HasThumbnail": hasThumbnail,
-		"HasStory":     hasStory,
-		"ChunkUpload":  a.chunkUpload,
+		"Paths":         getPathParts(request),
+		"Files":         items,
+		"SavedSearches": savedSearches,
+		"Cover":         cover,
+		"Request":       request,
+		"Message":       message,
+		"HasMap":        len(directoryAggregate.Location),
+		"HasThumbnail":  hasThumbnail,
+		"HasStory":      hasStory,
+		"ChunkUpload":   a.chunkUpload,
 	}
 
 	if request.CanShare {
diff --git a/pkg/crud/post.go b/pkg/crud/post.go
index e3d6999b..5652c841 100644
--- a/pkg/crud/post.go
+++ b/pkg/crud/post.go
@@ -200,11 +200,20 @@ func (a App) handlePost(w http.ResponseWriter, r *http.Request, request provider
 		switch putType := r.FormValue("type"); putType {
 		case "folder":
 			a.Create(w, r, request)
+		case "saved-search":
+			a.CreateSavedSearch(w, r, request)
 		default:
 			a.error(w, r, request, model.WrapInvalid(fmt.Errorf("unknown type `%s`", putType)))
 		}
 	case http.MethodDelete:
-		a.Delete(w, r, request)
+		switch putType := r.FormValue("type"); putType {
+		case "file":
+			a.Delete(w, r, request)
+		case "saved-search":
+			a.DeleteSavedSearch(w, r, request)
+		default:
+			a.error(w, r, request, model.WrapInvalid(fmt.Errorf("unknown type `%s`", putType)))
+		}
 	case http.MethodTrace:
 		a.regenerate(w, r, request)
 	default:
diff --git a/pkg/provider/search.go b/pkg/provider/search.go
new file mode 100644
index 00000000..4570e2f5
--- /dev/null
+++ b/pkg/provider/search.go
@@ -0,0 +1,11 @@
+package provider
+
+type Search struct {
+	ID    string `json:"id"`
+	Name  string `json:"name"`
+	Query string `json:"query"`
+}
+
+func (s Search) IsZero() bool {
+	return len(s.Name) != 0
+}
diff --git a/pkg/search/crud.go b/pkg/search/crud.go
new file mode 100644
index 00000000..566c3048
--- /dev/null
+++ b/pkg/search/crud.go
@@ -0,0 +1,107 @@
+package search
+
+import (
+	"context"
+	"fmt"
+	"path/filepath"
+	"time"
+
+	absto "github.com/ViBiOh/absto/pkg/model"
+	"github.com/ViBiOh/fibr/pkg/provider"
+)
+
+const semaphoreDuration = time.Second * 10
+
+func path(item absto.Item) string {
+	if item.IsDir {
+		return provider.MetadataDirectory(item) + "searches.json"
+	}
+
+	return fmt.Sprintf("%s%s.json", provider.MetadataDirectory(item), item.ID)
+}
+
+func (a App) List(ctx context.Context, item absto.Item) (map[string]provider.Search, error) {
+	searches, err := a.load(ctx, item)
+	if err != nil {
+		return nil, fmt.Errorf("load: %w", err)
+	}
+
+	return searches, nil
+}
+
+func (a App) Get(ctx context.Context, item absto.Item, name string) (provider.Search, error) {
+	searches, err := a.List(ctx, item)
+	if err != nil {
+		return provider.Search{}, fmt.Errorf("list: %w", err)
+	}
+
+	return searches[name], nil
+}
+
+func (a App) Update(ctx context.Context, item absto.Item, search provider.Search) error {
+	return a.Exclusive(ctx, a.amqpExclusiveRoutingKey, semaphoreDuration, func(ctx context.Context) error {
+		searches, err := a.load(ctx, item)
+		if err != nil {
+			return fmt.Errorf("load: %w", err)
+		}
+
+		searches[search.Name] = search
+
+		if err = a.save(ctx, item, searches); err != nil {
+			return fmt.Errorf("save: %w", err)
+		}
+
+		return nil
+	})
+}
+
+func (a App) Delete(ctx context.Context, item absto.Item, name string) error {
+	return a.Exclusive(ctx, a.amqpExclusiveRoutingKey, semaphoreDuration, func(ctx context.Context) error {
+		searches, err := a.load(ctx, item)
+		if err != nil {
+			return fmt.Errorf("load: %w", err)
+		}
+
+		delete(searches, name)
+
+		if err = a.save(ctx, item, searches); err != nil {
+			return fmt.Errorf("delete: %w", err)
+		}
+
+		return nil
+	})
+}
+
+func (a App) load(ctx context.Context, item absto.Item) (map[string]provider.Search, error) {
+	output, err := provider.LoadJSON[map[string]provider.Search](ctx, a.storageApp, path(item))
+	if err != nil {
+		if !absto.IsNotExist(err) {
+			return nil, err
+		}
+
+		return make(map[string]provider.Search), nil
+	}
+
+	return output, nil
+}
+
+func (a App) save(ctx context.Context, item absto.Item, content map[string]provider.Search) error {
+	filename := path(item)
+	dirname := filepath.Dir(filename)
+
+	if _, err := a.storageApp.Info(ctx, dirname); err != nil {
+		if !absto.IsNotExist(err) {
+			return fmt.Errorf("check directory existence: %w", err)
+		}
+
+		if err = a.storageApp.CreateDir(ctx, dirname); err != nil {
+			return fmt.Errorf("create directory: %w", err)
+		}
+	}
+
+	if err := provider.SaveJSON(ctx, a.storageApp, filename, content); err != nil {
+		return fmt.Errorf("save: %w", err)
+	}
+
+	return nil
+}
diff --git a/pkg/search/search.go b/pkg/search/search.go
index 731993b5..95ca79b1 100644
--- a/pkg/search/search.go
+++ b/pkg/search/search.go
@@ -1,32 +1,83 @@
 package search
 
 import (
+	"context"
+	"flag"
+	"fmt"
 	"net/http"
+	"strings"
 	"time"
 
 	absto "github.com/ViBiOh/absto/pkg/model"
 	"github.com/ViBiOh/fibr/pkg/exif"
 	"github.com/ViBiOh/fibr/pkg/provider"
 	"github.com/ViBiOh/fibr/pkg/thumbnail"
+	"github.com/ViBiOh/flags"
+	"github.com/ViBiOh/httputils/v4/pkg/amqp"
 	httpModel "github.com/ViBiOh/httputils/v4/pkg/model"
 	"github.com/ViBiOh/httputils/v4/pkg/tracer"
 	"go.opentelemetry.io/otel/trace"
 )
 
+type Config struct {
+	amqpExclusiveRoutingKey *string
+}
+
+func Flags(fs *flag.FlagSet, prefix string) Config {
+	return Config{
+		amqpExclusiveRoutingKey: flags.String(fs, prefix, "search", "AmqpExclusiveRoutingKey", "AMQP Routing Key for exclusive lock on default exchange", "fibr.semaphore.search", nil),
+	}
+}
+
 type App struct {
-	tracer       trace.Tracer
-	storageApp   absto.Storage
-	exifApp      provider.ExifManager
-	thumbnailApp thumbnail.App
+	tracer                  trace.Tracer
+	storageApp              absto.Storage
+	exifApp                 provider.ExifManager
+	amqpClient              *amqp.Client
+	amqpExclusiveRoutingKey string
+	thumbnailApp            thumbnail.App
 }
 
-func New(storageApp absto.Storage, thumbnailApp thumbnail.App, exifApp exif.App, tracer trace.Tracer) App {
+func New(config Config, storageApp absto.Storage, thumbnailApp thumbnail.App, exifApp exif.App, amqpClient *amqp.Client, tracer trace.Tracer) (App, error) {
+	var amqpExclusiveRoutingKey string
+
+	if amqpClient != nil {
+		amqpExclusiveRoutingKey = strings.TrimSpace(*config.amqpExclusiveRoutingKey)
+
+		if err := amqpClient.SetupExclusive(amqpExclusiveRoutingKey); err != nil {
+			return App{}, fmt.Errorf("setup amqp exclusive: %w", err)
+		}
+	}
+
 	return App{
 		tracer:       tracer,
 		storageApp:   storageApp,
 		thumbnailApp: thumbnailApp,
 		exifApp:      exifApp,
+
+		amqpExclusiveRoutingKey: amqpExclusiveRoutingKey,
+	}, nil
+}
+
+func (a App) Exclusive(ctx context.Context, name string, duration time.Duration, action func(ctx context.Context) error) error {
+	if a.amqpClient == nil {
+		return action(ctx)
+	}
+
+exclusive:
+	acquired, err := a.amqpClient.Exclusive(ctx, name, duration, func(ctx context.Context) error {
+		return action(ctx)
+	})
+	if err != nil {
+		return err
 	}
+
+	if !acquired {
+		time.Sleep(time.Second)
+		goto exclusive
+	}
+
+	return nil
 }
 
 func (a App) Files(r *http.Request, request provider.Request) (items []absto.Item, err error) {
diff --git a/pkg/share/amqp.go b/pkg/share/amqp.go
index a2c4162e..ed662ff4 100644
--- a/pkg/share/amqp.go
+++ b/pkg/share/amqp.go
@@ -16,8 +16,8 @@ func (a *App) AMQPHandler(_ context.Context, message amqp.Delivery) error {
 		return fmt.Errorf("decode: %w", err)
 	}
 
-	a.Lock()
-	defer a.Unlock()
+	a.mutex.Lock()
+	defer a.mutex.Unlock()
 
 	if share.Creation.IsZero() {
 		delete(a.shares, share.ID)
diff --git a/pkg/share/crud.go b/pkg/share/crud.go
index 542dbfb9..d6f6806a 100644
--- a/pkg/share/crud.go
+++ b/pkg/share/crud.go
@@ -26,10 +26,9 @@ func (a *App) generateID() (string, error) {
 	}
 }
 
-// List shares
 func (a *App) List() (output []provider.Share) {
-	a.RLock()
-	defer a.RUnlock()
+	a.mutex.RLock()
+	defer a.mutex.RUnlock()
 
 	output = make([]provider.Share, 0, len(a.shares))
 
@@ -46,7 +45,6 @@ func (a *App) List() (output []provider.Share) {
 	return output
 }
 
-// Create a share
 func (a *App) Create(ctx context.Context, filepath string, edit, story bool, password string, isDir bool, duration time.Duration) (string, error) {
 	var id string
 
@@ -87,7 +85,6 @@ func (a *App) Create(ctx context.Context, filepath string, edit, story bool, pas
 	return id, err
 }
 
-// Delete a share
 func (a *App) Delete(ctx context.Context, id string) error {
 	_, err := a.Exclusive(ctx, a.amqpExclusiveRoutingKey, semaphoreDuration, func(_ context.Context) error {
 		return a.delete(ctx, id)
diff --git a/pkg/share/share.go b/pkg/share/share.go
index f93424bb..0eaf0c95 100644
--- a/pkg/share/share.go
+++ b/pkg/share/share.go
@@ -33,7 +33,7 @@ type App struct {
 	amqpRoutingKey          string
 	amqpExclusiveRoutingKey string
 
-	sync.RWMutex
+	mutex sync.RWMutex
 }
 
 type Config struct {
@@ -81,8 +81,8 @@ func New(config Config, storageApp absto.Storage, amqpClient *amqp.Client) (*App
 
 func (a *App) Exclusive(ctx context.Context, name string, duration time.Duration, action func(ctx context.Context) error) (bool, error) {
 	fn := func() error {
-		a.Lock()
-		defer a.Unlock()
+		a.mutex.Lock()
+		defer a.mutex.Unlock()
 
 		if err := a.refresh(ctx); err != nil {
 			return fmt.Errorf("refresh shares: %w", err)
@@ -113,8 +113,8 @@ exclusive:
 func (a *App) Get(requestPath string) provider.Share {
 	cleanPath := strings.TrimPrefix(requestPath, "/")
 
-	a.RLock()
-	defer a.RUnlock()
+	a.mutex.RLock()
+	defer a.mutex.RUnlock()
 
 	for key, share := range a.shares {
 		if strings.HasPrefix(cleanPath, key) {
@@ -143,8 +143,8 @@ func (a *App) Start(ctx context.Context) {
 }
 
 func (a *App) loadShares(ctx context.Context) error {
-	a.Lock()
-	defer a.Unlock()
+	a.mutex.Lock()
+	defer a.mutex.Unlock()
 
 	return a.refresh(ctx)
 }
diff --git a/pkg/webhook/amqp.go b/pkg/webhook/amqp.go
index 447320c2..89afd1d9 100644
--- a/pkg/webhook/amqp.go
+++ b/pkg/webhook/amqp.go
@@ -16,8 +16,8 @@ func (a *App) AMQPHandler(_ context.Context, message amqp.Delivery) error {
 		return fmt.Errorf("decode: %w", err)
 	}
 
-	a.Lock()
-	defer a.Unlock()
+	a.mutex.Lock()
+	defer a.mutex.Unlock()
 
 	if len(webhook.URL) == 0 {
 		delete(a.webhooks, webhook.ID)
diff --git a/pkg/webhook/crud.go b/pkg/webhook/crud.go
index 32756ec8..6a3895de 100644
--- a/pkg/webhook/crud.go
+++ b/pkg/webhook/crud.go
@@ -25,8 +25,8 @@ func (a *App) generateID() (string, error) {
 }
 
 func (a *App) List() (output []provider.Webhook) {
-	a.RLock()
-	defer a.RUnlock()
+	a.mutex.RLock()
+	defer a.mutex.RUnlock()
 
 	output = make([]provider.Webhook, 0, len(a.webhooks))
 
diff --git a/pkg/webhook/event.go b/pkg/webhook/event.go
index 21c2094f..36c6e930 100644
--- a/pkg/webhook/event.go
+++ b/pkg/webhook/event.go
@@ -21,8 +21,8 @@ import (
 const amqpThumbnailDiscordDelay = 10 * time.Second
 
 func (a *App) EventConsumer(ctx context.Context, event provider.Event) {
-	a.RLock()
-	defer a.RUnlock()
+	a.mutex.RLock()
+	defer a.mutex.RUnlock()
 
 	for _, webhook := range a.webhooks {
 		if !webhook.Match(event) {
diff --git a/pkg/webhook/webhook.go b/pkg/webhook/webhook.go
index 7f364258..28b93979 100644
--- a/pkg/webhook/webhook.go
+++ b/pkg/webhook/webhook.go
@@ -39,7 +39,7 @@ type App struct {
 	rendererApp  renderer.App
 	thumbnailApp thumbnail.App
 
-	sync.RWMutex
+	mutex sync.RWMutex
 }
 
 type Config struct {
@@ -95,8 +95,8 @@ func New(config Config, storageApp absto.Storage, prometheusRegisterer prometheu
 
 func (a *App) Exclusive(ctx context.Context, name string, duration time.Duration, action func(ctx context.Context) error) error {
 	fn := func() error {
-		a.Lock()
-		defer a.Unlock()
+		a.mutex.Lock()
+		defer a.mutex.Unlock()
 
 		if err := a.loadWebhooks(ctx); err != nil {
 			return fmt.Errorf("refresh webhooks: %w", err)
@@ -125,8 +125,8 @@ exclusive:
 }
 
 func (a *App) Start(ctx context.Context) {
-	a.Lock()
-	defer a.Unlock()
+	a.mutex.Lock()
+	defer a.mutex.Unlock()
 
 	if err := a.loadWebhooks(ctx); err != nil {
 		logger.Error("refresh webhooks: %s", err)