]> dev.renevier.net Git - syj.git/blob - application/models/PendingMapper.php
cleanup po files
[syj.git] / application / models / PendingMapper.php
1 <?php
2 /*  This file is part of Syj, Copyright (c) 2010 Arnaud Renevier,
3     and is published under the AGPL license. */
4
5 class Syj_Model_PendingMapper
6 {
7     protected $_dbTable;
8     protected $_tableInfos = array('name' => 'pending_actions');
9
10     public function getDbTable() {
11         if (null === $this->_dbTable) {
12             $this->_dbTable = new Zend_Db_Table($this->_tableInfos);
13         }
14         return $this->_dbTable;
15     }
16
17     public function fetchByHash($hash) {
18         $table = $this->getDbTable();
19         $result = $table->fetchAll(array('hash = ?' => (string)$hash));
20
21         if (1 !== count($result)) {
22             return null;
23         }
24         $row = $result->current();
25
26         $entry = $this->pendingFactory($row->action);
27         if (!isset($entry)) {
28             continue;
29         }
30         $this->_itemFromRow($entry, $row);
31         return $entry;
32     }
33
34     public function find($id, Syj_Model_Pending $pending) {
35         $result = $this->getDbTable()->find((int)$id);
36         if (0 == count($result)) {
37             return false;
38         }
39         $row = $result->current();
40         $this->_itemFromRow($pending,$row);
41         return true;
42     }
43
44
45     public function fetchForUser(Syj_Model_User $user) {
46         $table = $this->getDbTable();
47         $select = $table->select();
48         $select->union(array_map(function($select) use (&$user) {
49             return $select->where('userid = ?', $user->id);
50         }, $this->_selects()));
51
52         $resultSet = $table->fetchAll($select);
53         $entries   = array();
54         foreach ($resultSet as $row) {
55             $entry = $this->pendingFactory($row->action);
56             if (!isset($entry)) {
57                 continue;
58             }
59             $entry->setUser($user);
60             $entries[] = $this->_itemFromRow($entry, $row);
61         }
62         return $entries;
63     }
64
65     public function fetchAll() {
66         $table = $this->getDbTable();
67         $select = $table->select();
68         $select->union($this->_selects());
69
70         $resultSet = $table->fetchAll($select);
71         $entries   = array();
72         foreach ($resultSet as $row) {
73             $entry = $this->pendingFactory($row->action);
74             if (!isset($entry)) {
75                 continue;
76             }
77             $entries[] = $this->_itemFromRow($entry, $row);
78         }
79         return $entries;
80     }
81
82     protected function pendingFactory($action) {
83         switch ($action) {
84             case 'validate_creation':
85                 return new Syj_Model_Pending_ValidateCreation();
86             break;
87             case 'reset_password':
88                 return new Syj_Model_Pending_ResetPassword();
89             break;
90             default:
91                 return null;
92             break;
93         }
94     }
95
96     protected function _selects() {
97         $res = array();
98         $table = $this->getDbTable();
99
100         foreach (Syj_Model_Pending::$rules as $action_name => $action) {
101             foreach ($action as $number => $item) {
102                 $select = $table->select();
103                 $select->where('action = ?', $action_name);
104                 if (isset($item)) {
105                     $select->where('creation_time < (NOW() - interval ?)', $item);
106                 }
107                 if ($item === end($action)) {
108                     $select->where('notifications_number >= ?', $number);
109                 } else {
110                     $select->where('notifications_number = ?', $number);
111                 }
112                 $res[] = $select;
113             }
114         }
115
116         return $res;
117     }
118
119     protected function _itemFromRow(Syj_Model_Pending $item, Zend_Db_Table_Row $row) {
120         $item->setId($row->id)
121              ->setHash($row->hash)
122              ->setNotificationsNumber($row->notifications_number)
123              ->setCreationTime($row->creation_time);
124
125         if (!$item->getUser()) {
126             $user = new Syj_Model_User();
127             $userMapper = new Syj_Model_UserMapper();
128             if ($userMapper->find($row->userid, $user)) {
129                 $item->setUser($user);
130             }
131         }
132
133         return $item;
134     }
135
136     public function save (Syj_Model_Pending $pending) {
137         $data = array(
138             'userid'=> (string) $pending->user->id,
139             'action'=> (string)$pending->action,
140         );
141         if (isset($pending->hash)) {
142             $data['hash'] = (string) $pending->hash;
143         }
144         if (isset($pending->notificationsNumber)) {
145             $data['notifications_number'] = (string) $pending->notificationsNumber;
146         }
147          if (null === ($id = $pending->getId())) {
148             $id = $this->getDbTable()->insert($data);
149             $this->find($id, $pending);
150         } else {
151             $this->getDbTable()->update($data, array('id = ?' => $id));
152             $this->find($id, $pending);
153         }
154     }
155
156     public function delete (Syj_Model_Pending $pending) {
157          if (null !== ($id = $pending->getId())) {
158             $this->getDbTable()->delete(array('id = ?' => $id));
159          }
160     }
161 }