Copyright 2016 <a href="https://github.com/hatena/Hatena-Textbook">はてな教科書</a> by <a href="http://www.hatena.ne.jp/">はてな</a>

Contributors

Stargazers

Forkers

poohsunny hirocaster unicode48 nashirox outan scixer ledmonster yuda0629 rightgo09 tkkemg-global amaterupc roshihy asosankai fuuryuu infinityth4 ainame kaerukun kazuph ikazoy duyoji azu yoshifuji yuutetu cutmail volanja puttyo m0rishita laiso trickre samurait kozyty glenferrielodge palpro anoworl yku yukiosh applideveloper kitakayu yu01 radineer-inc veryblue st0326s kakari bojodango onishi mizuru takuyaa saga1 watarufujiwara cncgl cartman0 karamage peco25 znatz tnantoka mitsuru793 kiyoshi-tokunaga yoshimaa s11y tomipos shunkimura aeha hakobe ha1f anatofuz yufyukky ytrino pingpoooong lanoskomatsu onobori xuwei-k jpmartha hex309 t-sato1220 dirtyhero yuheinakasaka wilshar10 polamjag atom084 shinogasa gatakaba stgctkm eiichiroi halueda kumamotone numamino siotouto cd-glacier royskim toshi-toma yangsin nafu romtin ur0n maru10t niwatako snghrsw sakatore th3m1s keisei1092

let db;
MongoClient.connect('mongodb://localhost:27017/rssDataBase')
    .then((_db) => {
        db = _db;
        return fs.readFile('./feed.xml', 'utf8');
    })
    .then(rssString => parseString(rssString))
    .then((result) => {
        const items = result.rss.channel[0].item;
        return Promise.all(items.map(item => request(item.link[0])));
    })
    .then((responses) => {
        return responses.map((res) => {
            return {
                url  : res.request.href,
                body : res.body,
            };
        });
    })
    .then((data) => {
        return db.collection('entries').insertMany(data);
    })
    .then(() => {
        db.close();
    });