chore: testing

Signed-off-by: Donnie Adams <[email protected]>

Author: thedadams

gptscript.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"io"
 	"log/slog"
 	"net"
 	"net/http"
@@ -49,13 +48,11 @@ func NewGPTScript(opts GlobalOptions) (GPTScript, error) {
 	defer lock.Unlock()
 	gptscriptCount++
 
-	disableServer := os.Getenv("GPT_SCRIPT_DISABLE_SERVER") == "true"
-
-	if serverURL == "" && disableServer {
+	if serverURL == "" {
 		serverURL = os.Getenv("GPTSCRIPT_URL")
 	}
 
-	if serverProcessCancel == nil && !disableServer {
+	if serverProcessCancel == nil && os.Getenv("GPTSCRIPT_DISABLE_SERVER") != "true" {
 		if serverURL == "" {
 			l, err := net.Listen("tcp", "127.0.0.1:0")
 			if err != nil {
@@ -72,14 +69,21 @@ func NewGPTScript(opts GlobalOptions) (GPTScript, error) {
 
 		ctx, cancel := context.WithCancel(context.Background())
 
-		in, _ := io.Pipe()
 		serverProcess = exec.CommandContext(ctx, getCommand(), "--listen-address", serverURL, "sdkserver")
+		serverProcess.Stdout = os.Stdout
+		serverProcess.Stderr = os.Stderr
 		serverProcess.Env = append(os.Environ(), opts.toEnv()...)
-		serverProcess.Stdin = in
+		stdin, err := serverProcess.StdinPipe()
+		if err != nil {
+			cancel()
+			return nil, err
+		}
+
+		stdin.Write([]byte("start!!!"))
 
 		serverProcessCancel = func() {
+			_ = stdin.Close()
 			cancel()
-			_ = in.Close()
 		}
 
 		if err := serverProcess.Start(); err != nil {
@@ -102,13 +106,15 @@ func waitForServerReady(ctx context.Context, serverURL string) error {
 	for {
 		resp, err := http.Get("http://" + serverURL + "/healthz")
 		if err != nil {
-			slog.DebugContext(ctx, "waiting for server to become ready")
+			slog.InfoContext(ctx, "waiting for server to become ready", "err", err)
 		} else {
 			_ = resp.Body.Close()
 
 			if resp.StatusCode == http.StatusOK {
 				return nil
 			}
+
+			slog.InfoContext(ctx, "waiting for server to become ready", "status", resp.StatusCode)
 		}
 
 		select {