-
Notifications
You must be signed in to change notification settings - Fork 1
/
environwatcher.go
executable file
·95 lines (78 loc) · 2.43 KB
/
environwatcher.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
// Copyright 2014 Canonical Ltd.
// Licensed under the AGPLv3, see LICENCE file for details.
package testing
import (
gc "launchpad.net/gocheck"
"launchpad.net/juju-core/environs"
"launchpad.net/juju-core/environs/config"
"launchpad.net/juju-core/state"
"launchpad.net/juju-core/state/api/watcher"
statetesting "launchpad.net/juju-core/state/testing"
jc "launchpad.net/juju-core/testing/checkers"
)
const (
HasSecrets = true
NoSecrets = false
)
type Façade interface {
WatchForEnvironConfigChanges() (watcher.NotifyWatcher, error)
EnvironConfig() (*config.Config, error)
}
type EnvironWatcherTest struct {
facade Façade
st *state.State
backing *state.State
hasSecrets bool
}
func NewEnvironWatcherTest(
facade Façade,
st *state.State,
backing *state.State,
hasSecrets bool) *EnvironWatcherTest {
return &EnvironWatcherTest{facade, st, backing, hasSecrets}
}
func (s *EnvironWatcherTest) TestEnvironConfig(c *gc.C) {
envConfig, err := s.st.EnvironConfig()
c.Assert(err, gc.IsNil)
conf, err := s.facade.EnvironConfig()
c.Assert(err, gc.IsNil)
// If the facade doesn't have secrets, we need to replace the config
// values in our environment to compare against with the secrets replaced.
if !s.hasSecrets {
env, err := environs.New(envConfig)
c.Assert(err, gc.IsNil)
secretAttrs, err := env.Provider().SecretAttrs(envConfig)
c.Assert(err, gc.IsNil)
secrets := make(map[string]interface{})
for key := range secretAttrs {
secrets[key] = "not available"
}
envConfig, err = envConfig.Apply(secrets)
c.Assert(err, gc.IsNil)
}
c.Assert(conf, jc.DeepEquals, envConfig)
}
func (s *EnvironWatcherTest) TestWatchForEnvironConfigChanges(c *gc.C) {
envConfig, err := s.st.EnvironConfig()
c.Assert(err, gc.IsNil)
w, err := s.facade.WatchForEnvironConfigChanges()
c.Assert(err, gc.IsNil)
defer statetesting.AssertStop(c, w)
wc := statetesting.NewNotifyWatcherC(c, s.backing, w)
// Initial event.
wc.AssertOneChange()
// Change the environment configuration, check it's detected.
attrs := envConfig.AllAttrs()
attrs["type"] = "blah"
newConfig, err := config.New(config.NoDefaults, attrs)
c.Assert(err, gc.IsNil)
err = s.st.SetEnvironConfig(newConfig, envConfig)
c.Assert(err, gc.IsNil)
wc.AssertOneChange()
// Change it back to the original config.
err = s.st.SetEnvironConfig(envConfig, newConfig)
c.Assert(err, gc.IsNil)
wc.AssertOneChange()
statetesting.AssertStop(c, w)
wc.AssertClosed()
}