$project_id, 'task_id' => $task_id, 'creator_id' => $creator_id, 'event_name' => $event_name, 'date_creation' => time(), ); $this->db->startTransaction(); $this->cleanup(self::MAX_EVENTS - 1); $result = $this->db->table(self::TABLE)->insert($values); $this->db->closeTransaction(); return $result; } /** * Remove old event entries to avoid a large table * * @access public * @param integer $max Maximum number of items to keep in the table */ public function cleanup($max) { if ($this->db->table(self::TABLE)->count() > $max) { $this->db->execute(' DELETE FROM '.self::TABLE.' WHERE id <= ( SELECT id FROM ( SELECT id FROM '.self::TABLE.' ORDER BY id DESC LIMIT 1 OFFSET '.$max.' ) foo )'); } } /** * Get all events for a given project * * @access public * @return array */ public function getAllByProjectId($project_id) { return $this->db->table(self::TABLE) ->eq('project_id', $project_id) ->desc('id') ->findAll(); } /** * Get all necessary content to display activity feed * * $author_name * $author_username * $task['id', 'title', 'position', 'column_name'] */ public function getAllContentByProjectId($project_id, $limit = 50) { $sql = ' SELECT task_has_events.date_creation, task_has_events.event_name, task_has_events.task_id, tasks.title as task_title, tasks.position as task_position, columns.title as task_column_name, users.username as author_username, users.name as author_name FROM task_has_events LEFT JOIN users ON users.id=task_has_events.creator_id LEFT JOIN tasks ON tasks.id=task_has_events.task_id LEFT JOIN columns ON columns.id=tasks.column_id WHERE task_has_events.project_id = ? ORDER BY task_has_events.id DESC LIMIT 0, '.$limit.' '; $rq = $this->db->execute($sql, array($project_id)); $events = $rq->fetchAll(PDO::FETCH_ASSOC); foreach ($events as &$event) { $event['author'] = $event['author_name'] ?: $event['author_username']; $event['event_title'] = $this->getTitle($event); $event['event_content'] = $this->getContent($event); $event['event_type'] = 'task'; } return $events; } /** * Get the event title (translated) * * @access public * @param array $event Event properties * @return string */ public function getTitle(array $event) { $titles = array( Task::EVENT_UPDATE => t('%s updated the task #%d', $event['author'], $event['task_id']), Task::EVENT_CREATE => t('%s created the task #%d', $event['author'], $event['task_id']), Task::EVENT_CLOSE => t('%s closed the task #%d', $event['author'], $event['task_id']), Task::EVENT_OPEN => t('%s open the task #%d', $event['author'], $event['task_id']), Task::EVENT_MOVE_COLUMN => t('%s moved the task #%d to the column %s', $event['author'], $event['task_id'], $event['task_column_name']), Task::EVENT_MOVE_POSITION => t('%s moved the task #%d to the position %d in the column %s', $event['author'], $event['task_id'], $event['task_position'], $event['task_column_name']), ); return isset($titles[$event['event_name']]) ? $titles[$event['event_name']] : ''; } /** * Get the event html content * * @access public * @param array $params Event properties * @return string */ public function getContent(array $params) { $tpl = new Template; return $tpl->load('event_'.str_replace('.', '_', $params['event_name']), $params); } /** * Attach events to be able to record the history * * @access public */ public function attachEvents() { $events = array( Task::EVENT_UPDATE, Task::EVENT_CREATE, Task::EVENT_CLOSE, Task::EVENT_OPEN, Task::EVENT_MOVE_COLUMN, Task::EVENT_MOVE_POSITION, ); $listener = new TaskHistoryListener($this); foreach ($events as $event_name) { $this->event->attach($event_name, $listener); } } }