Merge pull request #216 from deleolajide/ofmeet-ver-0.1.7

ofmeet plugin version 0.1.7

src/plugins/ofmeet/changelog.html

@@ -49,6 +49,15 @@
     Openfire Meetings Plugin Changelog
 </h1>
 
+<p><b>0.1.7</b> -- May 13th, 2015</p>
+
+<ul>
+    <li>Logs openfire meeting audit events with Openfire security auditor</li>
+    <li>Logs meeting SIP calls via SIP plugin</li>
+    <li>Added support for audio conferencing meetings (no video)</li>
+    <li>Updated Jitsi Videobridge</li>
+</ul>
+
 <p><b>0.1.6</b> -- May 9th, 2015</p>
 
 <ul>

src/plugins/ofmeet/plugin.xml

@@ -5,8 +5,8 @@
     <name>Openfire Meetings</name>
     <description>Provides high quality, scalable video conferences using Jitsi Meet and Jitsi Videobridge</description>
     <author>Ignite Realtime</author>
-    <version>0.1.6</version>
-    <date>05/09/2015</date>
+    <version>0.1.7</version>
+    <date>05/13/2015</date>
     <minServerVersion>3.9.9</minServerVersion>
     
     <adminconsole>

src/plugins/ofmeet/src/api/index.html

@@ -17,6 +17,13 @@
 		var visible = false;
 		var joined = false;
 
+		function urlParam(name)
+		{
+			var results = new RegExp('[\\?&]' + name + '=([^&#]*)').exec(window.location.href);
+			if (!results) { return undefined; }
+			return unescape(results[1] || undefined);
+		};
+
 		$(document).bind('ofmeet.connected', function (event, connection)
 		{
 			console.log("ofmeet connected", connection);
@@ -55,7 +62,7 @@
 		$(document).bind('ofmeet.ready', function ()
 		{
 			console.log("ofmeet.ready");
-			ofmeet.connect();
+			ofmeet.connect(urlParam("novideo"));
 		});
 
 		$(document).ready(function ()

src/plugins/ofmeet/src/app.js

@@ -211,8 +211,20 @@ function obtainAudioAndVideoPermissions(callback) {
             video: stream.getVideoTracks().length
         });
     }
+    
+    var media = ['audio', 'video'];
+    var resolution = config.resolution || '360';
+    
+    if (urlParam("novideo"))
+    {
+    	media = ['audio'];
+    	resolution = null;
+    }
+    
+    console.log("using media", media);
+    
     getUserMediaWithConstraints(
-        ['audio', 'video'],
+        media,
         cb,
         function (error) {
             console.error('failed to obtain audio/video stream - trying audio only', error);
@@ -231,7 +243,7 @@ function obtainAudioAndVideoPermissions(callback) {
                 }
             );
         },
-        config.resolution || '360');
+        resolution);
 }
 
 function maybeDoJoin() {
@@ -285,6 +297,13 @@ function doJoin() {
         roomName, doJoinAfterFocus);
 }
 
