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

Merge pull request #3695 from nats-io/accs-resolver-jwt-tests

Browse Source 
Fix JWT tests JS store dir
This commit is contained in:
Derek Collison
2022-12-07 17:10:34 -08:00
committed by GitHub
parent 89b5f8319f 9bf0154465
commit bf19db17e0
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
server/jetstream_jwt_test.go
View File

@@ -128,14 +128,14 @@ func TestJetStreamJWTLimits(t *testing.T) {
defer removeDir(t, dir)
conf := createConfFile(t, []byte(fmt.Sprintf(`
listen: 127.0.0.1:-1
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb}
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb, store_dir: "%s"}
operator: %s
resolver: {
type: full
dir: '%s'
}
system_account: %s
`, ojwt, dir, sysPub)))
`, dir, ojwt, dir, sysPub)))
defer removeFile(t, conf)
s, opts := RunServerWithConfig(conf)
defer s.Shutdown()
@@ -174,14 +174,14 @@ func TestJetStreamJWTLimits(t *testing.T) {
s.Shutdown()
conf = createConfFile(t, []byte(fmt.Sprintf(`
listen: 127.0.0.1:%d
jetstream: {max_mem_store: 20Mb, max_file_store: 20Mb}
jetstream: {max_mem_store: 20Mb, max_file_store: 20Mb, store_dir: "%s"}
operator: %s
resolver: {
type: full
dir: '%s'
}
system_account: %s
`, port, ojwt, dir, sysPub)))
`, port, dir, ojwt, dir, sysPub)))
defer removeFile(t, conf)
s, _ = RunServerWithConfig(conf)
defer s.Shutdown()
@@ -890,7 +890,7 @@ func TestJetStreamJWTSysAccUpdateMixedMode(t *testing.T) {
require_NoError(t, err)
}
func TestJetStreamExpiredAccountNotCountedTowardLimits(t *testing.T) {
func TestJetStreamJWTExpiredAccountNotCountedTowardLimits(t *testing.T) {
op, _ := nkeys.CreateOperator()
opPk, _ := op.PublicKey()
sk, _ := nkeys.CreateOperator()
@@ -940,7 +940,7 @@ func TestJetStreamExpiredAccountNotCountedTowardLimits(t *testing.T) {
conf := createConfFile(t, []byte(fmt.Sprintf(`
listen: 127.0.0.1:-1
operator: %s
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb}
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb, store_dir: "%s"}
system_account: %s
resolver: {
type: full
@@ -948,7 +948,7 @@ func TestJetStreamExpiredAccountNotCountedTowardLimits(t *testing.T) {
dir: '%s'
timeout: "500ms"
}
`, opJwt, syspub, dirSrv)))
`, opJwt, dirSrv, syspub, dirSrv)))
defer removeFile(t, conf)
s, _ := RunServerWithConfig(conf)
@@ -991,7 +991,7 @@ func TestJetStreamExpiredAccountNotCountedTowardLimits(t *testing.T) {
require_True(t, ai.Limits.MaxMemory == 7*1024*1024)
}
func TestJetStreamDeletedAccountDoesNotLeakSubscriptions(t *testing.T) {
func TestJetStreamJWTDeletedAccountDoesNotLeakSubscriptions(t *testing.T) {
op, _ := nkeys.CreateOperator()
opPk, _ := op.PublicKey()
sk, _ := nkeys.CreateOperator()
@@ -1115,7 +1115,7 @@ func TestJetStreamDeletedAccountDoesNotLeakSubscriptions(t *testing.T) {
checkNumSubs(beforeCreate + 1)
}
func TestJetStreamDeletedAccountIsReEnabled(t *testing.T) {
func TestJetStreamJWTDeletedAccountIsReEnabled(t *testing.T) {
op, _ := nkeys.CreateOperator()
opPk, _ := op.PublicKey()
sk, _ := nkeys.CreateOperator()
@@ -1166,7 +1166,7 @@ func TestJetStreamDeletedAccountIsReEnabled(t *testing.T) {
conf := createConfFile(t, []byte(fmt.Sprintf(`
listen: 127.0.0.1:-1
operator: %s
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb, store_dir: %v}
jetstream: {max_mem_store: 10Mb, max_file_store: 10Mb, store_dir: "%s"}
system_account: %s
resolver: {
type: full