/
path_destroy_test.go
110 lines (91 loc) · 2.51 KB
/
path_destroy_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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
// Copyright (c) HashiCorp, Inc.
// SPDX-License-Identifier: MPL-2.0
package kv
import (
"context"
"testing"
"github.com/hashicorp/vault/sdk/helper/testhelpers/schema"
"github.com/hashicorp/vault/sdk/logical"
)
func TestVersionedKV_Destroy_Put(t *testing.T) {
b, storage, events := getBackendWithEvents(t)
data := map[string]interface{}{
"data": map[string]interface{}{
"bar": "baz",
},
}
req := &logical.Request{
Operation: logical.CreateOperation,
Path: "data/foo",
Storage: storage,
Data: data,
}
resp, err := b.HandleRequest(context.Background(), req)
if err != nil || (resp != nil && resp.IsError()) {
t.Fatalf("err:%s resp:%#v\n", err, resp)
}
if resp.Data["version"] != uint64(1) {
t.Fatalf("Bad response: %#v", resp)
}
data = map[string]interface{}{
"data": map[string]interface{}{
"bar": "baz1",
},
"options": map[string]interface{}{
"cas": float64(1),
},
}
req = &logical.Request{
Operation: logical.CreateOperation,
Path: "data/foo",
Storage: storage,
Data: data,
}
resp, err = b.HandleRequest(context.Background(), req)
if err != nil || (resp != nil && resp.IsError()) {
t.Fatalf("err:%s resp:%#v\n", err, resp)
}
if resp.Data["version"] != uint64(2) {
t.Fatalf("Bad response: %#v", resp)
}
data = map[string]interface{}{
"versions": "1,2",
}
req = &logical.Request{
Operation: logical.UpdateOperation,
Path: "destroy/foo",
Storage: storage,
Data: data,
}
resp, err = b.HandleRequest(context.Background(), req)
if err != nil || (resp != nil && resp.IsError()) {
t.Fatalf("err:%s resp:%#v\n", err, resp)
}
schema.ValidateResponse(
t,
schema.GetResponseSchema(t, b.(*versionedKVBackend).Route(req.Path), req.Operation),
resp,
true,
)
req = &logical.Request{
Operation: logical.ReadOperation,
Path: "metadata/foo",
Storage: storage,
Data: data,
}
resp, err = b.HandleRequest(context.Background(), req)
if err != nil || resp == nil || resp.IsError() {
t.Fatalf("err:%s resp:%#v\n", err, resp)
}
if resp.Data["versions"].(map[string]interface{})["1"].(map[string]interface{})["destroyed"].(bool) != true {
t.Fatalf("Bad response: %#v", resp)
}
if resp.Data["versions"].(map[string]interface{})["2"].(map[string]interface{})["destroyed"].(bool) != true {
t.Fatalf("Bad response: %#v", resp)
}
events.expectEvents(t, []expectedEvent{
{"kv-v2/data-write", "data/foo", "data/foo"},
{"kv-v2/data-write", "data/foo", "data/foo"},
{"kv-v2/destroy", "destroy/foo", ""},
})
}