nerve-test.js

var nerve = require('./nerve/nerve');
var tyrant = require('./tyrant/tyrant');
var querystring = require('./querystring/querystring');
var Mu = require('./mu/mu');

var sys = require('sys');

// combo library
function Combo(callback) {
  this.callback = callback;
  this.items = 0;
  this.results = [];
}
Combo.prototype = {
  add: function () {
    var self = this;
    this.items++;
    return function () {
      self.check(self.items - 1, arguments);
    };
  },
  check: function (id, arguments_in) {
    this.results[id] = arguments_in;
    this.items--;
    if (this.items == 0) {
      this.callback.call(this, this.results);
    }
  }
};

Mu.templateRoot = './theme';

var get = nerve.get;
var post = nerve.post;

var getPostParams = function(req, callback) {
  var body = '';
  req.addListener('body', function(chunk){body += chunk;})
     .addListener('complete', function(){
       callback(unescape(body.replace(/\+/g,' ')));
     });
};

var site ={
    title: 'Small Node.js blog'
};

var hello = [
    ["/", function(req, res) {
        tyrant.connect();

        tyrant.addListener('error', function(e) {
            sys.puts('Error: ' + JSON.stringify(e));
        });

        tyrant.addListener('connect', function() {
            tyrant.search(tyrant.is('type', 'blog'), tyrant.sort('time', 'desc')).addCallback(function(value) {
                tyrant.getlist(value).addCallback(function(added_posts) {

                    // res.respond('Done: ' + JSON.stringify(added_posts));

                    var posts_processed = [];

                    for (var raw_item in added_posts) {
                        var item = tyrant.dict(added_posts[raw_item][0]);

                        var post_date = new Date(parseInt(item.time));
                        posts_processed.push({
                            id: raw_item,
                            title:item.name,
                            link:'blog/' + raw_item,
                            date: post_date.getDate() + '.' + (post_date.getMonth() + 1) + '.' + post_date.getFullYear() + ' ' + post_date.getHours() + ':' + post_date.getMinutes() + ':' + post_date.getSeconds(),
                            text: JSON.stringify(item), // item.text,
                            tags: '',
                            num_of_comments: 0
                        });
                    }

                    var page = {'id': '0','title':'My small Node blog', 'posts': posts_processed, 'pages':[]};

                    Mu.render('page', page, {chunkSize: 10}).addCallback(function (output) {

                        var buffer = '';

                        output
                          .addListener('data', function (c) {
                            buffer += c;
                          })
                          .addListener('eof', function () {
                            res.respond(buffer);
                          });
                      })
                      .addErrback(function (e) {
                        res.respond('Oops:' + JSON.stringify(e));
                      });
                });

                // res.respond(page_text);
            }).addErrback(function(e){
                res.respond('Search Oops:' + JSON.stringify(e));
            });
        });
    }],
    ["/write", function(req, res) {
        page_text += '<h1>My small node blog</h1>';

        page_text += '<h2>Write new blog entry</h2>';

        page_text += '<form method="POST" action="/save">';

        page_text += '<label for="title">Post title</label><br/><input type="text" name="title" /><br/>';

        page_text += '<label for="body">Post body</label><br/><textarea cols="80" rows="24" name="body" >Enter post body</textarea>';

        page_text += '<input type="submit" value="Save post" />';

        page_text += '</form>';

        page_title = 'Add content to blog';

        var page = {
            'id': '0',
            'title': page_title,
            'text': page_text,
            'tags': '',
            'num_of_comments': 0
        };



        Mu.render('post', page, {chunkSize: 10}).addCallback(function (output) {

            var buffer = '';

            output
              .addListener('data', function (c) {
                buffer += c;
              })
              .addListener('eof', function () {
                res.respond(buffer);
              });
        })
          .addErrback(function (e) {
            res.respond('Theming Oops:' + JSON.stringify(e));
        });


        res.respond(page_text);
    }],

    [post('/save'), function(req, res) {

        // Save post to Tyrant
        getPostParams(req, function(data) {
            tyrant.connect();
            tyrant.addListener('connect', function() {
                var post = querystring.parse(data);
                post.time = (new Date()).getTime();
                tyrant.put('blogentry' + post.time, 'type', 'blog', 'name', post.title, 'text', post.body, 'time', post.time.toString());
                res.respond('Post saved succesfully. <a href="/">Return</a> to main page.');
            });
        });

    }],

    [get(/^\/blog\/(\w+)$/), function(req, res, post_id) {

        tyrant.connect();
        tyrant.addListener('connect', function() {
            tyrant.get(post_id).addCallback(function(raw_item) {

                var item = tyrant.dict(raw_item);

                var post_date = new Date(parseInt(item.time));

                var blog_post = {
                    'id': '0',
                    'title':item.name,
                    'text': item.text,
                    'date': post_date.getDate() + '.' + (post_date.getMonth() + 1) + '.' + post_date.getFullYear() + ' ' + post_date.getHours() + ':' + post_date.getMinutes() + ':' + post_date.getSeconds(),
                    'tags': item.tags,
                    'num_of_comments': 0
                };

                Mu.render('post', blog_post, {chunkSize: 10}).addCallback(function (output) {

                    var buffer = '';

                    output
                      .addListener('data', function (c) {
                        buffer += c;
                      })
                      .addListener('eof', function () {
                        res.respond(buffer);
                      });
                }).addErrback(function (e) {
                    res.respond('Render Oops:' + JSON.stringify(e));
                });

            }).addErrback(function(e) {
                res.respond('Get Oops:' + JSON.stringify(e));
            });
        });

    }]

];

server = nerve.create(hello);
server.serve();