Add sync_done handshake: server signals when ready, client waits before watching

1 files changed, 33 insertions, 0 deletions

diff --git a/cmd_windows.go b/cmd_windows.go
index f728182..f722b47 100644
--- a/cmd_windows.go
+++ b/cmd_windows.go
@@ -3,6 +3,7 @@
 package main
 
 import (
+	"bufio"
 	"context"
 	"flag"
 	"fmt"
@@ -92,6 +93,14 @@ func run() {
 			continue
 		}
 
+		logInfo("watcher: waiting for server to finish sync ...")
+
+		if err := waitForSyncDone(conn); err != nil {
+			logErrorf("wait for sync_done: %v", err)
+			conn.Close()
+			continue
+		}
+
 		logInfo("watcher: monitoring for changes ...")
 
 		// Heartbeat goroutine to detect disconnects
@@ -387,6 +396,30 @@ func sendEvent(conn net.Conn, evt FileEvent) error {
 	return err
 }
 
+func waitForSyncDone(conn net.Conn) error {
+	scanner := bufio.NewScanner(conn)
+	scanner.Buffer(make([]byte, 0, 1024*1024), 1024*1024)
+	conn.SetReadDeadline(time.Now().Add(10 * time.Minute)) // large repos can take a while
+	defer conn.SetReadDeadline(time.Time{})
+	for scanner.Scan() {
+		msg, err := DecodeMessage(scanner.Bytes())
+		if err != nil {
+			continue
+		}
+		switch msg.Type {
+		case "sync_done":
+			return nil
+		case "ping":
+			// respond to heartbeats during long sync
+			pong := &ProtocolMessage{Type: "pong"}
+			data, _ := EncodeMessage(pong)
+			data = append(data, '\n')
+			conn.Write(data)
+		}
+	}
+	return fmt.Errorf("connection closed before sync_done")
+}
+
 func addWatchersRecursively(watcher *fsnotify.Watcher, root string, stack *GitignoreStack) error {
 	var count, failCount, skippedCount int
 	bufBytes := *bufSizeKB * 1024