[Erp5-report] r12672 - /erp5/trunk/products/CMFActivity/tests/testCMFActivity.py

[nobody at svn.erp5.org]

Author: seb
Date: Tue Feb 13 16:51:59 2007
New Revision: 12672

URL: http://svn.erp5.org?rev=12672&view=rev
Log:
show that it working even with some Operationnal errors

Modified:
    erp5/trunk/products/CMFActivity/tests/testCMFActivity.py

Modified: erp5/trunk/products/CMFActivity/tests/testCMFActivity.py
URL: http://svn.erp5.org/erp5/trunk/products/CMFActivity/tests/testCMFActivity.py?rev=12672&r1=12671&r2=12672&view=diff
==============================================================================
--- erp5/trunk/products/CMFActivity/tests/testCMFActivity.py (original)
+++ erp5/trunk/products/CMFActivity/tests/testCMFActivity.py Tue Feb 13 16:51:59 2007
@@ -708,6 +708,51 @@
       del Queue.current_num_conflict_errors
       del Queue.conflict_errors_limit
 
+  def TryErrorsWhileFinishingCommitDB(self, activity):
+    """Try to execute active objects which may throw conflict errors
+    while validating, and check if they are still executed."""
+    # Make sure that no active object is installed.
+    activity_tool = self.getPortal().portal_activities
+    activity_tool.manageClearActivities(keep=0)
+
+    # Need an object.
+    organisation_module = self.getOrganisationModule()
+    if not organisation_module.hasContent(self.company_id):
+      organisation_module.newContent(id=self.company_id)
+    o = organisation_module._getOb(self.company_id)
+    get_transaction().commit()
+    self.flushAllActivities(silent = 1, loop_size = 10)
+    self.assertEquals(len(activity_tool.getMessageList()), 0)
+
+    from _mysql_exceptions import OperationalError
+
+    # Monkey patch Queue to induce conflict errors artificially.
+    def query(self, query_string,*args, **kw):
+      # No so nice, this is specific to zsql method
+      if query_string.find("REPLACE INTO")>=0:
+        raise OperationalError
+      else:
+        return self.original_query(query_string,*args, **kw)
+    from Products.ZMySQLDA.db import DB
+    portal = self.getPortal()
+
+    try:
+      # Test some range of conflict error occurences.
+      organisation_module.recursiveReindexObject()
+      get_transaction().commit()
+      self.assertEquals(len(activity_tool.getMessageList()), 1)
+      DB.original_query = DB.query
+      DB.query = query
+      portal.portal_activities.distribute()
+      portal.portal_activities.tic()
+      get_transaction().commit()
+      DB.query = DB.original_query
+      message_list = portal.portal_activities.getMessageList()
+      self.assertEquals(len(message_list),1)
+    finally:
+      DB.query = DB.original_query
+      del DB.original_query
+
   def test_01_DeferedSetTitleSQLDict(self, quiet=0, run=run_all_test):
     # Test if we can add a complete sales order
     if not run: return
@@ -1518,6 +1563,26 @@
       LOG('Testing... ', 0, message)
     self.TryConflictErrorsWhileValidating('SQLQueue')
 
+  def test_72_TestErrorsWhileFinishingCommitDBWithSQLDict(self, quiet=0, run=run_all_test):
+    """
+    """
+    if not run: return
+    if not quiet:
+      message = '\nTest Errors While Finishing Commit DB With SQLDict'
+      ZopeTestCase._print(message)
+      LOG('Testing... ', 0, message)
+    self.TryErrorsWhileFinishingCommitDB('SQLDict')
+
+  def test_73_TestErrorsWhileFinishingCommitDBWithSQLQueue(self, quiet=0, run=run_all_test):
+    """
+    """
+    if not run: return
+    if not quiet:
+      message = '\nTest Errors While Finishing Commit DB With SQLQueue'
+      ZopeTestCase._print(message)
+      LOG('Testing... ', 0, message)
+    self.TryErrorsWhileFinishingCommitDB('SQLQueue')
+
 
 if __name__ == '__main__':
     framework()