Function addTusHandlers

main.go:243–287

https://tus.github.io/tusd/advanced-topics/usage-package/

(e *echo.Echo, uploadEndpoints map[string]echo.MiddlewareFunc)

// https://tus.github.io/tusd/advanced-topics/usage-package/
func addTusHandlers(e *echo.Echo, uploadEndpoints map[string]echo.MiddlewareFunc) error {
	uploadsPath := storage.GetUploadsPath()
	store := filestore.New(uploadsPath)
	locker := filelocker.New(uploadsPath)
	composer := tusd.NewStoreComposer()
	store.UseIn(composer)
	locker.UseIn(composer)
	logger := xzerolog.NewHandler(&log.Logger)
	handler, err := tusd.NewUnroutedHandler(tusd.Config{
		BasePath:              "/files/",
		StoreComposer:         composer,
		NotifyCompleteUploads: true,
		UseRelativeUrls:       true,
		Logger:                log3.New(logger),
	})
	go func() {
		for {
			event := <-handler.CompleteUploads
			storage.Uploads.Add(event.Upload.ID)
		}
	}()
	if err != nil {
		return err
	}
	tusMiddleware := echo.WrapMiddleware(handler.Middleware)
	stripMiddleware := echo.WrapMiddleware(func(h http.Handler) http.Handler {
		return http.StripPrefix("/files/", h)
	})
	for prefix, authMiddleware := range uploadEndpoints {
		// middlewares run in order, make sure auth goes first!
		e.POST(prefix, func(c echo.Context) error {
			handler.PostFile(c.Response().Writer, c.Request())
			return nil
		}, authMiddleware, tusMiddleware)
	}
	e.HEAD("/files/:file_id", func(c echo.Context) error {
		handler.HeadFile(c.Response().Writer, c.Request())
		return nil
	}, stripMiddleware, tusMiddleware)
	e.PATCH("/files/:file_id", func(c echo.Context) error {
		handler.PatchFile(c.Response().Writer, c.Request())
		return nil
	}, stripMiddleware, tusMiddleware)
	return nil
}

func getTweaks(c echo.Context, app storage.App) error {
	tweaks, err := app.ReadDir(storage.TweaksDir)