mirror of
https://github.com/bellingcat/snscrape.git
synced 2026-06-13 12:58:27 +03:00
Refactor Reddit scrapers into a more reasonable code structure
Cf. #328
This commit is contained in:
@@ -202,33 +202,41 @@ class RedditPushshiftScraper(snscrape.base.Scraper):
|
|||||||
subparser.add_argument('--after', metavar = 'TIMESTAMP', type = int, help = 'Fetch results after a Unix timestamp')
|
subparser.add_argument('--after', metavar = 'TIMESTAMP', type = int, help = 'Fetch results after a Unix timestamp')
|
||||||
|
|
||||||
|
|
||||||
def _make_scraper(name_, validationFunc, apiField):
|
class RedditScraper(RedditPushshiftScraper):
|
||||||
class Scraper(RedditPushshiftScraper):
|
def __init__(self, name, **kwargs):
|
||||||
name = f'reddit-{name_}'
|
super().__init__(**kwargs)
|
||||||
|
self._name = name
|
||||||
|
if not type(self)._validationFunc(self._name):
|
||||||
|
raise ValueError(f'invalid {type(self).name.split("-", 1)[1]} name')
|
||||||
|
|
||||||
def __init__(self, name, **kwargs):
|
def get_items(self):
|
||||||
super().__init__(**kwargs)
|
yield from self._iter_api_submissions_and_comments({type(self)._apiField: self._name})
|
||||||
self._name = name
|
|
||||||
if not validationFunc(self._name):
|
|
||||||
raise ValueError(f'invalid {name_} name')
|
|
||||||
|
|
||||||
def get_items(self):
|
@classmethod
|
||||||
yield from self._iter_api_submissions_and_comments({apiField: self._name})
|
def setup_parser(cls, subparser):
|
||||||
|
super()._setup_parser_opts(subparser)
|
||||||
|
name = cls.name.split('-', 1)[1]
|
||||||
|
subparser.add_argument(name, type = snscrape.base.nonempty_string(name))
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def setup_parser(cls, subparser):
|
def from_args(cls, args):
|
||||||
super()._setup_parser_opts(subparser)
|
name = cls.name.split('-', 1)[1]
|
||||||
subparser.add_argument(name_, type = snscrape.base.nonempty_string(name_))
|
return cls._construct(args, getattr(args, name), submissions = not args.noSubmissions, comments = not args.noComments, before = args.before, after = args.after)
|
||||||
|
|
||||||
@classmethod
|
|
||||||
def from_args(cls, args):
|
|
||||||
return cls._construct(args, getattr(args, name_), submissions = not args.noSubmissions, comments = not args.noComments, before = args.before, after = args.after)
|
|
||||||
|
|
||||||
Scraper.__name__ = f'Reddit{name_.capitalize()}Scraper'
|
|
||||||
Scraper.__qualname__ = Scraper.__name__
|
|
||||||
globals()[Scraper.__name__] = Scraper
|
|
||||||
|
|
||||||
|
|
||||||
_make_scraper('user', lambda x: re.match('^[A-Za-z0-9_-]{3,20}$', x), 'author')
|
class RedditUserScraper(RedditScraper):
|
||||||
_make_scraper('subreddit', lambda x: re.match('^[A-Za-z0-9][A-Za-z0-9_]{2,20}$', x), 'subreddit')
|
name = 'reddit-user'
|
||||||
_make_scraper('search', lambda x: True, 'q')
|
_validationFunc = lambda x: re.match('^[A-Za-z0-9_-]{3,20}$', x)
|
||||||
|
_apiField = 'author'
|
||||||
|
|
||||||
|
|
||||||
|
class RedditSubredditScraper(RedditScraper):
|
||||||
|
name = 'reddit-subreddit'
|
||||||
|
_validationFunc = lambda x: re.match('^[A-Za-z0-9][A-Za-z0-9_]{2,20}$', x)
|
||||||
|
_apiField = 'subreddit'
|
||||||
|
|
||||||
|
|
||||||
|
class RedditSearchScraper(RedditScraper):
|
||||||
|
name = 'reddit-search'
|
||||||
|
_validationFunc = lambda x: True
|
||||||
|
_apiField = 'q'
|
||||||
|
|||||||
Reference in New Issue
Block a user