AuthProvider.tsx

'use client';

import React, {
  createContext,
  useContext,
  useEffect,
  useState,
  useCallback,
} from 'react';
import { useLazyQuery, useMutation } from '@apollo/client';
import { CHECK_TOKEN_QUERY, GET_USER_INFO } from '@/graphql/request';
import { REFRESH_TOKEN_MUTATION } from '@/graphql/mutations/auth';
import { LocalStore } from '@/lib/storage';
import { LoadingPage } from '@/components/global-loading';
import { User } from '@/graphql/type';

interface AuthContextValue {
  isAuthorized: boolean;
  isLoading: boolean;
  token: string | null;
  user: User | null;
  login: (accessToken: string, refreshToken: string) => void;
  logout: () => void;
  refreshAccessToken: () => Promise<string | boolean | void>;
  validateToken: () => Promise<boolean>;
}

const AuthContext = createContext<AuthContextValue>({
  isAuthorized: false,
  isLoading: false,
  token: null,
  user: null,
  login: () => {},
  logout: () => {},
  refreshAccessToken: async () => {},
  validateToken: async () => false,
});

export function AuthProvider({ children }: { children: React.ReactNode }) {
  const [token, setToken] = useState<string | null>(null);
  const [isAuthorized, setIsAuthorized] = useState(false);
  const [isLoading, setIsLoading] = useState(true);
  const [user, setUser] = useState<User | null>(null);

  const [checkToken] = useLazyQuery<{ checkToken: boolean }>(CHECK_TOKEN_QUERY);
  const [refreshTokenMutation] = useMutation(REFRESH_TOKEN_MUTATION);
  const [getUserInfo] = useLazyQuery<{ me: User }>(GET_USER_INFO);

  const validateToken = useCallback(async () => {
    const storedToken = localStorage.getItem(LocalStore.accessToken);
    if (!storedToken) {
      setIsAuthorized(false);
      setUser(null);
      return false;
    }
    try {
      const { data } = await checkToken({
        variables: { input: { token: storedToken } },
      });
      if (data?.checkToken) {
        setToken(storedToken);
        return true;
      }
      return false;
    } catch (error) {
      console.error('Token validation error:', error);
      return false;
    }
  }, [checkToken]);

  const fetchUserInfo = useCallback(async () => {
    try {
      const { data } = await getUserInfo();
      if (data?.me) {
        setUser(data.me);
        return true;
      }
      return false;
    } catch (error) {
      console.error('Failed to fetch user info:', error);
      return false;
    }
  }, [getUserInfo]);

  const refreshAccessToken = useCallback(async () => {
    try {
      const refreshToken = localStorage.getItem(LocalStore.refreshToken);
      if (!refreshToken) {
        logout();
        return false;
      }
      const { data } = await refreshTokenMutation({
        variables: { refreshToken },
      });
      if (data?.refreshToken) {
        const newAccess = data.refreshToken.accessToken;
        const newRefresh = data.refreshToken.refreshToken;

        localStorage.setItem(LocalStore.accessToken, newAccess);
        if (newRefresh) {
          localStorage.setItem(LocalStore.refreshToken, newRefresh);
        }
        setToken(newAccess);
        setIsAuthorized(true);
        return newAccess;
      } else {
        logout();
        return false;
      }
    } catch (error) {
      console.error('Refresh token error:', error);
      logout();
      return false;
    }
  }, [refreshTokenMutation]);

  const login = useCallback(
    (accessToken: string, refreshToken: string) => {
      localStorage.setItem(LocalStore.accessToken, accessToken);
      localStorage.setItem(LocalStore.refreshToken, refreshToken);

      setToken(accessToken);
      if (process.env.NODE_ENV !== 'production') {
        console.log('Token saved successfully');
      }
      setIsAuthorized(true);
      fetchUserInfo();
    },
    [fetchUserInfo]
  );

  const logout = useCallback(() => {
    setToken(null);
    setIsAuthorized(false);
    setUser(null);
    localStorage.removeItem(LocalStore.accessToken);
    localStorage.removeItem(LocalStore.refreshToken);
  }, []);

  useEffect(() => {
    async function initAuth() {
      setIsLoading(true);

      const storedToken = localStorage.getItem(LocalStore.accessToken);
      if (!storedToken) {
        console.log('No stored token found, skip checkToken');
        setIsAuthorized(false);
        setUser(null);
        setIsLoading(false);
        return;
      }

      let isValid = await validateToken();

      // 如果验证失败，再试图刷新
      if (!isValid) {
        isValid = (await refreshAccessToken()) ? true : false;
      }

      // 最终判断
      if (isValid) {
        setIsAuthorized(true);
        await fetchUserInfo();
      } else {
        setIsAuthorized(false);
        setUser(null);
      }

      setIsLoading(false);
    }

    initAuth();
  }, [validateToken, refreshAccessToken, fetchUserInfo]);

  if (isLoading) {
    return <LoadingPage />;
  }

  return (
    <AuthContext.Provider
      value={{
        isAuthorized,
        isLoading,
        token,
        user,
        login,
        logout,
        refreshAccessToken,
        validateToken,
      }}
    >
      {children}
    </AuthContext.Provider>
  );
}

export function useAuthContext() {
  return useContext(AuthContext);
}