From 2beffeb1b433aa159ca2c20203d55400ab4d46ef Mon Sep 17 00:00:00 2001
From: Jonathan Bennett <jbennett@incomsystems.biz>
Date: Wed, 12 Jan 2022 22:46:26 -0600
Subject: [PATCH] Add Janus to Cycle view. Remove debug Alert() messages

---
 src/zm_monitor.cpp                      |  6 ++-
 web/skins/classic/views/cycle.php       |  2 +
 web/skins/classic/views/js/cycle.js     | 65 +++++++++++++++++++++++++
 web/skins/classic/views/js/cycle.js.php |  3 +-
 web/skins/classic/views/js/montage.js   |  4 +-
 web/skins/classic/views/js/watch.js     |  4 +-
 6 files changed, 75 insertions(+), 9 deletions(-)

diff --git a/src/zm_monitor.cpp b/src/zm_monitor.cpp
index 4b136e1aa..a612e84c3 100644
--- a/src/zm_monitor.cpp
+++ b/src/zm_monitor.cpp
@@ -1117,12 +1117,13 @@ bool Monitor::connect() {
     //End ONVIF Setup
 #endif
 
-    //janus setup.
+#if HAVE_LIBCURL    //janus setup. Depends on libcurl.
     if (janus_enabled && (path.find("rtsp://") !=  std::string::npos)) {
       if (add_to_janus() != 0) {
         Warning("Failed to add monitor stream to Janus!");
       }
     }
+#endif
 
   } else if (!shared_data->valid) {
     Error("Shared data not initialised by capture daemon for monitor %s", name.c_str());
@@ -3206,10 +3207,11 @@ int Monitor::Close() {
     soap = nullptr;
   }  //End ONVIF
 #endif
-  //Janus Teardown
+#if HAVE_LIBCURL  //Janus Teardown
     if (janus_enabled && (purpose == CAPTURE)) {
       remove_from_janus();
     }
+#endif
 
   packetqueue.clear();
   if (audio_fifo) {
diff --git a/web/skins/classic/views/cycle.php b/web/skins/classic/views/cycle.php
index b9f779c50..279d9bba5 100644
--- a/web/skins/classic/views/cycle.php
+++ b/web/skins/classic/views/cycle.php
@@ -192,4 +192,6 @@ xhtmlHeaders(__FILE__, translate('CycleWatch'));
         </div>
       </div>
     </div>
+<script src="<?php echo cache_bust('js/adapter.min.js') ?>"></script>
+<script src="<?php echo cache_bust('js/janus.js') ?>"></script>
 <?php xhtmlFooter() ?>
diff --git a/web/skins/classic/views/js/cycle.js b/web/skins/classic/views/js/cycle.js
index 767fad475..401e36760 100644
--- a/web/skins/classic/views/js/cycle.js
+++ b/web/skins/classic/views/js/cycle.js
@@ -1,3 +1,6 @@
+var server;
+var janus = null;
+var streaming2;
 var intervalId;
 var pauseBtn = $j('#pauseBtn');
 var playBtn = $j('#playBtn');
@@ -46,6 +49,68 @@ function initCycle() {
   intervalId = setInterval(nextCycleView, cycleRefreshTimeout);
   var scale = $j('#scale').val();
   if ( scale == '0' || scale == 'auto' ) changeScale();
+
+  if (monitorData[monIdx].janusEnabled) {
+    server = "http://" + window.location.hostname + ":8088/janus";
+    opaqueId = "streamingtest-"+Janus.randomString(12);
+    Janus.init({debug: "all", callback: function() {
+      janus = new Janus({
+        server: server,
+        success: function() {
+          janus.attach({
+            plugin: "janus.plugin.streaming",
+            opaqueId: opaqueId,
+            success: function(pluginHandle) {
+              streaming2 = pluginHandle;
+              var body = { "request": "watch", "id":monitorData[monIdx].id };
+              streaming2.send({"message": body});
+            },
+            error: function(error) {
+              Janus.error("  -- Error attaching plugin... ", error);
+            },
+            onmessage: function(msg, jsep) {
+              Janus.debug(" ::: Got a message :::");
+              Janus.debug(msg);
+              var result = msg["result"];
+              if(result !== null && result !== undefined) {
+                if(result["status"] !== undefined && result["status"] !== null) {
+                  var status = result["status"];
+                }
+              } else if(msg["error"] !== undefined && msg["error"] !== null) {
+                Janus.debug(msg["error"]);
+                return;
+              }
+              if(jsep !== undefined && jsep !== null) {
+                Janus.debug("Handling SDP as well...");
+                Janus.debug(jsep);
+                // Offer from the plugin, let's answer
+                streaming2.createAnswer({
+                  jsep: jsep,
+                  // We want recvonly audio/video and, if negotiated, datachannels
+                  media: { audioSend: false, videoSend: false, data: true },
+                  success: function(jsep) {
+                    Janus.debug("Got SDP!");
+                    Janus.debug(jsep);
+                    var body = { "request": "start"};
+                    streaming2.send({"message": body, "jsep": jsep});
+                  },
+                  error: function(error) {
+                    Janus.error("WebRTC error:", error);
+                  }
+                });
+              }
+            }, //onmessage function
+            onremotestream: function(stream) {
+              Janus.debug(" ::: Got a remote track :::");
+              Janus.debug(stream);
+              Janus.attachMediaStream(document.getElementById("liveStream" + monitorData[monIdx].id), stream);
+              document.getElementById("liveStream" + monitorData[monIdx].id).play();
+            }
+          });// attach
+        } //Success functio
+      }); //new Janus
+    }}); //janus.init callback
+  } //if janus
 }
 
 function changeSize() {
diff --git a/web/skins/classic/views/js/cycle.js.php b/web/skins/classic/views/js/cycle.js.php
index 7bcd4497c..201deea76 100644
--- a/web/skins/classic/views/js/cycle.js.php
+++ b/web/skins/classic/views/js/cycle.js.php
@@ -20,7 +20,8 @@ monitorData[monitorData.length] = {
   'url': '<?php echo $monitor->UrlToIndex() ?>',
   'onclick': function(){window.location.assign( '?view=watch&mid=<?php echo $monitor->Id() ?>' );},
   'type': '<?php echo $monitor->Type() ?>',
-  'refresh': '<?php echo $monitor->Refresh() ?>'
+  'refresh': '<?php echo $monitor->Refresh() ?>',
+  'janusEnabled': <?php echo $monitor->JanusEnabled() ?>
 };
 <?php
 } // end foreach monitor
diff --git a/web/skins/classic/views/js/montage.js b/web/skins/classic/views/js/montage.js
index cfa831354..d02fb63f8 100644
--- a/web/skins/classic/views/js/montage.js
+++ b/web/skins/classic/views/js/montage.js
@@ -373,8 +373,7 @@ function attachVideo(janus, i) {
               var status = result["status"];
             }
           } else if(msg["error"] !== undefined && msg["error"] !== null) {
-            alert(msg["error"]);
-            stopStream();
+            Janus.error(msg["error"]);
             return;
           }
           if(jsep !== undefined && jsep !== null) {
@@ -393,7 +392,6 @@ function attachVideo(janus, i) {
               },
               error: function(error) {
                 Janus.error("WebRTC error:", error);
-                alert("WebRTC error... " + JSON.stringify(error));
               }
             });
           }
diff --git a/web/skins/classic/views/js/watch.js b/web/skins/classic/views/js/watch.js
index 21154d1f6..f3ea6385f 100644
--- a/web/skins/classic/views/js/watch.js
+++ b/web/skins/classic/views/js/watch.js
@@ -937,8 +937,7 @@ function initPage() {
                   var status = result["status"];
                 }
               } else if(msg["error"] !== undefined && msg["error"] !== null) {
-                alert(msg["error"]);
-                stopStream();
+                Janus.error(msg["error"]);
                 return;
               }
               if(jsep !== undefined && jsep !== null) {
@@ -957,7 +956,6 @@ function initPage() {
                   },
                   error: function(error) {
                     Janus.error("WebRTC error:", error);
-                    alert("WebRTC error... " + JSON.stringify(error));
                   }
                 });
               }