Backend/app chat logic

.env.example

@@ -1,6 +1,5 @@
-# KittyProtocol Hub address conf - adjust to situtation (given addres is private vm on Azure)
-# 20.82.139.232:9999
+# -----------------------------
+# KittyProtocol configuration
+# -----------------------------
 KITTY_HUB_ADDR=127.0.0.1:9999
-
-# KittyProtocol Intercept address conf - adjust to situtation (better not to change)
-KITTY_INTERCEPT_ADDR=0.0.0.0:9999
+KITTY_INTERCEPT_ADDR=0.0.0.0:9999

.github/workflows/ci.yml

@@ -0,0 +1,70 @@
+name: CI
+
+on:
+  push:
+    branches: [ main, backend/app-chat-logic ]
+  pull_request:
+    branches: [ main, backend/app-chat-logic ]
+
+jobs:
+  lint:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '1.22'
+          cache: true
+          cache-dependency-path: go.sum
+
+      - name: Go build cache
+        uses: actions/cache@v4
+        with:
+          path: |
+            ~/.cache/go-build
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
+
+      - name: Run golangci-lint
+        uses: golangci/golangci-lint-action@v7
+        with:
+          version: latest
+          args: --timeout=5m
+
+  test-and-build:
+    runs-on: ubuntu-latest
+    needs: [ lint ]
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '1.22'
+          cache: true
+          cache-dependency-path: go.sum
+
+      - name: Go build cache
+        uses: actions/cache@v4
+        with:
+          path: |
+            ~/.cache/go-build
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
+
+      - name: Download modules
+        run: go mod download
+
+      - name: Run tests
+        run: go test ./... -race -coverprofile=coverage.out -covermode=atomic
+
+      - name: Build hub
+        run: go build -v -o bin/kitty-hub ./cmd/hub
+
+      - name: Build client
+        run: go build -v -o bin/kitty-client ./cmd/client
+
+      - name: Upload binaries
+        uses: actions/upload-artifact@v4
+        with:
+          name: kitty-binaries
+          path: bin/

.github/workflows/release.yml

@@ -0,0 +1,41 @@
+name: Release
+
+on:
+  push:
+    tags:
+      - 'v*.*.*'
+
+jobs:
+  build-and-release:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '1.22'
+          cache: true
+          cache-dependency-path: go.sum
+
+      - name: Go build cache
+        uses: actions/cache@v4
+        with:
+          path: |
+            ~/.cache/go-build
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
+
+      - name: Build hub
+        run: go build -v -o bin/kitty-hub ./cmd/hub
+
+      - name: Build client
+        run: go build -v -o bin/kitty-client ./cmd/client
+
+      - name: Create GitHub Release
+        uses: softprops/action-gh-release@v2
+        with:
+          files: |
+            bin/kitty-hub
+            bin/kitty-client
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -2,4 +2,9 @@
 
 .env
 
-.structure.txt
+.structure.txt
+
+bin/
+
+cover.out
+coverage.out

README.md

@@ -2,7 +2,7 @@
 
  # Kitty Protocol
 
-![image](kitty_logo.png)
+![image](resources/img/kitty_logo.png)
 
  ## Project Overview
 
@@ -16,7 +16,7 @@
  * **`Attack Resistance`**: Native support for TLS 1.3 and mechanisms preventing Man‑in‑the‑Middle (MitM) and Replay attacks.
 
  ### Documentation:
- Full protocol documentation is available here: [KittyProtocol.pdf](documentation/KittyProtocol-EN.pdf)
+ Full protocol documentation is available here: [KittyProtocol.pdf](docs/KittyProtocol-EN.pdf)
 
  ---
  Authors: 

README.pl.md

@@ -2,7 +2,7 @@
 
  # Kitty Protocol
 
-![image](kitty_logo.png)
+![image](resources/img/kitty_logo.png)
 
  ## Opis projektu
 
@@ -15,7 +15,7 @@
  * **`Odporność na ataki`**: Natywne wsparcie dla TLS 1.3 oraz mechanizmy zapobiegające atakom typu Man-in-the-Middle (MitM) i Replay.
 
  ### Dokumentacja:
- Szczegółowa dokumentacja protokołu znajduje się w dokumencie: [KittyProtocol.pdf](documentation/KittyProtocol.pdf)
+ Szczegółowa dokumentacja protokołu znajduje się w dokumencie: [KittyProtocol.pdf](docs/KittyProtocol.pdf)
 
  ---
  Authors: 

TODO

@@ -1,9 +1,64 @@
-- nawiązanie połączenia pomiędzy użytkownikami już jest po stronie aplikacji !!
 - przy prezentowaniu gotowego projektu można pokazać że na warstwie protokołu działa operacja /replay która symuluje ten atak
