Commit: 22c55d62993483364156e5986880ad84823755aa - node_sample_mobbs (git)

Node.js sample application with jQuery Mobile and Express.

Commit MetaInfo

• Revision: 22c55d62993483364156e5986880ad84823755aa (tree)
• Zeit: 2012-10-20 19:14:27
• Autor: hylom <hylom@hylo...>
• Commiter: hylom

Log Message

add some fixes...

Ändern Zusammenfassung

• add: Makefile
• modified: models/database.js
• add: testing/models.js
• modified: views/index.jade

Diff

--- /dev/null
+++ b/Makefile
@@ -0,0 +1,9 @@
+MOCHA = node_modules/.bin/mocha -R spec
+
+test:
+	$(MOCHA) testing/models 
+
+reset-db:
+	mongo mobbs tools/sampledata.js
+
+

--- a/models/database.js
+++ b/models/database.js
@@ -54,7 +54,8 @@ Database.prototype.close = function() {
 Database.prototype._getCollection = function (collectionName, callback) {
   this._open('mobbs', function(err, db) {
     if (err) {
-      return callback(err);
+      callback(err);
+      return;
     }
     db.createCollection(collectionName, callback);
   });
@@ -83,11 +84,8 @@ Topics.prototype.getLatest = function (start, end, callback) {
       callback(err);
       return;
     }
-    // topicsデータの全データにアクセスするカーソルを作成する
     var cursor = collection.find({});
-    // start、endの値に応じてカーソル位置を移動させる
     cursor.sort([['date', -1]]).limit(end - start).skip(start);
-    // カーソルの対象となる値を配列として返す
     cursor.toArray(callback);
   });
 };
@@ -101,7 +99,6 @@ Topics.prototype.findById = function (topicId, callback) {
       callback(err);
       return;
     }
-    // topicIdフィールドが指定したトピックIDであるドキュメントを取得
     collection.findOne({topicId: topicId}, callback);
   });
 };
