mirror of
https://github.com/knadh/listmonk.git
synced 2024-09-20 15:26:33 +08:00
b5cd9498b1
This is a long pending refactor. All the DB, query, CRUD, and related logic scattered across HTTP handlers are now moved into a central `core` package with clean, abstracted methods, decoupling HTTP handlers from executing direct DB queries and other business logic. eg: `core.CreateList()`, `core.GetLists()` etc. - Remove obsolete subscriber methods. - Move optin hook queries to core. - Move campaign methods to `core`. - Move all campaign methods to `core`. - Move public page functions to `core`. - Move all template functions to `core`. - Move media and settings function to `core`. - Move handler middleware functions to `core`. - Move all bounce functions to `core`. - Move all dashboard functions to `core`. - Fix GetLists() not honouring type - Fix unwrapped JSON responses. - Clean up obsolete pre-core util function. - Replace SQL array null check with cardinality check. - Fix missing validations in `core` queries. - Remove superfluous deps on internal `subimporter`. - Add dashboard functions to `core`. - Fix broken domain ban check. - Fix broken subscriber check middleware. - Remove redundant error handling. - Remove obsolete functions. - Remove obsolete structs. - Remove obsolete queries and DB functions. - Document the `core` package.
78 lines
2.4 KiB
Go
78 lines
2.4 KiB
Go
package core
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/gofrs/uuid"
|
|
"github.com/knadh/listmonk/internal/media"
|
|
"github.com/labstack/echo/v4"
|
|
)
|
|
|
|
// GetAllMedia returns all uploaded media.
|
|
func (c *Core) GetAllMedia(provider string, s media.Store) ([]media.Media, error) {
|
|
out := []media.Media{}
|
|
if err := c.q.GetAllMedia.Select(&out, provider); err != nil {
|
|
return out, echo.NewHTTPError(http.StatusInternalServerError,
|
|
c.i18n.Ts("globals.messages.errorFetching",
|
|
"name", "{globals.terms.media}", "error", pqErrMsg(err)))
|
|
}
|
|
|
|
for i := 0; i < len(out); i++ {
|
|
out[i].URL = s.Get(out[i].Filename)
|
|
out[i].ThumbURL = s.Get(out[i].Thumb)
|
|
}
|
|
|
|
return out, nil
|
|
}
|
|
|
|
// GetMedia returns a media item.
|
|
func (c *Core) GetMedia(id int, uuid string, s media.Store) (media.Media, error) {
|
|
var uu interface{}
|
|
if uuid != "" {
|
|
uu = uuid
|
|
}
|
|
|
|
var out media.Media
|
|
if err := c.q.GetMedia.Get(&out, id, uu); err != nil {
|
|
return out, echo.NewHTTPError(http.StatusInternalServerError,
|
|
c.i18n.Ts("globals.messages.errorFetching", "name", "{globals.terms.media}", "error", pqErrMsg(err)))
|
|
}
|
|
|
|
out.URL = s.Get(out.Filename)
|
|
out.ThumbURL = s.Get(out.Thumb)
|
|
|
|
return out, nil
|
|
}
|
|
|
|
// InsertMedia inserts a new media file into the DB.
|
|
func (c *Core) InsertMedia(fileName, thumbName string, provider string, s media.Store) (media.Media, error) {
|
|
uu, err := uuid.NewV4()
|
|
if err != nil {
|
|
c.log.Printf("error generating UUID: %v", err)
|
|
return media.Media{}, echo.NewHTTPError(http.StatusInternalServerError,
|
|
c.i18n.Ts("globals.messages.errorUUID", "error", err.Error()))
|
|
}
|
|
|
|
// Write to the DB.
|
|
var newID int
|
|
if err := c.q.InsertMedia.Get(&newID, uu, fileName, thumbName, provider); err != nil {
|
|
c.log.Printf("error inserting uploaded file to db: %v", err)
|
|
return media.Media{}, echo.NewHTTPError(http.StatusInternalServerError,
|
|
c.i18n.Ts("globals.messages.errorCreating", "name", "{globals.terms.media}", "error", pqErrMsg(err)))
|
|
}
|
|
|
|
return c.GetMedia(newID, "", s)
|
|
}
|
|
|
|
// DeleteMedia deletes a given media item and returns the filename of the deleted item.
|
|
func (c *Core) DeleteMedia(id int) (string, error) {
|
|
var fname string
|
|
if err := c.q.DeleteMedia.Get(&fname, id); err != nil {
|
|
c.log.Printf("error inserting uploaded file to db: %v", err)
|
|
return "", echo.NewHTTPError(http.StatusInternalServerError,
|
|
c.i18n.Ts("globals.messages.errorCreating", "name", "{globals.terms.media}", "error", pqErrMsg(err)))
|
|
}
|
|
|
|
return fname, nil
|
|
}
|