test

Zondax · Feb 2, 2024 · df61121 · df61121
1 parent c6d0b82
commit df61121
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/znats/kv_test.go b/znats/kv_test.go
@@ -4,8 +4,26 @@ import (
 	"github.com/nats-io/nats.go"
 	"gotest.tools/assert"
 	"testing"
+	"time"
 )
 
+func TestNatsPing(t *testing.T) {
+	nc, err := nats.Connect("nats://localhost:4222")
+	if err != nil {
+		t.Fatalf("Error connecting to nats: %v", err)
+	}
+	defer nc.Close()
+
+	response, err := nc.Request("ping", []byte("ping"), 1000*time.Millisecond)
+	if err != nil {
+		t.Fatalf("error sending ping: %v", err)
+	}
+
+	if string(response.Data) != "pong" {
+		t.Fatalf("wrong answer: %s", response.Data)
+	}
+}
+
 func TestCreateKVStore(t *testing.T) {
 	bucketNameHandle := "testKVStore"
 	err := natsComponent.CreateKVStore(ConfigKVStore{