first implementation of required fields
This commit is contained in:
parent
e3fad9df06
commit
ce27e88049
3 changed files with 28 additions and 9 deletions
|
|
@ -37,12 +37,16 @@ class YoujizzBackend(BaseBackend, ICapVideo):
|
||||||
BROWSER = YoujizzBrowser
|
BROWSER = YoujizzBrowser
|
||||||
|
|
||||||
def get_video(self, _id):
|
def get_video(self, _id):
|
||||||
return self.browser.get_video(_id)
|
video = self.browser.get_video(_id)
|
||||||
|
video.nsfw = True
|
||||||
|
return video
|
||||||
|
|
||||||
def iter_page_urls(self, mozaic_url):
|
def iter_page_urls(self, mozaic_url):
|
||||||
return self.browser.iter_page_urls(mozaic_url)
|
return self.browser.iter_page_urls(mozaic_url)
|
||||||
|
|
||||||
def iter_search_results(self, pattern=None, sortby=ICapVideo.SEARCH_RELEVANCE, nsfw=False):
|
def iter_search_results(self, pattern=None, sortby=ICapVideo.SEARCH_RELEVANCE, nsfw=False, required_fields=None):
|
||||||
if not nsfw:
|
if not nsfw:
|
||||||
return iter(set())
|
yield iter(set())
|
||||||
return self.browser.iter_search_results(pattern)
|
for video in self.browser.iter_search_results(pattern, required_fields=required_fields):
|
||||||
|
video.nsfw = True
|
||||||
|
yield video
|
||||||
|
|
|
||||||
|
|
@ -22,6 +22,7 @@ from logging import warning
|
||||||
|
|
||||||
from weboob.tools.browser import BaseBrowser, BrowserUnavailable
|
from weboob.tools.browser import BaseBrowser, BrowserUnavailable
|
||||||
from weboob.tools.browser.decorators import check_domain, id2url
|
from weboob.tools.browser.decorators import check_domain, id2url
|
||||||
|
from weboob.tools.misc import iter_fields
|
||||||
|
|
||||||
from .pages.index import IndexPage
|
from .pages.index import IndexPage
|
||||||
from .video import YoujizzVideo
|
from .video import YoujizzVideo
|
||||||
|
|
@ -39,7 +40,9 @@ class YoujizzBrowser(BaseBrowser):
|
||||||
}
|
}
|
||||||
|
|
||||||
@id2url(YoujizzVideo.id2url)
|
@id2url(YoujizzVideo.id2url)
|
||||||
def get_video(self, url):
|
def get_video(self, url, video=None):
|
||||||
|
if video is None:
|
||||||
|
video = YoujizzVideo()
|
||||||
try:
|
try:
|
||||||
data = self.openurl(url).read()
|
data = self.openurl(url).read()
|
||||||
except BrowserUnavailable:
|
except BrowserUnavailable:
|
||||||
|
|
@ -62,17 +65,26 @@ class YoujizzBrowser(BaseBrowser):
|
||||||
duration = minutes * 60 + seconds
|
duration = minutes * 60 + seconds
|
||||||
else:
|
else:
|
||||||
duration = 0
|
duration = 0
|
||||||
return YoujizzVideo(_id=_id, title=title, url=_get_url(), duration=duration, nsfw=True)
|
video._id = _id
|
||||||
|
video.title = title
|
||||||
|
video.url = _get_url()
|
||||||
|
video.duration = duration
|
||||||
|
return video
|
||||||
|
|
||||||
@check_domain
|
@check_domain
|
||||||
def iter_page_urls(self, mozaic_url):
|
def iter_page_urls(self, mozaic_url):
|
||||||
raise NotImplementedError()
|
raise NotImplementedError()
|
||||||
|
|
||||||
def iter_search_results(self, pattern):
|
def iter_search_results(self, pattern, required_fields=None):
|
||||||
if not pattern:
|
if not pattern:
|
||||||
self.home()
|
self.home()
|
||||||
else:
|
else:
|
||||||
self.location('/search/%s-1.html' % (urllib.quote_plus(pattern)))
|
self.location('/search/%s-1.html' % (urllib.quote_plus(pattern)))
|
||||||
|
|
||||||
assert self.is_on_page(IndexPage)
|
assert self.is_on_page(IndexPage)
|
||||||
return self.page.iter_videos()
|
|
||||||
|
for video in self.page.iter_videos():
|
||||||
|
if required_fields is not None:
|
||||||
|
required_fields_missing = set(required_fields) - set(iter_fields(video))
|
||||||
|
if required_fields_missing:
|
||||||
|
self.get_video(video.id, video=video)
|
||||||
|
yield video
|
||||||
|
|
|
||||||
|
|
@ -240,3 +240,6 @@ class ConsoleApplication(BaseApplication):
|
||||||
super(ConsoleApplication, klass).run(args)
|
super(ConsoleApplication, klass).run(args)
|
||||||
except BackendNotFound, e:
|
except BackendNotFound, e:
|
||||||
logging.error(e)
|
logging.error(e)
|
||||||
|
def do(self, function, *args, **kwargs):
|
||||||
|
kwargs['required_fields'] = self.options.select
|
||||||
|
return self.weboob.do(function, *args, **kwargs)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue