Activity Streams Boilerplate App Part 3

Makefile

@@ -0,0 +1,6 @@
+TESTS = $(shell find test/ -name '*.tobi.js' -o -name '*.test.js')
+
+test:
+	@node_modules/.bin/mocha --reporter spec $(TESTS)
+
+.PHONY: test

README.md

@@ -34,6 +34,13 @@ npm install
 ```
 
 * Edit siteConfig.js if needed
+* If you change the activities templates you need to regenerate the client side version of them, you can do this with `clientjade`
+
+```bash
+npm install -g clientjade
+clientjade views/*.* > public/js/templates.js
+```
+
 * Run locally
 
 ``` bash
@@ -80,6 +87,7 @@ vmc env-add $APP_NAME facebook_app_secret=fb_secret
 vmc env-add $APP_NAME NODE_ENV=production
 vmc env-add $APP_NAME twitter_consumer_key=twitter_key
 vmc env-add $APP_NAME twitter_consumer_secret=twitter_secret
+vmc env-add $APP_NAME TMP=tmp
 ```
 
 ## Finally

cloudfoundry.json

@@ -0,0 +1 @@
+{ "ignoreNodeModules" : true }

lib/asms-client.js

@@ -0,0 +1,198 @@
+module.exports = function(app, cf) {
+    var https = require('https');
+
+    var getUri = function(path) {
+        return app.siteConf.uri + path;
+    }
+
+    var defaultStream = "firehose";
+
+    // Setup the Asms DB and User Schema and Auth
+    var defaultAvatar = getUri('/img/codercat-sm.jpg');
+
+    var actorTypes = ['Person', 'Group', 'Application', 'Service'];
+    var objectTypes = ['Photo', 'Application', 'Article', 'Person', 'Place', 'Service'];
+    var verbs = ['Post', 'Favorite', 'Follow', 'Join', 'Like', 'Friend', 'Play', 'Save', 'Share', 'Tag', 'Create', 'Update', 'Read', 'Delete', 'Check In'];
+
+    var githubHash = {objectType: 'Service', displayName: 'GitHub', url: 'http://github.com', icon : {url: 'http://github.com/favicon.ico'}};
+    var facebookHash = {objectType: 'Service', displayName: 'Facebook', url: 'http://facebook.com', icon : {url: 'http://facebook.com/favicon.ico'}};
+    var twitterHash = {objectType: 'Service', displayName: 'Twitter', url: 'http://twitter.com', icon : {url: 'http://twitter.com/favicon.ico'}};
+
+    var streamLib = require('activity-streams-mongoose')({
+        mongoUrl: app.siteConf.mongoUrl,
+        redis: app.siteConf.redisOptions,
+        defaultActor: defaultAvatar
+    });
+
+    var authentication = new require('./authentication.js')(streamLib, app.siteConf);
+
+    // Moved normalization to only be done on pre save
+    streamLib.types.UserSchema.pre('save', function (next) {
+        var user = this;
+        var svcUrl = null;
+        if (user.fb && user.fb.id) {
+            user.displayName = user.fb.name.full;
+            asmsDB.ActivityObject.findOne().where('url', facebookHash.url).exec(function(err, doc){
+                if (err) throw err;
+                user.author = doc._id;
+                // Need to fetch the users image...
+                https.get({
+                    'host': 'graph.facebook.com'
+                    , 'path': '/me/picture?access_token='+ user.fb.accessToken
+                }, function(response) {
+                    user.image = {url: response.headers.location};
+                    next();
+                }).on('error', function(e) {
+                    next();
+                });
+            })
+        } else  {
+            if (user.github && user.github.id) {
+                user.displayName = user.github.name;
+                var avatar = 'http://1.gravatar.com/avatar/'+ user.github.gravatarId + '?s=48'
+                user.image = {url: avatar};
+                svcUrl = githubHash.url;
+            } else if (user.twit && user.twit.id) {
+                if (user.twit.geoEnabled && user.twit.location){
+                    //"ÜT: 34.075755,-118.393416"
+                    var parts = user.twit.location.substr(4).split(',');
+                    user.location = {position: {latitude: parts[0],longitude: parts[1]}};
+                }
+                user.displayName = user.twit.name;
+                user.image = {url: user.twit.profileImageUrl};
+                user.url = user.twit.url;
+                svcUrl = twitterHash.url;
+            }
+
+            if(!user.actor) {
+                asmsDB.ActivityObject.findOne().where('url', svcUrl).exec(function(err, doc){
+                    user.author = doc;
+                    next();
+                });
+            } else {
+                next();
+            }
+        }
+      });
+
+    var asmsDB = new streamLib.DB(streamLib.db, streamLib.types);
+    streamLib.asmsDB = asmsDB;
+
+    // Setup default Objects
+    // TODO: Change to find or create by
+    var thisInstance = {objectType : "AppInstance"};
+    if (cf.app) {
+        thisInstance.image = {url: getUri('/img/cf-process.jpg')};
+        thisInstance.url = "http://" + cf.host + ":" + cf.port;
+        thisInstance.displayName = "App Instance " + cf.app['instance_index'] + " at " + thisInstance.url;
+        thisInstance.content = cf.app['instance_id']
+    } else {
+        thisInstance.displayName =  "Instance 0 -- Local";
+    }
+
+    var appOwner = {displayName: app.siteConf.user_email, image:{url: getUri("/img/me.jpg")}};
+
+    var thisApp = new asmsDB.ActivityObject({
+        objectType: 'Application',
+        displayName: 'Activity Streams App',
+        url: app.siteConf.uri,
+        image:{url: getUri('/img/as-logo-sm.png')}
+    });
+
+    thisApp.save(function (err) {
+        if (err) throw err;
+    });
+
+    var thisProvider = new asmsDB.ActivityObject({
+        objectType: 'Service',
+        'displayName': 'Cloud Foundry',
+        icon:{url: 'http://www.cloudfoundry.com/images/favicon.ico'}
+    });
+    thisProvider.save(function(err){if (err) throw err});
+
+    var github = new asmsDB.ActivityObject(githubHash);
+    github.save(function(err){if (err) throw err});
+    var facebook = new asmsDB.ActivityObject(facebookHash);
+    facebook.save(function(err){if (err) throw err});
+    var twitter = new asmsDB.ActivityObject(twitterHash);
+    twitter.save(function(err){if (err) throw err});
+
+    var getCurrentUserObject = function(session) {
+        if (session.user) {
+            return session.user;
+        } else if(session.uid) {
+            var currentUser = {};
+            currentUser.displayName = session.uid;
+            currentUser.image = { url: defaultAvatar};
+            return currentUser;
+        }
+        return null;
+    }
+
+    var publishActivity = function(desiredStream, currentUser, actHash) {
+
+        if (!currentUser) throw("Cannot publish activity without an actor");
+        if (actHash && actHash.object && actHash.object.objectType && actHash.verb) {
+            actHash.actor = currentUser;
+
+            if (!actHash.title) {
+                actHash.title = actHash.verb  + "ed a new " + actHash.object.objectType;
+            }
+
+            var act = new asmsDB.Activity(actHash);
+            // Send back the message to the users room.
+            act.publish(desiredStream);
+        } else {
+            console.log("Missing required parameters");
+            console.log(actHash);
+            throw(new Error("Missing required parameters"));
+        }
+    };
+
+    var getDistinct = function (req, res, next, term, init){
+        var key = 'used.' + term;
+        req[key] = init ? init : [];
+        asmsDB.Activity.distinct(term, {streams: req.session.desiredStream}, function(err, docs) {
+            if (!err && docs) {
+                _.each(docs, function(result){
+                    req[key].push(result);
+                });
+                next();
+            } else {
+                next(new Error('Failed to fetch distinct ' + term));
+            }
+        });
+    }
+
+    return {
+        helpers: {
+            getUri: getUri,
+            getCurrentUserObject : getCurrentUserObject,
+            publishActivity : publishActivity,
+            getDistinct : getDistinct
+        },
+        default :{
+            owner: appOwner,
+            provider : thisProvider,
+            app: thisApp,
+            instance: thisInstance,
+            avatar: defaultAvatar,
+            stream : defaultStream
+        },
+        users : {
+            providers :{
+                facebook: facebook,
+                twitter: twitter,
+                github : github
+            }
+        },
+        streamLib : streamLib,
+        asmsDB: asmsDB,
+        authentication : authentication,
+        metadata: {
+            actorTypes: actorTypes,
+            objectTypes: objectTypes,
+            verbs: verbs
+        }
+    }
+};