feat(web): added new endpoint DELETE /api/v1/audio - remove audio by id

web/internal/audio/database.go

@@ -2,9 +2,11 @@ package audio
 
 import (
 	"context"
+	"errors"
 	"github.com/wittano/komputer/db"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
+	"os"
 )
 
 const audioCollectionName = "audio"
@@ -13,6 +15,8 @@ type DatabaseService struct {
 	Database db.MongodbService
 }
 
+var NotFoundErr = errors.New("audio not found")
+
 func (a DatabaseService) save(ctx context.Context, filename string) error {
 	client, err := a.Database.Client(ctx)
 	if err != nil {
@@ -46,3 +50,33 @@ func (a DatabaseService) Get(ctx context.Context, id string) (result db.AudioInf
 
 	return
 }
+
+func (a DatabaseService) Delete(ctx context.Context, id string) (err error) {
+	hex, err := primitive.ObjectIDFromHex(id)
+	if err != nil {
+		return
+	}
+
+	info, err := a.Get(ctx, id)
+	if err != nil {
+		return errors.Join(NotFoundErr, err)
+	}
+
+	client, err := a.Database.Client(ctx)
+	if err != nil {
+		return
+	}
+
+	_, err = client.Database(db.DatabaseName).
+		Collection(audioCollectionName).
+		DeleteOne(ctx, bson.D{{"_id", hex}})
+	if err != nil {
+		return
+	}
+
+	if _, err = os.Stat(info.Path); errors.Is(err, os.ErrNotExist) {
+		return os.Remove(info.Path)
+	}
+
+	return
+}

web/internal/handler/audio.go

@@ -1,6 +1,8 @@
 package handler
 
 import (
+	"errors"
+	"fmt"
 	"github.com/labstack/echo/v4"
 	"github.com/wittano/komputer/db"
 	"github.com/wittano/komputer/web/internal/audio"
@@ -10,19 +12,31 @@ import (
 )
 
 func GetAudio(c echo.Context) error {
-	id := c.Param("id")
-
 	ctx := c.Request().Context()
 	service := audio.DatabaseService{Database: db.Mongodb(ctx)}
 
-	info, err := service.Get(ctx, id)
+	info, err := service.Get(ctx, c.Param("id"))
 	if err != nil {
 		return err
 	}
 
 	return c.File(info.Path)
 }
 
+func RemoveAudio(c echo.Context) error {
+	ctx := c.Request().Context
+	service := audio.DatabaseService{Database: db.Mongodb(ctx())}
+
+	id := c.Param("id")
+	if err := service.Delete(ctx(), id); errors.Is(err, audio.NotFoundErr) {
+		return echo.NewHTTPError(http.StatusNotFound, fmt.Sprintf("audio with id '%s' wasn't found", id))
+	} else if err != nil {
+		return err
+	}
+
+	return c.String(http.StatusOK, "")
+}
+
 func UploadNewAudio(c echo.Context) (err error) {
 	multipartForm, err := c.MultipartForm()
 	if err != nil {

web/server.go

@@ -19,6 +19,7 @@ func NewWebConsoleServer(configPath string) (*echo.Echo, error) {
 
 	e.POST("/api/v1/audio", handler.UploadNewAudio)
 	e.GET("/api/v1/audio/:id", handler.GetAudio)
+	e.DELETE("/api/v1/audio/:id", handler.RemoveAudio)
 
 	e.GET("/api/v1/setting", handler.GetSettings)
 	e.PUT("/api/v1/setting", handler.UpdateSettings)