Function TestIsSystemAccount

test/basic_test.go:204–245

(t *testing.T)

}

func TestIsSystemAccount(t *testing.T) {
	conf := createConfFile(t, []byte(`
	listen: 127.0.0.1:-1
	accounts: {
		SYS: {
			users: [ {user: "sys", password: "pass"} ]
		}
		APP: {
			users: [ {user: "app", password: "pass"} ]
		}
	}
	system_account: SYS
	`))
	defer os.Remove(conf)

	s, _ := RunServerWithConfig(conf)
	defer s.Shutdown()

	nc, err := nats.Connect(s.ClientURL(), nats.UserInfo("sys", "pass"))
	if err != nil {
		t.Fatalf("Error connecting: %v", err)
	}
	defer nc.Close()

	// IsSystemAccount is sent by the server in an async INFO after connect.
	checkFor(t, time.Second, 15*time.Millisecond, func() error {
		if !nc.IsSystemAccount() {
			return fmt.Errorf("expected system account")
		}
		return nil
	})

	nc2, err := nats.Connect(s.ClientURL(), nats.UserInfo("app", "pass"))
	if err != nil {
		t.Fatalf("Error connecting: %v", err)
	}
	defer nc2.Close()

	if nc2.IsSystemAccount() {
		t.Fatalf("Expected non-system account")
	}
}

func TestMultipleClose(t *testing.T) {
	s := RunDefaultServer()