update rss content on runtime changed

boypt · Jul 16, 2021 · bc50088 · bc50088
1 parent eb8d1c5
commit bc50088
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/engine/config.go b/engine/config.go
@@ -18,6 +18,7 @@ const (
 	NeedRestartWatch
 	NeedUpdateTracker
 	NeedLoadWaitList
+	NeedUpdateRSS
 )
 
 const (
@@ -124,7 +125,7 @@ func (c *Config) NormlizeConfigDir() (bool, error) {
 	if c.DownloadDirectory != "" {
 		dldir, err := filepath.Abs(c.DownloadDirectory)
 		if err != nil {
-			return false, fmt.Errorf("Invalid path %s, %w", c.WatchDirectory, err)
+			return false, fmt.Errorf("ERROR: Invalid path %s, %w", c.WatchDirectory, err)
 		}
 		if c.DownloadDirectory != dldir {
 			changed = true
@@ -135,7 +136,7 @@ func (c *Config) NormlizeConfigDir() (bool, error) {
 	if c.WatchDirectory != "" {
 		wdir, err := filepath.Abs(c.WatchDirectory)
 		if err != nil {
-			return false, fmt.Errorf("Invalid path %s, %w", c.WatchDirectory, err)
+			return false, fmt.Errorf("ERROR: Invalid path %s, %w", c.WatchDirectory, err)
 		}
 		if c.WatchDirectory != wdir {
 			changed = true
@@ -182,6 +183,9 @@ func (c *Config) Validate(nc *Config) uint8 {
 	if c.MaxConcurrentTask < nc.MaxConcurrentTask {
 		status |= NeedLoadWaitList
 	}
+	if c.RssURL != nc.RssURL {
+		status |= NeedUpdateRSS
+	}
 
 	rfc := reflect.ValueOf(c)
 	rfnc := reflect.ValueOf(nc)

diff --git a/server/server_api.go b/server/server_api.go
@@ -255,6 +255,9 @@ func (s *Server) apiConfigure(data []byte) error {
 		if status&engine.NeedUpdateTracker > 0 {
 			go s.engine.ParseTrackerList()
 		}
+		if status&engine.NeedUpdateRSS > 0 {
+			go s.updateRSS()
+		}
 		s.state.Push()
 
 		// do after config synced