Merge pull request #15 from sqlrsync/v0.0.5

v0.0.5 release

Author: pnwmatt

client/go.sum

@@ -5,8 +5,6 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/fatih/color v1.18.0 h1:S8gINlzdQ840/4pfAwic/ZE0djQEH3wM94VfqLTZcOM=
 github.com/fatih/color v1.18.0/go.mod h1:4FelSpRwEGDpQ12mAdzqdOukCy4u8WUtOY6lkT/6HfU=
-github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=
-github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=

client/remote/client.go

@@ -405,6 +405,7 @@ type Config struct {
 	AuthKey                 string
 	ClientVersion           string // version of the client software
 	SendKeyRequest          bool   // the -sqlrsync file doesn't exist, so make a key
+	AuthToken               string
 
 	SendConfigCmd     bool // we don't have the version number or remote path
 	LocalHostname     string
@@ -702,6 +703,14 @@ func (c *Client) Connect() error {
 		c.logger.Fatal("No wsID provided for X-ClientID header")
 	}
 
+	headers.Set("X-ClientVersion", c.config.ClientVersion)
+
+	if c.config.WsID != "" {
+		headers.Set("X-ClientID", c.config.WsID)
+	} else {
+		c.logger.Fatal("No wsID provided for X-ClientID header")
+	}
+
 	if c.config.LocalHostname != "" {
 		headers.Set("X-LocalHostname", c.config.LocalHostname)
 	}

client/sync/coordinator.go

@@ -831,7 +831,7 @@ func (c *Coordinator) executePushSubscribe() error {
 	} else {
 		defer c.subManager.Close()
 		fmt.Println("✅ Subscribed to remote updates - will pull new versions automatically")
-		
+
 		// Start goroutine to handle pull notifications
 		go c.handlePullNotifications()
 	}
@@ -1212,7 +1212,7 @@ func (c *Coordinator) sendMergeConflictNotification(serverURL, replicaName, vers
 // handlePullNotifications runs in a goroutine to listen for remote updates and pull them
 func (c *Coordinator) handlePullNotifications() {
 	c.logger.Info("Starting pull notification handler")
-	
+
 	for {
 		select {
 		case <-c.ctx.Done():
@@ -1283,7 +1283,7 @@ func (c *Coordinator) waitForVersionAndPull(isBackground bool) error {
 	} else {
 		fmt.Printf("🔄 New version %s announced at %s!\n", version, time.Now().Format(time.RFC3339))
 	}
-	
+
 	// Update version for the pull
 	oldVersion := c.config.Version
 	if version != "latest" {
@@ -1300,7 +1300,7 @@ func (c *Coordinator) waitForVersionAndPull(isBackground bool) error {
 		}
 		return err
 	}
-	
+
 	if isBackground {
 		fmt.Printf("✅ Successfully pulled version %s at %s\n", version, time.Now().Format(time.RFC3339))
 	}