fix: network grapth staleness check

Author: jvsena42

src/utils/lightning/index.ts

@@ -300,6 +300,67 @@ export const checkRgsHealth = async (): Promise<
 	}
 };
 
+/**
+ * Checks if the network graph needs to be refreshed before making a payment.
+ * Considers the graph stale if RGS data is older than the specified threshold.
+ * @param {number} maxAgeHours - Maximum acceptable age in hours (default: 6)
+ * @returns {Promise<boolean>} - True if refresh is needed
+ */
+export const shouldRefreshNetworkGraph = async (
+	maxAgeHours: number = 6,
+): Promise<boolean> => {
+	const healthCheck = await checkRgsHealth();
+
+	if (healthCheck.isErr()) {
+		// If we can't check RGS health, assume refresh is needed
+		console.warn(
+			`Network graph health check failed: ${healthCheck.error.message}`,
+		);
+		return true;
+	}
+
+	const { ageHours } = healthCheck.value;
+
+	if (ageHours > maxAgeHours) {
+		console.log(
+			`Network graph is stale (${ageHours.toFixed(1)}h old), refresh needed`,
+		);
+		return true;
+	}
+
+	return false;
+};
+
+/**
+ * Forces a network graph refresh by calling syncLdk.
+ * This ensures we have the latest routing information before attempting payments.
+ * @returns {Promise<Result<string>>}
+ */
+export const forceNetworkGraphRefresh = async (): Promise<Result<string>> => {
+	try {
+		console.log('Forcing network graph refresh for payment routing...');
+
+		// Sync LDK to get latest network graph
+		const syncResult = await lm.syncLdk();
+		if (syncResult.isErr()) {
+			return err(`Network graph refresh failed: ${syncResult.error.message}`);
+		}
+
+		// Optionally download fresh scorer data
+		const scorerResult = await ldk.downloadScorer();
+		if (scorerResult.isErr()) {
+			console.warn(
+				`Scorer download failed: ${scorerResult.error.message}, continuing with cached scorer`,
+			);
+		}
+
+		console.log('Network graph refresh completed successfully');
+		return ok('Network graph refreshed');
+	} catch (e) {
+		return err(`Network graph refresh error: ${e.message}`);
+	}
+};
+
 /**
  * Fetch fees from mempool.space and blocktank.to, prioritizing mempool.space.
  * Multiple attempts are made to fetch the fees from each provider
@@ -1702,6 +1763,17 @@ export const payLightningInvoice = async ({
 	try {
 		await waitForLdkChannels();
 
+		// Check if network graph needs refresh before attempting payment
+		const needsRefresh = await shouldRefreshNetworkGraph(6); // 6 hour threshold
+		if (needsRefresh) {
+			console.log('Network graph is stale, forcing refresh before payment...');
+			const refreshResult = await forceNetworkGraphRefresh();
+			if (refreshResult.isErr()) {
+				console.warn(`Failed to refresh network graph: ${refreshResult.error.message}`);
+				// Continue anyway - better to try with stale data than fail immediately
+			}
+		}
+
 		const addPeersResponse = await addPeers();
 		if (addPeersResponse.isErr()) {
 			return err(addPeersResponse.error.message);