Skip to content

Commit

Permalink
style(yapf): use yapf to format all files
Browse files Browse the repository at this point in the history
  • Loading branch information
@musnows
musnows committed Jan 24, 2023
1 parent e6e2f3d commit 0e4cdf2
Show file tree
Hide file tree
Showing 19 changed files with 1,149 additions and 898 deletions.
106 changes: 85 additions & 21 deletions code/api.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,32 +2,53 @@
import traceback
from aiohttp import web
from endpoints.Gtime import GetTime
from endpoints.ApiHandler import tfa_code_requeset,afd_request,login_img_request,img_draw_request
from endpoints.ApiHandler import tfa_code_requeset, afd_request, login_img_request, img_draw_request

# 初始化节点
routes = web.RouteTableDef()


# 基础返回
# 基础返回
@routes.get('/')
def hello_world(request): # put application's code here
print(f"[{GetTime()}] [request] /")
return web.Response(body=json.dumps({
'code':0,
'message': 'Hello! Use path /shop-url or /shop-img to get valorant daily shop','info':'在path后添加/shop-img或者/shop-url来获取每日商店，前者会直接跳转，后者返回一个带图片url的json。示例: /shop-url?account=Riot账户&passwd=Riot密码&img_src=可选参数，自定义背景图','docs':'https://github.com/Aewait/Kook-Valorant-Bot/blob/main/docs/valorant-shop-img-api.md'
},indent=2, sort_keys=True,ensure_ascii=False), status=200, content_type='application/json')
return web.Response(body=json.dumps(
{
'code': 0,
'message': 'Hello! Use path /shop-url or /shop-img to get valorant daily shop',
'info':
'在path后添加/shop-img或者/shop-url来获取每日商店，前者会直接跳转，后者返回一个带图片url的json。示例: /shop-url?account=Riot账户&passwd=Riot密码&img_src=可选参数，自定义背景图',
'docs': 'https://github.com/Aewait/Kook-Valorant-Bot/blob/main/docs/valorant-shop-img-api.md'
},
indent=2,
sort_keys=True,
ensure_ascii=False),
status=200,
content_type='application/json')


# 提供4个皮肤uuid，返回图片
@routes.get('/shop-draw')
async def get_dailshop_img(request):
print(f"[{GetTime()}] [request] /shop-draw")
try:
ret = await img_draw_request(request)
return web.Response(body=json.dumps(ret,indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(ret, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')
except:
err_cur = traceback.format_exc()
print(f"[{GetTime()}] [Api] ERR in /shop-url\n{err_cur}")
return web.Response(body=json.dumps({'code':200,'message': 'unkown err','info':f'未知错误','except':f'{err_cur}'},indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(
{
'code': 200,
'message': 'unkown err',
'info': f'未知错误',
'except': f'{err_cur}'
},
indent=2,
sort_keys=True,
ensure_ascii=False),
content_type='application/json')


# 直接跳转图片
Expand All @@ -36,50 +57,93 @@ async def get_dailshop_img(request):
print(f"[{GetTime()}] [request] /shop-img")
try:
ret = await login_img_request(request)
if ret['code']==0:
return web.Response(headers={'Location': ret['message']},status=303) # 303是直接跳转到图片
if ret['code'] == 0:
return web.Response(headers={'Location': ret['message']}, status=303) # 303是直接跳转到图片
else:
return web.Response(body=json.dumps(ret,indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(ret, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')
except:
err_cur = traceback.format_exc()
print(f"[{GetTime()}] [Api] ERR in /shop-img\n{err_cur}")
return web.Response(body=json.dumps({'code':200,'message': 'unkown err','info':f'未知错误','except':f'{err_cur}'},indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')

return web.Response(body=json.dumps(
{
'code': 200,
'message': 'unkown err',
'info': f'未知错误',
'except': f'{err_cur}'
},
indent=2,
sort_keys=True,
ensure_ascii=False),
content_type='application/json')


# 获取图片url
@routes.get('/shop-url')
async def get_dailshop_img(request):
print(f"[{GetTime()}] [request] /shop-url")
try:
ret = await login_img_request(request)
return web.Response(body=json.dumps(ret,indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(ret, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')
except:
err_cur = traceback.format_exc()
print(f"[{GetTime()}] [Api] ERR in /shop-url\n{err_cur}")
return web.Response(body=json.dumps({'code':200,'message': 'unkown err','info':f'未知错误','except':f'{err_cur}'},indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(
{
'code': 200,
'message': 'unkown err',
'info': f'未知错误',
'except': f'{err_cur}'
},
indent=2,
sort_keys=True,
ensure_ascii=False),
content_type='application/json')


@routes.post('/tfa')
async def post_tfa_code(request):
print(f"[{GetTime()}] [request] /tfa")
try:
ret = await tfa_code_requeset(request)
return web.Response(body=json.dumps(ret,indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps(ret, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')
except:
err_cur = traceback.format_exc()
print(f"[{GetTime()}] [Api] ERR in /tfa\n{err_cur}")
return web.Response(body=json.dumps({'code':200,'message': 'unkown err','info':f'未知错误','except':f'{err_cur}'},indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')

return web.Response(body=json.dumps(
{
'code': 200,
'message': 'unkown err',
'info': f'未知错误',
'except': f'{err_cur}'
},
indent=2,
sort_keys=True,
ensure_ascii=False),
content_type='application/json')


from main import bot


# 爱发电的wh
@routes.post('/afd')
async def aifadian_webhook(request):
print(f"[{GetTime()}] [request] /afd")
try:
ret = await afd_request(request,bot)
return web.Response(body=json.dumps(ret,indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
ret = await afd_request(request, bot)
return web.Response(body=json.dumps(ret, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')
except:
err_cur = traceback.format_exc()
print(f"[{GetTime()}] [Api] ERR in /afd\n{err_cur}")
return web.Response(body=json.dumps({"ec":0,"em":"err ouccer"},indent=2, sort_keys=True,ensure_ascii=False), content_type='application/json')
return web.Response(body=json.dumps({
"ec": 0,
"em": "err ouccer"
}, indent=2, sort_keys=True, ensure_ascii=False),
content_type='application/json')


print(f"[API Start] starting at {GetTime()}")
Expand Down
Loading

0 comments on commit 0e4cdf2

Please sign in to comment.