project-ize testAPI

JIRA: FUNCTEST-284

Change-Id: I219e934bb11f50de84df2aa0345ecc7885223491
Signed-off-by: SerenaFeng <feng.xiaowei@zte.com.cn>

1 files changed, 0 insertions, 144 deletions

diff --git a/utils/test/result_collection_api/tests/unit/fake_pymongo.py b/utils/test/result_collection_api/tests/unit/fake_pymongo.py
deleted file mode 100644
index bebb9e8b3..000000000
--- a/utils/test/result_collection_api/tests/unit/fake_pymongo.py
+++ /dev/null
@@ -1,144 +0,0 @@
-from bson.objectid import ObjectId
-from concurrent.futures import ThreadPoolExecutor
-
-
-__author__ = 'serena'
-
-
-def thread_execute(method, *args, **kwargs):
-        with ThreadPoolExecutor(max_workers=2) as executor:
-            result = executor.submit(method, *args, **kwargs)
-        return result
-
-
-class MemCursor(object):
-    def __init__(self, collection):
-        self.collection = collection
-        self.count = len(self.collection)
-
-    def _is_next_exist(self):
-        return self.count != 0
-
-    @property
-    def fetch_next(self):
-        return thread_execute(self._is_next_exist)
-
-    def next_object(self):
-        self.count -= 1
-        return self.collection.pop()
-
-
-class MemDb(object):
-
-    def __init__(self):
-        self.contents = []
-        pass
-
-    def _find_one(self, spec_or_id=None, *args):
-        if spec_or_id is not None and not isinstance(spec_or_id, dict):
-            spec_or_id = {"_id": spec_or_id}
-        if '_id' in spec_or_id:
-            spec_or_id['_id'] = str(spec_or_id['_id'])
-        cursor = self._find(spec_or_id, *args)
-        for result in cursor:
-            return result
-        return None
-
-    def find_one(self, spec_or_id=None, *args):
-        return thread_execute(self._find_one, spec_or_id, *args)
-
-    def _insert(self, doc_or_docs, check_keys=True):
-
-        docs = doc_or_docs
-        return_one = False
-        if isinstance(docs, dict):
-            return_one = True
-            docs = [docs]
-
-        ids = []
-        for doc in docs:
-            if '_id' not in doc:
-                doc['_id'] = str(ObjectId())
-            if not check_keys or not self._find_one(doc['_id']):
-                ids.append(doc['_id'])
-                self.contents.append(doc_or_docs)
-
-        if len(ids) == 0:
-            return None
-        if return_one:
-            return ids[0]
-        else:
-            return ids
-
-    def insert(self, doc_or_docs, check_keys=True):
-        return thread_execute(self._insert, doc_or_docs, check_keys)
-
-    @staticmethod
-    def _compare_date(spec, value):
-        for k, v in spec.iteritems():
-            if k == '$gte' and value >= v:
-                return True
-        return False
-
-    @staticmethod
-    def _in(content, *args):
-        for arg in args:
-            for k, v in arg.iteritems():
-                if k == 'start_date':
-                    if not MemDb._compare_date(v, content.get(k)):
-                        return False
-                elif k == 'trust_indicator':
-                    if float(content.get(k)) != float(v):
-                        return False
-                elif content.get(k, None) != v:
-                    return False
-
-        return True
-
-    def _find(self, *args):
-        res = []
-        for content in self.contents:
-            if self._in(content, *args):
-                res.append(content)
-
-        return res
-
-    def find(self, *args):
-        return MemCursor(self._find(*args))
-
-    def _update(self, spec, document):
-        updated = False
-        for index in range(len(self.contents)):
-            content = self.contents[index]
-            if self._in(content, spec):
-                for k, v in document.iteritems():
-                    updated = True
-                    content[k] = v
-            self.contents[index] = content
-        return updated
-
-    def update(self, spec, document):
-        return thread_execute(self._update, spec, document)
-
-    def _remove(self, spec_or_id=None):
-        if spec_or_id is None:
-            self.contents = []
-        if not isinstance(spec_or_id, dict):
-            spec_or_id = {'_id': spec_or_id}
-        for index in range(len(self.contents)):
-            content = self.contents[index]
-            if self._in(content, spec_or_id):
-                del self.contents[index]
-                return True
-        return False
-
-    def remove(self, spec_or_id=None):
-        return thread_execute(self._remove, spec_or_id)
-
-    def clear(self):
-        self._remove()
-
-pods = MemDb()
-projects = MemDb()
-testcases = MemDb()
-results = MemDb()