Edit File - File Manager

Edit File: helper.js

'user strict';

/**
 * mysql queries helper functions
 */

const DB = require('./db');

// const fs = require('fs');

class Helper {

constructor(app) {
        this.db = DB;
    }

// insert message of room and update by last_message_id
    insertMessageAndUpdateRoom(data) {
        try{
            // obj need ==> { room_id - sender_id - sender_type - type - body - duration - created_at
            return new Promise(function (resolve, reject) {
                DB.query('INSERT INTO messages SET ?', data).then((results,error) => {
                    // update room last_message_id and date
                    DB.query('UPDATE rooms SET ? WHERE id = ?', [{last_message_id:results.insertId,updated_at:new Date()},data.room_id]);
                    // return result
                    resolve(results.insertId);
                });
            });
        } catch (error) {
                console.log(error);
                return null;
        }
    }
    // find all row of table room_members
    findAllMemberInRoom(room_id){
        try{
            return new Promise(function (resolve, reject) {
                DB.query("SELECT * From room_members Where room_id = "+ room_id).then((members,error) =>{
                    return resolve(members);
                })
            });
        } catch (error) {
            console.log(error);
            return null;
        }
    }
    // insert row of table message_notifications
    insertMessageNotifications(data,message_id,member,is_sender,is_seen){
        try{
            return new Promise(function (resolve, reject) {
                DB.query('INSERT INTO message_notifications SET ?', {room_id: data.room_id,message_id: message_id,userable_type:member.memberable_type,userable_id:member.memberable_id,is_flagged:0,is_sender:is_sender,is_seen:is_seen,created_at:new Date()});
            });
        } catch (error) {
            console.log(error);
            return null;
        }

}
    //updateLocations
    updateLocations(data){
        try{
            return new Promise(function (resolve, reject) {
                DB.query('UPDATE providers SET ? WHERE id = ?', [{lat:data.lat,lng:data.lng,map_desc:data.map_desc},data.provider_id], function (error, results, fields) {
                    return resolve(results);
                });
            });
        } catch (error) {
            console.log(error);
            return null;
        }
    }
    //getDelegateOrder
    getDelegateOrder(provider_id){
        try{
            return new Promise(function (resolve, reject) {
                DB.query('SELECT user_id From orders Where provider_id = ? AND status= ? ',[provider_id,"in_road"], function (err, results) {
                    return resolve(results);
                });
            });
        } catch (error) {
            console.log(error);
            return null;
        }
    }
}

module.exports = new Helper();

Back to File Manager