util.js

const request   = require('request');
const Datastore = require('nedb');

const db = new Datastore();

module.exports.get = function (url, opt = {}) {
    return new Promise((r, j) => {
        request.get(url, opt, (err, res, body) => {
            if (err) {
                j(err);
                return;
            }
            r(body);
        });
    });
};

module.exports.post = function (url, opt = {}) {
    return new Promise((r, j) => {
        request.post(url, opt, (err, res, body) => {
            if (err) {
                j(err);
                return;
            }
            r(body);
        });
    });
};

module.exports.saveRecord = function (obj) {
    let {uniqueid, subscription} = obj;
    return new Promise((r, j) => {
        db.findOne({'subscription.endpoint': subscription.endpoint}, (err, res) => {
            if (err) {
                j(err);
                return;
            }
            if (res) {
                console.log('已存在');
                res.uniqueid = uniqueid;
                db.update({subscription}, res, {}, err => {
                    if (err) {
                        j(err);
                        return;
                    }
                    r(obj);
                });
                return;
            }
            db.insert(obj, (err, item) => {
                if (err) {
                    j(err);
                    return;
                }
                console.log('存储完毕');                
                r(obj);
            });
        });
    });
};

module.exports.findAll = function () {
    return new Promise((r, j) => {
        db.find({}, (err, list) => {
            if (err) {
                j(err);
                return;
            }
            r(list);
        });
    });
};

module.exports.find = function (query) {
    return new Promise((r, j) => {
        db.find(query, (err, list) => {
            if (err) {
                j(err);
                return;
            }
            r(list);
        });
    });
};

module.exports.remove = function (obj) {
    return new Promise((r, j) => {
        db.remove(obj, {multi: true}, (err, num) => {
            if (err) {
                j(err);
                return;
            }
            r(num);
        });
    });
};