server.js

#!/usr/bin/env node

var http = require('http')
var request = require('request')
var debug = require('debug')('peerwiki.server')
var peerwiki = require('./')

var USE_INDEX = process.argv.indexOf('--use-index') > -1
var USE_FALLBACK = process.argv.indexOf('--no-fallback') === -1
var ON_DEMAND = process.argv.indexOf('--on-demand') > -1

var wiki = peerwiki({onDemand:ON_DEMAND})
var port = Number(process.argv[2]) || 9090

console.log('Verifying previously downloaded data...')

wiki.on('ready', function() {
  var server = http.createServer(function(req, res) {
    var url = decodeURI(req.url.slice(1).split('?')[0])
    if (!url) url = 'BitTorrent.html'

    if (url === 'favicon.ico') url = 'favicon'
    else if (url === '-/style/style.css') url = 'style/style.css'

    url = url.replace(/^[a-z]\//i, '') // remove namespace

    if (url === '-/style/Icons-mini-file_acrobat.gif') { // haxx - find out if this is a bug
      res.statusCode = 404
      res.end()
      return
    }

    if (/\.json$/.test(url)) {
      var destroy = wiki.findEntryByUrl(url, function(err, entry) {
        if (err) return res.end(err.message)
        res.end(JSON.stringify(entry))
      })

      res.on('close', destroy)
    }

    var fallback = function() {
      if (!USE_FALLBACK) {
        res.statusCode = 404
        res.end()
        return
      }

      debug('using fallback binary search for %s', url)

      var destroy = wiki.findBlobByUrl(url, function(err, entry) {
        if (err) return res.end(err.message)
        res.end(entry)
      })

      res.on('close', destroy)
    }

    if (!USE_INDEX) return fallback()

    // this is not needed for peerwiki to work but it might speed things up a bit (a precompiled index of the torrent)
    request('http://peerwiki-index.mathiasbuus.eu:9999/'+url, {json:true}, function(err, response) {
      var body = response.body
      if (!body || !body.offset) return fallback()

      debug('using hot index for %s', url)

      var destroy = wiki.readCluster(body, function(err, cluster) {
        if (err) return fallback()
        var blob = cluster.blobs[body.blob]
        if (!blob) return fallback()
        res.end(blob)
      })

      res.on('close', destroy)
    })
  })

  server.listen(port, function() {
    wiki.listen(port+1)
    console.log('Server is listening on port %d', server.address().port)
  })
})