rendered paste body<?php/** * Sayume logger class * * Class that is responsible for querying the log files. All selects, * inserts, deletes, and creating new log files goes through this * class. * * @author Sean Hickey */class SayLogger { /** * The directory the log files are stored in. * @var string */ var $logDir; /** * The name of the log file to query * @var string */ var $log; /** * The full path and name of the log file * to query. * @var string */ var $logFile; /** * The full path and name of the log description * file that's being queried. * @var string */ var $logDescFile; /** * Array that comes from the log description * file, that expresses the column layout of * the log file. * @var array */ var $logDesc = array(); /** * Set to TRUE if a method produced an error. * @var bool */ var $error = false; var $ASC = true; var $DESC = false; /** * Class constructor * * @param string $logDir The directory where the log files are stored * @param string $log The name of the log file * @return void */ function SayLogger($logDir, $log) { $this->logDir = $logDir; $this->log = $log; $this->logFile = $logDir . '/' . $log . '.slog'; $this->logDescFile = $logDir . '/' . $log . '.sdes'; if (!file_exists($this->logFile) || !file_exists($this->logDescFile)) { $this->error = true; } if (!$this->parseDesc()) { $this->error = true; } } /** * Parses a log description file into an array * * The log description file contains information about the name of the * columns in the log file, any extra instructions for the column such * as auto_increment, and the next auto_increment value. * * Returns TRUE if the log description file was successfully parsed, FALSE * if there was an error. * * @return bool */ function parseDesc() { $contents = file_get_contents($this->logDescFile); if (empty($contents)) { return false; } $this->logDesc = unserialize($contents); return true; } /** * Writes log file description to description file * * Takes the log file description array, and any changes made to it, and * writes it back to the log description file. * * Returns TRUE if the data was successfully written to the log description * file, or FALSE if there was an error. * * @return bool */ function writeDesc() { $contents = serialize($this->logDesc); if (!file_exists($this->logDescFile)) { return false; } if (!$handler = @fopen($this->logDescFile, 'w')) { return false; } $result = @fwrite($handler, $contents); @fclose($handler); return $result; } /** * Selects rows from the log file * * @return obj */ function select($what) { $columns = explode(',', $what); $handle = fopen($this->logFile, "r"); $rows = array(); while (($data = fgetcsv($handle)) !== false) { $nData = array(); for ($i = 0; $i < count($data); $i++) { $nData[$this->logDesc[$i]['name']] = $data[$i]; } $yData = array(); foreach ($nData as $key => $value) { if (in_array($key, $columns)) { $yData[$key] = $value; } } $rows[] = $yData; } $results = & new SayResults($rows, $this->logDesc); return $results; } function insert() { $args = func_get_args(); $contents = ''; for ($i = 0; $i < count($args); $i++) { if ($args[$i] == null) { if ($this->logDesc[$i]['type'] == 'int') { if ($this->logDesc[$i]['extra'] == 'auto_increment') { $args[$i] = $this->logDesc[$i]['val']; $this->logDesc[$i]['val']++; } else { $args[$i] = 0; } } else if ($this->logDesc[$i]['type'] == 'date') { $args[$i] = time(); } } $args[$i] = str_replace('"', '\\"', $args[$i]); $contents .= '"' . $args[$i] . '"'; if ($i < (count($args) - 1)) { $contents .= ','; } } $this->writeDesc(); if (!$handler = @fopen($this->logFile, 'a')) { return false; } $result = @fwrite($handler, $contents . "\r\n"); @fclose($handler); return $result; } function delete($what) { } function create($logDir, $name, $column) { if (!is_object($column)) { return false; } $columns = $column->getDesc(); $results = $column->getResults(); $logDesc = serialize($columns); if (!is_writable($logDir)) { return false; } if (!$handler = @fopen($logDir . '/' . $name . '.sdes', 'w')) { return false; } $result = @fwrite($handler, $logDesc); @fclose($handler); if (!$result) { return false; } if (!$handler = @fopen($logDir . '/' . $name . '.slog', 'w')) { return false; } $result = @fwrite($handler, $results . "\r\n"); @fclose($handler); return $result; } function getDesc() { return $this->logDesc; }}/** * Sayume logger results class * * Stores the results from each query to the log files. * * @author Sean Hickey */class SayResults { var $resultData; var $tempResults; var $logDesc; var $skey = false; var $sarray = false; var $sasc = true; function SayResults($resultData, $logDesc) { $this->resultData = $resultData; $this->logDesc = $logDesc; } function get() { return $this->resultData; } function eq($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] == $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function neq($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] != $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function lt($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] < $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function lteq($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] <= $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function gt($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] > $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function gteq($what, $val) { $nData = array(); foreach ($this->resultData as $data) { if ($data[$what] >= $val) { $nData[] = $data; } } $results = & new SayResults($nData, $this->logDesc); return $results; } function distinct($what) { $nArray = $this->resultData; foreach ($nArray as $sub) { $cmp[] = $sub[$what]; } $unique = array_unique($cmp); foreach ($unique as $k => $rien) { $new[] = $nArray[$k]; } $results = & new SayResults($new, $this->logDesc); return $results; } function orderby($what, $order) { $this->skey = $what; $this->sasc = $order; $this->tempResults = $this->resultData; uksort($this->tempResults, array(&$this, "_as_cmp")); $results = & new SayResults($this->tempResults, $this->logDesc); return $results; } function limit($what) { $nData = array(); $nData = array_slice($this->resultData, 0, $what); $results = & new SayResults($nData, $this->logDesc); return $results; } function _as_cmp($a, $b) { //since uksort will pass here only indexes get real values from our array if (!is_array($a) && !is_array($b)) { $a = $this->tempResults[$a][$this->skey]; $b = $this->tempResults[$b][$this->skey]; } //if string - use string comparision if (!ctype_digit($a) && !ctype_digit($b)) { if ($this->sasc) { return strcasecmp($a, $b); } else { return strcasecmp($b, $a); } } else { if (intval($a) == intval($b)) { return 0; } if ($this->sasc) { return (intval($a) > intval($b)) ? -1 : 1; } else { return (intval($a) > intval($b)) ? 1 : -1; } } } function getDesc() { return $this->logDesc; } function getResults() { return $this->flattenResults(); } function flattenResults() { $contents = ''; foreach ($this->resultData as $data) { $nData = array(); foreach ($data as $d) { $nData[] = '"' . str_replace('"', '\\"', $d) . '"'; } $contents .= join(',', $nData) . "\r\n"; } return $contents; }}class SayColumn { var $columns; function add($name, $type, $extra = '', $val = '') { $types = array('int', 'str', 'date'); if (!in_array($type, $types)) { return false; } if ($extra == 'auto_increment' && $val == '') { $val = 1; } $this->columns[] = array('name' => $name, 'type' => $type, 'extra' => $extra, 'val' => $val); return true; } function getDesc() { return $this->columns; } function getResults() { return ''; }}$sl = new SayLogger('logs', 'main');//$sl->insert(null, '127.0.0.3', 'http://www.yahoo.com', time(), 'Non-Geeks');$rows = $sl->select('id,ip,referrer,timestamp,page');$vars = $rows->eq('ip', '127.0.0.1')->get();print_r($vars);?>