Rev 202: Added verify_sigs option to TestCaseWithQueue.getQueue and QueueSetup. in http://bzr.daniel-watkins.co.uk/pqm/xmlrpc

[Daniel Watkins]

At http://bzr.daniel-watkins.co.uk/pqm/xmlrpc

------------------------------------------------------------
revno: 202
revision-id: daniel at daniel-watkins.co.uk-20080801004241-vu29ldmrbb0hyel9
parent: daniel at daniel-watkins.co.uk-20080801003329-8mex8k3m6fedizab
committer: Daniel Watkins <daniel at daniel-watkins.co.uk>
branch nick: xmlrpc
timestamp: Fri 2008-08-01 01:42:41 +0100
message:
  Added verify_sigs option to TestCaseWithQueue.getQueue and QueueSetup.
-------------- next part --------------
=== modified file 'pqm/tests/__init__.py'
--- a/pqm/tests/__init__.py	2008-07-22 17:02:03 +0000
+++ b/pqm/tests/__init__.py	2008-08-01 00:42:41 +0000
@@ -27,11 +27,12 @@
 class QueueSetup(object):
     """Setup a queue with mock messages in it."""
 
-    def __init__(self, processing=True, empty=False):
+    def __init__(self, processing=True, empty=False, verify_sigs=True):
         self.configFileName = "Foo"
         self.cwd = os.path.abspath(os.path.curdir)
         self.processing = processing
         self.empty = empty
+        self.verify_sigs = verify_sigs
         if not empty:
             self.message = sample_message
             self.message_bad = sample_message_bad
@@ -42,10 +43,16 @@
         myFile.write(dedent("""\
             [DEFAULT]
             queuedir=%s/queue
+            """ % (self.cwd,)))
+        if not self.verify_sigs:
+            myFile.write(dedent("""\
+                verify_sigs=False
+                """))
+        myFile.write(dedent("""\
             [http://www.example.com/bar/baz]
             project=project
             [http://www.example.com/fred/waldo]
-            """ % self.cwd))
+            """))
         myFile.close()
         self.queuedir = os.path.join(self.cwd, "queue")
         try:
@@ -75,7 +82,7 @@
 
 class TestCaseWithQueue(TestCaseWithTransport):
 
-    def getQueue(self, processing=True, empty=False):
-        queue = QueueSetup(processing, empty)
+    def getQueue(self, processing=True, empty=False, verify_sigs=True):
+        queue = QueueSetup(processing, empty, verify_sigs)
         queue.setUp()
         return queue