import string
import time
import os
-import StringIO
import sys
+if sys.version_info[0] == 2:
+ import StringIO
+else:
+ from io import StringIO
import fnmatch
import gpg
from bqueue import B_Queue
from config import config, init_conf
from mailer import Message
+#import messagebus
def check_double_id(id):
id_nl = id + "\n"
ids = open(path.processed_ids_file)
- for i in ids.xreadlines():
+ for i in ids:
if i == id_nl:
# FIXME: security email here?
log.alert("request %s already processed" % id)
batch.builders_status_time[bld] = time.time()
if bld not in config.binary_builders and bld != config.builder:
fail_mail("I (src rpm builder '%s') do not handle binary builder '%s', only '%s'" % \
- (config.builder, bld, string.join(config.binary_builders)))
+ (config.builder, bld, config.binary_builders.join()))
lockf.close()
return
if batch.is_command():
q = B_Queue(path.req_queue_file)
q.lock(0)
q.read()
- not_fin = filter(lambda (r): not r.is_done(), q.requests)
+ not_fin = list(filter(lambda r: not r.is_done(), q.requests))
r.apply_to(q)
for r in not_fin:
if r.is_done():
util.clean_tmp(path.srpms_dir + '/' + r.id)
return False
return True
- q.requests = filter(leave_it, q.requests)
+ q.requests = list(filter(leave_it, q.requests))
q.write()
q.dump(path.queue_stats_file)
q.dump_html(path.queue_html_stats_file)
status.push("request from %s" % user.login)
r = request.parse_request(body)
if r.kind == 'group':
+# messagebus.notify(topic="request.group", user=user.login, **r.dump_json())
handle_group(r, user)
elif r.kind == 'notification':
+# messagebus.notify(topic="request.notify", user=user.login, **r.dump_json())
handle_notification(r, user)
else:
msg = "%s: don't know how to handle requests of this kind '%s'" \