Skip to content
This repository was archived by the owner on Dec 19, 2024. It is now read-only.

Commit 09ff82b

Browse files
committed
Default use_db_cache to True, refactoring
1 parent 1b21a45 commit 09ff82b

File tree

3 files changed

+15
-14
lines changed

3 files changed

+15
-14
lines changed

orbitdbapi/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '0.1.0.rc.1.dev5'
1+
__version__ = '0.1.0.rc.1.dev6'

orbitdbapi/client.py

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,12 @@ def __init__ (self, **kwargs):
99
self.logger = logging.getLogger(__name__)
1010
self.__config = kwargs
1111
self.__base_url = self.__config.get('base_url')
12-
self.__use_db_cache = self.__config.get('use_db_cache')
12+
self.__use_db_cache = self.__config.get('use_db_cache', True)
1313
self.__session = requests.Session()
1414

15-
15+
@property
16+
def use_db_cache(self):
17+
return self.__use_db_cache
1618

1719
def _do_request(self, *args, **kwargs):
1820
try:
@@ -41,9 +43,9 @@ def _call(self, method, endpoint, body=None):
4143
def list_dbs(self):
4244
return self._call('get', 'dbs')
4345

44-
def db(self, dbname, params=None):
45-
return DB(self, self.open_db(urlquote(dbname, safe=''), params), **self.__config)
46+
def db(self, dbname, **kwargs):
47+
return DB(self, self.open_db(dbname, **kwargs), **self.__config)
4648

47-
def open_db(self, dbname, params=None):
48-
endpoint = '/'.join(['db', dbname])
49-
return self._call('post', endpoint, params)
49+
def open_db(self, dbname, **kwargs):
50+
endpoint = '/'.join(['db', urlquote(dbname, safe='')])
51+
return self._call('post', endpoint, kwargs)

orbitdbapi/db.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,11 @@ def __init__(self, client, params, **kwargs):
1414
self.__id = params['id']
1515
self.__id_safe = urlquote(self.__id, safe='')
1616
self.__type = params['type']
17-
self.__use_cache = kwargs.get('use_db_cache')
17+
self.__use_cache = kwargs.get('use_db_cache', client.use_db_cache)
1818
self.__enforce_caps = kwargs.get('__enforce_caps', True)
1919
self.logger = logging.getLogger(__name__)
20+
self.__index_by = self.index_by
2021

21-
if hasattr( self.params, 'indexBy'):
22-
self.__index_by = self.__params.indexBy
2322

2423
def clear_cache(self):
2524
self.__cache = {}
@@ -34,7 +33,7 @@ def cache_remove(self, item):
3433
del self.__cache[item]
3534

3635
@property
37-
def indexBy(self):
36+
def index_by(self):
3837
return self.__params.get('indexBy')
3938

4039
@property
@@ -82,7 +81,7 @@ def incrementable(self):
8281

8382
@property
8483
def indexed(self):
85-
return hasattr(self, '__index_by')
84+
return 'indexBy' in self.__params
8685

8786
def info(self):
8887
endpoint = '/'.join(['db', self.__id_safe])
@@ -112,7 +111,7 @@ def put(self, item, cache=None):
112111
raise CapabilityError('Db {} does not have put capability'.format(self.__dbname))
113112
if cache is None: cache = self.__use_cache
114113
if cache:
115-
if hasattr(self, '__index_by'):
114+
if self.indexed:
116115
if hasattr(item, self.__index_by):
117116
index_val = getattr(item, self.__index_by)
118117
else:

0 commit comments

Comments
 (0)