[WIP] Create Update Feed

flows/followings.moon

@@ -1,7 +1,7 @@
 
 import Flow from require "lapis.flow"
 
-import Followings, Notifications from require "models"
+import Events, Followings, Notifications, TimelineEvents, Users from require "models"
 
 import assert_error from require "lapis.application"
 
@@ -12,7 +12,8 @@ class FollowingsFlow extends Flow
     super ...
     assert_error @current_user, "must be logged in"
 
-  follow_object: (object, type) =>
+    follow_object: (object, type) =>
+
     f = Followings\create {
       source_user_id: @current_user.id
       :object
@@ -25,6 +26,9 @@ class FollowingsFlow extends Flow
         Notifications\notify_for target_user, object,
           type, @current_user
 
+    event = Events\create(@current_user, object, Events.event_types.subscription)
+    TimelineEvents\deliver(@current_user, event)
+
     f
 
   unfollow_object: (object, type) =>
@@ -35,6 +39,13 @@ class FollowingsFlow extends Flow
       type: Followings.types\for_db type
     }
 
+    event = Events\find {
+      source_user_id: @current_user.id
+      object_object_id: object.id
+      object_object_type: Events\object_type_for_object object
+      event_type: Events.event_types.subscription
+    }
+
     return unless following
 
     if object.get_user

models/events.moon

@@ -0,0 +1,40 @@
+db = require "lapis.db"
+
+import Model, enum from require "lapis.db.model"
+import safe_insert from require "helpers.models"
+
+class Events extends Model
+  @timestamp: true
+
+  @event_types: enum {
+    subscription: 1
+    bookmark: 2
+    update: 3
+  }
+
+  @relations: {
+    {"source_user", belongs_to: "Users"}
+    {"object", polymorphic_belongs_to: {
+      [1]: {"module", "Modules"}
+      [2]: {"user", "Users"}
+    }}
+  }
+
+  @create: (user, object, event_type) =>
+    assert user, "missing event's user"
+    assert object, "missing event's object"
+    assert event_type, "missing event_type, events must have a type"
+
+    opts = {
+      :event_type
+      source_user_id: user.id
+      object_object_id: object.id
+      object_object_type: @@object_type_for_object object
+    }
+
+    event = safe_insert @, opts
+
+    return event
+
+  delete: () =>
+    db.delete @@table_name!, { id: @id }

models/timeline_events.moon

@@ -0,0 +1,32 @@
+db = require "lapis.db"
+import Model from require "lapis.db.model"
+import Events, Followings, Users from require "models"
+
+class TimelineEvents extends Model
+  @primary_key: { "user_id", "event_id" }
+
+  @create: (user, event) =>
+    super {
+      user_id: user.id
+      event_id: event.id
+    }
+
+  @delete: (user, event) =>
+    db.delete @table_name!, { user_id: user.id, event_id: event.id }
+
+  @deliver: (user, event) =>
+    switch event.event_type
+      when Events.event_types.update
+        followers = Followings\select "where object_id = ?", event.object_object_id
+
+        for users in *followers
+          follower_user = Users\find users.source_user_id
+          @@create(follower_user, event)
+      else
+        @@create(user, event)
+
+        if Events\model_for_object_type(event.object_object_type) == Users
+          @@create(Users\find(event.object_object_id), event)
+
+  @user_timeline: (user) =>
+    @@select "where user_id = ?", user.id

models/users.moon

@@ -234,3 +234,7 @@ class Users extends Model
 
     uuid = generate_uuid()
     "#{username}-#{uuid\gsub("-", "")\sub 1, 10}"
+
+  timeline: () =>
+    import TimelineEvents from require "models"
+    TimelineEvents\user_timeline @

spec/applications/modules_spec.moon

@@ -6,13 +6,13 @@ import request_as from require "spec.helpers"
 factory = require "spec.factory"
 
 
-import Modules, Versions, Followings, Users, Notifications, NotificationObjects from require "models"
+import Modules, Versions, Events, Followings, Users, Notifications, NotificationObjects from require "spec.models"
 
 describe "applications.modules", ->
   use_test_server!
 
   before_each ->
-    truncate_tables Modules, Versions, Followings, Users, Notifications, NotificationObjects
+    truncate_tables Events, Modules, Versions, Followings, Users, Notifications, NotificationObjects
 
   it "follows module", ->
     current_user = factory.Users!
@@ -21,8 +21,13 @@ describe "applications.modules", ->
     assert.same 302, status
 
     followings = Followings\select!
