Convert FetchService into singleton GitService

The $head signal should probably live in the same service.

Author: mtsgrd

apps/desktop/src/lib/fetchSignal/fetchSignal.ts

@@ -0,0 +1,14 @@
+import type { Tauri } from '$lib/backend/tauri';
+
+export class GitService {
+	constructor(private tauri: Tauri) {}
+
+	/**
+	 * Emits a new value when a fetch was detected by the back end.
+	 * @example
+	 * $effect(() => gitService.onFetch(data.projectId, () => {}));
+	 */
+	onFetch(projectId: string, callback: () => void) {
+		return this.tauri.listen<any>(`project://${projectId}/git/fetch`, callback);
+	}
+}

apps/desktop/src/lib/git/gitService.ts

@@ -37,6 +37,7 @@
 	import { GitHubClient } from '$lib/forge/github/githubClient';
 	import { GitHubUserService } from '$lib/forge/github/githubUserService.svelte';
 	import { GitLabClient } from '$lib/forge/gitlab/gitlabClient.svelte';
+	import { GitService } from '$lib/git/gitService';
 	import { OplogService } from '$lib/history/oplogService.svelte';
 	import SnapshotDiffService from '$lib/history/snapshotDiffService.svelte';
 	import { HooksService } from '$lib/hooks/hooksService';
@@ -240,6 +241,7 @@
 	setContext(DragStateService, new DragStateService());
 	setContext(ResizeSync, new ResizeSync());
 	setContext(UncommitedFilesWatcher, new UncommitedFilesWatcher());
+	setContext(GitService, new GitService(data.tauri));
 
 	const settingsService = data.settingsService;
 	const settingsStore = settingsService.appSettings;

apps/desktop/src/routes/+layout.svelte

@@ -26,6 +26,7 @@
 	import { GitLabClient } from '$lib/forge/gitlab/gitlabClient.svelte';
 	import { GitLabState } from '$lib/forge/gitlab/gitlabState.svelte';
 	import { TemplateService } from '$lib/forge/templateService';
+	import { GitService } from '$lib/git/gitService';
 	import { HistoryService } from '$lib/history/history';
 	import { ModeService } from '$lib/mode/modeService';
 	import { showError, showInfo } from '$lib/notifications/toasts';
@@ -44,7 +45,7 @@
 
 	const { data, children: pageChildren }: { data: LayoutData; children: Snippet } = $props();
 
-	const { projectId, userService, fetchSignal, posthog, projectMetrics, tauri } = $derived(data);
+	const { projectId, userService, posthog, projectMetrics, tauri } = $derived(data);
 
 	const baseBranchService = getContext(BaseBranchService);
 	const repoInfoResponse = $derived(baseBranchService.repo(projectId));
@@ -114,23 +115,27 @@
 	const mode = $derived(modeService.mode);
 	const head = $derived(modeService.head);
 
-	// TODO: can we eliminate the need to debounce?
-	const fetch = $derived(fetchSignal.event);
-	const debouncedBaseBranchRefresh = debounce(async () => {
-		await baseBranchService.refreshBaseBranch(projectId);
-	}, 500);
-	$effect(() => {
-		if ($fetch || $head) debouncedBaseBranchRefresh();
-	});
+	const debouncedBaseBranchRefresh = debounce(
+		async () => await baseBranchService.refreshBaseBranch(projectId),
+		500
+	);
 
-	// TODO: can we eliminate the need to debounce?
 	const debouncedRemoteBranchRefresh = debounce(
 		async () => await branchService.refresh(projectId),
 		500
 	);
 
+	// TODO: Refactor `$head` into `.onHead()` as well.
+	const gitService = getContext(GitService);
+	$effect(() =>
+		gitService.onFetch(data.projectId, () => {
+			debouncedBaseBranchRefresh();
+			debouncedRemoteBranchRefresh();
+		})
+	);
+
 	$effect(() => {
-		if (baseBranch || $head || $fetch) debouncedRemoteBranchRefresh();
+		if (baseBranch || $head) debouncedRemoteBranchRefresh();
 	});
 
 	const gitlabConfigured = $derived(gitLabState.configured);

apps/desktop/src/routes/[projectId]/+layout.svelte

@@ -1,6 +1,4 @@
 import { GitBranchService } from '$lib/branches/gitBranch';
-import { FetchSignal } from '$lib/fetchSignal/fetchSignal.js';
-// import { UncommitedFilesWatcher } from '$lib/files/watcher';
 import { TemplateService } from '$lib/forge/templateService';
 import { HistoryService } from '$lib/history/history';
 import type { LayoutLoad } from './$types';
@@ -12,23 +10,15 @@ export const load: LayoutLoad = async ({ params, parent }) => {
 	const { projectMetrics } = await parent();
 
 	const projectId = params.projectId;
-
-	const fetchSignal = new FetchSignal(projectId);
-
 	const historyService = new HistoryService(projectId);
 	const templateService = new TemplateService(projectId);
-
 	const gitBranchService = new GitBranchService(projectId);
 
 	return {
 		templateService,
 		historyService,
 		projectId,
 		gitBranchService,
-		projectMetrics,
-		fetchSignal
-		// uncommitedFileWatcher,
-		// Cloud-related services
-		// syncedSnapshotService,
+		projectMetrics
 	};
 };