[twitter] simplify 'user' assignment
This commit is contained in:
@@ -336,6 +336,10 @@ class TwitterExtractor(Extractor):
|
|||||||
|
|
||||||
return udata
|
return udata
|
||||||
|
|
||||||
|
def _assign_user(self, user):
|
||||||
|
self._user_obj = user
|
||||||
|
self._user = self._transform_user(user)
|
||||||
|
|
||||||
def _users_result(self, users):
|
def _users_result(self, users):
|
||||||
userfmt = self.config("users")
|
userfmt = self.config("users")
|
||||||
if not userfmt or userfmt == "timeline":
|
if not userfmt or userfmt == "timeline":
|
||||||
@@ -630,10 +634,9 @@ class TwitterSearchExtractor(TwitterExtractor):
|
|||||||
|
|
||||||
if user is not None:
|
if user is not None:
|
||||||
try:
|
try:
|
||||||
self._user_obj = user = self.api.user_by_screen_name(user)
|
self._assign_user(self.api.user_by_screen_name(user))
|
||||||
except KeyError:
|
except KeyError:
|
||||||
raise exception.NotFoundError("user")
|
raise exception.NotFoundError("user")
|
||||||
self._user = self._transform_user(user)
|
|
||||||
|
|
||||||
return self.api.search_adaptive(query)
|
return self.api.search_adaptive(query)
|
||||||
|
|
||||||
@@ -797,8 +800,7 @@ class TwitterTweetExtractor(TwitterExtractor):
|
|||||||
for tweet in self.api.tweet_detail(tweet_id):
|
for tweet in self.api.tweet_detail(tweet_id):
|
||||||
if tweet["rest_id"] == tweet_id or \
|
if tweet["rest_id"] == tweet_id or \
|
||||||
tweet.get("_retweet_id_str") == tweet_id:
|
tweet.get("_retweet_id_str") == tweet_id:
|
||||||
self._user_obj = tweet["core"]["user_results"]["result"]
|
self._assign_user(tweet["core"]["user_results"]["result"])
|
||||||
self._user = self._transform_user(self._user_obj)
|
|
||||||
tweets.append(tweet)
|
tweets.append(tweet)
|
||||||
|
|
||||||
tweet_id = tweet["legacy"].get("quoted_status_id_str")
|
tweet_id = tweet["legacy"].get("quoted_status_id_str")
|
||||||
@@ -815,8 +817,7 @@ class TwitterTweetExtractor(TwitterExtractor):
|
|||||||
buffer.append(tweet)
|
buffer.append(tweet)
|
||||||
if tweet["rest_id"] == tweet_id or \
|
if tweet["rest_id"] == tweet_id or \
|
||||||
tweet.get("_retweet_id_str") == tweet_id:
|
tweet.get("_retweet_id_str") == tweet_id:
|
||||||
self._user_obj = tweet["core"]["user_results"]["result"]
|
self._assign_user(tweet["core"]["user_results"]["result"])
|
||||||
self._user = self._transform_user(self._user_obj)
|
|
||||||
break
|
break
|
||||||
|
|
||||||
return itertools.chain(buffer, tweets)
|
return itertools.chain(buffer, tweets)
|
||||||
@@ -1095,10 +1096,7 @@ class TwitterAPI():
|
|||||||
else:
|
else:
|
||||||
raise exception.NotFoundError("user")
|
raise exception.NotFoundError("user")
|
||||||
|
|
||||||
extr = self.extractor
|
self.extractor._assign_user(user)
|
||||||
extr._user_obj = user
|
|
||||||
extr._user = extr._transform_user(user)
|
|
||||||
|
|
||||||
return user_id
|
return user_id
|
||||||
|
|
||||||
@cache(maxage=3600)
|
@cache(maxage=3600)
|
||||||
|
|||||||
Reference in New Issue
Block a user