parent
4496972205
commit
9095f35545
3 changed files with 18 additions and 0 deletions
|
|
@ -92,6 +92,9 @@ class FeedBuilder(PostBuilder):
|
||||||
content_details = "\n ".join([item.get("value") for item in content_items])
|
content_details = "\n ".join([item.get("value") for item in content_items])
|
||||||
return self.sanitize_fragment(content_details)
|
return self.sanitize_fragment(content_details)
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.stream.rule.pk}: FeedBuilder"
|
||||||
|
|
||||||
|
|
||||||
class FeedStream(PostStream):
|
class FeedStream(PostStream):
|
||||||
rule_type = RuleTypeChoices.feed
|
rule_type = RuleTypeChoices.feed
|
||||||
|
|
@ -108,6 +111,9 @@ class FeedStream(PostStream):
|
||||||
message = "Could not parse feed"
|
message = "Could not parse feed"
|
||||||
raise StreamParseException(response=response, message=message) from e
|
raise StreamParseException(response=response, message=message) from e
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.rule.pk}: FeedStream"
|
||||||
|
|
||||||
|
|
||||||
class FeedClient(PostClient):
|
class FeedClient(PostClient):
|
||||||
stream = FeedStream
|
stream = FeedStream
|
||||||
|
|
|
||||||
|
|
@ -290,6 +290,9 @@ class RedditBuilder(PostBuilder):
|
||||||
title=title,
|
title=title,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.stream.rule.pk}: RedditBuilder"
|
||||||
|
|
||||||
|
|
||||||
class RedditStream(PostStream):
|
class RedditStream(PostStream):
|
||||||
rule_type = RuleTypeChoices.subreddit
|
rule_type = RuleTypeChoices.subreddit
|
||||||
|
|
@ -315,6 +318,9 @@ class RedditStream(PostStream):
|
||||||
response=response, message="Failed parsing json"
|
response=response, message="Failed parsing json"
|
||||||
) from e
|
) from e
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.rule.pk}: RedditStream"
|
||||||
|
|
||||||
|
|
||||||
class RedditClient(PostClient):
|
class RedditClient(PostClient):
|
||||||
stream = RedditStream
|
stream = RedditStream
|
||||||
|
|
|
||||||
|
|
@ -175,6 +175,9 @@ class TwitterBuilder(PostBuilder):
|
||||||
|
|
||||||
return formatted_entities
|
return formatted_entities
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.stream.rule.pk}: TwitterBuilder"
|
||||||
|
|
||||||
|
|
||||||
class TwitterStream(PostStream):
|
class TwitterStream(PostStream):
|
||||||
rule_type = RuleTypeChoices.twitter_timeline
|
rule_type = RuleTypeChoices.twitter_timeline
|
||||||
|
|
@ -199,6 +202,9 @@ class TwitterStream(PostStream):
|
||||||
response=response, message="Failed parsing json"
|
response=response, message="Failed parsing json"
|
||||||
) from e
|
) from e
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.rule.pk}: TwitterStream"
|
||||||
|
|
||||||
|
|
||||||
class TwitterClient(PostClient):
|
class TwitterClient(PostClient):
|
||||||
stream = TwitterStream
|
stream = TwitterStream
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue