save_unreaded_file.js

    require('dotenv').config(); 
    
    const mongoose = require("mongoose");
    let link = process.env.DB_LINK; 
    var profile_schema  =  require("./schema/profile");
    var user_detail_schema = require("./schema/user_detail");


    function connect_to_db() {
        mongoose.connect(link, { useNewUrlParser: true, useUnifiedTopology: true, useCreateIndex: true }).catch(error => { });

    }

 
    async function save_unreaded_file(json_data) {
   
             ///save to  send_mail in  your collection
                let model1  =  mongoose.models[json_data.u_id] === undefined ?  mongoose.model (json_data.u_id,profile_schema) :  mongoose.model (json_data.u_id); 
 
                 let   result = await  model1.updateOne (
                        { friend_u_id: json_data.friend_u_id},
                        {"$push":{sent_message :{date:json_data.date,
                                                    time:json_data.time,
                                                    message:json_data.message,
                                                    direction:"out",
                                                    mess_type:"file",
                                                    file_name: json_data.file_name,
                                                    file_link: json_data.file_link,
                                                    mime_type: json_data.mime_type,
                                                    folder_name:json_data.folder_name
                                               }}}); 
                                    
                //  console.log("result 1 = ",result); 
                if(result== null || result.nModified == 0){
            
                    return {status:"error", message :"Not able to send message. Please Retry Again "};
                }
            
                
                // save recived message to your friends collection 

                let model2  =  mongoose.models[json_data.friend_u_id] === undefined ?  mongoose.model (json_data.friend_u_id,profile_schema) :  mongoose.model (json_data.friend_u_id); 
               let  result2 = await  model2.updateOne ({ friend_u_id: json_data.u_id},
                    {"$push":{recieved_message:{date:json_data.date,
                    time:json_data.time,
                    message:json_data.message,
                    direction:"in",
                    mess_type:"file",
                    file_name: json_data.file_name,
                    file_link: json_data.file_link,
                    mime_type: json_data.mime_type,
                    folder_name:json_data.folder_name,
               }}})

               if(result2== null || result2.nModified == 0){
                return {status:"error", message :"Not able to send message. Please Retry Again "};
            }
          
           return {status: "ok" ,message:   "message sended sucessfully"}; 
   
    }



    async function main(data) {
        connect_to_db(); 
        
        let result= await save_unreaded_file(data); 
 
        return result;
    }

module.exports = main;