Saturday 18 March 2017

nodejs lambda epipe error

I'm getting this error & unable to find any reason for it. Following is the snapshot of my code. Is it due to asynchronous execution of code?? I have deployed this code on amazon aws. Stackoverflow says me to add more details, but i dont have more than this.

    "Error: write EPIPE
     at Object.exports._errnoException (util.js:870:11)
     at exports._exceptionWithHostPort (util.js:893:20)
   at WriteWrap.afterWrite (net.js:763:14)"

    module.exports.register = function(client, body, s, rclient, redis, callback){
    console.log("inside registration module function");
    console.log(body);
    console.log("mobile no", body.mobile_no);

    client.connectAsync()
.then(()=>
 {


return client.queryAsync('select count(*) from users where mobile_no=$1',[body.mobile_no]);})
.then(res=>{

console.log("connection successful");

if(res.rows[0].count==0)
{
    return client.queryAsync('insert into users(mobile_no, email, city, uname, password) values ($1, $2, $3, $4, $5)', [body.mobile_no, body.email, body.city, body.uname, body.password])
    .then(()=>{
        return client.queryAsync('select uid from users where mobile_no=$1',[body.mobile_no]);
    })
    .then(res=>{
        var uid = JSON.stringify(res);
        uid = JSON.parse(uid).rows[0].uid;

        console.log("uid: ", uid);

        console.log(uid);
        console.log(s);
        rclient.set(s,uid,redis.print);

        const response = {

            statusCode:201,
            body: JSON.stringify({
                sid: s,
                message: 'user registered',
            }),
        };

        console.log('success');
        return Promise.promisify(response);

    })
     .then(res=>{
        callback(null, res);
    })

}
else
{
    console.log("It is already registered mobile no");

              const response = {

            statusCode:412,
            body: JSON.stringify({
                sid: '',
                message: 'error: mobile no already registered',
            }),
        };

        Promise.promisify(response);

   }
 })
     .then(res=>{
     callback(null, res);
      })
    .then(()=>{

    client.end();
    rclient.quit();

  })

  .catch(err=>{
   console.log(err.stack);
    console.log("error occured");
   })

}



via Akshay Barpute

No comments:

Post a Comment