GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-06-07 00:30:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix typing

Browse Source
This commit is contained in:
jxxghp
2025-03-24 19:14:04 +08:00
parent 1918b0f192
commit 63049f61f7
6 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/modules/filemanager/storages/__init__.py
View File

@@ -128,7 +128,7 @@ class StorageBase(metaclass=ABCMeta):
pass
@abstractmethod
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: str = None) -> Optional[schemas.FileItem]:
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: Optional[str] = None) -> Optional[schemas.FileItem]:
"""
上传文件
:param fileitem: 上传目录项

5
app/modules/filemanager/storages/alipan.py
View File

@@ -209,7 +209,7 @@ class AliPan(StorageBase, metaclass=Singleton):
elif driver.category == "backup":
self.__update_params({"backDriveId": driver.drive_id})
def __get_fileitem(self, fileinfo: BaseFile, parent: str = "/") -> schemas.FileItem:
def __get_fileitem(self, fileinfo: BaseFile, parent: Optional[str] = "/") -> schemas.FileItem:
"""
获取文件信息
"""
@@ -374,7 +374,8 @@ class AliPan(StorageBase, metaclass=Singleton):
return Path(local_path)
return None
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: str = None) -> Optional[schemas.FileItem]:
def upload(self, fileitem: schemas.FileItem, path: Path,
new_name: Optional[str] = None) -> Optional[schemas.FileItem]:
"""
上传文件，并标记完成
:param fileitem: 上传目录项

8
app/modules/filemanager/storages/alist.py
View File

@@ -133,7 +133,7 @@ class Alist(StorageBase, metaclass=Singleton):
def list(
self,
fileitem: schemas.FileItem,
password: str = "",
password: Optional[str] = "",
page: int = 1,
per_page: int = 0,
refresh: bool = False,
@@ -291,7 +291,7 @@ class Alist(StorageBase, metaclass=Singleton):
def get_item(
self,
path: Path,
password: str = "",
password: Optional[str] = "",
page: int = 1,
per_page: int = 0,
refresh: bool = False,
@@ -468,7 +468,7 @@ class Alist(StorageBase, metaclass=Singleton):
self,
fileitem: schemas.FileItem,
path: Path = None,
password: str = "",
password: Optional[str] = "",
) -> Optional[Path]:
"""
下载文件，保存到本地，返回本地临时文件地址
@@ -547,7 +547,7 @@ class Alist(StorageBase, metaclass=Singleton):
return None
def upload(
self, fileitem: schemas.FileItem, path: Path, new_name: str = None, task: bool = False
self, fileitem: schemas.FileItem, path: Path, new_name: Optional[str] = None, task: bool = False
) -> Optional[schemas.FileItem]:
"""
上传文件

2
app/modules/filemanager/storages/local.py
View File

@@ -191,7 +191,7 @@ class LocalStorage(StorageBase):
"""
return Path(fileitem.path)
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: str = None) -> Optional[schemas.FileItem]:
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: Optional[str] = None) -> Optional[schemas.FileItem]:
"""
上传文件
:param fileitem: 上传目录项

5
app/modules/filemanager/storages/rclone.py
View File

@@ -56,7 +56,7 @@ class Rclone(StorageBase):
else:
return None
def __get_rcloneitem(self, item: dict, parent: str = "/") -> schemas.FileItem:
def __get_rcloneitem(self, item: dict, parent: Optional[str] = "/") -> schemas.FileItem:
"""
获取rclone文件项
"""
@@ -254,7 +254,8 @@ class Rclone(StorageBase):
logger.error(f"rclone复制文件失败：{err}")
return None
def upload(self, fileitem: schemas.FileItem, path: Path, new_name: str = None) -> Optional[schemas.FileItem]:
def upload(self, fileitem: schemas.FileItem, path: Path,
new_name: Optional[str] = None) -> Optional[schemas.FileItem]:
"""
上传文件
:param fileitem: 上传目录项

4
app/modules/filemanager/storages/u115.py
View File

@@ -150,7 +150,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
return result.get("data")
def _request_api(self, method: str, endpoint: str,
result_key: str = None, **kwargs) -> Optional[Union[dict, list]]:
result_key: Optional[str] = None, **kwargs) -> Optional[Union[dict, list]]:
"""
带错误处理和速率限制的API请求
"""
@@ -395,7 +395,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
modify_time=int(time.time())
)
def upload(self, target_dir: schemas.FileItem, local_path: Path, new_name: str = None) -> schemas.FileItem:
def upload(self, target_dir: schemas.FileItem, local_path: Path, new_name: Optional[str] = None) -> schemas.FileItem:
"""
实现带秒传、断点续传和二次认证的文件上传
"""