matthisk

// Don't copy over history
user1.follow('user', '2', { limit: 0 });
// Copy over a maximum of 300 activities
user1.follow('user', '3', { limit: 300 });

matthisk

var client = stream.connect('API_KEY', 'API_SECRET', 'APP_ID', { expireTokens: true });

matthisk

var client = stream.connect('API_KEY', 'API_SECRET'),
    user1 = client.feed('user','1');

user1.follow('user', '2')
  .then(function(body) {
    return user1.get({ limit: 1 });
  })
  .then(function(body) {
    console.log(body);
  })

matthisk

var follows = [
  {'source': 'flat:1', 'target': 'user:1'},
  {'source': 'flat:1', 'target': 'user:2'},
  {'source': 'flat:1', 'target': 'user:3'}
];

client.followMany(follows)
  .then(function(body) { /* fulfillment handler */ })
  .catch(function(error) { /* rejection handler */ });

matthisk

var activity = {'actor': 'User:1', 'verb': 'tweet', 'object': 'Tweet:1'};
var feeds = ['flat:1','flat:2','aggregated:3'];

client.addToMany(activity, feeds)
  .then(function(body) { /* fulfillment handler */ })
  .catch(function(error) { /* rejection handler */ });

matthisk

{
  "streamApiSecret": "",

  "public" : {
    "streamApiKey": "",

    "streamApiAppId": ""
  }
}

matthisk

// New users news feed follow his own user feed
Stream.feedManager.followUser(user._id, user._id);

matthisk

if (! this.isSimulation && loc && loc.coords)
  activity.place = getLocationPlace(loc);

matthisk

// Global subscriptions
if (Meteor.isClient) {
  Meteor.subscribe('news');
  Meteor.subscribe('bookmarkCounts');
  feedSubscription = Meteor.subscribe('Stream.feeds.flat');
}

matthisk

Handlebars.registerHelper('equals', function(a1, a2) {
  return a1 === a2;
});