summaryrefslogtreecommitdiff
path: root/internal/tcpserver.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2023-05-19 01:26:18 +0300
committerPaul Buetow <paul@buetow.org>2023-05-19 01:26:18 +0300
commit5dc583de26cc7fc9816ce6b44ca4e80e723b8311 (patch)
tree079a564ad847a27217c237fefca791f5094b6588 /internal/tcpserver.go
parentf03889b92628d1589d2e161c56510646398686a1 (diff)
add vote test
Diffstat (limited to 'internal/tcpserver.go')
-rw-r--r--internal/tcpserver.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/internal/tcpserver.go b/internal/tcpserver.go
index a7153f8..b689419 100644
--- a/internal/tcpserver.go
+++ b/internal/tcpserver.go
@@ -6,7 +6,6 @@ import (
"fmt"
"log"
"net"
- "time"
)
func startTcpServer(ctx context.Context, config config, ch chan<- vote) error {
@@ -54,7 +53,7 @@ func handleConnection(ctx context.Context, conn net.Conn, ch chan<- vote) {
}
log.Printf("Received message from %s: %s", remoteAddr, message)
- ch <- vote{From: remoteAddr, time: time.Now()}
+ ch <- newVote(remoteAddr, message)
conn.Write([]byte(message))
}