Activity Stream

.gitignore

@@ -8,3 +8,6 @@ node_modules
 tmp
 docs/api
 builds
+
+# ide
+.idea

client/source/controllers/buckets_controller.coffee

@@ -7,6 +7,8 @@ DashboardView = require 'views/buckets/dashboard'
 EntriesBrowser = require 'views/entries/browser'
 EntryEditView = require 'views/entries/edit'
 
+Activity = require 'models/activity'
+Activities = require 'models/activities'
 Bucket = require 'models/bucket'
 Buckets = require 'models/buckets'
 Fields = require 'models/fields'
@@ -20,7 +22,11 @@ mediator = require('chaplin').mediator
 module.exports = class BucketsController extends Controller
 
   dashboard: ->
-    @view = new DashboardView
+    @activities = new Activities
+
+    @activities.fetch().done =>
+      @view = new DashboardView
+        collection: @activities
 
   add: ->
     @adjustTitle 'New Bucket'

client/source/helpers.coffee

@@ -88,3 +88,25 @@ Handlebars.registerHelper 'startsWith', (string1, string2, options) ->
     options.fn @
   else
     options.inverse @
+
+Handlebars.registerHelper 'activityResourceLink', (resource) ->
+  escapeExpression = (expression) ->
+    Handlebars.Utils.escapeExpression expression
+  id = escapeExpression resource.id
+  type = escapeExpression resource.type
+  name = escapeExpression resource.name
+  email = escapeExpression resource.email
+  bucketSlug = escapeExpression resource.bucket?.slug
+
+  if resource.id
+    switch resource.type
+      when 'entry' then href = '/' + mediator.options.adminSegment + '/buckets/' + bucketSlug + '/' + id
+      when 'bucket' then href = '/' + mediator.options.adminSegment + '/buckets/' + bucketSlug
+      when 'user' then href = '/' + mediator.options.adminSegment + '/users/' + email
+
+    link = '<a href="' + href + '">' + name + '</a>'
+  else
+    link = name
+
+  new Handlebars.SafeString link;
+

client/source/models/activities.coffee

@@ -0,0 +1,6 @@
+Collection = require 'lib/collection'
+Activity = require 'models/activity'
+
+module.exports = class Activities extends Collection
+  url: '/api/activities'
+  model: Activity

client/source/models/activity.coffee

@@ -0,0 +1,7 @@
+Model = require 'lib/model'
+
+module.exports = class Activity extends Model
+  urlRoot: '/api/activities'
+
+  hello: ->
+    'test'

client/source/templates/buckets/dashboard.hbs

@@ -1,11 +1,33 @@
 <div class="row">
   <h1 class="page-title color-yellow">Buckets</h1>
 
-  <div class="col-md-4 col-sm-6">
+  <div class="col-md-12 col-sm-6">
     <div class="panel">
       <div class="panel-body">
-        <p class="lead">Buckets is an open-source CMS, built in Node.js, which is being actively developed by <a href="https://assembly.com/buckets" target="_blank">the community at Assembly</a>.</p>
+        <p class="lead">Buckets is an open-source CMS, built in Node.js, which is being actively developed by <a
+          href="https://assembly.com/buckets" target="_blank">the community at Assembly</a>.</p>
       </div>
     </div>
   </div>
