added automatic port detect support

test_scripts/go/client_test.go

@@ -10,12 +10,10 @@ import (
 )
 
 func main() {
-	agentClient, err := client.NewWithAddress(
-		"841debad-7433-46ae-a0ec-0540d0df7314",
+	agentClient, err := client.New(
+		"acfef275-a0ff-4d80-89a6-e23490408e97",
 		"minimal",
 		true,
-		"localhost",
-		8450,
 	)
 	if err != nil {
 		log.Fatalf("Failed to create client: %v", err)

test_scripts/go/client_test_2.go

@@ -1,57 +1,57 @@
-package main
-
-import (
-	"context"
-	"fmt"
-	"log"
-	"time"
-
-	"github.com/runagent-dev/runagent-go/pkg/client"
-)
-
-func main() {
-	fmt.Println("=== Minimal Streaming Example ===")
-
-	// Create client for streaming entrypoint
-	agentClient, err := client.NewWithAddress(
-		"841debad-7433-46ae-a0ec-0540d0df7314", // agentID
-		"minimal_stream",                       // streaming entrypoint tag
-		true,                                   // local
-		"localhost",                            // host
-		8450,                                   // port
-	)
-	if err != nil {
-		log.Fatalf("Failed to create client: %v", err)
-	}
-	defer agentClient.Close()
-
-	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
-	defer cancel()
-
-	// Run streaming
-	fmt.Println("Starting stream...")
-	stream, err := agentClient.RunStream(ctx, map[string]interface{}{
-		"role":    "user",
-		"message": "Analyze the benefits of remote work for software teams",
-	})
-	if err != nil {
-		log.Fatalf("Failed to start stream: %v", err)
-	}
-	defer stream.Close()
-
-	// Read from stream
-	for {
-		data, hasMore, err := stream.Next(ctx)
-		if err != nil {
-			log.Printf("Stream error: %v", err)
-			break
-		}
-
-		if !hasMore {
-			fmt.Println("Stream completed")
-			break
-		}
-
-		fmt.Printf("Received: %v\n", data)
-	}
-}
+// package main
+
+// import (
+// 	"context"
+// 	"fmt"
+// 	"log"
+// 	"time"
+
+// 	"github.com/runagent-dev/runagent-go/pkg/client"
+// )
+
+// func main() {
+// 	fmt.Println("=== Minimal Streaming Example ===")
+
+// 	// Create client for streaming entrypoint
+// 	agentClient, err := client.NewWithAddress(
+// 		"841debad-7433-46ae-a0ec-0540d0df7314", // agentID
+// 		"minimal_stream",                       // streaming entrypoint tag
+// 		true,                                   // local
+// 		"localhost",                            // host
+// 		8450,                                   // port
+// 	)
+// 	if err != nil {
+// 		log.Fatalf("Failed to create client: %v", err)
+// 	}
+// 	defer agentClient.Close()
+
+// 	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
+// 	defer cancel()
+
+// 	// Run streaming
+// 	fmt.Println("Starting stream...")
+// 	stream, err := agentClient.RunStream(ctx, map[string]interface{}{
+// 		"role":    "user",
+// 		"message": "Analyze the benefits of remote work for software teams",
+// 	})
+// 	if err != nil {
+// 		log.Fatalf("Failed to start stream: %v", err)
+// 	}
+// 	defer stream.Close()
+
+// 	// Read from stream
+// 	for {
+// 		data, hasMore, err := stream.Next(ctx)
+// 		if err != nil {
+// 			log.Printf("Stream error: %v", err)
+// 			break
+// 		}
+
+// 		if !hasMore {
+// 			fmt.Println("Stream completed")
+// 			break
+// 		}
+
+// 		fmt.Printf("Received: %v\n", data)
+// 	}
+// }

test_scripts/go/client_test_ag2.go

@@ -10,12 +10,12 @@ import (
 )
 
 func main() {
-	agentClient, err := client.NewWithAddress(
-		"7c8c54d0-297b-4c63-86ae-38326a882067",
+	agentClient, err := client.New(
+		"<agent_id>", // agentID
 		"ag2_invoke",
 		true,
-		"localhost",
-		8453,
+		// "localhost",
+		// 8453,
 	)
 	if err != nil {
 		log.Fatalf("Failed to create client: %v", err)