Changeset 12740 for main/waeup.ikoba/branches/uli-payments/src/waeup/ikoba/customers

Timestamp:

12 Mar 2015, 05:23:47 (10 years ago)

Author:

uli

Message:

Let cc payments basically run.

Location:

main/waeup.ikoba/branches/uli-payments/src/waeup/ikoba/customers

Files:

• browser.py (modified) (1 diff)
• contracts.py (modified) (4 diffs)

main/waeup.ikoba/branches/uli-payments/src/waeup/ikoba/customers/browser.py

@@ -1532 +1532 @@
             payment, view_name = service.next_step(payment.payment_id)
             url = self.url(payment, view_name)
-            IWorkflowInfo(self.context).fireTransition('await')
             self.redirect(url)
             return

main/waeup.ikoba/branches/uli-payments/src/waeup/ikoba/customers/contracts.py

@@ -20 +20 @@
 """
 import grok
+from hurry.workflow.interfaces import IWorkflowInfo, IWorkflowState
 from zope.catalog.interfaces import ICatalog
 from zope.component import getUtility, queryUtility
@@ -25 +26 @@
 from zope.interface import implementedBy
 from zope.schema import getFields
-from hurry.workflow.interfaces import IWorkflowInfo, IWorkflowState
 from waeup.ikoba.interfaces import MessageFactory as _
 from waeup.ikoba.interfaces import (
@@ -33 +33 @@
     IContractSelectProduct, ICustomersUtils, ISampleContract,
     ISampleContractProcess, ISampleContractEdit, ISampleContractOfficialUse)
-from waeup.ikoba.payments.interfaces import IPayer, IPayableFinder, IPayable
-from waeup.ikoba.payments.payment import PaymentItem
+from waeup.ikoba.payments.interfaces import (
+    IPayer, IPayableFinder, IPayable, IPaymentWaitingForGatewayEvent,
+    STATE_PAID, STATE_FAILED, IPaymentFinishedEvent
+    )
+from waeup.ikoba.payments.payment import (
+    PaymentItem, find_payable_from_payable_id,
+    )
 from waeup.ikoba.utils.helpers import attrs_to_fields
 
@@ -248 +253 @@
 
 
+@grok.subscribe(IPaymentWaitingForGatewayEvent)
+def handle_payment_waiting_for_gw(event):
+    maybe_contract = find_payable_from_payable_id(
+        event.object.payable_id)
+    if IContract.providedBy(maybe_contract):
+        IWorkflowInfo(maybe_contract).fireTransition('await')
+
+
+@grok.subscribe(IPaymentFinishedEvent)
+def handle_payment_finished(event):
+    payment = event.object
+    maybe_contract = find_payable_from_payable_id(payment.payable_id)
+    if not IContract.providedBy(maybe_contract):
+        return
+    if payment.state == STATE_PAID:
+        IWorkflowInfo(maybe_contract).fireTransition('confirm')
+    else:
+        IWorkflowInfo(maybe_contract).fireTransition('discard')
+
+
 class ContractFinder(grok.GlobalUtility):
     grok.name('contracts_finder')