metadata.py

   1 # -*- coding: utf-8 -*-
   2 #######################################################################################
   3 #   Photo is a part of Plinn - http://plinn.org                                       #
   4 #   Copyright © 2004-2008  Benoît PIN <benoit.pin@ensmp.fr>                           #
   5 #                                                                                     #
   6 #   This program is free software; you can redistribute it and/or                     #
   7 #   modify it under the terms of the GNU General Public License                       #
   8 #   as published by the Free Software Foundation; either version 2                    #
   9 #   of the License, or (at your option) any later version.                            #
  10 #                                                                                     #
  11 #   This program is distributed in the hope that it will be useful,                   #
  12 #   but WITHOUT ANY WARRANTY; without even the implied warranty of                    #
  13 #   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                     #
  14 #   GNU General Public License for more details.                                      #
  15 #                                                                                     #
  16 #   You should have received a copy of the GNU General Public License                 #
  17 #   along with this program; if not, write to the Free Software                       #
  18 #   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.   #
  19 #######################################################################################
  20 """ Photo metadata read / write module
  21
  22 $Id: metadata.py 1272 2009-08-11 08:57:35Z pin $
  23 $URL: http://svn.luxia.fr/svn/labo/projects/zope/Photo/trunk/metadata.py $
  24 """
  25
  26 from AccessControl import ClassSecurityInfo
  27 from Acquisition import aq_base
  28 from Globals import InitializeClass
  29 from AccessControl.Permissions import view
  30 from ZODB.interfaces import BlobError
  31 from ZODB.utils import cp
  32 from OFS.Image import File
  33 from xmp import XMP
  34 from logging import getLogger
  35 from cache import memoizedmethod
  36 from libxml2 import parseDoc
  37 from standards.xmp import accessors as xmpAccessors
  38 import xmputils
  39 from types import TupleType
  40 from subprocess import Popen, PIPE
  41 from Products.PortalTransforms.libtransforms.utils import bin_search, \
  42                                                                                                                   MissingBinary
  43
  44 XPATH_EMPTY_TAGS = "//node()[name()!='' and not(node()) and not(@*)]"
  45 console = getLogger('Photo.metadata')
  46
  47 try :
  48         XMPDUMP = 'xmpdump'
  49         XMPLOAD = 'xmpload'
  50         bin_search(XMPDUMP)
  51         bin_search(XMPLOAD)
  52         xmpIO_OK = True
  53 except MissingBinary :
  54         xmpIO_OK = False
  55         console.warn("xmpdump or xmpload not available.")
  56
  57 class Metadata :
  58         """ Photo metadata read / write mixin """
  59
  60         security = ClassSecurityInfo()
  61
  62
  63         #
  64         # reading api
  65         #
  66
  67         security.declarePrivate('getXMP')
  68         if xmpIO_OK :
  69                 @memoizedmethod()
  70                 def getXMP(self):
  71                         """returns xmp metadata packet with xmpdump call
  72                         """
  73                         if self.size :
  74                                 blob_file_path = self.bdata._current_filename()
  75                                 dumpcmd = '%s %s' % (XMPDUMP, blob_file_path)
  76                                 p = Popen(dumpcmd, stdout=PIPE, stderr=PIPE, stdin=PIPE, shell=True)
  77                                 xmp, err = p.communicate()
  78                                 if err :
  79                                         raise SystemError, err
  80                                 return xmp
  81
  82         else :
  83                 @memoizedmethod()
  84                 def getXMP(self):
  85                         """returns xmp metadata packet with XMP object
  86                         """
  87                         xmp = None
  88                         if self.size :
  89                                 try :
  90                                         bf = self.open('r')
  91                                         x = XMP(bf, content_type=self.content_type)
  92                                         xmp = x.getXMP()
  93                                 except NotImplementedError :
  94                                         pass
  95
  96                         return xmp
  97
  98         security.declareProtected(view, 'getXmpFile')
  99         def getXmpFile(self, REQUEST):
 100                 """returns the xmp packet over http.
 101                 """
 102                 xmp = self.getXMP()
 103                 if xmp is not None :
 104                         return File('xmp', 'xmp', xmp, content_type='text/xml').index_html(REQUEST, REQUEST.RESPONSE)
 105                 else :
 106                         return None
 107
 108         security.declarePrivate('getXmpBag')
 109         def getXmpBag(self, name, root, index=None) :
 110                 index = self.getXmpPathIndex()
 111                 if index :
 112                         path = '/'.join(filter(None, ['rdf:RDF/rdf:Description', root, name]))
 113                         node = index.get(path)
 114
 115                         if node :
 116                                 values = xmputils.getBagValues(node.element)
 117                                 return values
 118                 return tuple()
 119
 120         security.declarePrivate('getXmpSeq')
 121         def getXmpSeq(self, name, root) :
 122                 index = self.getXmpPathIndex()
 123                 if index :
 124                         path = '/'.join(filter(None, ['rdf:RDF/rdf:Description', root, name]))
 125                         node = index.get(path)
 126
 127                         if node :
 128                                 values = xmputils.getSeqValues(node.element)
 129                                 return values
 130                 return tuple()
 131
 132         security.declarePrivate('getXmpAlt')
 133         def getXmpAlt(self, name, root) :
 134                 index = self.getXmpPathIndex()
 135                 if index :
 136                         path = '/'.join(filter(None, ['rdf:RDF/rdf:Description', root, name]))
 137                         node = index.get(path)
 138
 139                         if node :
 140                                 firstLi = node.get('rdf:Alt/rdf:li')
 141                                 if firstLi :
 142                                         assert firstLi.unique, "More than one rdf:Alt (localisation not yet supported)"
 143                                         return firstLi.element.content
 144                 return ''
 145
 146         security.declarePrivate('getXmpProp')
 147         def getXmpProp(self, name, root):
 148                 index = self.getXmpPathIndex()
 149                 if index :
 150                         path = '/'.join(filter(None, ['rdf:RDF/rdf:Description', root, name]))
 151                         node = index.get(path)
 152                         if node :
 153                                 return node.element.content
 154                 return ''
 155
 156
 157         security.declarePrivate('getXmpPathIndex')
 158         @memoizedmethod(volatile=True)
 159         def getXmpPathIndex(self):
 160                 xmp = self.getXMP()
 161                 if xmp :
 162                         d = parseDoc(xmp)
 163                         index = xmputils.getPathIndex(d)
 164                         return index
 165
 166         security.declarePrivate('getXmpValue')
 167         def getXmpValue(self, name):
 168                 """ returns pythonic version of xmp property """
 169                 info = xmpAccessors[name]
 170                 root = info['root']
 171                 rdfType = info['rdfType'].capitalize()
 172                 methName = 'getXmp%s' % rdfType
 173                 meth = getattr(aq_base(self), methName)
 174                 return meth(name, root)
 175
 176
 177         security.declareProtected(view, 'getXmpField')
 178         def getXmpField(self, name):
 179                 """ returns data formated for a html form field """
 180                 editableValue = self.getXmpValue(name)
 181                 if type(editableValue) == TupleType :
 182                         editableValue = ', '.join(editableValue)
 183                 return {'id' : name.replace(':', '_'),
 184                                 'value' : editableValue}
 185
 186
 187         #
 188         # writing api
 189         #
 190
 191         security.declarePrivate('setXMP')
 192         if xmpIO_OK :
 193                 def setXMP(self, xmp):
 194                         """setXMP with xmpload call
 195                         """
 196                         if self.size :
 197                                 blob = self.bdata
 198                                 if blob.readers :
 199                                         raise BlobError("Already opened for reading.")
 200
 201                                 if blob._p_blob_uncommitted is None:
 202                                         filename = blob._create_uncommitted_file()
 203                                         uncommitted = file(filename, 'w')
 204                                         cp(file(blob._p_blob_committed, 'rb'), uncommitted)
 205                                         uncommitted.close()
 206                                 else :
 207                                         filename = blob._p_blob_uncommitted
 208
 209                                 loadcmd = '%s %s' % (XMPLOAD, filename)
 210                                 p = Popen(loadcmd, stdin=PIPE, stderr=PIPE, shell=True)
 211                                 p.stdin.write(xmp)
 212                                 p.stdin.close()
 213                                 p.wait()
 214                                 err = p.stderr.read()
 215                                 if err :
 216                                         raise SystemError, err
 217
 218                                 f = file(filename)
 219                                 f.seek(0,2)
 220                                 self.updateSize(size=f.tell())
 221                                 f.close()
 222                                 self.bdata._p_changed = True
 223
 224
 225                                 # purge caches
 226                                 try : del self._methodResultsCache['getXMP']
 227                                 except KeyError : pass
 228
 229                                 for name in ('getXmpPathIndex',) :
 230                                         try :
 231                                                 del self._v__methodResultsCache[name]
 232                                         except (AttributeError, KeyError):
 233                                                 continue
 234
 235                                 self.ZCacheable_invalidate()
 236                                 self.ZCacheable_set(None)
 237                                 self.http__refreshEtag()
 238
 239         else :
 240                 def setXMP(self, xmp):
 241                         """setXMP with XMP object
 242                         """
 243                         if self.size :
 244                                 bf = self.open('r+')
 245                                 x = XMP(bf, content_type=self.content_type)
 246                                 x.setXMP(xmp)
 247                                 x.save()
 248                                 self.updateSize(size=bf.tell())
 249
 250                                 # don't call update_data
 251                                 self.ZCacheable_invalidate()
 252                                 self.ZCacheable_set(None)
 253                                 self.http__refreshEtag()
 254
 255                                 # purge caches
 256                                 try : del self._methodResultsCache['getXMP']
 257                                 except KeyError : pass
 258                                 for name in ('getXmpPathIndex', ) :
 259                                         try :
 260                                                 del self._v__methodResultsCache[name]
 261                                         except (AttributeError, KeyError):
 262                                                 continue
 263
 264
 265
 266         security.declarePrivate('setXmpField')
 267         def setXmpFields(self, **kw):
 268                 xmp = self.getXMP()
 269                 if xmp :
 270                         doc = parseDoc(xmp)
 271                 else :
 272                         doc = xmputils.createEmptyXmpDoc()
 273
 274                 index = xmputils.getPathIndex(doc)
 275
 276                 pathPrefix = 'rdf:RDF/rdf:Description'
 277                 preferedNsDeclaration = 'rdf:RDF/rdf:Description'
 278
 279                 for id, value in kw.items() :
 280                         name = id.replace('_', ':')
 281                         info = xmpAccessors.get(name)
 282                         if not info : continue
 283                         root = info['root']
 284                         rdfType = info['rdfType']
 285                         path = '/'.join([p for p in [pathPrefix, root, name] if p])
 286
 287                         Metadata._setXmpField(index
 288                                                                 , path
 289                                                                 , rdfType
 290                                                                 , name
 291                                                                 , value
 292                                                                 , preferedNsDeclaration)
 293
 294                 # clean empty tags without attributes
 295                 context = doc.xpathNewContext()
 296                 nodeset = context.xpathEval(XPATH_EMPTY_TAGS)
 297                 while nodeset :
 298                         for n in nodeset :
 299                                 n.unlinkNode()
 300                                 n.freeNode()
 301                         nodeset = context.xpathEval(XPATH_EMPTY_TAGS)
 302
 303
 304
 305                 xmp = doc.serialize('utf-8')
 306                 # remove <?xml version="1.0" encoding="utf-8"?> header
 307                 xmp = xmp.split('?>', 1)[1].lstrip('\n')
 308                 self.setXMP(xmp)
 309
 310         @staticmethod
 311         def _setXmpField(index, path, rdfType, name, value, preferedNsDeclaration) :
 312                 if rdfType in ('Bag', 'Seq') :
 313                         value = value.replace(';', ',')
 314                         value = value.split(',')
 315                         value = [item.strip() for item in value]
 316                         value = filter(None, value)
 317
 318                 if value :
 319                         # edit
 320                         xmpPropIndex = index.getOrCreate(path
 321                                                                         , rdfType
 322                                                                         , preferedNsDeclaration)
 323                         if rdfType == 'prop' :
 324                                 xmpPropIndex.element.setContent(value)
 325                         else :
 326                                 #rdfPrefix = index.getDocumentNs()['http://www.w3.org/1999/02/22-rdf-syntax-ns#']
 327                                 func = getattr(xmputils, 'createRDF%s' % rdfType)
 328                                 newNode = func(name, value, index)
 329                                 oldNode = xmpPropIndex.element
 330                                 oldNode.replaceNode(newNode)
 331                 else :
 332                         # delete
 333                         xmpPropIndex = index.get(path)
 334                         if xmpPropIndex is not None :
 335                                 xmpPropIndex.element.unlinkNode()
 336                                 xmpPropIndex.element.freeNode()
 337
 338
 339 InitializeClass(Metadata)