gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 11:04:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Ensure old connection still works in TLS reload test

Browse Source
This commit is contained in:
Tyler Treat
2017-06-07 17:03:33 -05:00
parent d172ca5801
commit 30db4be965
1 changed files with 20 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
server/reload_test.go
View File

@@ -244,7 +244,12 @@ func TestConfigReloadRotateTLS(t *testing.T) {
if err != nil {
t.Fatalf("Error creating client: %v", err)
}
nc.Close()
defer nc.Close()
sub, err := nc.SubscribeSync("foo")
if err != nil {
t.Fatalf("Error subscribing: %v", err)
}
defer sub.Unsubscribe()
// Rotate cert and enable client verification.
if err := os.Remove(config); err != nil {
@@ -264,11 +269,23 @@ func TestConfigReloadRotateTLS(t *testing.T) {
// Ensure connecting succeeds when client presents cert.
cert := nats.ClientCert("./configs/certs/cert.new.pem", "./configs/certs/key.new.pem")
nc, err = nats.Connect(addr, cert, nats.RootCAs("./configs/certs/cert.new.pem"))
conn, err := nats.Connect(addr, cert, nats.RootCAs("./configs/certs/cert.new.pem"))
if err != nil {
t.Fatalf("Error creating client: %v", err)
}
nc.Close()
conn.Close()
// Ensure the original connection can still publish/receive.
if err := nc.Publish("foo", []byte("hello")); err != nil {
t.Fatalf("Error publishing: %v", err)
}
msg, err := sub.NextMsg(time.Second)
if err != nil {
t.Fatalf("Error receiving msg: %v", err)
}
if string(msg.Data) != "hello" {
t.Fatalf("Msg is incorrect.\nexpected: %+v\ngot: %+v", []byte("hello"), msg.Data)
}
}
// Ensure Reload supports enabling TLS. Test this by starting a server without