From d317e8f6df0e0e16445db606da1d683a6b35f531 Mon Sep 17 00:00:00 2001
From: Alexander Neonxp Kiryukhin <i@neonxp.ru>
Date: Tue, 30 Dec 2025 19:33:39 +0300
Subject: =?UTF-8?q?=D0=BD=D0=B0=D1=87=D0=B0=D0=BB=D1=8C=D0=BD=D1=8B=D0=B9?=
 =?UTF-8?q?=20=D0=BA=D0=BE=D0=BC=D0=BC=D0=B8=D1=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/server/client.go | 58 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 internal/server/client.go

(limited to 'internal/server/client.go')

diff --git a/internal/server/client.go b/internal/server/client.go
new file mode 100644
index 0000000..dbea5a9
--- /dev/null
+++ b/internal/server/client.go
@@ -0,0 +1,58 @@
+package server
+
+import (
+	"context"
+	"io"
+	"log/slog"
+
+	"go.neonxp.ru/qchat/internal/chat"
+	"golang.org/x/term"
+)
+
+func (s *Server) serveClient(ctx context.Context, rw io.ReadWriteCloser, user *chat.User) {
+	t := term.NewTerminal(rw, "[] ")
+
+	go func() {
+		// defer s.bus.Unsubscribe(evCh)
+		for {
+			select {
+			case <-ctx.Done():
+				return
+			default:
+			}
+			if user.CurrentChan != nil {
+				t.SetPrompt("[" + user.CurrentChan.Name + "] ")
+			}
+			line, err := t.ReadLine()
+			if err != nil {
+				s.chat.RemoveUser(user)
+
+				if err != io.EOF {
+					slog.Error("failed read line", slog.Any("err", err))
+				}
+
+				return
+			}
+			if len(line) == 0 {
+				continue
+			}
+
+			s.chat.Input(ctx, user, line)
+		}
+	}()
+
+	for message := range user.Events {
+		switch message := message.(type) {
+		case chat.Message:
+			displayMessage(t, message, user)
+		case chat.SelfMessage:
+			displaySelfMessage(t, message)
+		case chat.SystemMessage:
+			displaySystemMessage(t, message)
+		case chat.UserJoined:
+			displayUserJoined(t, message)
+		case chat.UserLeft:
+			displayUserLeft(t, message)
+		}
+	}
+}
-- 
cgit v1.2.3