update

src/lib/api.ts

@@ -284,11 +284,12 @@ export async function getBrands(opts?: {
 }
 
 // ===================== 账号体系（/api/auth/*） =====================
-// 说明：当前前端只用「取当前用户 + 登出」两个能力（顶栏已登录态）。
-// 登录/注册的表单提交暂未接入，相关接口函数已移除，避免无人调用的死代码。
+// 双令牌：access_token（短命，请求鉴权）+ refresh_token（长命，落库可吊销）。
+// 登录写两者；fetchMe 等受保护请求遇 401 自动用 refresh 续期一次；登出吊销 refresh。
 
 const BASE_API_URL = (BASE_API || "").replace(/\/$/, "")
-const TOKEN_KEY = "fa_token"
+const TOKEN_KEY = "fa_token" // access token
+const REFRESH_KEY = "fa_refresh" // refresh token
 const USER_KEY = "fa_user"
 
 // 注意：getUser / clearSession 只读写 localStorage，不发网络请求。
@@ -302,21 +303,77 @@ export function getUser(): AuthUser | null {
   }
 }
 
+export function getAccessToken(): string | null {
+  if (typeof localStorage === "undefined") return null
+  return localStorage.getItem(TOKEN_KEY)
+}
+
+export function getRefreshToken(): string | null {
+  if (typeof localStorage === "undefined") return null
+  return localStorage.getItem(REFRESH_KEY)
+}
+
 export function clearSession(): void {
   if (typeof localStorage === "undefined") return
   localStorage.removeItem(TOKEN_KEY)
+  localStorage.removeItem(REFRESH_KEY)
   localStorage.removeItem(USER_KEY)
 }
 
+// 写登录态：登录成功后把 access + refresh + user 写入 localStorage。
+export function saveSession(access: string, refresh: string, user: AuthUser): void {
+  if (typeof localStorage === "undefined") return
+  localStorage.setItem(TOKEN_KEY, access)
+  localStorage.setItem(REFRESH_KEY, refresh)
+  localStorage.setItem(USER_KEY, JSON.stringify(user))
+}
+
+// 刷新 token：用 refresh_token 换新的 access_token（refresh 复用、不轮换）。
+export async function refreshSession(): Promise<string> {
+  const refresh = getRefreshToken()
+  if (!refresh) throw new Error("no refresh token")
+  const res = await fetch(`${BASE_API_URL}/api/v1/auth/refresh`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ refresh_token: refresh }),
+  })
+  if (!res.ok) {
+    clearSession()
+    throw new Error("refresh failed")
+  }
+  const json: any = await res.json()
+  const access: string | undefined = json?.access_token
+  if (!access) throw new Error("refresh failed")
+  // refresh 复用：仅更新 access，保留原 refresh。
+  const user = getUser()
+  if (user) saveSession(access, refresh, user)
+  return access
+}
+
+// 带鉴权的请求：自动附带 Bearer，遇 401 静默刷新一次后重试。
+async function authedFetch(url: string, opts: RequestInit = {}): Promise<Response> {
+  const headers = new Headers(opts.headers)
+  const token = getAccessToken()
+  if (token) headers.set("Authorization", `Bearer ${token}`)
+  let res = await fetch(url, { ...opts, headers })
+  if (res.status === 401 && getRefreshToken()) {
+    try {
+      await refreshSession()
+      const newToken = getAccessToken()
+      if (newToken) headers.set("Authorization", `Bearer ${newToken}`)
+      res = await fetch(url, { ...opts, headers })
+    } catch {
+      /* 刷新失败：返回原始 401，由调用方处理 */
+    }
+  }
+  return res
+}
+
 export async function fetchMe(): Promise<AuthUser | null> {
   if (typeof localStorage === "undefined") return null
-  const token = localStorage.getItem(TOKEN_KEY)
-  if (!token) return null
+  if (!getAccessToken()) return null
   try {
-    // 接口：GET /api/auth/me（需 Bearer token，客户端运行期 base 走 BASE_API）
-    const res = await fetch(`${BASE_API_URL}/api/v1/auth/me?locale=${encodeURIComponent(currentLocale())}`, {
-      headers: { Authorization: `Bearer ${token}` },
-    })
+    const res = await authedFetch(`${BASE_API_URL}/api/v1/auth/me?locale=${encodeURIComponent(currentLocale())}`)
     if (!res.ok) {
       clearSession()
       return null
@@ -329,9 +386,59 @@ export async function fetchMe(): Promise<AuthUser | null> {
   }
 }
 
-// 注：saveSession（登录/注册成功后写 token+user 进 localStorage）已移除——
-// 站点没有登录注册入口，后端 POST /auth/register、POST /auth/login 也已下线。
-// 将来接入时恢复此函数，并补回后端注册/登录接口与前端表单。
+// 登录：POST /api/v1/auth/login（公开端点）。成功后写 access+refresh+user 进 localStorage。
+export async function login(input: { account: string; password: string }): Promise<AuthUser> {
+  const res = await fetch(`${BASE_API_URL}/api/v1/auth/login`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify(input),
+  })
+  if (!res.ok) {
+    clearSession()
+    throw new Error("login failed")
+  }
+  const json: any = await res.json()
+  const access: string | undefined = json?.access_token
+  const refresh: string | undefined = json?.refresh_token
+  const user: any = json?.user
+  if (!access || !refresh || !user) throw new Error("login failed")
+  saveSession(access, refresh, user)
+  return user as AuthUser
+}
+
+// 登出：吊销当前 refresh_token，再清本地态。
+export async function logout(): Promise<void> {
+  const refresh = getRefreshToken()
+  if (refresh) {
+    try {
+      await fetch(`${BASE_API_URL}/api/v1/auth/logout`, {
+        method: "POST",
+        headers: { "Content-Type": "application/json" },
+        body: JSON.stringify({ refresh_token: refresh }),
+      })
+    } catch {
+      /* 忽略网络错误，仍清本地态 */
+    }
+  }
+  clearSession()
+}
+
+// 踢下线：吊销当前用户所有 refresh_token（全设备退出）。
+export async function logoutAll(): Promise<void> {
+  const refresh = getRefreshToken()
+  if (refresh) {
+    try {
+      await fetch(`${BASE_API_URL}/api/v1/auth/logout-all`, {
+        method: "POST",
+        headers: { "Content-Type": "application/json" },
+        body: JSON.stringify({ refresh_token: refresh }),
+      })
+    } catch {
+      /* 忽略网络错误，仍清本地态 */
+    }
+  }
+  clearSession()
+}
 
 // ===================== SSG 构建专用（/api/ssg/*，仅 Node 构建期） =====================