-
Notifications
You must be signed in to change notification settings - Fork 0
/
vault_test.go
62 lines (51 loc) · 1.72 KB
/
vault_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package vivoupdater_test
import (
"os"
"testing"
"github.com/OIT-ADS-Web/vivoupdater"
)
func TestVaultLogin(t *testing.T) {
// NOTE: these are set as globals
vivoupdater.VaultEndpoint = os.Getenv("VAULT_ENDPOINT")
vivoupdater.VaultRoleId = os.Getenv("VAULT_ROLE_ID")
vivoupdater.VaultSecretId = os.Getenv("VAULT_SECRET_ID")
vaultConfig := &vivoupdater.VaultConfig{
Endpoint: vivoupdater.VaultEndpoint,
RoleId: vivoupdater.VaultRoleId,
SecretId: vivoupdater.VaultSecretId,
// e.g. without Token yet
}
err := vivoupdater.FetchToken(vaultConfig)
if err != nil {
t.Errorf("could not login to vault err=%s\n", err)
}
if err == nil && len(vaultConfig.Token) == 0 {
t.Error("could not get token from vault - although no error\n")
}
}
func TestVaultRead(t *testing.T) {
// NOTE: these are set as globals
vivoupdater.VaultEndpoint = os.Getenv("VAULT_ENDPOINT")
vivoupdater.VaultRoleId = os.Getenv("VAULT_ROLE_ID")
vivoupdater.VaultSecretId = os.Getenv("VAULT_SECRET_ID")
vivoupdater.AppEnvironment = os.Getenv("APP_ENVIRONMENT")
vaultConfig := &vivoupdater.VaultConfig{
Endpoint: vivoupdater.VaultEndpoint,
RoleId: vivoupdater.VaultRoleId,
SecretId: vivoupdater.VaultSecretId,
// e.g. without Token yet
}
// don't actually need config kafka fully to test vault
kafkaConfig := &vivoupdater.KafkaSubscriber{}
vivoupdater.GetCertsFromVault(vivoupdater.AppEnvironment,
vaultConfig, kafkaConfig)
if len(kafkaConfig.ClientCert) == 0 {
t.Error("could not configure kafka client cert from vault\n")
}
if len(kafkaConfig.ClientKey) == 0 {
t.Error("could not configure kafka client key from vault\n")
}
if len(kafkaConfig.ServerCert) == 0 {
t.Error("could not configure kafka server cert from vault\n")
}
}