Refactor tweet-formatting logic in to it's own functions
This commit is contained in:
parent
02ddb85167
commit
801eb5adb4
1 changed files with 46 additions and 37 deletions
|
@ -19,45 +19,22 @@ class Module(ModuleManager.BaseModule):
|
|||
since, unit = utils.time_unit(seconds_since)
|
||||
return "%s %s ago" % (since, unit)
|
||||
|
||||
@utils.hook("received.command.tw", alias_of="tweet")
|
||||
@utils.hook("received.command.tweet")
|
||||
def tweet(self, event):
|
||||
"""
|
||||
:help: Get/find a tweet
|
||||
:usage: [@username/URL/ID]
|
||||
"""
|
||||
def _get_api(self):
|
||||
api_key = self.bot.config["twitter-api-key"]
|
||||
api_secret = self.bot.config["twitter-api-secret"]
|
||||
access_token = self.bot.config["twitter-access-token"]
|
||||
access_secret = self.bot.config["twitter-access-secret"]
|
||||
|
||||
if event["args"]:
|
||||
target = event["args"]
|
||||
else:
|
||||
target = event["target"].buffer.find(REGEX_TWITTERURL)
|
||||
if target:
|
||||
target = target.message
|
||||
if target:
|
||||
twitter_object = twitter.Twitter(auth=twitter.OAuth(
|
||||
return twitter.Twitter(auth=twitter.OAuth(
|
||||
access_token, access_secret, api_key, api_secret))
|
||||
url_match = re.search(REGEX_TWITTERURL, target)
|
||||
if url_match or target.isdigit():
|
||||
tweet_id = url_match.group(1) if url_match else target
|
||||
|
||||
def _from_id(self, tweet_id):
|
||||
api = self._get_api()
|
||||
try:
|
||||
tweet = twitter_object.statuses.show(id=tweet_id)
|
||||
return api.statuses.show(id=tweet_id)
|
||||
except:
|
||||
traceback.print_exc()
|
||||
tweet = None
|
||||
else:
|
||||
if target.startswith("@"):
|
||||
target = target[1:]
|
||||
try:
|
||||
tweet = twitter_object.statuses.user_timeline(
|
||||
screen_name=target, count=1)[0]
|
||||
except:
|
||||
traceback.print_exc()
|
||||
tweet = None
|
||||
if tweet:
|
||||
|
||||
def _format_tweet(self, tweet):
|
||||
linked_id = tweet["id"]
|
||||
username = tweet["user"]["screen_name"]
|
||||
|
||||
|
@ -75,15 +52,47 @@ class Module(ModuleManager.BaseModule):
|
|||
"created_at"])
|
||||
original_timestamp = self.make_timestamp(tweet[
|
||||
"retweeted_status"]["created_at"])
|
||||
event["stdout"].write(
|
||||
"(@%s (%s) retweeted %s (%s)) %s%s" % (
|
||||
return "(@%s (%s) retweeted %s (%s)) %s%s" % (
|
||||
username, retweet_timestamp, original_username,
|
||||
original_timestamp, html.unescape(original_text),
|
||||
short_url))
|
||||
short_url)
|
||||
else:
|
||||
event["stdout"].write("(@%s, %s) %s%s" % (username,
|
||||
return "(@%s, %s) %s%s" % (username,
|
||||
self.make_timestamp(tweet["created_at"]),
|
||||
html.unescape(tweet["text"]), short_url))
|
||||
html.unescape(tweet["text"]), short_url)
|
||||
|
||||
@utils.hook("received.command.tw", alias_of="tweet")
|
||||
@utils.hook("received.command.tweet")
|
||||
def tweet(self, event):
|
||||
"""
|
||||
:help: Get/find a tweet
|
||||
:usage: [@username/URL/ID]
|
||||
"""
|
||||
|
||||
if event["args"]:
|
||||
target = event["args"]
|
||||
else:
|
||||
target = event["target"].buffer.find(REGEX_TWITTERURL)
|
||||
if target:
|
||||
target = target.message
|
||||
if target:
|
||||
api = self._get_api()
|
||||
url_match = re.search(REGEX_TWITTERURL, target)
|
||||
if url_match or target.isdigit():
|
||||
tweet_id = url_match.group(1) if url_match else target
|
||||
tweet = self._from_id(tweet_id)
|
||||
else:
|
||||
if target.startswith("@"):
|
||||
target = target[1:]
|
||||
try:
|
||||
tweet = twitter_object.statuses.user_timeline(
|
||||
screen_name=target, count=1)[0]
|
||||
except:
|
||||
traceback.print_exc()
|
||||
tweet = None
|
||||
if tweet:
|
||||
tweet_str = self._format_tweet(tweet)
|
||||
event["stdout"].write(tweet_str)
|
||||
else:
|
||||
event["stderr"].write("Invalid tweet identifiers provided")
|
||||
else:
|
||||
|
|
Loading…
Reference in a new issue