Munin graphs for Nextcloud

1 files changed, 156 insertions, 216 deletions

diff --git a/nextcloud_munin.php b/nextcloud_munin.php
index f18468b..8675235 100644
--- a/nextcloud_munin.php
+++ b/nextcloud_munin.php
@@ -1,11 +1,8 @@
-
-
 #!/usr/bin/php
 <?php
 
-
 $set['host'] = getenv('host');
-//$set['occ_user'] = getenv('occ_user');
+//$set['occ_user'] = getenv('occ_user');	//If "serverinfo" would be a part of occ commands...
 //$set['occ_path'] = getenv('occ_path');
 $set['db_user'] = getenv('db_user');
 $set['db_pass'] = getenv('db_pass');
@@ -13,8 +10,9 @@ $set['db_db'] = getenv('db_db');
 $set['db_host'] = getenv('db_host');
 $set['db_prefix'] = getenv('db_prefix');
 $set['diff_minutes'] = intval(getenv('diff_minutes'));
-/*
-$set['host'] = "felho.example.com";
+$set['nxt_plugins'] = explode(" ", getenv('nxt_plugins'));
+/*	//For debugging
+$set['host'] = "cloud.example.com";			
 $set['db_user'] = "root";
 $set['db_pass'] = "";
 $set['db_db']	= "Nextcloud_db";
@@ -22,264 +20,206 @@ $set['db_host'] = "localhost";
 $set['db_prefix'] = "oc_";
 $set['diff_minutes'] = 5;   // --> 5 minutes
 */