@@ -113,11 +110,12 @@ Topics.prototype.insert = function (topic, callback) {
   var self = this;
 
   // countersコレクションからカウンタの値を取得する
-  this._getCollection('counters', function (err, collection) {
+  self._getCollection('counters', function (err, collection) {
     if (err) {
       callback(err);
       return;
     }
+    // counterの値を取得すると同時にインクリメントする
     collection.findAndModify({name:'topics'}, {}, {$inc: {count:1}}, createTopic);
   });
 
@@ -150,30 +148,9 @@ Topics.prototype.insert = function (topic, callback) {
 };
 
 /**
- * 指定したトピックのreplies要素に指定したコメントIDを追加する
- */
-Topics.prototype.appendReply = function (topicId, commentId, callback) { 
-  this._getCollection('topics', function (err, collection) {
-    if (err) {
-      callback(err);
-      return;
-    }
-    var cursor = collection.findAndModify(
-      {topicId:topicId},
-      {},
-      {$push: {replies:commentId}},
-      callback
-    );
-  });
-};
-
-/**
  * コメントデータにアクセスするためのオブジェクト
  */
-var Comments = function () {
-  this._db = null;
-  this._client = null;
-};
+var Comments = function () {};
 Comments.prototype = new Database();
 
 /**
@@ -192,41 +169,30 @@ Comments.prototype.findById = function (commentId, callback) {
       callback(err);
       return;
     }
-    // commentIdフィールドが指定したコメントIDであるドキュメントを取得
-    var cursor = collection.findOne({commentId: commentId}, callback);
-  });
-};
-
-/**
- * 指定したコメントのreplies要素に指定したコメントIDを追加する
- */
-Comments.prototype.appendReply = function (parentId, childId, callback) { 
-  this._getCollection('comments', function (err, collection) {
-    if (err) {
-      callback(err);
-      return;
+    // commentId引数が数値の場合、コメントオブジェクトを返す
+    if (typeof commentId === 'number') {
+      collection.findOne({commentId: commentId}, callback);
+    } else {
+      // commentId引数が配列の場合、取得したコメントを配列で返す
+      var cursor = collection.find({commentId: {$in: commentId}});
+      cursor.sort([['date', -1]]);
+      cursor.toArray(callback);
     }
-    var cursor = collection.findAndModify(
-      {commentId:parentId},
-      {},
-      {$push: {replies:childId}},
-      callback
-    );
   });
 };
 
 /**
  * コメントを新規作成してデータベースに挿入する
  */
-Comments.prototype.insert = function (comment, callback) {
+Comments.prototype.insert = function (topicId, comment, callback) {
   var self = this;
   // countersコレクションからカウンタの値を取得する
-  this._getCollection('counters', function (err, collection) {
+  self._getCollection('counters', function (err, collection) {
     if (err) {
       callback(err);
       return;
     }
-    collection.findAndModify({name:'comment'}, {}, {$inc: {count:1}}, createComment);
+    collection.findAndModify({name:'comments'}, {}, {$inc: {count:1}}, createComment);
   });
 
   // 取得したカウンタの値をコメントIDとするコメントを作成
@@ -234,7 +200,7 @@ Comments.prototype.insert = function (comment, callback) {
     var nextId = counter.count;
     var newComment = {
       commentId: nextId,
-      topicId: comment.topicId,
+      topicId: topicId,
       title: comment.title,
       text: comment.text,
       date: new Date(),
@@ -244,31 +210,64 @@ Comments.prototype.insert = function (comment, callback) {
       parentCommentId: comment.parentCommentId || null
     };
 
-    // 親コメントが指定されていない場合、トピックのrepliesにIDを追加
-    if (comment.parentCommentId === null) {
-      var topics = database.getTopics();
-      topics.appendReply(comment.topicId, nextId, function (err, topic) {
-        topics.close();
+    // 親コメントが指定されていない場合、トピックのrepliesフィールドに
+    // コメントIDを追加する
+    if (newComment.parentCommentId === null) {
+      appendReplyToTopic(newComment, function (err) {
         if (err) {
           callback(err);
           return;
         }
-        insertComment(newComment, callback);
-        });
+        insertComment(newComment);
+      });
     } else {
-      self.appendReply(comment.parentCommentId, nextId, function (err, parent) {
+      // 親コメントが指定されている場合は親コメントのrepliesフィールドに
+      // コメントIDを追加する
+      appendReplyToComment(newComment, function (err) {
         if (err) {
           callback(err);
           return;
         }
-        insertComment(newComment, callback);
+        insertComment(newComment);
       });
     }
   }
 
+  // 指定したコメントのrepliesフィールドに指定したコメントIDを追加する
+  function appendReplyToComment(comment, callback) { 
+    var parentId = comment.parentCommentId;
+    var childId = comment.commentId;
+    self._getCollection('comments', function (err, collection) {
+      if (err) {
+        callback(err);
+        return;
+      }
+      collection.findAndModify( {commentId:parentId},
+                                {},
+                                {$push: {replies:childId}},
+                                callback);
+    });
+  };
+
+  // 指定したトピックのreplesフィールドに指定したコメントIDを追加する
+  function appendReplyToTopic(comment, callback) {
+    var parentId = comment.topicId;
+    var childId = comment.commentId;
+    self._getCollection('topics', function (err, collection) {
+      if (err) {
+        callback(err);
+        return;
+      }
+      collection.findAndModify( {topicId:parentId},
+                                {},
+                                {$push: {replies:childId}},
+                                callback);
+    });
+  };
+
   // コメントをデータベースに挿入する
-  function inserteComment(newComment) {
-    this._getCollection('comments', function (err, collection) {
+  function insertComment(newComment) {
+    self._getCollection('comments', function (err, collection) {
       if (err) {
         callback(err);
         return;
@@ -278,6 +277,7 @@ Comments.prototype.insert = function (comment, callback) {
           callback(err);
           return;
         }
+        // 挿入したオブジェクトを引数に与えてコールバック関数を実行する
         callback(err, obj[0]);
       });
     });
@@ -285,12 +285,12 @@ Comments.prototype.insert = function (comment, callback) {
 };
 
 /**
- * コメントに付けられたコメントをツリー状のオブジェクトで取得する
+ * トピックに付けられたコメントをツリー状のオブジェクトで取得する
  */
 Comments.prototype.getCommentTree = function (topicId, callback) {
   var self = this;
-  var topics = database.getTopics();
 
+  var topics = database.getTopics();
   topics.findById(topicId, function (err, topic) {
     topics.close();
     if (err) {
@@ -314,7 +314,6 @@ Comments.prototype.getCommentTree = function (topicId, callback) {
           items[comment.commentId] =  comment;
         } else {
           // ループ終了時の処理
-          comments.close();
           var tree = buildCommentTree(topic.replies, items, []);
           callback(null, tree);
         }

--- /dev/null
+++ b/testing/models.js
@@ -0,0 +1,137 @@
+
+var assert = require('assert');
+var database = require('../models/database');
+
+describe('database', function () {
+  
+  describe('.Topics#getLatest(start, end)', function () {
+    it('can retrive some topic', function(done) {
+      var topics = database.getTopics();
+      topics.getLatest(1, 2, function (err, doc) {
+        topics.close();
+        assert(!err);
+        console.log('--------');
+        assert(doc.length > 0, 'Number of found items is invalid.');
+        for (var i = 0; i < doc.length; i++) {
+          console.log(doc[i]);
+        }
+        done();
+        return;
+      });
+    });
+  });
+
+  describe('.Topics#findById(topicId)', function () {
+    it('can retrive one topic', function(done) {
+      var topics = database.getTopics();
+      topics.findById(1, function (err, doc) {
+        topics.close();
+        assert(!err);
+        assert(doc);
+        console.log('--------');
+        console.log(doc);
+        done();
+        return;
+      });
+    });
+  });
+
+  describe('.Topics#insert(topic, callback)', function () {
+    it('insert new topic', function(done) {
+      var topics = database.getTopics();
+      var topic = {
+        title: 'テストトピック',
+        text: 'テスト用本文'
+      };
+      topics.insert(topic, function (err, topicId) {
+        topics.close();
+        assert(!err);
+        assert(topicId !== undefined);
+        done();
+      });
+    });
+  });
+
+  describe('.Comments#findById(commentId)', function () {
+    it('can retrive one comments', function(done) {
+      var comments = database.getComments();
+      comments.findById(1, function (err, doc) {
+        comments.close();
+        assert(!err);
+        console.log('--------');
+        console.log(doc);
+        done();
+        return;
+      });
+    });
+  });
+
+  describe('.Comments#findById(commentId)', function () {
+    it('can retrive some comments', function(done) {
+      var comments = database.getComments();
+      comments.findById([1, 2], function (err, docs) {
+        comments.close();
+        assert(!err);
+        assert(docs.length == 2, 'length is ' + docs.length);
+        console.log('--------');
+        console.log(docs[0]);
+        console.log(docs[1]);
+        done();
+        return;
+      });
+    });
+  });
+
+  describe('.Comments#insert(topicId, comment, callback)', function () {
+    it('can insert comment', function(done) {
+      var comments = database.getComments();
+      var comment = {
+        title: 'テストコメント',
+        text: 'テスト用コメント本文',
+      };
+      comments.insert(1, comment, function (err, comment) {
+        comments.close();
+        assert(!err);
+        assert(comment.commentId !== undefined);
+        done();
+      });
+    });
+  });
+
+  describe('.Comments#insert(topicId, comment, callback)', function () {
+    it('can insert child comment', function(done) {
+      var comments = database.getComments();
+      var comment = {
+        title: 'テストコメント',
+        text: 'テスト用コメント本文',
+        parentCommentId: 2,
+      };
+      comments.insert(1, comment, function (err, comment) {
+        comments.close();
+        assert(!err);
+        assert(comment.commentId !== undefined);
+        assert(comment.parentCommentId === 2);
+        done();
+      });
+    });
+  });
+
+  describe('.Comments#getCommentTree(topicId)', function () {
+    it('can retrive some comment', function(done) {
+      var count = 0;
+      var comments = database.getComments();
+      comments.getCommentTree(1, function (err, doc) {
+        comments.close();
+        assert(!err);
+        assert(doc);
+        console.log(doc);
+        done();
+        return;
+      });
+    });
+  });
+
+});
+
+
+

--- a/views/index.jade
+++ b/views/index.jade
@@ -21,48 +21,3 @@ block content
       h1 
         a(href='#about') mobbs ver.0.0.1 
 
-  // aboutページ
-  #about(data-role='page')
-    div(data-role='header')
-      h1 mobbs test BBS
-      // a要素にdata-rel='back'属性を付けると、要素をクリックしたときに
-      // 「戻る」動作が行われる
-      a(href='#', data-rel='back') 戻る
-    div(data-role='content')
-      h2 mobbsについて
-      p mobbsはNode.jsとjQuery Mobileで実装されたスマートフォン/タブレット向け掲示板アプリケーションです。
-    div(data-role='footer')
-      h1 
-        | mobbs ver.0.0.1 
-
-  // トピック一覧ページ
-  #topics-list(data-role='page')
-    div(data-role='header')
-      h1 トピック一覧
-      a.ui-btn-right(href='#dialog-create-topic', data-role='button') 新規作成
-    div(data-role='content')
-      // data-role='listview'を指定すると、リストをリストビュー形式で
-      // 表示できる
-      ul#topics-listview(data-role='listview')
-    div(data-role='footer')
-      h1 
-        a(href='#about') mobbs ver.0.0.1 
-
-  #dialog-create-topic(data-role='dialog')
-    div(data-role='header')
-      h2 トピックの新規作成
-    div(data-role='content')
-      form(action='/topic/create', method='post', data-ajax='false')
-        label(for='topic-post-name') お名前：
-        input(type='text', id='topic-post-name', name='name')
-        label(for='topic-post-title') タイトル（必須）：
-        input(type='text', id='topic-post-title', name='title')
-        label(for='topic-post-related') URL：
-        input(type='url', id='topic-post-related', name='relatedUrl')
-        label(for='topic-post-text') 本文（必須）：
-        textarea(id='topic-post-text', name='text')
-        // data-rel='back'を指定すると、クリック時に前ページに戻る
-        a(href='#', data-rel='back', type='button') トピック一覧に戻る
-        input(type='submit', id='topic-post-submit', value='トピック作成', disabled='disabled')
-
-