You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 

1221 lines
40 KiB

  1. """vobject module for reading vCard and vCalendar files."""
  2. from __future__ import print_function
  3. import copy
  4. import codecs
  5. import logging
  6. import re
  7. import six
  8. import sys
  9. # ------------------------------------ Python 2/3 compatibility challenges ----
  10. # Python 3 no longer has a basestring type, so....
  11. try:
  12. basestring = basestring
  13. except NameError:
  14. basestring = (str, bytes)
  15. # One more problem ... in python2 the str operator breaks on unicode
  16. # objects containing non-ascii characters
  17. try:
  18. unicode
  19. def str_(s):
  20. """
  21. Return byte string with correct encoding
  22. """
  23. if type(s) == unicode:
  24. return s.encode('utf-8')
  25. else:
  26. return str(s)
  27. except NameError:
  28. def str_(s):
  29. """
  30. Return string
  31. """
  32. return s
  33. if not isinstance(b'', type('')):
  34. unicode_type = str
  35. else:
  36. unicode_type = unicode # noqa
  37. def to_unicode(value):
  38. """Converts a string argument to a unicode string.
  39. If the argument is already a unicode string, it is returned
  40. unchanged. Otherwise it must be a byte string and is decoded as utf8.
  41. """
  42. if isinstance(value, unicode_type):
  43. return value
  44. return value.decode('utf-8')
  45. def to_basestring(s):
  46. """Converts a string argument to a byte string.
  47. If the argument is already a byte string, it is returned unchanged.
  48. Otherwise it must be a unicode string and is encoded as utf8.
  49. """
  50. if isinstance(s, bytes):
  51. return s
  52. return s.encode('utf-8')
  53. # ------------------------------------ Logging ---------------------------------
  54. logger = logging.getLogger(__name__)
  55. if not logging.getLogger().handlers:
  56. handler = logging.StreamHandler()
  57. formatter = logging.Formatter('%(name)s %(levelname)s %(message)s')
  58. handler.setFormatter(formatter)
  59. logger.addHandler(handler)
  60. logger.setLevel(logging.ERROR) # Log errors
  61. DEBUG = False # Don't waste time on debug calls
  62. # ----------------------------------- Constants --------------------------------
  63. CR = '\r'
  64. LF = '\n'
  65. CRLF = CR + LF
  66. SPACE = ' '
  67. TAB = '\t'
  68. SPACEORTAB = SPACE + TAB
  69. # --------------------------------- Main classes -------------------------------
  70. class VBase(object):
  71. """
  72. Base class for ContentLine and Component.
  73. @ivar behavior:
  74. The Behavior class associated with this object, which controls
  75. validation, transformations, and encoding.
  76. @ivar parentBehavior:
  77. The object's parent's behavior, or None if no behaviored parent exists.
  78. @ivar isNative:
  79. Boolean describing whether this component is a Native instance.
  80. @ivar group:
  81. An optional group prefix, should be used only to indicate sort order in
  82. vCards, according to spec.
  83. Current spec: 4.0 (http://tools.ietf.org/html/rfc6350)
  84. """
  85. def __init__(self, group=None, *args, **kwds):
  86. super(VBase, self).__init__(*args, **kwds)
  87. self.group = group
  88. self.behavior = None
  89. self.parentBehavior = None
  90. self.isNative = False
  91. def copy(self, copyit):
  92. self.group = copyit.group
  93. self.behavior = copyit.behavior
  94. self.parentBehavior = copyit.parentBehavior
  95. self.isNative = copyit.isNative
  96. def validate(self, *args, **kwds):
  97. """
  98. Call the behavior's validate method, or return True.
  99. """
  100. if self.behavior:
  101. return self.behavior.validate(self, *args, **kwds)
  102. return True
  103. def getChildren(self):
  104. """
  105. Return an iterable containing the contents of the object.
  106. """
  107. return []
  108. def clearBehavior(self, cascade=True):
  109. """
  110. Set behavior to None. Do for all descendants if cascading.
  111. """
  112. self.behavior = None
  113. if cascade:
  114. self.transformChildrenFromNative()
  115. def autoBehavior(self, cascade=False):
  116. """
  117. Set behavior if name is in self.parentBehavior.knownChildren.
  118. If cascade is True, unset behavior and parentBehavior for all
  119. descendants, then recalculate behavior and parentBehavior.
  120. """
  121. parentBehavior = self.parentBehavior
  122. if parentBehavior is not None:
  123. knownChildTup = parentBehavior.knownChildren.get(self.name, None)
  124. if knownChildTup is not None:
  125. behavior = getBehavior(self.name, knownChildTup[2])
  126. if behavior is not None:
  127. self.setBehavior(behavior, cascade)
  128. if isinstance(self, ContentLine) and self.encoded:
  129. self.behavior.decode(self)
  130. elif isinstance(self, ContentLine):
  131. self.behavior = parentBehavior.defaultBehavior
  132. if self.encoded and self.behavior:
  133. self.behavior.decode(self)
  134. def setBehavior(self, behavior, cascade=True):
  135. """
  136. Set behavior. If cascade is True, autoBehavior all descendants.
  137. """
  138. self.behavior = behavior
  139. if cascade:
  140. for obj in self.getChildren():
  141. obj.parentBehavior = behavior
  142. obj.autoBehavior(True)
  143. def transformToNative(self):
  144. """
  145. Transform this object into a custom VBase subclass.
  146. transformToNative should always return a representation of this object.
  147. It may do so by modifying self in place then returning self, or by
  148. creating a new object.
  149. """
  150. if self.isNative or not self.behavior or not self.behavior.hasNative:
  151. return self
  152. else:
  153. self_orig = copy.copy(self)
  154. try:
  155. return self.behavior.transformToNative(self)
  156. except Exception as e:
  157. # wrap errors in transformation in a ParseError
  158. lineNumber = getattr(self, 'lineNumber', None)
  159. if isinstance(e, ParseError):
  160. if lineNumber is not None:
  161. e.lineNumber = lineNumber
  162. raise
  163. else:
  164. msg = "In transformToNative, unhandled exception on line {0}: {1}: {2}"
  165. msg = msg.format(lineNumber, sys.exc_info()[0], sys.exc_info()[1])
  166. msg = msg + " (" + str(self_orig) + ")"
  167. raise ParseError(msg, lineNumber)
  168. def transformFromNative(self):
  169. """
  170. Return self transformed into a ContentLine or Component if needed.
  171. May have side effects. If it does, transformFromNative and
  172. transformToNative MUST have perfectly inverse side effects. Allowing
  173. such side effects is convenient for objects whose transformations only
  174. change a few attributes.
  175. Note that it isn't always possible for transformFromNative to be a
  176. perfect inverse of transformToNative, in such cases transformFromNative
  177. should return a new object, not self after modifications.
  178. """
  179. if self.isNative and self.behavior and self.behavior.hasNative:
  180. try:
  181. return self.behavior.transformFromNative(self)
  182. except Exception as e:
  183. # wrap errors in transformation in a NativeError
  184. lineNumber = getattr(self, 'lineNumber', None)
  185. if isinstance(e, NativeError):
  186. if lineNumber is not None:
  187. e.lineNumber = lineNumber
  188. raise
  189. else:
  190. msg = "In transformFromNative, unhandled exception on line {0} {1}: {2}"
  191. msg = msg.format(lineNumber, sys.exc_info()[0], sys.exc_info()[1])
  192. raise NativeError(msg, lineNumber)
  193. else:
  194. return self
  195. def transformChildrenToNative(self):
  196. """
  197. Recursively replace children with their native representation.
  198. """
  199. pass
  200. def transformChildrenFromNative(self, clearBehavior=True):
  201. """
  202. Recursively transform native children to vanilla representations.
  203. """
  204. pass
  205. def serialize(self, buf=None, lineLength=75, validate=True, behavior=None):
  206. """
  207. Serialize to buf if it exists, otherwise return a string.
  208. Use self.behavior.serialize if behavior exists.
  209. """
  210. if not behavior:
  211. behavior = self.behavior
  212. if behavior:
  213. if DEBUG:
  214. logger.debug("serializing {0!s} with behavior {1!s}".format(self.name, behavior))
  215. return behavior.serialize(self, buf, lineLength, validate)
  216. else:
  217. if DEBUG:
  218. logger.debug("serializing {0!s} without behavior".format(self.name))
  219. return defaultSerialize(self, buf, lineLength)
  220. def toVName(name, stripNum=0, upper=False):
  221. """
  222. Turn a Python name into an iCalendar style name,
  223. optionally uppercase and with characters stripped off.
  224. """
  225. if upper:
  226. name = name.upper()
  227. if stripNum != 0:
  228. name = name[:-stripNum]
  229. return name.replace('_', '-')
  230. class ContentLine(VBase):
  231. """
  232. Holds one content line for formats like vCard and vCalendar.
  233. For example::
  234. <SUMMARY{u'param1' : [u'val1'], u'param2' : [u'val2']}Bastille Day Party>
  235. @ivar name:
  236. The uppercased name of the contentline.
  237. @ivar params:
  238. A dictionary of parameters and associated lists of values (the list may
  239. be empty for empty parameters).
  240. @ivar value:
  241. The value of the contentline.
  242. @ivar singletonparams:
  243. A list of parameters for which it's unclear if the string represents the
  244. parameter name or the parameter value. In vCard 2.1, "The value string
  245. can be specified alone in those cases where the value is unambiguous".
  246. This is crazy, but we have to deal with it.
  247. @ivar encoded:
  248. A boolean describing whether the data in the content line is encoded.
  249. Generally, text read from a serialized vCard or vCalendar should be
  250. considered encoded. Data added programmatically should not be encoded.
  251. @ivar lineNumber:
  252. An optional line number associated with the contentline.
  253. """
  254. def __init__(self, name, params, value, group=None, encoded=False,
  255. isNative=False, lineNumber=None, *args, **kwds):
  256. """
  257. Take output from parseLine, convert params list to dictionary.
  258. Group is used as a positional argument to match parseLine's return
  259. """
  260. super(ContentLine, self).__init__(group, *args, **kwds)
  261. self.name = name.upper()
  262. self.encoded = encoded
  263. self.params = {}
  264. self.singletonparams = []
  265. self.isNative = isNative
  266. self.lineNumber = lineNumber
  267. self.value = value
  268. def updateTable(x):
  269. if len(x) == 1:
  270. self.singletonparams += x
  271. else:
  272. paramlist = self.params.setdefault(x[0].upper(), [])
  273. paramlist.extend(x[1:])
  274. list(map(updateTable, params))
  275. qp = False
  276. if 'ENCODING' in self.params:
  277. if 'QUOTED-PRINTABLE' in self.params['ENCODING']:
  278. qp = True
  279. self.params['ENCODING'].remove('QUOTED-PRINTABLE')
  280. if len(self.params['ENCODING']) == 0:
  281. del self.params['ENCODING']
  282. if 'QUOTED-PRINTABLE' in self.singletonparams:
  283. qp = True
  284. self.singletonparams.remove('QUOTED-PRINTABLE')
  285. if qp:
  286. if 'ENCODING' in self.params:
  287. self.value = codecs.decode(self.value.encode("utf-8"), "quoted-printable").decode(self.params['ENCODING'])
  288. else:
  289. if 'CHARSET' in self.params:
  290. self.value = codecs.decode(self.value.encode("utf-8"), "quoted-printable").decode(self.params['CHARSET'][0])
  291. else:
  292. self.value = codecs.decode(self.value.encode("utf-8"), "quoted-printable").decode('utf-8')
  293. @classmethod
  294. def duplicate(clz, copyit):
  295. newcopy = clz('', {}, '')
  296. newcopy.copy(copyit)
  297. return newcopy
  298. def copy(self, copyit):
  299. super(ContentLine, self).copy(copyit)
  300. self.name = copyit.name
  301. self.value = copy.copy(copyit.value)
  302. self.encoded = self.encoded
  303. self.params = copy.copy(copyit.params)
  304. for k, v in self.params.items():
  305. self.params[k] = copy.copy(v)
  306. self.singletonparams = copy.copy(copyit.singletonparams)
  307. self.lineNumber = copyit.lineNumber
  308. def __eq__(self, other):
  309. try:
  310. return (self.name == other.name) and (self.params == other.params) and (self.value == other.value)
  311. except Exception:
  312. return False
  313. def __getattr__(self, name):
  314. """
  315. Make params accessible via self.foo_param or self.foo_paramlist.
  316. Underscores, legal in python variable names, are converted to dashes,
  317. which are legal in IANA tokens.
  318. """
  319. try:
  320. if name.endswith('_param'):
  321. return self.params[toVName(name, 6, True)][0]
  322. elif name.endswith('_paramlist'):
  323. return self.params[toVName(name, 10, True)]
  324. else:
  325. raise AttributeError(name)
  326. except KeyError:
  327. raise AttributeError(name)
  328. def __setattr__(self, name, value):
  329. """
  330. Make params accessible via self.foo_param or self.foo_paramlist.
  331. Underscores, legal in python variable names, are converted to dashes,
  332. which are legal in IANA tokens.
  333. """
  334. if name.endswith('_param'):
  335. if type(value) == list:
  336. self.params[toVName(name, 6, True)] = value
  337. else:
  338. self.params[toVName(name, 6, True)] = [value]
  339. elif name.endswith('_paramlist'):
  340. if type(value) == list:
  341. self.params[toVName(name, 10, True)] = value
  342. else:
  343. raise VObjectError("Parameter list set to a non-list")
  344. else:
  345. prop = getattr(self.__class__, name, None)
  346. if isinstance(prop, property):
  347. prop.fset(self, value)
  348. else:
  349. object.__setattr__(self, name, value)
  350. def __delattr__(self, name):
  351. try:
  352. if name.endswith('_param'):
  353. del self.params[toVName(name, 6, True)]
  354. elif name.endswith('_paramlist'):
  355. del self.params[toVName(name, 10, True)]
  356. else:
  357. object.__delattr__(self, name)
  358. except KeyError:
  359. raise AttributeError(name)
  360. def valueRepr(self):
  361. """
  362. Transform the representation of the value
  363. according to the behavior, if any.
  364. """
  365. v = self.value
  366. if self.behavior:
  367. v = self.behavior.valueRepr(self)
  368. return v
  369. def __str__(self):
  370. try:
  371. return "<{0}{1}{2}>".format(self.name, self.params, self.valueRepr())
  372. except UnicodeEncodeError as e:
  373. return "<{0}{1}{2}>".format(self.name, self.params, self.valueRepr().encode('utf-8'))
  374. def __repr__(self):
  375. return self.__str__()
  376. def __unicode__(self):
  377. return u"<{0}{1}{2}>".format(self.name, self.params, self.valueRepr())
  378. def prettyPrint(self, level=0, tabwidth=3):
  379. pre = ' ' * level * tabwidth
  380. print(pre, self.name + ":", self.valueRepr())
  381. if self.params:
  382. print(pre, "params for ", self.name + ':')
  383. for k in self.params.keys():
  384. print(pre + ' ' * tabwidth, k, self.params[k])
  385. class Component(VBase):
  386. """
  387. A complex property that can contain multiple ContentLines.
  388. For our purposes, a component must start with a BEGIN:xxxx line and end with
  389. END:xxxx, or have a PROFILE:xxx line if a top-level component.
  390. @ivar contents:
  391. A dictionary of lists of Component or ContentLine instances. The keys
  392. are the lowercased names of child ContentLines or Components.
  393. Note that BEGIN and END ContentLines are not included in contents.
  394. @ivar name:
  395. Uppercase string used to represent this Component, i.e VCARD if the
  396. serialized object starts with BEGIN:VCARD.
  397. @ivar useBegin:
  398. A boolean flag determining whether BEGIN: and END: lines should
  399. be serialized.
  400. """
  401. def __init__(self, name=None, *args, **kwds):
  402. super(Component, self).__init__(*args, **kwds)
  403. self.contents = {}
  404. if name:
  405. self.name = name.upper()
  406. self.useBegin = True
  407. else:
  408. self.name = ''
  409. self.useBegin = False
  410. self.autoBehavior()
  411. @classmethod
  412. def duplicate(cls, copyit):
  413. newcopy = cls()
  414. newcopy.copy(copyit)
  415. return newcopy
  416. def copy(self, copyit):
  417. super(Component, self).copy(copyit)
  418. # deep copy of contents
  419. self.contents = {}
  420. for key, lvalue in copyit.contents.items():
  421. newvalue = []
  422. for value in lvalue:
  423. newitem = value.duplicate(value)
  424. newvalue.append(newitem)
  425. self.contents[key] = newvalue
  426. self.name = copyit.name
  427. self.useBegin = copyit.useBegin
  428. def setProfile(self, name):
  429. """
  430. Assign a PROFILE to this unnamed component.
  431. Used by vCard, not by vCalendar.
  432. """
  433. if self.name or self.useBegin:
  434. if self.name == name:
  435. return
  436. raise VObjectError("This component already has a PROFILE or "
  437. "uses BEGIN.")
  438. self.name = name.upper()
  439. def __getattr__(self, name):
  440. """
  441. For convenience, make self.contents directly accessible.
  442. Underscores, legal in python variable names, are converted to dashes,
  443. which are legal in IANA tokens.
  444. """
  445. # if the object is being re-created by pickle, self.contents may not
  446. # be set, don't get into an infinite loop over the issue
  447. if name == 'contents':
  448. return object.__getattribute__(self, name)
  449. try:
  450. if name.endswith('_list'):
  451. return self.contents[toVName(name, 5)]
  452. else:
  453. return self.contents[toVName(name)][0]
  454. except KeyError:
  455. raise AttributeError(name)
  456. normal_attributes = ['contents', 'name', 'behavior', 'parentBehavior', 'group']
  457. def __setattr__(self, name, value):
  458. """
  459. For convenience, make self.contents directly accessible.
  460. Underscores, legal in python variable names, are converted to dashes,
  461. which are legal in IANA tokens.
  462. """
  463. if name not in self.normal_attributes and name.lower() == name:
  464. if type(value) == list:
  465. if name.endswith('_list'):
  466. name = name[:-5]
  467. self.contents[toVName(name)] = value
  468. elif name.endswith('_list'):
  469. raise VObjectError("Component list set to a non-list")
  470. else:
  471. self.contents[toVName(name)] = [value]
  472. else:
  473. prop = getattr(self.__class__, name, None)
  474. if isinstance(prop, property):
  475. prop.fset(self, value)
  476. else:
  477. object.__setattr__(self, name, value)
  478. def __delattr__(self, name):
  479. try:
  480. if name not in self.normal_attributes and name.lower() == name:
  481. if name.endswith('_list'):
  482. del self.contents[toVName(name, 5)]
  483. else:
  484. del self.contents[toVName(name)]
  485. else:
  486. object.__delattr__(self, name)
  487. except KeyError:
  488. raise AttributeError(name)
  489. def getChildValue(self, childName, default=None, childNumber=0):
  490. """
  491. Return a child's value (the first, by default), or None.
  492. """
  493. child = self.contents.get(toVName(childName))
  494. if child is None:
  495. return default
  496. else:
  497. return child[childNumber].value
  498. def add(self, objOrName, group=None):
  499. """
  500. Add objOrName to contents, set behavior if it can be inferred.
  501. If objOrName is a string, create an empty component or line based on
  502. behavior. If no behavior is found for the object, add a ContentLine.
  503. group is an optional prefix to the name of the object (see RFC 2425).
  504. """
  505. if isinstance(objOrName, VBase):
  506. obj = objOrName
  507. if self.behavior:
  508. obj.parentBehavior = self.behavior
  509. obj.autoBehavior(True)
  510. else:
  511. name = objOrName.upper()
  512. try:
  513. id = self.behavior.knownChildren[name][2]
  514. behavior = getBehavior(name, id)
  515. if behavior.isComponent:
  516. obj = Component(name)
  517. else:
  518. obj = ContentLine(name, [], '', group)
  519. obj.parentBehavior = self.behavior
  520. obj.behavior = behavior
  521. obj = obj.transformToNative()
  522. except (KeyError, AttributeError):
  523. obj = ContentLine(objOrName, [], '', group)
  524. if obj.behavior is None and self.behavior is not None:
  525. if isinstance(obj, ContentLine):
  526. obj.behavior = self.behavior.defaultBehavior
  527. self.contents.setdefault(obj.name.lower(), []).append(obj)
  528. return obj
  529. def remove(self, obj):
  530. """
  531. Remove obj from contents.
  532. """
  533. named = self.contents.get(obj.name.lower())
  534. if named:
  535. try:
  536. named.remove(obj)
  537. if len(named) == 0:
  538. del self.contents[obj.name.lower()]
  539. except ValueError:
  540. pass
  541. def getChildren(self):
  542. """
  543. Return an iterable of all children.
  544. """
  545. for objList in self.contents.values():
  546. for obj in objList:
  547. yield obj
  548. def components(self):
  549. """
  550. Return an iterable of all Component children.
  551. """
  552. return (i for i in self.getChildren() if isinstance(i, Component))
  553. def lines(self):
  554. """
  555. Return an iterable of all ContentLine children.
  556. """
  557. return (i for i in self.getChildren() if isinstance(i, ContentLine))
  558. def sortChildKeys(self):
  559. try:
  560. first = [s for s in self.behavior.sortFirst if s in self.contents]
  561. except Exception:
  562. first = []
  563. return first + sorted(k for k in self.contents.keys() if k not in first)
  564. def getSortedChildren(self):
  565. return [obj for k in self.sortChildKeys() for obj in self.contents[k]]
  566. def setBehaviorFromVersionLine(self, versionLine):
  567. """
  568. Set behavior if one matches name, versionLine.value.
  569. """
  570. v = getBehavior(self.name, versionLine.value)
  571. if v:
  572. self.setBehavior(v)
  573. def transformChildrenToNative(self):
  574. """
  575. Recursively replace children with their native representation.
  576. Sort to get dependency order right, like vtimezone before vevent.
  577. """
  578. for childArray in (self.contents[k] for k in self.sortChildKeys()):
  579. for child in childArray:
  580. child = child.transformToNative()
  581. child.transformChildrenToNative()
  582. def transformChildrenFromNative(self, clearBehavior=True):
  583. """
  584. Recursively transform native children to vanilla representations.
  585. """
  586. for childArray in self.contents.values():
  587. for child in childArray:
  588. child = child.transformFromNative()
  589. child.transformChildrenFromNative(clearBehavior)
  590. if clearBehavior:
  591. child.behavior = None
  592. child.parentBehavior = None
  593. def __str__(self):
  594. if self.name:
  595. return "<{0}| {1}>".format(self.name, self.getSortedChildren())
  596. else:
  597. return u'<*unnamed*| {0}>'.format(self.getSortedChildren())
  598. def __repr__(self):
  599. return self.__str__()
  600. def prettyPrint(self, level=0, tabwidth=3):
  601. pre = ' ' * level * tabwidth
  602. print(pre, self.name)
  603. if isinstance(self, Component):
  604. for line in self.getChildren():
  605. line.prettyPrint(level + 1, tabwidth)
  606. class VObjectError(Exception):
  607. def __init__(self, msg, lineNumber=None):
  608. self.msg = msg
  609. if lineNumber is not None:
  610. self.lineNumber = lineNumber
  611. def __str__(self):
  612. if hasattr(self, 'lineNumber'):
  613. return "At line {0!s}: {1!s}".format(self.lineNumber, self.msg)
  614. else:
  615. return repr(self.msg)
  616. class ParseError(VObjectError):
  617. pass
  618. class ValidateError(VObjectError):
  619. pass
  620. class NativeError(VObjectError):
  621. pass
  622. # --------- Parsing functions and parseLine regular expressions ----------------
  623. patterns = {}
  624. # Note that underscore is not legal for names, it's included because
  625. # Lotus Notes uses it
  626. patterns['name'] = '[a-zA-Z0-9\-_]+'
  627. patterns['safe_char'] = '[^";:,]'
  628. patterns['qsafe_char'] = '[^"]'
  629. # the combined Python string replacement and regex syntax is a little confusing;
  630. # remember that {foobar} is replaced with patterns['foobar'], so for instance
  631. # param_value is any number of safe_chars or any number of qsaf_chars surrounded
  632. # by double quotes.
  633. patterns['param_value'] = ' "{qsafe_char!s} * " | {safe_char!s} * '.format(**patterns)
  634. # get a tuple of two elements, one will be empty, the other will have the value
  635. patterns['param_value_grouped'] = """
  636. " ( {qsafe_char!s} * )" | ( {safe_char!s} + )
  637. """.format(**patterns)
  638. # get a parameter and its values, without any saved groups
  639. patterns['param'] = r"""
  640. ; (?: {name!s} ) # parameter name
  641. (?:
  642. (?: = (?: {param_value!s} ) )? # 0 or more parameter values, multiple
  643. (?: , (?: {param_value!s} ) )* # parameters are comma separated
  644. )*
  645. """.format(**patterns)
  646. # get a parameter, saving groups for name and value (value still needs parsing)
  647. patterns['params_grouped'] = r"""
  648. ; ( {name!s} )
  649. (?: =
  650. (
  651. (?: (?: {param_value!s} ) )? # 0 or more parameter values, multiple
  652. (?: , (?: {param_value!s} ) )* # parameters are comma separated
  653. )
  654. )?
  655. """.format(**patterns)
  656. # get a full content line, break it up into group, name, parameters, and value
  657. patterns['line'] = r"""
  658. ^ ((?P<group> {name!s})\.)?(?P<name> {name!s}) # name group
  659. (?P<params> ;?(?: {param!s} )* ) # params group (may be empty)
  660. : (?P<value> .* )$ # value group
  661. """.format(**patterns)
  662. ' "%(qsafe_char)s*" | %(safe_char)s* ' # what is this line?? - never assigned?
  663. param_values_re = re.compile(patterns['param_value_grouped'], re.VERBOSE)
  664. params_re = re.compile(patterns['params_grouped'], re.VERBOSE)
  665. line_re = re.compile(patterns['line'], re.DOTALL | re.VERBOSE)
  666. begin_re = re.compile('BEGIN', re.IGNORECASE)
  667. def parseParams(string):
  668. """
  669. Parse parameters
  670. """
  671. all = params_re.findall(string)
  672. allParameters = []
  673. for tup in all:
  674. paramList = [tup[0]] # tup looks like (name, valuesString)
  675. for pair in param_values_re.findall(tup[1]):
  676. # pair looks like ('', value) or (value, '')
  677. if pair[0] != '':
  678. paramList.append(pair[0])
  679. else:
  680. paramList.append(pair[1])
  681. allParameters.append(paramList)
  682. return allParameters
  683. def parseLine(line, lineNumber=None):
  684. """
  685. Parse line
  686. """
  687. match = line_re.match(line)
  688. if match is None:
  689. raise ParseError("Failed to parse line: {0!s}".format(line), lineNumber)
  690. # Underscores are replaced with dash to work around Lotus Notes
  691. return (match.group('name').replace('_', '-'),
  692. parseParams(match.group('params')),
  693. match.group('value'), match.group('group'))
  694. # logical line regular expressions
  695. patterns['lineend'] = r'(?:\r\n|\r|\n|$)'
  696. patterns['wrap'] = r'{lineend!s} [\t ]'.format(**patterns)
  697. patterns['logicallines'] = r"""
  698. (
  699. (?: [^\r\n] | {wrap!s} )*
  700. {lineend!s}
  701. )
  702. """.format(**patterns)
  703. patterns['wraporend'] = r'({wrap!s} | {lineend!s} )'.format(**patterns)
  704. wrap_re = re.compile(patterns['wraporend'], re.VERBOSE)
  705. logical_lines_re = re.compile(patterns['logicallines'], re.VERBOSE)
  706. testLines = """
  707. Line 0 text
  708. , Line 0 continued.
  709. Line 1;encoding=quoted-printable:this is an evil=
  710. evil=
  711. format.
  712. Line 2 is a new line, it does not start with whitespace.
  713. """
  714. def getLogicalLines(fp, allowQP=True):
  715. """
  716. Iterate through a stream, yielding one logical line at a time.
  717. Because many applications still use vCard 2.1, we have to deal with the
  718. quoted-printable encoding for long lines, as well as the vCard 3.0 and
  719. vCalendar line folding technique, a whitespace character at the start
  720. of the line.
  721. Quoted-printable data will be decoded in the Behavior decoding phase.
  722. # We're leaving this test in for awhile, because the unittest was ugly and dumb.
  723. >>> from six import StringIO
  724. >>> f=StringIO(testLines)
  725. >>> for n, l in enumerate(getLogicalLines(f)):
  726. ... print("Line %s: %s" % (n, l[0]))
  727. ...
  728. Line 0: Line 0 text, Line 0 continued.
  729. Line 1: Line 1;encoding=quoted-printable:this is an evil=
  730. evil=
  731. format.
  732. Line 2: Line 2 is a new line, it does not start with whitespace.
  733. """
  734. if not allowQP:
  735. val = fp.read(-1)
  736. lineNumber = 1
  737. for match in logical_lines_re.finditer(val):
  738. line, n = wrap_re.subn('', match.group())
  739. if line != '':
  740. yield line, lineNumber
  741. lineNumber += n
  742. else:
  743. quotedPrintable = False
  744. newbuffer = six.StringIO
  745. logicalLine = newbuffer()
  746. lineNumber = 0
  747. lineStartNumber = 0
  748. while True:
  749. line = fp.readline()
  750. if line == '':
  751. break
  752. else:
  753. line = line.rstrip(CRLF)
  754. lineNumber += 1
  755. if line.rstrip() == '':
  756. if logicalLine.tell() > 0:
  757. yield logicalLine.getvalue(), lineStartNumber
  758. lineStartNumber = lineNumber
  759. logicalLine = newbuffer()
  760. quotedPrintable = False
  761. continue
  762. if quotedPrintable and allowQP:
  763. logicalLine.write('\n')
  764. logicalLine.write(line)
  765. quotedPrintable = False
  766. elif line[0] in SPACEORTAB:
  767. logicalLine.write(line[1:])
  768. elif logicalLine.tell() > 0:
  769. yield logicalLine.getvalue(), lineStartNumber
  770. lineStartNumber = lineNumber
  771. logicalLine = newbuffer()
  772. logicalLine.write(line)
  773. else:
  774. logicalLine = newbuffer()
  775. logicalLine.write(line)
  776. # vCard 2.1 allows parameters to be encoded without a parameter name
  777. # False positives are unlikely, but possible.
  778. val = logicalLine.getvalue()
  779. if val[-1] == '=' and val.lower().find('quoted-printable') >= 0:
  780. quotedPrintable = True
  781. if logicalLine.tell() > 0:
  782. yield logicalLine.getvalue(), lineStartNumber
  783. def textLineToContentLine(text, n=None):
  784. return ContentLine(*parseLine(text, n), **{'encoded': True,
  785. 'lineNumber': n})
  786. def dquoteEscape(param):
  787. """
  788. Return param, or "param" if ',' or ';' or ':' is in param.
  789. """
  790. if param.find('"') >= 0:
  791. raise VObjectError("Double quotes aren't allowed in parameter values.")
  792. for char in ',;:':
  793. if param.find(char) >= 0:
  794. return '"' + param + '"'
  795. return param
  796. def foldOneLine(outbuf, input, lineLength=75):
  797. """
  798. Folding line procedure that ensures multi-byte utf-8 sequences are not
  799. broken across lines
  800. TO-DO: This all seems odd. Is it still needed, especially in python3?
  801. """
  802. if len(input) < lineLength:
  803. # Optimize for unfolded line case
  804. try:
  805. outbuf.write(bytes(input, 'UTF-8'))
  806. except Exception:
  807. # fall back on py2 syntax
  808. outbuf.write(input)
  809. else:
  810. # Look for valid utf8 range and write that out
  811. start = 0
  812. written = 0
  813. counter = 0 # counts line size in bytes
  814. decoded = to_unicode(input)
  815. length = len(to_basestring(input))
  816. while written < length:
  817. s = decoded[start] # take one char
  818. size = len(to_basestring(s)) # calculate it's size in bytes
  819. if counter + size > lineLength:
  820. try:
  821. outbuf.write(bytes("\r\n ", 'UTF-8'))
  822. except Exception:
  823. # fall back on py2 syntax
  824. outbuf.write("\r\n ")
  825. counter = 1 # one for space
  826. if str is unicode_type:
  827. outbuf.write(to_unicode(s))
  828. else:
  829. # fall back on py2 syntax
  830. outbuf.write(s.encode('utf-8'))
  831. written += size
  832. counter += size
  833. start += 1
  834. try:
  835. outbuf.write(bytes("\r\n", 'UTF-8'))
  836. except Exception:
  837. # fall back on py2 syntax
  838. outbuf.write("\r\n")
  839. def defaultSerialize(obj, buf, lineLength):
  840. """
  841. Encode and fold obj and its children, write to buf or return a string.
  842. """
  843. outbuf = buf or six.StringIO()
  844. if isinstance(obj, Component):
  845. if obj.group is None:
  846. groupString = ''
  847. else:
  848. groupString = obj.group + '.'
  849. if obj.useBegin:
  850. foldOneLine(outbuf, "{0}BEGIN:{1}".format(groupString, obj.name),
  851. lineLength)
  852. for child in obj.getSortedChildren():
  853. # validate is recursive, we only need to validate once
  854. child.serialize(outbuf, lineLength, validate=False)
  855. if obj.useBegin:
  856. foldOneLine(outbuf, "{0}END:{1}".format(groupString, obj.name),
  857. lineLength)
  858. elif isinstance(obj, ContentLine):
  859. startedEncoded = obj.encoded
  860. if obj.behavior and not startedEncoded:
  861. obj.behavior.encode(obj)
  862. s = six.StringIO()
  863. if obj.group is not None:
  864. s.write(obj.group + '.')
  865. s.write(str_(obj.name.upper()))
  866. keys = sorted(obj.params.keys())
  867. for key in keys:
  868. paramstr = ','.join(dquoteEscape(p) for p in obj.params[key])
  869. try:
  870. s.write(";{0}={1}".format(key, paramstr))
  871. except (UnicodeDecodeError, UnicodeEncodeError):
  872. s.write(";{0}={1}".format(key, paramstr.encode('utf-8')))
  873. try:
  874. s.write(":{0}".format(obj.value))
  875. except (UnicodeDecodeError, UnicodeEncodeError):
  876. s.write(":{0}".format(obj.value.encode('utf-8')))
  877. if obj.behavior and not startedEncoded:
  878. obj.behavior.decode(obj)
  879. foldOneLine(outbuf, s.getvalue(), lineLength)
  880. return buf or outbuf.getvalue()
  881. class Stack:
  882. def __init__(self):
  883. self.stack = []
  884. def __len__(self):
  885. return len(self.stack)
  886. def top(self):
  887. if len(self) == 0:
  888. return None
  889. else:
  890. return self.stack[-1]
  891. def topName(self):
  892. if len(self) == 0:
  893. return None
  894. else:
  895. return self.stack[-1].name
  896. def modifyTop(self, item):
  897. top = self.top()
  898. if top:
  899. top.add(item)
  900. else:
  901. new = Component()
  902. self.push(new)
  903. new.add(item) # add sets behavior for item and children
  904. def push(self, obj):
  905. self.stack.append(obj)
  906. def pop(self):
  907. return self.stack.pop()
  908. def readComponents(streamOrString, validate=False, transform=True,
  909. ignoreUnreadable=False, allowQP=False):
  910. """
  911. Generate one Component at a time from a stream.
  912. """
  913. if isinstance(streamOrString, basestring):
  914. stream = six.StringIO(streamOrString)
  915. else:
  916. stream = streamOrString
  917. try:
  918. stack = Stack()
  919. versionLine = None
  920. n = 0
  921. for line, n in getLogicalLines(stream, allowQP):
  922. if ignoreUnreadable:
  923. try:
  924. vline = textLineToContentLine(line, n)
  925. except VObjectError as e:
  926. if e.lineNumber is not None:
  927. msg = "Skipped line {lineNumber}, message: {msg}"
  928. else:
  929. msg = "Skipped a line, message: {msg}"
  930. logger.error(msg.format(**{'lineNumber': e.lineNumber, 'msg': str(e)}))
  931. continue
  932. else:
  933. vline = textLineToContentLine(line, n)
  934. if vline.name == "VERSION":
  935. versionLine = vline
  936. stack.modifyTop(vline)
  937. elif vline.name == "BEGIN":
  938. stack.push(Component(vline.value, group=vline.group))
  939. elif vline.name == "PROFILE":
  940. if not stack.top():
  941. stack.push(Component())
  942. stack.top().setProfile(vline.value)
  943. elif vline.name == "END":
  944. if len(stack) == 0:
  945. err = "Attempted to end the {0} component but it was never opened"
  946. raise ParseError(err.format(vline.value), n)
  947. if vline.value.upper() == stack.topName(): # START matches END
  948. if len(stack) == 1:
  949. component = stack.pop()
  950. if versionLine is not None:
  951. component.setBehaviorFromVersionLine(versionLine)
  952. else:
  953. behavior = getBehavior(component.name)
  954. if behavior:
  955. component.setBehavior(behavior)
  956. if validate:
  957. component.validate(raiseException=True)
  958. if transform:
  959. component.transformChildrenToNative()
  960. yield component # EXIT POINT
  961. else:
  962. stack.modifyTop(stack.pop())
  963. else:
  964. err = "{0} component wasn't closed"
  965. raise ParseError(err.format(stack.topName()), n)
  966. else:
  967. stack.modifyTop(vline) # not a START or END line
  968. if stack.top():
  969. if stack.topName() is None:
  970. logger.warning("Top level component was never named")
  971. elif stack.top().useBegin:
  972. raise ParseError("Component {0!s} was never closed".format(
  973. (stack.topName())), n)
  974. yield stack.pop()
  975. except ParseError as e:
  976. e.input = streamOrString
  977. raise
  978. def readOne(stream, validate=False, transform=True, ignoreUnreadable=False,
  979. allowQP=False):
  980. """
  981. Return the first component from stream.
  982. """
  983. return next(readComponents(stream, validate, transform, ignoreUnreadable,
  984. allowQP))
  985. # --------------------------- version registry ---------------------------------
  986. __behaviorRegistry = {}
  987. def registerBehavior(behavior, name=None, default=False, id=None):
  988. """
  989. Register the given behavior.
  990. If default is True (or if this is the first version registered with this
  991. name), the version will be the default if no id is given.
  992. """
  993. if not name:
  994. name = behavior.name.upper()
  995. if id is None:
  996. id = behavior.versionString
  997. if name in __behaviorRegistry:
  998. if default:
  999. __behaviorRegistry[name].insert(0, (id, behavior))
  1000. else:
  1001. __behaviorRegistry[name].append((id, behavior))
  1002. else:
  1003. __behaviorRegistry[name] = [(id, behavior)]
  1004. def getBehavior(name, id=None):
  1005. """
  1006. Return a matching behavior if it exists, or None.
  1007. If id is None, return the default for name.
  1008. """
  1009. name = name.upper()
  1010. if name in __behaviorRegistry:
  1011. if id:
  1012. for n, behavior in __behaviorRegistry[name]:
  1013. if n == id:
  1014. return behavior
  1015. return __behaviorRegistry[name][0][1]
  1016. return None
  1017. def newFromBehavior(name, id=None):
  1018. """
  1019. Given a name, return a behaviored ContentLine or Component.
  1020. """
  1021. name = name.upper()
  1022. behavior = getBehavior(name, id)
  1023. if behavior is None:
  1024. raise VObjectError("No behavior found named {0!s}".format(name))
  1025. if behavior.isComponent:
  1026. obj = Component(name)
  1027. else:
  1028. obj = ContentLine(name, [], '')
  1029. obj.behavior = behavior
  1030. obj.isNative = False
  1031. return obj
  1032. # --------------------------- Helper function ----------------------------------
  1033. def backslashEscape(s):
  1034. s = s.replace("\\", "\\\\").replace(";", "\;").replace(",", "\,")
  1035. return s.replace("\r\n", "\\n").replace("\n", "\\n").replace("\r", "\\n")