feat: use cookie to store jwt token, better performance

.github/workflows/go.yml

@@ -25,6 +25,8 @@ jobs:
 
     steps:
       - uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
 
       - name: Login to image repository
         uses: docker/login-action@v2

.github/workflows/release.yml

@@ -22,6 +22,8 @@ jobs:
 
     steps:
       - uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
 
       - name: Set Up QEMU
         uses: docker/setup-qemu-action@v3

Dockerfile

@@ -22,10 +22,10 @@ COPY . .
 
 COPY --from=flutter /app/build/web ./ui/build/web/
 # 指定OS等，并go build
-RUN CGO_ENABLED=1 go build -o polaris ./cmd/ 
+RUN CGO_ENABLED=1 go build -o polaris -ldflags="-X polaris/db.Version=$(git describe --tags --long)"  ./cmd/ 
 
 FROM debian:12
-ENV TZ="Asia/Shanghai"
+ENV TZ="Asia/Shanghai" GIN_MODE=release
 
 WORKDIR /app
 RUN apt-get update && apt-get -y install ca-certificates

cmd/main.go

@@ -7,6 +7,7 @@ import (
 )
 
 func main() {
+	log.Infof("------------------- Starting Polaris ---------------------")
 	dbClient, err := db.Open()
 	if err != nil {
 		log.Panicf("init db error: %v", err)

db/const.go

@@ -1,5 +1,7 @@
 package db
 
+var Version = "undefined"
+
 const (
 	SettingTmdbApiKey = "tmdb_api_key"
 	SettingLanguage = "language"
@@ -7,6 +9,7 @@ const (
 	SettingJacketApiKey = "jacket_api_key"
 	SettingDownloadDir = "download_dir"
 	SettingLogLevel = "log_level"
+	SettingProxy = "proxy"
 )
 
 const (

db/db.go

@@ -56,17 +56,17 @@ func (c *Client) init() {
 	downloadDir := c.GetSetting(SettingDownloadDir)
 	if downloadDir == "" {
 		log.Infof("set default download dir")
-		c.SetSetting(downloadDir, "/downloads")
+		c.SetSetting(SettingDownloadDir, "/downloads")
 	}
 	logLevel := c.GetSetting(SettingLogLevel)
 	if logLevel == "" {
 		log.Infof("set default log level")
 		c.SetSetting(SettingLogLevel, "info")
 	}
-	// if tr := c.GetTransmission(); tr == nil {
-	// 	log.Warnf("no download client, set default download client")
-	// 	c.SaveTransmission("transmission", "http://transmission:9091", "", "")
-	// }
+	if tr := c.GetTransmission(); tr == nil {
+		log.Warnf("no download client, set default download client")
+		c.SaveTransmission("transmission", "http://transmission:9091", "", "")
+	}
 }
 
 func (c *Client) generateJwtSerectIfNotExist() {
@@ -98,7 +98,7 @@ func (c *Client) generateDefaultLocalStorage() error {
 func (c *Client) GetSetting(key string) string {
 	v, err := c.ent.Settings.Query().Where(settings.Key(key)).Only(context.TODO())
 	if err != nil {
-		log.Errorf("get setting by key: %s error: %v", key, err)
+		log.Warnf("get setting by key: %s error: %v", key, err)
 		return ""
 	}
 	return v.Value
@@ -201,6 +201,10 @@ func (c *Client) GetMediaDetails(id int) *MediaDetails {
 	return md
 }
 
+func (c *Client) GetMedia(id int) (*ent.Media, error) {
+	return c.ent.Media.Query().Where(media.ID(id)).First(context.TODO())
+}
+
 func (c *Client) DeleteMedia(id int) error {
 	_, err := c.ent.Episode.Delete().Where(episode.MediaID(id)).Exec(context.TODO())
 	if err != nil {
@@ -506,13 +510,13 @@ func (c *Client) GetDownloadDir() string {
 	return r.Value
 }
 
-func (c *Client) UpdateEpisodeFile(mediaID int, seasonNum, episodeNum int, file string) error {
+func (c *Client) UpdateEpisodeStatus(mediaID int, seasonNum, episodeNum int) error {
 	ep, err := c.ent.Episode.Query().Where(episode.MediaID(mediaID)).Where(episode.EpisodeNumber(episodeNum)).
 		Where(episode.SeasonNumber(seasonNum)).First(context.TODO())
 	if err != nil {
 		return errors.Wrap(err, "finding episode")
 	}
-	return ep.Update().SetFileInStorage(file).SetStatus(episode.StatusDownloaded).Exec(context.TODO())
+	return ep.Update().SetStatus(episode.StatusDownloaded).Exec(context.TODO())
 }
 
 func (c *Client) SetEpisodeStatus(id int, status episode.Status) error {

ent/episode.go

@@ -31,8 +31,6 @@ type Episode struct {
 	AirDate string `json:"air_date,omitempty"`
 	// Status holds the value of the "status" field.
 	Status episode.Status `json:"status,omitempty"`
-	// FileInStorage holds the value of the "file_in_storage" field.
-	FileInStorage string `json:"file_in_storage,omitempty"`
 	// Edges holds the relations/edges for other nodes in the graph.
 	// The values are being populated by the EpisodeQuery when eager-loading is set.
 	Edges        EpisodeEdges `json:"edges"`
@@ -66,7 +64,7 @@ func (*Episode) scanValues(columns []string) ([]any, error) {
 		switch columns[i] {
 		case episode.FieldID, episode.FieldMediaID, episode.FieldSeasonNumber, episode.FieldEpisodeNumber:
 			values[i] = new(sql.NullInt64)
-		case episode.FieldTitle, episode.FieldOverview, episode.FieldAirDate, episode.FieldStatus, episode.FieldFileInStorage:
+		case episode.FieldTitle, episode.FieldOverview, episode.FieldAirDate, episode.FieldStatus:
 			values[i] = new(sql.NullString)
 		default:
 			values[i] = new(sql.UnknownType)
@@ -131,12 +129,6 @@ func (e *Episode) assignValues(columns []string, values []any) error {
 			} else if value.Valid {
 				e.Status = episode.Status(value.String)
 			}
-		case episode.FieldFileInStorage:
-			if value, ok := values[i].(*sql.NullString); !ok {
-				return fmt.Errorf("unexpected type %T for field file_in_storage", values[i])
-			} else if value.Valid {
-				e.FileInStorage = value.String
-			}
 		default:
 			e.selectValues.Set(columns[i], values[i])
 		}
@@ -198,9 +190,6 @@ func (e *Episode) String() string {
 	builder.WriteString(", ")
 	builder.WriteString("status=")
 	builder.WriteString(fmt.Sprintf("%v", e.Status))
-	builder.WriteString(", ")
-	builder.WriteString("file_in_storage=")
-	builder.WriteString(e.FileInStorage)
 	builder.WriteByte(')')
 	return builder.String()
 }

ent/episode/episode.go

@@ -28,8 +28,6 @@ const (
 	FieldAirDate = "air_date"
 	// FieldStatus holds the string denoting the status field in the database.
 	FieldStatus = "status"
-	// FieldFileInStorage holds the string denoting the file_in_storage field in the database.
-	FieldFileInStorage = "file_in_storage"
 	// EdgeMedia holds the string denoting the media edge name in mutations.
 	EdgeMedia = "media"
 	// Table holds the table name of the episode in the database.
@@ -53,7 +51,6 @@ var Columns = []string{
 	FieldOverview,
 	FieldAirDate,
 	FieldStatus,
-	FieldFileInStorage,
 }
 
 // ValidColumn reports if the column name is valid (part of the table columns).
@@ -136,11 +133,6 @@ func ByStatus(opts ...sql.OrderTermOption) OrderOption {
 	return sql.OrderByField(FieldStatus, opts...).ToFunc()
 }
 
-// ByFileInStorage orders the results by the file_in_storage field.
-func ByFileInStorage(opts ...sql.OrderTermOption) OrderOption {
-	return sql.OrderByField(FieldFileInStorage, opts...).ToFunc()
-}
-
 // ByMediaField orders the results by media field.
 func ByMediaField(field string, opts ...sql.OrderTermOption) OrderOption {
 	return func(s *sql.Selector) {

ent/episode/where.go

@@ -84,11 +84,6 @@ func AirDate(v string) predicate.Episode {
 	return predicate.Episode(sql.FieldEQ(FieldAirDate, v))
 }
 
-// FileInStorage applies equality check predicate on the "file_in_storage" field. It's identical to FileInStorageEQ.
-func FileInStorage(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldEQ(FieldFileInStorage, v))
-}
-
 // MediaIDEQ applies the EQ predicate on the "media_id" field.
 func MediaIDEQ(v int) predicate.Episode {
 	return predicate.Episode(sql.FieldEQ(FieldMediaID, v))
@@ -414,81 +409,6 @@ func StatusNotIn(vs ...Status) predicate.Episode {
 	return predicate.Episode(sql.FieldNotIn(FieldStatus, vs...))
 }
 
-// FileInStorageEQ applies the EQ predicate on the "file_in_storage" field.
-func FileInStorageEQ(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldEQ(FieldFileInStorage, v))
-}
-
-// FileInStorageNEQ applies the NEQ predicate on the "file_in_storage" field.
-func FileInStorageNEQ(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldNEQ(FieldFileInStorage, v))
-}
-
-// FileInStorageIn applies the In predicate on the "file_in_storage" field.
-func FileInStorageIn(vs ...string) predicate.Episode {
-	return predicate.Episode(sql.FieldIn(FieldFileInStorage, vs...))
-}
-
-// FileInStorageNotIn applies the NotIn predicate on the "file_in_storage" field.
-func FileInStorageNotIn(vs ...string) predicate.Episode {
-	return predicate.Episode(sql.FieldNotIn(FieldFileInStorage, vs...))
-}
-
-// FileInStorageGT applies the GT predicate on the "file_in_storage" field.
-func FileInStorageGT(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldGT(FieldFileInStorage, v))
-}
-
-// FileInStorageGTE applies the GTE predicate on the "file_in_storage" field.
-func FileInStorageGTE(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldGTE(FieldFileInStorage, v))
-}
-
-// FileInStorageLT applies the LT predicate on the "file_in_storage" field.
-func FileInStorageLT(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldLT(FieldFileInStorage, v))
-}
-
-// FileInStorageLTE applies the LTE predicate on the "file_in_storage" field.
-func FileInStorageLTE(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldLTE(FieldFileInStorage, v))
-}
-
-// FileInStorageContains applies the Contains predicate on the "file_in_storage" field.
-func FileInStorageContains(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldContains(FieldFileInStorage, v))
-}
-
-// FileInStorageHasPrefix applies the HasPrefix predicate on the "file_in_storage" field.
-func FileInStorageHasPrefix(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldHasPrefix(FieldFileInStorage, v))
-}
-
-// FileInStorageHasSuffix applies the HasSuffix predicate on the "file_in_storage" field.
-func FileInStorageHasSuffix(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldHasSuffix(FieldFileInStorage, v))
-}
-
-// FileInStorageIsNil applies the IsNil predicate on the "file_in_storage" field.
-func FileInStorageIsNil() predicate.Episode {
-	return predicate.Episode(sql.FieldIsNull(FieldFileInStorage))
-}
-
-// FileInStorageNotNil applies the NotNil predicate on the "file_in_storage" field.
-func FileInStorageNotNil() predicate.Episode {
-	return predicate.Episode(sql.FieldNotNull(FieldFileInStorage))
-}
-
-// FileInStorageEqualFold applies the EqualFold predicate on the "file_in_storage" field.
-func FileInStorageEqualFold(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldEqualFold(FieldFileInStorage, v))
-}
-
-// FileInStorageContainsFold applies the ContainsFold predicate on the "file_in_storage" field.
-func FileInStorageContainsFold(v string) predicate.Episode {
-	return predicate.Episode(sql.FieldContainsFold(FieldFileInStorage, v))
-}
-
 // HasMedia applies the HasEdge predicate on the "media" edge.
 func HasMedia() predicate.Episode {
 	return predicate.Episode(func(s *sql.Selector) {

ent/episode_create.go

@@ -78,20 +78,6 @@ func (ec *EpisodeCreate) SetNillableStatus(e *episode.Status) *EpisodeCreate {
 	return ec
 }
 
-// SetFileInStorage sets the "file_in_storage" field.
-func (ec *EpisodeCreate) SetFileInStorage(s string) *EpisodeCreate {
-	ec.mutation.SetFileInStorage(s)
-	return ec
-}
-
-// SetNillableFileInStorage sets the "file_in_storage" field if the given value is not nil.
-func (ec *EpisodeCreate) SetNillableFileInStorage(s *string) *EpisodeCreate {
-	if s != nil {
-		ec.SetFileInStorage(*s)
-	}
-	return ec
-}
-
 // SetMedia sets the "media" edge to the Media entity.
 func (ec *EpisodeCreate) SetMedia(m *Media) *EpisodeCreate {
 	return ec.SetMediaID(m.ID)
@@ -213,10 +199,6 @@ func (ec *EpisodeCreate) createSpec() (*Episode, *sqlgraph.CreateSpec) {
 		_spec.SetField(episode.FieldStatus, field.TypeEnum, value)
 		_node.Status = value
 	}
-	if value, ok := ec.mutation.FileInStorage(); ok {
-		_spec.SetField(episode.FieldFileInStorage, field.TypeString, value)
-		_node.FileInStorage = value
-	}
 	if nodes := ec.mutation.MediaIDs(); len(nodes) > 0 {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.M2O,

ent/episode_update.go

@@ -146,26 +146,6 @@ func (eu *EpisodeUpdate) SetNillableStatus(e *episode.Status) *EpisodeUpdate {
 	return eu
 }
 
-// SetFileInStorage sets the "file_in_storage" field.
-func (eu *EpisodeUpdate) SetFileInStorage(s string) *EpisodeUpdate {
-	eu.mutation.SetFileInStorage(s)
-	return eu
-}
-
-// SetNillableFileInStorage sets the "file_in_storage" field if the given value is not nil.
-func (eu *EpisodeUpdate) SetNillableFileInStorage(s *string) *EpisodeUpdate {
-	if s != nil {
-		eu.SetFileInStorage(*s)
-	}
-	return eu
-}
-
-// ClearFileInStorage clears the value of the "file_in_storage" field.
-func (eu *EpisodeUpdate) ClearFileInStorage() *EpisodeUpdate {
-	eu.mutation.ClearFileInStorage()
-	return eu
-}
-
 // SetMedia sets the "media" edge to the Media entity.
 func (eu *EpisodeUpdate) SetMedia(m *Media) *EpisodeUpdate {
 	return eu.SetMediaID(m.ID)
@@ -255,12 +235,6 @@ func (eu *EpisodeUpdate) sqlSave(ctx context.Context) (n int, err error) {
 	if value, ok := eu.mutation.Status(); ok {
 		_spec.SetField(episode.FieldStatus, field.TypeEnum, value)
 	}
-	if value, ok := eu.mutation.FileInStorage(); ok {
-		_spec.SetField(episode.FieldFileInStorage, field.TypeString, value)
-	}
-	if eu.mutation.FileInStorageCleared() {
-		_spec.ClearField(episode.FieldFileInStorage, field.TypeString)
-	}
 	if eu.mutation.MediaCleared() {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.M2O,
@@ -428,26 +402,6 @@ func (euo *EpisodeUpdateOne) SetNillableStatus(e *episode.Status) *EpisodeUpdate
 	return euo
 }
 
-// SetFileInStorage sets the "file_in_storage" field.
-func (euo *EpisodeUpdateOne) SetFileInStorage(s string) *EpisodeUpdateOne {
-	euo.mutation.SetFileInStorage(s)
-	return euo
-}
-
-// SetNillableFileInStorage sets the "file_in_storage" field if the given value is not nil.
-func (euo *EpisodeUpdateOne) SetNillableFileInStorage(s *string) *EpisodeUpdateOne {
-	if s != nil {
-		euo.SetFileInStorage(*s)
-	}
-	return euo
-}
-
-// ClearFileInStorage clears the value of the "file_in_storage" field.
-func (euo *EpisodeUpdateOne) ClearFileInStorage() *EpisodeUpdateOne {
-	euo.mutation.ClearFileInStorage()
-	return euo
-}
-
 // SetMedia sets the "media" edge to the Media entity.
 func (euo *EpisodeUpdateOne) SetMedia(m *Media) *EpisodeUpdateOne {
 	return euo.SetMediaID(m.ID)
@@ -567,12 +521,6 @@ func (euo *EpisodeUpdateOne) sqlSave(ctx context.Context) (_node *Episode, err e
 	if value, ok := euo.mutation.Status(); ok {
 		_spec.SetField(episode.FieldStatus, field.TypeEnum, value)
 	}
-	if value, ok := euo.mutation.FileInStorage(); ok {
-		_spec.SetField(episode.FieldFileInStorage, field.TypeString, value)
-	}
-	if euo.mutation.FileInStorageCleared() {
-		_spec.ClearField(episode.FieldFileInStorage, field.TypeString)
-	}
 	if euo.mutation.MediaCleared() {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.M2O,

ent/media.go

@@ -41,6 +41,8 @@ type Media struct {
 	StorageID int `json:"storage_id,omitempty"`
 	// TargetDir holds the value of the "target_dir" field.
 	TargetDir string `json:"target_dir,omitempty"`
+	// tv series only
+	DownloadHistoryEpisodes bool `json:"download_history_episodes,omitempty"`
 	// Edges holds the relations/edges for other nodes in the graph.
 	// The values are being populated by the MediaQuery when eager-loading is set.
 	Edges        MediaEdges `json:"edges"`
@@ -70,6 +72,8 @@ func (*Media) scanValues(columns []string) ([]any, error) {
 	values := make([]any, len(columns))
 	for i := range columns {
 		switch columns[i] {
+		case media.FieldDownloadHistoryEpisodes:
+			values[i] = new(sql.NullBool)
 		case media.FieldID, media.FieldTmdbID, media.FieldStorageID:
 			values[i] = new(sql.NullInt64)
 		case media.FieldImdbID, media.FieldMediaType, media.FieldNameCn, media.FieldNameEn, media.FieldOriginalName, media.FieldOverview, media.FieldAirDate, media.FieldResolution, media.FieldTargetDir:
@@ -169,6 +173,12 @@ func (m *Media) assignValues(columns []string, values []any) error {
 			} else if value.Valid {
 				m.TargetDir = value.String
 			}
+		case media.FieldDownloadHistoryEpisodes:
+			if value, ok := values[i].(*sql.NullBool); !ok {
+				return fmt.Errorf("unexpected type %T for field download_history_episodes", values[i])
+			} else if value.Valid {
+				m.DownloadHistoryEpisodes = value.Bool
+			}
 		default:
 			m.selectValues.Set(columns[i], values[i])
 		}
@@ -245,6 +255,9 @@ func (m *Media) String() string {
 	builder.WriteString(", ")
 	builder.WriteString("target_dir=")
 	builder.WriteString(m.TargetDir)
+	builder.WriteString(", ")
+	builder.WriteString("download_history_episodes=")
+	builder.WriteString(fmt.Sprintf("%v", m.DownloadHistoryEpisodes))
 	builder.WriteByte(')')
 	return builder.String()
 }

ent/media/media.go

@@ -39,6 +39,8 @@ const (
 	FieldStorageID = "storage_id"
 	// FieldTargetDir holds the string denoting the target_dir field in the database.
 	FieldTargetDir = "target_dir"
+	// FieldDownloadHistoryEpisodes holds the string denoting the download_history_episodes field in the database.
+	FieldDownloadHistoryEpisodes = "download_history_episodes"
 	// EdgeEpisodes holds the string denoting the episodes edge name in mutations.
 	EdgeEpisodes = "episodes"
 	// Table holds the table name of the media in the database.
@@ -67,6 +69,7 @@ var Columns = []string{
 	FieldResolution,
 	FieldStorageID,
 	FieldTargetDir,
+	FieldDownloadHistoryEpisodes,
 }
 
 // ValidColumn reports if the column name is valid (part of the table columns).
@@ -84,6 +87,8 @@ var (
 	DefaultCreatedAt time.Time
 	// DefaultAirDate holds the default value on creation for the "air_date" field.
 	DefaultAirDate string
+	// DefaultDownloadHistoryEpisodes holds the default value on creation for the "download_history_episodes" field.
+	DefaultDownloadHistoryEpisodes bool
 )
 
 // MediaType defines the type for the "media_type" enum field.
@@ -204,6 +209,11 @@ func ByTargetDir(opts ...sql.OrderTermOption) OrderOption {
 	return sql.OrderByField(FieldTargetDir, opts...).ToFunc()
 }
 
+// ByDownloadHistoryEpisodes orders the results by the download_history_episodes field.
+func ByDownloadHistoryEpisodes(opts ...sql.OrderTermOption) OrderOption {
+	return sql.OrderByField(FieldDownloadHistoryEpisodes, opts...).ToFunc()
+}
+
 // ByEpisodesCount orders the results by episodes count.
 func ByEpisodesCount(opts ...sql.OrderTermOption) OrderOption {
 	return func(s *sql.Selector) {

ent/media/where.go

@@ -105,6 +105,11 @@ func TargetDir(v string) predicate.Media {
 	return predicate.Media(sql.FieldEQ(FieldTargetDir, v))
 }
 
+// DownloadHistoryEpisodes applies equality check predicate on the "download_history_episodes" field. It's identical to DownloadHistoryEpisodesEQ.
+func DownloadHistoryEpisodes(v bool) predicate.Media {
+	return predicate.Media(sql.FieldEQ(FieldDownloadHistoryEpisodes, v))
+}
+
 // TmdbIDEQ applies the EQ predicate on the "tmdb_id" field.
 func TmdbIDEQ(v int) predicate.Media {
 	return predicate.Media(sql.FieldEQ(FieldTmdbID, v))
@@ -750,6 +755,26 @@ func TargetDirContainsFold(v string) predicate.Media {
 	return predicate.Media(sql.FieldContainsFold(FieldTargetDir, v))
 }
 
+// DownloadHistoryEpisodesEQ applies the EQ predicate on the "download_history_episodes" field.
+func DownloadHistoryEpisodesEQ(v bool) predicate.Media {
+	return predicate.Media(sql.FieldEQ(FieldDownloadHistoryEpisodes, v))
+}
+
+// DownloadHistoryEpisodesNEQ applies the NEQ predicate on the "download_history_episodes" field.
+func DownloadHistoryEpisodesNEQ(v bool) predicate.Media {
+	return predicate.Media(sql.FieldNEQ(FieldDownloadHistoryEpisodes, v))
+}
+
+// DownloadHistoryEpisodesIsNil applies the IsNil predicate on the "download_history_episodes" field.
+func DownloadHistoryEpisodesIsNil() predicate.Media {
+	return predicate.Media(sql.FieldIsNull(FieldDownloadHistoryEpisodes))
+}
+
+// DownloadHistoryEpisodesNotNil applies the NotNil predicate on the "download_history_episodes" field.
+func DownloadHistoryEpisodesNotNil() predicate.Media {
+	return predicate.Media(sql.FieldNotNull(FieldDownloadHistoryEpisodes))
+}
+
 // HasEpisodes applies the HasEdge predicate on the "episodes" edge.
 func HasEpisodes() predicate.Media {
 	return predicate.Media(func(s *sql.Selector) {

ent/media_create.go

@@ -141,6 +141,20 @@ func (mc *MediaCreate) SetNillableTargetDir(s *string) *MediaCreate {
 	return mc
 }
 
+// SetDownloadHistoryEpisodes sets the "download_history_episodes" field.
+func (mc *MediaCreate) SetDownloadHistoryEpisodes(b bool) *MediaCreate {
+	mc.mutation.SetDownloadHistoryEpisodes(b)
+	return mc
+}
+
+// SetNillableDownloadHistoryEpisodes sets the "download_history_episodes" field if the given value is not nil.
+func (mc *MediaCreate) SetNillableDownloadHistoryEpisodes(b *bool) *MediaCreate {
+	if b != nil {
+		mc.SetDownloadHistoryEpisodes(*b)
+	}
+	return mc
+}
+
 // AddEpisodeIDs adds the "episodes" edge to the Episode entity by IDs.
 func (mc *MediaCreate) AddEpisodeIDs(ids ...int) *MediaCreate {
 	mc.mutation.AddEpisodeIDs(ids...)
@@ -203,6 +217,10 @@ func (mc *MediaCreate) defaults() {
 		v := media.DefaultResolution
 		mc.mutation.SetResolution(v)
 	}
+	if _, ok := mc.mutation.DownloadHistoryEpisodes(); !ok {
+		v := media.DefaultDownloadHistoryEpisodes
+		mc.mutation.SetDownloadHistoryEpisodes(v)
+	}
 }
 
 // check runs all checks and user-defined validators on the builder.
@@ -318,6 +336,10 @@ func (mc *MediaCreate) createSpec() (*Media, *sqlgraph.CreateSpec) {
 		_spec.SetField(media.FieldTargetDir, field.TypeString, value)
 		_node.TargetDir = value
 	}
+	if value, ok := mc.mutation.DownloadHistoryEpisodes(); ok {
+		_spec.SetField(media.FieldDownloadHistoryEpisodes, field.TypeBool, value)
+		_node.DownloadHistoryEpisodes = value
+	}
 	if nodes := mc.mutation.EpisodesIDs(); len(nodes) > 0 {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.O2M,

ent/media_update.go

@@ -229,6 +229,26 @@ func (mu *MediaUpdate) ClearTargetDir() *MediaUpdate {
 	return mu
 }
 
+// SetDownloadHistoryEpisodes sets the "download_history_episodes" field.
+func (mu *MediaUpdate) SetDownloadHistoryEpisodes(b bool) *MediaUpdate {
+	mu.mutation.SetDownloadHistoryEpisodes(b)
+	return mu
+}
+
+// SetNillableDownloadHistoryEpisodes sets the "download_history_episodes" field if the given value is not nil.
+func (mu *MediaUpdate) SetNillableDownloadHistoryEpisodes(b *bool) *MediaUpdate {
+	if b != nil {
+		mu.SetDownloadHistoryEpisodes(*b)
+	}
+	return mu
+}
+
+// ClearDownloadHistoryEpisodes clears the value of the "download_history_episodes" field.
+func (mu *MediaUpdate) ClearDownloadHistoryEpisodes() *MediaUpdate {
+	mu.mutation.ClearDownloadHistoryEpisodes()
+	return mu
+}
+
 // AddEpisodeIDs adds the "episodes" edge to the Episode entity by IDs.
 func (mu *MediaUpdate) AddEpisodeIDs(ids ...int) *MediaUpdate {
 	mu.mutation.AddEpisodeIDs(ids...)
@@ -375,6 +395,12 @@ func (mu *MediaUpdate) sqlSave(ctx context.Context) (n int, err error) {
 	if mu.mutation.TargetDirCleared() {
 		_spec.ClearField(media.FieldTargetDir, field.TypeString)
 	}
+	if value, ok := mu.mutation.DownloadHistoryEpisodes(); ok {
+		_spec.SetField(media.FieldDownloadHistoryEpisodes, field.TypeBool, value)
+	}
+	if mu.mutation.DownloadHistoryEpisodesCleared() {
+		_spec.ClearField(media.FieldDownloadHistoryEpisodes, field.TypeBool)
+	}
 	if mu.mutation.EpisodesCleared() {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.O2M,
@@ -640,6 +666,26 @@ func (muo *MediaUpdateOne) ClearTargetDir() *MediaUpdateOne {
 	return muo
 }
 
+// SetDownloadHistoryEpisodes sets the "download_history_episodes" field.
+func (muo *MediaUpdateOne) SetDownloadHistoryEpisodes(b bool) *MediaUpdateOne {
+	muo.mutation.SetDownloadHistoryEpisodes(b)
+	return muo
+}
+
+// SetNillableDownloadHistoryEpisodes sets the "download_history_episodes" field if the given value is not nil.
+func (muo *MediaUpdateOne) SetNillableDownloadHistoryEpisodes(b *bool) *MediaUpdateOne {
+	if b != nil {
+		muo.SetDownloadHistoryEpisodes(*b)
+	}
+	return muo
+}
+
+// ClearDownloadHistoryEpisodes clears the value of the "download_history_episodes" field.
+func (muo *MediaUpdateOne) ClearDownloadHistoryEpisodes() *MediaUpdateOne {
+	muo.mutation.ClearDownloadHistoryEpisodes()
+	return muo
+}
+
 // AddEpisodeIDs adds the "episodes" edge to the Episode entity by IDs.
 func (muo *MediaUpdateOne) AddEpisodeIDs(ids ...int) *MediaUpdateOne {
 	muo.mutation.AddEpisodeIDs(ids...)
@@ -816,6 +862,12 @@ func (muo *MediaUpdateOne) sqlSave(ctx context.Context) (_node *Media, err error
 	if muo.mutation.TargetDirCleared() {
 		_spec.ClearField(media.FieldTargetDir, field.TypeString)
 	}
+	if value, ok := muo.mutation.DownloadHistoryEpisodes(); ok {
+		_spec.SetField(media.FieldDownloadHistoryEpisodes, field.TypeBool, value)
+	}
+	if muo.mutation.DownloadHistoryEpisodesCleared() {
+		_spec.ClearField(media.FieldDownloadHistoryEpisodes, field.TypeBool)
+	}
 	if muo.mutation.EpisodesCleared() {
 		edge := &sqlgraph.EdgeSpec{
 			Rel:     sqlgraph.O2M,

ent/migrate/schema.go

@@ -38,7 +38,6 @@ var (
 		{Name: "overview", Type: field.TypeString},
 		{Name: "air_date", Type: field.TypeString},
 		{Name: "status", Type: field.TypeEnum, Enums: []string{"missing", "downloading", "downloaded"}, Default: "missing"},
-		{Name: "file_in_storage", Type: field.TypeString, Nullable: true},
 		{Name: "media_id", Type: field.TypeInt, Nullable: true},
 	}
 	// EpisodesTable holds the schema information for the "episodes" table.
@@ -49,7 +48,7 @@ var (
 		ForeignKeys: []*schema.ForeignKey{
 			{
 				Symbol:     "episodes_media_episodes",
-				Columns:    []*schema.Column{EpisodesColumns[8]},
+				Columns:    []*schema.Column{EpisodesColumns[7]},
 				RefColumns: []*schema.Column{MediaColumns[0]},
 				OnDelete:   schema.SetNull,
 			},
@@ -103,6 +102,7 @@ var (
 		{Name: "resolution", Type: field.TypeEnum, Enums: []string{"720p", "1080p", "4k"}, Default: "1080p"},
 		{Name: "storage_id", Type: field.TypeInt, Nullable: true},
 		{Name: "target_dir", Type: field.TypeString, Nullable: true},
+		{Name: "download_history_episodes", Type: field.TypeBool, Nullable: true, Default: false},
 	}
 	// MediaTable holds the schema information for the "media" table.
 	MediaTable = &schema.Table{

ent/mutation.go

@@ -919,7 +919,6 @@ type EpisodeMutation struct {
 	overview          *string
 	air_date          *string
 	status            *episode.Status
-	file_in_storage   *string
 	clearedFields     map[string]struct{}
 	media             *int
 	clearedmedia      bool
@@ -1331,55 +1330,6 @@ func (m *EpisodeMutation) ResetStatus() {
 	m.status = nil
 }
 
-// SetFileInStorage sets the "file_in_storage" field.
-func (m *EpisodeMutation) SetFileInStorage(s string) {
-	m.file_in_storage = &s
-}
-
-// FileInStorage returns the value of the "file_in_storage" field in the mutation.
-func (m *EpisodeMutation) FileInStorage() (r string, exists bool) {
-	v := m.file_in_storage
-	if v == nil {
-		return
-	}
-	return *v, true
-}
-
-// OldFileInStorage returns the old "file_in_storage" field's value of the Episode entity.
-// If the Episode object wasn't provided to the builder, the object is fetched from the database.
-// An error is returned if the mutation operation is not UpdateOne, or the database query fails.
-func (m *EpisodeMutation) OldFileInStorage(ctx context.Context) (v string, err error) {
-	if !m.op.Is(OpUpdateOne) {
-		return v, errors.New("OldFileInStorage is only allowed on UpdateOne operations")
-	}
-	if m.id == nil || m.oldValue == nil {
-		return v, errors.New("OldFileInStorage requires an ID field in the mutation")
-	}
-	oldValue, err := m.oldValue(ctx)
-	if err != nil {
-		return v, fmt.Errorf("querying old value for OldFileInStorage: %w", err)
-	}
-	return oldValue.FileInStorage, nil
-}
-
-// ClearFileInStorage clears the value of the "file_in_storage" field.
-func (m *EpisodeMutation) ClearFileInStorage() {
-	m.file_in_storage = nil
-	m.clearedFields[episode.FieldFileInStorage] = struct{}{}
-}
-
-// FileInStorageCleared returns if the "file_in_storage" field was cleared in this mutation.
-func (m *EpisodeMutation) FileInStorageCleared() bool {
-	_, ok := m.clearedFields[episode.FieldFileInStorage]
-	return ok
-}
-
-// ResetFileInStorage resets all changes to the "file_in_storage" field.
-func (m *EpisodeMutation) ResetFileInStorage() {
-	m.file_in_storage = nil
-	delete(m.clearedFields, episode.FieldFileInStorage)
-}
-
 // ClearMedia clears the "media" edge to the Media entity.
 func (m *EpisodeMutation) ClearMedia() {
 	m.clearedmedia = true
@@ -1441,7 +1391,7 @@ func (m *EpisodeMutation) Type() string {
 // order to get all numeric fields that were incremented/decremented, call
 // AddedFields().
 func (m *EpisodeMutation) Fields() []string {
-	fields := make([]string, 0, 8)
+	fields := make([]string, 0, 7)
 	if m.media != nil {
 		fields = append(fields, episode.FieldMediaID)
 	}
@@ -1463,9 +1413,6 @@ func (m *EpisodeMutation) Fields() []string {
 	if m.status != nil {
 		fields = append(fields, episode.FieldStatus)
 	}
-	if m.file_in_storage != nil {
-		fields = append(fields, episode.FieldFileInStorage)
-	}
 	return fields
 }
 
@@ -1488,8 +1435,6 @@ func (m *EpisodeMutation) Field(name string) (ent.Value, bool) {
 		return m.AirDate()
 	case episode.FieldStatus:
 		return m.Status()
-	case episode.FieldFileInStorage:
-		return m.FileInStorage()
 	}
 	return nil, false
 }
@@ -1513,8 +1458,6 @@ func (m *EpisodeMutation) OldField(ctx context.Context, name string) (ent.Value,
 		return m.OldAirDate(ctx)
 	case episode.FieldStatus:
 		return m.OldStatus(ctx)
-	case episode.FieldFileInStorage:
-		return m.OldFileInStorage(ctx)
 	}
 	return nil, fmt.Errorf("unknown Episode field %s", name)
 }
@@ -1573,13 +1516,6 @@ func (m *EpisodeMutation) SetField(name string, value ent.Value) error {
 		}
 		m.SetStatus(v)
 		return nil
-	case episode.FieldFileInStorage:
-		v, ok := value.(string)
-		if !ok {
-			return fmt.Errorf("unexpected type %T for field %s", value, name)
-		}
-		m.SetFileInStorage(v)
-		return nil
 	}
 	return fmt.Errorf("unknown Episode field %s", name)
 }
@@ -1640,9 +1576,6 @@ func (m *EpisodeMutation) ClearedFields() []string {
 	if m.FieldCleared(episode.FieldMediaID) {
 		fields = append(fields, episode.FieldMediaID)
 	}
-	if m.FieldCleared(episode.FieldFileInStorage) {
-		fields = append(fields, episode.FieldFileInStorage)
-	}
 	return fields
 }
 
@@ -1660,9 +1593,6 @@ func (m *EpisodeMutation) ClearField(name string) error {
 	case episode.FieldMediaID:
 		m.ClearMediaID()
 		return nil
-	case episode.FieldFileInStorage:
-		m.ClearFileInStorage()
-		return nil
 	}
 	return fmt.Errorf("unknown Episode nullable field %s", name)
 }
@@ -1692,9 +1622,6 @@ func (m *EpisodeMutation) ResetField(name string) error {
 	case episode.FieldStatus:
 		m.ResetStatus()
 		return nil
-	case episode.FieldFileInStorage:
-		m.ResetFileInStorage()
-		return nil
 	}
 	return fmt.Errorf("unknown Episode field %s", name)
 }
@@ -3202,30 +3129,31 @@ func (m *IndexersMutation) ResetEdge(name string) error {
 // MediaMutation represents an operation that mutates the Media nodes in the graph.
 type MediaMutation struct {
 	config
-	op              Op
-	typ             string
-	id              *int
-	tmdb_id         *int
-	addtmdb_id      *int
-	imdb_id         *string
-	media_type      *media.MediaType
-	name_cn         *string
-	name_en         *string
-	original_name   *string
-	overview        *string
-	created_at      *time.Time
-	air_date        *string
-	resolution      *media.Resolution
-	storage_id      *int
-	addstorage_id   *int
-	target_dir      *string
-	clearedFields   map[string]struct{}
-	episodes        map[int]struct{}
-	removedepisodes map[int]struct{}
-	clearedepisodes bool
-	done            bool
-	oldValue        func(context.Context) (*Media, error)
-	predicates      []predicate.Media
+	op                        Op
+	typ                       string
+	id                        *int
+	tmdb_id                   *int
+	addtmdb_id                *int
+	imdb_id                   *string
+	media_type                *media.MediaType
+	name_cn                   *string
+	name_en                   *string
+	original_name             *string
+	overview                  *string
+	created_at                *time.Time
+	air_date                  *string
+	resolution                *media.Resolution
+	storage_id                *int
+	addstorage_id             *int
+	target_dir                *string
+	download_history_episodes *bool
+	clearedFields             map[string]struct{}
+	episodes                  map[int]struct{}
+	removedepisodes           map[int]struct{}
+	clearedepisodes           bool
+	done                      bool
+	oldValue                  func(context.Context) (*Media, error)
+	predicates                []predicate.Media
 }
 
 var _ ent.Mutation = (*MediaMutation)(nil)
@@ -3838,6 +3766,55 @@ func (m *MediaMutation) ResetTargetDir() {
 	delete(m.clearedFields, media.FieldTargetDir)
 }
 
+// SetDownloadHistoryEpisodes sets the "download_history_episodes" field.
+func (m *MediaMutation) SetDownloadHistoryEpisodes(b bool) {
+	m.download_history_episodes = &b
+}
+
+// DownloadHistoryEpisodes returns the value of the "download_history_episodes" field in the mutation.
+func (m *MediaMutation) DownloadHistoryEpisodes() (r bool, exists bool) {
+	v := m.download_history_episodes
+	if v == nil {
+		return
+	}
+	return *v, true
+}
+
+// OldDownloadHistoryEpisodes returns the old "download_history_episodes" field's value of the Media entity.
+// If the Media object wasn't provided to the builder, the object is fetched from the database.
+// An error is returned if the mutation operation is not UpdateOne, or the database query fails.
+func (m *MediaMutation) OldDownloadHistoryEpisodes(ctx context.Context) (v bool, err error) {
+	if !m.op.Is(OpUpdateOne) {
+		return v, errors.New("OldDownloadHistoryEpisodes is only allowed on UpdateOne operations")
+	}
+	if m.id == nil || m.oldValue == nil {
+		return v, errors.New("OldDownloadHistoryEpisodes requires an ID field in the mutation")
+	}
+	oldValue, err := m.oldValue(ctx)
+	if err != nil {
+		return v, fmt.Errorf("querying old value for OldDownloadHistoryEpisodes: %w", err)
+	}
+	return oldValue.DownloadHistoryEpisodes, nil
+}
+
+// ClearDownloadHistoryEpisodes clears the value of the "download_history_episodes" field.
+func (m *MediaMutation) ClearDownloadHistoryEpisodes() {
+	m.download_history_episodes = nil
+	m.clearedFields[media.FieldDownloadHistoryEpisodes] = struct{}{}
+}
+
+// DownloadHistoryEpisodesCleared returns if the "download_history_episodes" field was cleared in this mutation.
+func (m *MediaMutation) DownloadHistoryEpisodesCleared() bool {
+	_, ok := m.clearedFields[media.FieldDownloadHistoryEpisodes]
+	return ok
+}
+
+// ResetDownloadHistoryEpisodes resets all changes to the "download_history_episodes" field.
+func (m *MediaMutation) ResetDownloadHistoryEpisodes() {
+	m.download_history_episodes = nil
+	delete(m.clearedFields, media.FieldDownloadHistoryEpisodes)
+}
+
 // AddEpisodeIDs adds the "episodes" edge to the Episode entity by ids.
 func (m *MediaMutation) AddEpisodeIDs(ids ...int) {
 	if m.episodes == nil {
@@ -3926,7 +3903,7 @@ func (m *MediaMutation) Type() string {
 // order to get all numeric fields that were incremented/decremented, call
 // AddedFields().
 func (m *MediaMutation) Fields() []string {
-	fields := make([]string, 0, 12)
+	fields := make([]string, 0, 13)
 	if m.tmdb_id != nil {
 		fields = append(fields, media.FieldTmdbID)
 	}
@@ -3963,6 +3940,9 @@ func (m *MediaMutation) Fields() []string {
 	if m.target_dir != nil {
 		fields = append(fields, media.FieldTargetDir)
 	}
+	if m.download_history_episodes != nil {
+		fields = append(fields, media.FieldDownloadHistoryEpisodes)
+	}
 	return fields
 }
 
@@ -3995,6 +3975,8 @@ func (m *MediaMutation) Field(name string) (ent.Value, bool) {
 		return m.StorageID()
 	case media.FieldTargetDir:
 		return m.TargetDir()
+	case media.FieldDownloadHistoryEpisodes:
+		return m.DownloadHistoryEpisodes()
 	}
 	return nil, false
 }
@@ -4028,6 +4010,8 @@ func (m *MediaMutation) OldField(ctx context.Context, name string) (ent.Value, e
 		return m.OldStorageID(ctx)
 	case media.FieldTargetDir:
 		return m.OldTargetDir(ctx)
+	case media.FieldDownloadHistoryEpisodes:
+		return m.OldDownloadHistoryEpisodes(ctx)
 	}
 	return nil, fmt.Errorf("unknown Media field %s", name)
 }
@@ -4121,6 +4105,13 @@ func (m *MediaMutation) SetField(name string, value ent.Value) error {
 		}
 		m.SetTargetDir(v)
 		return nil
+	case media.FieldDownloadHistoryEpisodes:
+		v, ok := value.(bool)
+		if !ok {
+			return fmt.Errorf("unexpected type %T for field %s", value, name)
+		}
+		m.SetDownloadHistoryEpisodes(v)
+		return nil
 	}
 	return fmt.Errorf("unknown Media field %s", name)
 }
@@ -4187,6 +4178,9 @@ func (m *MediaMutation) ClearedFields() []string {
 	if m.FieldCleared(media.FieldTargetDir) {
 		fields = append(fields, media.FieldTargetDir)
 	}
+	if m.FieldCleared(media.FieldDownloadHistoryEpisodes) {
+		fields = append(fields, media.FieldDownloadHistoryEpisodes)
+	}
 	return fields
 }
 
@@ -4210,6 +4204,9 @@ func (m *MediaMutation) ClearField(name string) error {
 	case media.FieldTargetDir:
 		m.ClearTargetDir()
 		return nil
+	case media.FieldDownloadHistoryEpisodes:
+		m.ClearDownloadHistoryEpisodes()
+		return nil
 	}
 	return fmt.Errorf("unknown Media nullable field %s", name)
 }
@@ -4254,6 +4251,9 @@ func (m *MediaMutation) ResetField(name string) error {
 	case media.FieldTargetDir:
 		m.ResetTargetDir()
 		return nil
+	case media.FieldDownloadHistoryEpisodes:
+		m.ResetDownloadHistoryEpisodes()
+		return nil
 	}
 	return fmt.Errorf("unknown Media field %s", name)
 }

ent/runtime.go

@@ -70,6 +70,10 @@ func init() {
 	mediaDescAirDate := mediaFields[8].Descriptor()
 	// media.DefaultAirDate holds the default value on creation for the air_date field.
 	media.DefaultAirDate = mediaDescAirDate.Default.(string)
+	// mediaDescDownloadHistoryEpisodes is the schema descriptor for download_history_episodes field.
+	mediaDescDownloadHistoryEpisodes := mediaFields[12].Descriptor()
+	// media.DefaultDownloadHistoryEpisodes holds the default value on creation for the download_history_episodes field.
+	media.DefaultDownloadHistoryEpisodes = mediaDescDownloadHistoryEpisodes.Default.(bool)
 	storageFields := schema.Storage{}.Fields()
 	_ = storageFields
 	// storageDescDeleted is the schema descriptor for deleted field.

ent/schema/media.go

@@ -28,6 +28,7 @@ func (Media) Fields() []ent.Field {
 		field.Enum("resolution").Values("720p", "1080p", "4k").Default("1080p"),
 		field.Int("storage_id").Optional(),
 		field.String("target_dir").Optional(),
+		field.Bool("download_history_episodes").Optional().Default(false).Comment("tv series only"),
 	}
 }
 

go.sum

@@ -93,6 +93,8 @@ github.com/magiconair/properties v1.8.7 h1:IeQXZAiQcpL9mgcAe1Nu6cX9LLw6ExEHKjN0V
 github.com/magiconair/properties v1.8.7/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-runewidth v0.0.9 h1:Lm995f3rfxdpd6TSmuVCHVb/QhupuXlYr8sCI/QdE+0=
+github.com/mattn/go-runewidth v0.0.9/go.mod h1:H031xJmbD/WCDINGzjvQ9THkh0rPKHF+m2gUSrubnMI=
 github.com/mattn/go-sqlite3 v1.14.16 h1:yOQRA0RpS5PFz/oikGwBEqvAWhWg5ufRz4ETLjwpU1Y=
 github.com/mattn/go-sqlite3 v1.14.16/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
 github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 h1:DpOJ2HYzCv8LZP15IdmG+YdwD2luVPHITV96TkirNBM=
@@ -106,6 +108,8 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
 github.com/natefinch/lumberjack v2.0.0+incompatible h1:4QJd3OLAMgj7ph+yZTuX13Ld4UpgHp07nNdFX7mqFfM=
 github.com/natefinch/lumberjack v2.0.0+incompatible/go.mod h1:Wi9p2TTF5DG5oU+6YfsmYQpsTIOm0B1VNzQg9Mw6nPk=
+github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N7AbDhec=
+github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY=
 github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
 github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
@@ -129,6 +133,8 @@ github.com/spf13/afero v1.11.0 h1:WJQKhtpdm3v2IzqG8VMqrr6Rf3UYpEF239Jy9wNepM8=
 github.com/spf13/afero v1.11.0/go.mod h1:GH9Y3pIexgf1MTIWtNGyogA5MwRIDXGUr+hbWNoBjkY=
 github.com/spf13/cast v1.6.0 h1:GEiTHELF+vaR5dhz3VqZfFSzZjYbgeKDpBxQVS4GYJ0=
 github.com/spf13/cast v1.6.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
+github.com/spf13/cobra v1.7.0 h1:hyqWnYt1ZQShIddO5kBpj3vu05/++x6tJ6dg8EC572I=
+github.com/spf13/cobra v1.7.0/go.mod h1:uLxZILRyS/50WlhOIKD7W6V5bgeIt+4sICxh6uRMrb0=
 github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/spf13/viper v1.19.0 h1:RWq5SEjt8o25SROyN3z2OrDB9l7RPd3lwTWU8EcEdcI=
@@ -177,6 +183,8 @@ golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR
 golang.org/x/net v0.0.0-20200301022130-244492dfa37a/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.25.0 h1:d/OCCoBEUq33pjydKrGQhw7IlUPI2Oylr+8qLx49kac=
 golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
+golang.org/x/sync v0.7.0 h1:YsImfSBoP9QPYL0xyKJPq0gcaJdG3rInoqxTWbfQu9M=
+golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
@@ -188,6 +196,8 @@ golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4=
 golang.org/x/text v0.16.0/go.mod h1:GhwF1Be+LQoKShO3cGOHzqOgRrGaYc9AvblQOmPVHnI=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
 google.golang.org/appengine v1.6.5/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
 google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg=
 google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=

log/log.go

@@ -1,6 +1,7 @@
 package log
 
 import (
+	"os"
 	"path/filepath"
 	"strings"
 
@@ -18,12 +19,16 @@ func init() {
 	atom = zap.NewAtomicLevel()
 	atom.SetLevel(zap.DebugLevel)
 
-	w := zapcore.AddSync(&lumberjack.Logger{
-		Filename:   filepath.Join(dataPath, "logs", "polaris.log"),
-		MaxSize:    50, // megabytes
-		MaxBackups: 3,
-		MaxAge:     30, // days
-	})
+	w := zapcore.Lock(os.Stdout)
+	if os.Getenv("GIN_MODE") == "release" {
+		w = zapcore.AddSync(&lumberjack.Logger{
+			Filename:   filepath.Join(dataPath, "logs", "polaris.log"),
+			MaxSize:    50, // megabytes
+			MaxBackups: 3,
+			MaxAge:     30, // days
+		})
+	
+	}
 
 	consoleEncoder := zapcore.NewConsoleEncoder(zap.NewDevelopmentEncoderConfig())
 

pkg/metadata/tv.go

@@ -112,25 +112,25 @@ func parseEnglishName(name string) *Metadata {
 		}
 	} else { //no episode, maybe like  One Punch Man S2 - 08 [1080p].mkv
 
-		numRe := regexp.MustCompile(`^\d{1,2}$`)
-		for i, p := range newSplits {
-			if numRe.MatchString(p) {
-				if i > 0 && strings.Contains(newSplits[i-1], "season") { //last word cannot be season
-					continue
-				}
-				if i < seasonIndex {
-					//episode number most likely  should comes alfter season number
-					continue
-				}
-				//episodeIndex = i
-				n, err := strconv.Atoi(p)
-				if err != nil {
-					panic(fmt.Sprintf("convert %s error: %v", p, err))
-				}
-				meta.Episode = n
+		// numRe := regexp.MustCompile(`^\d{1,2}$`)
+		// for i, p := range newSplits {
+		// 	if numRe.MatchString(p) {
+		// 		if i > 0 && strings.Contains(newSplits[i-1], "season") { //last word cannot be season
+		// 			continue
+		// 		}
+		// 		if i < seasonIndex {
+		// 			//episode number most likely  should comes alfter season number
+		// 			continue
+		// 		}
+		// 		//episodeIndex = i
+		// 		n, err := strconv.Atoi(p)
+		// 		if err != nil {
+		// 			panic(fmt.Sprintf("convert %s error: %v", p, err))
+		// 		}
+		// 		meta.Episode = n
 
-			}
-		}
+		// 	}
+		// }
 
 	}
 	if resIndex != -1 {

server/auth.go

@@ -5,7 +5,6 @@ import (
 	"polaris/db"
 	"polaris/log"
 	"polaris/pkg/utils"
-	"strings"
 	"time"
 
 	"github.com/gin-gonic/gin"
@@ -23,16 +22,15 @@ func (s *Server) authModdleware(c *gin.Context) {
 		c.Next()
 		return
 	}
-
-	auth := c.GetHeader("Authorization")
-	if auth == "" {
-		log.Infof("token is not present, abort")
+	token, err := c.Cookie("token")
+	if err != nil {
+		log.Errorf("token error: %v", err)
 		c.AbortWithStatus(http.StatusForbidden)
 		return
 	}
-	auth = strings.TrimPrefix(auth, "Bearer ")
-	//log.Infof("current token: %v", auth)
-	token, err := jwt.ParseWithClaims(auth, &jwt.RegisteredClaims{}, func(t *jwt.Token) (interface{}, error) {	
+
+	//log.Debugf("current token: %v", auth)
+	tokenParsed, err := jwt.ParseWithClaims(token, &jwt.RegisteredClaims{}, func(t *jwt.Token) (interface{}, error) {
 		return []byte(s.jwtSerect), nil
 	})
 	if err != nil {
@@ -40,15 +38,15 @@ func (s *Server) authModdleware(c *gin.Context) {
 		c.AbortWithStatus(http.StatusForbidden)
 		return
 	}
-	if !token.Valid {
-		log.Errorf("token is not valid: %v", auth)
+	if !tokenParsed.Valid {
+		log.Errorf("token is not valid: %v", token)
 		c.AbortWithStatus(http.StatusForbidden)
 		return
 	}
-	claim := token.Claims.(*jwt.RegisteredClaims)
+	claim := tokenParsed.Claims.(*jwt.RegisteredClaims)
 
 	if time.Until(claim.ExpiresAt.Time) <= 0 {
-		log.Infof("token is no longer valid: %s", auth)
+		log.Infof("token is no longer valid: %s", token)
 		c.AbortWithStatus(http.StatusForbidden)
 		return
 	}
@@ -61,7 +59,6 @@ type LoginIn struct {
 	Password string `json:"password"`
 }
 
-
 func (s *Server) Login(c *gin.Context) (interface{}, error) {
 	var in LoginIn
 
@@ -93,11 +90,23 @@ func (s *Server) Login(c *gin.Context) (interface{}, error) {
 	if err != nil {
 		return nil, errors.Wrap(err, "sign")
 	}
+	c.SetSameSite(http.SameSiteNoneMode)
+	c.SetCookie("token", sig, 0, "/", "", true, false)
 	return gin.H{
 		"token": sig,
 	}, nil
 }
 
+func (s *Server) Logout(c *gin.Context) (interface{}, error) {
+	if !s.isAuthEnabled() {
+		return nil, errors.New( "auth is not enabled")
+	}
+
+	c.SetSameSite(http.SameSiteNoneMode)
+	c.SetCookie("token", "", -1, "/", "", true, false)
+	return nil, nil
+}
+
 type EnableAuthIn struct {
 	Enable   bool   `json:"enable"`
 	User     string `json:"user"`

server/core/torrent.go

@@ -28,10 +28,10 @@ func isNumberedSeries(detail *db.MediaDetails) bool {
 			if ep.EpisodeNumber == 1 {
 				season2HasEpisode1 = true
 			}
-	
+
 		}
 	}
-	return hasSeason2 && !season2HasEpisode1//only one 1st episode
+	return hasSeason2 && !season2HasEpisode1 //only one 1st episode
 }
 
 func SearchEpisode(db1 *db.Client, seriesId, seasonNum, episodeNum int, checkResolution bool) ([]torznab.Result, error) {
@@ -54,7 +54,7 @@ func SearchEpisode(db1 *db.Client, seriesId, seasonNum, episodeNum int, checkRes
 		if !isNumberedSeries(series) { //do not check season on series that only rely on episode number
 			if meta.Season != seasonNum {
 				continue
-			}	
+			}
 		}
 		if isNumberedSeries(series) && episodeNum == -1 {
 			//should not want season
@@ -63,7 +63,7 @@ func SearchEpisode(db1 *db.Client, seriesId, seasonNum, episodeNum int, checkRes
 
 		if episodeNum != -1 && meta.Episode != episodeNum { //not season pack, episode number equals
 			continue
-		} else if seasonNum == -1 && !meta.IsSeasonPack { //want season pack, but not season pack
+		}else if episodeNum == -1 && !meta.IsSeasonPack { //want season pack, but not season pack
 			continue
 		}
 		if checkResolution && meta.Resolution != series.Resolution.String() {
@@ -131,7 +131,7 @@ func searchWithTorznab(db *db.Client, q string) []torznab.Result {
 
 	for _, tor := range allTorznab {
 		wg.Add(1)
-		go func ()  {
+		go func() {
 			log.Debugf("search torznab %v with %v", tor.Name, q)
 			defer wg.Done()
 			resp, err := torznab.Search(tor.URL, tor.ApiKey, q)
@@ -140,7 +140,7 @@ func searchWithTorznab(db *db.Client, q string) []torznab.Result {
 				return
 			}
 			resChan <- resp
-	
+
 		}()
 	}
 	go func() {

server/resources.go

@@ -5,20 +5,17 @@ import (
 	"polaris/ent"
 	"polaris/ent/episode"
 	"polaris/ent/history"
+	"polaris/ent/media"
 	"polaris/log"
+	"polaris/pkg/torznab"
 	"polaris/pkg/utils"
 	"polaris/server/core"
-	"strconv"
 
 	"github.com/gin-gonic/gin"
 	"github.com/pkg/errors"
 )
 
 func (s *Server) searchAndDownloadSeasonPackage(seriesId, seasonNum int) (*string, error) {
-	trc, err := s.getDownloadClient()
-	if err != nil {
-		return nil, errors.Wrap(err, "connect transmission")
-	}
 
 	res, err := core.SearchSeasonPackage(s.db, seriesId, seasonNum, true)
 	if err != nil {
@@ -27,7 +24,15 @@ func (s *Server) searchAndDownloadSeasonPackage(seriesId, seasonNum int) (*strin
 
 	r1 := res[0]
 	log.Infof("found resource to download: %+v", r1)
+	return s.downloadSeasonPackage(r1, seriesId, seasonNum)
 
+}
+
+func (s *Server) downloadSeasonPackage(r1 torznab.Result, seriesId, seasonNum int) (*string, error) {
+	trc, err := s.getDownloadClient()
+	if err != nil {
+		return nil, errors.Wrap(err, "connect transmission")
+	}
 	downloadDir := s.db.GetDownloadDir()
 	size := utils.AvailableSpace(downloadDir)
 	if size < uint64(r1.Size) {
@@ -63,9 +68,10 @@ func (s *Server) searchAndDownloadSeasonPackage(seriesId, seasonNum int) (*strin
 
 	s.tasks[history.ID] = &Task{Torrent: torrent}
 	return &r1.Name, nil
+
 }
 
-func (s *Server) searchAndDownload(seriesId, seasonNum, episodeNum int) (*string, error) {
+func (s *Server) downloadEpisodeTorrent(r1 torznab.Result, seriesId, seasonNum, episodeNum int) (*string, error) {
 	trc, err := s.getDownloadClient()
 	if err != nil {
 		return nil, errors.Wrap(err, "connect transmission")
@@ -83,13 +89,6 @@ func (s *Server) searchAndDownload(seriesId, seasonNum, episodeNum int) (*string
 	if ep == nil {
 		return nil, errors.Errorf("no episode of season %d episode %d", seasonNum, episodeNum)
 	}
-
-	res, err := core.SearchEpisode(s.db, seriesId, seasonNum, episodeNum, true)
-	if err != nil {
-		return nil, err
-	}
-	r1 := res[0]
-	log.Infof("found resource to download: %+v", r1)
 	torrent, err := trc.Download(r1.Link, s.db.GetDownloadDir())
 	if err != nil {
 		return nil, errors.Wrap(err, "downloading")
@@ -116,6 +115,17 @@ func (s *Server) searchAndDownload(seriesId, seasonNum, episodeNum int) (*string
 
 	log.Infof("success add %s to download task", r1.Name)
 	return &r1.Name, nil
+
+}
+func (s *Server) searchAndDownload(seriesId, seasonNum, episodeNum int) (*string, error) {
+
+	res, err := core.SearchEpisode(s.db, seriesId, seasonNum, episodeNum, true)
+	if err != nil {
+		return nil, err
+	}
+	r1 := res[0]
+	log.Infof("found resource to download: %+v", r1)
+	return s.downloadEpisodeTorrent(r1, seriesId, seasonNum, episodeNum)
 }
 
 type searchAndDownloadIn struct {
@@ -124,15 +134,46 @@ type searchAndDownloadIn struct {
 	Episode int `json:"episode"`
 }
 
-func (s *Server) SearchAvailableEpisodeResource(c *gin.Context) (interface{}, error) {
+func (s *Server) SearchAvailableTorrents(c *gin.Context) (interface{}, error) {
 	var in searchAndDownloadIn
 	if err := c.ShouldBindJSON(&in); err != nil {
 		return nil, errors.Wrap(err, "bind json")
 	}
-	log.Infof("search episode resources link: %v", in)
-	res, err := core.SearchEpisode(s.db, in.ID, in.Season, in.Episode, true)
+	m, err := s.db.GetMedia(in.ID)
 	if err != nil {
-		return nil, errors.Wrap(err, "search episode")
+		return nil, errors.Wrap(err, "get media")
+	}
+	log.Infof("search torrents resources link: %+v", in)
+
+	var res []torznab.Result
+	if m.MediaType == media.MediaTypeTv {
+		if in.Episode == 0 {
+			//search season package
+			log.Infof("search series season package S%02d", in.Season)
+			res, err = core.SearchSeasonPackage(s.db, in.ID, in.Season, false)
+			if err != nil {
+				return nil, errors.Wrap(err, "search season package")
+			}
+		} else {
+			log.Infof("search series episode S%02dE%02d", in.Season, in.Episode)
+			res, err = core.SearchEpisode(s.db, in.ID, in.Season, in.Episode, false)
+			if err != nil {
+				if err.Error() == "no resource found" {
+					return []TorznabSearchResult{}, nil
+				}
+				return nil, errors.Wrap(err, "search episode")
+			}
+
+		}
+	} else {
+		log.Info("search movie %d", in.ID)
+		res, err = core.SearchMovie(s.db, in.ID, false)
+		if err != nil {
+			if err.Error() == "no resource found" {
+				return []TorznabSearchResult{}, nil
+			}
+			return nil, err
+		}
 	}
 	var searchResults []TorznabSearchResult
 	for _, r := range res {
@@ -144,9 +185,6 @@ func (s *Server) SearchAvailableEpisodeResource(c *gin.Context) (interface{}, er
 			Link:    r.Link,
 		})
 	}
-	if len(searchResults) == 0 {
-		return nil, errors.New("no resource found")
-	}
 	return searchResults, nil
 }
 
@@ -187,59 +225,45 @@ type TorznabSearchResult struct {
 	Peers   int    `json:"peers"`
 	Source  string `json:"source"`
 }
-
-func (s *Server) SearchAvailableMovies(c *gin.Context) (interface{}, error) {
-	ids := c.Param("id")
-	id, err := strconv.Atoi(ids)
-	if err != nil {
-		return nil, errors.Wrap(err, "convert")
-	}
-
-	res, err := core.SearchMovie(s.db, id, false)
-	if err != nil {
-		if err.Error() == "no resource found" {
-			return []TorznabSearchResult{}, nil
-		}
-		return nil, err
-	}
-
-	var searchResults []TorznabSearchResult
-	for _, r := range res {
-		searchResults = append(searchResults, TorznabSearchResult{
-			Name:    r.Name,
-			Size:    r.Size,
-			Seeders: r.Seeders,
-			Peers:   r.Peers,
-			Link:    r.Link,
-			Source:  r.Source,
-		})
-	}
-	if len(searchResults) == 0 {
-		return []TorznabSearchResult{}, nil
-	}
-	return searchResults, nil
-}
-
 type downloadTorrentIn struct {
-	MediaID int `json:"media_id" binding:"required"`
+	MediaID int `json:"id" binding:"required"`
+	Season  int `json:"season"`
+	Episode int `json:"episode"`
 	TorznabSearchResult
 }
 
-func (s *Server) DownloadMovieTorrent(c *gin.Context) (interface{}, error) {
+func (s *Server) DownloadTorrent(c *gin.Context) (interface{}, error) {
 	var in downloadTorrentIn
 	if err := c.ShouldBindJSON(&in); err != nil {
 		return nil, errors.Wrap(err, "bind json")
 	}
 	log.Infof("download torrent input: %+v", in)
 
+	m, err := s.db.GetMedia(in.MediaID)
+	if err != nil {
+		return nil, fmt.Errorf("no tv series of id %v", in.MediaID)
+	}
+	if m.MediaType == media.MediaTypeTv {
+		if in.Episode == 0 {
+			//download season package
+			name := in.Name
+			if name == "" {
+				name = fmt.Sprintf("%v S%02d", m.OriginalName, in.Season)
+			}
+			res := torznab.Result{Name: name, Link: in.Link, Size: in.Size}
+			return s.downloadSeasonPackage(res, in.MediaID, in.Season)
+		}
+		name := in.Name
+		if name == "" {
+			name = fmt.Sprintf("%v S%02dE%02d", m.OriginalName, in.Season, in.Episode)
+		}
+		res := torznab.Result{Name: name, Link: in.Link, Size: in.Size}
+		return s.downloadEpisodeTorrent(res, in.MediaID, in.Season, in.Episode)
+	}
 	trc, err := s.getDownloadClient()
 	if err != nil {
 		return nil, errors.Wrap(err, "connect transmission")
 	}
-	media := s.db.GetMediaDetails(in.MediaID)
-	if media == nil {
-		return nil, fmt.Errorf("no tv series of id %v", in.MediaID)
-	}
 
 	torrent, err := trc.Download(in.Link, s.db.GetDownloadDir())
 	if err != nil {
@@ -248,12 +272,12 @@ func (s *Server) DownloadMovieTorrent(c *gin.Context) (interface{}, error) {
 	torrent.Start()
 	name := in.Name
 	if name == "" {
-		name = media.OriginalName
+		name = m.OriginalName
 	}
 	go func() {
-		ep := media.Episodes[0]
+		ep, _ := s.db.GetMovieDummyEpisode(m.ID)
 		history, err := s.db.SaveHistoryRecord(ent.History{
-			MediaID:     media.ID,
+			MediaID:     m.ID,
 			EpisodeID:   ep.ID,
 			SourceTitle: name,
 			TargetDir:   "./",

server/scheduler.go

@@ -192,12 +192,18 @@ func (s *Server) checkDownloadedSeriesFiles(m *ent.Media) error {
 				log.Errorf("find season episode num error: %v", err)
 				continue
 			}
-			var dirname = filepath.Join(in.Name(), ep.Name())
 			log.Infof("found match, season num %d, episode num %d", seNum, epNum)
-			err = s.db.UpdateEpisodeFile(m.ID, seNum, epNum, dirname)
+			ep, err := s.db.GetEpisode(m.ID, seNum, epNum)
 			if err != nil {
 				log.Error("update episode: %v", err)
+				continue
 			}
+			err = s.db.SetEpisodeStatus(ep.ID, episode.StatusDownloaded)
+			if err != nil {
+				log.Error("update episode: %v", err)
+				continue
+			}
+
 		}
 	}
 	return nil
@@ -215,14 +221,17 @@ func (s *Server) downloadTvSeries() {
 	for _, series := range allSeries {
 		tvDetail := s.db.GetMediaDetails(series.ID)
 		for _, ep := range tvDetail.Episodes {
-			t, err := time.Parse("2006-01-02", ep.AirDate)
-			if err != nil {
-				log.Error("air date not known, skip: %v", ep.Title)
-				continue
-			}
-			if series.CreatedAt.Sub(t) > 24*time.Hour { //剧集在加入watchlist之前，不去下载
-				continue
+			if !series.DownloadHistoryEpisodes { //设置不下载历史已播出剧集，只下载将来剧集
+				t, err := time.Parse("2006-01-02", ep.AirDate)
+				if err != nil {
+					log.Error("air date not known, skip: %v", ep.Title)
+					continue
+				}
+				if series.CreatedAt.Sub(t) > 24*time.Hour { //剧集在加入watchlist之前，不去下载
+					continue
+				}	
 			}
+			
 			if ep.Status != episode.StatusMissing { //已经下载的不去下载
 				continue
 			}

server/server.go

@@ -43,6 +43,8 @@ type Server struct {
 func (s *Server) Serve() error {
 	s.scheduler()
 	s.reloadTasks()
+	s.restoreProxy()
+
 	s.jwtSerect = s.db.GetSetting(db.JwtSerectKey)
 	//st, _ := fs.Sub(ui.Web, "build/web")
 	s.r.Use(static.Serve("/", static.EmbedFolder(ui.Web, "build/web")))
@@ -61,12 +63,15 @@ func (s *Server) Serve() error {
 
 	setting := api.Group("/setting")
 	{
+		setting.GET("/logout", HttpHandler(s.Logout))
 		setting.POST("/general", HttpHandler(s.SetSetting))
 		setting.GET("/general", HttpHandler(s.GetSetting))
 		setting.POST("/auth", HttpHandler(s.EnableAuth))
 		setting.GET("/auth", HttpHandler(s.GetAuthSetting))
 		setting.GET("/logfiles", HttpHandler(s.GetAllLogs))
 		setting.GET("/about", HttpHandler(s.About))
+		setting.POST("/parse/tv", HttpHandler(s.ParseTv))
+		setting.POST("/parse/movie", HttpHandler(s.ParseMovie))
 	}
 	activity := api.Group("/activity")
 	{
@@ -81,11 +86,10 @@ func (s *Server) Serve() error {
 		tv.GET("/search", HttpHandler(s.SearchMedia))
 		tv.POST("/tv/watchlist", HttpHandler(s.AddTv2Watchlist))
 		tv.GET("/tv/watchlist", HttpHandler(s.GetTvWatchlist))
-		tv.POST("/tv/torrents", HttpHandler(s.SearchAvailableEpisodeResource))
+		tv.POST("/torrents", HttpHandler(s.SearchAvailableTorrents))
+		tv.POST("/torrents/download/", HttpHandler(s.DownloadTorrent))
 		tv.POST("/movie/watchlist", HttpHandler(s.AddMovie2Watchlist))
 		tv.GET("/movie/watchlist", HttpHandler(s.GetMovieWatchlist))
-		tv.GET("/movie/resources/:id", HttpHandler(s.SearchAvailableMovies))
-		tv.POST("/movie/resources/", HttpHandler(s.DownloadMovieTorrent))
 		tv.GET("/record/:id", HttpHandler(s.GetMediaDetails))
 		tv.DELETE("/record/:id", HttpHandler(s.DeleteFromWatchlist))
 		tv.GET("/resolutions", HttpHandler(s.GetAvailableResolutions))

server/setting.go

@@ -2,6 +2,8 @@ package server
 
 import (
 	"fmt"
+	"net/http"
+	"net/url"
 	"polaris/db"
 	"polaris/log"
 	"polaris/pkg/transmission"
@@ -15,6 +17,7 @@ type GeneralSettings struct {
 	TmdbApiKey  string `json:"tmdb_api_key"`
 	DownloadDir string `json:"download_dir"`
 	LogLevel    string `json:"log_level"`
+	Proxy       string `json:"proxy"`
 }
 
 func (s *Server) SetSetting(c *gin.Context) (interface{}, error) {
@@ -29,6 +32,7 @@ func (s *Server) SetSetting(c *gin.Context) (interface{}, error) {
 		}
 	}
 	if in.DownloadDir != "" {
+		log.Info("set download dir to %s", in.DownloadDir)
 		if err := s.db.SetSetting(db.SettingDownloadDir, in.DownloadDir); err != nil {
 			return nil, errors.Wrap(err, "save download dir")
 		}
@@ -40,9 +44,30 @@ func (s *Server) SetSetting(c *gin.Context) (interface{}, error) {
 		}
 
 	}
+
+	s.setProxy(in.Proxy)
 	return nil, nil
 }
 
+func (s *Server) setProxy(proxy string) {
+	proxyUrl, err := url.Parse(proxy)
+	tp := http.DefaultTransport.(*http.Transport)
+	if proxy == "" || err != nil {
+		log.Warnf("proxy url not valid, disabling: %v", proxy)
+		tp.Proxy = nil
+		s.db.SetSetting(db.SettingProxy, "")
+	} else {
+		log.Infof("set proxy to %v", proxy)
+		tp.Proxy = http.ProxyURL(proxyUrl)
+		s.db.SetSetting(db.SettingProxy, proxy)
+	}
+}
+
+func (s *Server) restoreProxy() {
+	p := s.db.GetSetting(db.SettingProxy)
+	s.setProxy(p)
+}
+
 func (s *Server) GetSetting(c *gin.Context) (interface{}, error) {
 	tmdb := s.db.GetSetting(db.SettingTmdbApiKey)
 	downloadDir := s.db.GetSetting(db.SettingDownloadDir)
@@ -51,6 +76,7 @@ func (s *Server) GetSetting(c *gin.Context) (interface{}, error) {
 		TmdbApiKey:  tmdb,
 		DownloadDir: downloadDir,
 		LogLevel:    logLevel,
+		Proxy:       s.db.GetSetting(db.SettingProxy),
 	}, nil
 }
 

server/storage.go

@@ -84,5 +84,6 @@ func (s *Server) SuggestedSeriesFolderName(c *gin.Context) (interface{}, error)
 	if year != "" {
 		name = fmt.Sprintf("%s (%s)", name, year)
 	}
+	log.Infof("tv series of tmdb id %v suggestting name is %v", id, name)
 	return gin.H{"name": name}, nil
 }

server/systems.go

@@ -4,6 +4,7 @@ import (
 	"os"
 	"polaris/db"
 	"polaris/log"
+	"polaris/pkg/metadata"
 	"polaris/pkg/uptime"
 	"runtime"
 
@@ -48,5 +49,26 @@ func (s *Server) About(c *gin.Context) (interface{}, error) {
 		"uptime":     uptime.Uptime(),
 		"chat_group": "https://t.me/+8R2nzrlSs2JhMDgx",
 		"go_version": runtime.Version(),
+		"version":    db.Version,
 	}, nil
 }
+
+type parseIn struct {
+	S         string `json:"s" binding:"required"`
+}
+
+func (s *Server) ParseTv(c *gin.Context) (interface{}, error) {
+	var in parseIn
+	if err := c.ShouldBindJSON(&in); err != nil {
+		return nil, errors.Wrap(err, "bind")
+	}
+	return metadata.ParseTv(in.S), nil
+}
+
+func (s *Server) ParseMovie(c *gin.Context) (interface{}, error) {
+	var in parseIn
+	if err := c.ShouldBindJSON(&in); err != nil {
+		return nil, errors.Wrap(err, "bind")
+	}
+	return metadata.ParseMovie(in.S), nil
+}

server/watchlist.go

@@ -57,10 +57,11 @@ func (s *Server) SearchMedia(c *gin.Context) (interface{}, error) {
 }
 
 type addWatchlistIn struct {
-	TmdbID     int    `json:"tmdb_id" binding:"required"`
-	StorageID  int    `json:"storage_id" `
-	Resolution string `json:"resolution" binding:"required"`
-	Folder     string `json:"folder"`
+	TmdbID                  int    `json:"tmdb_id" binding:"required"`
+	StorageID               int    `json:"storage_id" `
+	Resolution              string `json:"resolution" binding:"required"`
+	Folder                  string `json:"folder"`
+	DownloadHistoryEpisodes bool   `json:"download_history_episodes"` //for tv
 }
 
 func (s *Server) AddTv2Watchlist(c *gin.Context) (interface{}, error) {
@@ -121,6 +122,7 @@ func (s *Server) AddTv2Watchlist(c *gin.Context) (interface{}, error) {
 		Resolution:   media.Resolution(in.Resolution),
 		StorageID:    in.StorageID,
 		TargetDir:    in.Folder,
+		DownloadHistoryEpisodes: in.DownloadHistoryEpisodes,
 	}, epIds)
 	if err != nil {
 		return nil, errors.Wrap(err, "add to list")
@@ -273,7 +275,7 @@ func (s *Server) GetTvWatchlist(c *gin.Context) (interface{}, error) {
 				}
 				if ep.Status == episode.StatusMissing {
 					ms.Status = "monitoring"
-				}	
+				}
 			}
 		}
 		res[i] = ms

ui/lib/main.dart

@@ -2,7 +2,6 @@ import 'package:flutter/material.dart';
 import 'package:flutter_adaptive_scaffold/flutter_adaptive_scaffold.dart';
 import 'package:flutter_riverpod/flutter_riverpod.dart';
 import 'package:go_router/go_router.dart';
-import 'package:shared_preferences/shared_preferences.dart';
 import 'package:ui/activity.dart';
 import 'package:ui/login_page.dart';
 import 'package:ui/movie_watchlist.dart';
@@ -177,41 +176,30 @@ class _MainSkeletonState extends State<MainSkeleton> {
                   (BuildContext context, SearchController controller) {
             return [Text("dadada")];
           }),
-          FutureBuilder(
-              future: APIs.isLoggedIn(),
-              builder: (context, snapshot) {
-                if (snapshot.hasData && snapshot.data == true) {
-                  return MenuAnchor(
-                    menuChildren: [
-                      MenuItemButton(
-                        leadingIcon: const Icon(Icons.exit_to_app),
-                        child: const Text("登出"),
-                        onPressed: () async {
-                          final SharedPreferences prefs =
-                              await SharedPreferences.getInstance();
-                          await prefs.remove('token');
-                          if (context.mounted) {
-                            context.go(LoginScreen.route);
-                          }
-                        },
-                      ),
-                    ],
-                    builder: (context, controller, child) {
-                      return TextButton(
-                        onPressed: () {
-                          if (controller.isOpen) {
-                            controller.close();
-                          } else {
-                            controller.open();
-                          }
-                        },
-                        child: const Icon(Icons.account_circle),
-                      );
-                    },
-                  );
-                }
-                return Container();
-              })
+          MenuAnchor(
+                  menuChildren: [
+                    MenuItemButton(
+                      leadingIcon: const Icon(Icons.exit_to_app),
+                      child: const Text("登出"),
+                      onPressed: () async {
+                        await APIs.logout();
+                      },
+                    ),
+                  ],
+                  builder: (context, controller, child) {
+                    return TextButton(
+                      onPressed: () {
+                        if (controller.isOpen) {
+                          controller.close();
+                        } else {
+                          controller.open();
+                        }
+                      },
+                      child: const Icon(Icons.account_circle),
+                    );
+                  },
+                )
+              
         ],
       ),
       useDrawer: false,
@@ -235,7 +223,7 @@ class _MainSkeletonState extends State<MainSkeleton> {
       destinations: const <NavigationDestination>[
         NavigationDestination(
           icon: Icon(Icons.live_tv),
-          label: '电视剧',
+          label: '剧集',
         ),
         NavigationDestination(
           icon: Icon(Icons.movie),

ui/lib/movie_watchlist.dart

@@ -5,7 +5,6 @@ import 'package:ui/providers/APIs.dart';
 import 'package:ui/providers/activity.dart';
 import 'package:ui/providers/series_details.dart';
 import 'package:ui/providers/settings.dart';
-import 'package:ui/providers/welcome_data.dart';
 import 'package:ui/utils.dart';
 import 'package:ui/welcome_page.dart';
 import 'package:ui/widgets/progress_indicator.dart';
@@ -46,8 +45,8 @@ class _MovieDetailsPageState extends ConsumerState<MovieDetailsPage> {
                             fit: BoxFit.fitWidth,
                             opacity: 0.5,
                             image: NetworkImage(
-                                "${APIs.imagesUrl}/${details.id}/backdrop.jpg",
-                                headers: APIs.authHeaders))),
+                              "${APIs.imagesUrl}/${details.id}/backdrop.jpg",
+                            ))),
                     child: Padding(
                       padding: const EdgeInsets.all(10),
                       child: Row(
@@ -59,7 +58,6 @@ class _MovieDetailsPageState extends ConsumerState<MovieDetailsPage> {
                               child: Image.network(
                                 "${APIs.imagesUrl}/${details.id}/poster.jpg",
                                 fit: BoxFit.contain,
-                                headers: APIs.authHeaders,
                               ),
                             ),
                           ),
@@ -172,7 +170,6 @@ class _NestedTabBarState extends ConsumerState<NestedTabBar>
 
   @override
   Widget build(BuildContext context) {
-    var torrents = ref.watch(movieTorrentsDataProvider(widget.id));
     var histories = ref.watch(mediaHistoryDataProvider(widget.id));
 
     return Column(
@@ -223,48 +220,58 @@ class _NestedTabBarState extends ConsumerState<NestedTabBar>
                 error: (error, trace) => Text("$error"),
                 loading: () => const MyProgressIndicator());
           } else {
-            return torrents.when(
-                data: (v) {
-                  if (v.isEmpty) {
-                    return const Center(
-                      child: Text("无可用资源"),
-                    );
-                  }
+            return Consumer(
+              builder: (context, ref, child) {
+                var torrents = ref.watch(mediaTorrentsDataProvider(
+                    (mediaId: widget.id, seasonNumber: 0, episodeNumber: 0)));
+                return torrents.when(
+                    data: (v) {
+                      if (v.isEmpty) {
+                        return const Center(
+                          child: Text("无可用资源"),
+                        );
+                      }
 
-                  return DataTable(
-                    columns: const [
-                      DataColumn(label: Text("名称")),
-                      DataColumn(label: Text("大小")),
-                      DataColumn(label: Text("seeders")),
-                      DataColumn(label: Text("peers")),
-                      DataColumn(label: Text("操作"))
-                    ],
-                    rows: List.generate(v.length, (i) {
-                      final torrent = v[i];
-                      return DataRow(cells: [
-                        DataCell(Text("${torrent.name}")),
-                        DataCell(Text("${torrent.size?.readableFileSize()}")),
-                        DataCell(Text("${torrent.seeders}")),
-                        DataCell(Text("${torrent.peers}")),
-                        DataCell(IconButton(
-                          icon: const Icon(Icons.download),
-                          onPressed: () {
-                            ref
-                                .read(movieTorrentsDataProvider(widget.id)
-                                    .notifier)
-                                .download(torrent)
-                                .then((v) =>
-                                    Utils.showSnakeBar("开始下载：${torrent.name}"))
-                                .onError((error, trace) =>
-                                    Utils.showSnakeBar("操作失败: $error"));
-                          },
-                        ))
-                      ]);
-                    }),
-                  );
-                },
-                error: (error, trace) => Text("$error"),
-                loading: () => const MyProgressIndicator());
+                      return DataTable(
+                        columns: const [
+                          DataColumn(label: Text("名称")),
+                          DataColumn(label: Text("大小")),
+                          DataColumn(label: Text("seeders")),
+                          DataColumn(label: Text("peers")),
+                          DataColumn(label: Text("操作"))
+                        ],
+                        rows: List.generate(v.length, (i) {
+                          final torrent = v[i];
+                          return DataRow(cells: [
+                            DataCell(Text("${torrent.name}")),
+                            DataCell(
+                                Text("${torrent.size?.readableFileSize()}")),
+                            DataCell(Text("${torrent.seeders}")),
+                            DataCell(Text("${torrent.peers}")),
+                            DataCell(IconButton(
+                              icon: const Icon(Icons.download),
+                              onPressed: () {
+                                ref
+                                    .read(mediaTorrentsDataProvider((
+                                      mediaId: widget.id,
+                                      seasonNumber: 0,
+                                      episodeNumber: 0
+                                    )).notifier)
+                                    .download(torrent)
+                                    .then((v) => Utils.showSnakeBar(
+                                        "开始下载：${torrent.name}"))
+                                    .onError((error, trace) =>
+                                        Utils.showSnakeBar("操作失败: $error"));
+                              },
+                            ))
+                          ]);
+                        }),
+                      );
+                    },
+                    error: (error, trace) => Text("$error"),
+                    loading: () => const MyProgressIndicator());
+              },
+            );
           }
         })
       ],

ui/lib/providers/APIs.dart

@@ -2,8 +2,6 @@ import 'package:dio/dio.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:go_router/go_router.dart';
-import 'package:quiver/strings.dart';
-import 'package:shared_preferences/shared_preferences.dart';
 import 'package:ui/providers/server_response.dart';
 
 class APIs {
@@ -13,7 +11,8 @@ class APIs {
   static final settingsGeneralUrl = "$_baseUrl/api/v1/setting/general";
   static final watchlistTvUrl = "$_baseUrl/api/v1/media/tv/watchlist";
   static final watchlistMovieUrl = "$_baseUrl/api/v1/media/movie/watchlist";
-  static final availableMoviesUrl = "$_baseUrl/api/v1/media/movie/resources/";
+  static final availableTorrentsUrl = "$_baseUrl/api/v1/media/torrents/";
+  static final downloadTorrentUrl = "$_baseUrl/api/v1/media/torrents/download";
   static final seriesDetailUrl = "$_baseUrl/api/v1/media/record/";
   static final suggestedTvName = "$_baseUrl/api/v1/media/suggest/";
   static final searchAndDownloadUrl = "$_baseUrl/api/v1/indexer/download";
@@ -25,6 +24,7 @@ class APIs {
   static final delDownloadClientUrl = "$_baseUrl/api/v1/downloader/del/";
   static final storageUrl = "$_baseUrl/api/v1/storage/";
   static final loginUrl = "$_baseUrl/api/login";
+  static final logoutUrl = "$_baseUrl/api/v1/setting/logout";
   static final loginSettingUrl = "$_baseUrl/api/v1/setting/auth";
   static final activityUrl = "$_baseUrl/api/v1/activity/";
   static final activityMediaUrl = "$_baseUrl/api/v1/activity/media/";
@@ -48,53 +48,20 @@ class APIs {
     return "http://127.0.0.1:8080";
   }
 
-  static Dio? gDio;
-  static Map<String, String> authHeaders = {};
-
-  static Future<bool> isLoggedIn() async {
-    return isNotBlank(await getToken());
-  }
-
-  static Future<String> getToken() async {
-    var token = authHeaders["Authorization"];
-    if (isBlank(token)) {
-      final SharedPreferences prefs = await SharedPreferences.getInstance();
-      var t = prefs.getString("token");
-      if (isNotBlank(t)) {
-        authHeaders["Authorization"] = t!;
-        token = t;
-      }
-    }
-    return token ?? "";
-  }
-
-  static Future<Dio> getDio() async {
-    if (gDio != null) {
-      return gDio!;
-    }
-    var token = await getToken();
-
+  static Dio getDio() {
     var dio = Dio();
     dio.interceptors.add(InterceptorsWrapper(
-      onRequest: (options, handler) {
-        options.headers['Authorization'] = token;
-        return handler.next(options);
-      },
       onError: (error, handler) {
         if (error.response?.statusCode != null &&
             error.response?.statusCode! == 403) {
           final context = navigatorKey.currentContext;
           if (context != null) {
             context.go('/login');
-            gDio = null;
           }
         }
         return handler.next(error);
       },
     ));
-    if (isNotBlank(token)) {
-      gDio = dio;
-    }
     return dio;
   }
 
@@ -107,9 +74,19 @@ class APIs {
     if (sp.code != 0) {
       throw sp.message;
     }
-    final SharedPreferences prefs = await SharedPreferences.getInstance();
-    var t = sp.data["token"];
-    authHeaders["Authorization"] = "Bearer $t";
-    prefs.setString("token", "Bearer $t");
+  }
+
+  static Future<void> logout() async {
+    var resp = await getDio().get(APIs.logoutUrl);
+
+    var sp = ServerResponse.fromJson(resp.data);
+
+    if (sp.code != 0) {
+      throw sp.message;
+    }
+    final context = navigatorKey.currentContext;
+    if (context != null) {
+      context.go('/login');
+    }
   }
 }

ui/lib/providers/series_details.dart

@@ -97,7 +97,7 @@ class SeriesDetails {
 
 class Episodes {
   int? id;
-  int? seriesId;
+  int? mediaId;
   int? episodeNumber;
   String? title;
   String? airDate;
@@ -107,7 +107,7 @@ class Episodes {
 
   Episodes(
       {this.id,
-      this.seriesId,
+      this.mediaId,
       this.episodeNumber,
       this.title,
       this.airDate,
@@ -117,7 +117,7 @@ class Episodes {
 
   Episodes.fromJson(Map<String, dynamic> json) {
     id = json['id'];
-    seriesId = json['series_id'];
+    mediaId = json['media_id'];
     episodeNumber = json['episode_number'];
     title = json['title'];
     airDate = json['air_date'];
@@ -126,3 +126,85 @@ class Episodes {
     overview = json['overview'];
   }
 }
+
+var mediaTorrentsDataProvider = AsyncNotifierProvider.autoDispose
+    .family<MediaTorrentResource, List<TorrentResource>, TorrentQuery>(
+        MediaTorrentResource.new);
+
+// class TorrentQuery {
+//   final String mediaId;
+//   final int seasonNumber;
+//   final int episodeNumber;
+//   TorrentQuery(
+//       {required this.mediaId, this.seasonNumber = 0, this.episodeNumber = 0});
+//   Map<String, dynamic> toJson() {
+//     final Map<String, dynamic> data = <String, dynamic>{};
+//     data["id"] = int.parse(mediaId);
+//     data["season"] = seasonNumber;
+//     data["episode"] = episodeNumber;
+//     return data;
+//   }
+// }
+
+typedef TorrentQuery =({String mediaId, int seasonNumber, int episodeNumber});
+
+class MediaTorrentResource extends AutoDisposeFamilyAsyncNotifier<
+    List<TorrentResource>, TorrentQuery> {
+
+  @override
+  FutureOr<List<TorrentResource>> build(TorrentQuery arg) async {
+
+    final dio = await APIs.getDio();
+    var resp = await dio.post(APIs.availableTorrentsUrl, data: {
+      "id": int.parse(arg.mediaId),
+      "season": arg.seasonNumber,
+      "episode": arg.episodeNumber
+    });
+    var rsp = ServerResponse.fromJson(resp.data);
+    if (rsp.code != 0) {
+      throw rsp.message;
+    }
+    return (rsp.data as List).map((v) => TorrentResource.fromJson(v)).toList();
+  }
+
+  Future<void> download(TorrentResource res) async {
+    final data = res.toJson();
+    data.addAll({
+      "id": int.parse(arg.mediaId),
+      "season": arg.seasonNumber,
+      "episode": arg.episodeNumber
+    });
+    final dio = await APIs.getDio();
+    var resp = await dio.post(APIs.downloadTorrentUrl, data: data);
+    var rsp = ServerResponse.fromJson(resp.data);
+    if (rsp.code != 0) {
+      throw rsp.message;
+    }
+  }
+}
+
+class TorrentResource {
+  TorrentResource({this.name, this.size, this.seeders, this.peers, this.link});
+
+  String? name;
+  int? size;
+  int? seeders;
+  int? peers;
+  String? link;
+
+  factory TorrentResource.fromJson(Map<String, dynamic> json) {
+    return TorrentResource(
+        name: json["name"],
+        size: json["size"],
+        seeders: json["seeders"],
+        peers: json["peers"],
+        link: json["link"]);
+  }
+  Map<String, dynamic> toJson() {
+    final Map<String, dynamic> data = <String, dynamic>{};
+    data['name'] = name;
+    data['size'] = size;
+    data["link"] = link;
+    return data;
+  }
+}

ui/lib/providers/settings.dart

@@ -50,14 +50,17 @@ class GeneralSetting {
   String? tmdbApiKey;
   String? downloadDIr;
   String? logLevel;
+  String? proxy;
 
-  GeneralSetting({this.tmdbApiKey, this.downloadDIr, this.logLevel});
+  GeneralSetting(
+      {this.tmdbApiKey, this.downloadDIr, this.logLevel, this.proxy});
 
   factory GeneralSetting.fromJson(Map<String, dynamic> json) {
     return GeneralSetting(
         tmdbApiKey: json["tmdb_api_key"],
         downloadDIr: json["download_dir"],
-        logLevel: json["log_level"]);
+        logLevel: json["log_level"],
+        proxy: json["proxy"]);
   }
 
   Map<String, dynamic> toJson() {
@@ -65,6 +68,7 @@ class GeneralSetting {
     data['tmdb_api_key'] = tmdbApiKey;
     data['download_dir'] = downloadDIr;
     data["log_level"] = logLevel;
+    data["proxy"] = proxy;
     return data;
   }
 }
@@ -336,6 +340,7 @@ class About {
     required this.homepage,
     required this.intro,
     required this.uptime,
+    required this.version,
   });
 
   final String? chatGroup;
@@ -343,6 +348,7 @@ class About {
   final String? homepage;
   final String? intro;
   final Duration? uptime;
+  final String? version;
 
   factory About.fromJson(Map<String, dynamic> json) {
     return About(
@@ -350,7 +356,9 @@ class About {
       goVersion: json["go_version"],
       homepage: json["homepage"],
       intro: json["intro"],
-      uptime: Duration(microseconds: (json["uptime"]/1000.0 as double).round()),
+      version: json["version"],
+      uptime:
+          Duration(microseconds: (json["uptime"] / 1000.0 as double).round()),
     );
   }
 }

ui/lib/providers/welcome_data.dart

@@ -44,10 +44,6 @@ final movieWatchlistDataProvider = FutureProvider.autoDispose((ref) async {
 var searchPageDataProvider = AsyncNotifierProvider.autoDispose
     .family<SearchPageData, List<SearchResult>, String>(SearchPageData.new);
 
-var movieTorrentsDataProvider = AsyncNotifierProvider.autoDispose
-    .family<MovieTorrentResource, List<TorrentResource>, String>(
-        MovieTorrentResource.new);
-
 class SearchPageData
     extends AutoDisposeFamilyAsyncNotifier<List<SearchResult>, String> {
   List<SearchResult> list = List.empty(growable: true);
@@ -88,14 +84,15 @@ class SearchPageData
   }
 
   Future<void> submit2Watchlist(int tmdbId, int storageId, String resolution,
-      String mediaType, String folder) async {
+      String mediaType, String folder, bool downloadHistoryEpisodes) async {
     final dio = await APIs.getDio();
     if (mediaType == "tv") {
       var resp = await dio.post(APIs.watchlistTvUrl, data: {
         "tmdb_id": tmdbId,
         "storage_id": storageId,
         "resolution": resolution,
-        "folder": folder
+        "folder": folder,
+        "download_history_episodes":downloadHistoryEpisodes
       });
       var sp = ServerResponse.fromJson(resp.data);
       if (sp.code != 0) {
@@ -245,56 +242,3 @@ class SearchResult {
   }
 }
 
-class MovieTorrentResource
-    extends AutoDisposeFamilyAsyncNotifier<List<TorrentResource>, String> {
-  String? mediaId;
-  @override
-  FutureOr<List<TorrentResource>> build(String id) async {
-    mediaId = id;
-    final dio = await APIs.getDio();
-    var resp = await dio.get(APIs.availableMoviesUrl + id);
-    var rsp = ServerResponse.fromJson(resp.data);
-    if (rsp.code != 0) {
-      throw rsp.message;
-    }
-    return (rsp.data as List).map((v) => TorrentResource.fromJson(v)).toList();
-  }
-
-  Future<void> download(TorrentResource res) async {
-    var m = res.toJson();
-    m["media_id"] = int.parse(mediaId!);
-
-    final dio = await APIs.getDio();
-    var resp = await dio.post(APIs.availableMoviesUrl, data: m);
-    var rsp = ServerResponse.fromJson(resp.data);
-    if (rsp.code != 0) {
-      throw rsp.message;
-    }
-  }
-}
-
-class TorrentResource {
-  TorrentResource({this.name, this.size, this.seeders, this.peers, this.link});
-
-  String? name;
-  int? size;
-  int? seeders;
-  int? peers;
-  String? link;
-
-  factory TorrentResource.fromJson(Map<String, dynamic> json) {
-    return TorrentResource(
-        name: json["name"],
-        size: json["size"],
-        seeders: json["seeders"],
-        peers: json["peers"],
-        link: json["link"]);
-  }
-  Map<String, dynamic> toJson() {
-    final Map<String, dynamic> data = <String, dynamic>{};
-    data['name'] = name;
-    data['size'] = size;
-    data["link"] = link;
-    return data;
-  }
-}

ui/lib/search.dart

@@ -50,7 +50,6 @@ class _SearchPageState extends ConsumerState<SearchPage> {
                           child: Image.network(
                             "${APIs.tmdbImgBaseUrl}${item.posterPath}",
                             fit: BoxFit.contain,
-                            headers: APIs.authHeaders,
                           ),
                         ),
                       ),
@@ -146,6 +145,8 @@ class _SearchPageState extends ConsumerState<SearchPage> {
               int storageSelected = 0;
               var storage = ref.watch(storageSettingProvider);
               var name = ref.watch(suggestNameDataProvider(item.id!));
+              bool downloadHistoryEpisodes = false;
+              bool buttonTapped = false;
 
               var pathController = TextEditingController();
               return AlertDialog(
@@ -230,6 +231,19 @@ class _SearchPageState extends ConsumerState<SearchPage> {
                                           ),
                                         )
                                       : Text(""),
+                                  item.mediaType == "tv"
+                                      ? SizedBox(
+                                          width: 250,
+                                          child: CheckboxListTile(
+                                              title: const Text("是否下载往期剧集"),
+                                              value: downloadHistoryEpisodes,
+                                              onChanged: (v) {
+                                                setState(() {
+                                                  downloadHistoryEpisodes = v!;
+                                                });
+                                              }),
+                                        )
+                                      : const SizedBox(),
                                 ],
                               );
                             });
@@ -254,18 +268,33 @@ class _SearchPageState extends ConsumerState<SearchPage> {
                       textStyle: Theme.of(context).textTheme.labelLarge,
                     ),
                     child: const Text('确定'),
-                    onPressed: () {
-                      ref
+                    onPressed: () async {
+                      if (buttonTapped) {
+                        return;
+                      }
+                      setState(() {
+                        buttonTapped = true;
+                      });
+
+                      await ref
                           .read(searchPageDataProvider(widget.query ?? "")
                               .notifier)
-                          .submit2Watchlist(item.id!, storageSelected,
-                              resSelected, item.mediaType!, pathController.text)
+                          .submit2Watchlist(
+                              item.id!,
+                              storageSelected,
+                              resSelected,
+                              item.mediaType!,
+                              pathController.text,
+                              downloadHistoryEpisodes)
                           .then((v) {
                         Utils.showSnakeBar("添加成功");
                         Navigator.of(context).pop();
                       }).onError((error, trace) {
                         Utils.showSnakeBar("添加失败：$error");
                       });
+                      setState(() {
+                        buttonTapped = false;
+                      });
                     },
                   ),
                 ],

ui/lib/settings.dart

@@ -36,14 +36,14 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
             initialValue: {
               "tmdb_api": v.tmdbApiKey,
               "download_dir": v.downloadDIr,
-              "log_level": v.logLevel
+              "log_level": v.logLevel,
+              "proxy": v.proxy,
             },
             child: Column(
               crossAxisAlignment: CrossAxisAlignment.start,
               children: [
                 FormBuilderTextField(
                   name: "tmdb_api",
-                  autofocus: true,
                   decoration: Commons.requiredTextFieldStyle(
                       text: "TMDB Api Key", icon: const Icon(Icons.key)),
                   //
@@ -51,12 +51,16 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
                 ),
                 FormBuilderTextField(
                   name: "download_dir",
-                  autofocus: true,
                   decoration: Commons.requiredTextFieldStyle(
-                      text: "下载路径", icon: const Icon(Icons.folder)),
+                      text: "下载路径", icon: const Icon(Icons.folder), helperText: "媒体文件临时下载路径，非最终存储路径"),
                   //
                   validator: FormBuilderValidators.required(),
                 ),
+                FormBuilderTextField(
+                  name: "proxy",
+                  decoration: const InputDecoration(
+                      labelText: "代理地址", icon: Icon(Icons.folder), helperText: "后台联网代理地址，留空表示不启用代理"),
+                ),
                 SizedBox(
                   width: 300,
                   child: FormBuilderDropdown(
@@ -66,13 +70,10 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
                       icon: Icon(Icons.file_present_rounded),
                     ),
                     items: const [
-                      DropdownMenuItem(
-                          value: "debug", child: Text("DEBUG")),
+                      DropdownMenuItem(value: "debug", child: Text("DEBUG")),
                       DropdownMenuItem(value: "info", child: Text("INFO")),
-                      DropdownMenuItem(
-                          value: "warn", child: Text("WARNING")),
-                      DropdownMenuItem(
-                          value: "error", child: Text("ERROR")),
+                      DropdownMenuItem(value: "warn", child: Text("WARN")),
+                      DropdownMenuItem(value: "error", child: Text("ERROR")),
                     ],
                     validator: FormBuilderValidators.required(),
                   ),
@@ -93,7 +94,8 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
                                 .updateSettings(GeneralSetting(
                                     tmdbApiKey: values["tmdb_api"],
                                     downloadDIr: values["download_dir"],
-                                    logLevel: values["log_level"]));
+                                    logLevel: values["log_level"],
+                                    proxy: values["proxy"]));
                             f.then((v) {
                               Utils.showSnakeBar("更新成功");
                             }).onError((e, s) {
@@ -164,8 +166,6 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
         loading: () => const MyProgressIndicator());
 
     var authData = ref.watch(authSettingProvider);
-    TextEditingController userController = TextEditingController();
-    TextEditingController passController = TextEditingController();
     var authSetting = authData.when(
         data: (data) {
           if (_enableAuth == null) {
@@ -173,7 +173,6 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
               _enableAuth = data.enable;
             });
           }
-          userController.text = data.user;
           return FormBuilder(
               key: _formKey2,
               initialValue: {
@@ -283,7 +282,7 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
 
   Future<void> showIndexerDetails(Indexer indexer) {
     final _formKey = GlobalKey<FormBuilderState>();
-    var selectImpl = "torznab";
+
     var body = FormBuilder(
       key: _formKey,
       initialValue: {
@@ -565,7 +564,7 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
                 "user": values["user"],
                 "password": values["password"],
                 "change_file_hash":
-                    values["change_file_hash"] as bool ? "true" : "false"
+                    (values["change_file_hash"]??false) as bool ? "true" : "false"
               },
             ));
       } else {
@@ -589,8 +588,8 @@ class _SystemSettingsPageState extends ConsumerState<SystemSettingsPage> {
           return AlertDialog(
             title: Text(title),
             content: SingleChildScrollView(
-              child: Container(
-                constraints: const BoxConstraints(maxWidth: 200),
+              child: SizedBox(
+                width: 300,
                 child: body,
               ),
             ),

ui/lib/system_page.dart

@@ -37,7 +37,7 @@ class _SystemPageState extends ConsumerState<SystemPage> {
                         columns: const [
                           DataColumn(label: Text("日志")),
                           DataColumn(label: Text("大小")),
-                          DataColumn(label: Text("*"))
+                          DataColumn(label: Text("下载"))
                         ],
                         rows: List.generate(list.length, (i) {
                           final item = list[i];
@@ -46,12 +46,10 @@ class _SystemPageState extends ConsumerState<SystemPage> {
 
                           return DataRow(cells: [
                             DataCell(Text(item.name ?? "")),
-                            DataCell(Text((item.size??0).readableFileSize())),
+                            DataCell(Text((item.size ?? 0).readableFileSize())),
                             DataCell(InkWell(
-                              child: Icon(Icons.download),
-                              onTap: () => launchUrl(uri,
-                                  webViewConfiguration: WebViewConfiguration(
-                                      headers: APIs.authHeaders)),
+                              child: const Icon(Icons.download),
+                              onTap: () => launchUrl(uri),
                             ))
                           ]);
                         }));
@@ -82,6 +80,7 @@ class _SystemPageState extends ConsumerState<SystemPage> {
                               "#",
                               style: TextStyle(height: 2.5),
                             ),
+                            Text("版本", style: TextStyle(height: 2.5)),
                             Text("主页", style: TextStyle(height: 2.5)),
                             Text("讨论组", style: TextStyle(height: 2.5)),
                             Text("go version", style: TextStyle(height: 2.5)),
@@ -104,8 +103,11 @@ class _SystemPageState extends ConsumerState<SystemPage> {
                                 ),
                                 Text(v.intro ?? "",
                                     style: const TextStyle(height: 2.5)),
+                                Text(v.version ?? "",
+                                    style: const TextStyle(height: 2.5)),
                                 InkWell(
                                   child: Text(v.homepage ?? "",
+                                      softWrap: false,
                                       style: const TextStyle(height: 2.5)),
                                   onTap: () => launchUrl(homepage),
                                 ),

ui/lib/tv_details.dart

@@ -26,7 +26,6 @@ class TvDetailsPage extends ConsumerStatefulWidget {
 }
 
 class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
-
   @override
   void initState() {
     super.initState();
@@ -45,7 +44,7 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
               DataCell(Text("${ep.title}")),
               DataCell(Opacity(
                 opacity: 0.5,
-                child: Text(ep.airDate??"-"),
+                child: Text(ep.airDate ?? "-"),
               )),
               DataCell(
                 Opacity(
@@ -80,13 +79,15 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
                               .onError((error, trace) =>
                                   Utils.showSnakeBar("操作失败: $error"));
                         },
-                        icon: const Icon(Icons.search)),
+                        icon: const Icon(Icons.download)),
                   ),
                   const SizedBox(
                     width: 10,
                   ),
                   IconButton(
-                      onPressed: () {}, icon: const Icon(Icons.manage_search))
+                      onPressed: () => showAvailableTorrents(widget.seriesId,
+                          ep.seasonNumber ?? 0, ep.episodeNumber ?? 0),
+                      icon: const Icon(Icons.manage_search))
                 ],
               ))
             ]);
@@ -113,19 +114,30 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
                   const DataColumn(label: Text("播出时间")),
                   const DataColumn(label: Text("状态")),
                   DataColumn(
-                      label: Tooltip(
-                    message: "搜索下载全部剧集",
-                    child: IconButton(
-                        onPressed: () {
-                          ref
-                              .read(mediaDetailsProvider(widget.seriesId)
-                                  .notifier)
-                              .searchAndDownload(widget.seriesId, k, 0)
-                              .then((v) => Utils.showSnakeBar("开始下载: $v"))
-                              .onError((error, trace) =>
-                                  Utils.showSnakeBar("操作失败: $error"));
-                        },
-                        icon: const Icon(Icons.search)),
+                      label: Row(
+                    children: [
+                      Tooltip(
+                        message: "搜索下载全部剧集",
+                        child: IconButton(
+                            onPressed: () {
+                              ref
+                                  .read(mediaDetailsProvider(widget.seriesId)
+                                      .notifier)
+                                  .searchAndDownload(widget.seriesId, k, 0)
+                                  .then((v) => Utils.showSnakeBar("开始下载: $v"))
+                                  .onError((error, trace) =>
+                                      Utils.showSnakeBar("操作失败: $error"));
+                            },
+                            icon: const Icon(Icons.download)),
+                      ),
+                      const SizedBox(
+                        width: 10,
+                      ),
+                      IconButton(
+                          onPressed: () =>
+                              showAvailableTorrents(widget.seriesId, k, 0),
+                          icon: const Icon(Icons.manage_search))
+                    ],
                   ))
                 ], rows: m[k]!),
               ],
@@ -143,8 +155,7 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
                           fit: BoxFit.fitWidth,
                           opacity: 0.5,
                           image: NetworkImage(
-                              "${APIs.imagesUrl}/${details.id}/backdrop.jpg",
-                              headers: APIs.authHeaders))),
+                              "${APIs.imagesUrl}/${details.id}/backdrop.jpg"))),
                   child: Padding(
                     padding: const EdgeInsets.all(10),
                     child: Row(
@@ -155,8 +166,7 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
                             padding: const EdgeInsets.all(10),
                             child: Image.network(
                               "${APIs.imagesUrl}/${details.id}/poster.jpg",
-                              fit: BoxFit.contain,
-                              headers: APIs.authHeaders,
+                              fit: BoxFit.contain
                             ),
                           ),
                         ),
@@ -198,7 +208,7 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
                                   ),
                                   const Text(""),
                                   Text(
-                                    details.overview??"",
+                                    details.overview ?? "",
                                   ),
                                 ],
                               )),
@@ -239,4 +249,71 @@ class _TvDetailsPageState extends ConsumerState<TvDetailsPage> {
         },
         loading: () => const MyProgressIndicator());
   }
+
+  Future<void> showAvailableTorrents(String id, int season, int episode) {
+    return showDialog<void>(
+      context: context,
+      barrierDismissible: true,
+      builder: (BuildContext context) {
+        return Consumer(builder: (context, ref, _) {
+          final torrents = ref.watch(mediaTorrentsDataProvider(
+              (mediaId: id, seasonNumber: season, episodeNumber: episode)));
+
+          return AlertDialog(
+              //title: Text("资源"),
+              content: SelectionArea(
+            child: SizedBox(
+              width: 800,
+              height: 400,
+              child: torrents.when(
+                  data: (v) {
+                    return SingleChildScrollView(
+                        child: DataTable(
+                            dataTextStyle: const TextStyle(fontSize: 12, height: 0),
+                            columns: const [
+                              DataColumn(label: Text("名称")),
+                              DataColumn(label: Text("大小")),
+                              DataColumn(label: Text("seeders")),
+                              DataColumn(label: Text("peers")),
+                              DataColumn(label: Text("操作"))
+                            ],
+                            rows: List.generate(v.length, (i) {
+                              final torrent = v[i];
+                              return DataRow(cells: [
+                                DataCell(Text("${torrent.name}")),
+                                DataCell(Text(
+                                    "${torrent.size?.readableFileSize()}")),
+                                DataCell(Text("${torrent.seeders}")),
+                                DataCell(Text("${torrent.peers}")),
+                                DataCell(IconButton(
+                                  icon: const Icon(Icons.download),
+                                  onPressed: () async {
+                                    await ref
+                                        .read(mediaTorrentsDataProvider((
+                                          mediaId: id,
+                                          seasonNumber: season,
+                                          episodeNumber: episode
+                                        )).notifier)
+                                        .download(torrent)
+                                        .then((v) {
+                                      Navigator.of(context).pop();
+                                      Utils.showSnakeBar(
+                                          "开始下载：${torrent.name}");
+                                    }).onError((error, trace) =>
+                                            Utils.showSnakeBar("下载失败：$error"));
+                                  },
+                                ))
+                              ]);
+                            })));
+                  },
+                  error: (err, trace) {
+                    return Text("$err");
+                  },
+                  loading: () => const MyProgressIndicator()),
+            ),
+          ));
+        });
+      },
+    );
+  }
 }

ui/lib/welcome_page.dart

@@ -1,7 +1,6 @@
 import 'package:flutter/material.dart';
 import 'package:flutter_riverpod/flutter_riverpod.dart';
 import 'package:go_router/go_router.dart';
-import 'package:quiver/strings.dart';
 import 'package:ui/movie_watchlist.dart';
 import 'package:ui/providers/APIs.dart';
 import 'package:ui/providers/welcome_data.dart';
@@ -30,50 +29,58 @@ class WelcomePage extends ConsumerWidget {
           child: Wrap(
             spacing: 10,
             runSpacing: 20,
-            children: List.generate(value.length, (i) {
-              var item = value[i];
-              return Card(
-                  margin: const EdgeInsets.all(4),
-                  clipBehavior: Clip.hardEdge,
-                  child: InkWell(
-                    //splashColor: Colors.blue.withAlpha(30),
-                    onTap: () {
-                      if (uri == routeMoivie) {
-                        context.go(MovieDetailsPage.toRoute(item.id!));
-                      } else {
-                        context.go(TvDetailsPage.toRoute(item.id!));
-                      }
-                    },
-                    child: Column(
-                      children: <Widget>[
-                        SizedBox(
-                          width: 140,
-                          height: 210,
-                          child: Image.network(
-                            "${APIs.imagesUrl}/${item.id}/poster.jpg",
-                            fit: BoxFit.fill,
-                            headers: APIs.authHeaders,
+            children: value.isEmpty
+                ? [
+                    Container(
+                        height: MediaQuery.of(context).size.height * 0.6,
+                        alignment: Alignment.center,
+                        child: const Text(
+                          "啥都没有...",
+                          style: TextStyle(fontSize: 16),
+                        ))
+                  ]
+                : List.generate(value.length, (i) {
+                    var item = value[i];
+                    return Card(
+                        margin: const EdgeInsets.all(4),
+                        clipBehavior: Clip.hardEdge,
+                        child: InkWell(
+                          //splashColor: Colors.blue.withAlpha(30),
+                          onTap: () {
+                            if (uri == routeMoivie) {
+                              context.go(MovieDetailsPage.toRoute(item.id!));
+                            } else {
+                              context.go(TvDetailsPage.toRoute(item.id!));
+                            }
+                          },
+                          child: Column(
+                            children: <Widget>[
+                              SizedBox(
+                                width: 140,
+                                height: 210,
+                                child: Image.network(
+                                    "${APIs.imagesUrl}/${item.id}/poster.jpg",
+                                    fit: BoxFit.fill),
+                              ),
+                              SizedBox(
+                                  width: 140,
+                                  child: LinearProgressIndicator(
+                                    value: 1,
+                                    color: item.status == "downloaded"
+                                        ? Colors.green
+                                        : Colors.blue,
+                                  )),
+                              Text(
+                                item.name!,
+                                style: const TextStyle(
+                                    fontSize: 14,
+                                    fontWeight: FontWeight.bold,
+                                    height: 2.5),
+                              ),
+                            ],
                           ),
-                        ),
-                        SizedBox(
-                            width: 140,
-                            child: LinearProgressIndicator(
-                              value: 1,
-                              color: item.status == "downloaded"
-                                  ? Colors.green
-                                  : Colors.blue,
-                            )),
-                        Text(
-                          item.name!,
-                          style: const TextStyle(
-                              fontSize: 14,
-                              fontWeight: FontWeight.bold,
-                              height: 2.5),
-                        ),
-                      ],
-                    ),
-                  ));
-            }),
+                        ));
+                  }),
           ),
         ),
       _ => const MyProgressIndicator(),

ui/lib/widgets/widgets.dart

@@ -4,8 +4,10 @@ class Commons {
   static InputDecoration requiredTextFieldStyle({
     required String text,
     Widget? icon,
+    String? helperText,
   }) {
     return InputDecoration(
+      helperText: helperText,
       label: Row(
         children: [
           Text(text),

ui/pubspec.lock

@@ -89,22 +89,6 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "1.3.1"
-  ffi:
-    dependency: transitive
-    description:
-      name: ffi
-      sha256: "493f37e7df1804778ff3a53bd691d8692ddf69702cf4c1c1096a2e41b4779e21"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.1.2"
-  file:
-    dependency: transitive
-    description:
-      name: file
-      sha256: "5fc22d7c25582e38ad9a8515372cd9a93834027aacf1801cf01164dac0ffa08c"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "7.0.0"
   flutter:
     dependency: "direct main"
     description: flutter
@@ -325,30 +309,6 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "1.9.0"
-  path_provider_linux:
-    dependency: transitive
-    description:
-      name: path_provider_linux
-      sha256: f7a1fe3a634fe7734c8d3f2766ad746ae2a2884abe22e241a8b301bf5cac3279
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.2.1"
-  path_provider_platform_interface:
-    dependency: transitive
-    description:
-      name: path_provider_platform_interface
-      sha256: "88f5779f72ba699763fa3a3b06aa4bf6de76c8e5de842cf6f29e2e06476c2334"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.1.2"
-  path_provider_windows:
-    dependency: transitive
-    description:
-      name: path_provider_windows
-      sha256: bd6f00dbd873bfb70d0761682da2b3a2c2fccc2b9e84c495821639601d81afe7
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.3.0"
   percent_indicator:
     dependency: "direct main"
     description:
@@ -365,14 +325,6 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "8.3.0"
-  platform:
-    dependency: transitive
-    description:
-      name: platform
-      sha256: "9b71283fc13df574056616011fb138fd3b793ea47cc509c189a6c3fa5f8a1a65"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "3.1.5"
   plugin_platform_interface:
     dependency: transitive
     description:
@@ -405,62 +357,6 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "2.5.1"
-  shared_preferences:
-    dependency: "direct main"
-    description:
-      name: shared_preferences
-      sha256: d3bbe5553a986e83980916ded2f0b435ef2e1893dfaa29d5a7a790d0eca12180
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.2.3"
-  shared_preferences_android:
-    dependency: transitive
-    description:
-      name: shared_preferences_android
-      sha256: "93d0ec9dd902d85f326068e6a899487d1f65ffcd5798721a95330b26c8131577"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.2.3"
-  shared_preferences_foundation:
-    dependency: transitive
-    description:
-      name: shared_preferences_foundation
-      sha256: "0a8a893bf4fd1152f93fec03a415d11c27c74454d96e2318a7ac38dd18683ab7"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.4.0"
-  shared_preferences_linux:
-    dependency: transitive
-    description:
-      name: shared_preferences_linux
-      sha256: "9f2cbcf46d4270ea8be39fa156d86379077c8a5228d9dfdb1164ae0bb93f1faa"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.3.2"
-  shared_preferences_platform_interface:
-    dependency: transitive
-    description:
-      name: shared_preferences_platform_interface
-      sha256: "22e2ecac9419b4246d7c22bfbbda589e3acf5c0351137d87dd2939d984d37c3b"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.3.2"
-  shared_preferences_web:
-    dependency: transitive
-    description:
-      name: shared_preferences_web
-      sha256: "9aee1089b36bd2aafe06582b7d7817fd317ef05fc30e6ba14bff247d0933042a"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.3.0"
-  shared_preferences_windows:
-    dependency: transitive
-    description:
-      name: shared_preferences_windows
-      sha256: "841ad54f3c8381c480d0c9b508b89a34036f512482c407e6df7a9c4aa2ef8f59"
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "2.3.2"
   sign_in_button:
     dependency: transitive
     description:
@@ -626,14 +522,6 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "0.5.1"
-  xdg_directories:
-    dependency: transitive
-    description:
-      name: xdg_directories
-      sha256: faea9dee56b520b55a566385b84f2e8de55e7496104adada9962e0bd11bcff1d
-      url: "https://pub.flutter-io.cn"
-    source: hosted
-    version: "1.0.4"
 sdks:
   dart: ">=3.4.3 <4.0.0"
   flutter: ">=3.22.0"

ui/pubspec.yaml

@@ -40,7 +40,6 @@ dependencies:
   flutter_riverpod: ^2.5.1
   quiver: ^3.2.1
   flutter_login: ^5.0.0
-  shared_preferences: ^2.2.3
   percent_indicator: ^4.2.3
   intl: ^0.19.0
   flutter_adaptive_scaffold: ^0.1.11+1