"keyFingerPrint", "privateSub", "mailDisableMessage",\
"mailGreylisting", "mailCallout", "mailRBL", "mailRHSBL",\
"mailWhitelist", "sudoPassword", "objectClass", "accountStatus",\
- "mailContentInspectionAction", "webPassword", "rtcPassword"])
+ "mailContentInspectionAction", "webPassword", "rtcPassword",\
+ "bATVToken"])
if passwd_attrs is None:
raise UDEmptyList, "No Users"
return (cache_last_ldap_mod, cache_last_unix_mod, cache_last_run)
-def mq_notify(options):
+def mq_notify(options, message):
options.section = 'dsa-udgenerate'
options.config = '/etc/dsa/pubsub.conf'
'rabbit_hosts': ['pubsub02.debian.org', 'pubsub01.debian.org'],
'use_ssl': False
}
+
+ msg = {
+ 'message': message,
+ 'timestamp': int(time.time())
+ }
conn = None
try:
conn = Connection(conf=conf)
conn.topic_send(config.topic,
- 'update',
+ json.dumps(msg),
exchange_name=config.exchange,
timeout=5)
finally:
help="Output directory.")
parser.add_option("-f", "--force", dest="force", action="store_true",
help="Force generation, even if no update to LDAP has happened.")
- parser.add_option("-m", "--mq", action="store_true", default=False,
- help="Send update trigger over MQ")
(options, args) = parser.parse_args()
if len(args) > 0:
fd = open(os.path.join(generate_dir, "last_update.trace"), "w")
if need_update or options.force:
+ msg = 'Update forced' if options.force else 'Update needed'
generate_all(generate_dir, l)
- if options.mq:
- mq_notify(options)
+ mq_notify(options, msg)
last_run = int(time.time())
fd.write("%s\n%s\n%s\n" % (ldap_last_mod, unix_last_mod, last_run))
fd.close()