+
+  <h1 class="page-title">Recent Activity</h1>
+
+  <div class="col-md-12 col-sm-4">
+    <div class="activities">
+      {{#if activities}}
+        {{#each activities}}
+          <div class="activity">
+            <a class="link-with-avatar" href="/{{adminSegment}}/users/{{actor.email}}">{{gravatar actor.email_hash}} <span class="actor-name">{{actor.name}}</span></a>
+            {{action}} {{kind}}
+            {{activityResourceLink resource}}
+            {{timeAgo publishDate}}
+          </div>
+        {{/each}}
+      {{else}}
+        <div class="activity">
+          There has been no activity yet.
+        </div>
+      {{/if}}
+    </div>
+  </div>
 </div>

client/source/views/buckets/dashboard.coffee

@@ -1,6 +1,11 @@
+_ = require 'underscore'
 PageView = require 'views/base/page'
 
 tpl = require 'templates/buckets/dashboard'
 
 module.exports = class DashboardView extends PageView
   template: tpl
+
+  getTemplateData: ->
+    _.extend super,
+      activities: @collection.toJSON()

client/source/views/entries/browser.coffee

@@ -4,6 +4,7 @@ Chaplin = require 'chaplin'
 
 PageView = require 'views/base/page'
 EntriesList = require 'views/entries/list'
+Activity = require 'models/activity'
 Entry = require 'models/entry'
 
 EntryEditView = require 'views/entries/edit'

client/style/_views.styl

@@ -95,6 +95,19 @@
   .handle
     cursor move
 
+// Activities
+
+.activities
+  .activity
+    padding 15px
+
+    a.link-with-avatar:hover
+      text-decoration: none
+
+      span
+        text-decoration: underline
+
+
 // Entries
 
 .entry-publish

server/models/activity.coffee

@@ -4,30 +4,55 @@ db = require '../lib/database'
 # Conforms, at least somewhat, to the activity stream spec outlined at
 # http://activitystrea.ms/specs/json/1.0
 activitySchema = new mongoose.Schema
-  published:
+  publishDate:
     type: Date
     default: Date.now
   actor:
+    type: mongoose.Schema.Types.ObjectId
+    ref: 'User'
+    required: true
+  action:
+    type: String
+    enum: ['created', 'updated', 'deleted']
+    required: true
+  resource:
     id:
       type: mongoose.Schema.Types.ObjectId
-      ref: 'User'
+    type:
+      type: String
       required: true
-  verb:
+      enum: ['entry', 'bucket', 'user']
     name:
       type: String
-      enum: ['post', 'update']
       required: true
-  object:
-    objectType:
+    # for users
+    email:
       type: String
-      required: true
-      enum: ['entry', 'bucket', 'user']
-    id:
-      type: mongoose.Schema.Types.ObjectId
-      required: true
+    bucket:
+      id:
+        type: mongoose.Schema.Types.ObjectId
+      slug:
+        type: String
+      singular:
+        type: String
 ,
   autoIndex: no
 
 activitySchema.set 'toJSON', virtuals: true
 
+activitySchema.virtual 'kind'
+  .get ->
+    if @resource.type is 'entry' then @resource.bucket.singular.toLowerCase() else @resource.type
+
+activitySchema.statics.createForResource = (resource, action, actor, callback) ->
+  @model('Activity').create { resource, action, actor }, (err, activity) ->
+    if err
+      console.log 'Error creating Activity', activity, err
+    else
+      callback(action) if callback
+
+activitySchema.statics.unlinkActivities = (resource) ->
+  @model('Activity').update { 'resource.id': resource._id }, { $set: { 'resource.id': null }}, { multi: true }, (err) ->
+    console.log 'Error unlinking Activities', resource, err if err
+
 module.exports = db.model 'Activity', activitySchema

server/models/bucket.coffee

@@ -2,6 +2,7 @@ inflection = require 'inflection'
 mongoose = require 'mongoose'
 uniqueValidator = require 'mongoose-unique-validator'
 
+Activity = require '../models/activity'
 Route = require '../models/route'
 db = require '../lib/database'
 {Sortable} = require '../lib/mongoose-plugins'
@@ -114,4 +115,15 @@ bucketSchema.methods.getMembers = (callback) ->
         resourceId: @_id
   , callback
 
+bucketSchema.methods.createActivity = (action, actor, callback) ->
+  Activity.createForResource
+    id: @_id
+    type: 'bucket'
+    name: @name
+    bucket:
+      id: @_id
+      slug: @slug
+      singular: @singular
+  , action, actor, callback
+
 module.exports = db.model 'Bucket', bucketSchema

server/models/entry.coffee

@@ -6,6 +6,8 @@ getSlug = require 'speakingurl'
 
 db = require '../lib/database'
 
+Activity = require '../models/activity'
+
 # Add a parser to Chrono to understand "now"
 # A bit hacky because Chrono doesn't support ms yet
 chrono.parsers.NowParser = (text, ref, opt) ->
@@ -97,7 +99,6 @@ entrySchema.path('publishDate').set (val='') ->
   parsed = chrono.parse(val)?[0]?.startDate
   parsed || Date.now()
 
-
 entrySchema.path('description').validate (val) ->
   val?.length < 140
 , 'Descriptions must be less than 140 characters.'
@@ -107,6 +108,17 @@ entrySchema.path 'keywords'
     return unless _.isString val
     _.compact _.map val.split(','), (val) -> val.trim()
 
+entrySchema.methods.createActivity = (action, actor, callback) ->
+  Activity.createForResource
+    id: @_id
+    type: 'entry'
+    name: @title
+    bucket:
+      id: @bucket._id
+      slug: @bucket.slug
+      singular: @bucket.singular
+  , action, actor, callback
+
 entrySchema.statics.findByParams = (params, callback) ->
 
   settings = _.defaults params,

server/models/user.coffee

@@ -8,6 +8,7 @@ async = require 'async'
 fs = require 'fs-extra'
 _ = require 'underscore'
 db = require '../lib/database'
+Activity = require '../models/activity'
 
 if process.env.DROPBOX_APP_KEY and process.env.DROPBOX_APP_SECRET
   dbox_app = dbox.app
@@ -265,6 +266,14 @@ userSchema.methods.syncDropbox = (host='', reset, callback) ->
         callback e, written
         console.log "Saved new Dropbox cursor for User."
 
+userSchema.methods.createActivity = (action, actor, callback) ->
+  Activity.createForResource
+    id: @_id
+    type: 'user'
+    name: @name
+    email: @email
+  , action, actor, callback
+
 userSchema.virtual 'email_hash'
   .get ->
     crypto.createHash('md5').update(@email).digest('hex') if @email

server/routes/api/activities.coffee

@@ -0,0 +1,16 @@
+express = require 'express'
+
+Activity = require '../../models/activity'
+
+module.exports = app = express()
+
+
+app.route('/activities')
+  .get (req, res) ->
+    return res.status(401).end() unless req.user
+
+    Activity.find({}).sort('-publishDate').limit(20).populate('actor').exec (err, activities) ->
+      if err
+        res.send err, 400
+      else if activities
+        res.send activities

server/routes/api/buckets.coffee

@@ -1,5 +1,6 @@
 express = require 'express'
 
+Activity = require '../../models/activity'
 Bucket = require '../../models/bucket'
 User = require '../../models/user'
 
@@ -159,6 +160,7 @@ app.route('/buckets')
       if err
         res.status(400).send err
       else if bucket
+        bucket.createActivity 'created', req.user
         res.status(200).send bucket
 
   .get (req, res) ->
@@ -197,14 +199,16 @@ app.route('/buckets/:bucketID')
   .delete (req, res) ->
     return res.status(401).end() unless req.user?.hasRole ['administrator']
 
-    Bucket.findById req.params.bucketID, (err, bkt) ->
+    Bucket.findById req.params.bucketID, (err, bucket) ->
       if err
         res.send 400, err
       else
-        bkt.remove (err) ->
+        bucket.remove (err) ->
           if err
             res.status(400).send err
           else
+            bucket.createActivity 'deleted', req.user, ->
+              Activity.unlinkActivities bucket
             res.status(204).end()
 
   .put (req, res) ->
@@ -215,6 +219,7 @@ app.route('/buckets/:bucketID')
       return res.status(400).send e: err if err
       bucket.set(req.body).save (err, bucket) ->
         return res.status(400).send err if err
+        bucket.createActivity 'updated', req.user
         res.status(200).send bucket
 
 ###

server/routes/api/entries.coffee

@@ -1,5 +1,6 @@
 express = require 'express'
 
+Activity = require '../../models/activity'
 Bucket = require '../../models/bucket'
 Entry = require '../../models/entry'
 
@@ -72,6 +73,7 @@ app.route '/entries'
           res.status(400).send err
         else
           entry.populate 'bucket author', ->
+            entry.createActivity 'created', req.user
             res.status(200).send entry
 
   .get (req, res) ->
@@ -161,11 +163,17 @@ app.route('/entries/:entryID')
         return res.status(400).send err if err
 
         entry.populate 'bucket author', ->
+          entry.createActivity 'updated', req.user
           res.status(200).send entry
 
   .delete (req, res) ->
-    Entry.findById(req.params.entryID).remove (err) ->
-      if err
-        res.status(400).send e: err
-      else
-        res.status(204).end()
+    Entry.findById req.params.entryID, (error, entry) ->
+      entry.remove (err) ->
+        if err
+          res.status(400).send e: err
+        else
+          entry.populate 'bucket', ->
+            entry.createActivity 'deleted', req.user, ->
+              Activity.unlinkActivities entry
+
+          res.status(204).end()