Add access log for DB

Author: technicalguru

src/WebApp/Application.php

@@ -72,7 +72,8 @@ protected function initDatabase() {
 	protected function initDataModel() {
 		if ($this->database && $this->config->has('dataModel') && $this->config->get('dataModel')) {
 			$this->dataModel = new \TgDatabase\DataModel($this->database);
-			$this->dataModel->register('log', new DataModel\LogDAO($this->database));
+			$this->dataModel->register('log',       new DataModel\LogDAO($this->database));
+			$this->dataModel->register('accessLog', new DataModel\AccessLogDAO($this->database));
 		}
 	}
 
@@ -365,9 +366,14 @@ public function afterRequest() {
 				$log           = new DataModel\Log();
 				$log->log_text = $messages;
 				$log->log_date = Date::getInstance(time(), WFW_TIMEZONE);
-				$this->dataModel->get('log')->create($log);
+				$this->dao('log')->create($log);
 			}
 		}
+		if ($this->config->has('accessLog') && $this->config->get('accessLog') && $this->dataModel) {
+			$principal = $this->getPrincipal();
+			$userId    = (($principal != NULL) && isset($principal->uid)) ? $principal->uid : 0;
+			$this->dao('accessLog')->log($userId, $this->request);
+		}
 	}
 
 	public function svc($name) {

src/WebApp/DataModel/AccessLog.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace WebApp\DataModel;
+
+class AccessLog {
+
+	public function __construct() {
+		if (is_string($this->log_date)) $this->log_date = new \TgUtils\Date($this->log_date, WFW_TIMEZONE);
+	}
+
+}

src/WebApp/DataModel/AccessLogDAO.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace WebApp\DataModel;
+
+use TgUtils\Date;
+use TgDatabase\Restrictions;
+use WebApp\WebAppException;
+
+/** DataModel class for access logs */
+class AccessLogDAO extends \TgDatabase\DAO {
+
+	public function __construct($database, $checkTable = FALSE) {
+		parent::__construct($database, '#__access_log', 'WebApp\\DataModel\\AccessLog', 'uid', $checkTable);
+	}
+
+	public function createTable() {
+		// Create it (try)
+		$sql =
+			'CREATE TABLE '.$this->database->quoteName($this->tableName).' ( '.
+				'`uid` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, '.
+				'`session_id` VARCHAR(50) NOT NULL COMMENT \'ID of session\', '.
+				'`log_time` DATETIME NOT NULL COMMENT \'When was access logged\', '.
+				'`response_code` INT(5) UNSIGNED NOT NULL COMMENT \'HTTP Response Code\', '.
+				'`method` VARCHAR(10) NOT NULL COMMENT \'HTTP method\', '.
+				'`path` VARCHAR(200) NOT NULL COMMENT \'Path and params\', '.
+				'`referer` VARCHAR(200) COMMENT \'Referer if given\', '.
+				'`ua` VARCHAR(200) COMMENT \'User Agent\', '.
+				'`user_id` INT(10) UNSIGNED NOT NULL COMMENT \'User ID if known\', '.
+				'PRIMARY KEY (`uid`) '.
+			') ENGINE = InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT = \'Access Log\'';
+		$res = $this->database->query($sql);
+		if ($res === FALSE) {
+			throw new WebAppException('Cannot create access log table: '.$this->database->error());
+		}
+		return TRUE;
+	}
+
+	public function log($userId = 0, $request = NULL) {
+		if ($request == NULL) $request = \TgUtils\Request::getRequest();
+		if ($request != NULL) {
+			$obj = new AccessLog();
+			$obj->session_id    = session_id();
+			$obj->log_time      = new \TgUtils\Date(time(), WFW_TIMEZONE);
+			$obj->response_code = http_response_code();
+			$obj->method        = $request->method;
+			$obj->path          = $request->originalUri;
+			$obj->referer       = $request->getHeader('referer');
+			$obj->ua            = $request->getHeader('user-agent');
+			$obj->user_id       = $userId;
+			$this->create($obj);
+		}
+	}
+}