241 lines
12 KiB
JavaScript
241 lines
12 KiB
JavaScript
|
var fs = require("fs")
|
||
|
|
const {
|
||
|
|
template,
|
||
|
|
checkEmail,
|
||
|
|
} = require("./emailUtils.js")
|
||
|
|
module.exports = function(s,config,lang){
|
||
|
|
// mailing with nodemailer
|
||
|
|
try{
|
||
|
|
if(config.mail){
|
||
|
|
if(config.mail.from === undefined){config.mail.from = '"ShinobiCCTV" <no-reply@shinobi.video>'}
|
||
|
|
s.nodemailer = require('nodemailer').createTransport(config.mail);
|
||
|
|
}
|
||
|
|
const sendMessage = s.nodemailer.sendMail
|
||
|
|
const onDetectorNoTriggerTimeoutForEmail = function(e){
|
||
|
|
//e = monitor object
|
||
|
|
if(config.mail && e.details.detector_notrigger_mail === '1'){
|
||
|
|
s.knexQuery({
|
||
|
|
action: "select",
|
||
|
|
columns: "mail",
|
||
|
|
table: "Users",
|
||
|
|
where: [
|
||
|
|
['ke','=',e.ke],
|
||
|
|
['details','NOT LIKE','%"sub"%'],
|
||
|
|
]
|
||
|
|
},(err,r) => {
|
||
|
|
r = r[0]
|
||
|
|
var mailOptions = {
|
||
|
|
from: config.mail.from, // sender address
|
||
|
|
to: checkEmail(r.mail), // list of receivers
|
||
|
|
subject: lang.NoMotionEmailText1+' '+e.name+' ('+e.id+')', // Subject line
|
||
|
|
html: '<i>'+lang.NoMotionEmailText2+' ' + (e.details.detector_notrigger_timeout || 10) + ' '+lang.minutes+'.</i>',
|
||
|
|
}
|
||
|
|
mailOptions.html+='<div><b>'+lang['Monitor Name']+' </b> : '+e.name+'</div>'
|
||
|
|
mailOptions.html+='<div><b>'+lang['Monitor ID']+' </b> : '+e.id+'</div>'
|
||
|
|
sendMessage(mailOptions, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.systemLog('detector:notrigger:sendMail',error)
|
||
|
|
s.tx({f:'error',ff:'detector_notrigger_mail',id:e.id,ke:e.ke,error:error},'GRP_'+e.ke);
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
s.tx({f:'detector_notrigger_mail',id:e.id,ke:e.ke,info:info},'GRP_'+e.ke);
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
const onTwoFactorAuthCodeNotificationForEmail = function(r){
|
||
|
|
// r = user object
|
||
|
|
if(r.details.factor_mail !== '0'){
|
||
|
|
sendMessage({
|
||
|
|
from: config.mail.from,
|
||
|
|
to: checkEmail(r.mail),
|
||
|
|
subject: r.lang['2-Factor Authentication'],
|
||
|
|
html: r.lang['Enter this code to proceed']+' <b>'+s.factorAuth[r.ke][r.uid].key+'</b>. '+r.lang.FactorAuthText1,
|
||
|
|
}, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.systemLog(r.lang.MailError,error)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
const onFilterEventForEmail = function(x,d){
|
||
|
|
// x = filter function
|
||
|
|
// d = filter event object
|
||
|
|
if(x === 'email'){
|
||
|
|
if(d.videos && d.videos.length > 0){
|
||
|
|
d.mailOptions = {
|
||
|
|
from: config.mail.from, // sender address
|
||
|
|
to: checkEmail(d.mail),
|
||
|
|
subject: lang['Filter Matches']+' : '+d.name, // Subject line
|
||
|
|
html: lang.FilterMatchesText1+' '+d.videos.length+' '+lang.FilterMatchesText2,
|
||
|
|
};
|
||
|
|
if(d.execute&&d.execute!==''){
|
||
|
|
d.mailOptions.html+='<div><b>'+lang.Executed+' :</b> '+d.execute+'</div>'
|
||
|
|
}
|
||
|
|
if(d.delete==='1'){
|
||
|
|
d.mailOptions.html+='<div><b>'+lang.Deleted+' :</b> '+lang.Yes+'</div>'
|
||
|
|
}
|
||
|
|
d.mailOptions.html+='<div><b>'+lang.Query+' :</b> '+d.query+'</div>'
|
||
|
|
d.mailOptions.html+='<div><b>'+lang['Filter ID']+' :</b> '+d.id+'</div>'
|
||
|
|
sendMessage(d.mailOptions, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.tx({f:'error',ff:'filter_mail',ke:d.ke,error:error},'GRP_'+d.ke);
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
s.tx({f:'filter_mail',ke:d.ke,info:info},'GRP_'+d.ke);
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
const onEventTriggerBeforeFilterForEmail = function(d,filter){
|
||
|
|
const monitorConfig = s.group[d.ke].rawMonitorConfigurations[d.id]
|
||
|
|
if(monitorConfig.details.detector_mail === '1'){
|
||
|
|
filter.mail = true
|
||
|
|
}else{
|
||
|
|
filter.mail = false
|
||
|
|
}
|
||
|
|
}
|
||
|
|
const onEventTriggerForEmail = async (d,filter) => {
|
||
|
|
const monitorConfig = s.group[d.ke].rawMonitorConfigurations[d.id]
|
||
|
|
if(filter.mail && config.mail && !s.group[d.ke].activeMonitors[d.id].detector_mail){
|
||
|
|
s.knexQuery({
|
||
|
|
action: "select",
|
||
|
|
columns: "mail",
|
||
|
|
table: "Users",
|
||
|
|
where: [
|
||
|
|
['ke','=',d.ke],
|
||
|
|
['details','NOT LIKE','%"sub"%'],
|
||
|
|
]
|
||
|
|
},async (err,r) => {
|
||
|
|
r = r[0];
|
||
|
|
var detector_mail_timeout
|
||
|
|
if(!monitorConfig.details.detector_mail_timeout||monitorConfig.details.detector_mail_timeout===''){
|
||
|
|
detector_mail_timeout = 1000*60*10;
|
||
|
|
}else{
|
||
|
|
detector_mail_timeout = parseFloat(monitorConfig.details.detector_mail_timeout)*1000*60;
|
||
|
|
}
|
||
|
|
//lock mailer so you don't get emailed on EVERY trigger event.
|
||
|
|
s.group[d.ke].activeMonitors[d.id].detector_mail = setTimeout(function(){
|
||
|
|
//unlock so you can mail again.
|
||
|
|
clearTimeout(s.group[d.ke].activeMonitors[d.id].detector_mail);
|
||
|
|
delete(s.group[d.ke].activeMonitors[d.id].detector_mail);
|
||
|
|
},detector_mail_timeout);
|
||
|
|
const sendMail = function(files){
|
||
|
|
const infoRows = []
|
||
|
|
Object.keys(d.details).forEach(function(key){
|
||
|
|
var value = d.details[key]
|
||
|
|
var text = value
|
||
|
|
if(value instanceof Object){
|
||
|
|
text = JSON.stringify(value,null,3)
|
||
|
|
}
|
||
|
|
infoRows.push(template.createRow({
|
||
|
|
title: key,
|
||
|
|
text: text
|
||
|
|
}))
|
||
|
|
})
|
||
|
|
sendMessage({
|
||
|
|
from: config.mail.from,
|
||
|
|
to: checkEmail(r.mail),
|
||
|
|
subject: lang.Event+' - '+d.screenshotName,
|
||
|
|
html: template.createFramework({
|
||
|
|
title: lang.EventText1 + ' ' + d.currentTimestamp,
|
||
|
|
subtitle: 'Shinobi Event',
|
||
|
|
body: infoRows.join(''),
|
||
|
|
}),
|
||
|
|
attachments: files || []
|
||
|
|
}, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.systemLog(lang.MailError,error)
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
})
|
||
|
|
}
|
||
|
|
if(monitorConfig.details.detector_mail_send_video === '1'){
|
||
|
|
// change to function that captures on going video capture, waits, grabs new video file, slices portion (max for transmission) and prepares for delivery
|
||
|
|
s.mergeDetectorBufferChunks(d,function(mergedFilepath,filename){
|
||
|
|
fs.readFile(mergedFilepath,function(err,buffer){
|
||
|
|
if(buffer){
|
||
|
|
sendMessage({
|
||
|
|
from: config.mail.from,
|
||
|
|
to: checkEmail(r.mail),
|
||
|
|
subject: filename,
|
||
|
|
html: '',
|
||
|
|
attachments: [
|
||
|
|
{
|
||
|
|
filename: filename,
|
||
|
|
content: buffer
|
||
|
|
}
|
||
|
|
]
|
||
|
|
}, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.systemLog(lang.MailError,error)
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
})
|
||
|
|
}
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
if(!d.screenshotBuffer){
|
||
|
|
const {screenShot, isStaticFile} = await s.getRawSnapshotFromMonitor(monitorConfig,{
|
||
|
|
secondsInward: monitorConfig.details.snap_seconds_inward
|
||
|
|
})
|
||
|
|
d.screenshotBuffer = screenShot
|
||
|
|
}
|
||
|
|
sendMail([
|
||
|
|
{
|
||
|
|
filename: d.screenshotName + '.jpg',
|
||
|
|
content: d.screenshotBuffer
|
||
|
|
}
|
||
|
|
])
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
const onMonitorUnexpectedExitForEmail = (monitorConfig) => {
|
||
|
|
if(monitorConfig.details.notify_email === '1' && monitorConfig.details.notify_onUnexpectedExit === '1'){
|
||
|
|
const ffmpegCommand = s.group[monitorConfig.ke].activeMonitors[monitorConfig.mid].ffmpeg
|
||
|
|
const description = ffmpegCommand
|
||
|
|
const subject = lang['Process Unexpected Exit'] + ' : ' + monitorConfig.name
|
||
|
|
const currentTime = new Date()
|
||
|
|
s.knexQuery({
|
||
|
|
action: "select",
|
||
|
|
columns: "mail",
|
||
|
|
table: "Users",
|
||
|
|
where: [
|
||
|
|
['ke','=',monitorConfig.ke],
|
||
|
|
['details','NOT LIKE','%"sub"%'],
|
||
|
|
]
|
||
|
|
},(err,r) => {
|
||
|
|
r = r[0]
|
||
|
|
sendMessage({
|
||
|
|
from: config.mail.from,
|
||
|
|
to: checkEmail(r.mail),
|
||
|
|
subject: subject,
|
||
|
|
html: template.createFramework({
|
||
|
|
title: subject,
|
||
|
|
subtitle: lang['Process Crashed for Monitor'],
|
||
|
|
body: description,
|
||
|
|
footerText: currentTime
|
||
|
|
}),
|
||
|
|
attachments: []
|
||
|
|
}, (error, info) => {
|
||
|
|
if (error) {
|
||
|
|
s.systemLog(lang.MailError,error)
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
s.onTwoFactorAuthCodeNotification(onTwoFactorAuthCodeNotificationForEmail)
|
||
|
|
s.onEventTriggerBeforeFilter(onEventTriggerBeforeFilterForEmail)
|
||
|
|
s.onEventTrigger(onEventTriggerForEmail)
|
||
|
|
s.onFilterEvent(onFilterEventForEmail)
|
||
|
|
s.onDetectorNoTriggerTimeout(onDetectorNoTriggerTimeoutForEmail)
|
||
|
|
s.onMonitorUnexpectedExit(onMonitorUnexpectedExitForEmail)
|
||
|
|
}catch(err){
|
||
|
|
console.log(err)
|
||
|
|
}
|
||
|
|
}
|