add version to client and daemon

1 files changed, 8 insertions, 5 deletions

diff --git a/pkg/server/server.go b/pkg/server/server.go
index 43cd542..524b6af 100644
--- a/pkg/server/server.go
+++ b/pkg/server/server.go
@@ -18,6 +18,8 @@ type Server struct {
 	listen net.Listener
 	since  time.Time
 
+	version string
+
 	wg sync.WaitGroup
 	mu sync.Mutex
 
@@ -97,7 +99,7 @@ func (s *Server) isDone() bool {
 	}
 }
 
-func New(path string) (*Server, error) {
+func New(path string, version string) (*Server, error) {
 	listen, err := net.Listen("unix", path)
 	if err != nil {
 		return nil, err
@@ -111,6 +113,7 @@ func New(path string) (*Server, error) {
 		since:   time.Now(),
 		done:    make(chan struct{}),
 		tunnels: make(automap),
+		version: version,
 	}
 
 	return s, nil
@@ -142,7 +145,7 @@ func (s *Server) Serve() {
 
 		s.wg.Add(1)
 
-		go c.handle()
+		go c.reader()
 	}
 
 	s.wg.Wait()
@@ -196,14 +199,14 @@ func (c *client) newRequest() *request {
 	return r
 }
 
-func (c *client) handle() {
+func (c *client) reader() {
 	defer c.close()
 
 	for {
 		req, er := c.r.Decode()
 		if er != nil {
 			if !errors.Is(er, io.EOF) {
-				log.Println(c, "handle:", er)
+				log.Println(c, "reader:", er)
 			}
 			break
 		}
@@ -220,7 +223,7 @@ func (c *client) handle() {
 
 		ew := c.w.Encode(r.out.String())
 		if ew != nil {
-			log.Println(c, "handle:", ew)
+			log.Println(c, "reader:", ew)
 			break
 		}
 	}