add Attending Gatherings view

Author: mmckegg

lib/depject/app/html/search.js

@@ -12,7 +12,7 @@ exports.needs = nest({
 
 exports.gives = nest('app.html.search')
 
-const pages = ['/public', '/private', '/mentions', '/all', '/gatherings']
+const pages = ['/public', '/private', '/mentions', '/all', '/gatherings', '/participating', '/attending-gatherings']
 
 exports.create = function (api) {
   const i18n = api.intl.sync.i18n

lib/depject/index.js

@@ -161,7 +161,8 @@ module.exports = {
           search: require('./page/html/render/search.js'),
           settings: require('./page/html/render/settings.js'),
           tag: require('./page/html/render/tag.js'),
-          'your-posts': require('./page/html/render/your-posts.js')
+          'your-posts': require('./page/html/render/your-posts.js'),
+          'attending-gatherings': require('./page/html/render/attending-gatherings.js')
         }
       }
     },

lib/depject/page/html/render/attending-gatherings.js

@@ -0,0 +1,37 @@
+const { h, send } = require('mutant')
+const nest = require('depnest')
+
+exports.needs = nest({
+  'feed.html.rollup': 'first',
+  'sbot.pull.resumeStream': 'first',
+  'app.navigate': 'first',
+  'sbot.pull.stream': 'first',
+  'contact.obs.following': 'first',
+  'intl.sync.i18n': 'first'
+})
+
+exports.gives = nest('page.html.render')
+
+exports.create = function (api) {
+  const i18n = api.intl.sync.i18n
+  return nest('page.html.render', function channel (path) {
+    if (path !== '/attending-gatherings') return
+    const prepend = [
+      h('PageHeading', [
+        h('h1', [h('strong', i18n('Attending Gatherings'))]),
+        h('div.meta', [
+          h('button', { 'ev-click': send(api.app.navigate, '/gatherings') }, 'View All Gatherings')
+        ])
+      ])
+    ]
+
+    const getStream = api.sbot.pull.resumeStream((sbot, opts) => {
+      return sbot.patchwork.gatherings.roots(opts)
+    }, { limit: 40, reverse: true, onlyAttending: true })
+
+    return api.feed.html.rollup(getStream, {
+      prepend,
+      updateStream: api.sbot.pull.stream(sbot => sbot.patchwork.gatherings.latestAttending())
+    })
+  })
+}

lib/main-window.js

@@ -229,7 +229,10 @@ module.exports = function (config) {
             [i18n('All Threads'), '/participating'],
             [i18n('Threads Started By You'), '/your-posts']
           ]),
-          [i18n('Gatherings'), '/gatherings'],
+          subMenu(i18n('Gatherings'), [
+            [i18n('All'), '/gatherings'],
+            [i18n('Attending'), '/attending-gatherings']
+          ]),
           [i18n('Tags'), `/tags/all/${encodeURIComponent(id)}`],
           [i18n('Extended Network'), '/all'],
           { separator: true },

lib/plugins/gatherings.js

@@ -6,10 +6,13 @@ const threadSummary = require('../thread-summary')
 const ResolveAbouts = require('../resolve-abouts')
 const Paramap = require('pull-paramap')
 const FilterBlocked = require('../filter-blocked')
+const LookupRoots = require('../lookup-roots')
+
 const async = require('async')
 
 exports.manifest = {
   latest: 'source',
+  latestAttending: 'source',
   roots: 'source'
 }
 
@@ -23,7 +26,18 @@ exports.init = function (ssb) {
         pull.filter(msg => !!msg.filterResult)
       )
     },
-    roots: function ({ reverse, limit, resume }) {
+    latestAttending: function () {
+      return pull(
+        ssb.query.read({
+          query: [{ $filter: { value: { content: { type: 'about', attendee: { link: ssb.id } } } } }]
+        }),
+        LookupRoots({ ssb }),
+        ResolveAbouts({ ssb }),
+        ApplyFilterResult({ ssb, passThroughOwn: true }),
+        pull.filter(msg => !!msg.filterResult)
+      )
+    },
+    roots: function ({ reverse, limit, resume, onlyAttending = false }) {
       // use resume option if specified
       const opts = { reverse, old: true, type: 'gathering', private: true }
       if (resume) {
@@ -45,7 +59,7 @@ exports.init = function (ssb) {
           ResolveAbouts({ ssb }),
 
           // FILTER GATHERINGS BASED ON ATTENDEES AND AUTHOR (and hide if no title)
-          ApplyFilterResult({ ssb }),
+          ApplyFilterResult({ ssb, onlyAttending }),
           pull.filter(msg => !!msg.filterResult),
 
           // ADD THREAD SUMMARY
@@ -77,7 +91,7 @@ function bumpFilter (msg) {
   }
 }
 
-function ApplyFilterResult ({ ssb, passThroughOwn = false }) {
+function ApplyFilterResult ({ ssb, passThroughOwn = false, onlyAttending = false }) {
   return pull.asyncMap((msg, cb) => {
     const isYours = ssb.id === msg.value.author
     const recps = msg.value.content.recps
@@ -93,14 +107,19 @@ function ApplyFilterResult ({ ssb, passThroughOwn = false }) {
         const isRecp = Array.isArray(recps) && recps.includes(ssb.id)
         const hasTitle = !!msg.gathering.title
         const isVisible = passThrough || hasTitle
-        if ((followingAttending.length || followingAuthor || isYours || isAttending || isRecp) && isVisible) {
+
+        if (onlyAttending && !isAttending && !isYours) {
+          // only wanting events we are attending, and we are not attending so don't run filters
+        } else if ((followingAttending.length || followingAuthor || isYours || isAttending || isRecp) && isVisible) {
           msg.filterResult = {
             followingAttending,
             followingAuthor,
+            isAttending,
             isYours,
             hasTitle
           }
         }
+
         cb(null, msg)
       })
     })

locales/en.json

@@ -311,5 +311,8 @@
 	"eo": "eo",
 	"zh-TW": "zh-TW",
 	"Blocking": "Blocking",
-	"Automatically delete messages from blocked authors. This is irreversible and will cause problems with clients that share the database but do not support deleted messages. Enable at your own risk!": "Automatically delete messages from blocked authors. This is irreversible and will cause problems with clients that share the database but do not support deleted messages. Enable at your own risk!"
-}
+	"Automatically delete messages from blocked authors. This is irreversible and will cause problems with clients that share the database but do not support deleted messages. Enable at your own risk!": "Automatically delete messages from blocked authors. This is irreversible and will cause problems with clients that share the database but do not support deleted messages. Enable at your own risk!",
+	"All": "All",
+	"Attending": "Attending",
+	"Attending Gatherings": "Attending Gatherings"
+}