<?php

	error_reporting(E_ALL & ~ E_NOTICE | E_WARNING);
	require_once ('MysqliDb.php');
	
	$db = new MysqliDb ('localhost', '', '', 'leak');
	
	function getDirContents($dir, &$results = array()){
		$files = scandir($dir);

		foreach($files as $key => $value){
			$path = realpath($dir.DIRECTORY_SEPARATOR.$value);
			if(!is_dir($path)) {
				$results[] = $path;
			} else if($value != "." && $value != "..") {
				getDirContents($path, $results);
				$results[] = $path;
			}
		}

		return $results;
	}

	$files = getDirContents('bigDB');
	$fileData = function($file) {
		$file = fopen($file, 'r');

		if (!$file)
			die('file does not exist or cannot be opened');

		while (($line = fgets($file)) !== false) {
			yield $line;
		}

		fclose($file);
	};
	
	$re1='([\\w-+]+(?:\\.[\\w-+]+)*@(?:[\\w-]+\\.)+[a-zA-Z]{2,7})';	# Email Address 1
	$re2='(:)';	# Any Single Character 1
	
	foreach($files as $file)
	{
		if(filetype($file) == "file")
		{
			foreach ($fileData($file) as $line) {
				// $line contains current line
				if ($c=preg_match_all ("/".$re1.$re2."/is", $line, $matches))
				{
					$data = explode(':', $line);
					if(count($data) > 2)
					{
						$i = 1;
						while($i <= count($data))
						{
							$password .= $data[$i];
							$i++;
						}
					}
					else
					{
						$password = $data[1];
					}
					
					$mail = $data[0];
					
					$db->where('username',$mail);
					$db->where('password',$password);
					$results = $db->get ('data');
					if(count($results) == 0){
						$insert = array("username" => $mail, "password" => $password);
						$id = $db->insert ('data', $insert);
						if($id) echo 'Entry created. Id=' . $id." username: ".$mail." password: ".$password."\n";
					}
					else{
						echo "Entry already exists!";
					}
				}
				
			}
		}
	}