var AWS = require('aws-sdk');
AWS.config.region = process.env.AWS_REGION;
var lambda = new AWS.Lambda();

var STAGE = process.env.STAGE
//let query=["select * from users"]

const callMysqlService=(query)=>new Promise((resolve,reject)=>{
  try{
    var params = {
      FunctionName: "backend-services-"+STAGE+"-mysql"
      InvocationType: 'RequestResponse',
      LogType: 'Tail',
      Payload: JSON.stringify({"query": query})
    };
    lambda.invoke(params, function(err, data) {
      if (err) {
        reject(err);
      } else {
        resolve(JSON.parse(data.Payload));
      }
    })
  }catch(err){
    console.log('err',err);
    reject(err);
  }
})

module.exports=callMysqlService;