@@ -26,6 +26,9 @@ discard block |
||
| 26 | 26 | echo "New connection! ({$conn->resourceId})\n"; |
| 27 | 27 | } |
| 28 | 28 | |
| 29 | + /** |
|
| 30 | + * @param ConnectionInterface $conn |
|
| 31 | + */ |
|
| 29 | 32 | public function setID($conn) |
| 30 | 33 | { |
| 31 | 34 | session_id($conn->WebSocket->request->getCookies()['PHPSESSID']); |
@@ -126,30 +129,47 @@ discard block |
||
| 126 | 129 | return $obSidebar->LoadSideBar($data); |
| 127 | 130 | } |
| 128 | 131 | |
| 132 | + /** |
|
| 133 | + * @param string $data |
|
| 134 | + * @param boolean $para |
|
| 135 | + */ |
|
| 129 | 136 | public function onConversation($data, $para, $sessionId) |
| 130 | 137 | { |
| 131 | 138 | $obConversation = new Conversation($sessionId); |
| 132 | 139 | return $obConversation->ConversationLoad($data, $para); |
| 133 | 140 | } |
| 134 | 141 | |
| 142 | + /** |
|
| 143 | + * @param string $data |
|
| 144 | + * @param boolean $para |
|
| 145 | + */ |
|
| 135 | 146 | public function onReceiver($data, $para, $sessionId) |
| 136 | 147 | { |
| 137 | 148 | $obReceiver = new Receiver($sessionId); |
| 138 | 149 | return $obReceiver->ReceiverLoad($data, True); |
| 139 | 150 | } |
| 140 | 151 | |
| 152 | + /** |
|
| 153 | + * @param string $data |
|
| 154 | + */ |
|
| 141 | 155 | public function onSearch($data, $sessionId) |
| 142 | 156 | { |
| 143 | 157 | $obSearch = new Search($sessionId); |
| 144 | 158 | return $obSearch->SearchItem(json_decode($data)); |
| 145 | 159 | } |
| 146 | 160 | |
| 161 | + /** |
|
| 162 | + * @param string $data |
|
| 163 | + */ |
|
| 147 | 164 | public function onCompose($data, $sessionId) |
| 148 | 165 | { |
| 149 | 166 | $obCompose = new Compose($sessionId); |
| 150 | 167 | return $obCompose->SelectUser(json_decode($data)); |
| 151 | 168 | } |
| 152 | 169 | |
| 170 | + /** |
|
| 171 | + * @param string $data |
|
| 172 | + */ |
|
| 153 | 173 | public function onReply($data, $sessionId) |
| 154 | 174 | { |
| 155 | 175 | $obReply = new Reply($sessionId); |
@@ -90,6 +90,11 @@ |
||
| 90 | 90 | $this->connect->close(); |
| 91 | 91 | } |
| 92 | 92 | |
| 93 | + /** |
|
| 94 | + * @param string $identifier |
|
| 95 | + * @param string $reply |
|
| 96 | + * @param string $time |
|
| 97 | + */ |
|
| 93 | 98 | function UpdateMessages($query, $identifier, $reply, $id, $time) |
| 94 | 99 | { |
| 95 | 100 | if($result = $this->connect->query($query)) |
@@ -6,6 +6,9 @@ |
||
| 6 | 6 | class Session |
| 7 | 7 | { |
| 8 | 8 | |
| 9 | + /** |
|
| 10 | + * @param string $key |
|
| 11 | + */ |
|
| 9 | 12 | public static function put($key, $value){ |
| 10 | 13 | $_SESSION[$key] = $value; |
| 11 | 14 | } |
@@ -97,6 +97,9 @@ |
||
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | |
| 100 | + /** |
|
| 101 | + * @param string $value |
|
| 102 | + */ |
|
| 100 | 103 | public function onError($key, $value) |
| 101 | 104 | { |
| 102 | 105 | $this->flag = 1; |