order.py

   1 # -*- coding: utf-8 -*-
   2 #######################################################################################
   3 #   Plinn - http://plinn.org                                                          #
   4 #   Copyright (C) 2009-2013  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 """
  21 Print order classes
  22
  23
  24
  25 """
  26
  27 from Globals import InitializeClass, PersistentMapping, Persistent
  28 from Acquisition import Implicit
  29 from AccessControl import ClassSecurityInfo
  30 from AccessControl.requestmethod import postonly
  31 from zope.interface import implements
  32 from zope.component.factory import Factory
  33 from OFS.SimpleItem import SimpleItem
  34 from ZTUtils import make_query
  35 from DateTime import DateTime
  36 from Products.CMFCore.PortalContent import PortalContent
  37 from Products.CMFCore.permissions import ModifyPortalContent, View, ManagePortal
  38 from Products.CMFCore.utils import getToolByName, getUtilityByInterfaceName
  39 from Products.CMFDefault.DublinCore import DefaultDublinCoreImpl
  40 from Products.Plinn.utils import getPreferredLanguages
  41 from interfaces import IPrintOrderTemplate, IPrintOrder
  42 from permissions import ManagePrintOrderTemplate, ManagePrintOrders
  43 from price import Price
  44 from utils import Message as _
  45 from utils import translate
  46 from xml.dom.minidom import Document
  47 from tool import COPIES_COUNTERS
  48 from App.config import getConfiguration
  49 from paypal.interface import PayPalInterface
  50 from logging import getLogger
  51 console = getLogger('Products.photoprint.order')
  52
  53
  54 def getPayPalConfig() :
  55     zopeConf = getConfiguration()
  56     try :
  57         conf = zopeConf.product_config['photoprint']
  58     except KeyError :
  59         EnvironmentError("No photoprint configuration found in Zope environment.")
  60
  61     ppconf = {'API_ENVIRONMENT'      : conf['paypal_api_environment'],
  62               'API_USERNAME'         : conf['paypal_username'],
  63               'API_PASSWORD'         : conf['paypal_password'],
  64               'API_SIGNATURE'        : conf['paypal_signature']}
  65
  66     return ppconf
  67
  68
  69 class PrintOrderTemplate(SimpleItem) :
  70     """
  71     predefined print order
  72     """
  73     implements(IPrintOrderTemplate)
  74
  75     security = ClassSecurityInfo()
  76
  77     def __init__(self
  78                 , id
  79                 , title=''
  80                 , description=''
  81                 , productReference=''
  82                 , maxCopies=0
  83                 , price=0
  84                 , VATRate=0) :
  85         self.id = id
  86         self.title = title
  87         self.description = description
  88         self.productReference = productReference
  89         self.maxCopies = maxCopies # 0 means unlimited
  90         self.price = Price(price, VATRate)
  91
  92     security.declareProtected(ManagePrintOrderTemplate, 'edit')
  93     def edit( self
  94             , title=''
  95             , description=''
  96             , productReference=''
  97             , maxCopies=0
  98             , price=0
  99             , VATRate=0 ) :
 100         self.title = title
 101         self.description = description
 102         self.productReference = productReference
 103         self.maxCopies = maxCopies
 104         self.price = Price(price, VATRate)
 105
 106     security.declareProtected(ManagePrintOrderTemplate, 'formWidgetData')
 107     def formWidgetData(self, REQUEST=None, RESPONSE=None):
 108         """formWidgetData documentation
 109         """
 110         d = Document()
 111         d.encoding = 'utf-8'
 112         root = d.createElement('formdata')
 113         d.appendChild(root)
 114
 115         def gua(name) :
 116             return str(getattr(self, name, '')).decode('utf-8')
 117
 118         id = d.createElement('id')
 119         id.appendChild(d.createTextNode(self.getId()))
 120         root.appendChild(id)
 121
 122         title = d.createElement('title')
 123         title.appendChild(d.createTextNode(gua('title')))
 124         root.appendChild(title)
 125
 126         description = d.createElement('description')
 127         description.appendChild(d.createTextNode(gua('description')))
 128         root.appendChild(description)
 129
 130         productReference = d.createElement('productReference')
 131         productReference.appendChild(d.createTextNode(gua('productReference')))
 132         root.appendChild(productReference)
 133
 134         maxCopies = d.createElement('maxCopies')
 135         maxCopies.appendChild(d.createTextNode(str(self.maxCopies)))
 136         root.appendChild(maxCopies)
 137
 138         price = d.createElement('price')
 139         price.appendChild(d.createTextNode(str(self.price.taxed)))
 140         root.appendChild(price)
 141
 142         vatrate = d.createElement('VATRate')
 143         vatrate.appendChild(d.createTextNode(str(self.price.vat)))
 144         root.appendChild(vatrate)
 145
 146         if RESPONSE is not None :
 147             RESPONSE.setHeader('content-type', 'text/xml; charset=utf-8')
 148
 149             manager = getToolByName(self, 'caching_policy_manager', None)
 150             if manager is not None:
 151                 view_name = 'formWidgetData'
 152                 headers = manager.getHTTPCachingHeaders(
 153                                   self, view_name, {}
 154                                   )
 155
 156                 for key, value in headers:
 157                     if key == 'ETag':
 158                         RESPONSE.setHeader(key, value, literal=1)
 159                     else:
 160                         RESPONSE.setHeader(key, value)
 161                 if headers:
 162                     RESPONSE.setHeader('X-Cache-Headers-Set-By',
 163                                        'CachingPolicyManager: %s' %
 164                                        '/'.join(manager.getPhysicalPath()))
 165
 166
 167         return d.toxml('utf-8')
 168
 169
 170 InitializeClass(PrintOrderTemplate)
 171 PrintOrderTemplateFactory = Factory(PrintOrderTemplate)
 172
 173 class PrintOrder(PortalContent, DefaultDublinCoreImpl) :
 174
 175     implements(IPrintOrder)
 176     security = ClassSecurityInfo()
 177
 178     def __init__( self, id) :
 179         DefaultDublinCoreImpl.__init__(self)
 180         self.id = id
 181         self.items = []
 182         self.quantity = 0
 183         self.price = Price(0, 0)
 184         # billing and shipping addresses
 185         self.billing = PersistentMapping()
 186         self.shipping = PersistentMapping()
 187         self.shippingFees = Price(0,0)
 188         self._paymentResponse = PersistentMapping()
 189
 190     @property
 191     def amountWithFees(self) :
 192         return self.price + self.shippingFees
 193
 194
 195     security.declareProtected(ModifyPortalContent, 'editBilling')
 196     def editBilling(self
 197                     , name
 198                     , address
 199                     , city
 200                     , zipcode
 201                     , country
 202                     , phone) :
 203         self.billing['name'] = name
 204         self.billing['address'] = address
 205         self.billing['city'] = city
 206         self.billing['zipcode'] = zipcode
 207         self.billing['country'] = country
 208         self.billing['phone'] = phone
 209
 210     security.declareProtected(ModifyPortalContent, 'editShipping')
 211     def editShipping(self, name, address, city, zipcode, country) :
 212         self.shipping['name'] = name
 213         self.shipping['address'] = address
 214         self.shipping['city'] = city
 215         self.shipping['zipcode'] = zipcode
 216         self.shipping['country'] = country
 217
 218     security.declarePrivate('loadCart')
 219     def loadCart(self, cart):
 220         pptool = getToolByName(self, 'portal_photo_print')
 221         uidh = getToolByName(self, 'portal_uidhandler')
 222         mtool = getToolByName(self, 'portal_membership')
 223
 224         items = []
 225         for item in cart :
 226             photo = uidh.getObject(item['cmf_uid'])
 227             pOptions = pptool.getPrintingOptionsContainerFor(photo)
 228             template = getattr(pOptions, item['printing_template'])
 229
 230             reference = template.productReference
 231             quantity = item['quantity']
 232             uPrice = template.price
 233             self.quantity += quantity
 234
 235             d = {'cmf_uid'          : item['cmf_uid']
 236                 ,'url'              : photo.absolute_url()
 237                 ,'title'            : template.title
 238                 ,'description'      : template.description
 239                 ,'unit_price'       : Price(uPrice._taxed, uPrice._rate)
 240                 ,'quantity'         : quantity
 241                 ,'productReference' : reference
 242                 }
 243             items.append(d)
 244             self.price += uPrice * quantity
 245             # confirm counters
 246             if template.maxCopies :
 247                 counters = getattr(photo, COPIES_COUNTERS)
 248                 counters.confirm(reference, quantity)
 249
 250         self.items = tuple(items)
 251
 252         member = mtool.getAuthenticatedMember()
 253         mg = lambda name : member.getProperty(name, '')
 254         billing = {'name'       : member.getMemberFullName(nameBefore=0)
 255                   ,'address'    : mg('billing_address')
 256                   ,'city'       : mg('billing_city')
 257                   ,'zipcode'    : mg('billing_zipcode')
 258                   ,'country'    : mg('country')
 259                   ,'phone'      : mg('phone') }
 260         self.editBilling(**billing)
 261
 262         sg = lambda name : cart._shippingInfo.get(name, '')
 263         shipping = {'name'      : sg('shipping_fullname')
 264                    ,'address'   : sg('shipping_address')
 265                    ,'city'      : sg('shipping_city')
 266                    ,'zipcode'   : sg('shipping_zipcode')
 267                    ,'country'   : sg('shipping_country')}
 268         self.editShipping(**shipping)
 269
 270         self.shippingFees = pptool.getShippingFeesFor(shippable=self)
 271
 272         cart._confirmed = True
 273         cart.pendingOrderPath = self.getPhysicalPath()
 274
 275     security.declareProtected(ManagePrintOrders, 'resetCopiesCounters')
 276     def resetCopiesCounters(self) :
 277         pptool = getToolByName(self, 'portal_photo_print')
 278         uidh = getToolByName(self, 'portal_uidhandler')
 279
 280         for item in self.items :
 281             photo = uidh.getObject(item['cmf_uid'])
 282             counters = getattr(photo, COPIES_COUNTERS, None)
 283             if counters :
 284                 counters.cancel(item['productReference'],
 285                                 item['quantity'])
 286
 287
 288     def _initPayPalInterface(self) :
 289         config = getPayPalConfig()
 290         config['API_AUTHENTICATION_MODE'] = '3TOKEN'
 291         ppi = PayPalInterface(**config)
 292         return ppi
 293
 294
 295     @staticmethod
 296     def recordifyPPResp(response) :
 297         d = {}
 298         d['zopeTime'] = DateTime()
 299         for k, v in response.raw.iteritems() :
 300             if len(v) == 1 :
 301                 d[k] = v[0]
 302             else :
 303                 d[k] = v
 304         return d
 305
 306     # paypal api
 307     security.declareProtected(ModifyPortalContent, 'ppSetExpressCheckout')
 308     def ppSetExpressCheckout(self) :
 309         utool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IURLTool')
 310         mtool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IMembershipTool')
 311         portal_url = utool()
 312         portal = utool.getPortalObject()
 313         member = mtool.getAuthenticatedMember()
 314
 315         options = {#'PAYMENTREQUEST_0_AMT' : '99.55', # todo
 316                    'PAYMENTREQUEST_0_CURRENCYCODE' : 'EUR',
 317                    'PAYMENTREQUEST_0_PAYMENTACTION' : 'Sale',
 318                    'RETURNURL' : '%s/photoprint_order_confirm' % self.absolute_url(),
 319                    'CANCELURL' : '%s/photoprint_order_cancel' % self.absolute_url(),
 320                    # 'CALLBACK' : TODO
 321                    'ALLOWNOTE' : 0, # The buyer is unable to enter a note to the merchant.
 322                    'HDRIMG' : '%s/logo.gif' % portal_url,
 323                    'EMAIL' : member.getProperty('email'),
 324                    'SOLUTIONTYPE' : 'Sole', #  Buyer does not need to create a PayPal account to check out. This is referred to as PayPal Account Optional.
 325                    'LANDINGPAGE' : 'Billing', # Non-PayPal account
 326                    'BRANDNAME' : portal.getProperty('title'),
 327                    'GIFTMESSAGEENABLE' : 0,
 328                    'GIFTRECEIPTENABLE' : 0,
 329                    'BUYEREMAILOPTINENABLE' : 0, # Do not enable buyer to provide email address.
 330                    'NOSHIPPING' : 1, # PayPal does not display shipping address fields whatsoever.
 331                    # 'PAYMENTREQUEST_0_NOTIFYURL' : TODO
 332
 333                    'PAYMENTREQUEST_0_SHIPTONAME' : self.billing['name'],
 334                    'PAYMENTREQUEST_0_SHIPTOSTREET' : self.billing['address'],
 335                    'PAYMENTREQUEST_0_SHIPTOCITY' : self.billing['city'],
 336                    'PAYMENTREQUEST_0_SHIPTOZIP' : self.billing['zipcode'],
 337                    'PAYMENTREQUEST_0_SHIPTOPHONENUM' : self.billing['phone'],
 338                    }
 339
 340         quantitySum = reduce(lambda a, b : a['quantity'] + b['quantity'], self.items)
 341         priceSum = reduce(lambda a, b : a['unit_price'] * a['quantity'] + b['unit_price'] * b['quantity'], self.items)
 342         priceValues = priceSum.getValues()
 343         total = round(priceValues['taxed'], 2)
 344         basePrice = round(priceValues['value'], 2)
 345         tax = round(total - basePrice, 2)
 346
 347         options['L_PAYMENTREQUEST_0_NAME0'] = 'Commande realis photo ref. %s' % self.getId()
 348         options['L_PAYMENTREQUEST_0_DESC0'] = 'Commande de %d tirages photo' % quantitySum
 349         options['L_PAYMENTREQUEST_0_AMT0'] =  total
 350         # options['L_PAYMENTREQUEST_0_TAXAMT0'] =  tax
 351         # options['L_PAYMENTREQUEST_0_QTY%d' % n] = 1
 352         options['PAYMENTREQUEST_0_AMT'] = total
 353
 354         ppi = self._initPayPalInterface()
 355         response = ppi.set_express_checkout(**options)
 356         response = PrintOrder.recordifyPPResp(response)
 357         # self._paypalLog.append(response)
 358         response['url'] = ppi.generate_express_checkout_redirect_url(response['TOKEN'])
 359         console.info(options)
 360         console.info(response)
 361         return response
 362
 363     security.declarePrivate('ppGetExpressCheckoutDetails')
 364     def ppGetExpressCheckoutDetails(self, token) :
 365         ppi = self._initPayPalInterface()
 366         response = ppi.get_express_checkout_details(TOKEN=token)
 367         response = Registration.recordifyPPResp(response)
 368         self._paypalLog.append(response)
 369         return response
 370
 371     security.declarePrivate('ppDoExpressCheckoutPayment')
 372     def ppDoExpressCheckoutPayment(self, token, payerid, amt) :
 373         ppi = self._initPayPalInterface()
 374         response = ppi.do_express_checkout_payment(PAYMENTREQUEST_0_PAYMENTACTION='Sale',
 375                                                    PAYMENTREQUEST_0_AMT=amt,
 376                                                    PAYMENTREQUEST_0_CURRENCYCODE='EUR',
 377                                                    TOKEN=token,
 378                                                    PAYERID=payerid)
 379         response = Registration.recordifyPPResp(response)
 380         self._paypalLog.append(response)
 381         return response
 382
 383     security.declareProtected(ModifyPortalContent, 'ppPay')
 384     def ppPay(self, token, payerid):
 385         # assure le paiement paypal en une passe :
 386         # récupération des détails et validation de la transaction.
 387         if not self.paid :
 388             details = self.ppGetExpressCheckoutDetails(token)
 389
 390             if payerid != details['PAYERID'] :
 391                 return False
 392
 393             if details['ACK'] == 'Success' :
 394                 response = self.ppDoExpressCheckoutPayment(token,
 395                                                            payerid,
 396                                                            details['AMT'])
 397                 if response['ACK'] == 'Success' and \
 398                     response['PAYMENTINFO_0_ACK'] == 'Success' and \
 399                     response['PAYMENTINFO_0_PAYMENTSTATUS'] == 'Completed' :
 400                     self.paid = (DateTime(), 'paypal')
 401                     wtool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IWorkflowTool')
 402                     wtool.doActionFor( self
 403                                      , 'paypal_pay'
 404                                      , wf_id='jma_registration_workflow'
 405                                      , comments='Paiement par PayPal')
 406                     return True
 407             return False
 408         else :
 409             return True
 410
 411     security.declareProtected(ModifyPortalContent, 'ppCancel')
 412     def ppCancel(self, token) :
 413         details = self.ppGetExpressCheckoutDetails(token)
 414
 415     security.declareProtected(ManagePortal, 'getPPLog')
 416     def getPPLog(self) :
 417         return self._paypalLog
 418
 419
 420
 421     # security.declareProtected(View, 'getPaymentRequest')
 422     # def getPaymentRequest(self) :
 423     #   config = _getCyberplusConfig()
 424     #   requester = CyberplusRequester(config)
 425     #   hereurl = self.absolute_url()
 426     #   amount = self.price + self.shippingFees
 427     #   amount = amount.getValues()['taxed']
 428     #   amount = amount * 100
 429     #   amount = str(int(round(amount, 0)))
 430     #   pptool = getToolByName(self, 'portal_photo_print')
 431     #   transaction_id = pptool.getNextTransactionId()
 432     #
 433     #   userLanguages = getPreferredLanguages(self)
 434     #   for pref in userLanguages :
 435     #       lang = pref.split('-')[0]
 436     #       if lang in CYBERPLUS_LANGUAGES :
 437     #           break
 438     #   else :
 439     #       lang = 'en'
 440     #
 441     #   options = {  'amount': amount
 442     #               ,'cancel_return_url'        : '%s/paymentCancelHandler' % hereurl
 443     #               ,'normal_return_url'        : '%s/paymentManualResponseHandler' % hereurl
 444     #               ,'automatic_response_url'   :'%s/paymentAutoResponseHandler' % hereurl
 445     #               ,'transaction_id'           : transaction_id
 446     #               ,'order_id'                 : self.getId()
 447     #               ,'language'                 : lang
 448     #              }
 449     #   req = requester.generateRequest(options)
 450     #   return req
 451     #
 452     # def _decodeCyberplusResponse(self, form) :
 453     #   config = _getCyberplusConfig()
 454     #   responder = CyberplusResponder(config)
 455     #   response = responder.getResponse(form)
 456     #   return response
 457     #
 458     # def _compareWithAutoResponse(self, manu) :
 459     #   keys = manu.keys()
 460     #   auto = self._paymentResponse
 461     #   autoKeys = auto.keys()
 462     #   if len(keys) != len(autoKeys) :
 463     #       console.warn('Manual has not the same keys.\nauto: %r\nmanual: %r' % \
 464     #           (sorted(autoKeys), sorted(keys)))
 465     #   else :
 466     #       for k, v in manu.items() :
 467     #           if not auto.has_key(k) :
 468     #               console.warn('%r field only found in manual response.' % k)
 469     #           else :
 470     #               if v != auto[k] :
 471     #                   console.warn('data mismatch for %r\nauto: %r\nmanual: %r' % (k, auto[k], v))
 472     #
 473     # def _checkOrderId(self, response) :
 474     #   expected = self.getId()
 475     #   assert expected == response['order_id'], \
 476     #       "Cyberplus response transaction_id doesn't match the order object:\n" \
 477     #       "expected: %s\n" \
 478     #       "found: %s" % (expected, response['transaction_id'])
 479
 480     # def _executeOrderWfTransition(self, response) :
 481     #   if CyberplusResponder.transactionAccepted(response) :
 482     #       wfaction = 'auto_accept_payment'
 483     #   elif CyberplusResponder.transactionRefused(response) :
 484     #       self.resetCopiesCounters()
 485     #       wfaction = 'auto_refuse_payment'
 486     #   elif CyberplusResponder.transactionCanceled(response) :
 487     #       wfaction = 'auto_cancel_order'
 488     #   else :
 489     #       # transaction failed
 490     #       wfaction = 'auto_transaction_failed'
 491     #
 492     #   wtool = getToolByName(self, 'portal_workflow')
 493     #   wf = wtool.getWorkflowById('order_workflow')
 494     #   tdef = wf.transitions.get(wfaction)
 495     #   wf._changeStateOf(self, tdef)
 496     #   wtool._reindexWorkflowVariables(self)
 497
 498     # security.declarePublic('paymentAutoResponseHandler')
 499     # @postonly
 500     # def paymentAutoResponseHandler(self, REQUEST) :
 501     #   """\
 502     #   Handle cyberplus payment auto response.
 503     #   """
 504     #   response = self._decodeCyberplusResponse(REQUEST.form)
 505     #   self._checkOrderId(response)
 506     #   self._paymentResponse.update(response)
 507     #   self._executeOrderWfTransition(response)
 508     #
 509     # @postonly
 510     # def paymentManualResponseHandler(self, REQUEST) :
 511     #   """\
 512     #   Handle cyberplus payment manual response.
 513     #   """
 514     #   response = self._decodeCyberplusResponse(REQUEST.form)
 515     #   self._checkOrderId(response)
 516     #
 517     #   autoResponse = self._paymentResponse
 518     #   if not autoResponse :
 519     #       console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath()))
 520     #       self._paymentResponse.update(response)
 521     #       self._executeOrderWfTransition(response)
 522     #   else :
 523     #       self._compareWithAutoResponse(response)
 524     #
 525     #   url = '%s?%s' % (self.absolute_url(),
 526     #                   make_query(portal_status_message=translate('Your payment is complete.', self).encode('utf-8'))
 527     #                   )
 528     #   return REQUEST.RESPONSE.redirect(url)
 529     #
 530     # @postonly
 531     # def paymentCancelHandler(self, REQUEST) :
 532     #   """\
 533     #   Handle cyberplus cancel response.
 534     #   This handler can be invoqued in two cases:
 535     #   - the user cancel the payment form
 536     #   - the payment transaction has been refused
 537     #   """
 538     #   response = self._decodeCyberplusResponse(REQUEST.form)
 539     #   self._checkOrderId(response)
 540     #
 541     #   if self._paymentResponse :
 542     #       # normaly, it happens when the transaction is refused by cyberplus.
 543     #       self._compareWithAutoResponse(response)
 544     #
 545     #
 546     #   if CyberplusResponder.transactionRefused(response) :
 547     #       if not self._paymentResponse :
 548     #           console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath()))
 549     #           self._paymentResponse.update(response)
 550     #           self._executeOrderWfTransition(response)
 551     #
 552     #       msg = 'Your payment has been refused.'
 553     #
 554     #   else :
 555     #       self._executeOrderWfTransition(response)
 556     #       msg = 'Your payment has been canceled. You will be able to pay later.'
 557     #
 558     #   url = '%s?%s' % (self.absolute_url(),
 559     #                   make_query(portal_status_message= \
 560     #                   translate(msg, self).encode('utf-8'))
 561     #                   )
 562     #   return REQUEST.RESPONSE.redirect(url)
 563
 564
 565     def getCustomerSummary(self) :
 566         ' '
 567         return {'quantity':self.quantity,
 568                 'price':self.price}
 569
 570
 571 InitializeClass(PrintOrder)
 572 PrintOrderFactory = Factory(PrintOrder)
 573
 574
 575 class CopiesCounters(Persistent, Implicit) :
 576
 577     def __init__(self):
 578         self._mapping = PersistentMapping()
 579
 580     def getBrowserId(self):
 581         sdm = self.session_data_manager
 582         bim = sdm.getBrowserIdManager()
 583         browserId = bim.getBrowserId(create=1)
 584         return browserId
 585
 586     def _checkBrowserId(self, browserId) :
 587         sdm = self.session_data_manager
 588         sd = sdm.getSessionDataByKey(browserId)
 589         return not not sd
 590
 591     def __setitem__(self, reference, count) :
 592         if not self._mapping.has_key(reference):
 593             self._mapping[reference] = PersistentMapping()
 594             self._mapping[reference]['pending'] = PersistentMapping()
 595             self._mapping[reference]['confirmed'] = 0
 596
 597         globalCount = self[reference]
 598         delta = count - globalCount
 599         bid = self.getBrowserId()
 600         if not self._mapping[reference]['pending'].has_key(bid) :
 601             self._mapping[reference]['pending'][bid] = delta
 602         else :
 603             self._mapping[reference]['pending'][bid] += delta
 604
 605
 606     def __getitem__(self, reference) :
 607         item = self._mapping[reference]
 608         globalCount = item['confirmed']
 609
 610         for browserId, count in item['pending'].items() :
 611             if self._checkBrowserId(browserId) :
 612                 globalCount += count
 613             else :
 614                 del self._mapping[reference]['pending'][browserId]
 615
 616         return globalCount
 617
 618     def get(self, reference, default=0) :
 619         if self._mapping.has_key(reference) :
 620             return self[reference]
 621         else :
 622             return default
 623
 624     def getPendingCounter(self, reference) :
 625         bid = self.getBrowserId()
 626         if not self._checkBrowserId(bid) :
 627             console.warn('BrowserId not found: %s' % bid)
 628             return 0
 629
 630         count = self._mapping[reference]['pending'].get(bid, None)
 631         if count is None :
 632             console.warn('No pending data found for browserId %s' % bid)
 633             return 0
 634         else :
 635             return count
 636
 637     def confirm(self, reference, quantity) :
 638         pending = self.getPendingCounter(reference)
 639         if pending != quantity :
 640             console.warn('Pending quantity mismatch with the confirmed value: (%d, %d)' % (pending, quantity))
 641
 642         browserId = self.getBrowserId()
 643         if self._mapping[reference]['pending'].has_key(browserId) :
 644             del self._mapping[reference]['pending'][browserId]
 645         self._mapping[reference]['confirmed'] += quantity
 646
 647     def cancel(self, reference, quantity) :
 648         self._mapping[reference]['confirmed'] -= quantity
 649
 650     def __str__(self):
 651         return str(self._mapping)