Update asgi_app.py
This commit is contained in:
+8
-8
@@ -118,9 +118,7 @@ async def mcp_protocol_handler(request: Request):
|
|||||||
|
|
||||||
request_state = clerk.authenticate_request(
|
request_state = clerk.authenticate_request(
|
||||||
mock_request,
|
mock_request,
|
||||||
AuthenticateRequestOptions(
|
AuthenticateRequestOptions()
|
||||||
authorized_parties=['https://api.yargimcp.com']
|
|
||||||
)
|
|
||||||
)
|
)
|
||||||
|
|
||||||
if request_state.is_signed_in:
|
if request_state.is_signed_in:
|
||||||
@@ -221,11 +219,15 @@ async def sse_protocol_handler(request: Request):
|
|||||||
|
|
||||||
request_state = clerk.authenticate_request(
|
request_state = clerk.authenticate_request(
|
||||||
mock_request,
|
mock_request,
|
||||||
AuthenticateRequestOptions(
|
AuthenticateRequestOptions()
|
||||||
authorized_parties=['https://api.yargimcp.com']
|
|
||||||
)
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
# Initialize variables
|
||||||
|
user_id = None
|
||||||
|
user_email = None
|
||||||
|
user_plan = 'free'
|
||||||
|
scopes = ['yargi.read']
|
||||||
|
|
||||||
if request_state.is_signed_in:
|
if request_state.is_signed_in:
|
||||||
# Get user info from token payload
|
# Get user info from token payload
|
||||||
payload = getattr(request_state, 'payload', {})
|
payload = getattr(request_state, 'payload', {})
|
||||||
@@ -237,8 +239,6 @@ async def sse_protocol_handler(request: Request):
|
|||||||
|
|
||||||
# Use email as primary user identifier
|
# Use email as primary user identifier
|
||||||
user_id = user_email or request_state.user_id
|
user_id = user_email or request_state.user_id
|
||||||
else:
|
|
||||||
user_id = None
|
|
||||||
|
|
||||||
if user_id:
|
if user_id:
|
||||||
logger.info(f"SSE Clerk Bearer JWT token validated for user: {user_id}")
|
logger.info(f"SSE Clerk Bearer JWT token validated for user: {user_id}")
|
||||||
|
|||||||
Reference in New Issue
Block a user