v0.9.0

- 配置文件版本号1.5.0
- 更新README
- 配置文件中变量名可以省略__

Author: wetor

README.md

@@ -44,8 +44,8 @@
 - `setting.download_path`: 下载器下载保存位置。临时位置，移动后将会删除
 - `setting.save_path`: 重命名后移动到位置。此时将会改名
 - `plugin.feed`中的`builtin_mikan_rss.py`插件 : 可选，内置自动订阅插件
-  - `vars.__url__`: 订阅地址，如Mikan的rss订阅地址
-  - `vars.__cron__`: 订阅时间，Cron格式，参考[Feed订阅插件帮助](assets/plugin/feed/README.md)
+  - `vars.__url`: 订阅地址，如Mikan的rss订阅地址
+  - `vars.__cron`: 订阅时间，Cron格式，参考[Feed订阅插件帮助](assets/plugin/feed/README.md)
 - 其余配置项根据需求修改
 
 ### 3 启动程序
@@ -93,6 +93,17 @@
 
 ## 开发日志
 
+## v0.9.0
+- **配置文件版本号为`1.5.0`**
+- 支持多内容torrent解析下载
+  - 优化下载管理器流程
+  - 预解析torrent文件
+- 单测改造
+  - testdata统一路径
+  - 更好的单测覆盖
+- 新增parser插件
+- 使用go1.20
+
 ### v0.8.4
 - 修改订阅流程
   - 移除多协程订阅功能

assets/plugin/README.md

@@ -178,22 +178,22 @@ log.errorf(format, ...)
      __url__: https://example.com/
 ``` 
 `args`将会追加并覆盖 `builtin_mikan_rss.py` 中**入口函数**的参数`args['test']`  
-`vars`将会追加并覆盖 `builtin_mikan_rss.py` 中的全局变量`__cron__`,`__name__`,`__url__`变量  
+`vars`将会追加并覆盖 `builtin_mikan_rss.py` 中的全局变量`cron`,`name`,`url`变量  
 其他字段参考配置文件中的注释  
 
 ## 通用的内置变量和函数
 所有被AnimeGo载入的插件，都将拥有以下变量或方法
-### \_\_debug\_\_
-全局变量`__debug__`，bool类型，当前是否为debug模式   
+### debug
+全局变量`debug`，bool类型，当前是否为debug模式   
 
-### \_\_plugin_name\_\_
-全局变量`__plugin_name__`，插件文件名，不含扩展名
+### plugin_name
+全局变量`plugin_name`，插件文件名，不含扩展名
 
-### \_\_plugin_dir\_\_
-全局变量`__plugin_dir__`，插件所在目录，绝对路径
+### plugin_dir
+全局变量`plugin_dir`，插件所在目录，绝对路径
 
-### \_\_animego_version\_\_
-全局变量`__animego_version__`，AnimeGo版本号，`vx.x.x`格式，如`v1.0.0`
+### animego_version
+全局变量`animego_version`，AnimeGo版本号，`vx.x.x`格式，如`v1.0.0`
 
 ### \_get_config()
 内置函数`_get_config`，获取插件配置  

assets/plugin/feed/README.md

@@ -9,31 +9,31 @@
    file: builtin_mikan_rss.py
    args: {}
    vars:
-     __cron__: 0 0/20 * * * ?
-     __name__: Example
-     __url__: https://example.com/
+     cron: 0 0/20 * * * ?
+     name: Example
+     url: https://example.com/
 ``` 
 对于内置的自动订阅插件，其中`type`和`file`为固定写法  
 启用自定订阅`enable`设置为`true`  
-设置`__cron__`设置定时(cron表达式)，设置`__url__`设置订阅地址  
+设置`cron`设置定时(cron表达式)，设置`url`设置订阅地址  
 
 ## 插件设置
 
-### \_\_name\_\_
-全局变量`__name__`，str类型，可选  
+### name
+全局变量`name`，str类型，可选  
 定时任务的名称，方便日志中区分
 
