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)
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'" \