LBRYFoundation/lbry-sdk
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbry-sdk.git synced 2025-09-01 01:35:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adding access control headers

Browse source
This commit is contained in:
John Leith 2021-03-27 21:56:19 -06:00 • committed by Lex Berezhny
parent 0dfb92281b
commit b97164fcfb
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
lbry/extras/daemon/daemon.py
View file

@ -338,6 +338,7 @@ class Daemon(metaclass=JSONRPCServerType):
rpc_app.router.add_get('/lbryapi', self.handle_old_jsonrpc) rpc_app.router.add_get('/lbryapi', self.handle_old_jsonrpc)
rpc_app.router.add_post('/lbryapi', self.handle_old_jsonrpc) rpc_app.router.add_post('/lbryapi', self.handle_old_jsonrpc)
rpc_app.router.add_post('/', self.handle_old_jsonrpc) rpc_app.router.add_post('/', self.handle_old_jsonrpc)
rpc_app.router.add_options('/', self.add_cors_headers)
self.rpc_runner = web.AppRunner(rpc_app) self.rpc_runner = web.AppRunner(rpc_app)
streaming_app = web.Application() streaming_app = web.Application()
@ -539,6 +540,18 @@ class Daemon(metaclass=JSONRPCServerType):
self.analytics_manager.stop() self.analytics_manager.stop()
log.info("finished shutting down") log.info("finished shutting down")
async def add_cors_headers(self, request):
if self.conf.allowed_origin:
response = web.Response(
headers={
'Access-Control-Allow-Origin': self.conf.allowed_origin,
'Access-Control-Allow-Methods': self.conf.allowed_origin,
'Access-Control-Allow-Headers': self.conf.allowed_origin,
}
)
return response
return None
async def handle_old_jsonrpc(self, request): async def handle_old_jsonrpc(self, request):
ensure_request_allowed(request, self.conf) ensure_request_allowed(request, self.conf)
data = await request.json() data = await request.json()
@ -559,8 +572,16 @@ class Daemon(metaclass=JSONRPCServerType):
'After successfully executing the command, failed to encode result for JSON RPC response.', 'After successfully executing the command, failed to encode result for JSON RPC response.',
{'traceback': format_exc()} {'traceback': format_exc()}
), ledger=ledger) ), ledger=ledger)
headers = {}
if self.conf.allowed_origin:
headers.update({
'Access-Control-Allow-Origin': self.conf.allowed_origin,
'Access-Control-Allow-Methods': self.conf.allowed_origin,
'Access-Control-Allow-Headers': self.conf.allowed_origin,
})
return web.Response( return web.Response(
text=encoded_result, text=encoded_result,
headers=headers,
content_type='application/json' content_type='application/json'
) )