fix(http): use explicit success checks in async callers

This commit is contained in:
InfinityPacer
2026-04-10 18:21:30 +08:00
committed by jxxghp
parent 217fcfd1b2
commit 1af5f02832
3 changed files with 5 additions and 5 deletions
+1 -1
View File
@@ -493,7 +493,7 @@ async def latest_version(_: schemas.TokenPayload = Depends(verify_token)):
version_res = await AsyncRequestUtils( version_res = await AsyncRequestUtils(
proxies=settings.PROXY, headers=settings.GITHUB_HEADERS proxies=settings.PROXY, headers=settings.GITHUB_HEADERS
).get_res(f"https://api.github.com/repos/jxxghp/MoviePilot/releases") ).get_res(f"https://api.github.com/repos/jxxghp/MoviePilot/releases")
if version_res: if version_res is not None and version_res.status_code == 200:
ver_json = version_res.json() ver_json = version_res.json()
if ver_json: if ver_json:
return schemas.Response(success=True, data=ver_json) return schemas.Response(success=True, data=ver_json)
+2 -2
View File
@@ -238,7 +238,7 @@ class ImageHelper(metaclass=Singleton):
# 请求远程图片 # 请求远程图片
params = self._get_request_params(url, proxy, cookies) params = self._get_request_params(url, proxy, cookies)
response = RequestUtils(**params).get_res(url=url) response = RequestUtils(**params).get_res(url=url)
if not response: if response is None or response.status_code != 200:
logger.warn(f"Failed to fetch image from URL: {url}") logger.warn(f"Failed to fetch image from URL: {url}")
return None return None
@@ -274,7 +274,7 @@ class ImageHelper(metaclass=Singleton):
# 请求远程图片 # 请求远程图片
params = self._get_request_params(url, proxy, cookies) params = self._get_request_params(url, proxy, cookies)
response = await AsyncRequestUtils(**params).get_res(url=url) response = await AsyncRequestUtils(**params).get_res(url=url)
if not response: if response is None or response.status_code != 200:
logger.warn(f"Failed to fetch image from URL: {url}") logger.warn(f"Failed to fetch image from URL: {url}")
return None return None
+2 -2
View File
@@ -39,7 +39,7 @@ class BangumiApi(object):
params.update(kwargs) params.update(kwargs)
resp = self._req.get_res(url=req_url, params=params) resp = self._req.get_res(url=req_url, params=params)
try: try:
if not resp: if resp is None or resp.status_code != 200:
return None return None
result = resp.json() result = resp.json()
return result.get(key) if key else result return result.get(key) if key else result
@@ -55,7 +55,7 @@ class BangumiApi(object):
params.update(kwargs) params.update(kwargs)
resp = await self._async_req.get_res(url=req_url, params=params) resp = await self._async_req.get_res(url=req_url, params=params)
try: try:
if not resp: if resp is None or resp.status_code != 200:
return None return None
result = resp.json() result = resp.json()
return result.get(key) if key else result return result.get(key) if key else result