+function urlParam(name)
+{
+	var results = new RegExp('[\\?&]' + name + '=([^&#]*)').exec(window.location.href);
+	if (!results) { return undefined; }
+	return unescape(results[1] || undefined);
+};
+
 function doJoinAfterFocus() {
 
     var roomjid;

src/plugins/ofmeet/src/chrome-extension/ofmeet-api.js

@@ -24047,6 +24047,11 @@ var ofmeet = (function(of)
 		VideoLayout.updateLargeVideo(localVideoSrc, 0,
 		    myResourceJid);
 		    
+		if (stream.getVideoTracks().length == 0)
+		{
+			localVideoSelector.css("display", "none");
+		}		    
+
 	    };
 
 	    /**
@@ -31184,7 +31189,7 @@ var ofmeet = (function(of)
 
 	var sessionTerminated = false;
 
-	function connectOpenfire(jid, password) 
+	function connectOpenfire(jid, password, novideo) 
 	{
 	    //console.log("connect", jid, password);
 	    
@@ -31269,7 +31274,7 @@ var ofmeet = (function(of)
 			}
 		    	
 		    	$(document).trigger('ofmeet.connected', [connection]);
-		    });
+		    }, novideo);
 		    
 		    
 		} else if (status === Strophe.Status.CONNFAIL) {
@@ -31293,18 +31298,30 @@ var ofmeet = (function(of)
 	 * We ask for audio and video combined stream in order to get permissions and
 	 * not to ask twice.
 	 */
-	function obtainAudioAndVideoPermissions(callback) {
+	function obtainAudioAndVideoPermissions(callback, novideo) {
 	    // Get AV
 	    var cb = function (stream) {
-		//console.log('got', stream, stream.getAudioTracks().length, stream.getVideoTracks().length);
+		console.log('got', stream, stream.getAudioTracks().length, stream.getVideoTracks().length);
 		callback(stream);
 		trackUsage('localMedia', {
 		    audio: stream.getAudioTracks().length,
 		    video: stream.getVideoTracks().length
 		});
 	    }
+
+	    var media = ['audio', 'video'];
+	    var resolution = config.resolution || '360';
+
+	    if (novideo)
+	    {
+		media = ['audio'];
+		resolution = null;
+	    }
+
+	    console.log("using media", media);
+
 	    getUserMediaWithConstraints(
-		['audio', 'video'],
+		media,
 		cb,
 		function (error) {
 		    console.error('failed to obtain audio/video stream - trying audio only', error);
@@ -31323,7 +31340,7 @@ var ofmeet = (function(of)
 			}
 		    );
 		},
-		config.resolution || '360');
+		resolution);
 	}
 
 	function generateRoomName() {
@@ -32534,7 +32551,9 @@ var ofmeet = (function(of)
 		
 		if (username && password)
 		{
-			headers = {"Authorization": "Basic " + btoa(username + ":" + password)}
+			headers = {"Authorization": "Basic " + btoa(username + ":" + password)};
+			of.username = username;
+			of.password = password;
 		}
 		
 		$.ajax({type: "GET", url: "/ofmeet/config", dataType: "script", headers: headers}).done(function()
@@ -32631,7 +32650,7 @@ var ofmeet = (function(of)
 	    setAudioMuted(!isAudioMuted());
 	}	
 
-	of.connect = function connect(username, password) 
+	of.connect = function connect(novideo) 
 	{	    
 	    RTC = setupRTC();
 	    
@@ -32642,7 +32661,7 @@ var ofmeet = (function(of)
 	    }
 
 	    var jid = config.hosts.domain;
-	    if (username) jid = username +  "@" + config.hosts.domain;
+	    if (of.username) jid = of.username +  "@" + config.hosts.domain;
 
 	    if (config.userName)
 	    {
@@ -32650,7 +32669,7 @@ var ofmeet = (function(of)
 		authenticatedUser = true;
 	    } 
 	    
-	    connectOpenfire(jid, password);	    
+	    connectOpenfire(jid, of.password, novideo);	    
 	}
 
 	of.leaveRoom = function leaveRoom() 

src/plugins/ofmeet/src/inum/index.js

@@ -89,6 +89,10 @@ window.addEventListener("load", function()
 	$(document).bind('inum.cleared', function(event, callId)
 	{
 		console.log("inum.cleared", callId);
+		dialer.setLabel("Call");
+		dialer.setState("inactive");				
+		dialer.call = null
+		stopTone();		
 	});	
 
 	$(document).bind('inum.dialled', function (event, confId, to, callId)

src/plugins/ofmeet/src/java/org/ifsoft/sip/CallSession.java

@@ -143,6 +143,8 @@ public class CallSession
 	public String callId;
 	public String focusJID;
 	public String roomJID;
+	public String username;
+	public long startTimestamp = 0;
 
 	private CallControlComponent callControl;
 

src/plugins/ofmeet/src/java/org/jitsi/jicofo/openfire/JicofoPlugin.java

@@ -57,7 +57,7 @@ public class JicofoPlugin
 			{
 				Log.info("JicofoPlugin - using focus " + focusUserJid + ":" + hostName);
 
-				System.setProperty("org.jitsi.videobridge.ofmeet.audio.mixer", JiveGlobals.getProperty("org.jitsi.videobridge.ofmeet.audio.mixer", "false"));
+				//System.setProperty("org.jitsi.videobridge.ofmeet.audio.mixer", JiveGlobals.getProperty("org.jitsi.videobridge.ofmeet.audio.mixer", "false"));
 
 				System.setProperty("net.java.sip.communicator.service.gui.ALWAYS_TRUST_MODE_ENABLED",  "true");
 				System.setProperty(FocusManager.HOSTNAME_PNAME, hostName);

src/plugins/ofmeet/src/java/org/jitsi/jigasi/openfire/CallControlComponent.java

@@ -25,6 +25,8 @@ import org.jivesoftware.openfire.SessionManager;
 import org.jivesoftware.openfire.XMPPServer;
 import org.jivesoftware.openfire.muc.*;
 import org.jivesoftware.openfire.session.*;
+import org.jivesoftware.database.DbConnectionManager;
+import java.sql.*;
 
 import org.slf4j.*;
 import org.slf4j.Logger;
@@ -159,7 +161,7 @@ public class CallControlComponent extends AbstractComponent
 		sendPacket(iq);
 	}
 
-	private void makeCall(Conference conference, String confJid, String to, String callId)
+	private void makeCall(Conference conference, String confJid, String to, String callId, String username, long startTimestamp)
 	{
 		Log.info("CallControlComponent - makeCall " + confJid + " " + to + " " + callId);
 
@@ -267,6 +269,8 @@ public class CallControlComponent extends AbstractComponent
 
 			cs.jabberRemote = to;
 			cs.jabberLocal = from;
+			cs.username = username;
+			cs.startTimestamp = startTimestamp;
 
 			SipService.sendInvite(cs);
 
@@ -280,11 +284,12 @@ public class CallControlComponent extends AbstractComponent
 	{
 		Log.info("hangupCall " + callId);
 
-		CallSession cs = callSessions.get(callId);
+		CallSession cs = callSessions.remove(callId);
 
 		if (cs != null)
 		{
 			SipService.sendBye(cs);
+			updateCallRecord(cs.startTimestamp, (int)(System.currentTimeMillis() - cs.startTimestamp));
 
 		} else {
 			Log.error("CallControlComponent hangup. cannot fine callid " + callId);
@@ -379,6 +384,12 @@ public class CallControlComponent extends AbstractComponent
 			}
 		}
 
+		if (session != null)
+		{
+			long startTimestamp = System.currentTimeMillis();
+			session.startTimestamp = startTimestamp;
+			createCallRecord("admin", from, confJID, startTimestamp, 0, "received");
+		}
 		return session;
 	}
 
@@ -455,7 +466,12 @@ public class CallControlComponent extends AbstractComponent
 						hangup.addElement("header").addAttribute("name", "caller_id").addAttribute("value", session.jabberRemote);
 						hangup.addElement("header").addAttribute("name", "called_id").addAttribute("value", session.jabberLocal);
 
-						callSessions.remove(callId);
+						CallSession cs = callSessions.remove(callId);
+
+						if (cs != null)
+						{
+							updateCallRecord(cs.startTimestamp, (int)(System.currentTimeMillis() - cs.startTimestamp));
+						}
 					}
 
 					sendPacket(presence);
@@ -548,7 +564,11 @@ public class CallControlComponent extends AbstractComponent
 
 						if (conference != null)
 						{
-							makeCall(conference, confJid, to, callId);
+							String username = iq.getFrom().getNode();
+							long startTimestamp = System.currentTimeMillis();
+
+							makeCall(conference, confJid, to, callId, username, startTimestamp);
+							createCallRecord(username, confJid, to, startTimestamp, 0, "dialed");
 
 						} else {
 							Log.error("CallControlComponent - can't find conference " + confId);
@@ -711,4 +731,70 @@ public class CallControlComponent extends AbstractComponent
 			Log.error("CallControlComponent sendPacket ", e);
 		}
 	}
+
+   private void createCallRecord(String username, String addressFrom, String addressTo, long datetime, int duration, String calltype)
+   {
+		boolean sipPlugin = XMPPServer.getInstance().getPluginManager().getPlugin("sip") != null;
+
+		if (sipPlugin)
+		{
+			Log.info("createCallRecord " + username + " " + addressFrom + " " + addressTo + " " + datetime);
+
+			String sql = "INSERT INTO ofSipPhoneLog (username, addressFrom, addressTo, datetime, duration, calltype) values  (?, ?, ?, ?, ?, ?)";
+
+			Connection con = null;
+			PreparedStatement psmt = null;
+			ResultSet rs = null;
+
+			try {
+				con = DbConnectionManager.getConnection();
+				psmt = con.prepareStatement(sql);
+				psmt.setString(1, username);
+				psmt.setString(2, addressFrom);
+				psmt.setString(3, addressTo);
+				psmt.setLong(4, datetime);
+				psmt.setInt(5, duration);
+				psmt.setString(6, calltype);
+
+				psmt.executeUpdate();
+
+			} catch (SQLException e) {
+				Log.error(e.getMessage(), e);
+			} finally {
+				DbConnectionManager.closeConnection(rs, psmt, con);
+			}
+		}
+    }
+
+	private void updateCallRecord(long datetime, int duration)
+	{
+		boolean sipPlugin = XMPPServer.getInstance().getPluginManager().getPlugin("sip") != null;
+
+		if (sipPlugin)
+		{
+			Log.info("updateCallRecord " + datetime + " " + duration);
+
+			String sql = "UPDATE ofSipPhoneLog SET duration = ? WHERE datetime = ?";
+
+			Connection con = null;
+			PreparedStatement psmt = null;
+
+			try {
+
+				con = DbConnectionManager.getConnection();
+				psmt = con.prepareStatement(sql);
+
+				psmt.setInt(1, duration);
+				psmt.setLong(2, (datetime / 1000));
+				psmt.executeUpdate();
+
+
+			} catch (SQLException e) {
+				Log.error(e.getMessage(), e);
+
+			} finally {
+				DbConnectionManager.closeConnection(psmt, con);
+			}
+		}
+	}
 }

src/plugins/ofmeet/src/java/org/jitsi/videobridge/log/OpenfireEventService.java

@@ -18,6 +18,11 @@ import java.util.concurrent.*;
 import org.slf4j.*;
 import org.slf4j.Logger;
 
+import org.jivesoftware.openfire.security.SecurityAuditManager;
+import org.jivesoftware.util.*;
+import org.xmpp.packet.*;
+
+
 /**
  * Allows logging of {@link org.jitsi.videobridge.log.Event}s using an
  * <tt>Openfire</tt> instance.
@@ -55,7 +60,7 @@ public class OpenfireEventService implements LoggingService
      */
     @SuppressWarnings("unchecked")
     @Override
-    public void logEvent(Event e)
+    public void logEvent(final Event e)
     {
         // The following is a sample JSON message in the format used by InfluxDB
         //  [
@@ -101,7 +106,7 @@ public class OpenfireEventService implements LoggingService
             @Override
             public void run()
             {
-                sendPost(jsonString);
+                sendPost(e.getName(), jsonString);
             }
         });
     }
@@ -111,11 +116,19 @@ public class OpenfireEventService implements LoggingService
      * {@link #url}.
      * @param s the content of the POST request.
      */
-    private void sendPost(final String s)
+    private void sendPost(final String summary, final String detail)
     {
         try
         {
-			Log.info("OpenfireEventService sendPost " + s);
+			String focusUsername = "focus";
+			String focusUserJid = JiveGlobals.getProperty("org.jitsi.videobridge.ofmeet.focus.user.jid");
+
+			if (focusUserJid != null)
+			{
+				focusUsername = (new JID(focusUserJid)).getNode();
+			}
+			Log.info("OpenfireEventService sendPost " + focusUsername + " " + detail);
+			SecurityAuditManager.getInstance().logEvent(focusUsername, summary, detail);
         }
         catch (Exception e)
         {

src/plugins/ofmeet/src/java/org/jivesoftware/openfire/plugin/ofmeet/OfMeetPlugin.java

@@ -43,6 +43,7 @@ import org.jivesoftware.openfire.user.UserManager;
 import org.jivesoftware.openfire.user.UserNotFoundException;
 import org.jivesoftware.openfire.muc.*;
 import org.jivesoftware.openfire.group.*;
+import org.jivesoftware.openfire.security.SecurityAuditManager;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -295,7 +296,7 @@ public class OfMeetPlugin implements Plugin, ClusterEventListener  {
 
 	public void processMeetingPlanner()
 	{
-		Log.info("OfMeet Plugin - processMeetingPlanner");
+		Log.debug("OfMeet Plugin - processMeetingPlanner");
 
 		final Collection<Bookmark> bookmarks = BookmarkManager.getBookmarks();
 
@@ -392,6 +393,7 @@ public class OfMeetPlugin implements Plugin, ClusterEventListener  {
 				variables.put("domain", XMPPServer.getInstance().getServerInfo().getXMPPDomain());
 
 				sendEmail(name, email, title, replaceTokens(template, variables), null);
+				SecurityAuditManager.getInstance().logEvent(user.getUsername(), "sent email - " + title, description);
 			}
 	   }
 	   catch (Exception e) {

src/plugins/ofmeet/src/libs/strophe/strophe.jingle.adapter.js

@@ -675,6 +675,7 @@ function getUserMediaWithConstraints(um, success_callback, failure_callback, res
         }
     }
 
+    if (constraints.video) {
 	    // Check if we are running on Android device
 	    var isAndroid = navigator.userAgent.indexOf('Android') != -1;
 
@@ -724,6 +725,8 @@ function getUserMediaWithConstraints(um, success_callback, failure_callback, res
 		    }
 		    break;
 	    }
+    }
+    
     if (constraints.video)
     {
 	    if (constraints.video.mandatory.minWidth)

src/plugins/ofmeet/src/videolayout.js

@@ -108,8 +108,12 @@ var VideoLayout = (function (my) {
         {
            myResourceJid = Strophe.getResourceFromJid(connection.emuc.myroomjid);
         }
-        VideoLayout.updateLargeVideo(localVideoSrc, 0,
-            myResourceJid);
+        VideoLayout.updateLargeVideo(localVideoSrc, 0,  myResourceJid);
+            
+	if (stream.getVideoTracks().length == 0)
+	{
+		localVideoSelector.css("display", "none");
+	}
 
     };