diff options
author | Michael Elkins <melkins@tislabs.com> | 2012-02-07 19:10:28 +0000 |
---|---|---|
committer | Michael Elkins <melkins@tislabs.com> | 2012-02-07 19:10:28 +0000 |
commit | d3dc1dfcb5e183e86504397e5c09e88db278461c (patch) | |
tree | 53cb33d46fa8ff61893572c534e85f04932b14de | |
parent | 72cb26e5366996b562ceb785a5dc59ebaf251a3b (diff) |
remove deprecated web portal scripts
svn path=/branches/tk161/; revision=4310
-rw-r--r-- | rpkid/Makefile.in | 12 | ||||
-rw-r--r-- | rpkid/portal-gui/scripts/adduser.py | 86 | ||||
-rw-r--r-- | rpkid/portal-gui/scripts/list_resources.py | 200 | ||||
-rwxr-xr-x | rpkid/portal-gui/scripts/load_csv.py | 143 | ||||
-rwxr-xr-x | rpkid/portal-gui/scripts/roa_check.py | 71 | ||||
-rwxr-xr-x | rpkid/portal-gui/scripts/rpkigui-response.py | 70 |
6 files changed, 1 insertions, 581 deletions
diff --git a/rpkid/Makefile.in b/rpkid/Makefile.in index fb6da2c2..0b18d9a2 100644 --- a/rpkid/Makefile.in +++ b/rpkid/Makefile.in @@ -41,8 +41,7 @@ SETUP_PY = \ POW_SO = rpki/POW/_POW.so SCRIPTS = rpki-sql-backup rpki-sql-setup rpki-start-servers irbe_cli irdbd myrpki \ - pubd rootd rpkic rpkid portal-gui/scripts/rpkigui-load-csv \ - portal-gui/scripts/rpkigui-add-user portal-gui/scripts/rpkigui-response \ + pubd rootd rpkic rpkid \ portal-gui/scripts/rpkigui-rcynic portal-gui/scripts/rpkigui-import-routes AUX_SCRIPTS = @@ -238,18 +237,9 @@ rpkic: rpkic.py rpkid: rpkid.py ${COMPILE_PYTHON} -portal-gui/scripts/rpkigui-load-csv: portal-gui/scripts/load_csv.py - ${COMPILE_DJANGO} - -portal-gui/scripts/rpkigui-add-user: portal-gui/scripts/adduser.py - ${COMPILE_DJANGO} - portal-gui/scripts/rpkigui-rcynic: portal-gui/scripts/rpkigui-rcynic.py ${COMPILE_DJANGO} -portal-gui/scripts/rpkigui-response: portal-gui/scripts/rpkigui-response.py - ${COMPILE_DJANGO} - portal-gui/scripts/rpkigui-import-routes: portal-gui/scripts/rpkigui-import-routes.py ${COMPILE_DJANGO} diff --git a/rpkid/portal-gui/scripts/adduser.py b/rpkid/portal-gui/scripts/adduser.py deleted file mode 100644 index b06c6bc4..00000000 --- a/rpkid/portal-gui/scripts/adduser.py +++ /dev/null @@ -1,86 +0,0 @@ -# $Id$ -# -# Copyright (C) 2010, 2011 SPARTA, Inc. dba Cobham Analytic Solutions -# -# Permission to use, copy, modify, and distribute this software for any -# purpose with or without fee is hereby granted, provided that the above -# copyright notice and this permission notice appear in all copies. -# -# THE SOFTWARE IS PROVIDED "AS IS" AND SPARTA DISCLAIMS ALL WARRANTIES WITH -# REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY -# AND FITNESS. IN NO EVENT SHALL SPARTA BE LIABLE FOR ANY SPECIAL, DIRECT, -# INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM -# LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE -# OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR -# PERFORMANCE OF THIS SOFTWARE. -# -# -# Helper script to quickly set up a new portal-gui user/handle. This script -# is designed to be safe to run multiple times for the same user. -# -# DO NOT EDIT! This script is automatically generated from adduser.py - -from django.contrib.auth.models import User -from rpki.gui.app import settings -from rpki.gui.app.models import Conf - -import getpass -import pwd - -# The username that apache runs as. This is required so that we can chown -# the csv files that the portal-gui needs to write. -web_uid = pwd.getpwnam(settings.WEB_USER)[2] - -if __name__ == '__main__': - if len(sys.argv) < 3: - print >>sys.stderr, 'usage: adduser <username> <user\'s email> <host handle>' - sys.exit(1) - - if os.getuid() != 0: - print >>sys.stderr, 'error: this script must be run as root so it can set file permissions.' - sys.exit(1) - - username = sys.argv[1] - email = sys.argv[2] - host = sys.argv[3] - print 'username=', username, 'email=', email, 'host=', host - - user_set = User.objects.filter(username=username) - if user_set: - print >>sys.stderr, 'user already exists' - user = user_set[0] - else: - print >>sys.stderr, 'creating user' - password = getpass.getpass() - user = User.objects.create_user(username, email, password) - - conf_set = Conf.objects.filter(handle=username) - if conf_set: - conf = conf_set[0] - else: - print >>sys.stderr, 'creating conf' - conf = Conf.objects.create(handle=username) - - # always try to add the user as owner just in case the Conf object was - # created previously by the "list_resources" script - conf.owner.add(user) - - if host != username: - host_set = Conf.objects.filter(handle=host) - if not host_set: - print >>sys.stderr, 'error: Conf object for host %s does not exist!' % host - sys.exit(1) - - conf.host = host_set[0] - else: - print >>sys.stderr, '%s is self-hosted' % username - conf.save() - - myrpki_dir = '%s/%s' % (settings.CONFDIR, username) - print 'myrpki_dir=', myrpki_dir - if not os.path.exists(myrpki_dir): - print 'creating ', myrpki_dir - os.mkdir(myrpki_dir) - os.chown(myrpki_dir, web_uid, -1) - -# vim:sw=4 ts=8 diff --git a/rpkid/portal-gui/scripts/list_resources.py b/rpkid/portal-gui/scripts/list_resources.py deleted file mode 100644 index 13864705..00000000 --- a/rpkid/portal-gui/scripts/list_resources.py +++ /dev/null @@ -1,200 +0,0 @@ -# $Id$ -# -# Copyright (C) 2010, 2011 SPARTA, Inc. dba Cobham Analytic Solutions -# -# Permission to use, copy, modify, and distribute this software for any -# purpose with or without fee is hereby granted, provided that the above -# copyright notice and this permission notice appear in all copies. -# -# THE SOFTWARE IS PROVIDED "AS IS" AND SPARTA DISCLAIMS ALL WARRANTIES WITH -# REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY -# AND FITNESS. IN NO EVENT SHALL SPARTA BE LIABLE FOR ANY SPECIAL, DIRECT, -# INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM -# LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE -# OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR -# PERFORMANCE OF THIS SOFTWARE. -# -# -# This script is reponsible for talking to rpkid and populating the -# portal-gui's sqlite database. It asks rpkid for the list of received -# resources, and the handles of any children. -# -# This script should be run in the directory containing the rpki.conf -# for the handle that is self-hosting rpkid. -# -# Exit values: -# 0 success, no errors -# 1 fatal error -# 2 usage error -# 3 did not receive all <list_received_resources/> responses, try again -# later - -import sys - -import os -os.environ['DJANGO_SETTINGS_MODULE'] = 'rpki.gui.settings' - -import getopt -from datetime import datetime, timedelta -from os.path import basename - -import rpki.config, rpki.left_right, rpki.resource_set -from rpki.gui.app import models, glue - -verbose = False -version = '$Id$' - -def query_rpkid(): - """ - Fetch our received resources from the local rpkid using the rpki.conf - in the current directory. - """ - cfg = rpki.config.parser(section='myrpki') - call_rpkid = glue.build_rpkid_caller(cfg, verbose) - - if verbose: - print 'retrieving the list of <self/> handles served by this rpkid' - rpkid_reply = call_rpkid(rpki.left_right.self_elt.make_pdu(action="list")) - - # retrieve info about each handle - pdus = [] - handles = [] - for h in rpkid_reply: - assert isinstance(h, rpki.left_right.self_elt) - if verbose: - print 'adding handle %s to query' % (h.self_handle,) - # keep a list of the handles served by rpkid so that we may check that - # all expected responses are received. - handles.append(h.self_handle) - pdus.extend( - [rpki.left_right.child_elt.make_pdu(action="list", self_handle=h.self_handle), - rpki.left_right.list_received_resources_elt.make_pdu(self_handle=h.self_handle) - #rpki.left_right.parent_elt.make_pdu(action="list", tag="parents", self_handle=handle), - #rpki.left_right.list_roa_requests_elt.make_pdu(tag='roas', self_handle=handle), - ]) - - if verbose: - print 'querying for children and resources' - return handles, call_rpkid(*pdus) - -def usage(rc): - print 'usage: %s [ -hvV ] [ --help ] [ --verbose ] [ --version ]' % basename(sys.argv[0],) - sys.exit(rc) - -try: - opts, args = getopt.getopt(sys.argv[1:], 'hvV', [ 'help', 'verbose', 'version']) -except getopt.GetoptError, err: - print str(err) - usage(2) - -for o,a in opts: - if o in ('-h', '--help'): - usage(0) - elif o in ('-v', '--verbose'): - verbose = True - elif o in ('-V', '--version'): - print basename(sys.argv[0]), version - sys.exit(0) - -handles, pdus = query_rpkid() -seen = set() # which handles we got <list_received_resources/> responses -for pdu in pdus: - conf_set = models.Conf.objects.filter(handle=pdu.self_handle) - if conf_set.count(): - conf = conf_set[0] - else: - if verbose: - print 'creating new conf for %s' % (pdu.self_handle,) - conf = models.Conf.objects.create(handle=pdu.self_handle) - - #if isinstance(pdu, rpki.left_right.parent_elt): -# print x.parent_handle, x.sia_base, x.sender_name, x.recipient_name, \ -# x.peer_contact_uri - if isinstance(pdu, rpki.left_right.child_elt): - # have we seen this child before? - child_set = conf.children.filter(handle=pdu.child_handle) - if not child_set: - if verbose: - print 'creating new child %s' % (pdu.child_handle,) - # default to 1 year. no easy way to query irdb for the - # current value. - valid_until = datetime.now() + timedelta(days=365) - child = models.Child(conf=conf, handle=pdu.child_handle, - valid_until=valid_until) - child.save() - #elif isinstance(x, rpki.left_right.list_roa_requests_elt): - # print x.asn, x.ipv4, x.ipv6 - elif isinstance(pdu, rpki.left_right.list_received_resources_elt): - # keep track of handles we got replies for - seen.add(pdu.self_handle) - # have we seen this parent before? - parent_set = conf.parents.filter(handle=pdu.parent_handle) - if not parent_set: - if verbose: - print 'creating new parent %s' % (pdu.parent_handle,) - parent = models.Parent(conf=conf, handle=pdu.parent_handle) - parent.save() - else: - parent = parent_set[0] - - not_before = datetime.strptime(pdu.notBefore, "%Y-%m-%dT%H:%M:%SZ") - not_after = datetime.strptime(pdu.notAfter, "%Y-%m-%dT%H:%M:%SZ") - - # have we seen this resource cert before? - cert_set = parent.resources.filter(uri=pdu.uri) - if cert_set.count() == 0: - cert = models.ResourceCert(uri=pdu.uri, parent=parent, - not_before=not_before, not_after=not_after) - else: - cert = cert_set[0] - # update timestamps since it could have been modified - cert.not_before = not_before - cert.not_after = not_after - cert.save() - - for asn in rpki.resource_set.resource_set_as(pdu.asn): - # see if this resource is already part of the cert - if cert.asn.filter(lo=asn.min, hi=asn.max).count() == 0: - # ensure this range wasn't seen from another of our parents - for v in models.Asn.objects.filter(lo=asn.min, hi=asn.max): - # determine if resource is delegated from another parent - if v.from_cert.filter(parent__in=conf.parents.all()).count(): - cert.asn.add(v) - break - else: - if verbose: - print 'adding AS %s' % (asn,) - cert.asn.create(lo=asn.min, hi=asn.max) - cert.save() - - # IPv4/6 - not separated in the django db - def add_missing_address(addr_set): - for ip in addr_set: - lo=str(ip.min) - hi=str(ip.max) - if cert.address_range.filter(lo=lo, hi=hi).count() == 0: - # ensure that this range wasn't previously seen from another of our parents - for v in models.AddressRange.objects.filter(lo=lo, hi=hi): - # determine if this resource is delegated from another parent as well - if v.from_cert.filter(parent__in=conf.parents.all()).count(): - cert.address_range.add(v) - break - else: - if verbose: - print 'adding address range %s' % (ip,) - cert.address_range.create(lo=lo, hi=hi) - cert.save() - - add_missing_address(rpki.resource_set.resource_set_ipv4(pdu.ipv4)) - add_missing_address(rpki.resource_set.resource_set_ipv6(pdu.ipv6)) - -# verify that we got responses for all expected handles -for h in handles: - if h not in seen: - if verbose: - print 'warning: did not receive response for handle %s' % (h,) - sys.exit(3) - -sys.exit(0) # success - -# vim:sw=4 expandtab ts=4 diff --git a/rpkid/portal-gui/scripts/load_csv.py b/rpkid/portal-gui/scripts/load_csv.py deleted file mode 100755 index 9d4fc1ac..00000000 --- a/rpkid/portal-gui/scripts/load_csv.py +++ /dev/null @@ -1,143 +0,0 @@ -# $Id$ -# -# Copyright (C) 2010, 2011 SPARTA, Inc. dba Cobham Analytic Solutions -# -# Permission to use, copy, modify, and distribute this software for any -# purpose with or without fee is hereby granted, provided that the above -# copyright notice and this permission notice appear in all copies. -# -# THE SOFTWARE IS PROVIDED "AS IS" AND SPARTA DISCLAIMS ALL WARRANTIES WITH -# REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY -# AND FITNESS. IN NO EVENT SHALL SPARTA BE LIABLE FOR ANY SPECIAL, DIRECT, -# INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM -# LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE -# OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR -# PERFORMANCE OF THIS SOFTWARE. -# -# -# Helper script to load existing data from csv into the Django DB. -# Primarly useful for the initial load, as the GUI does not sync changes -# made directly to the csv files back into the database. -# -# This script should be run from the directory containing the rpki.conf -# for the handle you are loading data -# - -import csv -import socket # for socket.error - -import rpki.resource_set, rpki.ipaddrs -from rpki.myrpki import csv_reader -from rpki.gui.app import models -from rpki.gui.app.views import add_roa_requests - -cfg = rpki.config.parser(section='myrpki') -handle = cfg.get('handle') -asn_csv = cfg.get('asn_csv') -prefix_csv = cfg.get('prefix_csv') -roa_csv = cfg.get('roa_csv') - -print 'processing csv files for resource handle', handle - -conf = models.Conf.objects.get(handle=handle) - -class RangeError(Exception): - """ - Problem with ASN range or address range. - """ - -# every parent has a favorite -def best_child(address_range, parent, parent_range): - '''Return the child address range that is the closest match, or - returns the arguments if no children.''' - if address_range == parent_range: - return (parent, parent_range) - for q in list(parent.children.all()): # force strict evaluation - t = q.as_resource_range() - if t.min <= address_range.min and t.max >= address_range.max: - return best_child(address_range, q, t) - # check for overlap - if t.min <= address_range.min <= t.max or t.min <= address_range.max <= t.max: - raise RangeError, \ - 'can not handle overlapping ranges: %s and %s' % (address_range, t) - return parent, parent_range - -def get_or_create_prefix(address_range): - '''Returns a AddressRange object for the resource_range_ip specified - as an argument. If no match is found, a new AddressRange object is - created as a child of the best matching received resource.''' - - # get all resources from our parents - prefix_set = models.AddressRange.objects.filter( - from_cert__parent__in=conf.parents.all()) - - # gross, since we store the address ranges as strings in the django - # db, we can't use the normal __lte and __gte filters, so we get to - # do it in python instead. - for prefix in prefix_set: - prefix_range = prefix.as_resource_range() - if (prefix_range.min <= address_range.min and - prefix_range.max >= address_range.max): - # there should only ever be a single matching prefix - break - else: - raise RangeError, '%s does not match any received address range.' % ( - address_range,) - - # find the best match among the children + grandchildren - prefix, prefix_range = best_child(address_range, prefix, prefix_range) - - print 'best match for %s is %s' % (address_range, prefix) - if prefix_range.min != address_range.min or prefix_range.max != address_range.max: - # create suballocation - print 'creating new range' - prefix = models.AddressRange.objects.create(lo=str(address_range.min), - hi=str(address_range.max), parent=prefix) - return prefix - -def get_or_create_asn(asn): - asn_set = models.Asn.objects.filter(lo__lte=asn.min, hi__gte=asn.max, - from_cert__parent__in=conf.parents.all()) - if not asn_set: - raise RangeError, '%s does not match any received AS range' % (asn,) - best = best_child(asn, asn_set[0], asn_set[0].as_resource_range())[0] - print 'best match for %s is %s' % (asn, best) - if best.lo != asn.min or best.hi != asn.max: - best = models.Asn.objects.create(lo=asn.min, hi=asn.max, parent=best) - return best - -def do_asns(): - print 'processing', asn_csv - for child_handle, asn in csv_reader(asn_csv, columns=2): - asn_range = rpki.resource_set.resource_range_as.parse_str(asn) - child = conf.children.get(handle=child_handle) - asn = get_or_create_asn(asn_range) - child.asn.add(asn) - -def do_prefixes(): - print 'processing', prefix_csv - for child_handle, prefix in csv_reader(prefix_csv, columns=2): - child = conf.children.get(handle=child_handle) - try: - rs = rpki.resource_set.resource_range_ipv4.parse_str(prefix) - except ValueError, err: - rs = rpki.resource_set.resource_range_ipv6.parse_str(prefix) - obj = get_or_create_prefix(rs) - obj.allocated = child - obj.save() - -def do_roas(): - print 'processing', roa_csv - for prefix, asn, group in csv_reader(roa_csv, columns=3): - try: - rs = rpki.resource_set.roa_prefix_ipv4.parse_str(prefix) - except ValueError, err: - rs = rpki.resource_set.roa_prefix_ipv6.parse_str(prefix) - - print str(rs.min()), str(rs.max()), rs.max_prefixlen - obj = get_or_create_prefix(rs.to_resource_range()) - add_roa_requests(conf, obj, [int(asn)], rs.max_prefixlen) - -do_asns() -do_prefixes() -do_roas() diff --git a/rpkid/portal-gui/scripts/roa_check.py b/rpkid/portal-gui/scripts/roa_check.py deleted file mode 100755 index c280d935..00000000 --- a/rpkid/portal-gui/scripts/roa_check.py +++ /dev/null @@ -1,71 +0,0 @@ -#!/usr/bin/env python -# $Id$ -# -# Runs through all the published ROAs and updates the Django DB with the -# current active status of each defined ROA. -# - -import socket - -from rcynic_output_iterator import rcynic_xml_iterator, rcynic_roa -from rpki.resource_set import resource_set_ipv4, resource_set_ipv6 -from rpki.resource_set import roa_prefix_set_ipv4, roa_prefix_set_ipv6 -from rpki.resource_set import resource_range_ipv4, resource_range_ipv6 -from rpki.ipaddrs import v4addr, v6addr - -from rpki.gui.app.models import Roa - -# build up a list of all the authenticated roa's using the asn as the key -roaiter = rcynic_xml_iterator( - rcynic_root='/home/melkins/rcynic/rcynic-data/', - xml_file='/home/melkins/rcynic/rcynic.xml') - -# key is an ASN -# each element is a tuple of (resource_set_ipv4, resource_set_ipv6) -roaauth = {} - -for roa in roaiter: - if isinstance(roa, rcynic_roa): - k = roa.asID - if not roaauth.has_key(k): - v = [resource_set_ipv4(), resource_set_ipv6()] - roaauth[k] = v - else: - v = roaauth[k] - for pfx in roa.prefix_sets: - if isinstance(pfx, roa_prefix_set_ipv4): - v[0] = v[0].union(pfx.to_resource_set()) - elif isinstance(pfx, roa_prefix_set_ipv6): - v[1] = v[1].union(pfx.to_resource_set()) - -#for k, v in roaauth.iteritems(): -# print 'asn %d : prefixes %s' % (k, ' '.join(map(str,v))) - -# run through all the ROA's in the GUI's database -for roa in Roa.objects.all(): - k = int(roa.asn) - valid = False - if roaauth.has_key(k): - # ensure that all prefixes listed in the roa are present - # we convert the list of prefixes into prefix sets and use the - # resource_set class to perform set comparisons - ipv4_set = resource_set_ipv4() - ipv6_set = resource_set_ipv6() - for pfx in roa.prefix.all(): - # IP addresses are just stored as strings in the sqlite db - try: - ipv4_set.append(resource_range_ipv4(v4addr(str(pfx.lo)), v4addr(str(pfx.hi)))) - except socket.error: - ipv6_set.append(resource_range_ipv6(v6addr(str(pfx.lo)), v6addr(str(pfx.hi)))) - r = roaauth[k] - if ipv4_set.issubset(r[0]) and ipv6_set.issubset(r[1]): - valid = True - if valid: - if not roa.active: - roa.active = True - roa.save() - else: - print 'roa for asn %s is not valid' % (roa.asn, ) - if roa.active: - roa.active = False - roa.save() diff --git a/rpkid/portal-gui/scripts/rpkigui-response.py b/rpkid/portal-gui/scripts/rpkigui-response.py deleted file mode 100755 index 9b150c51..00000000 --- a/rpkid/portal-gui/scripts/rpkigui-response.py +++ /dev/null @@ -1,70 +0,0 @@ -# $Id$ -# Copyright (C) 2011 SPARTA, Inc. dba Cobham Analytic Solutions -# -# Permission to use, copy, modify, and distribute this software for any -# purpose with or without fee is hereby granted, provided that the above -# copyright notice and this permission notice appear in all copies. -# -# THE SOFTWARE IS PROVIDED "AS IS" AND SPARTA DISCLAIMS ALL WARRANTIES WITH -# REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY -# AND FITNESS. IN NO EVENT SHALL SPARTA BE LIABLE FOR ANY SPECIAL, DIRECT, -# INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM -# LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE -# OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR -# PERFORMANCE OF THIS SOFTWARE. -# -# -# Helper script for use on the server side when using rpkidemo. -# Takes a xml result from either configure_parent or -# configure_publication_client and places it in the portal gui -# outbox with the appropriate rfc822 header fields. - -import os -os.environ['DJANGO_SETTINGS_MODULE'] = 'rpki.gui.settings' - -import sys -import pwd -import email.message, email.utils, mailbox -from django.conf import settings - -if len(sys.argv) < 4: - sys.stderr.write("""usage: rpkigui-response <target-handle> <response-type> <xml-response-file> - -<target-handle> the handle for the rpkidemo user to which this - response should be sent - -<response-type> 'parent' for a configure_child response, or - 'repository' for a configure_publication_client - response - -<xml-response-file> the file containing the xml response for a - configure_child or configure_publication_client - command -""") - - sys.exit(0) - -class InvalidResponseType(Exception): - """ - Invalid response type. - """ - -request_type = sys.argv[2] -if not request_type in ('parent', 'repository'): - raise InvalidResponseType, 'invalid response type: %s' % request_type - -# make sure apache process can manipulate the outbox! -os.setuid(pwd.getpwnam(settings.WEB_USER)[2]) - -msg = email.message.Message() -msg['X-rpki-self-handle'] = sys.argv[1] -msg['X-rpki-type'] = request_type -msg['Date'] = email.utils.formatdate() -msg['Message-ID'] = email.utils.make_msgid() -msg.set_type('application/x-rpki-setup') -msg.set_payload(open(sys.argv[3]).read()) - -box = mailbox.Maildir(settings.OUTBOX) -box.add(msg) - -# vim:sw=4 ts=8 expandtab |