w.png

/**

* 實現(xiàn)串行化流程控制

*

*/

const fs = require('fs')

const request = require('request')

const htmlparser = require('htmlparser')

const configFileName = './rss_feeds.txt'

//檢查文件是否存在,確保文件沒問題.

function checkForRSSFile(){

    fs.exists(configFileName,(err,exist)=>{

        if(!exist){

            return next(new Error(`missing RSS file ${configFileName}`))

        }

        next(null,configFileName)

    })

}

//讀取文件內(nèi)容

function readRSSFile(configFileName){

    fs.readFile(configFileName,(err,feedList)=>{

        if(err){

            next(err)

            return

        }

        feedList = feedList.toString()

                    .replace(/^\s+|\s+$/g,'')

                    .split('\n')

        let random = Math.floor(Math.random() * feedList.length)

        next(null,feedList[random])           

    })

}

function downloadRSSFeed(feedUrl){

    request({url:feedUrl},(err,response,body) =>{

        if(err) next(err)

        if(response.statusCode != 200){

            return next(new Error('abnormal response status code.'))

        }

        next(null,body)

    })

}

var tasts = [

    checkForRSSFile,

    readRSSFile,

    downloadRSSFeed

]

function next(err,result){

    if(err) throw err //往上拋出異常

    let currentTask = tasts.shift() //返回數(shù)組一個元素,并且刪除

    if(currentTask){ //如果判斷函數(shù)存在

        currentTask(result) //執(zhí)行函數(shù)

    }

}

next() //開始執(zhí)行當前任務