SF.net SVN: fclient: [463] trunk/fcp2/src/fcp2/test_fcp/test_client.py
Status: Pre-Alpha
Brought to you by:
jurner
Menu
▾
▴
SF.net SVN: fclient: [463] trunk/fcp2/src/fcp2/test_fcp/test_client.py
|
From: <jU...@us...> - 2008-07-01 11:27:47
|
Revision: 463
http://fclient.svn.sourceforge.net/fclient/?rev=463&view=rev
Author: jUrner
Date: 2008-07-01 04:27:56 -0700 (Tue, 01 Jul 2008)
Log Message:
-----------
for ease of use, all necessary symbols are now imported to main
Modified Paths:
--------------
trunk/fcp2/src/fcp2/test_fcp/test_client.py
Modified: trunk/fcp2/src/fcp2/test_fcp/test_client.py
===================================================================
--- trunk/fcp2/src/fcp2/test_fcp/test_client.py 2008-07-01 11:27:47 UTC (rev 462)
+++ trunk/fcp2/src/fcp2/test_fcp/test_client.py 2008-07-01 11:27:56 UTC (rev 463)
@@ -17,13 +17,8 @@
def __del__(self): sys.path.pop(0)
hack = _RelImportHack(3)
-from fcp2 import client
-from fcp2.client import Client
-from fcp2 import consts
+import fcp2
-from fcp2 import iohandler
-from fcp2 import message
-
del hack
#<-- rel import hack
@@ -34,16 +29,17 @@
DIR = os.path.dirname(os.path.abspath(__file__))
##TestAgainstNode = 0 # don't know how to test against node. Do not touch this!
-
+# for testing some valid key data
+DummyKeyData = 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa,aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa,AAAAAAA'
#***********************************************************************************
#
#***********************************************************************************
class BaseTestClient(unittest.TestCase):
"""Base class for all tests"""
- client = Client(
- #debugVerbosity=Client.consts.DebugVerbosity.Debug
- debugVerbosity=Client.consts.DebugVerbosity.Quiet
+ client = fcp2.Client(
+ #debugVerbosity=Client.fcp2.DebugVerbosity.Debug
+ debugVerbosity=fcp2.ConstDebugVerbosity.Quiet
)
client.ioHandler.setIOPrototype(DummyIO)
@@ -88,7 +84,7 @@
self.assertHasNextEvent(
self.client.events.ClientConnected,
- consts.Message.NodeHello,
+ fcp2.MsgNodeHello,
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -100,14 +96,14 @@
self.client.close()
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.Close),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.Close),
)
def assertHasNextEvent(self,
expectedEvent=None,
- messageName=None,
+ message=None,
param1=None,
param2=None,
param3=None,
@@ -130,8 +126,8 @@
event, msg = self.events.pop(0)
self.assertEqual(event, expectedEvent)
- if messageName is not None:
- self.assertEqual(msg.name, messageName)
+ if message is not None:
+ self.assertEqual(msg.name, message.name)
if param1 is not None:
param1, value1 = param1
self.failUnless(param1 in msg.params)
@@ -159,7 +155,7 @@
return msg
def assertHasNextMessage(self,
- messageName,
+ message,
param1=None,
param2=None,
param3=None,
@@ -185,11 +181,11 @@
@return: message if a message was received or None
"""
msg = self.getNextMessage()
- if messageName is None:
+ if message is None:
self.failUnless(msg is None)
else:
self.failIf(msg is None)
- self.assertEqual(msg.name, messageName)
+ self.assertEqual(msg.name, message.name)
if param1 is not None:
param1, value1 = param1
self.failUnless(param1 in msg.params)
@@ -256,10 +252,10 @@
def sendResponseMessage(self, messageName, data=None, callNext=True, **params):
"""Sends a message to the client"""
- if messageName in message.MessagesAll:
- msgClass = message.MessagesAll[messageName]
+ if messageName in fcp2.MessagesAll:
+ msgClass = fcp2.MessagesAll[messageName]
else:
- msgClass = message.newMessageClass(messageName)
+ msgClass = fcp2.newMessageClass(messageName)
msg = msgClass(data=data, **params)
self.client.ioHandler.io.readBuffer += msg.toString()
if callNext:
@@ -280,7 +276,7 @@
self.client.ioHandler.io.setReverseDirection(True)
try:
msg = self.client.ioHandler.readMessage()
- except consts.IOTimeoutError:
+ except fcp2.ErrorIOTimeout:
return None
finally:
self.client.ioHandler.io.setReverseDirection(False)
@@ -328,8 +324,8 @@
self.client.close()
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.Close),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.Close),
)
def test_close_connected_client(self):
@@ -337,8 +333,8 @@
self.client.close()
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.Close),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.Close),
)
#***********************************************************************************
@@ -388,7 +384,7 @@
self.assertHasNextEvent(
self.client.events.ClientConnected,
- consts.Message.NodeHello,
+ fcp2.MsgNodeHello,
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -403,8 +399,8 @@
self.failUnless(nodeHello is None)
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.IOConnectFailed),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.IOConnectFailed),
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -418,8 +414,8 @@
self.failUnless(nodeHello is None)
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.NoNodeHello),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.NoNodeHello),
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -434,12 +430,12 @@
enum.next()
except StopIteration:
break
- except consts.IOBrokenError, d:
+ except fcp2.ErrorIOBroken, d:
errorRaised = True
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.ConnectionDied),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.ConnectionDied),
#('Param', None),
)
break
@@ -462,8 +458,8 @@
self.failUnless(nodeHello is None)
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.UnknownNodeHello),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.UnknownNodeHello),
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -491,7 +487,7 @@
self.assertHasNextEvent(
self.client.events.ClientConnected,
- consts.Message.NodeHello,
+ fcp2.MsgNodeHello,
)
self.assertHasNextEvent(None)
#self.assertHasNextMessage(None) # due to our message hacking, NodeHello is still in io
@@ -522,12 +518,12 @@
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.Reconnect)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.Reconnect)
)
self.assertHasNextEvent(
self.client.events.ClientConnected,
- consts.Message.NodeHello,
+ fcp2.MsgNodeHello,
)
self.assertHasNextEvent(None)
#self.assertHasNextMessage(None) # due to our message hacking, NodeHello is still in io
@@ -556,8 +552,8 @@
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.VersionMissmatch)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.VersionMissmatch)
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -586,8 +582,8 @@
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.VersionMissmatch)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.VersionMissmatch)
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -608,8 +604,8 @@
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.DuplicateClientName)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.DuplicateClientName)
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -624,7 +620,7 @@
def test_closeNode(self):
self.connectClient()
self.client.closeNode()
- self.assertHasNextMessage('Shutdown')
+ self.assertHasNextMessage(fcp2.MsgShutdown)
self.sendResponseMessage(
'ProtocolError',
Code='18'
@@ -632,8 +628,8 @@
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.NodeClosing)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.NodeClosing)
)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -665,7 +661,7 @@
def test_get_setDebugVerbosity(self):
oldVerbosity = self.client.getDebugVerbosity()
- self.client.setDebugVerbosity(self.client.consts.DebugVerbosity.Quiet)
+ self.client.setDebugVerbosity(fcp2.ConstDebugVerbosity.Quiet)
self.client.setDebugVerbosity(oldVerbosity)
#***********************************************************************************
@@ -727,7 +723,7 @@
msg = self.client.next()
msg2 = self.assertHasNextEvent(
self.client.events.Idle,
- self.client.message.ClientSocketTimeout.name,
+ fcp2.MsgClientSocketTimeout,
)
self.failUnless(msg == msg2)
@@ -736,11 +732,11 @@
self.connectClient()
self.getIO().setBroken(True)
- self.assertRaises(consts.IOBrokenError, self.client.next, )
+ self.assertRaises(fcp2.ErrorIOBroken, self.client.next, )
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.ConnectionDied)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.ConnectionDied)
)
self.assertHasNextEvent(None)
@@ -777,11 +773,11 @@
self.connectClient()
self.getIO().setBroken(True)
- self.assertRaises(consts.IOBrokenError, self.client.sendMessage, self.client.message.ClientHello())
+ self.assertRaises(fcp2.ErrorIOBroken, self.client.sendMessage, fcp2.MsgClientHello())
self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.ConnectionDied)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.ConnectionDied)
)
self.assertHasNextEvent(None)
@@ -791,9 +787,9 @@
def test_messageSend(self):
self.connectClient()
- self.client.sendMessage(self.client.message.ClientHello())
+ self.client.sendMessage(fcp2.MsgClientHello())
msg = self.client.next()
- self.assertHasNextMessage('ClientHello')
+ self.assertHasNextMessage(fcp2.MsgClientHello)
self.assertHasNextEvent(self.client.events.Idle)
self.assertHasNextEvent(None)
@@ -818,7 +814,7 @@
withDataTypes=True,
)
msg = self.client.next()
- self.assertHasNextMessage('GetConfig',
+ self.assertHasNextMessage(fcp2.MsgGetConfig,
('WithCurrent', True),
('WithDefaults', True),
('WithExpertFlag', True),
@@ -836,7 +832,7 @@
)
self.assertHasNextEvent(
self.client.events.ConfigData,
- consts.Message.ConfigData,
+ fcp2.MsgConfigData,
('foo', '1234')
)
@@ -855,7 +851,7 @@
{'foo': '1234'}
)
msg = self.client.next()
- self.assertHasNextMessage('ModifyConfig',
+ self.assertHasNextMessage(fcp2.MsgModifyConfig,
('foo', '1234'),
)
self.assertHasNextEvent(self.client.events.Idle)
@@ -871,22 +867,22 @@
def test_100_request_registered(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getData(myKey)
requestsAll = self.client.getRequests()
self.failUnless(myIdentifier in requestsAll)
myRequest = self.client.getRequest(myIdentifier)
- self.assertEqual(myRequest['RequestType'], self.client.consts.RequestType.GetData)
+ self.assertEqual(myRequest['RequestType'], fcp2.ConstRequestType.GetData)
def test_300_message_send(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getData(myKey)
requestsAll = self.client.getRequests()
self.assertHasNextMessage(
- 'ClientGet',
+ fcp2.MsgClientGet,
('URI', myKey),
)
@@ -898,11 +894,11 @@
def test_400_progress(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getData(myKey)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
'SimpleProgress',
Identifier=myIdentifier,
@@ -915,7 +911,7 @@
self.assertHasNextEvent(
self.client.events.RequestProgress,
- 'ClientGet',
+ fcp2.MsgClientGet,
)
self.assertHasNextEvent(None)
@@ -926,11 +922,11 @@
def test_500_completed_successfuly(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getData(myKey)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
data = 'foo'
params = {
'Identifier': myIdentifier,
@@ -955,10 +951,10 @@
# client should complete and remove the request
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
data=data
)
@@ -973,13 +969,13 @@
def test_600_completed_with_error(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getData(myKey)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
- 'GetFailed',
+ fcp2.MsgGetFailed.name,
Code='28', # All data not found
Identifier=myIdentifier,
Global='false',
@@ -987,10 +983,10 @@
)
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -1005,11 +1001,11 @@
def test_700_peristent_request_auto_retrieve_data(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
- myIdentifier = self.client.getData(myKey, persistence=self.client.consts.Persistence.Forever)
+ myKey = fcp2.Key('KSK@foo')
+ myIdentifier = self.client.getData(myKey, persistence=fcp2.ConstPersistence.Forever)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
data = 'foo'
params = {
@@ -1023,7 +1019,7 @@
**params
)
- self.assertHasNextMessage('GetRequestStatus')
+ self.assertHasNextMessage(fcp2.MsgGetRequestStatus)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1033,11 +1029,11 @@
def test_800_peristent_request_not_removed_on_success(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
- myIdentifier = self.client.getData(myKey, persistence=self.client.consts.Persistence.Forever)
+ myKey = fcp2.Key('KSK@foo')
+ myIdentifier = self.client.getData(myKey, persistence=fcp2.ConstPersistence.Forever)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
data = 'foo'
self.sendResponseMessage(
'AllData',
@@ -1059,11 +1055,11 @@
def test_900_peristent_request_not_removed_on_error(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
- myIdentifier = self.client.getData(myKey, persistence=self.client.consts.Persistence.Forever)
+ myKey = fcp2.Key('KSK@foo')
+ myIdentifier = self.client.getData(myKey, persistence=fcp2.ConstPersistence.Forever)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
'GetFailed',
Code='28', # All data not found
@@ -1094,15 +1090,15 @@
callNext=False
)
- self.assertRaises(consts.MessageParseError, self.client.next)
+ self.assertRaises(fcp2.ErrorMessageParse, self.client.next)
self.failIf(myIdentifier in requestsAll)
def test_920_restore_peristent_request_success(self):
self.connectClient()
requestsAll = self.client.getRequests()
- myKey = self.client.key.key('KSK@foo')
- myIdentifier = self.client.getData(myKey, persistence=self.client.consts.Persistence.Forever)
+ myKey = fcp2.Key('KSK@foo')
+ myIdentifier = self.client.getData(myKey, persistence=fcp2.ConstPersistence.Forever)
self.failUnless(myIdentifier in requestsAll)
myRequest = self.client.getRequest(myIdentifier)
del requestsAll[myIdentifier]
@@ -1115,9 +1111,9 @@
myRequest = self.client.getRequest(myIdentifier)
msg = self.assertHasNextEvent(
self.client.events.RequestRestored,
- 'ClientGet',
+ fcp2.MsgClientGet,
('Identifier', myIdentifier),
- ('RequestStatus', consts.RequestStatus.Restored), # no RequestStatus.Pending flag should be set here
+ ('RequestStatus', fcp2.ConstRequestStatus.Restored), # no RequestStatus.Pending flag should be set here
)
@@ -1129,24 +1125,24 @@
def test_100_request_registered(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(myKey, 'foo.txt')
requestsAll = self.client.getRequests()
self.failUnless(myIdentifier in requestsAll)
myRequest = self.client.getRequest(myIdentifier)
- self.assertEqual(myRequest['RequestType'], self.client.consts.RequestType.GetFile)
+ self.assertEqual(myRequest['RequestType'], fcp2.ConstRequestType.GetFile)
def test_200_key_object_is_accepted(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(myKey, 'foo.txt')
requestsAll = self.client.getRequests()
def test_300_dda_denied(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
os.path.join(DIR, 'DDATest.txt')
@@ -1154,7 +1150,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
'ProtocolError',
Code=25, # DDADenied
@@ -1166,7 +1162,7 @@
# client should respond with a TestDDARequest
self.assertHasNextMessage(
- consts.Message.TestDDARequest,
+ fcp2.MsgTestDDARequest,
('Directory', DIR),
('WantWriteDirectory', True)
)
@@ -1184,7 +1180,7 @@
# client should respond with a TestDDAResponse
self.assertHasNextMessage(
- consts.Message.TestDDAResponse,
+ fcp2.MsgTestDDAResponse,
('Directory', DIR)
)
@@ -1203,7 +1199,7 @@
self.failIf(os.path.isfile(fpath))
# client sahould send a new ClientGet
- msg = self.assertHasNextMessage(consts.Message.ClientGet)
+ msg = self.assertHasNextMessage(fcp2.MsgClientGet)
# no events should have been triggered upo to now
self.assertHasNextEvent(None)
@@ -1230,16 +1226,16 @@
def test_100_request_registered(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getKeyInfo(myKey)
requestsAll = self.client.getRequests()
self.failUnless(myIdentifier in requestsAll)
myRequest = self.client.getRequest(myIdentifier)
- self.assertEqual(myRequest['RequestType'], self.client.consts.RequestType.GetKeyInfo)
+ self.assertEqual(myRequest['RequestType'], fcp2.ConstRequestType.GetKeyInfo)
def test_200_key_object_is_accepted(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getKeyInfo(myKey)
requestsAll = self.client.getRequests()
@@ -1247,12 +1243,12 @@
def test_300_getKeyInfo_Success(self):
self.connectClient()
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getKeyInfo(myKey)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage('ClientGet')
+ self.assertHasNextMessage(fcp2.MsgClientGet)
data = 'foo'
params = {
@@ -1267,10 +1263,10 @@
)
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
@@ -1284,12 +1280,12 @@
# test specdial case where ProtocolError.TooBig is handled as success
# request a arbitrary uri
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getKeyInfo(myKey)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
'GetFailed',
Code='21', # Too big
@@ -1299,10 +1295,10 @@
)
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
@@ -1315,12 +1311,12 @@
self.connectClient()
# request a arbitrary file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getKeyInfo(myKey)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.sendResponseMessage(
'GetFailed',
Code='28', # All data not found
@@ -1330,10 +1326,10 @@
)
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
@@ -1351,8 +1347,8 @@
self.sendResponseMessage('CloseConnectionDuplicateClientName')
msg = self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.DuplicateClientName),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.DuplicateClientName),
)
self.failIf(self.ioOpen())
@@ -1363,13 +1359,13 @@
def test_1001_SocketDied_Receive(self):
self.connectClient()
self.getIO().setBroken(True)
- self.assertRaises(consts.IOBrokenError, self.client.next)
+ self.assertRaises(fcp2.ErrorIOBroken, self.client.next)
# check if ClientDisconnected events has been triggered
msg = self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.ConnectionDied),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.ConnectionDied),
)
self.failIf(self.ioOpen())
@@ -1383,13 +1379,13 @@
self.getIO().setBroken(True)
# send a test message
- self.assertRaises(consts.IOBrokenError, self.client.sendMessage, message.newMessageClass('test')())
+ self.assertRaises(fcp2.ErrorIOBroken, self.client.sendMessage, fcp2.newMessageClass('test')())
# check if ClientDisconnected events has been triggered
msg = self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.ConnectionDied),
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.ConnectionDied),
)
self.failIf(self.ioOpen())
@@ -1402,7 +1398,7 @@
self.connectClient()
self.client.closeNode()
- msg = self.assertHasNextMessage(consts.Message.Shutdown)
+ msg = self.assertHasNextMessage(fcp2.MsgShutdown)
self.sendResponseMessage(
'ProtocolError',
Code='18', # Shutting down
@@ -1411,8 +1407,8 @@
# check events the client triggered
msg = self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.NodeClosing)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.NodeClosing)
)
self.failIf(self.ioOpen())
@@ -1426,7 +1422,7 @@
for n, nodeHello in enumerate(self.client.iterConnect(duration=1, timeout=0.1)):
if n == 2:
self.assertHasNextMessage(
- consts.Message.ClientHello
+ fcp2.MsgClientHello
)
self.sendResponseMessage(
'NodeHello',
@@ -1447,8 +1443,8 @@
# check events the client triggered
msg = self.assertHasNextEvent(
self.client.events.ClientDisconnected,
- consts.Message.ClientDisconnected,
- ('DisconnectReason', consts.DisconnectReason.VersionMissmatch)
+ fcp2.MsgClientDisconnected,
+ ('DisconnectReason', fcp2.ConstDisconnectReason.VersionMissmatch)
)
self.failIf(self.ioOpen())
@@ -1470,12 +1466,12 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.assertHasNextEvent(None)
self.failUnless(myIdentifier in requestsAll)
self.assertEqual(myIdentifier, myRequest['Identifier'])
- self.assertEqual(myRequest['RequestStatus'], consts.RequestStatus.Null)
+ self.assertEqual(myRequest['RequestStatus'], fcp2.ConstRequestStatus.Null)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1494,7 +1490,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1544,23 +1540,23 @@
# client should complete and remove the request
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
data=data
)
self.failIf(myIdentifier in requestsAll)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
# cheat a bit to test peristence == Forever (client should not remove request)
requestsAll[myIdentifier] =myRequest
- myRequest['Persistence'] = consts.Persistence.Forever
- myRequest['RequestStatus'] &= ~(consts.RequestStatus.Success |
- consts.RequestStatus.Completed |
- consts.RequestStatus.RemovedFromQueue
+ myRequest['Persistence'] = fcp2.Persistence.Forever
+ myRequest['RequestStatus'] &= ~(fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.Completed |
+ fcp2.ConstRequestStatus.RemovedFromQueue
)
self.sendResponseMessage(
'AllData',
@@ -1573,12 +1569,12 @@
# client should complete but not remove the request
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success | consts.RequestStatus.Completed),
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success | fcp2.ConstRequestStatus.Completed),
data=data
)
self.failUnless(myIdentifier in requestsAll)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1596,7 +1592,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1617,10 +1613,10 @@
# client should complete request and remove it
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.assertHasNextEvent(None)
@@ -1631,10 +1627,10 @@
# cheat a bit to test peristence == Forever (client should not remove request)
requestsAll[myIdentifier] =myRequest
- myRequest['Persistence'] = consts.Persistence.Forever
- myRequest['RequestStatus'] &= ~(consts.RequestStatus.Error |
- consts.RequestStatus.Completed |
- consts.RequestStatus.RemovedFromQueue
+ myRequest['Persistence'] = fcp2.Persistence.Forever
+ myRequest['RequestStatus'] &= ~(fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.Completed |
+ fcp2.ConstRequestStatus.RemovedFromQueue
)
self.sendResponseMessage(
'GetFailed',
@@ -1647,8 +1643,8 @@
# client should complete but not remove the request
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error | consts.RequestStatus.Completed),
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error | fcp2.ConstRequestStatus.Completed),
)
self.failUnless(myIdentifier in requestsAll)
self.assertHasNextEvent(None)
@@ -1668,7 +1664,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1691,14 +1687,14 @@
)
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1715,7 +1711,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1735,10 +1731,10 @@
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
@@ -1757,7 +1753,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1780,14 +1776,14 @@
)
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1804,7 +1800,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1823,13 +1819,13 @@
)
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1846,7 +1842,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -1865,13 +1861,13 @@
)
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
- self.failUnless(myRequest['RequestStatus'] & consts.RequestStatus.Completed)
+ self.failUnless(myRequest['RequestStatus'] & fcp2.ConstRequestStatus.Completed)
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -1886,7 +1882,7 @@
def test_putData_Success(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putData(
myKey,
'any data here'
@@ -1894,7 +1890,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -1905,10 +1901,10 @@
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -1920,7 +1916,7 @@
def test_putData_Failure(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putData(
myKey,
'any data here'
@@ -1929,7 +1925,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -1940,10 +1936,10 @@
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -1957,7 +1953,7 @@
def test_putDir_Success(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putDir(
myKey,
'myDirectory'
@@ -1965,7 +1961,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPutDiskDir)
+ self.assertHasNextMessage(fcp2.MsgClientPutDiskDir)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -1976,10 +1972,10 @@
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientPutDiskDir,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPutDiskDir,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -1991,7 +1987,7 @@
def test_putDir_Failure(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putDir(
myKey,
'myDirectory'
@@ -1999,7 +1995,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPutDiskDir)
+ self.assertHasNextMessage(fcp2.MsgClientPutDiskDir)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -2010,10 +2006,10 @@
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientPutDiskDir,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPutDiskDir,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2029,7 +2025,7 @@
def test_putFile_Success(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putFile(
myKey,
'myFile.txt'
@@ -2037,7 +2033,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -2048,10 +2044,10 @@
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2063,7 +2059,7 @@
def test_putFile_Failure(self):
self.connectClient()
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putFile(
myKey,
'myFile.txt'
@@ -2071,7 +2067,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -2082,10 +2078,10 @@
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2102,29 +2098,29 @@
items = [
{
- 'RequestType': consts.RequestType.PutData,
+ 'RequestType': fcp2.ConstRequestType.PutData,
'Data': '12345',
'Name': 'myItem0',
},
{
- 'RequestType': consts.RequestType.PutFile,
+ 'RequestType': fcp2.ConstRequestType.PutFile,
'Filename': 'myFile.txt',
'Name': 'myItem1',
},
{
- 'RequestType': consts.RequestType.PutRedirect,
+ 'RequestType': fcp2.ConstRequestType.PutRedirect,
'TargetURI': 'CHK@123456789',
'Name': 'myItem2',
},
{
- 'RequestType': consts.RequestType.PutData,
+ 'RequestType': fcp2.ConstRequestType.PutData,
'Data': '67890',
'Name': 'myItem3',
},
]
# request a arbitrary file
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
myIdentifier = self.client.putMultiple(
myKey,
items
@@ -2133,7 +2129,7 @@
requestsAll = self.client.getRequests()
msg = self.assertHasNextMessage(
- consts.Message.ClientPutComplexDir,
+ fcp2.MsgClientPutComplexDir,
('Files.0.Name', 'myItem0'),
('Files.0.UploadFrom', 'direct'),
('Files.0.DataLength', 5),
@@ -2166,10 +2162,10 @@
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientPutComplexDir,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPutComplexDir,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2184,12 +2180,12 @@
# upload directory is not allowed
items = [
{
- 'RequestType': consts.RequestType.PutDir,
+ 'RequestType': fcp2.ConstRequestType.PutDir,
'Data': '12345',
'Name': 'myItem0',
},
]
- myKey = self.client.key.KSK('foo')
+ myKey = fcp2.KeyKSK('foo')
self.assertRaises(ValueError, self.client.putMultiple, myKey, items)
#TODO: how to test required params?
@@ -2198,7 +2194,7 @@
# no request type specified
items = [
{
- #'RequestType': consts.RequestType.PutData,
+ #'RequestType': fcp2.ConstRequestType.PutData,
'Data': '12345',
'Name': 'myItem0',
},
@@ -2208,7 +2204,7 @@
# param missing (we enforce all required parameters)
items = [
{
- 'RequestType': consts.RequestType.PutData,
+ 'RequestType': fcp2.ConstRequestType.PutData,
#'Data': '12345',
#'Name': 'myItem0',
},
@@ -2225,8 +2221,8 @@
self.connectClient()
# request a arbitrary file
- myRedirect = self.client.key.KSK('foo')
- myKey = self.client.key.key('CHK@' + self.client.key.DummyKeyData)
+ myRedirect = fcp2.KeyKSK('foo')
+ myKey = fcp2.Key('CHK@' + DummyKeyData)
myIdentifier = self.client.putRedirect(
myRedirect,
myKey,
@@ -2234,7 +2230,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -2245,10 +2241,10 @@
self.assertHasNextEvent(
self.client.events.RequestCompleted,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Success |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Success |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2261,8 +2257,8 @@
self.connectClient()
# request a arbitrary file
- myRedirect = self.client.key.KSK('foo')
- myKey = self.client.key.key('CHK@' + self.client.key.DummyKeyData)
+ myRedirect = fcp2.KeyKSK('foo')
+ myKey = fcp2.Key('CHK@' + DummyKeyData)
myIdentifier = self.client.putRedirect(
myRedirect,
myKey,
@@ -2270,7 +2266,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientPut)
+ self.assertHasNextMessage(fcp2.MsgClientPut)
self.failUnless(myIdentifier in requestsAll)
self.sendResponseMessage(
@@ -2281,10 +2277,10 @@
self.assertHasNextEvent(
self.client.events.RequestFailed,
- consts.Message.ClientPut,
- ('RequestStatus', consts.RequestStatus.Error |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientPut,
+ ('RequestStatus', fcp2.ConstRequestStatus.Error |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
@@ -2302,18 +2298,18 @@
# request a arbitrary file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
'arbitryry.txt',
persistentUserData='foo',
- priorityClass=consts.Priority.Medium,
- persistence=consts.Persistence.Reboot,
+ priorityClass=fcp2.ConstPriority.Medium,
+ persistence=fcp2.ConstPersistence.Reboot,
)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -2321,12 +2317,12 @@
Started='false',
**myRequest.params
)
- #self.assertNextMessage(consts.Message.ClientGet)
+ #self.assertNextMessage(fcp2.MsgClientGet)
# test modify persistent user data
- self.client.modifyRequest(myIdentifier, persistentUserData='bar', priorityClass=consts.Priority.High)
- msg = self.assertHasNextMessage(consts.Message.ModifyPersistentRequest)
+ self.client.modifyRequest(myIdentifier, persistentUserData='bar', priorityClass=fcp2.ConstPriority.High)
+ msg = self.assertHasNextMessage(fcp2.MsgModifyPersistentRequest)
# respond to the file request
self.sendResponseMessage(
@@ -2335,10 +2331,10 @@
)
self.assertHasNextEvent(self.client.events.RequestModified)
- self.failUnless(consts.RequestModified.PersistentUserData in myRequest['Modified'])
- self.failUnless(consts.RequestModified.PriorityClass in myRequest['Modified'])
+ self.failUnless(fcp2.ConstRequestModified.PersistentUserData in myRequest['Modified'])
+ self.failUnless(fcp2.ConstRequestModified.PriorityClass in myRequest['Modified'])
self.assertEqual('bar', myRequest['PersistentUserData'])
- self.assertEqual(consts.Priority.High, myRequest['PriorityClass'])
+ self.assertEqual(fcp2.ConstPriority.High, myRequest['PriorityClass'])
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -2351,17 +2347,17 @@
self.connectClient()
# request a arbitrary file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
'arbitryry.txt',
persistentUserData='foo',
- priorityClass=consts.Priority.Medium,
+ priorityClass=fcp2.ConstPriority.Medium,
)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
@@ -2371,12 +2367,12 @@
)
# test modify persistent user data
- self.client.modifyRequest(myIdentifier, persistentUserData='bar', priorityClass=consts.Priority.High)
+ self.client.modifyRequest(myIdentifier, persistentUserData='bar', priorityClass=fcp2.ConstPriority.High)
# no way to modify priority in Fcp. The client ignores all attempts to do so currently
# no message is send,instead the event is triggered emidiately
- #msg = self.assertHasNextMessage(consts.Message.ModifyPersistentRequest)
+ #msg = self.assertHasNextMessage(fcp2.MsgModifyPersistentRequest)
# respond to the file request
#self.sendResponseMessage(
# 'PersistentRequestModified',
@@ -2385,10 +2381,10 @@
self.assertHasNextEvent(self.client.events.RequestModified)
- self.failUnless(consts.RequestModified.PersistentUserData in myRequest['Modified'])
- #self.failUnless(consts.RequestModified.PriorityClass in myRequest['Modified'])
+ self.failUnless(fcp2.ConstRequestModified.PersistentUserData in myRequest['Modified'])
+ #self.failUnless(fcp2.RequestModified.PriorityClass in myRequest['Modified'])
self.assertEqual('bar', myRequest['PersistentUserData'])
- #self.assertEqual(consts.Priority.High, myRequest['PriorityClass'])
+ #self.assertEqual(fcp2.Priority.High, myRequest['PriorityClass'])
self.assertHasNextEvent(None)
self.assertHasNextMessage(None)
@@ -2404,7 +2400,7 @@
self.connectClient()
# request a file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
'arbitrary.txt'
@@ -2412,7 +2408,7 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond to the file request
self.sendResponseMessage(
'PersistentGet',
@@ -2426,11 +2422,11 @@
# now cancel request
self.client.removeRequest(myIdentifier)
- self.assertHasNextMessage('RemoveRequest')
+ self.assertHasNextMessage(fcp2.MsgRemoveRequest)
# of our request should be marked as removed
- self.assertEqual(myRequest['RequestStatus'], consts.RequestStatus.Removed |
- consts.RequestStatus.Completed
+ self.assertEqual(myRequest['RequestStatus'], fcp2.ConstRequestStatus.Removed |
+ fcp2.ConstRequestStatus.Completed
)
# respond with a Getfailed
@@ -2444,10 +2440,10 @@
# now the request should have been removed
self.assertHasNextEvent(
self.client.events.RequestRemoved,
- consts.Message.ClientGet,
- ('RequestStatus', consts.RequestStatus.Removed |
- consts.RequestStatus.RemovedFromQueue |
- consts.RequestStatus.Completed
+ fcp2.MsgClientGet,
+ ('RequestStatus', fcp2.ConstRequestStatus.Removed |
+ fcp2.ConstRequestStatus.RemovedFromQueue |
+ fcp2.ConstRequestStatus.Completed
),
)
self.failIf(myIdentifier in requestsAll)
@@ -2468,7 +2464,7 @@
# throw an invalid PersistentRequest at the client
myIdentifier = '123456789'
self.assertRaises(
- consts.MessageParseError,
+ fcp2.ErrorMessageParse,
self.sendResponseMessage,
'PersistentGet',
Identifier=myIdentifier,
@@ -2489,14 +2485,14 @@
#NOTE: the client will recognize it as unknown request and query to remove it
#self.assertHasNextMessage(None)
- self.assertHasNextMessage(consts.Message.RemoveRequest)
+ self.assertHasNextMessage(fcp2.MsgRemoveRequest)
def test_restorePersistentGet_validIdentifier(self):
self.connectClient()
# we need a valid identifier to restore a request, so hack a bit
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
'arbitryry.txt'
@@ -2504,14 +2500,14 @@
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
self.client.removeRequest(myIdentifier)
self.sendResponseMessage(
'PersistentRequestRemoved',
Identifier=myIdentifier,
)
- self.assertHasNextMessage(self.client.message.RemoveRequest.name)
+ self.assertHasNextMessage(fcp2.MsgRemoveRequest)
self.assertHasNextEvent(self.client.events.RequestRemoved)
# throw a PersistentGet at the client with the identifier we hacked
@@ -2529,9 +2525,9 @@
# check if the client restored the request
msg = self.assertHasNextEvent(
self.client.events.RequestRestored,
- consts.Message.ClientGet,
+ fcp2.MsgClientGet,
('Identifier', myIdentifier),
- ('RequestStatus', consts.RequestStatus.Restored), # no RequestStatus.Pending flag should be set here
+ ('RequestStatus', fcp2.ConstRequestStatus.Restored), # no RequestStatus.Pending flag should be set here
)
self.failUnless(myIdentifier in requestsAll)
@@ -2553,7 +2549,7 @@
self.connectClient()
# request a file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
os.path.join(DIR, 'DDATest.txt')
@@ -2562,7 +2558,7 @@
requestsAll = self.client.getRequests()
# client schould send a ClientGet
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond with a ProtocolError
self.sendResponseMessage(
@@ -2576,14 +2572,14 @@
# client should respond with a TestDDARequest
self.assertHasNextMessage(
- consts.Message.TestDDARequest,
+ fcp2.MsgTestDDARequest,
('Directory', DIR),
('WantWriteDirectory', True)
)
#msg = self.nextMessage()
#self.failIf(msg is None)
- #self.assertEqual(msg.name, consts.Message.TestDDARequest)
+ #self.assertEqual(msg.name, fcp2.MsgTestDDARequest)
##self.assertEqual(msg['Directory'], DIR)
#self.failIf(not msg['WantWriteDirectory'])
@@ -2601,7 +2597,7 @@
# client should respond with a TestDDAResponse
self.assertHasNextMessage(
- consts.Message.TestDDAResponse,
+ fcp2.MsgTestDDAResponse,
('Directory', DIR)
)
@@ -2620,7 +2616,7 @@
self.failIf(os.path.isfile(fpath))
# client sahould send a new ClientGet
- msg = self.assertHasNextMessage(consts.Message.ClientGet)
+ msg = self.assertHasNextMessage(fcp2.MsgClientGet)
# no events should have been triggered upo to now
self.assertHasNextEvent(None)
@@ -2655,7 +2651,7 @@
self.connectClient()
# request a file
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
os.path.join(DIR, 'test.txt')
@@ -2664,7 +2660,7 @@
requestsAll = self.client.getRequests()
# client schould send a ClientGet
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# respond with an IdentifierCollision
@@ -2674,16 +2670,16 @@
)
# client schould send a new ClientGet
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# check if RequestModified event has been triggered
msg = self.assertHasNextEvent(
self.client.events.RequestModified,
- consts.Message.ClientGet,
+ fcp2.MsgClientGet,
)
- self.failUnless(consts.RequestModified.Identifier in msg['Modified'])
- oldIdentifier = msg['Modified'][consts.RequestModified.Identifier]
+ self.failUnless(fcp2.ConstRequestModified.Identifier in msg['Modified'])
+ oldIdentifier = msg['Modified'][fcp2.ConstRequestModified.Identifier]
newIdentifier = msg['Identifier']
self.assertEqual(oldIdentifier, myIdentifier)
self.assertNotEqual(newIdentifier, myIdentifier)
@@ -2703,17 +2699,17 @@
open(fpath, 'wb').close()
self.tmpfiles.append(fpath)
- myKey = self.client.key.key('KSK@foo')
+ myKey = fcp2.Key('KSK@foo')
myIdentifier = self.client.getFile(
myKey,
fpath,
- filenameCollision=consts.FilenameCollision.HandleRename,
+ filenameCollision=fcp2.ConstFilenameCollision.HandleRename,
)
myRequest = self.client.getRequest(myIdentifier)
requestsAll = self.client.getRequests()
# client schould send a ClientGet
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
# now respond with a ProtocolError
self.sendResponseMessage(
@@ -2726,23 +2722,23 @@
)
# client schould send a new ClientGet with a different filename
- self.assertHasNextMessage(consts.Message.ClientGet)
+ self.assertHasNextMessage(fcp2.MsgClientGet)
msg = self.assertHasNextEvent(
self.client.events.RequestModified,
- consts.Message.ClientGet
+ fcp2.MsgClientGet
)
- self.failUnless(consts.RequestModified.File...
[truncated message content] |