+    events = Events\select!
+    user_timeline = current_user\timeline!
 
     assert.same 1, #followings
+    assert.same 1, #events
+    assert.same 1, #user_timeline
+
     following = unpack followings
 
     assert.same current_user.id, following.source_user_id
@@ -44,7 +49,12 @@ describe "applications.modules", ->
     assert.same 302, status
 
     followings = Followings\select!
+    events = Events\select!
+    user_timeline = current_user\timeline!
+
     assert.same 0, #followings
+    assert.same 0, #events
+    assert.same 0, #user_timeline
 
     current_user\refresh!
     mod\refresh!

spec/models/events_spec.moon

@@ -0,0 +1,63 @@
+import use_test_env from require "lapis.spec"
+
+factory = require "spec.factory"
+
+import
+  Modules
+  Users from require "spec.models"
+
+import Events, TimelineEvents from require "models"
+
+describe "models.events", ->
+  use_test_env!
+
+  it "creates an event of user following user", ->
+    user = factory.Users!
+    followed_user = factory.Users!
+
+    event = Events\create(user, followed_user, Events.event_types.subscription)
+    user_timeline = user\timeline!
+
+    assert.same user.id, event.source_user_id
+    assert.same followed_user.id, event.object_object_id
+    assert.same event.event_type, Events.event_types.subscription
+
+    assert.same, #user_timeline, 1
+
+  it "creates an event of user following a module", ->
+    user = factory.Users!
+    module = factory.Modules!
+
+    event = Events\create(user, module, Events.event_types.subscription)
+    user_timeline = user\timeline!
+
+    assert.same user.id, event.source_user_id
+    assert.same module.id, event.object_object_id
+    assert.same event.event_type, Events.event_types.subscription
+
+    assert.same, #user_timeline, 1
+
+  it "creates an event of user starring a module", ->
+    user = factory.Users!
+    module = factory.Modules!
+
+    event = Events\create(user, module, Events.event_types.bookmark)
+    user_timeline = user\timeline!
+
+    assert.same user.id, event.source_user_id
+    assert.same module.id, event.object_object_id
+    assert.same event.event_type, Events.event_types.bookmark
+
+    assert.same, #user_timeline, 1
+
+  it "deletes an event", ->
+    user = factory.Users!
+    module = factory.Modules!
+
+    event = Events\create(user, module, Events.event_types.bookmark)
+    event_id = event.id
+
+    event\delete!
+
+    assert.same nil, Events\find user.id, event_id
+    assert.same 0, #user\timeline!

views/index.moon

@@ -1,5 +1,7 @@
 import to_json from require "lapis.util"
 
+TimelineEvents = require "widgets.timeline_events"
+
 class Index extends require "widgets.page"
   content: =>
     div class: @@css_classes!, ->
@@ -14,6 +16,10 @@ class Index extends require "widgets.page"
         @inner_content!
 
   inner_content: =>
+    if @current_user
+      h2 ->
+        text "Timeline"
+      widget TimelineEvents!
 
     div class: "home_columns", ->
       div class: "column", ->
@@ -63,4 +69,3 @@ class Index extends require "widgets.page"
 
       script type: "text/javascript", ->
         raw "new M.Index(#{@widget_selector!}, #{to_json @downloads_daily});"
-

widgets/timeline_events.moon

@@ -0,0 +1,43 @@
+import Events, Modules, Users from require "models"
+
+class TimelineEvents extends require "widgets.base"
+  @needs: {
+    "modules"
+  }
+
+  inner_content: =>
+    ul ->
+      for event in *@current_user\timeline!
+        row_event = Events\find(event.event_id)
+        user = Users\find(row_event.source_user_id)
+
+
+        message = switch row_event.event_type
+          when Events.event_types.subscription
+            " followed "
+          when Events.event_type.bookmark
+            " starred "
+          when Events.event_type.update
+            " delivered a new version of "
+          else
+            ""
+        li ->
+          span class: "author", ->
+            a href: @url_for("user_profile", user: user.slug), user\name_for_display!
+            text message
+
+            switch Events\model_for_object_type(row_event.object_object_type)
+              when Modules
+                mod = Modules\find row_event.object_object_id
+                a {
+                  class: "title",
+                  href: @url_for("module", user: user.slug, module: mod.name)
+                }, mod\name_for_display!
+              when Users
+                usr = Users\find row_event.object_object_id
+                a {
+                  class: "title",
+                  href: @url_for("user_profile", user: usr.slug)
+                }, usr\name_for_display!
+              else
+                ""