Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
simon-ding committed Jul 14, 2024
1 parent a465468 commit e8a3648
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 2 deletions.
12 changes: 10 additions & 2 deletions db/db.go
Original file line number Diff line number Diff line change
Expand Up @@ -126,8 +126,16 @@ type SeriesDetails struct {
}

func (c *Client) GetSeriesDetails(id int) *SeriesDetails {
se := c.ent.Series.Query().Where(series.ID(id)).FirstX(context.TODO())
ep := se.QueryEpisodes().AllX(context.Background())
se, err := c.ent.Series.Query().Where(series.ID(id)).First(context.TODO())
if err != nil {
log.Errorf("get series %d: %v", id, err)
return nil
}
ep, err := se.QueryEpisodes().All(context.Background())
if err != nil {
log.Errorf("get episodes %d: %v", id, err)
return nil
}
return &SeriesDetails{
Series: se,
Episodes: ep,
Expand Down
3 changes: 3 additions & 0 deletions server/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,9 @@ func (s *Server) moveCompletedTask(id int) error {
r := s.db.GetHistory(id)

series := s.db.GetSeriesDetails(r.SeriesID)
if series == nil {
return nil
}
st := s.db.GetStorage(series.StorageID)
log.Infof("move task files to target dir: %v", r.TargetDir)
if st.Implementation == storage1.ImplementationWebdav {
Expand Down

0 comments on commit e8a3648

Please sign in to comment.