[2563] | 1 | #!/usr/bin/python |
---|
| 2 | |
---|
| 3 | """Validate and add a new item to the Invirt build queue. |
---|
| 4 | |
---|
| 5 | This script, intended to be invoked by remctl, first validates the |
---|
| 6 | build submitted parameters, and then adds a new item to the |
---|
| 7 | Invirtibuilder build queue, triggering the Invirtibuilder to start the |
---|
| 8 | build. |
---|
| 9 | |
---|
| 10 | The expected arguments are |
---|
| 11 | |
---|
| 12 | pocket package commit |
---|
| 13 | |
---|
| 14 | This script will also automatically extract the Kerberos principal |
---|
| 15 | used to submit the job, and include that in the queue file for records |
---|
| 16 | keeping. |
---|
| 17 | """ |
---|
| 18 | |
---|
| 19 | |
---|
| 20 | import datetime |
---|
[3028] | 21 | import optparse |
---|
[2563] | 22 | import os |
---|
| 23 | import sys |
---|
| 24 | import tempfile |
---|
| 25 | import uuid |
---|
| 26 | |
---|
| 27 | import invirt.builder as b |
---|
| 28 | |
---|
| 29 | |
---|
| 30 | def main(): |
---|
[3028] | 31 | parser = optparse.OptionParser('Usage: %prog pocket package commit') |
---|
| 32 | opts, args = parser.parse_args() |
---|
| 33 | if len(args) != 3: |
---|
| 34 | parser.print_help() |
---|
| 35 | return 1 |
---|
| 36 | pocket, package, commit = args |
---|
[2563] | 37 | principal = os.environ['REMOTE_USER'] |
---|
| 38 | request_time = datetime.datetime.utcnow() |
---|
| 39 | q_path = os.path.join(b._QUEUE_DIR, |
---|
| 40 | '%s_%s' % (request_time.strftime('%Y%m%d%H%M%S'), |
---|
| 41 | uuid.uuid4())) |
---|
| 42 | |
---|
| 43 | try: |
---|
[2639] | 44 | b.validateBuild(pocket, package, commit) |
---|
[2563] | 45 | except b.InvalidBuild, e: |
---|
| 46 | print >>sys.stderr, "E: %s" % e |
---|
| 47 | sys.exit(1) |
---|
| 48 | |
---|
| 49 | # To keep from triggering the Invirtibuilder before we've actually |
---|
| 50 | # written the file out, first write the queue entry to a temporary |
---|
| 51 | # file, and then move it into the queue directory. |
---|
[2567] | 52 | q_fd, q_name = tempfile.mkstemp() |
---|
[2569] | 53 | q = os.fdopen(q_fd, 'r+') |
---|
[2563] | 54 | print >>q, "%s %s %s %s" % (pocket, package, commit, principal) |
---|
[3028] | 55 | q.close() |
---|
[2567] | 56 | os.rename(q_name, q_path) |
---|
[2563] | 57 | |
---|
| 58 | |
---|
| 59 | if __name__ == '__main__': |
---|
| 60 | main() |
---|