Initial commit
This commit is contained in:
parent
a7b4271a7d
commit
13a87d5ecb
15 changed files with 3579 additions and 0 deletions
|
|
@ -5,3 +5,4 @@ from django.utils.translation import gettext as _
|
|||
class RuleTypeChoices(TextChoices):
|
||||
feed = "feed", _("Feed")
|
||||
subreddit = "subreddit", _("Subreddit")
|
||||
twitter = "twitter", _("Twitter")
|
||||
|
|
|
|||
0
src/newsreader/news/collection/tests/twitter/__init__.py
Normal file
0
src/newsreader/news/collection/tests/twitter/__init__.py
Normal file
3546
src/newsreader/news/collection/tests/twitter/builder/mocks.py
Normal file
3546
src/newsreader/news/collection/tests/twitter/builder/mocks.py
Normal file
File diff suppressed because it is too large
Load diff
32
src/newsreader/news/collection/twitter.py
Normal file
32
src/newsreader/news/collection/twitter.py
Normal file
|
|
@ -0,0 +1,32 @@
|
|||
from newsreader.news.collection.base import Builder, Client, Collector, Stream
|
||||
|
||||
|
||||
class TwitterScheduler:
|
||||
pass
|
||||
|
||||
|
||||
class TwitterBuilder(Builder):
|
||||
def __enter__(self):
|
||||
_, stream = self.stream
|
||||
|
||||
self.instances = []
|
||||
self.existing_posts = {
|
||||
post.remote_identifier: post
|
||||
for post in Post.objects.filter(
|
||||
rule=stream.rule, rule__type=RuleTypeChoices.twitter
|
||||
)
|
||||
}
|
||||
|
||||
return super().__enter__()
|
||||
|
||||
|
||||
class TwitterStream(Stream):
|
||||
pass
|
||||
|
||||
|
||||
class TwitterClient(Client):
|
||||
pass
|
||||
|
||||
|
||||
class TwitterCollector(Collector):
|
||||
pass
|
||||
Loading…
Add table
Add a link
Reference in a new issue