2024-09-30 17:59:15

protocol/etch/engine.go

@@ -20,7 +20,31 @@ func (s *Server) Run() error {
 		if err != nil {
 			break
 		}
-		log.Println(addr, buf[:n])
+		log.Println(addr, string(buf[:n]))
 	}
 	return nil
 }
+
+func NewServer(listen string) *Server {
+	return &Server{
+		Listen: listen,
+	}
+}
+
+type Client struct {
+	Server string
+}
+
+func (s *Client) Run() {
+	addr := doa.Try(net.ResolveUDPAddr("udp", s.Server))
+	conn := doa.Try(net.DialUDP("udp", nil, addr))
+	for range 32 {
+		doa.Try(conn.Write([]byte("Hello World!")))
+	}
+}
+
+func NewClient(server string) *Client {
+	return &Client{
+		Server: server,
+	}
+}

protocol/etch/engine_test.go

@@ -0,0 +1,20 @@
+package etch
+
+import (
+	"testing"
+	"time"
+)
+
+const (
+	DazeServerListenOn = "127.0.0.1:28081"
+)
+
+func TestProtocolEtch(t *testing.T) {
+	server := NewServer(DazeServerListenOn)
+	go server.Run()
+	time.Sleep(time.Second)
+
+	client := NewClient(DazeServerListenOn)
+	client.Run()
+	time.Sleep(time.Second)
+}