'use strict';

const request = require('request');
const db = require('../app/db')
const logger = require('../app/logger');

var members_action = {
    refreshActions: function (req, res, next) {
        logger.info(req.query);

        let Qstring =   "SELECT id,uid,updated from members ORDER BY updated ASC LIMIT 2";
        logger.info( Qstring );
        db.query(Qstring, function (err, result) {
            try {
                if (err) throw err;

                if (result.rowCount > 0 ){
                    result.rows.map( (rw)=>{
                        console.log(rw);
                        console.log(rw["uid"]);

                        const updateQuery =  "UPDATE members SET updated =now() WHERE uid::text='"+rw["uid"]+"'"
                        db.query(updateQuery, (err, res) => {
                            if (err) {
                                logger.info(err.stack)
                            } else {
                                logger.info(res.rows[0])
                            }
                        })

                        const insertQuery = 'INSERT INTO members_actions(member_id, member_uid, action_label,action_name,status_description,status ) VALUES($1, $2, $3, $4, $5, $6)'

                        var Querydata2 = {
                            "members_id":rw["id"],
                            "members_uid": rw["uid"],
                            "action_label": 'Systems Status Checks ',
                            "action_name": 'system_status_checks',
                            "status_description": 'processing',
                            "status": 0
                        };

                        var Querydata = [
                                rw["id"],
                                rw["uid"],
                                'Systems Status Checks ',
                                'system_status_checks',
                                'processing',
                                0
                        ];

                        logger.info(Querydata);
                        db.query(insertQuery, Querydata, (err, res) => {
                            if (err) {
                                console.log(err.stack)
                            } else {
                                console.log(res.rows[0])
                            }
                        })
                  })
                }

                let resultItem ={
                    "result": result.rows,
                    "total_record":  result.rowCount
                }
                // logger.info(result);
                next(null, resultItem); // pass control to the next handler
            } catch (e) {
                next(e.message, null); // pass control to the next handler
            }
        });

    },
    updateSelection: async function (){
        logger.info("Ameye-Called -The-Function")
    }
};
module.exports = members_action;