deploy: update habadashi_login
Browse files
app.py
CHANGED
|
@@ -139,6 +139,9 @@ class RequestLoggingMiddleware(BaseHTTPMiddleware):
|
|
| 139 |
return None
|
| 140 |
try:
|
| 141 |
res = supabase.auth.get_user(token)
|
|
|
|
|
|
|
|
|
|
| 142 |
return {"user_id": str(res.user.id), "email": res.user.email}
|
| 143 |
except Exception:
|
| 144 |
return None
|
|
@@ -249,9 +252,9 @@ if private_app_dir:
|
|
| 249 |
def get_org_for_storage():
|
| 250 |
"""現在のリクエストユーザーの組織名を返す(HF dataset のネームスペース用)"""
|
| 251 |
user_ctx = get_user_context()
|
| 252 |
-
if user_ctx and isinstance(user_ctx, dict)
|
| 253 |
-
|
| 254 |
-
return None
|
| 255 |
|
| 256 |
set_org_name_getter(get_org_for_storage)
|
| 257 |
print("[ORG_CONTEXT] Connected org_name getter to hf_storage")
|
|
|
|
| 139 |
return None
|
| 140 |
try:
|
| 141 |
res = supabase.auth.get_user(token)
|
| 142 |
+
# NOTE: org_name はここでは取得しない(軽量化のため profiles を叩かない)。
|
| 143 |
+
# そのため get_user_context() から org_name は取れず、upload 時に "default" に落ちる可能性がある。
|
| 144 |
+
print(f"[ORG_CONTEXT] _resolve_user: user_id={res.user.id} email={res.user.email} org_name=NOT_FETCHED")
|
| 145 |
return {"user_id": str(res.user.id), "email": res.user.email}
|
| 146 |
except Exception:
|
| 147 |
return None
|
|
|
|
| 252 |
def get_org_for_storage():
|
| 253 |
"""現在のリクエストユーザーの組織名を返す(HF dataset のネームスペース用)"""
|
| 254 |
user_ctx = get_user_context()
|
| 255 |
+
org = user_ctx.get("org_name") if user_ctx and isinstance(user_ctx, dict) else None
|
| 256 |
+
print(f"[ORG_CONTEXT] get_org_for_storage called: user_ctx_keys={list(user_ctx.keys()) if user_ctx else None} org_name={org!r}")
|
| 257 |
+
return org or None
|
| 258 |
|
| 259 |
set_org_name_getter(get_org_for_storage)
|
| 260 |
print("[ORG_CONTEXT] Connected org_name getter to hf_storage")
|