1 files changed, 0 insertions, 142 deletions
diff --git a/rpki/left_right.py b/rpki/left_right.py
index 09d8a5ca..653a2eaf 100644
--- a/rpki/left_right.py
+++ b/rpki/left_right.py
@@ -1373,100 +1373,6 @@ class list_ee_certificate_requests_elt(rpki.xml_utils.base_elt, left_right_names
       elt.set("valid_until", self.valid_until.toXMLtime())
     return elt
 
-class list_published_objects_elt(rpki.xml_utils.text_elt, left_right_namespace):
-  """
-  <list_published_objects/> element.
-  """
-
-  element_name = "list_published_objects"
-  attributes = ("self_handle", "tag", "uri", "child_handle")
-  text_attribute = "obj"
-
-  obj = None
-  child_handle = None
-
-  def __repr__(self):
-    return rpki.log.log_repr(self, self.self_handle, self.child_handle, self.uri)
-
-  def serve_dispatch(self, r_msg, cb, eb):
-    """
-    Handle a <list_published_objects/> query.  The method name is a
-    misnomer here, there's no action attribute and no dispatch, we
-    just dump every published object for the specified <self/> and return.
-    """
-
-    for parent in self_elt.serve_fetch_handle(self.gctx, None, self.self_handle).parents:
-      for ca in parent.cas:
-        ca_detail = ca.active_ca_detail
-        if ca_detail is not None:
-          r_msg.append(self.make_reply(ca_detail.crl_uri, ca_detail.latest_crl))
-          r_msg.append(self.make_reply(ca_detail.manifest_uri, ca_detail.latest_manifest))
-          r_msg.extend(self.make_reply(c.uri, c.cert, c.child.child_handle)
-                       for c in ca_detail.child_certs)
-          r_msg.extend(self.make_reply(r.uri, r.roa)
-                       for r in ca_detail.roas if r.roa is not None)
-          r_msg.extend(self.make_reply(g.uri, g.ghostbuster)
-                       for g in ca_detail.ghostbusters)
-          r_msg.extend(self.make_reply(c.uri, c.cert)
-                       for c in ca_detail.ee_certificates)
-    cb()
-
-  def make_reply(self, uri, obj, child_handle = None):
-    """
-    Generate one reply PDU.
-    """
-
-    r_pdu = self.make_pdu(tag = self.tag, self_handle = self.self_handle,
-                          uri = uri, child_handle = child_handle)
-    r_pdu.obj = obj.get_Base64()
-    return r_pdu
-
-class list_received_resources_elt(rpki.xml_utils.base_elt, left_right_namespace):
-  """
-  <list_received_resources/> element.
-  """
-
-  element_name = "list_received_resources"
-  attributes = ("self_handle", "tag", "parent_handle",
-                "notBefore", "notAfter", "uri", "sia_uri", "aia_uri", "asn", "ipv4", "ipv6")
-
-  def __repr__(self):
-    return rpki.log.log_repr(self, self.self_handle, self.parent_handle, self.uri, self.notAfter)
-
-  def serve_dispatch(self, r_msg, cb, eb):
-    """
-    Handle a <list_received_resources/> query.  The method name is a
-    misnomer here, there's no action attribute and no dispatch, we
-    just dump a bunch of data about every certificate issued to us by
-    one of our parents, then return.
-    """
-
-    for parent in self_elt.serve_fetch_handle(self.gctx, None, self.self_handle).parents:
-      for ca in parent.cas:
-        ca_detail = ca.active_ca_detail
-        if ca_detail is not None and ca_detail.latest_ca_cert is not None:
-          r_msg.append(self.make_reply(parent.parent_handle, ca_detail.ca_cert_uri, ca_detail.latest_ca_cert))
-    cb()
-
-  def make_reply(self, parent_handle, uri, cert):
-    """
-    Generate one reply PDU.
-    """
-
-    resources = cert.get_3779resources()
-    return self.make_pdu(
-      tag = self.tag,
-      self_handle = self.self_handle,
-      parent_handle = parent_handle,
-      notBefore = str(cert.getNotBefore()),
-      notAfter = str(cert.getNotAfter()),
-      uri = uri,
-      sia_uri = cert.get_sia_directory_uri(),
-      aia_uri = cert.get_aia_uri(),
-      asn = resources.asn,
-      ipv4 = resources.v4,
-      ipv6 = resources.v6)
-
 class report_error_elt(rpki.xml_utils.text_elt, left_right_namespace):
   """
   <report_error/> element.
@@ -1494,54 +1400,6 @@ class report_error_elt(rpki.xml_utils.text_elt, left_right_namespace):
     self.error_text = str(e)
     return self
 
-class msg(rpki.xml_utils.msg, left_right_namespace):
-  """
-  Left-right PDU.
-  """
-
-  ## @var version
-  # Protocol version
-  version = int(rpki.relaxng.left_right.version)
-
-  ## @var pdus
-  # Dispatch table of PDUs for this protocol.
-  pdus = dict((x.element_name, x)
-              for x in (self_elt, child_elt, parent_elt, bsc_elt,
-                        repository_elt, list_resources_elt,
-                        list_roa_requests_elt, list_ghostbuster_requests_elt,
-                        list_ee_certificate_requests_elt,
-                        list_published_objects_elt,
-                        list_received_resources_elt, report_error_elt))
-
-  def serve_top_level(self, gctx, cb):
-    """
-    Serve one msg PDU.
-    """
-
-    r_msg = self.__class__.reply()
-
-    def loop(iterator, q_pdu):
-
-      def fail(e):
-        if not isinstance(e, rpki.exceptions.NotFound):
-          logger.exception("Unhandled exception serving left-right PDU %r", q_pdu)
-        r_msg.append(report_error_elt.from_exception(
-          e, self_handle = q_pdu.self_handle, tag = q_pdu.tag))
-        cb(r_msg)
-
-      try:
-        q_pdu.gctx = gctx
-        q_pdu.serve_dispatch(r_msg, iterator, fail)
-      except (rpki.async.ExitNow, SystemExit):
-        raise
-      except Exception, e:
-        fail(e)
-
-    def done():
-      cb(r_msg)
-
-    rpki.async.iterator(self, loop, done)
-
 
 class cms_msg(rpki.x509.XML_CMS_object):
   """