|
@@ -37,13 +37,7 @@ export class FeedProvider {
|
|
|
);
|
|
|
|
|
|
if (privateTweetHashs.length) {
|
|
|
- // Load private tweets from P2P storage
|
|
|
- let privateTweets = await this.ipfs.fetchTweets(privateTweetHashs);
|
|
|
-
|
|
|
- // Add user object to private tweets
|
|
|
- privateTweets = await Promise.all(
|
|
|
- privateTweets.map(async tweet => await this.addUserToTweet(tweet))
|
|
|
- );
|
|
|
+ const privateTweets = await this.fetchPrivateTweets(privateTweetHashs);
|
|
|
|
|
|
// Combine and sort tweets
|
|
|
return tweets
|
|
@@ -94,13 +88,7 @@ export class FeedProvider {
|
|
|
);
|
|
|
|
|
|
if (privateTweetHashs.length) {
|
|
|
- // Load private tweets from P2P storage
|
|
|
- let privateTweets = await this.ipfs.fetchTweets(privateTweetHashs);
|
|
|
-
|
|
|
- // Add user object to private tweets
|
|
|
- privateTweets = await Promise.all(
|
|
|
- privateTweets.map(async tweet => await this.addUserToTweet(tweet))
|
|
|
- );
|
|
|
+ const privateTweets = await this.fetchPrivateTweets(privateTweetHashs);
|
|
|
|
|
|
// Combine and sort tweets
|
|
|
return tweets
|
|
@@ -111,6 +99,16 @@ export class FeedProvider {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ private async fetchPrivateTweets(privateTweetHashs) {
|
|
|
+ // Load private tweets from P2P storage
|
|
|
+ const privateTweets = await this.ipfs.fetchTweets(privateTweetHashs);
|
|
|
+
|
|
|
+ // Add user object to private tweets
|
|
|
+ return await Promise.all(
|
|
|
+ privateTweets.map(async tweet => await this.addUserToTweet(tweet))
|
|
|
+ );
|
|
|
+ }
|
|
|
+
|
|
|
private async addUserToTweet(tweet) {
|
|
|
tweet.user = await this.twitter.fetchUser(tweet.user_id);
|
|
|
return tweet;
|