b87f14a361
Five interop issues fixed against PROTOCOL.md:
- Join signature now covers nonce_raw || net_ascii (64-char UTF-8 hex
string) as specified in §5.1, not net_raw_bytes. Both anchor server
and client updated to match.
- Chat wire fields renamed to spec names: text/ts (Unix ms int64)
replacing body/sent_at (ISO timestamp). Flat layout on PeerMessage
matches §8 exactly; store and TUI updated accordingly.
- Direct messages now use the spec "pm" type (flat {type,mid,text,ts})
instead of chat+to. Receiver reconstructs a ChatMessage with
dm:<short-id> room for IPC/storage. §8 compliant.
- File transfer message types changed to spec hyphenated names:
file-offer, file-accept, file-cancel, file-done with spec field
names (name/size not filename/size_bytes). §9 compliant.
- DataChannel open-race (§14 gotcha #3) fixed with sync.Once: doOpen
fires on OnOpen callback or immediately if the channel is already
open when WireDataChannel is called (answerer race).
Also fixes two bugs found during testing:
- mid was missing from outgoing wire messages, causing all received
messages to arrive with mid="" and collide on the UNIQUE DB
constraint. mid is now included on all sent chat/pm messages; a
random mid is generated for any received message that omits it.
- Test scripts hardened: kill -9 + active lsof polling replaces blind
sleep for port cleanup; join_network sent before peer_field queries
(local_peer is now network-scoped and nil until joined).
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
104 lines
2.4 KiB
Go
104 lines
2.4 KiB
Go
package store
|
|
|
|
import (
|
|
"path/filepath"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/waste-go/internal/proto"
|
|
)
|
|
|
|
func TestRoundTrip(t *testing.T) {
|
|
st, err := Open(filepath.Join(t.TempDir(), "test.db"))
|
|
if err != nil {
|
|
t.Fatalf("Open: %v", err)
|
|
}
|
|
defer st.Close()
|
|
|
|
msg := &proto.ChatMessage{
|
|
Mid: "aabbccdd00112233",
|
|
From: proto.PeerID("deadbeef"),
|
|
Room: "general",
|
|
Text: "hello world",
|
|
Ts: time.Now().UTC().Truncate(time.Second).UnixMilli(),
|
|
}
|
|
|
|
if err := st.SaveMessage(msg); err != nil {
|
|
t.Fatalf("SaveMessage: %v", err)
|
|
}
|
|
|
|
// Duplicate mid must be silently ignored.
|
|
if err := st.SaveMessage(msg); err != nil {
|
|
t.Fatalf("duplicate SaveMessage: %v", err)
|
|
}
|
|
|
|
msgs, err := st.RecentMessages("general", 10)
|
|
if err != nil {
|
|
t.Fatalf("RecentMessages: %v", err)
|
|
}
|
|
if len(msgs) != 1 {
|
|
t.Fatalf("got %d messages, want 1", len(msgs))
|
|
}
|
|
got := msgs[0]
|
|
if got.Mid != msg.Mid || got.Text != msg.Text || got.Room != msg.Room {
|
|
t.Fatalf("message mismatch: %+v", got)
|
|
}
|
|
}
|
|
|
|
func TestSavePeerAndKnownPeers(t *testing.T) {
|
|
st, err := Open(filepath.Join(t.TempDir(), "test.db"))
|
|
if err != nil {
|
|
t.Fatalf("Open: %v", err)
|
|
}
|
|
defer st.Close()
|
|
|
|
if err := st.SavePeer("aabbccdd", "alice"); err != nil {
|
|
t.Fatalf("SavePeer: %v", err)
|
|
}
|
|
// Upsert with updated alias.
|
|
if err := st.SavePeer("aabbccdd", "alice-updated"); err != nil {
|
|
t.Fatalf("SavePeer upsert: %v", err)
|
|
}
|
|
|
|
peers, err := st.KnownPeers()
|
|
if err != nil {
|
|
t.Fatalf("KnownPeers: %v", err)
|
|
}
|
|
if peers["aabbccdd"] != "alice-updated" {
|
|
t.Fatalf("alias = %q, want %q", peers["aabbccdd"], "alice-updated")
|
|
}
|
|
}
|
|
|
|
func TestRecentMessagesOrdering(t *testing.T) {
|
|
st, err := Open(filepath.Join(t.TempDir(), "test.db"))
|
|
if err != nil {
|
|
t.Fatalf("Open: %v", err)
|
|
}
|
|
defer st.Close()
|
|
|
|
base := time.Now().UTC().Truncate(time.Second)
|
|
for i := range 5 {
|
|
st.SaveMessage(&proto.ChatMessage{
|
|
Mid: string(rune('a'+i)) + "000000000000000",
|
|
From: "deadbeef",
|
|
Room: "general",
|
|
Text: string(rune('a' + i)),
|
|
Ts: base.Add(time.Duration(i) * time.Second).UnixMilli(),
|
|
})
|
|
}
|
|
|
|
msgs, err := st.RecentMessages("general", 10)
|
|
if err != nil {
|
|
t.Fatalf("RecentMessages: %v", err)
|
|
}
|
|
if len(msgs) != 5 {
|
|
t.Fatalf("got %d messages, want 5", len(msgs))
|
|
}
|
|
// Must be oldest-first.
|
|
for i := 1; i < len(msgs); i++ {
|
|
if msgs[i].Ts < msgs[i-1].Ts {
|
|
t.Fatalf("messages not in ascending order at index %d", i)
|
|
}
|
|
}
|
|
}
|