Index: appengine/findit/model/test/versioned_model_test.py |
diff --git a/appengine/findit/model/test/versioned_model_test.py b/appengine/findit/model/test/versioned_model_test.py |
deleted file mode 100644 |
index f9016814e5b9b96a1346d3e6e2bbc2e706953a56..0000000000000000000000000000000000000000 |
--- a/appengine/findit/model/test/versioned_model_test.py |
+++ /dev/null |
@@ -1,200 +0,0 @@ |
-# Copyright 2015 The Chromium Authors. All rights reserved. |
-# Use of this source code is governed by a BSD-style license that can be |
-# found in the LICENSE file. |
- |
-from google.appengine.api import datastore_errors |
-from google.appengine.ext import ndb |
- |
-from testing_utils import testing |
- |
-from model.versioned_model import VersionedModel |
- |
- |
-class _Entity(VersionedModel): |
- value = ndb.IntegerProperty(indexed=False) |
- |
- |
-class VersionedModelTest(testing.AppengineTestCase): |
- |
- def testGetRootModel(self): |
- root_model_class = _Entity._GetRootModel() |
- self.assertEqual('_EntityRoot', root_model_class._get_kind()) |
- self.assertTrue(issubclass(root_model_class, ndb.Model)) |
- self.assertEqual(3, root_model_class(current=3).current) |
- |
- def testDefaultVersionIsZero(self): |
- self.assertEqual(0, _Entity.Create().version_number) |
- self.assertEqual(0, _Entity.Create('m1').version_number) |
- |
- def testRootId(self): |
- self.assertEqual(1, _Entity.Create()._root_id) |
- self.assertEqual( |
- 1, _Entity(key=ndb.Key('_EntityRoot', 1, '_Entity', 2))._root_id) |
- self.assertEqual('m1', _Entity.Create('m1')._root_id) |
- |
- def testCreate(self): |
- self.assertEqual(_Entity(key=ndb.Key('_EntityRoot', 'm1', '_Entity', 0)), |
- _Entity.Create('m1')) |
- |
- def testGetMostRecentVersionWhenNoData(self): |
- self.assertIsNone(_Entity.GetVersion()) |
- self.assertIsNone(_Entity.GetVersion('m1')) |
- |
- def testGetMostRecentVersionWhenDataExists(self): |
- entity = _Entity.Create() |
- entity.value = 1 |
- entity.Save() |
- entity.value = 2 |
- entity.Save() |
- |
- entity = _Entity.GetVersion() |
- self.assertEqual(2, entity.version_number) |
- self.assertEqual(2, entity.value) |
- |
- def testGetSpecificVersion(self): |
- entity = _Entity.Create() |
- entity.value = 1 |
- entity.Save() |
- entity.value = 2 |
- entity.Save() |
- |
- entity_version_2 = _Entity.GetVersion(version=2) |
- self.assertEqual(2, entity_version_2.version_number) |
- self.assertEqual(2, entity_version_2.value) |
- self.assertIsNone(_Entity.GetVersion(version=0)) |
- self.assertIsNone(_Entity.GetVersion(version=3)) |
- |
- def testGetLatestVersionNumber(self): |
- entity = _Entity.Create() |
- entity.Save() |
- self.assertEqual(1, _Entity.GetLatestVersionNumber()) |
- |
- def testGetVersionForEntityWithKeyId(self): |
- entity = _Entity.Create('m1') |
- entity.value = 1 |
- entity.Save() |
- entity.value = 2 |
- entity.Save() |
- |
- self.assertEqual(2, _Entity.GetVersion('m1').version_number) |
- self.assertEqual(2, _Entity.GetVersion('m1').value) |
- self.assertIsNone(_Entity.GetVersion('m1', version=0)) |
- self.assertIsNone(_Entity.GetVersion('m1', version=3)) |
- |
- def testGetLatestVersionNumberWhenNoRecordYet(self): |
- self.assertEqual(-1, _Entity.GetLatestVersionNumber()) |
- self.assertEqual(-1, _Entity.GetLatestVersionNumber('m1')) |
- |
- def testSaveNewVersion(self): |
- entity = _Entity.Create() |
- entity.value = 1 |
- key, saved = entity.Save() |
- |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertTrue(saved) |
- |
- entity = _Entity.GetVersion() |
- self.assertEqual(1, entity.version_number) |
- self.assertEqual(1, entity.value) |
- |
- def testSaveEntityWithRootId(self): |
- entity = _Entity.Create('m1') |
- entity.value = 1 |
- entity.Save() |
- entity.value = 3 |
- entity.Save() |
- |
- self.assertEqual(entity.version_number, 2) |
- self.assertEqual(entity.value, 3) |
- |
- def testSaveNewVersionOfEntityWithKeyId(self): |
- entity = _Entity.Create('m1') |
- entity.value = 1 |
- key, saved = entity.Save() |
- expected_key = ndb.Key('_EntityRoot', 'm1', '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertTrue(saved) |
- |
- def testSaveNewVersionWithConflictRetry(self): |
- original_ndb_transaction = ndb.transaction |
- |
- def MockNdbTransaction(func, **options): |
- _Entity(key=ndb.Key('_EntityRoot', 1, '_Entity', 1), value=1).put() |
- _Entity(key=ndb.Key('_EntityRoot', 1, '_Entity', 2), value=2).put() |
- return original_ndb_transaction(func, **options) |
- self.mock(ndb, 'transaction', MockNdbTransaction) |
- |
- entity = _Entity.Create() |
- key, saved = entity.Save() |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 3) |
- self.assertEqual(expected_key, key) |
- self.assertTrue(saved) |
- |
- def testSaveNewVersionWithConflictBeforeTransactionNoRetry(self): |
- original_ndb_transaction = ndb.transaction |
- |
- def MockNdbTransaction(func, **options): |
- # To simulate another transaction occuring before this one, write a new |
- # version first before the transaction is called. |
- _Entity(key=ndb.Key('_EntityRoot', 1, '_Entity', 1), value=1).put() |
- return original_ndb_transaction(func, **options) |
- self.mock(ndb, 'transaction', MockNdbTransaction) |
- |
- entity = _Entity.Create() |
- key, saved = entity.Save(retry_on_conflict=False) |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertFalse(saved) |
- |
- def testSaveNewVersionConflictBeforeSaving(self): |
- original_save = VersionedModel.Save |
- |
- def MockSave(*args, **kwargs): |
- # Smulate another transaction beating this call to Save() to creating a |
- # new entity. |
- _Entity(key=ndb.Key('_EntityRoot', 1, '_Entity', 1), value=1).put() |
- return original_save(*args, **kwargs) |
- self.mock(VersionedModel, 'Save', MockSave) |
- |
- entity = _Entity.Create() |
- key, saved = entity.Save(retry_on_conflict=False) |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertFalse(saved) |
- |
- def testLikelyTransactionFailure(self): |
- original_ndb_transaction = ndb.transaction |
- |
- calls = [] |
- def MockNdbTransaction(func, **options): |
- if len(calls) < 1: |
- calls.append(1) |
- raise datastore_errors.Timeout() |
- return original_ndb_transaction(func, **options) |
- self.mock(ndb, 'transaction', MockNdbTransaction) |
- |
- entity = _Entity.Create() |
- key, saved = entity.Save() |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertTrue(saved) |
- self.assertEqual([1], calls) |
- |
- def testTransactionFailure(self): |
- original_ndb_transaction = ndb.transaction |
- |
- calls = [] |
- def MockNdbTransaction(func, **options): |
- if len(calls) < 1: |
- calls.append(1) |
- raise datastore_errors.BadRequestError() |
- return original_ndb_transaction(func, **options) |
- self.mock(ndb, 'transaction', MockNdbTransaction) |
- |
- entity = _Entity.Create() |
- key, saved = entity.Save() |
- expected_key = ndb.Key('_EntityRoot', 1, '_Entity', 1) |
- self.assertEqual(expected_key, key) |
- self.assertEqual([1], calls) |
- self.assertTrue(saved) |