|
|
|
|
@@ -20,6 +20,7 @@ import type {
|
|
|
|
|
import { loadStorage, saveStorage } from './GlobalStateStore.utils';
|
|
|
|
|
|
|
|
|
|
const initialState: GlobalState = {
|
|
|
|
|
initialized: false,
|
|
|
|
|
layout: {
|
|
|
|
|
bottomBar: { open: false },
|
|
|
|
|
leftBar: { open: false },
|
|
|
|
|
@@ -141,13 +142,14 @@ const createNavigationSlice = (set: SetState) => ({
|
|
|
|
|
})),
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
const createComplexActions = (set: SetState, get: GetState) => ({
|
|
|
|
|
fetchData: async (url?: string) => {
|
|
|
|
|
const createComplexActions = (set: SetState, get: GetState) => {
|
|
|
|
|
// Internal implementation without lock
|
|
|
|
|
const fetchDataInternal = async (url?: string) => {
|
|
|
|
|
try {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
apiURL: url ?? state.session.apiURL,
|
|
|
|
|
apiURL: url || state.session.apiURL,
|
|
|
|
|
loading: true,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
@@ -190,7 +192,16 @@ const createComplexActions = (set: SetState, get: GetState) => ({
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
fetchData: async (url?: string) => {
|
|
|
|
|
// Wait for initialization to complete
|
|
|
|
|
await waitForInitialization();
|
|
|
|
|
|
|
|
|
|
// Use lock to prevent concurrent fetchData calls
|
|
|
|
|
return withOperationLock(() => fetchDataInternal(url));
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
isLoggedIn: (): boolean => {
|
|
|
|
|
const session = get().session;
|
|
|
|
|
@@ -203,92 +214,146 @@ const createComplexActions = (set: SetState, get: GetState) => ({
|
|
|
|
|
return true;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
login: async (authToken?: string) => {
|
|
|
|
|
try {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
authToken: authToken ?? '',
|
|
|
|
|
expiryDate: new Date(Date.now() + 24 * 60 * 60 * 1000).toISOString(),
|
|
|
|
|
loading: true,
|
|
|
|
|
loggedIn: true,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
await get().fetchData();
|
|
|
|
|
const currentState = get();
|
|
|
|
|
const result = await currentState.onLogin?.(currentState);
|
|
|
|
|
if (result) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...state,
|
|
|
|
|
owner: result.owner ? { ...state.owner, ...result.owner } : state.owner,
|
|
|
|
|
program: result.program ? { ...state.program, ...result.program } : state.program,
|
|
|
|
|
session: result.session ? { ...state.session, ...result.session } : state.session,
|
|
|
|
|
user: result.user ? { ...state.user, ...result.user } : state.user,
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
} catch (e) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: false,
|
|
|
|
|
error: `Login Exception: ${String(e)}`,
|
|
|
|
|
loading: false,
|
|
|
|
|
loggedIn: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
} finally {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
login: async (authToken?: string, user?: Partial<UserState>) => {
|
|
|
|
|
// Wait for initialization to complete
|
|
|
|
|
await waitForInitialization();
|
|
|
|
|
|
|
|
|
|
logout: async () => {
|
|
|
|
|
try {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...initialState,
|
|
|
|
|
session: {
|
|
|
|
|
...initialState.session,
|
|
|
|
|
apiURL: state.session.apiURL,
|
|
|
|
|
expiryDate: undefined,
|
|
|
|
|
loading: true,
|
|
|
|
|
loggedIn: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
await get().fetchData();
|
|
|
|
|
const currentState = get();
|
|
|
|
|
const result = await currentState.onLogout?.(currentState);
|
|
|
|
|
if (result) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...state,
|
|
|
|
|
owner: result.owner ? { ...state.owner, ...result.owner } : state.owner,
|
|
|
|
|
program: result.program ? { ...state.program, ...result.program } : state.program,
|
|
|
|
|
session: result.session ? { ...state.session, ...result.session } : state.session,
|
|
|
|
|
user: result.user ? { ...state.user, ...result.user } : state.user,
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
} catch (e) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: false,
|
|
|
|
|
error: `Logout Exception: ${String(e)}`,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
} finally {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
});
|
|
|
|
|
// Use lock to prevent concurrent auth operations
|
|
|
|
|
return withOperationLock(async () => {
|
|
|
|
|
try {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
authToken: authToken ?? '',
|
|
|
|
|
expiryDate: new Date(Date.now() + 24 * 60 * 60 * 1000).toISOString(),
|
|
|
|
|
loading: true,
|
|
|
|
|
loggedIn: true,
|
|
|
|
|
},
|
|
|
|
|
user: {
|
|
|
|
|
...state.user,
|
|
|
|
|
...user,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
|
|
|
|
|
const currentState = get();
|
|
|
|
|
const result = await currentState.onLogin?.(currentState);
|
|
|
|
|
if (result) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...state,
|
|
|
|
|
owner: result.owner ? { ...state.owner, ...result.owner } : state.owner,
|
|
|
|
|
program: result.program ? { ...state.program, ...result.program } : state.program,
|
|
|
|
|
session: result.session ? { ...state.session, ...result.session } : state.session,
|
|
|
|
|
user: result.user ? { ...state.user, ...result.user } : state.user,
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
// Call internal version to avoid nested lock
|
|
|
|
|
await fetchDataInternal();
|
|
|
|
|
} catch (e) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: false,
|
|
|
|
|
error: `Login Exception: ${String(e)}`,
|
|
|
|
|
loading: false,
|
|
|
|
|
loggedIn: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
} finally {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
logout: async () => {
|
|
|
|
|
// Wait for initialization to complete
|
|
|
|
|
await waitForInitialization();
|
|
|
|
|
|
|
|
|
|
// Use lock to prevent concurrent auth operations
|
|
|
|
|
return withOperationLock(async () => {
|
|
|
|
|
try {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...initialState,
|
|
|
|
|
session: {
|
|
|
|
|
...initialState.session,
|
|
|
|
|
apiURL: state.session.apiURL,
|
|
|
|
|
expiryDate: undefined,
|
|
|
|
|
loading: true,
|
|
|
|
|
loggedIn: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
|
|
|
|
|
const currentState = get();
|
|
|
|
|
const result = await currentState.onLogout?.(currentState);
|
|
|
|
|
if (result) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
...state,
|
|
|
|
|
owner: result.owner ? { ...state.owner, ...result.owner } : state.owner,
|
|
|
|
|
program: result.program ? { ...state.program, ...result.program } : state.program,
|
|
|
|
|
session: result.session ? { ...state.session, ...result.session } : state.session,
|
|
|
|
|
user: result.user ? { ...state.user, ...result.user } : state.user,
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
// Call internal version to avoid nested lock
|
|
|
|
|
await fetchDataInternal();
|
|
|
|
|
} catch (e) {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: false,
|
|
|
|
|
error: `Logout Exception: ${String(e)}`,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
} finally {
|
|
|
|
|
set((state: GlobalState) => ({
|
|
|
|
|
session: {
|
|
|
|
|
...state.session,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// State management flags and locks - must be defined before store creation
|
|
|
|
|
let isStorageInitialized = false;
|
|
|
|
|
let initializationPromise: null | Promise<void> = null;
|
|
|
|
|
let operationLock: Promise<void> = Promise.resolve();
|
|
|
|
|
|
|
|
|
|
// Helper to wait for initialization - must be defined before store creation
|
|
|
|
|
const waitForInitialization = async (): Promise<void> => {
|
|
|
|
|
if (initializationPromise) {
|
|
|
|
|
await initializationPromise;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// Helper to ensure async operations run sequentially
|
|
|
|
|
const withOperationLock = async <T>(operation: () => Promise<T>): Promise<T> => {
|
|
|
|
|
const currentLock = operationLock;
|
|
|
|
|
let releaseLock: () => void;
|
|
|
|
|
|
|
|
|
|
// Create new lock promise
|
|
|
|
|
operationLock = new Promise<void>((resolve) => {
|
|
|
|
|
releaseLock = resolve;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
// Wait for previous operation to complete
|
|
|
|
|
await currentLock;
|
|
|
|
|
// Run the operation
|
|
|
|
|
return await operation();
|
|
|
|
|
} finally {
|
|
|
|
|
// Release the lock
|
|
|
|
|
releaseLock!();
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
const GlobalStateStore = createStore<GlobalStateStoreType>((set, get) => ({
|
|
|
|
|
...initialState,
|
|
|
|
|
@@ -301,33 +366,40 @@ const GlobalStateStore = createStore<GlobalStateStoreType>((set, get) => ({
|
|
|
|
|
...createComplexActions(set, get),
|
|
|
|
|
}));
|
|
|
|
|
|
|
|
|
|
// Flag to prevent saving during initial load
|
|
|
|
|
let isInitialLoad = true;
|
|
|
|
|
|
|
|
|
|
loadStorage()
|
|
|
|
|
// Initialize storage and load saved state
|
|
|
|
|
initializationPromise = loadStorage()
|
|
|
|
|
.then((state) => {
|
|
|
|
|
GlobalStateStore.setState((current) => ({
|
|
|
|
|
...current,
|
|
|
|
|
...state,
|
|
|
|
|
session: {
|
|
|
|
|
...current.session,
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: true,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}));
|
|
|
|
|
// Merge loaded state with initial state
|
|
|
|
|
GlobalStateStore.setState(
|
|
|
|
|
(current) => ({
|
|
|
|
|
...current,
|
|
|
|
|
...state,
|
|
|
|
|
initialized: true,
|
|
|
|
|
session: {
|
|
|
|
|
...current.session,
|
|
|
|
|
...state.session,
|
|
|
|
|
connected: true,
|
|
|
|
|
loading: false,
|
|
|
|
|
},
|
|
|
|
|
}),
|
|
|
|
|
true // Replace state completely to avoid triggering subscription during init
|
|
|
|
|
);
|
|
|
|
|
})
|
|
|
|
|
.catch((e) => {
|
|
|
|
|
console.error('Error loading storage:', e);
|
|
|
|
|
// Mark as initialized even on error so app doesn't hang
|
|
|
|
|
GlobalStateStore.setState({ initialized: true });
|
|
|
|
|
})
|
|
|
|
|
.finally(() => {
|
|
|
|
|
// Enable saving after initial load completes
|
|
|
|
|
isInitialLoad = false;
|
|
|
|
|
// Mark initialization as complete
|
|
|
|
|
isStorageInitialized = true;
|
|
|
|
|
initializationPromise = null;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
// Subscribe to state changes and persist to storage
|
|
|
|
|
// Only saves after initialization is complete
|
|
|
|
|
GlobalStateStore.subscribe((state) => {
|
|
|
|
|
// Skip saving during initial load
|
|
|
|
|
if (isInitialLoad) {
|
|
|
|
|
if (!isStorageInitialized) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|