ssl_logs.php

<?php
include_once('functions.php');
include_once('config.php');

function LoadBroSSLLogs($fileName) {
/**
 * This file contains all of the functionality to import bro conn logs into the database
 * All CONSTANTS are defined within config.php
 */
	$insertStatement = ""; //Holds the overall SQL insert statement
	$currentRecordVals = ""; //Holds the values for this particular record before adding to $insertStatement
	//$currentFile = "../test2/ssl.log"; //use only for testing
	print("Importing SSL log file $fileName \n");
	$file = fopen($fileName, "r");
	$i = 1;
	$insertStatement = SSL_LOG_INSERT;
	$completeStatement = True;
	while(! feof($file)){
		$tmpRecord = fgetcsv($file, 0, "\t");
		// Check to ensure that the first charachter 
		// isn't '#' and if it is, skip the line
		if ($tmpRecord[0][0] == '#') continue;  //Line is a header
		if ($tmpRecord[0][0] == false) continue; //Line is blank
			
		$uid = $tmpRecord[SSL_UID];
		$version = ReturnString($tmpRecord[SSL_VERSION]);
		$cipher = ReturnString($tmpRecord[SSL_CIPHER]);
		$server = ReturnString($tmpRecord[SSL_SERVER]);
		$subject = ReturnString($tmpRecord[SSL_SUBJECT]);
		$issuer = ReturnString($tmpRecord[SSL_ISSUER]);
		
		//Build $currentRecordVals
		$currentRecordVals = "('$uid', '$version', '$cipher', '$server', '$subject', '$issuer')";
	
		if ($i == 1) { //First record, no need to add the comma
			$insertStatement = $insertStatement . $currentRecordVals;
			$i++;
			$completeStatement = False;
		} elseif ($i == 10) { //Final record in the current set, close out the sql statement and insert
			$insertStatement = $insertStatement . ", " . $currentRecordVals . ";";
			//INSERT THE RECORD INTO THE DATABASE
			if (! db_query($insertStatement)){
				echo "ERROR...... $insertStatement \n";
			}
			$i = 1; //Reset the counter
			$completeStatement = True;
			$insertStatement = SSL_LOG_INSERT;
		} else { //add a comma and the the next set of values
			$insertStatement = $insertStatement . ", " . $currentRecordVals;
			$i++;
			$completeStatement = False;
		}
	}
	//If we reach end of file without properly finishing and inserting the sql statement, do it now
	if (! $completeStatement){
		$insertStatement = $insertStatement . ";";
		//INSERT THE RECORD INTO THE DATABASE
		if (! db_query($insertStatement)){
			echo "ERROR...... $insertStatement \n";
		}
		$completeStatement = True;
	}
}
?>