SF.net SVN: fclient: [245] trunk/sandbox/fcp/test_fcp/test_fcp2_0_client.py

[<ju...@us...>]

Revision: 245
          http://fclient.svn.sourceforge.net/fclient/?rev=245&view=rev
Author:   jurner
Date:     2008-02-24 03:50:25 -0800 (Sun, 24 Feb 2008)

Log Message:
-----------
added tests for putRedirect()

Modified Paths:
--------------
    trunk/sandbox/fcp/test_fcp/test_fcp2_0_client.py

Modified: trunk/sandbox/fcp/test_fcp/test_fcp2_0_client.py
===================================================================
--- trunk/sandbox/fcp/test_fcp/test_fcp2_0_client.py	2008-02-24 11:48:04 UTC (rev 244)
+++ trunk/sandbox/fcp/test_fcp/test_fcp2_0_client.py	2008-02-24 11:50:25 UTC (rev 245)
@@ -548,7 +548,6 @@
 		self.assertHasNextEvent(None)
 				
 		self.failUnless(myIdentifier in requestsAll)
-		myRequest = self.fcpClient.getRequest(myIdentifier)
 		self.assertEqual(myIdentifier, myRequest['Identifier'])
 		self.assertEqual(myRequest['FcRequestStatus'], consts.RequestStatus.Null)
 		
@@ -955,7 +954,79 @@
 #***********************************************************************************
 #
 #***********************************************************************************
-#TODO: class TestClientPut(BaseTestConnectedClient):
+#TODO:
+#
+#
+#
+class TestClientPut(BaseTestClient):
+	
+	
+	def testPutRedirect_Success(self):
+		# request a arbitrary file
+		myIdentifier = self.fcpClient.putRedirect(
+			'my-redirect-name',
+			'SSK@arbitrary-uri',
+			)
+		myRequest = self.fcpClient.getRequest(myIdentifier)
+		requestsAll = self.fcpClient.getRequests()
+		
+		self.assertHasNextMessage(consts.Message.ClientPut)
+		self.failUnless(myIdentifier in requestsAll)
+		
+		self.sendResponseMessage(
+				'PutSuccessful',
+				Identifier=myIdentifier,
+				URI='KSK@my-redirect-name'
+				)
+				
+		self.assertHasNextEvent(
+				self.fcpClient.events.RequestCompleted,
+				consts.Message.ClientPut,
+				('FcRequestStatus', 	consts.RequestStatus.Success | 
+													consts.RequestStatus.RemovedFromQueue |
+													consts.RequestStatus.Completed
+													),
+				)		
+				
+		self.assertHasNextEvent(None)
+		self.assertHasNextMessage(None)
+		self.failIf(requestsAll)		
+			
+		
+	def testPutRedirect_Failure(self):
+		# request a arbitrary file
+		myIdentifier = self.fcpClient.putRedirect(
+			'my-redirect-name',
+			'SSK@arbitrary-uri',
+			)
+		myRequest = self.fcpClient.getRequest(myIdentifier)
+		requestsAll = self.fcpClient.getRequests()
+		
+		self.assertHasNextMessage(consts.Message.ClientPut)
+		self.failUnless(myIdentifier in requestsAll)
+		
+		self.sendResponseMessage(
+				'PutFailed',
+				Identifier=myIdentifier,
+				Code='5', 			# rout not found
+				)
+				
+		self.assertHasNextEvent(
+				self.fcpClient.events.RequestFailed,
+				consts.Message.ClientPut,
+				('FcRequestStatus', 	consts.RequestStatus.Error | 
+													consts.RequestStatus.RemovedFromQueue |
+													consts.RequestStatus.Completed
+													),
+				)		
+				
+		self.assertHasNextEvent(None)
+		self.assertHasNextMessage(None)
+		self.failIf(requestsAll)		
+			
+		
+		
+		
 
 #***********************************************************************************
 #
@@ -1856,6 +1927,7 @@
 			TestConnect,
 			TestDisconnectReason,
 			TestClientGet,
+			TestClientPut,
 			TestRequests,
 			TestRestoreRequests,
 			TestDDA,


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.