-### \_\_url\_\_
-全局变量`__url__`，str类型，必要  
+### url
+全局变量`url`，str类型，必要  
 订阅地址，AnimeGo将会使用GET方式请求此地址，将结果转为str类型，传递给入口函数。  
 其中`args['data']`为请求响应的body  
 
-### \_\_header\_\_
-全局变量`__header__`，dict类型，可选  
+### header
+全局变量`header`，dict类型，可选  
 请求订阅地址时所携带的header请求头，其中`user-agent`默认为AnimeGo信息，无法设置
 
-### \_\_cron\_\_
-全局变量`__cron__`，str类型，必要  
+### cron
+全局变量`cron`，str类型，必要  
 订阅的定时规则，执行完毕后，将会把返回值传递给启用的**过滤器**([过滤器文档](../filter/README.md))，之后进行下载    
 支持 [秒] [分] [小时] [日] [月] [周] 六项的Cron表达式    
 [Cron表达式文档（维基百科，推荐）](https://zh.wikipedia.org/wiki/Cron)  
@@ -53,7 +53,7 @@ args = {
     "data": "..."
 }
 ```
-其中`args['data']`为`__url__`的请求结果，str类型  
+其中`args['data']`为`url`的请求结果，str类型  
 如果为mikan订阅地址，则可以使用`core.parse_mikan_rss(args['data'])`解析  
 也可以选择自行解析  
 

assets/plugin/rename/README.md

@@ -4,8 +4,8 @@
 
 ## 插件设置
 
-### \_\_write_tvshow\_\_
-全局变量`__write_tvshow__`，bool类型，可选，默认`True`  
+### write_tvshow
+全局变量`write_tvshow`，bool类型，可选，默认`True`  
 是否写入Jellyfin的`tvshow.nfo`文件  
 启用后将会写入返回值中`tvshow_dir`所设置路径。如未返回`tvshow_dir`，将写入目标文件路径`filepath`的**上上**层目录
 
@@ -42,7 +42,7 @@ args = {
 #### 返回值
 `error`: 必要，错误信息，为None则没有错误  
 `filepath`: 必要，重命名后的文件路径。最终将会保存到`save_path/{filepath}`    
-`tvshow_dir`: 可选，全局变量`__write_tvshow__`开启后，将会把`tvshow.nfo`文件写到此文件夹中。如为空或文件夹不存在，将会使用`filepath`的**上上**层目录      
+`tvshow_dir`: 可选，全局变量`write_tvshow`开启后，将会把`tvshow.nfo`文件写到此文件夹中。如为空或文件夹不存在，将会使用`filepath`的**上上**层目录      
 
 ```python
 def rename(args):

assets/plugin/schedule/README.md

@@ -1,12 +1,12 @@
 # Schedule定时任务插件
 使用Cron表达式定时执行任务
 ## 插件设置
-### \_\_name\_\_
-全局变量`__name__`，str类型，可选  
+### name
+全局变量`name`，str类型，可选  
 定时任务的名称，方便日志中区分  
 
-### \_\_cron\_\_
-全局变量`__cron__`，str类型，必要  
+### cron
+全局变量`cron`，str类型，必要  
 定时任务的定时规则，支持 [秒] [分] [小时] [日] [月] [周] 六项的Cron表达式    
 [Cron表达式文档（维基百科，推荐）](https://zh.wikipedia.org/wiki/Cron)  
 [Cron表达式文档（百度百科）](https://baike.baidu.com/item/cron/10952601)  

configs/config_test.go

@@ -69,7 +69,7 @@ func TestUpdateConfig_141(t *testing.T) {
 	EqualFile(t, "data/animego.yaml", test.GetDataPath(testdata, "animego_141.yaml"))
 }
 
-func TestUpdateConfig_151(t *testing.T) {
+func TestUpdateConfig_150(t *testing.T) {
 	configs.ConfigVersion = "1.5.0"
 	file := test.GetData(testdata, "animego_141.yaml")
 	_ = os.WriteFile("data/animego.yaml", file, 0666)

configs/default.go

@@ -56,7 +56,8 @@ func defaultPluginComment() {
   type: 插件类型，目前仅支持 'python'(py) 和 'builtin' 插件类型。builtin为内置插件
   file: 插件文件，相对于 'data/plugin' 文件夹的路径，或内置插件名
   args: [可空]插件额外参数，字典类型，会覆盖同名参数
-  vars: [可空]插件全局变量，字典类型，会覆盖插件脚本中同名变量，具体变量和作用参考订阅插件文档`
+  vars: [可空]插件全局变量，字典类型，如果变量名前缀或后缀不是'__'将会自动补充，即在插件中变量名前后缀始终为'__'，
+    会覆盖插件脚本中同名变量，具体变量和作用参考订阅插件文档`
 }
 
 func defaultPlugin() {
@@ -66,8 +67,8 @@ func defaultPlugin() {
 			Type:   "builtin",
 			File:   "builtin_mikan_rss.py",
 			Vars: map[string]any{
-				"__url__":  "",
-				"__cron__": "0 0/20 * * * ?",
+				"url":  "",
+				"cron": "0 0/20 * * * ?",
 			},
 		},
 	}

configs/update.go

@@ -357,6 +357,21 @@ func update_141_150(file string) {
 			File:   "builtin_parser.py",
 		},
 	}
+	for i, p := range newConfig.Plugin.Feed {
+		fmt.Println(p)
+		for key, val := range p.Vars {
+			oldKey := key
+			key = strings.TrimPrefix(key, "__")
+			key = strings.TrimSuffix(key, "__")
+			if key != oldKey {
+				p.Vars[key] = val
+				delete(p.Vars, oldKey)
+			}
+		}
+		newConfig.Plugin.Feed[i] = p
+	}
+	log.Println("[清理] 清理缓存(data/cache/bolt.db)")
+	_ = os.Remove(xpath.Join(oldConfig.DataPath, "cache", "bolt.db"))
 	content, err := encodeConfig(newConfig)
 	if err != nil {
 		log.Fatal("配置文件升级失败：", err)

internal/animego/manager/manager_test.go

@@ -496,6 +496,7 @@ func TestManager_ReStart_NotDownloaded(t *testing.T) {
 			time.Sleep(5 * time.Second)
 			cancel()
 		}()
+		time.Sleep(300 * time.Millisecond)
 		manager.Conf.Rename = "move"
 		{
 			log.Info("下载 1")
@@ -515,6 +516,7 @@ func TestManager_ReStart_NotDownloaded(t *testing.T) {
 			time.Sleep(3 * time.Second)
 			cancel()
 		}()
+		time.Sleep(300 * time.Millisecond)
 		{
 			log.Info("下载 1")
 			file1, _, _ = download("动画1", 1, []int{1})
@@ -540,9 +542,8 @@ func TestManager_ReStart_NotDownloaded(t *testing.T) {
 		"正常退出",
 		"正常退出",
 		"重启",
+		2,
 		"下载 1",
-		"移动完成",
-		"存在可能未下载完成的项目",
 		"接收到下载项",
 		"发现已下载",
 		"取消下载，不允许重复",

internal/plugin/plugin.go

@@ -72,6 +72,19 @@ func LoadPlugin(opts *LoadPluginOptions) (p api.Plugin) {
 			break
 		}
 	}
+	for key, val := range opts.Vars {
+		oldKey := key
+		if !strings.HasPrefix(key, "__") {
+			key = "__" + key
+		}
+		if !strings.HasSuffix(key, "__") {
+			key = key + "__"
+		}
+		if key != oldKey {
+			opts.Vars[key] = val
+			delete(opts.Vars, oldKey)
+		}
+	}
 	p.Load(&plugin.LoadOptions{
 		File:       opts.File,
 		Code:       code,