1
// Copyright 2013 Canonical Ltd.
2
// Licensed under the AGPLv3, see LICENCE file for details.
9
jc "github.com/juju/testing/checkers"
10
gc "gopkg.in/check.v1"
11
"gopkg.in/juju/names.v2"
13
"github.com/juju/juju/apiserver/common"
14
"github.com/juju/juju/apiserver/params"
15
apiservertesting "github.com/juju/juju/apiserver/testing"
16
"github.com/juju/juju/state"
19
type removeSuite struct{}
21
var _ = gc.Suite(&removeSuite{})
23
type fakeRemover struct {
31
func (r *fakeRemover) EnsureDead() error {
32
return r.errEnsureDead
35
func (r *fakeRemover) Remove() error {
39
func (r *fakeRemover) Life() state.Life {
43
func (*removeSuite) TestRemove(c *gc.C) {
45
entities: map[names.Tag]entityWithError{
46
u("x/0"): &fakeRemover{life: state.Dying, errEnsureDead: fmt.Errorf("x0 EnsureDead fails")},
47
u("x/1"): &fakeRemover{life: state.Dying, errRemove: fmt.Errorf("x1 Remove fails")},
48
u("x/2"): &fakeRemover{life: state.Alive},
49
u("x/3"): &fakeRemover{life: state.Dying},
50
u("x/4"): &fakeRemover{life: state.Dead},
51
u("x/5"): &fakeRemover{fetchError: "x5 error"},
54
getCanModify := func() (common.AuthFunc, error) {
60
return func(tag names.Tag) bool {
61
return tag == u0 || tag == u1 || tag == u2 || tag == u3 || tag == u5
65
r := common.NewRemover(st, true, getCanModify)
66
entities := params.Entities{[]params.Entity{
67
{"unit-x-0"}, {"unit-x-1"}, {"unit-x-2"}, {"unit-x-3"}, {"unit-x-4"}, {"unit-x-5"}, {"unit-x-6"},
69
result, err := r.Remove(entities)
70
c.Assert(err, jc.ErrorIsNil)
71
c.Assert(result, gc.DeepEquals, params.ErrorResults{
72
Results: []params.ErrorResult{
73
{¶ms.Error{Message: "x0 EnsureDead fails"}},
74
{¶ms.Error{Message: "x1 Remove fails"}},
75
{¶ms.Error{Message: `cannot remove entity "unit-x-2": still alive`}},
77
{apiservertesting.ErrUnauthorized},
78
{¶ms.Error{Message: "x5 error"}},
79
{apiservertesting.ErrUnauthorized},
83
// Make sure when callEnsureDead is false EnsureDead() doesn't
85
r = common.NewRemover(st, false, getCanModify)
86
entities = params.Entities{[]params.Entity{{"unit-x-0"}, {"unit-x-1"}}}
87
result, err = r.Remove(entities)
88
c.Assert(err, jc.ErrorIsNil)
89
c.Assert(result, gc.DeepEquals, params.ErrorResults{
90
Results: []params.ErrorResult{
92
{¶ms.Error{Message: "x1 Remove fails"}},
97
func (*removeSuite) TestRemoveError(c *gc.C) {
98
getCanModify := func() (common.AuthFunc, error) {
99
return nil, fmt.Errorf("pow")
101
r := common.NewRemover(&fakeState{}, true, getCanModify)
102
_, err := r.Remove(params.Entities{[]params.Entity{{"x0"}}})
103
c.Assert(err, gc.ErrorMatches, "pow")
106
func (*removeSuite) TestRemoveNoArgsNoError(c *gc.C) {
107
getCanModify := func() (common.AuthFunc, error) {
108
return nil, fmt.Errorf("pow")
110
r := common.NewRemover(&fakeState{}, true, getCanModify)
111
result, err := r.Remove(params.Entities{})
112
c.Assert(err, jc.ErrorIsNil)
113
c.Assert(result.Results, gc.HasLen, 0)