package example; import static io.getstream.core.utils.Enrichment.createCollectionReference; import static io.getstream.core.utils.Enrichment.createUserReference; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; import io.getstream.client.Client; import io.getstream.client.FlatFeed; import io.getstream.client.NotificationFeed; import io.getstream.core.KeepHistory; import io.getstream.core.LookupKind; import io.getstream.core.Region; import io.getstream.core.models.*; import io.getstream.core.options.*; import java.io.File; import java.net.URL; import java.time.LocalDateTime; import java.util.Date; import java.util.List; import java.util.Map; class Example { private static final String apiKey = System.getenv("STREAM_KEY") != null ? System.getenv("STREAM_KEY") : System.getProperty("STREAM_KEY"); private static final String secret = System.getenv("STREAM_SECRET") != null ? System.getenv("STREAM_SECRET") : System.getProperty("STREAM_SECRET"); public static void main(String[] args) throws Exception { Client client = Client.builder(apiKey, secret).build(); FlatFeed chris = client.flatFeed("user", "chris"); // Add an Activity; message is a custom field - tip: you can add unlimited // custom fields! chris.addActivity(Activity.builder().actor("chris").verb("add").object("picture:10").foreignID("picture:10") .extraField("message", "Beautiful bird!").build()); // Create a following relationship between Jack's "timeline" feed and Chris' // "user" feed: FlatFeed jack = client.flatFeed("timeline", "jack"); jack.follow(chris); // Read Jack's timeline and Chris' post appears in the feed: List response = jack.getActivities(new Pagination().limit(10)).join(); for (Activity activity : response) { // ... } // Remove an Activity by referencing it's foreign_id chris.removeActivityByForeignID("picture:10"); /* -------------------------------------------------------- */ // Instantiate a feed object FlatFeed userFeed = client.flatFeed("user", "1"); // Add an activity to the feed, where actor, object and target are references to // objects // (`Eric`, `Hawaii`, `Places to Visit`) Activity activity = Activity.builder().actor("User:1").verb("pin").object("Place:42").target("Board:1").build(); userFeed.addActivity(activity); // Create a bit more complex activity activity = Activity.builder().actor("User:1").verb("run").object("Exercise:42").foreignID("run:1") .extra(new ImmutableMap.Builder() .put("course", new ImmutableMap.Builder().put("name", "Golden Gate park") .put("distance", 10).build()) .put("participants", new String[] { "Thierry", "Tommaso", }) .put("started_at", LocalDateTime.now()) .put("location", new ImmutableMap.Builder().put("type", "point") .put("coordinates", new double[] { 37.769722, -122.476944 }).build()) .build()) .build(); userFeed.addActivity(activity); // Remove an activity by its id userFeed.removeActivityByID("e561de8f-00f1-11e4-b400-0cc47a024be0"); // Remove activities with foreign_id 'run:1' userFeed.removeActivityByForeignID("run:1"); activity = Activity.builder().actor("1").verb("like").object("3").time(new Date()).foreignID("like:3") .extraField("popularity", 100).build(); // first time the activity is added userFeed.addActivity(activity); // update the popularity value for the activity activity = Activity.builder().fromActivity(activity).extraField("popularity", 10).build(); client.batch().updateActivities(activity); /* -------------------------------------------------------- */ // partial update by activity ID // prepare the set operations Map set = new ImmutableMap.Builder().put("product.price", 19.99) .put("shares", new ImmutableMap.Builder().put("facebook", "...").put("twitter", "...").build()) .build(); // prepare the unset operations String[] unset = new String[] { "daily_likes", "popularity" }; String id = "54a60c1e-4ee3-494b-a1e3-50c06acb5ed4"; client.updateActivityByID(id, set, unset); String foreignID = "product:123"; Date timestamp = new Date(); client.updateActivityByForeignID(foreignID, timestamp, set, unset); FeedID[] add = new FeedID[0]; FeedID[] remove = new FeedID[0]; userFeed.updateActivityToTargets(activity, add, remove); FeedID[] newTargets = new FeedID[0]; userFeed.replaceActivityToTargets(activity, newTargets); /* -------------------------------------------------------- */ Date now = new Date(); Activity firstActivity = userFeed .addActivity( Activity.builder().actor("1").verb("like").object("3").time(now).foreignID("like:3").build()) .join(); Activity secondActivity = userFeed.addActivity(Activity.builder().actor("1").verb("like").object("3").time(now) .extraField("extra", "extra_value").foreignID("like:3").build()).join(); // foreign ID and time are the same for both activities // hence only one activity is created and first and second IDs are equal // firstActivity.ID == secondActivity.ID /* -------------------------------------------------------- */ // Get 5 activities with id less than the given UUID (Faster - Recommended!) response = userFeed.getActivities(new Filter().idLessThan("e561de8f-00f1-11e4-b400-0cc47a024be0").limit(5)) .join(); // Get activities from 5 to 10 (Pagination-based - Slower) response = userFeed.getActivities(new Pagination().offset(0).limit(5)).join(); // Get activities sorted by rank (Ranked Feeds Enabled): response = userFeed.getActivities(new Pagination().limit(5), "popularity").join(); /* -------------------------------------------------------- */ // timeline:timeline_feed_1 follows user:user_42 FlatFeed user = client.flatFeed("user", "user_42"); FlatFeed timeline = client.flatFeed("timeline", "timeline_feed_1"); timeline.follow(user); // follow feed without copying the activities: timeline.follow(user, 0); /* -------------------------------------------------------- */ // user := client.FlatFeed("user", "42") // Stop following feed user:user_42 timeline.unfollow(user); // Stop following feed user:user_42 but keep history of activities timeline.unfollow(user, KeepHistory.YES); // list followers List followers = userFeed.getFollowers(new Pagination().offset(0).limit(10)).join(); for (FollowRelation follow : followers) { System.out.format("%s -> %s", follow.getSource(), follow.getTarget()); // ... } // Retrieve last 10 feeds followed by user_feed_1 List followed = userFeed.getFollowed(new Pagination().offset(0).limit(10)).join(); // Retrieve 10 feeds followed by user_feed_1 starting from the 11th followed = userFeed.getFollowed(new Pagination().offset(10).limit(10)).join(); // Check if user_feed_1 follows specific feeds followed = userFeed .getFollowed(new Pagination().offset(0).limit(2), new FeedID("user:42"), new FeedID("user", "43")) .join(); /* -------------------------------------------------------- */ NotificationFeed notifications = client.notificationFeed("notifications", "1"); // Mark all activities in the feed as seen List> activityGroups = notifications.getActivities(new ActivityMarker().allSeen()) .join(); for (NotificationGroup group : activityGroups) { // ... } // Mark some activities as read via specific Activity Group Ids activityGroups = notifications.getActivities(new ActivityMarker().read("groupID1", "groupID2" /* ... */)) .join(); /* -------------------------------------------------------- */ // Add an activity to the feed, where actor, object and target are references to // objects - // adding your ranking method as a parameter (in this case, "popularity"): activity = Activity.builder().actor("User:1").verb("pin").object("place:42").target("board:1") .extraField("popularity", 5).build(); userFeed.addActivity(activity); // Get activities sorted by the ranking method labelled 'activity_popularity' // (Ranked Feeds // Enabled) response = userFeed.getActivities(new Pagination().limit(5), "activity_popularity").join(); /* -------------------------------------------------------- */ // Add the activity to Eric's feed and to Jessica's notification feed activity = Activity.builder().actor("User:Eric").verb("tweet").object("tweet:id") .to(Lists.newArrayList(new FeedID("notification:Jessica"))) .extraField("message", "@Jessica check out getstream.io it's so dang awesome.").build(); userFeed.addActivity(activity); // The TO field ensures the activity is send to the player, match and team feed activity = Activity.builder().actor("Player:Suarez").verb("foul").object("Player:Ramos") .to(Lists.newArrayList(new FeedID("team:barcelona"), new FeedID("match:1"))) .extraField("match", ImmutableMap.of("El Classico", 10)).build(); // playerFeed.addActivity(activity); userFeed.addActivity(activity); // Get activities sorted by the ranking method along with externalRankingVars Map mp=new LinkedHashMap(); mp.put("boolVal",true); mp.put("music",1); mp.put("sports",2.1); mp.put("string","str"); response = userFeed.feed.getActivities( new Limit(69), new Offset(13), DefaultOptions.DEFAULT_FILTER, "rank", new RankingVars(mp) ); /* -------------------------------------------------------- */ // Batch following many feeds // Let timeline:1 will follow user:1, user:2 and user:3 FollowRelation[] follows = new FollowRelation[] { new FollowRelation("timeline:1", "user:1"), new FollowRelation("timeline:1", "user:2"), new FollowRelation("timeline:1", "user:3") }; client.batch().followMany(follows); // copy only the last 10 activities from every feed client.batch().followMany(10, follows); /* -------------------------------------------------------- */ Activity[] activities = new Activity[] { Activity.builder().actor("User:1").verb("tweet").object("Tweet:1").build(), Activity.builder().actor("User:2").verb("watch").object("Movie:1").build() }; userFeed.addActivities(activities); /* -------------------------------------------------------- */ // adds 1 activity to many feeds in one request activity = Activity.builder().actor("User:2").verb("pin").object("Place:42").target("Board:1").build(); FeedID[] feeds = new FeedID[] { new FeedID("timeline", "1"), new FeedID("timeline", "2"), new FeedID("timeline", "3"), new FeedID("timeline", "4") }; client.batch().addToMany(activity, feeds); /* -------------------------------------------------------- */ // retrieve two activities by ID client.batch().getActivitiesByID("01b3c1dd-e7ab-4649-b5b3-b4371d8f7045", "ed2837a6-0a3b-4679-adc1-778a1704852"); // retrieve an activity by foreign ID and time client.batch().getActivitiesByForeignID(new ForeignIDTimePair("foreignID1", new Date()), new ForeignIDTimePair("foreignID2", new Date())); /* -------------------------------------------------------- */ // connect to the us-east region client = Client.builder(apiKey, secret).region(Region.US_EAST).build(); /* -------------------------------------------------------- */ Reaction like = new Reaction.Builder().kind("like").activityID(activity.getID()).build(); // add a like reaction to the activity with id activityId like = client.reactions().add("john-doe", like).join(); Reaction comment = new Reaction.Builder().kind("comment").activityID(activity.getID()) .extraField("text", "awesome post!").build(); // adds a comment reaction to the activity with id activityId comment = client.reactions().add("john-doe", comment).join(); /* -------------------------------------------------------- */ // first let's read current user's timeline feed and pick one activity response = client.flatFeed("timeline", "mike").getActivities().join(); activity = response.get(0); // then let's add a like reaction to that activity client.reactions().add("john-doe", Reaction.builder().kind("like").activityID(activity.getID()).build()); /* -------------------------------------------------------- */ comment = new Reaction.Builder().kind("comment").activityID(activity.getID()) .extraField("text", "awesome post!").build(); // adds a comment reaction to the activity and notify Thierry's notification // feed client.reactions().add("john-doe", comment, new FeedID("notification:thierry")); /* -------------------------------------------------------- */ // read bob's timeline and include most recent reactions to all activities and // their total count client.flatFeed("timeline", "bob") .getEnrichedActivities(new EnrichmentFlags().withRecentReactions().withReactionCounts()); // read bob's timeline and include most recent reactions to all activities and // her own reactions client.flatFeed("timeline", "bob").getEnrichedActivities( new EnrichmentFlags().withOwnReactions().withRecentReactions().withReactionCounts()); /* -------------------------------------------------------- */ // retrieve all kind of reactions for an activity List reactions = client.reactions() .filter(LookupKind.ACTIVITY, "ed2837a6-0a3b-4679-adc1-778a1704852d").join(); // retrieve first 10 likes for an activity reactions = client.reactions() .filter(LookupKind.ACTIVITY, "ed2837a6-0a3b-4679-adc1-778a1704852d", new Filter().limit(10), "like") .join(); // retrieve the next 10 likes using the id_lt param reactions = client.reactions().filter(LookupKind.ACTIVITY, "ed2837a6-0a3b-4679-adc1-778a1704852d", new Filter().idLessThan("e561de8f-00f1-11e4-b400-0cc47a024be0"), "like").join(); /* -------------------------------------------------------- */ // adds a like to the previously created comment Reaction reaction = client.reactions() .addChild("john-doe", comment.getId(), Reaction.builder().kind("like").build()).join(); /* -------------------------------------------------------- */ client.reactions().update(Reaction.builder().id(reaction.getId()).extraField("text", "love it!").build()); /* -------------------------------------------------------- */ client.reactions().delete(reaction.getId()); /* -------------------------------------------------------- */ client.collections().add("food", new CollectionData("cheese-burger").set("name", "Cheese Burger").set("rating", "4 stars")); // if you don't have an id on your side, just use null as the ID and Stream will // generate a // unique ID client.collections().add("food", new CollectionData().set("name", "Cheese Burger").set("rating", "4 stars")); /* -------------------------------------------------------- */ CollectionData collection = client.collections().get("food", "cheese-burger").join(); /* -------------------------------------------------------- */ client.collections().delete("food", "cheese-burger"); /* -------------------------------------------------------- */ client.collections().update("food", new CollectionData("cheese-burger").set("name", "Cheese Burger").set("rating", "1 star")); /* -------------------------------------------------------- */ client.collections().upsert("visitor", new CollectionData("123").set("name", "John").set("favorite_color", "blue"), new CollectionData("124").set("name", "Jane").set("favorite_color", "purple").set("interests", Lists.newArrayList("fashion", "jazz"))); /* -------------------------------------------------------- */ // select the entries with ID 123 and 124 from items collection List objects = client.collections().select("items", "123", "124").join(); /* -------------------------------------------------------- */ // delete the entries with ID 123 and 124 from visitor collection client.collections().deleteMany("visitor", "123", "124"); /* -------------------------------------------------------- */ // first we add our object to the food collection CollectionData cheeseBurger = client.collections() .add("food", new CollectionData("123").set("name", "Cheese Burger").set("ingredients", Lists.newArrayList("cheese", "burger", "bread", "lettuce", "tomato"))) .join(); // the object returned by .add can be embedded directly inside of an activity userFeed.addActivity(Activity.builder().actor(createUserReference("john-doe")).verb("grill") .object(createCollectionReference(cheeseBurger.getCollection(), cheeseBurger.getID())).build()); // if we now read the feed, the activity we just added will include the entire // full object userFeed.getEnrichedActivities(); // we can then update the object and Stream will propagate the change to all // activities client.collections() .update(cheeseBurger.getCollection(), cheeseBurger.set("name", "Amazing Cheese Burger") .set("ingredients", Lists.newArrayList("cheese", "burger", "bread", "lettuce", "tomato"))) .join(); /* -------------------------------------------------------- */ // First create a collection entry with upsert api client.collections().upsert("food", new CollectionData().set("name", "Cheese Burger")); // Then create a user client.user("john-doe").create( new Data().set("name", "John Doe").set("occupation", "Software Engineer").set("gender", "male")); // Since we know their IDs we can create references to both without reading from // APIs String cheeseBurgerRef = createCollectionReference("food", "cheese-burger"); String johnDoeRef = createUserReference("john-doe"); client.flatFeed("user", "john") .addActivity(Activity.builder().actor(johnDoeRef).verb("eat").object(cheeseBurgerRef).build()); /* -------------------------------------------------------- */ // create a new user, if the user already exist an error is returned client.user("john-doe").create( new Data().set("name", "John Doe").set("occupation", "Software Engineer").set("gender", "male")); // get or create a new user, if the user already exist the user is returned client.user("john-doe").getOrCreate( new Data().set("name", "John Doe").set("occupation", "Software Engineer").set("gender", "male")); /* -------------------------------------------------------- */ client.user("123").get(); /* -------------------------------------------------------- */ client.user("123").delete(); /* -------------------------------------------------------- */ client.user("123").update( new Data().set("name", "Jane Doe").set("occupation", "Software Engineer").set("gender", "female")); /* -------------------------------------------------------- */ // Read the personalization feed for a given user client.personalization().get("personalized_feed", new ImmutableMap.Builder().put("user_id", 123).put("feed_slug", "timeline").build()); // Our data science team will typically tell you which endpoint to use client.personalization().get("discovery_feed", new ImmutableMap.Builder().put("user_id", 123) .put("source_feed_slug", "timeline").put("target_feed_slug", "user").build()); /* -------------------------------------------------------- */ client.analytics() .trackEngagement(Engagement .builder().feedID("user:thierry").content(new Content("message:34349698").set("verb", "share") .set("actor", ImmutableMap.of("1", "user1"))) .boost(2).location("profile_page").position(3).build()); /* -------------------------------------------------------- */ client.analytics().trackImpression(Impression.builder() .contentList( new Content("tweet:34349698").set("verb", "share").set("actor", ImmutableMap.of("1", "user1")), new Content("tweet:34349699"), new Content("tweet:34349700")) .feedID("flat:tommaso").location("android-app").build()); /* -------------------------------------------------------- */ // the URL to direct to URL targetURL = new URL("http://mysite.com/detail"); // track the impressions and a click List impressions = Lists.newArrayList( Impression.builder().contentList(new Content("tweet:1"), new Content("tweet:2"), new Content("tweet:3")) .userData(new UserData("tommaso", null)).location("email").feedID("user:global").build()); List engagements = Lists .newArrayList(Engagement.builder().content(new Content("tweet:2")).label("click").position(1) .userData(new UserData("tommaso", null)).location("email").feedID("user:global").build()); // when the user opens the tracking URL in their browser gets redirected to the // target URL // the events are added to our analytics platform URL trackingURL = client.analytics().createRedirectURL(targetURL, impressions, engagements); /* -------------------------------------------------------- */ File image = new File("..."); URL imageURL = client.images().upload(image).join(); File file = new File("..."); URL fileURL = client.files().upload(file).join(); /* -------------------------------------------------------- */ // deleting an image using the url returned by the APIs client.images().delete(imageURL); // deleting a file using the url returned by the APIs client.files().delete(fileURL); /* -------------------------------------------------------- */ // create a 50x50 thumbnail and crop from center client.images().process(imageURL, new Resize(50, 50, Resize.Type.CROP)); // create a 50x50 thumbnail using clipping (keeps aspect ratio) client.images().process(imageURL, new Resize(50, 50, Resize.Type.CLIP)); /* -------------------------------------------------------- */ OGData urlPreview = client.openGraph(new URL("http://www.imdb.com/title/tt0117500/")).join(); } }