sam boyerandRyan McKinley
ba97b268d0
* playlist: Split PlaylistItem into standalone TS type * update playlist model * actually set the title Co-authored-by: Ryan McKinley <ryantxu@gmail.com>
80 lines
2.0 KiB
Go
80 lines
2.0 KiB
Go
package playlistimpl
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/grafana/grafana/pkg/services/playlist"
|
|
"github.com/grafana/grafana/pkg/services/sqlstore/db"
|
|
"github.com/grafana/grafana/pkg/setting"
|
|
)
|
|
|
|
type Service struct {
|
|
store store
|
|
}
|
|
|
|
func ProvideService(db db.DB, cfg *setting.Cfg) playlist.Service {
|
|
if cfg.IsFeatureToggleEnabled("newDBLibrary") {
|
|
return &Service{
|
|
store: &sqlxStore{
|
|
sess: db.GetSqlxSession(),
|
|
},
|
|
}
|
|
}
|
|
return &Service{
|
|
store: &sqlStore{
|
|
db: db,
|
|
},
|
|
}
|
|
}
|
|
|
|
func (s *Service) Create(ctx context.Context, cmd *playlist.CreatePlaylistCommand) (*playlist.Playlist, error) {
|
|
return s.store.Insert(ctx, cmd)
|
|
}
|
|
|
|
func (s *Service) Update(ctx context.Context, cmd *playlist.UpdatePlaylistCommand) (*playlist.PlaylistDTO, error) {
|
|
return s.store.Update(ctx, cmd)
|
|
}
|
|
|
|
func (s *Service) GetWithoutItems(ctx context.Context, q *playlist.GetPlaylistByUidQuery) (*playlist.Playlist, error) {
|
|
return s.store.Get(ctx, q)
|
|
}
|
|
|
|
func (s *Service) Get(ctx context.Context, q *playlist.GetPlaylistByUidQuery) (*playlist.PlaylistDTO, error) {
|
|
v, err := s.store.Get(ctx, q)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
rawItems, err := s.store.GetItems(ctx, &playlist.GetPlaylistItemsByUidQuery{
|
|
PlaylistUID: v.UID,
|
|
OrgId: q.OrgId,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
items := make([]playlist.PlaylistItemDTO, len(rawItems))
|
|
for i := 0; i < len(rawItems); i++ {
|
|
items[i].Type = playlist.PlaylistItemType(rawItems[i].Type)
|
|
items[i].Value = rawItems[i].Value
|
|
|
|
// Add the unused title to the result
|
|
title := rawItems[i].Title
|
|
if title != "" {
|
|
items[i].Title = &title
|
|
}
|
|
}
|
|
return &playlist.PlaylistDTO{
|
|
Uid: v.UID,
|
|
Name: v.Name,
|
|
Interval: v.Interval,
|
|
Items: &items,
|
|
}, nil
|
|
}
|
|
|
|
func (s *Service) Search(ctx context.Context, q *playlist.GetPlaylistsQuery) (playlist.Playlists, error) {
|
|
return s.store.List(ctx, q)
|
|
}
|
|
|
|
func (s *Service) Delete(ctx context.Context, cmd *playlist.DeletePlaylistCommand) error {
|
|
return s.store.Delete(ctx, cmd)
|
|
}
|