feat: sync wallet data

src/app/App.tsx

@@ -24,7 +24,7 @@ import { middlewares, RouterView, routes } from "../router";
 import { EnvironmentProvider, useEnvironmentContext } from "./contexts";
 import { useNetworkStatus } from "./hooks";
 import { i18n } from "./i18n";
-import { httpClient } from "./services";
+import { httpClient, Scheduler } from "./services";
 
 const __DEV__ = process.env.NODE_ENV !== "production";
 
@@ -44,7 +44,7 @@ const Main = ({ syncInterval }: Props) => {
 	}, [pathname]);
 
 	useLayoutEffect(() => {
-		const syncDelegates = () => {
+		const syncDelegates = async () => {
 			console.log("Running delegates sync...");
 			const coinsData = env.usedCoinsWithNetworks();
 			const coinsInUse = Object.keys(coinsData);
@@ -57,20 +57,36 @@ const Main = ({ syncInterval }: Props) => {
 				}
 			}
 
-			Promise.allSettled(delegatesPromises).then(() => {
-				setShowSplash(false);
-			});
+			await Promise.allSettled(delegatesPromises);
+		};
+
+		const syncWallets = async () => {
+			console.log("Running wallet data sync...");
+			const profiles = env.profiles().values();
+
+			for (const profile of profiles) {
+				const [wallet] = profile.wallets().values();
+				try {
+					await wallet?.syncVotes();
+					await wallet?.syncIdentity();
+					await wallet?.syncExchangeRate();
+
+					setShowSplash(false);
+				} catch (error) {
+					console.error(`Error synchronizing wallet data ${error}`);
+					setShowSplash(false);
+				}
+			}
 		};
 
 		const boot = async () => {
 			await env.verify(fixtureData);
-			syncDelegates();
-
-			console.info("Scheduling next delegates synchronization...");
-			setInterval(() => syncDelegates(), syncInterval);
-
+			await syncDelegates();
 			await env.boot();
+			await syncWallets();
 			await persist();
+
+			Scheduler(syncInterval).schedule([syncDelegates, syncWallets], persist);
 		};
 
 		if (process.env.REACT_APP_BUILD_MODE === "demo") {
@@ -138,3 +154,7 @@ export const App = ({ syncInterval }: Props) => {
 		</ErrorBoundary>
 	);
 };
+
+App.defaultProps = {
+	syncInterval: 300000,
+};

src/app/services/Scheduler.test.ts

@@ -0,0 +1,29 @@
+import { Scheduler } from "./Scheduler";
+
+describe("Scheduler test", () => {
+	jest.useFakeTimers();
+
+	it("should run an action after an determined interval", () => {
+		const action = jest.fn();
+		Scheduler(100).schedule([action]);
+		jest.advanceTimersByTime(100);
+		expect(action).toHaveBeenCalled();
+	});
+
+	it("should run an action using the default interval", () => {
+		const action = jest.fn();
+		Scheduler().schedule([action]);
+		jest.advanceTimersByTime(300000);
+		expect(action).toHaveBeenCalled();
+	});
+
+	it("should run actions and the done callback", () => {
+		const action = jest.fn();
+		const done = jest.fn();
+		Scheduler().schedule([action], done);
+
+		jest.advanceTimersByTime(300500);
+		expect(action).toHaveBeenCalled();
+		expect(done).toHaveBeenCalled();
+	});
+});

src/app/services/Scheduler.ts

@@ -0,0 +1,12 @@
+export const Scheduler = (interval = 300000) => ({
+	schedule: (actions: any, done: Function) => {
+		for (const action of actions) {
+			console.log(`Scheduling action ${action.name} for every ${interval / 60000} mins`);
+
+			setInterval(() => action(), interval);
+
+			// Run a done action once all timers runned
+			return done && setTimeout(() => done(), interval + 500);
+		}
+	},
+});

src/app/services/index.ts

@@ -1,3 +1,5 @@
 import { HttpClient } from "./HttpClient";
 
 export const httpClient = new HttpClient(10);
+
+export * from "./Scheduler";

src/domains/vote/components/AddressTable/AddressRow/AddressRow.tsx

@@ -42,15 +42,10 @@ export const AddressRow = ({ index, wallet, isLoading, onSelect }: AddressRowPro
 	const getIconColor = (type: string) => (type === "Starred" ? "text-theme-warning-400" : "text-theme-neutral-600");
 
 	useEffect(() => {
-		const loadVotes = async () => {
+		const loadVotes = () => {
 			if (!hasProperty(wallet, "isLoading")) {
-				// TODO: move this to profile initialising and run it every X period
-				await env.coins().syncDelegates(wallet?.coinId(), wallet?.networkId());
-
 				let votes: ReadOnlyWallet[] = [];
 				try {
-					await wallet.syncVotes();
-
 					votes = wallet.votes();
 				} catch {
 					votes = [];

src/domains/vote/pages/Votes/Votes.tsx

@@ -94,10 +94,7 @@ export const Votes = () => {
 	}, [activeProfile, network]);
 
 	const loadDelegates = useCallback(
-		async (wallet) => {
-			// TODO: move this to profile initialising and run it every X period
-			// eslint-disable-next-line @typescript-eslint/no-non-null-asserted-optional-chain
-			await env.coins().syncDelegates(wallet?.coinId()!, wallet?.networkId()!);
+		(wallet) => {
 			// eslint-disable-next-line @typescript-eslint/no-non-null-asserted-optional-chain
 			const delegates = env.coins().delegates(wallet?.coinId()!, wallet?.networkId()!);
 			const readOnlyDelegates = DelegateMapper.execute(
@@ -119,10 +116,10 @@ export const Votes = () => {
 		setNetwork(network!);
 	};
 
-	const handleSelectAddress = async (address: string) => {
+	const handleSelectAddress = (address: string) => {
 		setAddress(address);
 		const wallet = activeProfile.wallets().findByAddress(address);
-		await loadDelegates(wallet);
+		loadDelegates(wallet);
 	};
 
 	return (

src/domains/wallet/pages/WalletDetails/WalletDetails.tsx

@@ -66,8 +66,6 @@ export const WalletDetails = ({ txSkeletonRowsLimit }: WalletDetailsProps) => {
 			let votes: ReadOnlyWallet[] = [];
 
 			try {
-				await activeWallet.syncVotes();
-
 				votes = activeWallet.votes();
 			} catch {
 				votes = [];
@@ -85,15 +83,6 @@ export const WalletDetails = ({ txSkeletonRowsLimit }: WalletDetailsProps) => {
 		fetchAllData();
 	}, [activeWallet, env]);
 
-	useEffect(() => {
-		const timer = setInterval(async () => {
-			await activeWallet.syncIdentity();
-			await persist();
-		}, 30000);
-
-		return () => clearInterval(timer);
-	}, [activeWallet, persist]);
-
 	const handleDeleteWallet = async () => {
 		activeProfile.wallets().forget(activeWallet.id());
 		await persist();