Commit 5e061ed5 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Simplify some tests by using checkArgs method of mock object.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@543 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent a55665ff
...@@ -536,26 +536,18 @@ server: 127.0.0.1:10020 ...@@ -536,26 +536,18 @@ server: 127.0.0.1:10020
# pt calls # pt calls
calls = self.app.pt.mockGetNamedCalls('setCell') calls = self.app.pt.mockGetNamedCalls('setCell')
self.assertEquals(len(calls), 3) self.assertEquals(len(calls), 3)
self.assertEquals(calls[0].getParam(0), 0) calls[0].checkArgs(0, app.nm.getNodeByUUID(uuid), UP_TO_DATE_STATE)
self.assertEquals(calls[1].getParam(0), 1) calls[1].checkArgs(1, app.nm.getNodeByUUID(app.uuid), DISCARDED_STATE)
self.assertEquals(calls[2].getParam(0), 2) calls[2].checkArgs(2, app.nm.getNodeByUUID(app.uuid), OUT_OF_DATE_STATE)
self.assertEquals(calls[0].getParam(1), app.nm.getNodeByUUID(uuid))
self.assertEquals(calls[1].getParam(1), app.nm.getNodeByUUID(app.uuid))
self.assertEquals(calls[2].getParam(1), app.nm.getNodeByUUID(app.uuid))
self.assertEquals(calls[0].getParam(2), UP_TO_DATE_STATE)
self.assertEquals(calls[1].getParam(2), DISCARDED_STATE)
self.assertEquals(calls[2].getParam(2), OUT_OF_DATE_STATE)
# replicator calls # replicator calls
calls = self.app.replicator.mockGetNamedCalls('removePartition') calls = self.app.replicator.mockGetNamedCalls('removePartition')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), 1) calls[0].checkArgs(1)
calls = self.app.replicator.mockGetNamedCalls('addPartition') calls = self.app.replicator.mockGetNamedCalls('addPartition')
# dm call # dm call
calls = self.app.dm.mockGetNamedCalls('changePartitionTable') calls = self.app.dm.mockGetNamedCalls('changePartitionTable')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), ptid2) calls[0].checkArgs(ptid2, cells)
self.assertEquals(calls[0].getParam(1), cells)
self.assertEquals(len(calls), 1)
def test_15_handleStartOperation(self): def test_15_handleStartOperation(self):
# unexpected packet # unexpected packet
...@@ -680,7 +672,7 @@ server: 127.0.0.1:10020 ...@@ -680,7 +672,7 @@ server: 127.0.0.1:10020
self.assertEquals(len(self.app.store_lock_dict), 0) self.assertEquals(len(self.app.store_lock_dict), 0)
calls = self.app.dm.mockGetNamedCalls('finishTransaction') calls = self.app.dm.mockGetNamedCalls('finishTransaction')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), INVALID_TID) calls[0].checkArgs(INVALID_TID)
# transaction not in transaction_dict -> KeyError # transaction not in transaction_dict -> KeyError
transaction = Mock({ 'getObjectList': ((0, ), ), }) transaction = Mock({ 'getObjectList': ((0, ), ), })
conn = Mock({ 'isServerConnection': False, }) conn = Mock({ 'isServerConnection': False, })
...@@ -715,9 +707,7 @@ server: 127.0.0.1:10020 ...@@ -715,9 +707,7 @@ server: 127.0.0.1:10020
calls = self.app.dm.mockGetNamedCalls('getObject') calls = self.app.dm.mockGetNamedCalls('getObject')
self.assertEquals(len(self.app.event_queue), 0) self.assertEquals(len(self.app.event_queue), 0)
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), INVALID_OID) calls[0].checkArgs(INVALID_OID, None, None)
self.assertEquals(calls[0].getParam(1), None)
self.assertEquals(calls[0].getParam(2), None)
self.checkErrorPacket(conn) self.checkErrorPacket(conn)
def test_24_handleAskObject3(self): def test_24_handleAskObject3(self):
...@@ -753,10 +743,7 @@ server: 127.0.0.1:10020 ...@@ -753,10 +743,7 @@ server: 127.0.0.1:10020
self.operation.handleAskTIDs(conn, packet, 1, 2, 1) self.operation.handleAskTIDs(conn, packet, 1, 2, 1)
calls = self.app.dm.mockGetNamedCalls('getTIDList') calls = self.app.dm.mockGetNamedCalls('getTIDList')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), 1) calls[0].checkArgs(1, 1, 1, [1, ])
self.assertEquals(calls[0].getParam(1), 1)
self.assertEquals(calls[0].getParam(2), 1)
self.assertEquals(calls[0].getParam(3), [1, ])
self.checkAnswerTids(conn) self.checkAnswerTids(conn)
def test_25_handleAskTIDs3(self): def test_25_handleAskTIDs3(self):
...@@ -771,10 +758,7 @@ server: 127.0.0.1:10020 ...@@ -771,10 +758,7 @@ server: 127.0.0.1:10020
self.assertEquals(len(self.app.pt.mockGetNamedCalls('getCellList')), 1) self.assertEquals(len(self.app.pt.mockGetNamedCalls('getCellList')), 1)
calls = self.app.dm.mockGetNamedCalls('getTIDList') calls = self.app.dm.mockGetNamedCalls('getTIDList')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), 1) calls[0].checkArgs(1, 1, 1, [0, ])
self.assertEquals(calls[0].getParam(1), 1)
self.assertEquals(calls[0].getParam(2), 1)
self.assertEquals(calls[0].getParam(3), [0, ])
self.checkAnswerTids(conn) self.checkAnswerTids(conn)
def test_26_handleAskObjectHistory1(self): def test_26_handleAskObjectHistory1(self):
...@@ -961,8 +945,7 @@ server: 127.0.0.1:10020 ...@@ -961,8 +945,7 @@ server: 127.0.0.1:10020
) )
calls = self.app.replicator.mockGetNamedCalls('setCriticalTID') calls = self.app.replicator.mockGetNamedCalls('setCriticalTID')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), packet) calls[0].checkArgs(packet, INVALID_TID)
self.assertEquals(calls[0].getParam(1), INVALID_TID)
def test_31_handleAnswerUnfinishedTransactions(self): def test_31_handleAnswerUnfinishedTransactions(self):
# unexpected packet # unexpected packet
...@@ -983,7 +966,7 @@ server: 127.0.0.1:10020 ...@@ -983,7 +966,7 @@ server: 127.0.0.1:10020
) )
calls = self.app.replicator.mockGetNamedCalls('setUnfinishedTIDList') calls = self.app.replicator.mockGetNamedCalls('setUnfinishedTIDList')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), (INVALID_TID, )) calls[0].checkArgs((INVALID_TID, ))
def test_25_handleAskOIDs1(self): def test_25_handleAskOIDs1(self):
# invalid offsets => error # invalid offsets => error
...@@ -1005,10 +988,7 @@ server: 127.0.0.1:10020 ...@@ -1005,10 +988,7 @@ server: 127.0.0.1:10020
self.operation.handleAskOIDs(conn, packet, 1, 2, 1) self.operation.handleAskOIDs(conn, packet, 1, 2, 1)
calls = self.app.dm.mockGetNamedCalls('getOIDList') calls = self.app.dm.mockGetNamedCalls('getOIDList')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), 1) calls[0].checkArgs(1, 1, 1, [1, ])
self.assertEquals(calls[0].getParam(1), 1)
self.assertEquals(calls[0].getParam(2), 1)
self.assertEquals(calls[0].getParam(3), [1, ])
self.checkAnswerOids(conn) self.checkAnswerOids(conn)
def test_25_handleAskOIDs3(self): def test_25_handleAskOIDs3(self):
...@@ -1023,10 +1003,7 @@ server: 127.0.0.1:10020 ...@@ -1023,10 +1003,7 @@ server: 127.0.0.1:10020
self.assertEquals(len(self.app.pt.mockGetNamedCalls('getCellList')), 1) self.assertEquals(len(self.app.pt.mockGetNamedCalls('getCellList')), 1)
calls = self.app.dm.mockGetNamedCalls('getOIDList') calls = self.app.dm.mockGetNamedCalls('getOIDList')
self.assertEquals(len(calls), 1) self.assertEquals(len(calls), 1)
self.assertEquals(calls[0].getParam(0), 1) calls[0].checkArgs(1, 1, 1, [0, ])
self.assertEquals(calls[0].getParam(1), 1)
self.assertEquals(calls[0].getParam(2), 1)
self.assertEquals(calls[0].getParam(3), [0, ])
self.checkAnswerOids(conn) self.checkAnswerOids(conn)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment