2 files changed, 15 insertions, 11 deletions
diff --git a/cmd/client/main.go b/cmd/client/main.go
index 244e543..a229632 100644
--- a/cmd/client/main.go
+++ b/cmd/client/main.go
@@ -4,6 +4,7 @@ import (
 	"flag"
 	"log"
 	"net"
+	"time"
 
 	"git.sr.ht/~rctt/solecd/core"
 )
@@ -18,16 +19,21 @@ func main() {
 
 	conn, err := d.Dial("tcp", serverAddr)
 	if err != nil {
-		log.Fatalf("cannot dial", err)
+		log.Fatal("cannot dial: ", err)
 	}
 	defer conn.Close()
 
-	for {
-		d, err := core.Read(conn)
-		if err != nil {
-			log.Fatalf("cannot read data: %v", err)
-		}
+	go ping(conn)
+	if err := core.Loop(conn); err != nil {
+		log.Fatal("event loop error ", err)
+	}
+}
 
-		log.Print(d)
+func ping(conn net.Conn) {
+	for {
+		log.Print("ping")
+		p := core.Ping{}
+		core.Send(conn, core.TypePing, p)
+		time.Sleep(time.Second)
 	}
 }
diff --git a/cmd/daemon/main.go b/cmd/daemon/main.go
index ad503c5..b344caf 100644
--- a/cmd/daemon/main.go
+++ b/cmd/daemon/main.go
@@ -45,9 +45,7 @@ func handle(conn net.Conn) {
 		return
 	}
 
-	test := core.Test{Message: "solec kujawski jest zajebisty"}
-	if err := core.Send(conn, core.TypeTest, test); err != nil {
-		log.Print("cannot send test message ", err)
-		return
+	if err := core.Loop(conn); err != nil {
+		log.Fatal("event loop error ", err)
 	}
 }