Merge branch 'kovidgoyal/master'

This commit is contained in:
Charles Haley 2013-07-12 10:02:27 +02:00
commit 1a7a6e3d92
4 changed files with 81 additions and 5 deletions

View File

@ -360,6 +360,30 @@ class Cache(object):
'''
return frozenset(iter(self.fields[name]))
@read_api
def all_field_names(self, field):
''' Frozen set of all fields names (should only be used for many-one and many-many fields) '''
try:
return frozenset(self.fields[field].table.id_map.itervalues())
except AttributeError:
raise ValueError('%s is not a many-one or many-many field' % field)
@read_api
def get_usage_count_by_id(self, field):
try:
return {k:len(v) for k, v in self.fields[field].table.col_book_map.iteritems()}
except AttributeError:
raise ValueError('%s is not a many-one or many-many field' % field)
@read_api
def get_id_map(self, field):
try:
return self.fields[field].table.id_map.copy()
except AttributeError:
if field == 'title':
return self.fields[field].table.book_col_map.copy()
raise ValueError('%s is not a many-one or many-many field' % field)
@read_api
def author_data(self, author_id):
'''

View File

@ -65,6 +65,22 @@ class LibraryDatabase(object):
for meth in ('get_next_series_num_for', 'has_book', 'author_sort_from_authors'):
setattr(self, meth, getattr(self.new_api, meth))
for field in ('authors', 'tags', 'publisher', 'series'):
name = field[:-1] if field in {'authors', 'tags'} else field
setattr(self, 'all_%s_names' % name, partial(self.new_api.all_field_names, field))
for func, field in {'all_authors':'authors', 'all_titles':'title', 'all_tags2':'tags', 'all_series':'series', 'all_publishers':'publisher'}.iteritems():
setattr(self, func, partial(self.field_id_map, field))
self.all_tags = lambda : list(self.all_tag_names())
for func in (
'standard_field_keys', 'custom_field_keys', 'all_field_keys',
'searchable_fields', 'sortable_field_keys',
'search_term_to_field_key', 'custom_field_metadata',
'all_metadata'):
setattr(self, func, getattr(self.field_metadata, func))
self.metadata_for_field = self.field_metadata.get
self.last_update_check = self.last_modified()
def close(self):
@ -129,6 +145,12 @@ class LibraryDatabase(object):
for book_id in self.data.cache.all_book_ids():
yield book_id
def get_usage_count_by_id(self, field):
return [[k, v] for k, v in self.new_api.get_usage_count_by_id(field).iteritems()]
def field_id_map(self, field):
return [(k, v) for k, v in self.new_api.get_id_map(field).iteritems()]
def refresh(self, field=None, ascending=True):
self.data.cache.refresh()
self.data.refresh(field=field, ascending=ascending)
@ -259,6 +281,11 @@ class LibraryDatabase(object):
return list(self.new_api.get_ids_for_custom_book_data(name))
# }}}
def get_field(self, index, key, default=None, index_is_id=False):
book_id = index if index_is_id else self.data.index_to_id(index)
mi = self.new_api.get_metadata(book_id, get_cover=key == 'cover')
return mi.get(key, default)
# Private interface {{{
def __iter__(self):

View File

@ -139,9 +139,33 @@ class LegacyTest(BaseTest):
'get_next_series_num_for': [('A Series One',)],
'author_sort_from_authors': [(['Author One', 'Author Two', 'Unknown'],)],
'has_book':[(Metadata('title one'),), (Metadata('xxxx1111'),)],
'all_author_names':[()],
'all_tag_names':[()],
'all_series_names':[()],
'all_publisher_names':[()],
'all_authors':[()],
'all_tags2':[()],
'all_tags':[()],
'all_publishers':[()],
'all_titles':[()],
'all_series':[()],
'standard_field_keys':[()],
'all_field_keys':[()],
'searchable_fields':[()],
'search_term_to_field_key':[('author',), ('tag',)],
'metadata_for_field':[('title',), ('tags',)],
'sortable_field_keys':[()],
'custom_field_keys':[(True,), (False,)],
'get_usage_count_by_id':[('authors',), ('tags',), ('series',), ('publisher',), ('#tags',), ('languages',)],
'get_field':[(1, 'title'), (2, 'tags'), (0, 'rating'), (1, 'authors'), (2, 'series'), (1, '#tags')],
}.iteritems():
for a in args:
self.assertEqual(getattr(db, meth)(*a), getattr(ndb, meth)(*a),
fmt = lambda x: x
if meth in {'get_usage_count_by_id', 'all_series', 'all_authors', 'all_tags2', 'all_publishers', 'all_titles'}:
fmt = dict
elif meth in {'all_tags'}:
fmt = frozenset
self.assertEqual(fmt(getattr(db, meth)(*a)), fmt(getattr(ndb, meth)(*a)),
'The method: %s() returned different results for argument %s' % (meth, a))
db.close()
# }}}
@ -220,7 +244,7 @@ class LegacyTest(BaseTest):
'get_feeds', 'get_feed', 'update_feed', 'remove_feeds', 'add_feed', 'set_feeds',
}
SKIP_ARGSPEC = {
'__init__', 'get_next_series_num_for', 'has_book', 'author_sort_from_authors',
'__init__', 'get_next_series_num_for', 'has_book', 'author_sort_from_authors', 'all_tags',
}
missing = []
@ -238,10 +262,11 @@ class LegacyTest(BaseTest):
if attr not in SKIP_ARGSPEC:
try:
argspec = inspect.getargspec(obj)
nargspec = inspect.getargspec(nobj)
except TypeError:
pass
else:
compare_argspecs(argspec, inspect.getargspec(nobj), attr)
compare_argspecs(argspec, nargspec, attr)
finally:
for db in (ndb, db):
db.close()

View File

@ -776,10 +776,10 @@ class LibraryDatabase2(LibraryDatabase, SchemaUpgrade, CustomColumns):
return self.field_metadata.sortable_field_keys()
def searchable_fields(self):
return self.field_metadata.searchable_field_keys()
return self.field_metadata.searchable_fields()
def search_term_to_field_key(self, term):
return self.field_metadata.search_term_to_key(term)
return self.field_metadata.search_term_to_field_key(term)
def custom_field_metadata(self, include_composites=True):
return self.field_metadata.custom_field_metadata(include_composites)