const sql = require('mssql');

module.exports = sqlDbOperations;

function sqlDbOperations(){
    this.config={
        user: process.env["PitePiteMessageDbUser"],
        password: process.env["PitePiteMessageDbPassword"],
        server: process.env["PitePiteMessageDbServer"],
        database: process.env["PitePiteMessageDbName"],
        options: {
            encrypt: true
        }
    };
}

sqlDbOperations.prototype.getMessage=function(context,timeStamp){
    sql.close();
    var dbCredentials=this.config;
    return new Promise(function(resolve,reject){
        sql.connect(dbCredentials).then(pool => {
             var dateTime=timeStamp

            var query ="SELECT * FROM [dbo].[ScheduledMessage_table]"
                        +"where DATEDIFF(minute,@dateTime_parameter,"
                        +"[dbo].[ScheduledMessage_table].[TimeBroadcasted])<=5"
                        +"AND DATEDIFF(minute,@dateTime_parameter,"
                        +"[dbo].[ScheduledMessage_table].[TimeBroadcasted])>=0";

            return pool.request()
            .input('dateTime_parameter', sql.NVarChar (50), dateTime)
            .query(query)
            }).then(result => {
                context.log("result is :"+result);
                resolve(result);
            }).catch(err =>{
                context.log("error is :"+err);
                reject(err);
            });

            sql.on('error', err => {
                context.log("error is :"+err);
            })
    });



}