owl-blogs/app/entry_service.go

128 lines
3.4 KiB
Go
Raw Normal View History

2023-06-25 19:32:36 +00:00
package app
import (
2024-05-17 20:37:18 +00:00
"errors"
2023-08-08 17:41:07 +00:00
"fmt"
2023-06-25 19:32:36 +00:00
"owl-blogs/app/repository"
"owl-blogs/domain/model"
2023-08-08 17:41:07 +00:00
"regexp"
"strings"
2023-06-25 19:32:36 +00:00
)
type EntryService struct {
2024-05-17 20:37:18 +00:00
EntryRepository repository.EntryRepository
siteConfigServcie *SiteConfigService
Bus *EventBus
2023-06-25 19:32:36 +00:00
}
2023-08-09 19:56:56 +00:00
func NewEntryService(
entryRepository repository.EntryRepository,
2024-05-17 20:37:18 +00:00
siteConfigServcie *SiteConfigService,
2023-08-11 13:14:38 +00:00
bus *EventBus,
2023-08-09 19:56:56 +00:00
) *EntryService {
return &EntryService{
2024-05-17 20:37:18 +00:00
EntryRepository: entryRepository,
siteConfigServcie: siteConfigServcie,
Bus: bus,
2023-08-09 19:56:56 +00:00
}
2023-06-25 19:32:36 +00:00
}
2023-07-09 20:12:06 +00:00
func (s *EntryService) Create(entry model.Entry) error {
2023-08-08 17:41:07 +00:00
// try to find a good ID
m := regexp.MustCompile(`[^a-z0-9-]`)
prefix := m.ReplaceAllString(strings.ToLower(entry.Title()), "-")
title := prefix
counter := 0
for {
_, err := s.EntryRepository.FindById(title)
if err == nil {
counter += 1
title = prefix + "-" + fmt.Sprintf("%s-%d", prefix, counter)
} else {
break
}
}
entry.SetID(title)
2023-08-09 19:56:56 +00:00
err := s.EntryRepository.Create(entry)
if err != nil {
return err
}
// only notify if the publishing date is set
// otherwise this is a draft.
// listeners might publish the entry to other services/platforms
// this should only happen for publshed content
if entry.PublishedAt() != nil && !entry.PublishedAt().IsZero() {
s.Bus.NotifyCreated(entry)
}
2023-08-09 19:56:56 +00:00
return nil
2023-06-25 19:32:36 +00:00
}
func (s *EntryService) Update(entry model.Entry) error {
2023-08-11 13:14:38 +00:00
err := s.EntryRepository.Update(entry)
if err != nil {
return err
}
// only notify if the publishing date is set
// otherwise this is a draft.
// listeners might publish the entry to other services/platforms
// this should only happen for publshed content
if entry.PublishedAt() != nil && !entry.PublishedAt().IsZero() {
s.Bus.NotifyUpdated(entry)
}
2023-08-11 13:14:38 +00:00
return nil
2023-06-25 19:32:36 +00:00
}
func (s *EntryService) Delete(entry model.Entry) error {
2023-08-11 13:14:38 +00:00
err := s.EntryRepository.Delete(entry)
if err != nil {
return err
}
// deletes should always be notfied
// a published entry might be converted to a draft before deletion
// omitting the deletion in this case would prevent deletion on other platforms
2023-08-11 13:14:38 +00:00
s.Bus.NotifyDeleted(entry)
return nil
2023-06-25 19:32:36 +00:00
}
func (s *EntryService) FindById(id string) (model.Entry, error) {
return s.EntryRepository.FindById(id)
}
2024-05-17 20:37:18 +00:00
func (s *EntryService) FindByUrl(url string) (model.Entry, error) {
cfg, _ := s.siteConfigServcie.GetSiteConfig()
if !strings.HasPrefix(url, cfg.FullUrl) {
return nil, errors.New("url does not belong to blog")
}
if strings.HasSuffix(url, "/") {
url = url[:len(url)-1]
}
parts := strings.Split(url, "/")
id := parts[len(parts)-1]
return s.FindById(id)
}
2023-07-19 18:45:42 +00:00
func (s *EntryService) filterEntries(entries []model.Entry, published bool, drafts bool) []model.Entry {
filteredEntries := make([]model.Entry, 0)
for _, entry := range entries {
if published && entry.PublishedAt() != nil && !entry.PublishedAt().IsZero() {
filteredEntries = append(filteredEntries, entry)
}
if drafts && (entry.PublishedAt() == nil || entry.PublishedAt().IsZero()) {
filteredEntries = append(filteredEntries, entry)
}
}
return filteredEntries
}
func (s *EntryService) FindAllByType(types *[]string, published bool, drafts bool) ([]model.Entry, error) {
entries, err := s.EntryRepository.FindAll(types)
return s.filterEntries(entries, published, drafts), err
2023-06-25 19:32:36 +00:00
}
func (s *EntryService) FindAll() ([]model.Entry, error) {
2023-07-13 19:20:00 +00:00
entries, err := s.EntryRepository.FindAll(nil)
2023-07-19 18:45:42 +00:00
return s.filterEntries(entries, true, true), err
2023-06-25 19:32:36 +00:00
}