fix: client ctx is not initialized (#12)

Signed-off-by: ZhangJian He <shoothzj@gmail.com>

opcua/client.go

@@ -177,6 +177,8 @@ func NewClient(config *ClientConfig) (*Client, error) {
 		config.BufferMax = 512 * 1024
 	}
 
+	ctx, cancel := context.WithCancel(context.Background())
+
 	client := &Client{
 		config: config,
 		logger: config.Logger,
@@ -185,6 +187,8 @@ func NewClient(config *ClientConfig) (*Client, error) {
 		eventsChan:   make(chan *sendRequest, config.SendQueueSize),
 		pendingQueue: make(chan *sendRequest, config.PendingQueueSize),
 		buffer:       buffer.NewBuffer(config.BufferMax),
+		ctx:          ctx,
+		ctxCancel:    cancel,
 	}
 	go func() {
 		client.read()

opcua/client_test.go

@@ -0,0 +1,35 @@
+package opcua
+
+import (
+	"github.com/shoothzj/gox/netx"
+	"github.com/stretchr/testify/require"
+	"log/slog"
+	"testing"
+)
+
+func TestClientConnect(t *testing.T) {
+	logger := slog.Default()
+
+	serverConfig := &ServerConfig{
+		Host:   "localhost",
+		Port:   0,
+		Logger: logger,
+	}
+	server := NewServer(serverConfig)
+
+	port, err := server.Run()
+	require.NoError(t, err)
+	defer server.Close()
+
+	clientConfig := &ClientConfig{
+		Address: netx.Address{
+			Host: "127.0.0.1",
+			Port: port,
+		},
+		Logger: logger,
+	}
+	client, err := NewClient(clientConfig)
+	require.NoError(t, err)
+
+	client.close()
+}