hexoプラグインでPromiseを使って逐次処理や非同期処理する

Hexoのgeneratorプラグインで投稿記事を一つづつ処理して、新たなページを生成するプラグインを作ったときの備忘録です。

Hexoのgeneratorプラグインではlocal.postsという投稿記事が配列格納されたデータが渡ってきます。この配列をES6またはBluebirdのPromise()を使って非同期・逐次処理する例をメモしてみました。

photo by Mr. Alex Garcia - Double Cliche on flickr

シングルページWebアプリケーション〜Node.js、MongoDBを活用したJavaScript SPA〜

Amazonでレビューを見る

hexoプラグインのサンプル

ということで、今回はhexoで記事に応じたページ/パーマリンク/generate-sample/index.htmlを新たに生成するプラグインを想定し、サンプルコードを書いてみたいと思います。

前述の通り、Hexoのgeneratorプラグインではlocal.postsという投稿記事が配列格納されたデータが渡ってきます。これをPromiseで処理する為に以下のような形で書いてみました。

index.js

1	hexo.extend.generator.register('sample', require('./lib/generator'));

./lib/generator.js

'use strict';

var Promise  = require('bluebird');
var assign   = require('object-assign');
var pathFn   = require('path');
var sequence = Promise.resolve();

module.exports = function(locals) {
    var config = this.config;
    
    // D1 : ここにtempDataを配置するとオブジェクトの値が保持される
    var tempData = { "count" : 0};
    return Promise.all( locals.posts.map(function(post){
      // D2 : ここにtempDataを配置するとオブジェクトの値を毎度 初期化できる
      // var tempData = { "count" : 0};
      return {
        path     : pathFn.join( post.path , "generate-sample/index.html" ) ,
        data     : "<html>sample HTML</html>" ,
        no       : tempData
      }
    }))
    .then(localPostsProcess)
    .then(finish_return);
};

// Processing upon completion
function finish_return(results){
  console.log("finish! " + results.length );
  return results;
}

// Processing on local.posts
function localPostsProcess(results){
  return new Promise.all( results.map(postProcess));
}

// Processing on post
function postProcess(result){
  
  // P1: 非同期で実行
  return filterA(result)
    .then(filterB)

  // // P2: 逐次実行 (promiseブロッキング)
  // return sequence = sequence
  //   .then(function () {
  //     return result
  //   })
  //   .then(filterA)
  //   .then(filterB)
}


function filterA(result){
  return new Promise(function(resolve , reject){
    setTimeout(function(){
      var update_result = assign(
        result ,
        {
          "no" : assign( result.no , {"count" : result.no.count + 1 } )
        }
      );
      
      console.log("A-" + String(update_result.no.count));
      resolve(update_result)
    },2000);
  })
}

function filterB(result){
  return new Promise(function(resolve , reject){
    setTimeout(function(){
      console.log("B-" + String(result.no.count));
      resolve(result)
    },1000);
  })
}