From 283b4ff52a156bf5afb63bb4be27cb72e3847d25 Mon Sep 17 00:00:00 2001
From: eyedeekay <hankhill19580@gmail.com>
Date: Thu, 9 Oct 2025 14:26:28 -0400
Subject: [PATCH] Rename test session identifiers to include 'stream_' prefix
 for clarity and consistency

---
 stream/dialer_test.go    | 6 +++---
 stream/lifecycle_test.go | 4 ++--
 stream/listener_test.go  | 4 ++--
 stream/session_test.go   | 6 +++---
 4 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/stream/dialer_test.go b/stream/dialer_test.go
index 1069bc2f5..d2b13650b 100644
--- a/stream/dialer_test.go
+++ b/stream/dialer_test.go
@@ -19,7 +19,7 @@ func TestStreamSession_Dial(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_dial", keys, []string{
+	session, err := NewStreamSession(sam, "stream_test_dial", keys, []string{
 		"inbound.length=1", "outbound.length=1",
 	})
 	if err != nil {
@@ -98,7 +98,7 @@ func TestStreamSession_DialI2P(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_dial_i2p", keys, []string{
+	session, err := NewStreamSession(sam, "stream_test_dial_i2p", keys, []string{
 		"inbound.length=1", "outbound.length=1",
 	})
 	if err != nil {
@@ -177,7 +177,7 @@ func TestStreamSession_DialContext(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_dial_context", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_dial_context", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
diff --git a/stream/lifecycle_test.go b/stream/lifecycle_test.go
index b73f0ada0..c65c8743f 100644
--- a/stream/lifecycle_test.go
+++ b/stream/lifecycle_test.go
@@ -12,7 +12,7 @@ func TestSessionListenerLifecycle(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_lifecycle", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_lifecycle", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
@@ -70,7 +70,7 @@ func TestExplicitListenerClose(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_explicit_close", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_explicit_close", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
diff --git a/stream/listener_test.go b/stream/listener_test.go
index f578023a0..24b0a631f 100644
--- a/stream/listener_test.go
+++ b/stream/listener_test.go
@@ -13,7 +13,7 @@ func TestStreamSession_Listen(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_listen", keys, []string{
+	session, err := NewStreamSession(sam, "stream_test_listen", keys, []string{
 		"inbound.length=1", "outbound.length=1",
 	})
 	if err != nil {
@@ -41,7 +41,7 @@ func TestStreamSession_NewDialer(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_dialer", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_dialer", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
diff --git a/stream/session_test.go b/stream/session_test.go
index 4af06b5fe..c484e2b1d 100644
--- a/stream/session_test.go
+++ b/stream/session_test.go
@@ -99,7 +99,7 @@ func TestStreamSession_Close(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_close", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_close", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
@@ -127,7 +127,7 @@ func TestStreamSession_Addr(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_addr", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_addr", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}
@@ -145,7 +145,7 @@ func TestStreamSession_ConcurrentOperations(t *testing.T) {
 	sam, keys := setupTestSAM(t)
 	defer sam.Close()
 
-	session, err := NewStreamSession(sam, "test_concurrent", keys, nil)
+	session, err := NewStreamSession(sam, "stream_test_concurrent", keys, nil)
 	if err != nil {
 		t.Fatalf("Failed to create session: %v", err)
 	}