koa-ueditor上传图片到七牛

"use strict";
var Q = require(‘q‘);
var path = require("path");
var os = require(‘os‘);
var snowflake = require(‘node-snowflake‘).Snowflake;
var qn = require(‘qn‘);
var parse = require(‘co-busboy‘);
var Rst = require(‘huanche-models‘).rst;
var img_type = ‘.jpg .png .gif .ico .bmp .jpeg‘;
var img_path = ‘/ueditor/upload‘;

var Config = {};

function* ueditor(next){
    if (this.query.action === ‘config‘) {
        this.set("Content-Type","json");
        this.redirect("/ueditor/nodejs/config.json");
    }
    else if(this.query.action === ‘uploadimage‘ || this.query.action === ‘uploadfile‘){
        if (!Config.qn) {
            throw (new Rst()).error(‘缺少qiniu配置‘);
        }
        var parts = parse(this);
        var part;
        // var stream;
        var tmp_name;
        var file_path;
        var filename;
        var deferred = Q.defer();
        while (part = yield parts) {
            if (part.length) {
                // fields are returned as arrays
                var key = part[0];
                var value = part[1];
                // check the CSRF token
                //if (key === ‘_csrf‘) this.assertCSRF(value);
            } else {
                // files are returned as readable streams
                // let‘s just save them to disk

                if(this.query.action === ‘uploadimage‘ && img_type.indexOf(path.extname(part.filename)) >= 0 ){
                    var tmpdir = path.join(os.tmpdir(), path.basename(part.filename));
                    filename = snowflake.nextId() + path.extname(tmpdir);
                    file_path = path.join(img_path, filename);
                    tmp_name = part.filename;

                    qn.create(Config.qn).upload(part, {
                        key: ‘ueditor/images/‘ + filename
                    }, function (err, results) {
                        if (err) deferred.reject(err);
                        deferred.resolve(results);
                    });
                }
            }
        }

        var rst = yield deferred.promise.then(function (result) {
            // console.log(result);
            return result;
        });
        this.body = {
            ‘url‘: rst.url,
            ‘title‘: filename,
            ‘original‘: tmp_name,
            ‘state‘: ‘SUCCESS‘
        };
    }else{
        this.body = {
            ‘state‘: ‘FAIL‘
        };
    }
    yield next;
}

module.exports = function(config){
    if(config){
        Config = config;
    }
    return ueditor;
};

const router = require(‘koa-router‘)();
const ueditor_qiniu = require(‘../../middleware/koa_ueditor_upload_qiniu‘);

router.all(‘/ueditor/ue‘, ueditor_qiniu({
    qn: {
        accessKey: ‘xxxxxxxxxxx‘, // 七牛的accessKey
        secretKey: ‘xxxxxxxxxxx‘, // 七牛的secretKey
        bucket: ‘imgpub‘, // bucket
        origin: ‘https://xxx.xxxx.com‘ // origin url
    }
}));

module.exports = router;