|
19533
|
1 |
#!/usr/bin/env python
|
|
|
2 |
# -*- coding: Latin-1 -*-
|
|
|
3 |
|
|
|
4 |
"""
|
|
|
5 |
Common services for parsing xhtml.
|
|
|
6 |
"""
|
|
|
7 |
|
|
|
8 |
__all__ = ['TransformerHandler']
|
|
|
9 |
|
|
|
10 |
__author__ = 'Florian Haftmann, florian.haftmann@informatik.tu-muenchen.de'
|
|
|
11 |
__revision__ = '$Id$'
|
|
|
12 |
|
|
|
13 |
from os import path
|
|
|
14 |
import codecs
|
|
|
15 |
import posixpath
|
|
|
16 |
from xml.sax.saxutils import escape
|
|
|
17 |
from xml.sax.saxutils import quoteattr
|
|
|
18 |
from xml.sax import make_parser as makeParser
|
|
|
19 |
from xml.sax.handler import ContentHandler
|
|
|
20 |
from xml.sax.handler import EntityResolver
|
|
|
21 |
from xml.sax.xmlreader import AttributesImpl as Attributes
|
|
|
22 |
from xml.sax import SAXException
|
|
|
23 |
from xml.sax import SAXParseException
|
|
|
24 |
|
|
|
25 |
nbsp = unichr(160)
|
|
|
26 |
|
|
|
27 |
class TransformerHandler(object, ContentHandler, EntityResolver):
|
|
|
28 |
|
|
|
29 |
def __init__(self, out, encoding, dtd):
|
|
|
30 |
|
|
|
31 |
ContentHandler.__init__(self)
|
|
|
32 |
self._out = codecs.getwriter(encoding)(out)
|
|
|
33 |
self._encoding = encoding
|
|
|
34 |
self._dtd = dtd
|
|
|
35 |
self._ns_contexts = [{}] # contains uri -> prefix dicts
|
|
|
36 |
self._current_context = self._ns_contexts[-1]
|
|
|
37 |
self._undeclared_ns_maps = []
|
|
|
38 |
self._characterBuffer = {}
|
|
|
39 |
self._lastStart = False
|
|
|
40 |
self._currentXPath = []
|
|
|
41 |
self._init = False
|
|
|
42 |
|
|
|
43 |
def closeLastStart(self):
|
|
|
44 |
|
|
|
45 |
if self._lastStart:
|
|
|
46 |
self._out.write(u'>')
|
|
|
47 |
self._lastStart = False
|
|
|
48 |
|
|
|
49 |
def currentContent(self):
|
|
|
50 |
|
|
|
51 |
return u"".join(self._characterBuffer)
|
|
|
52 |
|
|
|
53 |
def flushCharacterBuffer(self):
|
|
|
54 |
|
|
|
55 |
content = escape(self.currentContent())
|
|
|
56 |
self._out.write(content)
|
|
|
57 |
self._characterBuffer = []
|
|
|
58 |
|
|
|
59 |
def startDocument(self):
|
|
|
60 |
|
|
|
61 |
if not self._init:
|
|
|
62 |
if self._encoding.upper() != 'UTF-8':
|
|
|
63 |
self._out.write(u'<?xml version="1.0" encoding="%s"?>\n' %
|
|
|
64 |
self._encoding)
|
|
|
65 |
else:
|
|
|
66 |
self._out.write(u'<?xml version="1.0"?>\n')
|
|
|
67 |
self._init = True
|
|
|
68 |
|
|
|
69 |
def startPrefixMapping(self, prefix, uri):
|
|
|
70 |
|
|
|
71 |
self._ns_contexts.append(self._current_context.copy())
|
|
|
72 |
self._current_context[uri] = prefix
|
|
|
73 |
self._undeclared_ns_maps.append((prefix, uri))
|
|
|
74 |
|
|
|
75 |
def endPrefixMapping(self, prefix):
|
|
|
76 |
|
|
|
77 |
self._current_context = self._ns_contexts[-1]
|
|
|
78 |
del self._ns_contexts[-1]
|
|
|
79 |
|
|
|
80 |
def startElement(self, name, attrs):
|
|
|
81 |
|
|
|
82 |
self.closeLastStart()
|
|
|
83 |
self.flushCharacterBuffer()
|
|
|
84 |
self._out.write(u'<' + name)
|
|
|
85 |
for (key, value) in attrs.items():
|
|
|
86 |
self._out.write(u' %s=%s' % (key, quoteattr(value)))
|
|
|
87 |
self._currentXPath.append(name)
|
|
|
88 |
self._lastStart = True
|
|
|
89 |
|
|
|
90 |
def endElement(self, name):
|
|
|
91 |
|
|
|
92 |
self.flushCharacterBuffer()
|
|
|
93 |
if self._lastStart:
|
|
|
94 |
self._out.write(u'/>')
|
|
|
95 |
self._lastStart = False
|
|
|
96 |
else:
|
|
|
97 |
self._out.write('</%s>' % name)
|
|
|
98 |
self._currentXPath.pop()
|
|
|
99 |
|
|
|
100 |
def startElementNS(self, name, qname, attrs):
|
|
|
101 |
|
|
|
102 |
self.closeLastStart()
|
|
|
103 |
self.flushCharacterBuffer()
|
|
|
104 |
if name[0] is None:
|
|
|
105 |
# if the name was not namespace-scoped, use the unqualified part
|
|
|
106 |
name = name[1]
|
|
|
107 |
else:
|
|
|
108 |
# else try to restore the original prefix from the namespace
|
|
|
109 |
name = self._current_context[name[0]] + u":" + name[1]
|
|
|
110 |
self._out.write(u'<' + name)
|
|
|
111 |
|
|
|
112 |
for pair in self._undeclared_ns_maps:
|
|
|
113 |
self._out.write(u' xmlns:%s="%s"' % pair)
|
|
|
114 |
self._undeclared_ns_maps = []
|
|
|
115 |
|
|
|
116 |
for (name, value) in attrs.items():
|
|
|
117 |
name = self._current_context[name[0]] + ":" + name[1]
|
|
|
118 |
self._out.write(' %s=%s' % (name, quoteattr(value)))
|
|
|
119 |
self._out.write('>')
|
|
|
120 |
self._currentXPath.append(name)
|
|
|
121 |
|
|
|
122 |
def endElementNS(self, name, qname):
|
|
|
123 |
|
|
|
124 |
self.flushCharacterBuffer()
|
|
|
125 |
if name[0] is None:
|
|
|
126 |
name = name[1]
|
|
|
127 |
else:
|
|
|
128 |
name = self._current_context[name[0]] + u":" + name[1]
|
|
|
129 |
if self._lastStart:
|
|
|
130 |
self._out.write(u'/>')
|
|
|
131 |
self._lastStart = False
|
|
|
132 |
else:
|
|
|
133 |
self._out.write(u'</%s>' % name)
|
|
|
134 |
self._currentXPath.pop()
|
|
|
135 |
|
|
|
136 |
def characters(self, content):
|
|
|
137 |
|
|
|
138 |
self.closeLastStart()
|
|
|
139 |
self._characterBuffer.append(content)
|
|
|
140 |
|
|
|
141 |
def ignorableWhitespace(self, content):
|
|
|
142 |
|
|
|
143 |
self.closeLastStart()
|
|
|
144 |
self.flushCharacterBuffer()
|
|
|
145 |
self._out.write(content)
|
|
|
146 |
|
|
|
147 |
def resolveEntity(self, publicId, systemId):
|
|
|
148 |
|
|
|
149 |
loc, name = posixpath.split(systemId)
|
|
|
150 |
if loc == u"http://www.w3.org/TR/xhtml1/DTD" or loc == u"":
|
|
|
151 |
systemId = path.abspath(path.join(self._dtd, name))
|
|
|
152 |
return EntityResolver.resolveEntity(self, publicId, systemId)
|
|
|
153 |
|
|
|
154 |
def processingInstruction(self, target, data):
|
|
|
155 |
|
|
|
156 |
raise Exception("no handler defined for processing instructions")
|
|
|
157 |
|
|
|
158 |
def parseWithER(istream, handler):
|
|
|
159 |
|
|
|
160 |
parser = makeParser()
|
|
|
161 |
parser.setContentHandler(handler)
|
|
|
162 |
parser.setEntityResolver(handler)
|
|
|
163 |
parser.parse(istream)
|