+++ /dev/null
-# vi: encoding=utf-8 ts=8 sts=4 sw=4 et
-
-import path
-import os
-import shutil
-import time
-
-from config import config
-import util
-
-class Notify_Queue:
- def __init__(self):
- self.queue = None
- self.some_failed = 0
-
- def init(self, g=None):
- self.queue = []
- self.requester_email = g.requester_email
- self.notify_url = config.notify_url
-
- def add(self, file):
- id = util.uuid()
- f = open(path.notify_queue_dir + '/' + id, 'w')
- f.write(file.read())
- f.close()
- self.queue.append({'id': id})
-
- def flush(self):
- def desc(l):
- return """Target: %s
-Id: %s
-Builder: %s
-Time: %d
-Requester: %s
-END
-""" % (self.notify_url, l['id'], config.builder, time.time(), self.requester_email)
-
- for l in self.queue:
- f = open(path.notify_queue_dir + '/' + l['id'] + ".desc", "w")
- f.write(desc(l))
- f.close()
-
- def kill(self):
- for l in self.queue:
- os.unlink(path.notify_queue_dir + '/' + l)
-
-queue = Notify_Queue()
-
-def add(notify):
- queue.add(notify)
-
-def flush():
- queue.flush()
-
-def kill():
- queue.kill()
-
-def init(r):
- queue.init(r)
-
-def status():
- return queue.status
-
-def clear_status():
- queue.status = ""