Skip to content

Commit

Permalink
feat: Adding more route tag
Browse files Browse the repository at this point in the history
Signed-off-by: Vincent Boutour <[email protected]>
  • Loading branch information
ViBiOh committed Jan 7, 2024
1 parent b5d32f3 commit 6d11cd4
Showing 1 changed file with 9 additions and 5 deletions.
14 changes: 9 additions & 5 deletions pkg/crud/get.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,23 +63,27 @@ func (s Service) getWithMessage(w http.ResponseWriter, r *http.Request, request

func (s Service) handleFile(w http.ResponseWriter, r *http.Request, request provider.Request, item absto.Item, message renderer.Message) (renderer.Page, error) {
if query.GetBool(r, "thumbnail") {
telemetry.SetRouteTag(r.Context(), "/thumbnail")
s.thumbnail.Serve(w, r, item)
return renderer.Page{}, nil
}

if query.GetBool(r, "stream") {
telemetry.SetRouteTag(r.Context(), "/stream")
s.thumbnail.Stream(w, r, item)
return renderer.Page{}, nil
}

if query.GetBool(r, "browser") {
telemetry.SetRouteTag(r.Context(), "/browse")
provider.SetPrefsCookie(w, request)

go s.pushEvent(cntxt.WithoutDeadline(r.Context()), provider.NewAccessEvent(r.Context(), item, r))

return s.browse(r.Context(), request, item, message)
}

telemetry.SetRouteTag(r.Context(), "/download")
return renderer.Page{}, s.serveFile(w, r, item)
}

Expand Down Expand Up @@ -118,34 +122,34 @@ func (s Service) handleDir(w http.ResponseWriter, r *http.Request, request provi
}

if query.GetBool(r, "geojson") {
telemetry.SetRouteTag(r.Context(), "/geojson")
telemetry.SetRouteTag(r.Context(), "/geojsons")
s.serveGeoJSON(w, r, request, item, items)
return renderer.Page{}, nil
}

if query.GetBool(r, "thumbnail") {
telemetry.SetRouteTag(r.Context(), "/thumbnail")
telemetry.SetRouteTag(r.Context(), "/thumbnails")
s.thumbnail.List(w, r, item, items)
return renderer.Page{}, nil
}

if query.GetBool(r, "download") {
telemetry.SetRouteTag(r.Context(), "/download")
telemetry.SetRouteTag(r.Context(), "/downloads")
s.Download(w, r, request, items)
return errorReturn(request, err)
}

go s.pushEvent(cntxt.WithoutDeadline(r.Context()), provider.NewAccessEvent(r.Context(), item, r))

if query.GetBool(r, "search") {
telemetry.SetRouteTag(r.Context(), "/search")
telemetry.SetRouteTag(r.Context(), "/searches")
return s.search(r, request, item, items)
}

provider.SetPrefsCookie(w, request)

if request.IsStory() {
telemetry.SetRouteTag(r.Context(), "/story")
telemetry.SetRouteTag(r.Context(), "/stories")
return s.story(r, request, item, items)
}

Expand Down

0 comments on commit 6d11cd4

Please sign in to comment.