deque-blog’s gists

deque-blog / IAccessProfileInfoAsync.java

Created April 2, 2018 12:41

	public interface IAccessProfileInfo {
	Future<Iterable<ProfileId>> friendsOf(ProfileId profileId);
	Future<Set<Topic>> favoriteTopicsOf(ProfileId profileId);
	Future<Iterable<PostSummary>> lastPostsOf(ProfileId profileId);
	}

deque-blog / suggestedPostsForAsync.java

Last active April 2, 2018 12:51

	public Iterable<PostSummary> suggestedPostsFor(ProfileId profileId) {
	try {
	Future<Iterable<ProfileId>> friendIds = friendsOf(profileId);
	Set<Topic> topics = favoriteTopicsOf(profileId).get();
	Stream<PostSummary> interestingPosts = stream(friendIds.get())
	.parallel() // Stream parallelization
	.flatMap(friendId -> lastPostsOf(friendId))
	.filter(post -> post.isAbout(topics));
	return mostLiked(3, interestingPosts);
	} catch (Exception e) { // InterruptedException and ExecutionException

deque-blog / suggestedPostsFor.java

Created April 2, 2018 12:25

	public Iterable<PostSummary> suggestedPostsFor(ProfileId profileId) {
	Iterable<ProfileId> friendIds = friendsOf(profileId);
	Set<Topic> topics = favoriteTopicsOf(profileId);
	Stream<PostSummary> interestingPosts = stream(friendIds)
	.flatMap(friendId -> lastPostsOf(friendId))
	.filter(post -> post.isAbout(topics));
	return mostLiked(3, interestingPosts);
	}

deque-blog / AssemblingThePieces.java

Created April 2, 2018 11:31

	class RestInfrastructure {
	@Bean
	@Autowired
	public static IAccessProfileInfo getProfileInfoAccess(/* ... */) {
	return new /.../;
	}
	}

deque-blog / SuggestPopularFriendPost_Summary.java

Created March 16, 2018 14:26

	class SuggestPopularFriendPost {
	private final IAccessProfileInfo profileInfo; // Injected with constructor

	public Iterable<PostSummary> suggestedPostsFor(ProfileId profileId) {
	// Same code as before, calling `friendsOf`, `favoriteTopicsOf` and `lastPostsOf`
	}

	private Iterable<ProfileId> friendsOf(ProfileId profileId) {
	return profileInfo.friendsOf(profileId); // Rerouting to `IAccessProfileInfo`
	}

deque-blog / ISuggestPosts.java

Created March 16, 2018 14:08

	public interface ISuggestPosts {
	Iterable<PostSummary> suggestedPostsFor(ProfileId profileId);
	void resetSuggestionOf(ProfileId profileId);
	}

deque-blog / ICacheSuggestions.java

Last active March 16, 2018 14:07

	public interface ICacheSuggestions {
	void saveSuggestions(ProfileId profileId, Iterable<PostSummary> suggestions);
	Iterable<PostSummary> loadSuggestions(ProfileId profileId);
	}

deque-blog / Factory.java

Last active March 16, 2018 14:16

	public static ISuggestPosts suggestPosts(IAccessProfileInfo profileInfo, ICacheSuggestions cache) {
	return new PostSuggestions(cache, new SuggestPopularFriendPost(profileInfo));
	}

deque-blog / IAccessProfileInfo.java

Created March 9, 2018 16:09

	public interface IAccessProfileInfo {
	Iterable<ProfileId> friendsOf(ProfileId profileId);
	Set<Topic> favoriteTopicsOf(ProfileId profileId);
	Iterable<PostSummary> lastPostsOf(ProfileId profileId);
	}

deque-blog / ISuggestPosts.java

Created March 9, 2018 16:08

	public interface ISuggestPosts {
	Iterable<PostSummary> suggestedPostsFor(ProfileId profileId);
	}