var promise = require('bluebird');
var options = {
    promiseLib: promise
};
var pgp = require('pg-promise')(options);

var cn = process.env.DATABASE_URL;
var db = pgp(cn);

module.exports = {
    addUser: function(firstName, lastName, email, password) {
        return db.query("insert into users(firstname, lastname, email, password) values($1, $2, $3, $4) returning user_id", [firstName, lastName, email, password]);
    },
    getUserId: function(email) {
        return db.query("select user_id from users where email=$1", email);
    },
    getPassword: function(userId){
        return db.query("select password from users where user_id=$1", userId);
    },
    getAll: function() {
        return db.query("select * from users")
            .catch(function(error) {
                console.log("error: %j", error);
                return 0;
            });
    },
    getThumb: function(userId) {
        return db.query("select thumb from users where user_id=$1", userId);
    },
    editUser: function(params) {
        return db.query("update users set firstname=$1, lastname=$2, location=$3, photo=$4, description=$5, phone_number=$6, address=$7 where user_id=$8",
                params)
            .then(function() {
                return 1;
            })
            .catch(function(error) {
                console.log("error: %j", error);
                return 0;
            });
    },
    getUser: function(userId) {
        return db.query("Select firstname, lastname, location, thumb, description, phone_number, email, address from users where user_id=$1", userId)
            .catch(function(error) {
                console.log("error: %j", error);
                return 0;
            });
    },
    addNumber: function(number, userId) {
        return db.query("update users set phone_number=$1 where user_id=$2", [number, userId]);
    },
    addStripeCustomerInfo: function(userId, stripeCustomerId, customer) {
        db.query("update users set stripe_customer_id=$1, stripe_customer_json=$2 where user_id=$3", [stripeCustomerId, customer, userId])
            .then(function() {
                console.log("Success adding stripeCustomerId to user");
            })
            .catch(function(error) {
                console.log("error: %j", error);
            });
    },
    getStripeCustomerId: function(userId) {
        return db.query("select stripe_customer_id from users where user_id = $1", userId)
            .catch(function(error) {
                console.log("error: %j", error);
                return 0;
            });
    },
    getCustomerJSON: function(userId) {
        return db.query("select stripe_customer_json from users where user_id = $1", userId)
            .catch(function(error) {
                console.log("error: %j", error);
                return 0
            });
    }
};