test-sse
This commit is contained in:
parent
554f08c440
commit
38219e83c5
2
CHECKS
2
CHECKS
|
@ -2,4 +2,4 @@ WAIT=10
|
||||||
TIMEOUT=10
|
TIMEOUT=10
|
||||||
ATTEMPTS=30 # 10 * 30 = 5 min
|
ATTEMPTS=30 # 10 * 30 = 5 min
|
||||||
|
|
||||||
/graphql Playground
|
/ Playground
|
||||||
|
|
|
@ -4,11 +4,11 @@ from resolvers.inbox.messages import message_generator
|
||||||
from base.exceptions import Unauthorized
|
from base.exceptions import Unauthorized
|
||||||
|
|
||||||
|
|
||||||
def sse_messages(request: Request):
|
async def sse_messages(request: Request):
|
||||||
print(f'[SSE] {request.scope}') # FIXME: DOES NOT HAPPEN TO BE CALLED
|
print(f'[SSE] {request.scope}') # FIXME: DOES NOT HAPPEN TO BE CALLED
|
||||||
# https://github.com/enisdenjo/graphql-sse/blob/master/PROTOCOL.md
|
# https://github.com/enisdenjo/graphql-sse/blob/master/PROTOCOL.md
|
||||||
if request['user']:
|
if request['user']:
|
||||||
event_generator = message_generator(None, request.scope)
|
event_generator = await message_generator(None, request.scope)
|
||||||
return EventSourceResponse(event_generator)
|
return EventSourceResponse(event_generator)
|
||||||
else:
|
else:
|
||||||
raise Unauthorized("Please login")
|
raise Unauthorized("Please login")
|
||||||
|
|
Loading…
Reference in New Issue
Block a user