refactor: remove deprecated Go CLI and macOS GUI components

cli-go/README.md

@@ -1,33 +0,0 @@
-# Go CLI for LLM Backend
-
-This folder contains a cross-platform command line client written in Go. The CLI can be built as a single executable for Windows, Linux and macOS.
-
-## Features
-
-- Interactive colour-coded chat sessions
-- Upload documents to the API
-- List, read, write and delete files in the VM
-
-## Building
-
-Install Go 1.20 or later and run:
-
-```bash
-cd cli-go
-go build -o llmcli
-```
-
-For other platforms pass `GOOS` and `GOARCH` environment variables:
-
-```bash
-GOOS=windows GOARCH=amd64 go build -o llmcli.exe
-```
-
-## Usage
-
-```
-./llmcli --user yourname --server http://localhost:8000 chat
-```
-
-Use `--help` on any subcommand for details.
-

cli-go/cmd/cat.go

@@ -1,27 +0,0 @@
-package cmd
-
-import (
-	"context"
-	"fmt"
-
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newCatCmd() *cobra.Command {
-	return &cobra.Command{
-		Use:   "cat <path>",
-		Short: "Print a file from the VM",
-		Args:  cobra.ExactArgs(1),
-		RunE: func(cmd *cobra.Command, args []string) error {
-			c := client.New(server)
-			content, err := c.ReadFile(context.Background(), user, args[0])
-			if err != nil {
-				return err
-			}
-			fmt.Print(content)
-			return nil
-		},
-	}
-}

cli-go/cmd/chat.go

@@ -1,83 +0,0 @@
-package cmd
-
-import (
-	"bufio"
-	"fmt"
-	"os"
-	"strconv"
-
-	"github.com/fatih/color"
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newChatCmd() *cobra.Command {
-	cmd := &cobra.Command{
-		Use:   "chat",
-		Short: "Start an interactive chat session",
-		RunE:  runChat,
-	}
-	return cmd
-}
-
-func runChat(cmd *cobra.Command, args []string) error {
-	ctx := cmd.Context()
-	c := client.New(server)
-
-	sessions, err := c.ListSessions(ctx, user)
-	if err != nil {
-		return err
-	}
-
-	session := "default"
-	if len(sessions) > 0 {
-		fmt.Println("Existing sessions:")
-		for i, s := range sessions {
-			fmt.Printf("  %d. %s\n", i+1, s)
-		}
-		fmt.Printf("Select session number or enter new name [%d]: ", len(sessions))
-		var choice string
-		fmt.Scanln(&choice)
-		if n, err := strconv.Atoi(choice); err == nil && n >= 1 && n <= len(sessions) {
-			session = sessions[n-1]
-		} else if choice != "" {
-			session = choice
-		}
-	}
-
-	cyan := color.New(color.FgCyan).SprintFunc()
-	green := color.New(color.FgGreen).SprintFunc()
-	yellow := color.New(color.FgYellow).SprintFunc()
-
-	fmt.Printf("Chatting as %s in session '%s'\n", green(user), session)
-
-	scanner := bufio.NewScanner(os.Stdin)
-	for {
-		fmt.Printf("%s> ", cyan("You"))
-		if !scanner.Scan() {
-			break
-		}
-		line := scanner.Text()
-		if line == "exit" || line == "quit" {
-			break
-		}
-		stream, err := c.ChatStream(ctx, user, session, line)
-		if err != nil {
-			fmt.Println("error:", err)
-			continue
-		}
-		r := bufio.NewReader(stream)
-		for {
-			part, err := r.ReadString('\n')
-			if len(part) > 0 {
-				fmt.Print(yellow(part))
-			}
-			if err != nil {
-				break
-			}
-		}
-		stream.Close()
-	}
-	return nil
-}

cli-go/cmd/ls.go

@@ -1,37 +0,0 @@
-package cmd
-
-import (
-	"context"
-	"fmt"
-
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newLsCmd() *cobra.Command {
-	return &cobra.Command{
-		Use:   "ls [path]",
-		Short: "List directory contents in the VM",
-		Args:  cobra.MaximumNArgs(1),
-		RunE: func(cmd *cobra.Command, args []string) error {
-			path := "/data"
-			if len(args) == 1 {
-				path = args[0]
-			}
-			c := client.New(server)
-			entries, err := c.ListDir(context.Background(), user, path)
-			if err != nil {
-				return err
-			}
-			for _, e := range entries {
-				if e.IsDir {
-					fmt.Println(e.Name + "/")
-				} else {
-					fmt.Println(e.Name)
-				}
-			}
-			return nil
-		},
-	}
-}

cli-go/cmd/rm.go

@@ -1,21 +0,0 @@
-package cmd
-
-import (
-	"context"
-
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newRmCmd() *cobra.Command {
-	return &cobra.Command{
-		Use:   "rm <path>",
-		Short: "Remove a file or directory in the VM",
-		Args:  cobra.ExactArgs(1),
-		RunE: func(cmd *cobra.Command, args []string) error {
-			c := client.New(server)
-			return c.DeleteFile(context.Background(), user, args[0])
-		},
-	}
-}

cli-go/cmd/root.go

@@ -1,39 +0,0 @@
-package cmd
-
-import (
-	"fmt"
-	"os"
-
-	"github.com/spf13/cobra"
-)
-
-var (
-	server string
-	user   string
-)
-
-func NewRootCmd() *cobra.Command {
-	cmd := &cobra.Command{
-		Use:   "llmcli",
-		Short: "CLI client for the LLM backend",
-	}
-
-	cmd.PersistentFlags().StringVarP(&server, "server", "s", "http://localhost:8000", "API server URL")
-	cmd.PersistentFlags().StringVarP(&user, "user", "u", "default", "User name")
-
-	cmd.AddCommand(newChatCmd())
-	cmd.AddCommand(newUploadCmd())
-	cmd.AddCommand(newLsCmd())
-	cmd.AddCommand(newCatCmd())
-	cmd.AddCommand(newWriteCmd())
-	cmd.AddCommand(newRmCmd())
-
-	return cmd
-}
-
-func Execute() {
-	if err := NewRootCmd().Execute(); err != nil {
-		fmt.Fprintln(os.Stderr, err)
-		os.Exit(1)
-	}
-}

cli-go/cmd/upload.go

@@ -1,28 +0,0 @@
-package cmd
-
-import (
-	"context"
-	"fmt"
-
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newUploadCmd() *cobra.Command {
-	return &cobra.Command{
-		Use:   "upload [file]",
-		Short: "Upload a document to the VM",
-		Args:  cobra.ExactArgs(1),
-		RunE: func(cmd *cobra.Command, args []string) error {
-			ctx := context.Background()
-			c := client.New(server)
-			path, err := c.UploadDocument(ctx, user, "default", args[0])
-			if err != nil {
-				return err
-			}
-			fmt.Println("Uploaded to", path)
-			return nil
-		},
-	}
-}

cli-go/cmd/write.go

@@ -1,26 +0,0 @@
-package cmd
-
-import (
-	"context"
-	"os"
-
-	"github.com/spf13/cobra"
-
-	"llm-cli/internal/client"
-)
-
-func newWriteCmd() *cobra.Command {
-	return &cobra.Command{
-		Use:   "write <path> <file>",
-		Short: "Write a local file to a path in the VM",
-		Args:  cobra.ExactArgs(2),
-		RunE: func(cmd *cobra.Command, args []string) error {
-			data, err := os.ReadFile(args[1])
-			if err != nil {
-				return err
-			}
-			c := client.New(server)
-			return c.WriteFile(context.Background(), user, args[0], string(data))
-		},
-	}
-}

cli-go/go.mod

@@ -1,16 +0,0 @@
-module llm-cli
-
-go 1.23.8
-
-require (
-	github.com/fatih/color v1.16.0
-	github.com/spf13/cobra v1.7.0
-)
-
-require (
-	github.com/inconshreveable/mousetrap v1.1.0 // indirect
-	github.com/mattn/go-colorable v0.1.13 // indirect
-	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/spf13/pflag v1.0.5 // indirect
-	golang.org/x/sys v0.14.0 // indirect
-)

cli-go/go.sum

@@ -1,21 +0,0 @@
-github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
-github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM=
-github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE=
-github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
-github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
-github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
-github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
-github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
-github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
-github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
-github.com/spf13/cobra v1.7.0 h1:hyqWnYt1ZQShIddO5kBpj3vu05/++x6tJ6dg8EC572I=
-github.com/spf13/cobra v1.7.0/go.mod h1:uLxZILRyS/50WlhOIKD7W6V5bgeIt+4sICxh6uRMrb0=
-github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
-github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
-golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q=
-golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

cli-go/internal/client/client.go

@@ -1,218 +0,0 @@
-package client
-
-import (
-	"bytes"
-	"context"
-	"encoding/json"
-	"fmt"
-	"io"
-	"mime/multipart"
-	"net/http"
-	"os"
-	"path/filepath"
-	"time"
-)
-
-type Client struct {
-	baseURL    string
-	httpClient *http.Client
-}
-
-func New(baseURL string) *Client {
-	return &Client{
-		baseURL:    baseURL,
-		httpClient: &http.Client{Timeout: 30 * time.Second},
-	}
-}
-
-type SessionInfo struct {
-	Sessions []string `json:"sessions"`
-}
-
-func (c *Client) ListSessions(ctx context.Context, user string) ([]string, error) {
-	req, err := http.NewRequestWithContext(ctx, http.MethodGet,
-		fmt.Sprintf("%s/sessions/%s", c.baseURL, user), nil)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		return nil, fmt.Errorf("list sessions failed: %s", resp.Status)
-	}
-	var data SessionInfo
-	if err := json.NewDecoder(resp.Body).Decode(&data); err != nil {
-		return nil, err
-	}
-	return data.Sessions, nil
-}
-
-type ChatRequest struct {
-	User    string `json:"user"`
-	Session string `json:"session"`
-	Prompt  string `json:"prompt"`
-}
-
-func (c *Client) ChatStream(ctx context.Context, user, session, prompt string) (io.ReadCloser, error) {
-	body, err := json.Marshal(ChatRequest{User: user, Session: session, Prompt: prompt})
-	if err != nil {
-		return nil, err
-	}
-	req, err := http.NewRequestWithContext(ctx, http.MethodPost, c.baseURL+"/chat/stream", bytes.NewReader(body))
-	if err != nil {
-		return nil, err
-	}
-	req.Header.Set("Content-Type", "application/json")
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	if resp.StatusCode != http.StatusOK {
-		defer resp.Body.Close()
-		b, _ := io.ReadAll(resp.Body)
-		return nil, fmt.Errorf("chat failed: %s - %s", resp.Status, string(b))
-	}
-	return resp.Body, nil
-}
-
-type UploadResp struct {
-	Path string `json:"path"`
-}
-
-func (c *Client) UploadDocument(ctx context.Context, user, session, path string) (string, error) {
-	file, err := os.Open(path)
-	if err != nil {
-		return "", err
-	}
-	defer file.Close()
-
-	buf := &bytes.Buffer{}
-	writer := multipart.NewWriter(buf)
-	_ = writer.WriteField("user", user)
-	_ = writer.WriteField("session", session)
-	fw, err := writer.CreateFormFile("file", filepath.Base(path))
-	if err != nil {
-		return "", err
-	}
-	if _, err = io.Copy(fw, file); err != nil {
-		return "", err
-	}
-	writer.Close()
-
-	req, err := http.NewRequestWithContext(ctx, http.MethodPost, c.baseURL+"/upload", buf)
-	if err != nil {
-		return "", err
-	}
-	req.Header.Set("Content-Type", writer.FormDataContentType())
-
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return "", err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		b, _ := io.ReadAll(resp.Body)
-		return "", fmt.Errorf("upload failed: %s - %s", resp.Status, string(b))
-	}
-	var out UploadResp
-	if err := json.NewDecoder(resp.Body).Decode(&out); err != nil {
-		return "", err
-	}
-	return out.Path, nil
-}
-
-type DirEntry struct {
-	Name  string `json:"name"`
-	IsDir bool   `json:"is_dir"`
-}
-
-type DirList struct {
-	Entries []DirEntry `json:"entries"`
-}
-
-func (c *Client) ListDir(ctx context.Context, user, path string) ([]DirEntry, error) {
-	req, err := http.NewRequestWithContext(ctx, http.MethodGet,
-		fmt.Sprintf("%s/vm/%s/list?path=%s", c.baseURL, user, path), nil)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		return nil, fmt.Errorf("list dir failed: %s", resp.Status)
-	}
-	var out DirList
-	if err := json.NewDecoder(resp.Body).Decode(&out); err != nil {
-		return nil, err
-	}
-	return out.Entries, nil
-}
-
-type FileContent struct {
-	Content string `json:"content"`
-}
-
-func (c *Client) ReadFile(ctx context.Context, user, path string) (string, error) {
-	req, err := http.NewRequestWithContext(ctx, http.MethodGet,
-		fmt.Sprintf("%s/vm/%s/file?path=%s", c.baseURL, user, path), nil)
-	if err != nil {
-		return "", err
-	}
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return "", err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		return "", fmt.Errorf("read file failed: %s", resp.Status)
-	}
-	var out FileContent
-	if err := json.NewDecoder(resp.Body).Decode(&out); err != nil {
-		return "", err
-	}
-	return out.Content, nil
-}
-
-func (c *Client) WriteFile(ctx context.Context, user, path, content string) error {
-	data, _ := json.Marshal(map[string]string{"path": path, "content": content})
-	req, err := http.NewRequestWithContext(ctx, http.MethodPost,
-		fmt.Sprintf("%s/vm/%s/file", c.baseURL, user), bytes.NewReader(data))
-	if err != nil {
-		return err
-	}
-	req.Header.Set("Content-Type", "application/json")
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		b, _ := io.ReadAll(resp.Body)
-		return fmt.Errorf("write file failed: %s - %s", resp.Status, string(b))
-	}
-	return nil
-}
-
-func (c *Client) DeleteFile(ctx context.Context, user, path string) error {
-	req, err := http.NewRequestWithContext(ctx, http.MethodDelete,
-		fmt.Sprintf("%s/vm/%s/file?path=%s", c.baseURL, user, path), nil)
-	if err != nil {
-		return err
-	}
-	resp, err := c.httpClient.Do(req)
-	if err != nil {
-		return err
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode != http.StatusOK {
-		b, _ := io.ReadAll(resp.Body)
-		return fmt.Errorf("delete file failed: %s - %s", resp.Status, string(b))
-	}
-	return nil
-}

cli-go/main.go

@@ -1,7 +0,0 @@
-package main
-
-import "llm-cli/cmd"
-
-func main() {
-	cmd.Execute()
-}

mac_gui/__main__.py

@@ -1,4 +0,0 @@
-from .app import main
-
-if __name__ == "__main__":
-    main()

mac_gui/api_client.py

@@ -1,70 +0,0 @@
-from __future__ import annotations
-
-import os
-from typing import Iterator, List, Dict, Any
-
-import httpx
-
-
-class APIClient:
-    """Simple client for the LLM backend API."""
-
-    def __init__(self, server: str = "http://localhost:8000", api_key: str | None = None) -> None:
-        self._server = server.rstrip("/")
-        self._headers = {"X-API-Key": api_key} if api_key else {}
-
-    # ------------------------------------------------------------------
-    # Helper methods
-    # ------------------------------------------------------------------
-    def _url(self, path: str) -> str:
-        return f"{self._server}{path}"
-
-    # ------------------------------------------------------------------
-    # Public API methods
-    # ------------------------------------------------------------------
-    def list_sessions(self, user: str) -> List[str]:
-        resp = httpx.get(self._url(f"/sessions/{user}"), headers=self._headers)
-        resp.raise_for_status()
-        data = resp.json()
-        return data.get("sessions", [])
-
-    def stream_chat(self, user: str, session: str, prompt: str) -> Iterator[str]:
-        with httpx.stream(
-            "POST",
-            self._url("/chat/stream"),
-            json={"user": user, "session": session, "prompt": prompt},
-            headers=self._headers,
-            timeout=None,
-        ) as resp:
-            resp.raise_for_status()
-            for line in resp.iter_lines():
-                if line:
-                    yield line.decode()
-
-    def upload_document(self, user: str, session: str, path: str) -> str:
-        name = os.path.basename(path)
-        with open(path, "rb") as f:
-            files = {"file": (name, f)}
-            data = {"user": user, "session": session}
-            resp = httpx.post(self._url("/upload"), data=data, files=files, headers=self._headers)
-        resp.raise_for_status()
-        return resp.json()["path"]
-
-    def list_vm_dir(self, user: str, path: str = "/data") -> List[Dict[str, Any]]:
-        resp = httpx.get(self._url(f"/vm/{user}/list"), params={"path": path}, headers=self._headers)
-        resp.raise_for_status()
-        return resp.json().get("entries", [])
-
-    def read_vm_file(self, user: str, path: str) -> str:
-        resp = httpx.get(self._url(f"/vm/{user}/file"), params={"path": path}, headers=self._headers)
-        resp.raise_for_status()
-        return resp.json().get("content", "")
-
-    def write_vm_file(self, user: str, path: str, content: str) -> None:
-        payload = {"path": path, "content": content}
-        resp = httpx.post(self._url(f"/vm/{user}/file"), json=payload, headers=self._headers)
-        resp.raise_for_status()
-
-    def delete_vm_file(self, user: str, path: str) -> None:
-        resp = httpx.delete(self._url(f"/vm/{user}/file"), params={"path": path}, headers=self._headers)
-        resp.raise_for_status()

mac_gui/app.py

@@ -1,144 +0,0 @@
-from __future__ import annotations
-
-import threading
-import queue
-from pathlib import Path
-from tkinter import (
-    Tk,
-    Text,
-    Entry,
-    Button,
-    Scrollbar,
-    Frame,
-    Label,
-    StringVar,
-    END,
-    filedialog,
-)
-
-from .api_client import APIClient
-
-
-class ChatApp:
-    """Tkinter GUI for interacting with the LLM backend."""
-
-    def __init__(self, root: Tk) -> None:
-        self.root = root
-        self.root.title("LLM Backend Chat")
-
-        self.server_var = StringVar(value="http://localhost:8000")
-        self.api_key_var = StringVar(value="")
-        self.user_var = StringVar(value="default")
-        self.session_var = StringVar(value="default")
-
-        self._client = APIClient()
-        self._queue: queue.Queue[tuple[str, str]] = queue.Queue()
-
-        self._build_ui()
-        self.root.after(100, self._process_queue)
-
-    # ------------------------------------------------------------------
-    # UI construction
-    # ------------------------------------------------------------------
-    def _build_ui(self) -> None:
-        top = Frame(self.root)
-        top.pack(fill="x")
-
-        Label(top, text="Server:").grid(row=0, column=0, sticky="w")
-        Entry(top, textvariable=self.server_var, width=30).grid(row=0, column=1, sticky="ew")
-
-        Label(top, text="API Key:").grid(row=0, column=2, sticky="w")
-        Entry(top, textvariable=self.api_key_var, width=20).grid(row=0, column=3, sticky="ew")
-
-        Label(top, text="User:").grid(row=1, column=0, sticky="w")
-        Entry(top, textvariable=self.user_var, width=15).grid(row=1, column=1, sticky="ew")
-
-        Label(top, text="Session:").grid(row=1, column=2, sticky="w")
-        Entry(top, textvariable=self.session_var, width=15).grid(row=1, column=3, sticky="ew")
-
-        self.chat_display = Text(self.root, wrap="word", height=20)
-        self.chat_display.pack(fill="both", expand=True)
-
-        scroll = Scrollbar(self.chat_display)
-        scroll.pack(side="right", fill="y")
-        self.chat_display.config(yscrollcommand=scroll.set)
-        scroll.config(command=self.chat_display.yview)
-
-        bottom = Frame(self.root)
-        bottom.pack(fill="x")
-
-        self.msg_entry = Entry(bottom)
-        self.msg_entry.pack(side="left", fill="x", expand=True)
-        self.msg_entry.bind("<Return>", lambda _: self.send_message())
-
-        Button(bottom, text="Send", command=self.send_message).pack(side="left")
-        Button(bottom, text="Upload", command=self.upload_file).pack(side="left")
-
-    # ------------------------------------------------------------------
-    # Event handlers
-    # ------------------------------------------------------------------
-    def _update_client(self) -> None:
-        self._client = APIClient(self.server_var.get(), self.api_key_var.get() or None)
-
-    def send_message(self) -> None:
-        prompt = self.msg_entry.get().strip()
-        if not prompt:
-            return
-        self.msg_entry.delete(0, END)
-        self.chat_display.insert(END, f"You: {prompt}\n")
-        self.chat_display.see(END)
-        self._update_client()
-        thread = threading.Thread(target=self._stream_prompt, args=(prompt,), daemon=True)
-        thread.start()
-
-    def _stream_prompt(self, prompt: str) -> None:
-        try:
-            for part in self._client.stream_chat(
-                self.user_var.get(), self.session_var.get(), prompt
-            ):
-                self._queue.put(("assistant", part))
-        except Exception as exc:  # pragma: no cover - runtime errors
-            self._queue.put(("error", str(exc)))
-
-    def upload_file(self) -> None:
-        path = filedialog.askopenfilename()
-        if path:
-            self._update_client()
-            thread = threading.Thread(target=self._upload_file, args=(Path(path),), daemon=True)
-            thread.start()
-
-    def _upload_file(self, path: Path) -> None:
-        try:
-            vm_path = self._client.upload_document(
-                self.user_var.get(), self.session_var.get(), str(path)
-            )
-            self._queue.put(("info", f"Uploaded {path.name} -> {vm_path}"))
-        except Exception as exc:  # pragma: no cover - runtime errors
-            self._queue.put(("error", str(exc)))
-
-    # ------------------------------------------------------------------
-    # Queue processing
-    # ------------------------------------------------------------------
-    def _process_queue(self) -> None:
-        while True:
-            try:
-                kind, msg = self._queue.get_nowait()
-            except queue.Empty:
-                break
-            if kind == "assistant":
-                self.chat_display.insert(END, msg)
-            else:
-                prefix = "INFO" if kind == "info" else "ERROR"
-                self.chat_display.insert(END, f"[{prefix}] {msg}\n")
-            self.chat_display.see(END)
-        self.root.after(100, self._process_queue)
-
-
-def main() -> None:
-    root = Tk()
-    ChatApp(root)
-    root.mainloop()
-
-
-if __name__ == "__main__":  # pragma: no cover - manual execution
-    main()

src/cli.py

@@ -1,83 +0,0 @@
-from __future__ import annotations
-
-import asyncio
-from typing import AsyncIterator
-
-import httpx
-import typer
-from colorama import Fore, Style, init
-
-
-API_URL = "http://localhost:8000"
-
-app = typer.Typer(add_completion=False, help="Interact with the LLM backend API")
-
-
-async def _get_sessions(user: str, server: str) -> list[str]:
-    async with httpx.AsyncClient(base_url=server) as client:
-        resp = await client.get(f"/sessions/{user}")
-        resp.raise_for_status()
-        data = resp.json()
-        return data.get("sessions", [])
-
-
-async def _stream_chat(
-    user: str, session: str, prompt: str, server: str
-) -> AsyncIterator[str]:
-    async with httpx.AsyncClient(base_url=server, timeout=None) as client:
-        async with client.stream(
-            "POST",
-            "/chat/stream",
-            json={"user": user, "session": session, "prompt": prompt},
-        ) as resp:
-            resp.raise_for_status()
-            async for line in resp.aiter_lines():
-                if line:
-                    yield line
-
-
-async def _chat_loop(user: str, server: str) -> None:
-    init(autoreset=True)
-    sessions = await _get_sessions(user, server)
-    session = "default"
-    if sessions:
-        typer.echo("Existing sessions:")
-        for idx, name in enumerate(sessions, 1):
-            typer.echo(f"  {idx}. {name}")
-        choice = typer.prompt(
-            "Select session number or enter new name", default=str(len(sessions))
-        )
-        if choice.isdigit() and 1 <= int(choice) <= len(sessions):
-            session = sessions[int(choice) - 1]
-        else:
-            session = choice.strip() or session
-    else:
-        session = typer.prompt("Session name", default=session)
-
-    typer.echo(
-        f"Chatting as {Fore.GREEN}{user}{Style.RESET_ALL} in session '{session}'"
-    )
-
-    while True:
-        try:
-            msg = typer.prompt(f"{Fore.CYAN}You{Style.RESET_ALL}")
-        except EOFError:
-            break
-        if msg.strip().lower() in {"exit", "quit"}:
-            break
-        async for part in _stream_chat(user, session, msg, server):
-            typer.echo(f"{Fore.YELLOW}{part}{Style.RESET_ALL}")
-
-
-@app.callback(invoke_without_command=True)
-def main(
-    user: str = typer.Option("default", "--user", "-u"),
-    server: str = typer.Option(API_URL, "--server", "-s"),
-) -> None:
-    """Start an interactive chat session."""
-
-    asyncio.run(_chat_loop(user, server))
-
-
-if __name__ == "__main__":  # pragma: no cover - manual execution
-    app()