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
|
#
# These macros are intended only for use in provider.json, although they are
# currently loaded in all .json contexts.
#
module LeapCli
module Macro
#
# returns an array of the service names, including only those services that
# are enabled for this environment.
#
def enabled_services
manager.env(self.environment).services[:service_type => :user_service].field(:name).select { |service|
manager.nodes[:environment => self.environment][:services => service].any?
}
end
#
# The webapp will not work unless the service level configuration is precisely defined.
# Here, we take what the sysadmin has specified in provider.json and clean it up to
# ensure it is OK.
#
# It would be better to add support for JSON schema.
#
def service_levels()
levels = {}
provider.service.levels.each do |name, level|
if name =~ /^[0-9]+$/
name = name.to_i
end
levels[name] = level_cleanup(name, level.clone)
end
levels
end
private
def print_warning(name, msg)
if self.environment
provider_str = "provider.json or %s" % ['provider', self.environment, 'json'].join('.')
else
provider_str = "provider.json"
end
LeapCli::log :warning, "In #{provider_str}, you have an incorrect definition for service level '#{name}':" do
LeapCli::log msg
end
end
def level_cleanup(name, level)
unless level['name']
print_warning(name, 'required field "name" is missing')
end
unless level['description']
print_warning(name, 'required field "description" is missing')
end
unless level['bandwidth'].nil? || level['bandwidth'] == 'limited'
print_warning(name, 'field "bandwidth" must be nil or "limited"')
end
unless level['rate'].nil? || level['rate'].is_a?(Hash)
print_warning(name, 'field "rate" must be nil or a hash (e.g. {"USD":10, "EUR":10})')
end
possible_services = enabled_services
if level['services']
level['services'].each do |service|
unless possible_services.include? service
print_warning(name, "the service '#{service}' does not exist or there are no nodes that provide this service.")
LeapCli::Util::bail!
end
end
else
level['services'] = possible_services
end
level['services'] = remap_services(level['services'])
level
end
#
# the service names that the webapp uses and that leap_platform uses are different. ugh.
#
SERVICE_MAP = {
"mx" => "email",
"openvpn" => "eip"
}
def remap_services(services)
services.map {|srv| SERVICE_MAP[srv]}
end
end
end
|