-$replace_chars = array("\"","\$","@","^","`",",","|","%",";",".","~","(",")","/","\\","{","}",":","?","[","]","=","+","#","!","-",);    // Special chars replace
-$time_req = time() - 60*$set['diff_minutes'];
-$dta = array();
-$dtv = array();
-
+$replace_chars = array("\"","\$","@","^","`",",","|","%",";",".","~","(",")","/","\\","{","}",":","?","[","]","=","+","#","!","-",);    // Special chars to replace
+$time_req = time()-60*$set['diff_minutes'];
+
+//--------------------------------------------------------------------------------------------------------------------------------------//
+	function  prepare_auth_stat($l){
+		global $set, $time_req, $replace_chars;
+		$ret = array();
+		$ret['g_name'] = "nxt_act_users_".str_replace($replace_chars, "_", $set['host'] );
+		$ret['g_host'] = $set['host'];
+		$ret['g_title'] = "Nextcloud Active Users";
+		$ret['g_vlabel'] = "Users";
+		$ret['g_category'] = "Nxt_actv_users";
+		$ret['g_info'] = "nextcloud_active_users";
+		$ret['g_order'] = "nxt_users_all nxt_users_web nxt_users_app";
+
+		// skeleton for returning
+		foreach(array('users_all', 'users_web', 'users_app', 'users_win', 'users_linux', 'users_oos') as $key => $val){	
+			$ret['data'][$val]['value'] = 0;
+			$ret['data'][$val]['draw'] =  "LINE1.2";
+			$ret['data'][$val]['type'] = "GAUGE";
+		}
+		$ret['data']['users_all']['label'] = "Total";
+		$ret['data']['users_all']['info'] = "Total clients";
+		$ret['data']['users_web']['label'] = "By Web";
+		$ret['data']['users_web']['info'] = "Clients logged in by webpage.";
+		$ret['data']['users_app']['label'] = "By App";
+		$ret['data']['users_app']['info'] = "Connected clients with an app.";
+		$ret['data']['users_win']['label'] = "Windows";
+		$ret['data']['users_win']['info'] = "Clients on windows";
+		$ret['data']['users_linux']['label'] = "Linux";
+		$ret['data']['users_linux']['info'] = "Clients on Linux";
+		$ret['data']['users_oos']['label'] = "Other OS";
+		$ret['data']['users_oos']['info'] = "Clients on other OS";
 
-	function  get_auth_stat($l) {
-		global $set, $time_req;
-		$ret = array('all' => 0,'app' => 0, 'web' => 0, 'windows' => 0, 'linux' => 0, 'other_os' => 0, 'firefox' => 0, 'chrome' => 0, 'safari' => 0, 'other_bw' => 0 );
 		mysqli_set_charset($l, "utf8");
-		$r = mysqli_query($l," SELECT * FROM ".$set['db_db'].".".$set['db_prefix']."authtoken WHERE `last_activity` >= ".$time_req." ORDER BY `last_activity` DESC ");
-
+		$r = mysqli_query($l, "SELECT * FROM ".mysqli_real_escape($l, $set['db_db']).".".mysqli_real_escape($l, $set['db_prefix'])."authtoken 
+								WHERE `last_activity` >= ".mysqli_real_escape($l, $time_req)." 
+								ORDER BY `last_activity` DESC ;"
+							);
 		while ($row = mysqli_fetch_array($r, MYSQLI_ASSOC)) {
-	        	if($row['type'] == 0) {		//web login
- 				if(strpos($row['name'], "mirall" ) !== false){	//without token on desktop
-					$ret['app'] ++;
-				} else {
-					$ret['web'] ++; 
+			if($row['type'] == 0) {									//with own password (usually on web browser)
+ 				if(strpos($row['name'], "mirall" ) !== false){		//with own password on (mirall) desktop client
+					$ret['data']['users_app']['value']++;
+				} else {											//password over web
+					$ret['data']['users_web']['value']++;		
 				}
-			} else if($row['type'] == 1) { 	//with application
-				$ret['app'] ++; 
+			} else if($row['type'] == 1) { 							//with token --> (usually on app)
+				$ret['data']['users_app']['value']++;
 			}
-			$ret['all'] ++; 		// everybody
+			$ret['data']['users_all']['value']++; 					//everybody
 			
-
-			if(stripos($row['name'], 'windows') !== false){
-				$ret['windows']++;
-			} else if(stripos($row['name'], 'linux') !== false){
-				$ret['linux']++;
-			} else {
-				$ret['other_os']++;
+			if(stripos($row['name'], 'windows') !== false){			//If "windows" in User Agent
+				$ret['data']['users_win']['value']++;
+			} else if(stripos($row['name'], 'linux') !== false){	//If "Linux" in User Agent
+				$ret['data']['users_linux']['value']++;
+			} else {												//Other OS
+				$ret['data']['users_oos']['value']++;
 			}
-
-			if(stripos($row['name'], 'firefox') !== false){
-                                $ret['firefox']++;
-                        } else if(stripos($row['name'], 'chrome') !== false){	//Chrome is using Safari motor also
-                                $ret['chrome']++;
-                        } else if(stripos($row['name'], 'safari') !== false){
-                                $ret['safari']++;
-                        } else {
-                                $ret['other_bw']++;
-                        }
-
 		}
 		@mysqli_free_result($r);
-	return $ret;
+		return $ret;
 	}
 
 
+//--------------------------------------------------------------------------------------------------------------------------------------//
+	function  prepare_event_stat($l){
+		global $set, $time_req, $replace_chars;
+		$d_pfx = "evt_";
+		$ret['g_name'] = "nxt_events_".str_replace($replace_chars, "_", $set['host'] );
+		$ret['g_host'] = $set['host'];
+		$ret['g_title'] = "Nextcloud Activity";
+		$ret['g_vlabel'] = "Events";
+		$ret['g_category'] = "Nxt_events";
+		$ret['g_info'] = "nextcloud_events";
+		$ret['g_order'] = "nxt_evt_all nxt_evt_files nxt_evt_share";	
+			// skeleton for returning
+		foreach(array_merge(array('all', 'files', 'share', 'pub', 'comm', 'cal', 'other'), $set['nxt_plugins']) as $key => $val){	
+			$ret['data'][$d_pfx.$val]['value'] = 0;
+			$ret['data'][$d_pfx.$val]['draw'] =  "LINE1.2";
+			$ret['data'][$d_pfx.$val]['type'] = "GAUGE";
+		}
+		$ret['data'][$d_pfx.'all']['label'] = "Total events";
+		$ret['data'][$d_pfx.'all']['info'] = "Total Actions generated";
+		$ret['data'][$d_pfx.'files']['label'] = "File actions";
+		$ret['data'][$d_pfx.'files']['info'] = "Files operations";				
+		$ret['data'][$d_pfx.'share']['label'] = "Saring actions";
+		$ret['data'][$d_pfx.'share']['info'] = "Sharing by groups or users inside";
+		$ret['data'][$d_pfx.'pub']['label'] = "Pub.link download";
+		$ret['data'][$d_pfx.'pub']['info'] = "Public Link downloaded";
+		$ret['data'][$d_pfx.'comm']['label'] = "Comments";
+		$ret['data'][$d_pfx.'comm']['info'] = "Comments";
+		$ret['data'][$d_pfx.'cal']['label'] = "Calendar actions";
+		$ret['data'][$d_pfx.'cal']['info'] = "Calendar actions/operations";
+		$ret['data'][$d_pfx.'other']['label'] = "Other actions";
+		$ret['data'][$d_pfx.'other']['info'] = "Other actions";
+		//------------ Applications enabled ------------/
+		$ret['data'][$d_pfx.'talk']['label'] = "Talk events";
+		$ret['data'][$d_pfx.'talk']['info'] = "Nextcloud Talk events";
+		$ret['data'][$d_pfx.'antivirus']['label'] = "Virus detect";
+		$ret['data'][$d_pfx.'antivirus']['info'] = "Virus Detections by files_antivirus";
 
-       function  get_activity_stat($l) {
-                global $set, $time_req;
-                $ret = array('all' => 0, 'file' =>0, 'share' => 0, 'calendar' => 0, 'comment' => 0, 'public' => 0, 'settings' => 0, 'virus' => 0, 'talk' => 0);
-                mysqli_set_charset($l, "utf8");
-                $q = " SELECT * FROM ".$set['db_db'].".".$set['db_prefix']."activity
-                       WHERE `timestamp` >= ".$time_req." 
-                        AND ( ((`type` LIKE '%file%' AND `subject` NOT LIKE '%by%') 
-                            OR (`type` LIKE '%shared%' AND `subject` NOT LIKE '%self%') ) 
-                           OR ( `type` NOT LIKE '%file%' AND `type`  NOT LIKE '%shared%') )
-                      ORDER BY `timestamp` DESC ;
-                     ";
-		$r = mysqli_query($l,$q);
-                while ($row = mysqli_fetch_array($r, MYSQLI_ASSOC)) {
+		mysqli_set_charset($l, "utf8");
+		$r = mysqli_query($l, " SELECT * FROM ".mysqli_real_escape_string($l, $set['db_db']).".".mysqli_real_escape_string($l, $set['db_prefix'])."activity
+								WHERE `timestamp` >= ".mysqli_real_escape_string($l, $time_req)." 
+									AND ( ((`type` LIKE '%file%' AND `subject` NOT LIKE '%by%') 
+										OR (`type` LIKE '%shared%' AND `subject` NOT LIKE '%self%') ) 
+									OR ( `type` NOT LIKE '%file%' AND `type`  NOT LIKE '%shared%') )
+								ORDER BY `timestamp` DESC ;"
+							);
+		while ($row = mysqli_fetch_array($r, MYSQLI_ASSOC)) {
 			if(stripos($row['type'], 'file_') !== false ){
-				$ret['file'] ++; 
-			}
-			if(stripos($row['type'], 'shared') !== false ){
-                                $ret['share'] ++;
-                        } 
-			if(stripos($row['type'], 'calendar') !== false ){
-                                $ret['calendar'] ++;
-                        } 
-			if(stripos($row['type'], 'virus_detected') !== false ){
-				if(!isset($ret['virus'])){ $ret['virus'] = 0; }
-                                $ret['virus'] ++;
-                        } 
-			if(stripos($row['type'], 'comments') !== false ){
-                                $ret['comment'] ++;
-                        }
-			if(stripos($row['type'], 'public_link') !== false ){
-                                $ret['public'] ++;
-                        }
-                        if(stripos($row['type'], 'settings') !== false ){
-                                $ret['settings'] ++;
-                        }
+				$ret['data'][$d_pfx.'files']['value']++;
+
+			} else if(stripos($row['type'], 'shared') !== false ){
+				$ret['data'][$d_pfx.'share']['value']++;
+				
+			} else if(stripos($row['type'], 'public_link') !== false ){
+				$ret['data'][$d_pfx.'pub']['value']++;
+
+			} else if(stripos($row['type'], 'comments') !== false ){
+				$ret['data'][$d_pfx.'comm']['value']++;
+
+			} else if(stripos($row['type'], 'calendar') !== false ){
+				$ret['data'][$d_pfx.'cal']['value']++;
+
+			} else if(stripos($row['type'], 'spreed') !== false ){			//nextcloud_talk app
+				$ret['data'][$d_pfx.'talk']['value']++;
+
+			} else if(stripos($row['type'], 'virus_detected') !== false ){ // files_antivirus app
+				$ret['data'][$d_pfx.'antivirus']['value']++;
+			} else {
+				$ret['data'][$d_pfx.'other']['value']++;
+			} 
+			$ret['data'][$d_pfx.'all']['value']++;
+		}
+		@mysqli_free_result($r);
+		return $ret;
+    }
 
-                        if(stripos($row['type'], 'spreed') !== false ){	//Nextcloud talk
-				if(!isset($ret['talk'])){$ret['talk'] = 0; }
-                                $ret['talk'] ++;
-                        }
-			$ret['all']++;
-                }
-                @mysqli_free_result($r);
-        return $ret;
-        }
 
+//--------------------------------------------------------------------------------------------------------------------------------------//
 
-	function print_headers($inp){
+	function print_config($inp){
 		global $replace_chars;
 		$cf  = "multigraph ".$inp['g_name']."\n";
-	        $cf .= "host_name ".$inp['g_host']."\n";
-	        $cf .= "graph_title ".$inp['g_title']."\n";
-	        $cf .= "graph_args --base 1000 \n";
-	        $cf .= "graph_vlabel ".$inp['g_vlabel']."\n";
-	        $cf .= "graph_category ".$inp['g_category']."\n";
-	        $cf .= "graph_info ".$inp['g_info']."\n";
+		$cf .= "host_name ".$inp['g_host']."\n";
+		$cf .= "graph_title ".$inp['g_title']."\n";
+		$cf .= "graph_args --base 1000 \n";
+		$cf .= "graph_vlabel ".$inp['g_vlabel']."\n";
+		$cf .= "graph_category ".$inp['g_category']."\n";
+		$cf .= "graph_info ".$inp['g_info']."\n";
 		$cf .= "graph_order ".$inp['g_order']."\n";
 
 		foreach($inp['data'] as $key => $val){
-	        	$cf .= "nxt_".str_replace($replace_chars, "_", $key).".label ".$val['label']." \n";
+			$cf .= "nxt_".str_replace($replace_chars, "_", $key).".label ".$val['label']." \n";
 			$cf .= "nxt_".str_replace($replace_chars, "_", $key).".draw ".$val['draw']." \n";
 			$cf .= "nxt_".str_replace($replace_chars, "_", $key).".info ".$val['info']." \n";
 			$cf .= "nxt_".str_replace($replace_chars, "_", $key).".type ".$val['type']." \n";
 		}
 		$cf .= "\n";
-		echo iconv("UTF-8", "ISO-8859-2", $cf).PHP_EOL;
+		//echo iconv("UTF-8", "ISO-8859-2", $cf).PHP_EOL;	//If you want Hungarian chars
+		echo $cf.PHP_EOL;
 	}
 
 
 	function print_values($inp){
 		global $replace_chars;
 		if(isset($inp['data'])){
-	                $cf  = "multigraph ".$inp['g_name']."\n";
-        		foreach($inp['data'] as $key => $val){
-	        		$cf .= "nxt_".str_replace($replace_chars, "_", $key).".value ".$val['value']."\n";
-		        }
+			$cf  = "multigraph ".$inp['g_name']."\n";
+			foreach($inp['data'] as $key => $val){
+				$cf .= "nxt_".str_replace($replace_chars, "_", $key).".value ".$val['value']."\n";
+			}
 			$cf .= "\n";
-        		echo iconv("UTF-8", "ISO-8859-2", $cf).PHP_EOL;
+			//echo iconv("UTF-8", "ISO-8859-2", $cf).PHP_EOL; 	//If you want Hungarian chars
+			echo $cf.PHP_EOL;
 		}
 	}
 
 
 
-
+//--------------------------------------------------------------------------------------------------------------------------------------//
 if (function_exists('mysqli_connect') and PHP_MAJOR_VERSION >= 7 ) { //mysqli && php > 7.0   needed
 
 	$l = mysqli_connect($set['db_host'], $set['db_user'], $set['db_pass'], $set['db_db']);
 	if(!$l){
-		//error
+		echo "\n MYSQL error. \n";
 	} else {
-		$auth = get_auth_stat($l);
-		$actv = get_activity_stat($l);
+		$auth_stat = prepare_auth_stat($l);
+		$actv_stat = prepare_event_stat($l);
+		if (isset($argv[1]) and $argv[1] == "config"){
+			print_config($auth_stat);
+			print_config($actv_stat);
+		} else {
+			print_values($auth_stat);
+			print_values($actv_stat);
+		}
 		@mysqli_close($l);
 	}
 }
 
-$dta['g_name'] = "nxt_active_users_".str_replace($replace_chars, "_", $set['host'] );
-$dta['g_host'] = $set['host'];
-$dta['g_title'] = "Nextcloud Users";
-$dta['g_vlabel'] = "Users";
-$dta['g_category'] = "Nxt_users";
-$dta['g_info'] = "nextcloud_active_users";
-$dta['g_order'] = "nxt_users_all nxt_users_web nxt_users_app";
-
-$dta['data']['users_all']['value'] = $auth['all'];
-$dta['data']['users_all']['label'] = "Total";
-$dta['data']['users_all']['draw'] =  "LINE1.2";
-$dta['data']['users_all']['info'] = "Total client";
-$dta['data']['users_all']['type'] = "GAUGE";
-
-$dta['data']['users_web']['value'] = $auth['web'];
-$dta['data']['users_web']['label'] = "By Web";
-$dta['data']['users_web']['draw'] =  "LINE1.2";
-$dta['data']['users_web']['info'] = "Webpage clients";
-$dta['data']['users_web']['type'] = "GAUGE";
-
-$dta['data']['users_app']['value'] = $auth['app'];
-$dta['data']['users_app']['label'] = "By APP";
-$dta['data']['users_app']['draw'] =  "LINE1.2";
-$dta['data']['users_app']['info'] = "Connected clients by app.";
-$dta['data']['users_app']['type'] = "GAUGE";
-
-$dta['data']['users_win']['value'] = $auth['windows'];
-$dta['data']['users_win']['label'] = "Windows";
-$dta['data']['users_win']['draw'] =  "LINE1.2";
-$dta['data']['users_win']['info'] = "Total client";
-$dta['data']['users_win']['type'] = "GAUGE";
-
-$dta['data']['users_linux']['value'] = $auth['linux'];
-$dta['data']['users_linux']['label'] = "Linux";
-$dta['data']['users_linux']['draw'] =  "LINE1.2";
-$dta['data']['users_linux']['info'] = "Webpage clients";
-$dta['data']['users_linux']['type'] = "GAUGE";
-
-$dta['data']['users_oos']['value'] = $auth['other_os'];
-$dta['data']['users_oos']['label'] = "Other OS";
-$dta['data']['users_oos']['draw'] =  "LINE1.2";
-$dta['data']['users_oos']['info'] = "Connected clients by app.";
-$dta['data']['users_oos']['type'] = "GAUGE";
-
-
-
-
-$dtb['g_name'] = "nxt_events_".str_replace($replace_chars, "_", $set['host'] );
-$dtb['g_host'] = $set['host'];
-$dtb['g_title'] = "Nextcloud Users Activity";
-$dtb['g_vlabel'] = "Events";
-$dtb['g_category'] = "Nxt_events";
-$dtb['g_info'] = "nextcloud_events";
-$dtb['g_order'] = "nxt_act_all nxt_act_files nxt_act_share";
-
-$dtb['data']['act_all']['value'] = $actv['all'];
-$dtb['data']['act_all']['label'] = "Total events";
-$dtb['data']['act_all']['draw'] =  "LINE1.2";
-$dtb['data']['act_all']['info'] = "Total client";
-$dtb['data']['act_all']['type'] = "GAUGE";
-$dtb['data']['act_files']['value'] = $actv['file'];
-$dtb['data']['act_files']['label'] = "File operations";
-$dtb['data']['act_files']['draw'] =  "LINE1.2";
-$dtb['data']['act_files']['info'] = "Webpage clients";
-$dtb['data']['act_files']['type'] = "GAUGE";
-$dtb['data']['act_share']['value'] = $actv['share'];
-$dtb['data']['act_share']['label'] = "Saring events";
-$dtb['data']['act_share']['draw'] =  "LINE1.2";
-$dtb['data']['act_share']['info'] = "Sharing to groups or users";
-$dtb['data']['act_share']['type'] = "GAUGE";
-$dtb['data']['act_pub']['value'] = $actv['public'];
-$dtb['data']['act_pub']['label'] = "Pub.link download";
-$dtb['data']['act_pub']['draw'] =  "LINE1.2";
-$dtb['data']['act_pub']['info'] = "Sharing by public links";
-$dtb['data']['act_pub']['type'] = "GAUGE";
-$dtb['data']['act_comm']['value'] = $actv['comment'];
-$dtb['data']['act_comm']['label'] = "Comments";
-$dtb['data']['act_comm']['draw'] =  "LINE1.2";
-$dtb['data']['act_comm']['info'] = "Comments";
-$dtb['data']['act_comm']['type'] = "GAUGE";
-$dtb['data']['act_talk']['value'] = $actv['talk'];
-$dtb['data']['act_talk']['label'] = "Talk events";
-$dtb['data']['act_talk']['draw'] =  "LINE1.2";
-$dtb['data']['act_talk']['info'] = "settings Change";
-$dtb['data']['act_talk']['type'] = "GAUGE";
-$dtb['data']['act_cal']['value'] = $actv['calendar'];
-$dtb['data']['act_cal']['label'] = "Calendar operations";
-$dtb['data']['act_cal']['draw'] =  "LINE1.2";
-$dtb['data']['act_cal']['info'] = "Calendar.";
-$dtb['data']['act_cal']['type'] = "GAUGE";
-$dtb['data']['act_virus']['value'] = $actv['virus'];
-$dtb['data']['act_virus']['label'] = "Virus detection";
-$dtb['data']['act_virus']['draw'] =  "LINE1.2";
-$dtb['data']['act_virus']['info'] = "Virus Detected";
-$dtb['data']['act_virus']['type'] = "GAUGE";
-$dtb['data']['act_setts']['value'] = $actv['settings'];
-$dtb['data']['act_setts']['label'] = "Change Settings";
-$dtb['data']['act_setts']['draw'] =  "LINE1.2";
-$dtb['data']['act_setts']['info'] = "settings Change";
-$dtb['data']['act_setts']['type'] = "GAUGE";
-
-
-
-
-
-if (isset($argv[1]) and $argv[1] == "config"){
-	print_headers($dta);
-	print_headers($dtb);
-} else {
-        print_values($dta);
-        print_values($dtb);
-}
 
 
 ?>