/**
 * 接口公共方法
 * @author: xuqiMqi.xu@yoho.cn>
 * @date: 2016/4/25
 */

'use strict';

const rp = require('request-promise');
const _ = require('lodash');
const log = require('./logger');
const api = require('../config/common').domains.api;

const ApiUrl = api;

class API {

    /**
     * get
     * @param url String
     * @param data Obejct
     */
    get(url, data) {
        
        log.info('API GET: %s, parms: %j',url,data,{});
        log.profile('%s %j',url,data);
        
        let ret =  rp({
            url: `${ApiUrl}${url}`,
            qs: data
        });
        
        ret.then((body)=>{
            log.profile('%s %j',url,data);
            log.info('API GET: %s, parms: %j ',url,data,body);
        }).catch((error)=>{
            log.profile('%s %j',url,data);
            log.error('API GET: %s, parms: %j ',url,data,error);
        });
        
        return ret;
    }

    /**
     * multi get
     * @params: urls => Array[Object[url[string], data[object]]]
     */
    multiGet(urls) {
        var rps = [];

        _.forEach(urls, function(el) {
            rps.push(rp({
                url: `${ApiUrl}${el.url}`,
                qs: el.data
            }));
        });

        return Promise.all(rps).then((d) => {
            return d;
        });
    }

    /**
     * post
     * @param url String
     * @param data Obejct
     */
    post(url, data) {
        return rp({
            url: `${ApiUrl}${url}`,
            method: 'post',
            form: data
        });
    }
}

module.exports = API;