78 lines
1.4 KiB
Go
78 lines
1.4 KiB
Go
|
package vault
|
||
|
|
|
||
|
|
import (
|
||
|
|
"reflect"
|
||
|
|
"strings"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
// mockExpiration returns a mock expiration manager
|
||
|
|
func mockExpiration(t *testing.T) *ExpirationManager {
|
||
|
|
router := NewRouter()
|
||
|
|
view := mockView(t, "expire/")
|
||
|
|
return NewExpirationManager(router, view)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestExpiration_Register(t *testing.T) {
|
||
|
|
exp := mockExpiration(t)
|
||
|
|
req := &Request{
|
||
|
|
Operation: ReadOperation,
|
||
|
|
Path: "prod/aws/foo",
|
||
|
|
}
|
||
|
|
resp := &Response{
|
||
|
|
IsSecret: true,
|
||
|
|
Lease: &Lease{
|
||
|
|
Duration: time.Hour,
|
||
|
|
MaxDuration: time.Hour,
|
||
|
|
},
|
||
|
|
Data: map[string]interface{}{
|
||
|
|
"access_key": "xyz",
|
||
|
|
"secret_key": "abcd",
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := exp.Register(req, resp)
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
if !strings.HasPrefix(id, req.Path) {
|
||
|
|
t.Fatalf("bad: %s", id)
|
||
|
|
}
|
||
|
|
|
||
|
|
if len(id) <= len(req.Path) {
|
||
|
|
t.Fatalf("bad: %s", id)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestLeaseEntry(t *testing.T) {
|
||
|
|
le := &leaseEntry{
|
||
|
|
VaultID: "foo/bar/1234",
|
||
|
|
Path: "foo/bar",
|
||
|
|
Data: map[string]interface{}{
|
||
|
|
"testing": true,
|
||
|
|
},
|
||
|
|
Lease: &Lease{
|
||
|
|
Renewable: true,
|
||
|
|
Duration: time.Minute,
|
||
|
|
MaxDuration: time.Hour,
|
||
|
|
},
|
||
|
|
IssueTime: time.Now(),
|
||
|
|
}
|
||
|
|
|
||
|
|
enc, err := le.encode()
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
out, err := decodeLeaseEntry(enc)
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
if !reflect.DeepEqual(out.Data, le.Data) {
|
||
|
|
t.Fatalf("got: %#v, expect %#v", out, le)
|
||
|
|
}
|
||
|
|
}
|