Function initTestHarness

cmd/test-conn/testutil.go:63–105

(autoAccept bool)

}

func initTestHarness(autoAccept bool) error {
	log.Printf("Initializing test harness...")

	err := setupWaveEnvVars()
	if err != nil {
		return fmt.Errorf("failed to setup wave env vars: %w", err)
	}

	err = wavebase.CacheAndRemoveEnvVars()
	if err != nil {
		return fmt.Errorf("failed to cache env vars: %w", err)
	}

	wshutil.DefaultRouter = wshutil.NewWshRouter()
	wshutil.DefaultRouter.SetAsRootRouter()

	wstore.SetClientId("test-client-" + fmt.Sprintf("%d", time.Now().Unix()))

	userinput.SetUserInputProvider(&CLIProvider{AutoAccept: autoAccept})

	keyPair, err := wavejwt.GenerateKeyPair()
	if err != nil {
		return fmt.Errorf("failed to generate JWT key pair: %w", err)
	}

	err = wavejwt.SetPrivateKey(keyPair.PrivateKey)
	if err != nil {
		return fmt.Errorf("failed to set JWT private key: %w", err)
	}

	err = wavejwt.SetPublicKey(keyPair.PublicKey)
	if err != nil {
		return fmt.Errorf("failed to set JWT public key: %w", err)
	}

	rpc := wshserver.GetMainRpcClient()
	wshutil.DefaultRouter.RegisterTrustedLeaf(rpc, wshutil.DefaultRoute)

	wconfig.GetWatcher().Start()

	log.Printf("Test harness initialized")
	return nil
}

func testBasicConnect(connName string, timeout time.Duration) error {
	opts, err := remote.ParseOpts(connName)