ca10e37592
When we setup things we didn't setup fedmsg in iad2 staging. Now we are using it, so we should configure it until we get rid of it. Signed-off-by: Kevin Fenzi <kevin@scrye.com>
39 lines
1.2 KiB
Python
39 lines
1.2 KiB
Python
import operator
|
|
|
|
|
|
def invert_fedmsg_policy(groups, vars, env):
|
|
""" Given hostvars that map hosts -> topics, invert that
|
|
and return a dict that maps topics -> hosts.
|
|
|
|
Really, returns a list of tuples -- not a dict.
|
|
"""
|
|
|
|
if env == 'staging':
|
|
hosts = groups['staging'] + groups['staging_friendly']
|
|
else:
|
|
hosts = [h for h in groups['all'] if h not in groups['staging']]
|
|
|
|
inverted = {}
|
|
for host in hosts:
|
|
prefix = '.'.join([vars[host]['fedmsg_prefix'],
|
|
vars[host]['fedmsg_env']])
|
|
fqdn = vars[host].get('fedmsg_fqdn', host)
|
|
|
|
for cert in vars[host]['fedmsg_certs']:
|
|
for topic in cert.get('can_send', []):
|
|
key = prefix + '.' + topic
|
|
inverted[key] = inverted.get(key, [])
|
|
inverted[key].append(cert['service'] + '-' + fqdn)
|
|
|
|
result = list(inverted.items())
|
|
# Sort things so they come out in a reliable order (idempotence)
|
|
[inverted[key].sort() for key in inverted]
|
|
result.sort(key=operator.itemgetter(0))
|
|
return result
|
|
|
|
|
|
class FilterModule(object):
|
|
def filters(self):
|
|
return {
|
|
"invert_fedmsg_policy": invert_fedmsg_policy,
|
|
}
|