listModerationBy

README.md

@@ -171,6 +171,22 @@ The objects in the output have the same form as `listByFlag()`.
 
 Optionally collect results into `cb(err, rows)`.
 
+#### cabal.moderation.listModerationBy(key, cb)
+
+Return a readable object stream of moderation documents authored by `key`.
+
+Each `row` object in the output is a document used for adding, removing, and
+setting flags.
+
+* `row.type` - `"flags/add"`, `"flags/set"`, or `"flags/remove"`
+* `row.content.id` - string key target of this moderation operation
+* `row.content.flags` - array of string flags for this operation
+* `row.content.reason` - array of string flags for this operation
+* `row.content.channel` - string channel name this operation applies to
+* `row.timestamp` - number, when this action was made in milliseconds since 1970
+
+Optionally collect results into `cb(err, rows)`.
+
 #### cabal.moderation.getFlags({ id, channel }, cb)
 
 Get a list of flags set for the user identified by `id` in `channel` as

index.js

@@ -20,7 +20,8 @@ var MEMBERSHIPS = 'j' // j for joined memberships..? :3
 var MESSAGES = 'm'
 var TOPICS = 't'
 var USERS = 'u'
-var MODERATION = 'x'
+var MODERATION_AUTH = 'x'
+var MODERATION_INFO = 'y'
 
 module.exports = Cabal
 module.exports.databaseVersion = DATABASE_VERSION
@@ -93,8 +94,10 @@ function Cabal (storage, key, opts) {
   this.kcore.use('users', createUsersView(
     sublevel(this.db, USERS, { valueEncoding: json })))
   this.kcore.use('moderation', createModerationView(
-    this, sublevel(this.db, MODERATION, { valueEncoding: json }))
-  )
+    this,
+    sublevel(this.db, MODERATION_AUTH, { valueEncoding: json }),
+    sublevel(this.db, MODERATION_INFO, { valueEncoding: json })
+  ))
 
   this.messages = this.kcore.api.messages
   this.channels = this.kcore.api.channels

views/moderation.js

@@ -10,9 +10,11 @@ var collect = require('collect-stream')
 var duplexify = require('duplexify')
 var { nextTick } = process
 
-module.exports = function (cabal, db) {
+const MOD = 'm!'
+
+module.exports = function (cabal, authDb, infoDb) {
   var events = new EventEmitter()
-  var auth = mauth(db)
+  var auth = mauth(authDb)
   auth.on('update', function (update) {
     events.emit('update', update)
   })
@@ -159,6 +161,22 @@ module.exports = function (cabal, db) {
         if (cb) collect(ro, cb)
         return ro
       }),
+      listModerationBy: function (core, key, cb) {
+        var r = infoDb.createReadStream({
+          gt: MOD + key + '@',
+          lt: MOD + key + '@\uffff'
+        })
+        var out = through.obj(function (row, enc, next) {
+          cabal.getMessage(row.key.slice(MOD.length), function (err, doc) {
+            if (err) return next(err)
+            next(null, doc)
+          })
+        })
+        pump(r, out)
+        var ro = readonly(out)
+        if (cb) collect(ro, cb)
+        return ro
+      },
       // ^--- queries above | updates below ---v
       setFlags: function (core, opts, cb) {
         publishFlagUpdate(core, 'set', opts, cb)
@@ -237,12 +255,20 @@ module.exports = function (cabal, db) {
   function map (rows, next) {
     next = once(next)
     var batch = []
+    var infoBatch = []
     var pending = 1
     rows.forEach(function (row) {
       if (!row.value || !row.value.content) return
+      var id = row.value.content.id
+      if (!id) return
+      if (/^flags\/(set|add|remove)$/.test(row.value.type)) {
+        infoBatch.push({
+          type: 'put',
+          key: MOD + row.key + '@' + row.seq,
+          value: ''
+        })
+      }
       if (row.value.type === 'flags/set') {
-        var id = row.value.content.id
-        if (!id) return
         var group = row.value.content.channel || '@'
         var flags = checkLocal(
           id, group, row.key,
@@ -257,8 +283,6 @@ module.exports = function (cabal, db) {
           flags
         })
       } else if (row.value.type === 'flags/add') {
-        var id = row.value.content.id
-        if (!id) return
         var group = row.value.content.channel || '@'
         pending++
         auth.getFlags({ group, id }, function (err, prevFlags) {
@@ -280,8 +304,6 @@ module.exports = function (cabal, db) {
           if (--pending === 0) done()
         })
       } else if (row.value.type === 'flags/remove') {
-        var id = row.value.content.id
-        if (!id) return
         var group = row.value.content.channel || '@'
         pending++
         auth.getFlags({ group, id }, function (err, flags) {
@@ -308,9 +330,22 @@ module.exports = function (cabal, db) {
     })
     if (--pending === 0) done()
     function done () {
+      var pending = 1
       if (batch.length > 0) {
-        auth.batch(batch, { skip: true }, next)
-      } else next()
+        pending++
+        auth.batch(batch, { skip: true }, function (err) {
+          if (err) next(err)
+          else if (--pending === 0) next()
+        })
+      }
+      if (infoBatch.length > 0) {
+        pending++
+        infoDb.batch(infoBatch, function (err) {
+          if (err) next(err)
+          else if (--pending === 0) next()
+        })
+      }
+      if (--pending === 0) next()
     }
   }