-- TESTY DO NOWEGO CRYPTOEE_TEST
-- TESTY OGÓLNIE
-- ŁADOWANIE KLUCZY KONWERSACJI Z PLIKU!
-- merge
-- rozwiązanie problemu z 3 rozmówcami podającymi ten sam sekret - status busy + pojedynczy czat naraz - logika aplikacyjna
-- brak mockowania!! zrobic w końcu normalne połączenie z bazą danych i tam przechowywanie, a nie tak jak teraz `internal/auth/auth.go`
-- jeżeli ramka PROTOKOŁU pełni obecnie więcej niż jedną funkcję logiczną (jak np. w przypadku operacji /quit i GET_STATUS) to gdy zaimpplementuje się logikę aplikacji to zmienić koniecznie 
+
+
+- info dodatkowe:
+    jak nie ma usera to gdy pytamy o jego status, to mimo to pokazuje offline gdy pytamy czy jest - brak zdradzania czy user istnieje
+- CURRENT_PROJECT do zmiany i ogólnie inne markdowny też
+- dać kroki dla dewelopera który ma stestować działanie bazy - jakie komendy, co usunąć itp.
+
+- deweloperom dać znać że sekrety są zapisywane lokalnie w katalogu domowym
+
+CLIENT
+======
+- forma przechowywania sekretów lokalnie - słabe szyfrowanie chyba bo widać że sekrety są te same. Zamiast tego zastanowić się nad hashowaniem
+
+- !!!!WAŻNE!!! plik ze stałymi (W tym z dokumentacji) aby w kodzie nie używać magicznych liczb, ale konkretnych stałych
+
+- SENSOWNOŚĆ CERTYFIKATÓW!
+
+- Uważać czy wszędzie gdzie trzeba jest:
+    _ "github.com/lib/pq"   !!!!!
+
+- możliwość usunięcia konta poprzez /delete lub /remove z opcją \<user\> i wtedy powinno poprosić o uwierzytelnienie (wpisanie hasła do logowania w ramach zatwerdzenia). Do tej operacji trzeba być zalogowanym to po zakończeniu operacji powinno wyjść jak za pomocą /quit + usunąć rekord z userem z bazy danych
+
+- update cross-networkowych rzeczy (przetestowanie i markdown update)
+
+- kolorowa konsola klienta
+
+- dlaczego [Client: Receive] Parse error: ERR_02: JSON parsing error przy wysyłaniu do samego siebie, powinna być możliwość zablokowania wysyłania do siebie 
+
+- TESTY OGÓLNIE - LEPIEJ POMYŚLANE, MOŻĘ JAKOŚ LEPIEJ USTRUKTURYZOWAĆ
+
+- ŁADOWANIE KLUCZY KONWERSACJI Z PLIKU! (opcjonalnie na końcu)
+
+- gotowe pod frontend
+
+- plik cover.out do analizy na przyszłość i do wykrozystania może
+
+UZUPEŁNIĆ DOKUMENTACJE W GITHUB O MEOWSSENGER I W README DAĆ ŻE EOWSSENGER POWERED BY KTTYPROTOCOL CZY COŚ TAKIEGO
+
+- Azure można jako nowe konto dodać i dostajesz chyba 200$ z darmo na 30 dni to można stestować jak się uda
+
+- golang-standards - dostosowanie
+
+- godoc !!! Sporawdzić czy zadziała u nas
+
+- CI/CD
+- gwiazdki w cli jak się hasło wpisuje albo nie pokazywać jak się wpisuje w ogóle bo obecnie się wyświetla w konsoli normalnie
+- czy komendy typu /fdfsdfdsf nie powinny byćogólnie dostępne, także w gui na przyszłość, żeby gui wołało tylko jakąś komendę np. /status albo /chat <user> itp
+- na język angielski zmiana wszystkiego w kodzie
+
+
+=====================================================================================================================================
+Jest jeszcze kilka rzeczy do zrobienia w tym projekcie. Daję listę, którą fajnie byłoby zrealizować:
+- dlaczego [Client: Receive] Parse error: ERR_02: JSON parsing error przy wysyłaniu do samego siebie, powinna być możliwość zablokowania wysyłania do siebie (mam logi do takiej sytuacji)
+- forma przechowywania sekretów lokalnie - słabe szyfrowanie chyba bo widać że sekrety są te same. Zamiast tego zastanowić się nad hashowaniem
+- jaka jest obecnie SENSOWNOŚĆ CERTYFIKATÓW!. zastanowić się nad tym
+- możliwość usunięcia konta poprzez /delete lub /remove z opcją \<user\> i wtedy powinno poprosić o uwierzytelnienie (wpisanie hasła do logowania w ramach zatwerdzenia). Do tej operacji trzeba być zalogowanym to po zakończeniu operacji powinno wyjść jak za pomocą /quit + usunąć rekord z userem z bazy danych
+- kolorowa konsola klienta w wersji cli
+- testy jednostkowe z bardzo dobrym pokryciem
+- gwiazdki w cli jak się hasło wpisuje albo nie pokazywać jak się wpisuje w ogóle bo obecnie się wyświetla w konsoli normalnie
+- czy komendy typu /command nie powinny być ogólnie dostępne, także w gui na przyszłość, żeby gui wołało tylko jakąś komendę np. /status albo /chat <user> itp pytanie do zasaatnowienia i odpowiedzi. Wiem że sporo tego, ale możesz to podzielić namniejsze etapy którymi będziemy się zajmować teraz po kolei
+- authtimer powinien się zaczynać po wybraniu opcji logowania/rejestracji a nie po wystartowaniu aplikacji. Powiniensię restartować przy każdorazowym wybraniu opcji /login bo w ogóle ten timer fl arejestracji chyba nie bardzo ma sens 
+- komenda /menu zamiast każdorazowo wyświetlać i psuć flow
+- brak pokazywania sekretu przy wpisywaniu sekretu

