From f750d5557dc04b7a85e0d0d5aee40cce285e568f Mon Sep 17 00:00:00 2001
From: Settel <settel@localhost>
Date: Thu, 29 Jul 2021 21:14:54 +0200
Subject: [PATCH] refactoring

---
 server/engine/engine.go |  4 ++--
 server/handler/sync.go  | 10 +++++-----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/server/engine/engine.go b/server/engine/engine.go
index d01ff82..1752a75 100644
--- a/server/engine/engine.go
+++ b/server/engine/engine.go
@@ -21,9 +21,9 @@ func NewEngine() *Engine {
 func (engine *Engine) Run() {
 	for {
 		value := engine.obs.Value().(handler.Value)
-		fmt.Printf("sleep: %d\n", value.Value)
+		fmt.Printf("sleep: %d\n", value.VersionRef)
 		time.Sleep(1 * time.Second)
-		value.Value++
+		value.VersionRef++
 		engine.obs.Update(value)
 	}
 }
diff --git a/server/handler/sync.go b/server/handler/sync.go
index 3b6af8d..78ea410 100644
--- a/server/handler/sync.go
+++ b/server/handler/sync.go
@@ -8,21 +8,21 @@ import (
 )
 
 type Value struct {
-	Value int
+	VersionRef int
 }
 
 func SyncFactory(obs observer.Property) HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		refId, err := strconv.Atoi(r.URL.Query().Get("ref"))
+		versionRef, err := strconv.Atoi(r.URL.Query().Get("v"))
 		if err != nil {
-			refId = -1
+			versionRef = -1
 		}
 
 		stream := obs.Observe()
 		var value Value
 		for {
 			value = stream.Value().(Value)
-			if value.Value > refId {
+			if value.VersionRef >= versionRef {
 				break
 			}
 
@@ -33,6 +33,6 @@ func SyncFactory(obs observer.Property) HandlerFunc {
 		}
 
 		w.Header().Add("Content-Type", "text/plain")
-		fmt.Fprintf(w, "%d (%d)\n", value.Value, refId)
+		fmt.Fprintf(w, "%d (%d)\n", value.VersionRef, versionRef)
 	}
 }