From 971ecc513a2e7c5c74339d232e4134b1edeb4aeb Mon Sep 17 00:00:00 2001
From: Moe <gitlab@m03.ca>
Date: Thu, 2 Aug 2018 22:58:28 -0700
Subject: [PATCH] Preparation for ONVIF Events (Profile T cameras only)

---
 camera.js                        | 71 +++++++++++++++++++++++++++++++-
 languages/en_CA.json             |  2 +
 package.json                     |  1 +
 web/pages/blocks/monitoredit.ejs | 13 ++++++
 4 files changed, 85 insertions(+), 2 deletions(-)

diff --git a/camera.js b/camera.js
index 4881a8dc..b0396662 100644
--- a/camera.js
+++ b/camera.js
@@ -27,7 +27,6 @@ try{
 }catch(err){
     staticFFmpeg = false;
     console.log('No Static FFmpeg. Continuing.')
-    //no static ffmpeg
 }
 var os = require('os');
 var URL = require('url');
@@ -54,6 +53,7 @@ var jsonfile = require("jsonfile");
 var connectionTester = require('connection-tester');
 var events = require('events');
 var onvif = require('node-onvif');
+var onvifHawk = require('onvif-nvt');
 var knex = require('knex');
 var Mp4Frag = require('mp4frag');
 var P2P = require('pipe2pam');
@@ -914,6 +914,8 @@ s.init=function(x,e,k,fn){
             //build a complete url from pieces
             e.authd='';
             if(e.details.muser&&e.details.muser!==''&&e.host.indexOf('@')===-1) {
+                e.username = e.details.muser
+                e.password = e.details.mpass
                 e.authd=e.details.muser+':'+e.details.mpass+'@';
             }
             if(e.port==80&&e.details.port_force!=='1'){e.porty=''}else{e.porty=':'+e.port}
@@ -2428,7 +2430,10 @@ s.camera=function(x,e,cn,tx){
             var monitorConfig = cn
             URLobject=URL.parse(e)
             if(monitorConfig.details.control_url_method === 'ONVIF' && monitorConfig.details.control_base_url === ''){
-                URLobject.port = 8000
+                if(monitorConfig.details.onvif_port === ''){
+                    monitorConfig.details.onvif_port = 8000
+                }
+                URLobject.port = monitorConfig.details.onvif_port
             }else if(!URLobject.port){
                 URLobject.port = 80
             }
@@ -2831,6 +2836,68 @@ s.camera=function(x,e,cn,tx){
                 }
             }
             setStreamDir()
+            //try to create HawkEye Onvif Object
+            if(e.details.is_onvif === '1'){
+                console.log('onvifHawk',e.hosty, e.porty.replace(':',''), e.username, e.password)
+                var doOnvifHawk = true
+                var errorCount = 0
+                var hawkFail = function(msg,callback){
+                    ++errorCount
+                    if(errorCount > 2){
+                        callback()
+                        s.log(e,msg);
+                    }
+                }
+                var createHawkOnvif = function(){
+                    if(doOnvifHawk === false){
+                        return false
+                    }
+                    if(!e.details.onvif_port || e.details.onvif_port === ''){
+                        e.details.onvif_port = 8000
+                    }
+                    onvifHawk.connect(e.hosty, e.details.onvif_port, e.username, e.password).then(function(results){
+                        var camera = results
+                        // if the camera supports events, the module will already be loaded.
+                        if (camera.events) {
+                            camera.events.soap.username = e.username
+                            camera.events.soap.password = e.password
+                            camera.events.on('messages', messages => {
+                                console.log('Messages Received:', (typeof messages))
+                                s.log(e,{type:lang.ONVIFEventsNotAvailable,msg:{msg:lang.ONVIFnotCompliantProfileT}});
+                            })
+                            camera.events.on('messages:error', error => {
+                                if(error.body.indexOf('anonymous') > -1){
+                                    hawkFail({type:lang.ONVIFEventsNotAvailable,msg:{msg:lang.ONVIFnotCompliantProfileT}},function(){
+                                        camera.events.stopPull()
+                                    })
+                                }
+                            })
+                            // start a pull event loop
+                            setTimeout(function(){
+                                camera.events.startPull()
+                            },3000)
+                            // call stopPull() to end the event loop
+                            // camera.events.stopPull()
+                            s.group[e.ke].mon[e.id].HawkEyeOnvifConnection = camera
+                        }
+                        if(s.group[e.ke].mon[e.id].HawkEyeOnvifConnection){
+                            console.log('Found')
+                        }else{
+                            console.log('Not Found')
+                        }
+                    }).catch(function(err){
+                        console.log('Error Connecting')
+                        console.log(err.code)
+                        hawkFail({type:lang.ONVIFEventsNotAvailable,msg:{msg:lang.ONVIFnotCompliantProfileT}},function(){
+                            doOnvifHawk = false
+                        })
+                        setTimeout(function(){
+                            createHawkOnvif()
+                        },3000)
+                    })
+                }
+                createHawkOnvif()
+            }
             //set up fatal error handler
             if(e.details.fatal_max===''){
                 e.details.fatal_max = 10
diff --git a/languages/en_CA.json b/languages/en_CA.json
index 0ccc6e05..28155771 100644
--- a/languages/en_CA.json
+++ b/languages/en_CA.json
@@ -156,6 +156,8 @@
    "FFmpegTip": "FFprobe is a simple multimedia streams analyzer. You can use it to output all kinds of information about an input including duration, frame rate, frame size, etc.",
    "Complete Stream URL": "Complete Stream URL",
    "ONVIF Scanner": "ONVIF Scanner",
+   "ONVIFEventsNotAvailable": "ONVIF Events not Available",
+   "ONVIFnotCompliantProfileT": "Camera is not ONVIF Profile T Compliant",
    "Scan Settings": "Scan Settings",
    "ONVIFnote": "Discover ONVIF devices on networks outside your own or leave it blank to scan your current network. <br>Username and Password can be left blank.",
    "Range or Single": "Range or Single",
diff --git a/package.json b/package.json
index 5f766674..86d398b7 100644
--- a/package.json
+++ b/package.json
@@ -35,6 +35,7 @@
     "pipe2pam": "^0.6.2",
     "nodemailer": "^4.0.1",
     "node-onvif": "^0.1.4",
+    "onvif-nvt": "0.2.8",
     "path": "^0.12.7",
     "request": "^2.79.0",
     "socket.io": "^1.7.1",
diff --git a/web/pages/blocks/monitoredit.ejs b/web/pages/blocks/monitoredit.ejs
index 11d9520f..86b7c294 100644
--- a/web/pages/blocks/monitoredit.ejs
+++ b/web/pages/blocks/monitoredit.ejs
@@ -180,6 +180,19 @@
                     </select></div>
                 </label>
               </div>
+              <div class="form-group">
+                <label><div><span><%-lang['ONVIF']%></span></div>
+                    <div><select class="form-control" detail="is_onvif" selector="h_onvif">
+                        <option value="0" selected><%-lang.No%></option>
+                        <option value="1"><%-lang.Yes%></option>
+                    </select></div>
+                </label>
+              </div>
+              <div class="form-group h_onvif_input h_onvif_1">
+                <label><div><span><%-lang['ONVIF Port']%></span></div>
+                    <div><input class="form-control" detail="onvif_port" placeholder="8000" type="number"></div>
+                </label>
+              </div>
             </div>
 <!--     END of Connection     -->
 <!--     START of Input     -->