Init

1 files changed, 102 insertions, 0 deletions

diff --git a/lib/app.js b/lib/app.js
new file mode 100644
index 0000000..de8585d
--- /dev/null
+++ b/lib/app.js
@@ -0,0 +1,102 @@
+var http = require('http')
+var memo = require('asyncmemo')
+var lru = require('lrucache')
+var pkg = require('../package')
+var u = require('./util')
+
+var Serve = require('./serve')
+var Render = require('./render')
+
+module.exports = App
+
+function App(sbot, config) {
+  this.sbot = sbot
+  this.config = config
+
+  var conf = config.patchfoo || {}
+  this.port = conf.port || 8027
+  this.host = conf.host || 'localhost'
+
+  var base = conf.base || '/'
+  this.opts = {
+    base: base,
+    blob_base: conf.blob_base || conf.img_base || base,
+    img_base: conf.img_base || base,
+    emoji_base: conf.emoji_base || (base + 'emoji/'),
+  }
+
+  sbot.get = memo({cache: lru(100)}, sbot.get)
+  this.getMsg = memo({cache: lru(100)}, getMsgWithValue, sbot)
+  this.getAbout = memo({cache: lru(100)}, require('ssb-avatar'), sbot, sbot.id)
+  this.unboxContent = memo({cache: lru(100)}, sbot.private.unbox)
+
+  this.unboxMsg = this.unboxMsg.bind(this)
+
+  this.render = new Render(this, this.opts)
+}
+
+App.prototype.go = function () {
+  var self = this
+  http.createServer(function (req, res) {
+    new Serve(self, req, res).go()
+  }).listen(self.port, self.host, function () {
+    self.log('Listening on http://' + self.host + ':' + self.port)
+  })
+}
+
+App.prototype.logPrefix = ['[' + pkg.name + ']']
+
+App.prototype.log = function () {
+  console.log.apply(console, [].concat.apply(this.logPrefix, arguments))
+}
+
+App.prototype.error = function () {
+  console.error.apply(console, [].concat.apply(this.logPrefix, arguments))
+}
+
+App.prototype.unboxMsg = function (msg, cb) {
+  var self = this
+  var c = msg.value.content
+  if (typeof c !== 'string') cb(null, msg)
+  else self.unboxContent(c, function (err, content) {
+    if (err) {
+      self.error('unbox:', err)
+      return cb(null, msg)
+    }
+    var m = {}
+    for (var k in msg) m[k] = msg[k]
+    m.value = {}
+    for (var k in msg.value) m.value[k] = msg.value[k]
+    m.value.content = content
+    m.value.private = true
+    cb(null, m)
+  })
+}
+
+App.prototype.search = function (opts) {
+  return this.sbot.fulltext.search(opts)
+}
+
+App.prototype.getMsgDecrypted = function (key, cb) {
+  var self = this
+  this.getMsg(key, function (err, msg) {
+    if (err) return cb(err)
+    self.unboxMsg(msg, cb)
+  })
+}
+
+App.prototype.publish = function (content, cb) {
+  if (Array.isArray(content.recps)) {
+    recps = content.recps.map(u.linkDest)
+    this.sbot.private.publish(content, recps, cb)
+  } else {
+    this.sbot.publish(content, cb)
+  }
+}
+
+function getMsgWithValue(sbot, id, cb) {
+  sbot.get(id, function (err, value) {
+    if (err) return cb(err)
+    cb(null, {key: id, value: value})
+  })
+}