client/api/ack.go

@@ -6,14 +6,15 @@ import (
 )
 
 // AckEventHandler defines callbacks for delivery acknowledgment events.
-// UI layers (CLI, GUI) or application components may subscribe to receive
-// notifications about message delivery or timeout.
+// UI layers (CLI, GUI) or higher-level application components may subscribe
+// to receive notifications about message delivery or timeout.
 //
 // CONTRACT:
 //   - OnDelivered(msgID) is called exactly once when MEOW_OK arrives.
 //   - OnTimeout(msgID) is called exactly once when the timeout expires.
 //   - A message will NEVER trigger both events.
-//   - Handlers are invoked synchronously in the caller goroutine.
+//   - Handlers are invoked synchronously in the goroutine that processes
+//     the event (no extra goroutines are spawned per handler).
 type AckEventHandler interface {
 	OnDelivered(msgID int64)
 	OnTimeout(msgID int64)
@@ -33,16 +34,19 @@ type AckManager struct {
 	timeout  time.Duration
 }
 
-// NewAckManager creates a new manager with a default timeout of 5 seconds.
+// NewAckManager creates a new manager with a default timeout.
 func NewAckManager() *AckManager {
 	return &AckManager{
 		pending: make(map[int64]chan struct{}),
-		timeout: 5 * time.Second,
+		timeout: defaultAckTimeout,
 	}
 }
 
-// RegisterHandler registers a UI or client component to receive ACK events.
-// Handlers are invoked synchronously in the caller goroutine.
+// RegisterHandler registers a component to receive ACK events.
+// Handlers are invoked synchronously in the event-processing goroutine.
+//
+// It is safe to call RegisterHandler before or after messages are added,
+// but handlers registered after AddPending() may miss earlier events.
 func (a *AckManager) RegisterHandler(h AckEventHandler) {
 	a.mu.Lock()
 	defer a.mu.Unlock()
@@ -54,12 +58,13 @@ func (a *AckManager) RegisterHandler(h AckEventHandler) {
 // BEHAVIOR:
 //   - If MEOW_OK arrives → NotifyDelivered() closes the channel.
 //   - If timeout expires → OnTimeout() is invoked.
-//   - Only one of these events will fire.
+//   - Only one of these events will fire for a given msgID.
 func (a *AckManager) AddPending(msgID int64) {
 	ch := make(chan struct{})
 
 	a.mu.Lock()
 	a.pending[msgID] = ch
+	timeout := a.timeout
 	a.mu.Unlock()
 
 	go func() {
@@ -68,13 +73,18 @@ func (a *AckManager) AddPending(msgID int64) {
 			// Delivered — nothing more to do.
 			return
 
-		case <-time.After(a.timeout):
+		case <-time.After(timeout):
 			a.mu.Lock()
+			// Check if still pending (may have been delivered just before timeout).
 			if _, ok := a.pending[msgID]; ok {
 				delete(a.pending, msgID)
-				for _, h := range a.handlers {
+				handlers := append([]AckEventHandler(nil), a.handlers...)
+				a.mu.Unlock()
+
+				for _, h := range handlers {
 					h.OnTimeout(msgID)
 				}
+				return
 			}
 			a.mu.Unlock()
 		}
@@ -83,24 +93,35 @@ func (a *AckManager) AddPending(msgID int64) {
 
 // NotifyDelivered is called when MEOW_OK arrives.
 // It removes the pending entry and notifies all handlers.
+//
+// If the message is no longer pending (e.g. timeout already fired),
+// this call is a no-op.
 func (a *AckManager) NotifyDelivered(msgID int64) {
 	a.mu.Lock()
 	ch, ok := a.pending[msgID]
 	if ok {
 		delete(a.pending, msgID)
 	}
+	handlers := append([]AckEventHandler(nil), a.handlers...)
 	a.mu.Unlock()
 
-	if ok {
-		close(ch)
-		for _, h := range a.handlers {
-			h.OnDelivered(msgID)
-		}
+	if !ok {
+		return
+	}
+
+	// Closing the channel unblocks the timeout goroutine (if still waiting).
+	close(ch)
+
+	for _, h := range handlers {
+		h.OnDelivered(msgID)
 	}
 }
 
 // RegisterAckHandler is the public API exposed by KittyClient.
 // It simply forwards the handler to the underlying AckManager.
+//
+// This keeps the AckManager internal while exposing a stable interface
+// for UI layers (CLI, Wails GUI, tests, etc.).
 func (c *KittyClient) RegisterAckHandler(h AckEventHandler) {
 	c.mu.Lock()
 	defer c.mu.Unlock()