LBRYCommunity/comment-server
1
0
Fork 0
Code Issues 18 Pull requests 1 Projects Releases Packages Wiki Activity

refactor to replace delete_comment with abandon_comment #8

Merged
osilkin98 merged 2 commits from api-refactor into master 2019-08-10 23:36:08 +02:00
Conversation 0 Commits 2 Files changed 2 +11 -7
2 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 670b34a95d - Show all commits

6
src/database/writes.py
View file

@ -44,10 +44,10 @@ async def abandon_comment(app, comment_id):
async def abandon_comment_if_authorized(app, comment_id, **kwargs): async def abandon_comment_if_authorized(app, comment_id, **kwargs):
authorized = await is_authentic_delete_signal(app, comment_id, **kwargs) authorized = await is_authentic_delete_signal(app, comment_id, **kwargs)
if not authorized: if not authorized:
return {'deleted': False} return False
job = await app['comment_scheduler'].spawn(delete_comment(app, comment_id)) job = await app['comment_scheduler'].spawn(abandon_comment(app, comment_id))
return {'deleted': await job.wait()} return await job.wait()
async def write_comment(app, params): async def write_comment(app, params):

12
src/server/handles.py
View file

@ -54,8 +54,8 @@ async def handle_create_comment(app, params):
raise ValueError('base comment is invalid') raise ValueError('base comment is invalid')
async def handle_delete_comment(app, params): async def handle_abandon_comment(app, params):
return await delete_comment_if_authorized(app, **params) return {'abandoned': await abandon_comment_if_authorized(app, **params)}
async def handle_hide_comments(app, params): async def handle_hide_comments(app, params):
@ -70,8 +70,8 @@ METHODS = {
'get_comments_by_id': handle_get_comments_by_id, 'get_comments_by_id': handle_get_comments_by_id,
'get_channel_from_comment_id': handle_get_channel_from_comment_id, 'get_channel_from_comment_id': handle_get_channel_from_comment_id,
'create_comment': handle_create_comment, 'create_comment': handle_create_comment,
'delete_comment': handle_delete_comment, 'delete_comment': handle_abandon_comment,
'abandon_comment': handle_delete_comment, 'abandon_comment': handle_abandon_comment,
'hide_comments': handle_hide_comments 'hide_comments': handle_hide_comments
} }
@ -108,6 +108,10 @@ async def process_json(app, body: dict) -> dict:
async def api_endpoint(request: web.Request): async def api_endpoint(request: web.Request):
try: try:
web.access_logger.info(f'Forwarded headers: {request.remote}') web.access_logger.info(f'Forwarded headers: {request.remote}')
logging.debug(f'Request: {request}')
for k, v in request.items():
logging.debug(f'{k}: {v}')
body = await request.json() body = await request.json()
if type(body) is list or type(body) is dict: if type(body) is list or type(body) is dict:
if type(body) is list: if type(body) is list: