From 5f6845c3997bd5478a1f51a8f108b71afa427a72 Mon Sep 17 00:00:00 2001 From: Kyren223 Date: Mon, 21 Jul 2025 13:46:40 +0300 Subject: Added the ability to delete users --- internal/server/server.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'internal/server/server.go') diff --git a/internal/server/server.go b/internal/server/server.go index 48d7d38..15c3a7a 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -60,7 +60,7 @@ const ( RateLimitCountThresholdMalicious = 10 ) -func getTlsConfig() *tls.Config { +func getTLSConfig() *tls.Config { path, ok := os.LookupEnv(CertFile) if !ok { // DEV MODE ONLY, DUMMY CERT @@ -219,7 +219,7 @@ func (s *server) Node() *snowflake.Node { func (s *server) Run() { slog.Info("starting eko-server...") - listener, err := tls.Listen("tcp4", ":"+strconv.Itoa(int(s.Port)), getTlsConfig()) + listener, err := tls.Listen("tcp4", ":"+strconv.Itoa(int(s.Port)), getTLSConfig()) if err != nil { slog.Error("error starting server", "error", err) assert.Abort("see logs") @@ -286,7 +286,7 @@ func (server *server) handleConnection(conn net.Conn) { defer conn.Close() var writerWg sync.WaitGroup - done := make(chan struct{}) + writeDone := make(chan struct{}) framer := packet.NewFramer() sess := session.NewSession(server, addr, cancel, &writerWg) @@ -306,7 +306,7 @@ func (server *server) handleConnection(conn net.Conn) { // Writer go func() { - defer close(done) + defer close(writeDone) defer conn.Close() // To unblock reader writeQueue := sess.Read() @@ -406,7 +406,7 @@ func (server *server) handleConnection(conn net.Conn) { close(framer.Out) // stop processing slog.InfoContext(ctx, "reader done, closed framer") - <-done + <-writeDone } func processPacket(ctx context.Context, sess *session.Session, pkt packet.Packet) bool { -- cgit v1.3.1