@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | * @param int $courseId |
63 | 63 | * @param int $sessionId |
64 | 64 | * |
65 | - * @return array |
|
65 | + * @return string |
|
66 | 66 | */ |
67 | 67 | public function getUserAcceptedLegal($userId, $courseId, $sessionId) |
68 | 68 | { |
@@ -112,7 +112,7 @@ discard block |
||
112 | 112 | * @param int $courseCode |
113 | 113 | * @param int $sessionId |
114 | 114 | * @param boolean $sendEmail Optional. Indicate whether the mail must be sent. Default is true |
115 | - * @return mixed |
|
115 | + * @return false|string |
|
116 | 116 | */ |
117 | 117 | public function saveUserLegal($userId, $courseCode, $sessionId, $sendEmail = true) |
118 | 118 | { |
@@ -218,7 +218,7 @@ discard block |
||
218 | 218 | * @param int $courseId |
219 | 219 | * @param int $sessionId |
220 | 220 | * |
221 | - * @return bool |
|
221 | + * @return boolean|null |
|
222 | 222 | */ |
223 | 223 | public function saveUserMailLegal($link, $userId, $courseId, $sessionId) |
224 | 224 | { |
@@ -108,12 +108,12 @@ |
||
108 | 108 | } |
109 | 109 | |
110 | 110 | /** |
111 | - * @param int $userId |
|
112 | - * @param int $courseCode |
|
113 | - * @param int $sessionId |
|
114 | - * @param boolean $sendEmail Optional. Indicate whether the mail must be sent. Default is true |
|
115 | - * @return mixed |
|
116 | - */ |
|
111 | + * @param int $userId |
|
112 | + * @param int $courseCode |
|
113 | + * @param int $sessionId |
|
114 | + * @param boolean $sendEmail Optional. Indicate whether the mail must be sent. Default is true |
|
115 | + * @return mixed |
|
116 | + */ |
|
117 | 117 | public function saveUserLegal($userId, $courseCode, $sessionId, $sendEmail = true) |
118 | 118 | { |
119 | 119 | $courseInfo = api_get_course_info($courseCode); |
@@ -421,7 +421,7 @@ |
||
421 | 421 | array('id = ? ' => $id) |
422 | 422 | ); |
423 | 423 | if (!empty($legalData['filename'])) { |
424 | - $fileToDelete = $coursePath . '/' . $legalData['filename']; |
|
424 | + $fileToDelete = $coursePath.'/'.$legalData['filename']; |
|
425 | 425 | if (file_exists($fileToDelete)) { |
426 | 426 | unlink($fileToDelete); |
427 | 427 | } |
@@ -14,7 +14,7 @@ |
||
14 | 14 | /** |
15 | 15 | * create (a singleton function that ensures KannelsmsPlugin instance is |
16 | 16 | * created only once. If it is already created, it returns the instance) |
17 | - * @return object KannelsmsPlugin instance |
|
17 | + * @return KannelsmsPlugin KannelsmsPlugin instance |
|
18 | 18 | */ |
19 | 19 | public static function create() |
20 | 20 | { |
@@ -138,6 +138,7 @@ discard block |
||
138 | 138 | * |
139 | 139 | * @param string key Your Kannel API Key |
140 | 140 | * @param array options Optional parameters for sending SMS |
141 | + * @param string $key |
|
141 | 142 | * @author Martin Steel |
142 | 143 | */ |
143 | 144 | public function __construct($key, array $options = array()) { |
@@ -471,6 +472,8 @@ discard block |
||
471 | 472 | * |
472 | 473 | * @param string method Kannel method to call (sms/credit) |
473 | 474 | * @param string data Content of HTTP POST |
475 | + * @param string $method |
|
476 | + * @param string $data |
|
474 | 477 | * |
475 | 478 | * @return string Response from Kannel |
476 | 479 | * @author Martin Steel |
@@ -505,6 +508,7 @@ discard block |
||
505 | 508 | * |
506 | 509 | * @param string url URL to send to |
507 | 510 | * @param string data Data to POST |
511 | + * @param string $url |
|
508 | 512 | * @return string Response returned by server |
509 | 513 | * @author Martin Steel |
510 | 514 | */ |
@@ -631,7 +635,7 @@ discard block |
||
631 | 635 | * Check if a number is a valid MSISDN |
632 | 636 | * |
633 | 637 | * @param string $val Value to check |
634 | - * @return bool True if valid MSISDN |
|
638 | + * @return integer True if valid MSISDN |
|
635 | 639 | * @author James Inman |
636 | 640 | * @since 1.3.0 |
637 | 641 | * @todo Take an optional country code and check that the number starts with it |
@@ -10,7 +10,7 @@ discard block |
||
10 | 10 | */ |
11 | 11 | |
12 | 12 | if ( !class_exists('KannelException') ) { |
13 | - require_once('exception.php'); |
|
13 | + require_once('exception.php'); |
|
14 | 14 | } |
15 | 15 | |
16 | 16 | /** |
@@ -21,130 +21,130 @@ discard block |
||
21 | 21 | */ |
22 | 22 | class Kannel { |
23 | 23 | |
24 | - /* |
|
24 | + /* |
|
25 | 25 | * Version of this class |
26 | 26 | */ |
27 | - const VERSION = '1.3.1'; |
|
28 | - |
|
29 | - /** |
|
30 | - * All Kannel API calls start with BASE_URL |
|
31 | - * @author Martin Steel |
|
32 | - */ |
|
33 | - const API_BASE_URL = 'api.kannelsms.com/xml/'; |
|
34 | - |
|
35 | - /** |
|
36 | - * string to append to API_BASE_URL to check authentication |
|
37 | - * @author Martin Steel |
|
38 | - */ |
|
39 | - const API_AUTH_METHOD = 'authenticate'; |
|
40 | - |
|
41 | - /** |
|
42 | - * string to append to API_BASE_URL for sending SMS |
|
43 | - * @author Martin Steel |
|
44 | - */ |
|
45 | - const API_SMS_METHOD = 'sms'; |
|
46 | - |
|
47 | - /** |
|
48 | - * string to append to API_BASE_URL for checking message credit |
|
49 | - * @author Martin Steel |
|
50 | - */ |
|
51 | - const API_CREDIT_METHOD = 'credit'; |
|
52 | - |
|
53 | - /** |
|
54 | - * string to append to API_BASE_URL for checking account balance |
|
55 | - * @author Martin Steel |
|
56 | - */ |
|
57 | - const API_BALANCE_METHOD = 'balance'; |
|
58 | - |
|
59 | - /** |
|
60 | - * Kannel API Key |
|
61 | - * |
|
62 | - * @var string |
|
63 | - * @author Martin Steel |
|
64 | - */ |
|
65 | - public $key; |
|
66 | - |
|
67 | - /** |
|
68 | - * Use SSL when making HTTP requests |
|
69 | - * |
|
70 | - * If this is not set, SSL will be used where PHP supports it |
|
71 | - * |
|
72 | - * @var bool |
|
73 | - * @author Martin Steel |
|
74 | - */ |
|
75 | - public $ssl; |
|
76 | - |
|
77 | - /** |
|
78 | - * Proxy server hostname (Optional) |
|
79 | - * |
|
80 | - * @var string |
|
81 | - * @author Martin Steel |
|
82 | - */ |
|
83 | - public $proxy_host; |
|
84 | - |
|
85 | - /** |
|
86 | - * Proxy server port (Optional) |
|
87 | - * |
|
88 | - * @var integer |
|
89 | - * @author Martin Steel |
|
90 | - */ |
|
91 | - public $proxy_port; |
|
92 | - |
|
93 | - /** |
|
94 | - * From address used on text messages |
|
95 | - * |
|
96 | - * @var string (11 characters or 12 numbers) |
|
97 | - * @author Martin Steel |
|
98 | - */ |
|
99 | - public $from; |
|
100 | - |
|
101 | - /** |
|
102 | - * Allow long SMS messages (Cost up to 3 credits) |
|
103 | - * |
|
104 | - * @var bool |
|
105 | - * @author Martin Steel |
|
106 | - */ |
|
107 | - public $long; |
|
108 | - |
|
109 | - /** |
|
110 | - * Truncate message text if it is too long |
|
111 | - * |
|
112 | - * @var bool |
|
113 | - * @author Martin Steel |
|
114 | - */ |
|
115 | - public $truncate; |
|
116 | - |
|
117 | - /** |
|
118 | - * Enables various logging of messages when true. |
|
119 | - * |
|
120 | - * @var bool |
|
121 | - * @author Martin Steel |
|
122 | - */ |
|
123 | - public $log; |
|
124 | - |
|
125 | - /** |
|
126 | - * What Kannel should do if you send an invalid character |
|
127 | - * |
|
128 | - * Possible values: |
|
129 | - * 'error' - Return an error (Messasge is not sent) |
|
130 | - * 'remove' - Remove the invalid character(s) |
|
131 | - * 'replace' - Replace invalid characters where possible, remove others |
|
132 | - * @author Martin Steel |
|
133 | - */ |
|
134 | - public $invalid_char_action; |
|
135 | - |
|
136 | - /** |
|
137 | - * Create a new instance of the Kannel wrapper |
|
138 | - * |
|
139 | - * @param string key Your Kannel API Key |
|
140 | - * @param array options Optional parameters for sending SMS |
|
141 | - * @author Martin Steel |
|
142 | - */ |
|
143 | - public function __construct($key, array $options = array()) { |
|
27 | + const VERSION = '1.3.1'; |
|
28 | + |
|
29 | + /** |
|
30 | + * All Kannel API calls start with BASE_URL |
|
31 | + * @author Martin Steel |
|
32 | + */ |
|
33 | + const API_BASE_URL = 'api.kannelsms.com/xml/'; |
|
34 | + |
|
35 | + /** |
|
36 | + * string to append to API_BASE_URL to check authentication |
|
37 | + * @author Martin Steel |
|
38 | + */ |
|
39 | + const API_AUTH_METHOD = 'authenticate'; |
|
40 | + |
|
41 | + /** |
|
42 | + * string to append to API_BASE_URL for sending SMS |
|
43 | + * @author Martin Steel |
|
44 | + */ |
|
45 | + const API_SMS_METHOD = 'sms'; |
|
46 | + |
|
47 | + /** |
|
48 | + * string to append to API_BASE_URL for checking message credit |
|
49 | + * @author Martin Steel |
|
50 | + */ |
|
51 | + const API_CREDIT_METHOD = 'credit'; |
|
52 | + |
|
53 | + /** |
|
54 | + * string to append to API_BASE_URL for checking account balance |
|
55 | + * @author Martin Steel |
|
56 | + */ |
|
57 | + const API_BALANCE_METHOD = 'balance'; |
|
58 | + |
|
59 | + /** |
|
60 | + * Kannel API Key |
|
61 | + * |
|
62 | + * @var string |
|
63 | + * @author Martin Steel |
|
64 | + */ |
|
65 | + public $key; |
|
66 | + |
|
67 | + /** |
|
68 | + * Use SSL when making HTTP requests |
|
69 | + * |
|
70 | + * If this is not set, SSL will be used where PHP supports it |
|
71 | + * |
|
72 | + * @var bool |
|
73 | + * @author Martin Steel |
|
74 | + */ |
|
75 | + public $ssl; |
|
76 | + |
|
77 | + /** |
|
78 | + * Proxy server hostname (Optional) |
|
79 | + * |
|
80 | + * @var string |
|
81 | + * @author Martin Steel |
|
82 | + */ |
|
83 | + public $proxy_host; |
|
84 | + |
|
85 | + /** |
|
86 | + * Proxy server port (Optional) |
|
87 | + * |
|
88 | + * @var integer |
|
89 | + * @author Martin Steel |
|
90 | + */ |
|
91 | + public $proxy_port; |
|
92 | + |
|
93 | + /** |
|
94 | + * From address used on text messages |
|
95 | + * |
|
96 | + * @var string (11 characters or 12 numbers) |
|
97 | + * @author Martin Steel |
|
98 | + */ |
|
99 | + public $from; |
|
100 | + |
|
101 | + /** |
|
102 | + * Allow long SMS messages (Cost up to 3 credits) |
|
103 | + * |
|
104 | + * @var bool |
|
105 | + * @author Martin Steel |
|
106 | + */ |
|
107 | + public $long; |
|
108 | + |
|
109 | + /** |
|
110 | + * Truncate message text if it is too long |
|
111 | + * |
|
112 | + * @var bool |
|
113 | + * @author Martin Steel |
|
114 | + */ |
|
115 | + public $truncate; |
|
116 | + |
|
117 | + /** |
|
118 | + * Enables various logging of messages when true. |
|
119 | + * |
|
120 | + * @var bool |
|
121 | + * @author Martin Steel |
|
122 | + */ |
|
123 | + public $log; |
|
124 | + |
|
125 | + /** |
|
126 | + * What Kannel should do if you send an invalid character |
|
127 | + * |
|
128 | + * Possible values: |
|
129 | + * 'error' - Return an error (Messasge is not sent) |
|
130 | + * 'remove' - Remove the invalid character(s) |
|
131 | + * 'replace' - Replace invalid characters where possible, remove others |
|
132 | + * @author Martin Steel |
|
133 | + */ |
|
134 | + public $invalid_char_action; |
|
135 | + |
|
136 | + /** |
|
137 | + * Create a new instance of the Kannel wrapper |
|
138 | + * |
|
139 | + * @param string key Your Kannel API Key |
|
140 | + * @param array options Optional parameters for sending SMS |
|
141 | + * @author Martin Steel |
|
142 | + */ |
|
143 | + public function __construct($key, array $options = array()) { |
|
144 | 144 | if (empty($key)) { |
145 | - throw new KannelException("Key can't be blank"); |
|
145 | + throw new KannelException("Key can't be blank"); |
|
146 | 146 | } else { |
147 | - $this->key = $key; |
|
147 | + $this->key = $key; |
|
148 | 148 | } |
149 | 149 | |
150 | 150 | $this->ssl = (array_key_exists('ssl', $options)) ? $options['ssl'] : null; |
@@ -155,22 +155,22 @@ discard block |
||
155 | 155 | $this->truncate = (array_key_exists('truncate', $options)) ? $options['truncate'] : null; |
156 | 156 | $this->invalid_char_action = (array_key_exists('invalid_char_action', $options)) ? $options['invalid_char_action'] : null; |
157 | 157 | $this->log = (array_key_exists('log', $options)) ? $options['log'] : false; |
158 | - } |
|
158 | + } |
|
159 | 159 | |
160 | - /** |
|
161 | - * Send some text messages |
|
162 | - * |
|
163 | - * |
|
164 | - * @author Martin Steel |
|
165 | - */ |
|
166 | - public function send(array $sms) { |
|
160 | + /** |
|
161 | + * Send some text messages |
|
162 | + * |
|
163 | + * |
|
164 | + * @author Martin Steel |
|
165 | + */ |
|
166 | + public function send(array $sms) { |
|
167 | 167 | if (!is_array($sms)) { |
168 | - throw new KannelException("sms parameter must be an array"); |
|
168 | + throw new KannelException("sms parameter must be an array"); |
|
169 | 169 | } |
170 | 170 | $single_message = $this->is_assoc($sms); |
171 | 171 | |
172 | 172 | if ($single_message) { |
173 | - $sms = array($sms); |
|
173 | + $sms = array($sms); |
|
174 | 174 | } |
175 | 175 | |
176 | 176 | $req_doc = new \DOMDocument('1.0', 'UTF-8'); |
@@ -182,70 +182,70 @@ discard block |
||
182 | 182 | $root->appendChild($user_node); |
183 | 183 | |
184 | 184 | for ($i = 0; $i < count($sms); $i++) { |
185 | - $single = $sms[$i]; |
|
185 | + $single = $sms[$i]; |
|
186 | 186 | |
187 | - $sms_node = $req_doc->createElement('SMS'); |
|
187 | + $sms_node = $req_doc->createElement('SMS'); |
|
188 | 188 | |
189 | - // Phone number |
|
190 | - $sms_node->appendChild($req_doc->createElement('To', $single['to'])); |
|
189 | + // Phone number |
|
190 | + $sms_node->appendChild($req_doc->createElement('To', $single['to'])); |
|
191 | 191 | |
192 | - // Message text |
|
193 | - $content_node = $req_doc->createElement('Content'); |
|
194 | - $content_node->appendChild($req_doc->createTextNode($single['message'])); |
|
195 | - $sms_node->appendChild($content_node); |
|
192 | + // Message text |
|
193 | + $content_node = $req_doc->createElement('Content'); |
|
194 | + $content_node->appendChild($req_doc->createTextNode($single['message'])); |
|
195 | + $sms_node->appendChild($content_node); |
|
196 | 196 | |
197 | - // From |
|
198 | - if (array_key_exists('from', $single) || isset($this->from)) { |
|
197 | + // From |
|
198 | + if (array_key_exists('from', $single) || isset($this->from)) { |
|
199 | 199 | $from_node = $req_doc->createElement('From'); |
200 | 200 | $from_node->appendChild($req_doc->createTextNode(array_key_exists('from', $single) ? $single['from'] : $this->from)); |
201 | 201 | $sms_node->appendChild($from_node); |
202 | - } |
|
202 | + } |
|
203 | 203 | |
204 | - // Client ID |
|
205 | - if (array_key_exists('client_id', $single)) { |
|
204 | + // Client ID |
|
205 | + if (array_key_exists('client_id', $single)) { |
|
206 | 206 | $client_id_node = $req_doc->createElement('ClientID'); |
207 | 207 | $client_id_node->appendChild($req_doc->createTextNode($single['client_id'])); |
208 | 208 | $sms_node->appendChild($client_id_node); |
209 | - } |
|
209 | + } |
|
210 | 210 | |
211 | - // Long |
|
212 | - if (array_key_exists('long', $single) || isset($this->long)) { |
|
211 | + // Long |
|
212 | + if (array_key_exists('long', $single) || isset($this->long)) { |
|
213 | 213 | $long = array_key_exists('long', $single) ? $single['long'] : $this->long; |
214 | 214 | $long_node = $req_doc->createElement('Long'); |
215 | 215 | $long_node->appendChild($req_doc->createTextNode($long ? 1 : 0)); |
216 | 216 | $sms_node->appendChild($long_node); |
217 | - } |
|
217 | + } |
|
218 | 218 | |
219 | - // Truncate |
|
220 | - if (array_key_exists('truncate', $single) || isset($this->truncate)) { |
|
219 | + // Truncate |
|
220 | + if (array_key_exists('truncate', $single) || isset($this->truncate)) { |
|
221 | 221 | $truncate = array_key_exists('truncate', $single) ? $single['truncate'] : $this->truncate; |
222 | 222 | $trunc_node = $req_doc->createElement('Truncate'); |
223 | 223 | $trunc_node->appendChild($req_doc->createTextNode($truncate ? 1 : 0)); |
224 | 224 | $sms_node->appendChild($trunc_node); |
225 | - } |
|
225 | + } |
|
226 | 226 | |
227 | - // Invalid Char Action |
|
228 | - if (array_key_exists('invalid_char_action', $single) || isset($this->invalid_char_action)) { |
|
227 | + // Invalid Char Action |
|
228 | + if (array_key_exists('invalid_char_action', $single) || isset($this->invalid_char_action)) { |
|
229 | 229 | $action = array_key_exists('invalid_char_action', $single) ? $single['invalid_char_action'] : $this->invalid_char_action; |
230 | 230 | switch (strtolower($action)) { |
231 | - case 'error': |
|
231 | + case 'error': |
|
232 | 232 | $sms_node->appendChild($req_doc->createElement('InvalidCharAction', 1)); |
233 | - break; |
|
234 | - case 'remove': |
|
233 | + break; |
|
234 | + case 'remove': |
|
235 | 235 | $sms_node->appendChild($req_doc->createElement('InvalidCharAction', 2)); |
236 | - break; |
|
237 | - case 'replace': |
|
236 | + break; |
|
237 | + case 'replace': |
|
238 | 238 | $sms_node->appendChild($req_doc->createElement('InvalidCharAction', 3)); |
239 | + break; |
|
240 | + default: |
|
239 | 241 | break; |
240 | - default: |
|
241 | - break; |
|
242 | 242 | } |
243 | - } |
|
243 | + } |
|
244 | 244 | |
245 | - // Wrapper ID |
|
246 | - $sms_node->appendChild($req_doc->createElement('WrapperID', $i)); |
|
245 | + // Wrapper ID |
|
246 | + $sms_node->appendChild($req_doc->createElement('WrapperID', $i)); |
|
247 | 247 | |
248 | - $root->appendChild($sms_node); |
|
248 | + $root->appendChild($sms_node); |
|
249 | 249 | } |
250 | 250 | |
251 | 251 | $req_xml = $req_doc->saveXML(); |
@@ -259,12 +259,12 @@ discard block |
||
259 | 259 | $err_desc = null; |
260 | 260 | |
261 | 261 | foreach($resp_doc->documentElement->childNodes AS $doc_child) { |
262 | - switch(strtolower($doc_child->nodeName)) { |
|
262 | + switch(strtolower($doc_child->nodeName)) { |
|
263 | 263 | case 'sms_resp': |
264 | 264 | $resp = array(); |
265 | 265 | $wrapper_id = null; |
266 | 266 | foreach($doc_child->childNodes AS $resp_node) { |
267 | - switch(strtolower($resp_node->nodeName)) { |
|
267 | + switch(strtolower($resp_node->nodeName)) { |
|
268 | 268 | case 'messageid': |
269 | 269 | $resp['id'] = $resp_node->nodeValue; |
270 | 270 | break; |
@@ -277,13 +277,13 @@ discard block |
||
277 | 277 | case 'wrapperid': |
278 | 278 | $wrapper_id = $resp_node->nodeValue; |
279 | 279 | break; |
280 | - } |
|
280 | + } |
|
281 | 281 | } |
282 | 282 | if( array_key_exists('error_code', $resp ) ) |
283 | 283 | { |
284 | - $resp['success'] = 0; |
|
284 | + $resp['success'] = 0; |
|
285 | 285 | } else { |
286 | - $resp['success'] = 1; |
|
286 | + $resp['success'] = 1; |
|
287 | 287 | } |
288 | 288 | $resp['sms'] = $sms[$wrapper_id]; |
289 | 289 | array_push($response, $resp); |
@@ -294,28 +294,28 @@ discard block |
||
294 | 294 | case 'errdesc': |
295 | 295 | $err_desc = $doc_child->nodeValue; |
296 | 296 | break; |
297 | - } |
|
297 | + } |
|
298 | 298 | } |
299 | 299 | |
300 | 300 | if (isset($err_no)) { |
301 | - throw new KannelException($err_desc, $err_no); |
|
301 | + throw new KannelException($err_desc, $err_no); |
|
302 | 302 | } |
303 | 303 | |
304 | 304 | if ($single_message) { |
305 | - return $response[0]; |
|
305 | + return $response[0]; |
|
306 | 306 | } else { |
307 | - return $response; |
|
307 | + return $response; |
|
308 | 308 | } |
309 | - } |
|
310 | - |
|
311 | - /** |
|
312 | - * Check how many SMS credits you have available |
|
313 | - * |
|
314 | - * @return integer SMS credits remaining |
|
315 | - * @deprecated Use checkBalance() instead |
|
316 | - * @author Martin Steel |
|
317 | - */ |
|
318 | - public function checkCredit() { |
|
309 | + } |
|
310 | + |
|
311 | + /** |
|
312 | + * Check how many SMS credits you have available |
|
313 | + * |
|
314 | + * @return integer SMS credits remaining |
|
315 | + * @deprecated Use checkBalance() instead |
|
316 | + * @author Martin Steel |
|
317 | + */ |
|
318 | + public function checkCredit() { |
|
319 | 319 | // Create XML doc for request |
320 | 320 | $req_doc = new \DOMDocument('1.0', 'UTF-8'); |
321 | 321 | $root = $req_doc->createElement('Credit'); |
@@ -336,7 +336,7 @@ discard block |
||
336 | 336 | $err_desc = null; |
337 | 337 | |
338 | 338 | foreach ($resp_doc->documentElement->childNodes AS $doc_child) { |
339 | - switch ($doc_child->nodeName) { |
|
339 | + switch ($doc_child->nodeName) { |
|
340 | 340 | case "Credit": |
341 | 341 | $credit = $doc_child->nodeValue; |
342 | 342 | break; |
@@ -348,22 +348,22 @@ discard block |
||
348 | 348 | break; |
349 | 349 | default: |
350 | 350 | break; |
351 | - } |
|
351 | + } |
|
352 | 352 | } |
353 | 353 | |
354 | 354 | if (isset($err_no)) { |
355 | - throw new KannelException($err_desc, $err_no); |
|
355 | + throw new KannelException($err_desc, $err_no); |
|
356 | 356 | } |
357 | 357 | return $credit; |
358 | - } |
|
358 | + } |
|
359 | 359 | |
360 | - /** |
|
361 | - * Check your account balance |
|
362 | - * |
|
363 | - * @return array Array of account balance: |
|
364 | - * @author Martin Steel |
|
365 | - */ |
|
366 | - public function checkBalance() { |
|
360 | + /** |
|
361 | + * Check your account balance |
|
362 | + * |
|
363 | + * @return array Array of account balance: |
|
364 | + * @author Martin Steel |
|
365 | + */ |
|
366 | + public function checkBalance() { |
|
367 | 367 | // Create XML doc for request |
368 | 368 | $req_doc = new \DOMDocument('1.0', 'UTF-8'); |
369 | 369 | $root = $req_doc->createElement('Balance'); |
@@ -384,20 +384,20 @@ discard block |
||
384 | 384 | $err_desc = null; |
385 | 385 | |
386 | 386 | foreach ($resp_doc->documentElement->childNodes as $doc_child) { |
387 | - switch ($doc_child->nodeName) { |
|
387 | + switch ($doc_child->nodeName) { |
|
388 | 388 | case "Balance": |
389 | 389 | $balance = number_format(floatval($doc_child->nodeValue), 2); |
390 | 390 | break; |
391 | 391 | case "Currency": |
392 | 392 | foreach ($doc_child->childNodes as $resp_node) { |
393 | - switch ($resp_node->tagName) { |
|
393 | + switch ($resp_node->tagName) { |
|
394 | 394 | case "Symbol": |
395 | 395 | $symbol = $resp_node->nodeValue; |
396 | 396 | break; |
397 | 397 | case "Code": |
398 | 398 | $code = $resp_node->nodeValue; |
399 | 399 | break; |
400 | - } |
|
400 | + } |
|
401 | 401 | } |
402 | 402 | break; |
403 | 403 | case "ErrNo": |
@@ -408,23 +408,23 @@ discard block |
||
408 | 408 | break; |
409 | 409 | default: |
410 | 410 | break; |
411 | - } |
|
411 | + } |
|
412 | 412 | } |
413 | 413 | |
414 | 414 | if (isset($err_no)) { |
415 | - throw new KannelException($err_desc, $err_no); |
|
415 | + throw new KannelException($err_desc, $err_no); |
|
416 | 416 | } |
417 | 417 | |
418 | 418 | return array( 'symbol' => $symbol, 'balance' => $balance, 'code' => $code ); |
419 | - } |
|
419 | + } |
|
420 | 420 | |
421 | - /** |
|
422 | - * Check whether the API Key is valid |
|
423 | - * |
|
424 | - * @return bool True indicates a valid key |
|
425 | - * @author Martin Steel |
|
426 | - */ |
|
427 | - public function checkKey() { |
|
421 | + /** |
|
422 | + * Check whether the API Key is valid |
|
423 | + * |
|
424 | + * @return bool True indicates a valid key |
|
425 | + * @author Martin Steel |
|
426 | + */ |
|
427 | + public function checkKey() { |
|
428 | 428 | // Create XML doc for request |
429 | 429 | $req_doc = new \DOMDocument('1.0', 'UTF-8'); |
430 | 430 | $root = $req_doc->createElement('Authenticate'); |
@@ -445,7 +445,7 @@ discard block |
||
445 | 445 | $err_desc = null; |
446 | 446 | |
447 | 447 | foreach ($resp_doc->documentElement->childNodes AS $doc_child) { |
448 | - switch ($doc_child->nodeName) { |
|
448 | + switch ($doc_child->nodeName) { |
|
449 | 449 | case "CustID": |
450 | 450 | $cust_id = $doc_child->nodeValue; |
451 | 451 | break; |
@@ -457,33 +457,33 @@ discard block |
||
457 | 457 | break; |
458 | 458 | default: |
459 | 459 | break; |
460 | - } |
|
460 | + } |
|
461 | 461 | } |
462 | 462 | |
463 | 463 | if (isset($err_no)) { |
464 | - throw new KannelException($err_desc, $err_no); |
|
464 | + throw new KannelException($err_desc, $err_no); |
|
465 | 465 | } |
466 | 466 | return isset($cust_id); |
467 | - } |
|
468 | - |
|
469 | - /** |
|
470 | - * Make an HTTP POST to Kannel |
|
471 | - * |
|
472 | - * @param string method Kannel method to call (sms/credit) |
|
473 | - * @param string data Content of HTTP POST |
|
474 | - * |
|
475 | - * @return string Response from Kannel |
|
476 | - * @author Martin Steel |
|
477 | - */ |
|
478 | - protected function postToKannel($method, $data) { |
|
467 | + } |
|
468 | + |
|
469 | + /** |
|
470 | + * Make an HTTP POST to Kannel |
|
471 | + * |
|
472 | + * @param string method Kannel method to call (sms/credit) |
|
473 | + * @param string data Content of HTTP POST |
|
474 | + * |
|
475 | + * @return string Response from Kannel |
|
476 | + * @author Martin Steel |
|
477 | + */ |
|
478 | + protected function postToKannel($method, $data) { |
|
479 | 479 | if ($this->log) { |
480 | - $this->logXML("API $method Request XML", $data); |
|
480 | + $this->logXML("API $method Request XML", $data); |
|
481 | 481 | } |
482 | 482 | |
483 | 483 | if( isset( $this->ssl ) ) { |
484 | - $ssl = $this->ssl; |
|
484 | + $ssl = $this->ssl; |
|
485 | 485 | } else { |
486 | - $ssl = $this->sslSupport(); |
|
486 | + $ssl = $this->sslSupport(); |
|
487 | 487 | } |
488 | 488 | |
489 | 489 | $url = $ssl ? 'https://' : 'http://'; |
@@ -492,152 +492,152 @@ discard block |
||
492 | 492 | $response = $this->xmlPost($url, $data); |
493 | 493 | |
494 | 494 | if ($this->log) { |
495 | - $this->logXML("API $method Response XML", $response); |
|
495 | + $this->logXML("API $method Response XML", $response); |
|
496 | 496 | } |
497 | 497 | |
498 | 498 | return $response; |
499 | - } |
|
500 | - |
|
501 | - /** |
|
502 | - * Make a HTTP POST |
|
503 | - * |
|
504 | - * cURL will be used if available, otherwise tries the PHP stream functions |
|
505 | - * |
|
506 | - * @param string url URL to send to |
|
507 | - * @param string data Data to POST |
|
508 | - * @return string Response returned by server |
|
509 | - * @author Martin Steel |
|
510 | - */ |
|
511 | - protected function xmlPost($url, $data) { |
|
499 | + } |
|
500 | + |
|
501 | + /** |
|
502 | + * Make a HTTP POST |
|
503 | + * |
|
504 | + * cURL will be used if available, otherwise tries the PHP stream functions |
|
505 | + * |
|
506 | + * @param string url URL to send to |
|
507 | + * @param string data Data to POST |
|
508 | + * @return string Response returned by server |
|
509 | + * @author Martin Steel |
|
510 | + */ |
|
511 | + protected function xmlPost($url, $data) { |
|
512 | 512 | if(extension_loaded('curl')) { |
513 | - $ch = curl_init($url); |
|
514 | - curl_setopt($ch, CURLOPT_POST, 1); |
|
515 | - curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
|
516 | - curl_setopt($ch, CURLOPT_HTTPHEADER, Array("Content-Type: text/xml")); |
|
517 | - curl_setopt($ch, CURLOPT_USERAGENT, 'Kannel PHP Wrapper/1.0' . self::VERSION); |
|
518 | - curl_setopt($ch, CURLOPT_POSTFIELDS, $data); |
|
519 | - if (isset($this->proxy_host) && isset($this->proxy_port)) { |
|
513 | + $ch = curl_init($url); |
|
514 | + curl_setopt($ch, CURLOPT_POST, 1); |
|
515 | + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
|
516 | + curl_setopt($ch, CURLOPT_HTTPHEADER, Array("Content-Type: text/xml")); |
|
517 | + curl_setopt($ch, CURLOPT_USERAGENT, 'Kannel PHP Wrapper/1.0' . self::VERSION); |
|
518 | + curl_setopt($ch, CURLOPT_POSTFIELDS, $data); |
|
519 | + if (isset($this->proxy_host) && isset($this->proxy_port)) { |
|
520 | 520 | curl_setopt($ch, CURLOPT_PROXY, $this->proxy_host); |
521 | 521 | curl_setopt($ch, CURLOPT_PROXYPORT, $this->proxy_port); |
522 | - } |
|
522 | + } |
|
523 | 523 | |
524 | - $response = curl_exec($ch); |
|
525 | - $info = curl_getinfo($ch); |
|
524 | + $response = curl_exec($ch); |
|
525 | + $info = curl_getinfo($ch); |
|
526 | 526 | |
527 | - if ($response === false || $info['http_code'] != 200) { |
|
527 | + if ($response === false || $info['http_code'] != 200) { |
|
528 | 528 | throw new \Exception('HTTP Error calling Kannel API - HTTP Status: ' . $info['http_code'] . ' - cURL Erorr: ' . curl_error($ch)); |
529 | - } elseif (curl_errno($ch) > 0) { |
|
529 | + } elseif (curl_errno($ch) > 0) { |
|
530 | 530 | throw new \Exception('HTTP Error calling Kannel API - cURL Error: ' . curl_error($ch)); |
531 | - } |
|
531 | + } |
|
532 | 532 | |
533 | - curl_close($ch); |
|
533 | + curl_close($ch); |
|
534 | 534 | |
535 | - return $response; |
|
535 | + return $response; |
|
536 | 536 | } elseif (function_exists('stream_get_contents')) { |
537 | - // Enable error Track Errors |
|
538 | - $track = ini_get('track_errors'); |
|
539 | - ini_set('track_errors',true); |
|
537 | + // Enable error Track Errors |
|
538 | + $track = ini_get('track_errors'); |
|
539 | + ini_set('track_errors',true); |
|
540 | 540 | |
541 | - $params = array('http' => array( |
|
542 | - 'method' => 'POST', |
|
543 | - 'header' => "Content-Type: text/xml\r\nUser-Agent: mediaburst PHP Wrapper/" . self::VERSION . "\r\n", |
|
544 | - 'content' => $data |
|
545 | - )); |
|
541 | + $params = array('http' => array( |
|
542 | + 'method' => 'POST', |
|
543 | + 'header' => "Content-Type: text/xml\r\nUser-Agent: mediaburst PHP Wrapper/" . self::VERSION . "\r\n", |
|
544 | + 'content' => $data |
|
545 | + )); |
|
546 | 546 | |
547 | - if (isset($this->proxy_host) && isset($this->proxy_port)) { |
|
547 | + if (isset($this->proxy_host) && isset($this->proxy_port)) { |
|
548 | 548 | $params['http']['proxy'] = 'tcp://'.$this->proxy_host . ':' . $this->proxy_port; |
549 | 549 | $params['http']['request_fulluri'] = True; |
550 | - } |
|
550 | + } |
|
551 | 551 | |
552 | - $ctx = stream_context_create($params); |
|
553 | - $fp = @fopen($url, 'rb', false, $ctx); |
|
554 | - if (!$fp) { |
|
552 | + $ctx = stream_context_create($params); |
|
553 | + $fp = @fopen($url, 'rb', false, $ctx); |
|
554 | + if (!$fp) { |
|
555 | 555 | ini_set('track_errors',$track); |
556 | 556 | throw new \Exception("HTTP Error calling Kannel API - fopen Error: $php_errormsg"); |
557 | - } |
|
558 | - $response = @stream_get_contents($fp); |
|
559 | - if ($response === false) { |
|
557 | + } |
|
558 | + $response = @stream_get_contents($fp); |
|
559 | + if ($response === false) { |
|
560 | 560 | ini_set('track_errors',$track); |
561 | 561 | throw new \Exception("HTTP Error calling Kannel API - stream Error: $php_errormsg"); |
562 | - } |
|
563 | - ini_set('track_errors',$track); |
|
564 | - return $response; |
|
562 | + } |
|
563 | + ini_set('track_errors',$track); |
|
564 | + return $response; |
|
565 | 565 | } else { |
566 | - throw new \Exception("Kannel requires PHP5 with cURL or HTTP stream support"); |
|
566 | + throw new \Exception("Kannel requires PHP5 with cURL or HTTP stream support"); |
|
567 | 567 | } |
568 | - } |
|
569 | - |
|
570 | - /** |
|
571 | - * Does the server/HTTP wrapper support SSL |
|
572 | - * |
|
573 | - * This is a best guess effort, some servers have weird setups where even |
|
574 | - * though cURL is compiled with SSL support is still fails to make |
|
575 | - * any requests. |
|
576 | - * |
|
577 | - * @return bool True if SSL is supported |
|
578 | - * @author Martin Steel |
|
579 | - */ |
|
580 | - protected function sslSupport() { |
|
568 | + } |
|
569 | + |
|
570 | + /** |
|
571 | + * Does the server/HTTP wrapper support SSL |
|
572 | + * |
|
573 | + * This is a best guess effort, some servers have weird setups where even |
|
574 | + * though cURL is compiled with SSL support is still fails to make |
|
575 | + * any requests. |
|
576 | + * |
|
577 | + * @return bool True if SSL is supported |
|
578 | + * @author Martin Steel |
|
579 | + */ |
|
580 | + protected function sslSupport() { |
|
581 | 581 | $ssl = false; |
582 | 582 | // See if PHP is compiled with cURL |
583 | 583 | if (extension_loaded('curl')) { |
584 | - $version = curl_version(); |
|
585 | - $ssl = ($version['features'] & CURL_VERSION_SSL) ? true : false; |
|
584 | + $version = curl_version(); |
|
585 | + $ssl = ($version['features'] & CURL_VERSION_SSL) ? true : false; |
|
586 | 586 | } elseif (extension_loaded('openssl')) { |
587 | - $ssl = true; |
|
587 | + $ssl = true; |
|
588 | 588 | } |
589 | 589 | return $ssl; |
590 | - } |
|
591 | - |
|
592 | - /** |
|
593 | - * Log some XML, tidily if possible, in the PHP error log |
|
594 | - * |
|
595 | - * @param string log_msg The log message to prepend to the XML |
|
596 | - * @param string xml An XML formatted string |
|
597 | - * |
|
598 | - * @return void |
|
599 | - * @author Martin Steel |
|
600 | - */ |
|
601 | - protected function logXML($log_msg, $xml) { |
|
590 | + } |
|
591 | + |
|
592 | + /** |
|
593 | + * Log some XML, tidily if possible, in the PHP error log |
|
594 | + * |
|
595 | + * @param string log_msg The log message to prepend to the XML |
|
596 | + * @param string xml An XML formatted string |
|
597 | + * |
|
598 | + * @return void |
|
599 | + * @author Martin Steel |
|
600 | + */ |
|
601 | + protected function logXML($log_msg, $xml) { |
|
602 | 602 | // Tidy if possible |
603 | 603 | if (class_exists('tidy')) { |
604 | - $tidy = new \tidy; |
|
605 | - $config = array( |
|
606 | - 'indent' => true, |
|
607 | - 'input-xml' => true, |
|
608 | - 'output-xml' => true, |
|
609 | - 'wrap' => 200 |
|
610 | - ); |
|
611 | - $tidy->parseString($xml, $config, 'utf8'); |
|
612 | - $tidy->cleanRepair(); |
|
613 | - $xml = $tidy; |
|
604 | + $tidy = new \tidy; |
|
605 | + $config = array( |
|
606 | + 'indent' => true, |
|
607 | + 'input-xml' => true, |
|
608 | + 'output-xml' => true, |
|
609 | + 'wrap' => 200 |
|
610 | + ); |
|
611 | + $tidy->parseString($xml, $config, 'utf8'); |
|
612 | + $tidy->cleanRepair(); |
|
613 | + $xml = $tidy; |
|
614 | 614 | } |
615 | 615 | // Output |
616 | 616 | error_log("Kannel $log_msg: $xml"); |
617 | - } |
|
618 | - |
|
619 | - /** |
|
620 | - * Check if an array is associative |
|
621 | - * |
|
622 | - * @param array $array Array to check |
|
623 | - * @return bool |
|
624 | - * @author Martin Steel |
|
625 | - */ |
|
626 | - protected function is_assoc($array) { |
|
617 | + } |
|
618 | + |
|
619 | + /** |
|
620 | + * Check if an array is associative |
|
621 | + * |
|
622 | + * @param array $array Array to check |
|
623 | + * @return bool |
|
624 | + * @author Martin Steel |
|
625 | + */ |
|
626 | + protected function is_assoc($array) { |
|
627 | 627 | return (bool)count(array_filter(array_keys($array), 'is_string')); |
628 | - } |
|
628 | + } |
|
629 | 629 | |
630 | - /** |
|
631 | - * Check if a number is a valid MSISDN |
|
632 | - * |
|
633 | - * @param string $val Value to check |
|
634 | - * @return bool True if valid MSISDN |
|
635 | - * @author James Inman |
|
636 | - * @since 1.3.0 |
|
637 | - * @todo Take an optional country code and check that the number starts with it |
|
638 | - */ |
|
639 | - public static function is_valid_msisdn($val) { |
|
630 | + /** |
|
631 | + * Check if a number is a valid MSISDN |
|
632 | + * |
|
633 | + * @param string $val Value to check |
|
634 | + * @return bool True if valid MSISDN |
|
635 | + * @author James Inman |
|
636 | + * @since 1.3.0 |
|
637 | + * @todo Take an optional country code and check that the number starts with it |
|
638 | + */ |
|
639 | + public static function is_valid_msisdn($val) { |
|
640 | 640 | return preg_match( '/^[1-9][0-9]{7,12}$/', $val ); |
641 | - } |
|
641 | + } |
|
642 | 642 | |
643 | 643 | } |
@@ -9,7 +9,7 @@ discard block |
||
9 | 9 | * @version 1.3.0 |
10 | 10 | */ |
11 | 11 | |
12 | -if ( !class_exists('KannelException') ) { |
|
12 | +if (!class_exists('KannelException')) { |
|
13 | 13 | require_once('exception.php'); |
14 | 14 | } |
15 | 15 | |
@@ -24,25 +24,25 @@ discard block |
||
24 | 24 | /* |
25 | 25 | * Version of this class |
26 | 26 | */ |
27 | - const VERSION = '1.3.1'; |
|
27 | + const VERSION = '1.3.1'; |
|
28 | 28 | |
29 | 29 | /** |
30 | 30 | * All Kannel API calls start with BASE_URL |
31 | 31 | * @author Martin Steel |
32 | 32 | */ |
33 | - const API_BASE_URL = 'api.kannelsms.com/xml/'; |
|
33 | + const API_BASE_URL = 'api.kannelsms.com/xml/'; |
|
34 | 34 | |
35 | 35 | /** |
36 | 36 | * string to append to API_BASE_URL to check authentication |
37 | 37 | * @author Martin Steel |
38 | 38 | */ |
39 | - const API_AUTH_METHOD = 'authenticate'; |
|
39 | + const API_AUTH_METHOD = 'authenticate'; |
|
40 | 40 | |
41 | 41 | /** |
42 | 42 | * string to append to API_BASE_URL for sending SMS |
43 | 43 | * @author Martin Steel |
44 | 44 | */ |
45 | - const API_SMS_METHOD = 'sms'; |
|
45 | + const API_SMS_METHOD = 'sms'; |
|
46 | 46 | |
47 | 47 | /** |
48 | 48 | * string to append to API_BASE_URL for checking message credit |
@@ -258,13 +258,13 @@ discard block |
||
258 | 258 | $err_no = null; |
259 | 259 | $err_desc = null; |
260 | 260 | |
261 | - foreach($resp_doc->documentElement->childNodes AS $doc_child) { |
|
262 | - switch(strtolower($doc_child->nodeName)) { |
|
261 | + foreach ($resp_doc->documentElement->childNodes AS $doc_child) { |
|
262 | + switch (strtolower($doc_child->nodeName)) { |
|
263 | 263 | case 'sms_resp': |
264 | 264 | $resp = array(); |
265 | 265 | $wrapper_id = null; |
266 | - foreach($doc_child->childNodes AS $resp_node) { |
|
267 | - switch(strtolower($resp_node->nodeName)) { |
|
266 | + foreach ($doc_child->childNodes AS $resp_node) { |
|
267 | + switch (strtolower($resp_node->nodeName)) { |
|
268 | 268 | case 'messageid': |
269 | 269 | $resp['id'] = $resp_node->nodeValue; |
270 | 270 | break; |
@@ -279,7 +279,7 @@ discard block |
||
279 | 279 | break; |
280 | 280 | } |
281 | 281 | } |
282 | - if( array_key_exists('error_code', $resp ) ) |
|
282 | + if (array_key_exists('error_code', $resp)) |
|
283 | 283 | { |
284 | 284 | $resp['success'] = 0; |
285 | 285 | } else { |
@@ -415,7 +415,7 @@ discard block |
||
415 | 415 | throw new KannelException($err_desc, $err_no); |
416 | 416 | } |
417 | 417 | |
418 | - return array( 'symbol' => $symbol, 'balance' => $balance, 'code' => $code ); |
|
418 | + return array('symbol' => $symbol, 'balance' => $balance, 'code' => $code); |
|
419 | 419 | } |
420 | 420 | |
421 | 421 | /** |
@@ -480,14 +480,14 @@ discard block |
||
480 | 480 | $this->logXML("API $method Request XML", $data); |
481 | 481 | } |
482 | 482 | |
483 | - if( isset( $this->ssl ) ) { |
|
483 | + if (isset($this->ssl)) { |
|
484 | 484 | $ssl = $this->ssl; |
485 | 485 | } else { |
486 | 486 | $ssl = $this->sslSupport(); |
487 | 487 | } |
488 | 488 | |
489 | 489 | $url = $ssl ? 'https://' : 'http://'; |
490 | - $url .= self::API_BASE_URL . $method; |
|
490 | + $url .= self::API_BASE_URL.$method; |
|
491 | 491 | |
492 | 492 | $response = $this->xmlPost($url, $data); |
493 | 493 | |
@@ -509,12 +509,12 @@ discard block |
||
509 | 509 | * @author Martin Steel |
510 | 510 | */ |
511 | 511 | protected function xmlPost($url, $data) { |
512 | - if(extension_loaded('curl')) { |
|
512 | + if (extension_loaded('curl')) { |
|
513 | 513 | $ch = curl_init($url); |
514 | 514 | curl_setopt($ch, CURLOPT_POST, 1); |
515 | 515 | curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
516 | 516 | curl_setopt($ch, CURLOPT_HTTPHEADER, Array("Content-Type: text/xml")); |
517 | - curl_setopt($ch, CURLOPT_USERAGENT, 'Kannel PHP Wrapper/1.0' . self::VERSION); |
|
517 | + curl_setopt($ch, CURLOPT_USERAGENT, 'Kannel PHP Wrapper/1.0'.self::VERSION); |
|
518 | 518 | curl_setopt($ch, CURLOPT_POSTFIELDS, $data); |
519 | 519 | if (isset($this->proxy_host) && isset($this->proxy_port)) { |
520 | 520 | curl_setopt($ch, CURLOPT_PROXY, $this->proxy_host); |
@@ -525,9 +525,9 @@ discard block |
||
525 | 525 | $info = curl_getinfo($ch); |
526 | 526 | |
527 | 527 | if ($response === false || $info['http_code'] != 200) { |
528 | - throw new \Exception('HTTP Error calling Kannel API - HTTP Status: ' . $info['http_code'] . ' - cURL Erorr: ' . curl_error($ch)); |
|
528 | + throw new \Exception('HTTP Error calling Kannel API - HTTP Status: '.$info['http_code'].' - cURL Erorr: '.curl_error($ch)); |
|
529 | 529 | } elseif (curl_errno($ch) > 0) { |
530 | - throw new \Exception('HTTP Error calling Kannel API - cURL Error: ' . curl_error($ch)); |
|
530 | + throw new \Exception('HTTP Error calling Kannel API - cURL Error: '.curl_error($ch)); |
|
531 | 531 | } |
532 | 532 | |
533 | 533 | curl_close($ch); |
@@ -536,31 +536,31 @@ discard block |
||
536 | 536 | } elseif (function_exists('stream_get_contents')) { |
537 | 537 | // Enable error Track Errors |
538 | 538 | $track = ini_get('track_errors'); |
539 | - ini_set('track_errors',true); |
|
539 | + ini_set('track_errors', true); |
|
540 | 540 | |
541 | 541 | $params = array('http' => array( |
542 | 542 | 'method' => 'POST', |
543 | - 'header' => "Content-Type: text/xml\r\nUser-Agent: mediaburst PHP Wrapper/" . self::VERSION . "\r\n", |
|
543 | + 'header' => "Content-Type: text/xml\r\nUser-Agent: mediaburst PHP Wrapper/".self::VERSION."\r\n", |
|
544 | 544 | 'content' => $data |
545 | 545 | )); |
546 | 546 | |
547 | 547 | if (isset($this->proxy_host) && isset($this->proxy_port)) { |
548 | - $params['http']['proxy'] = 'tcp://'.$this->proxy_host . ':' . $this->proxy_port; |
|
548 | + $params['http']['proxy'] = 'tcp://'.$this->proxy_host.':'.$this->proxy_port; |
|
549 | 549 | $params['http']['request_fulluri'] = True; |
550 | 550 | } |
551 | 551 | |
552 | 552 | $ctx = stream_context_create($params); |
553 | 553 | $fp = @fopen($url, 'rb', false, $ctx); |
554 | 554 | if (!$fp) { |
555 | - ini_set('track_errors',$track); |
|
555 | + ini_set('track_errors', $track); |
|
556 | 556 | throw new \Exception("HTTP Error calling Kannel API - fopen Error: $php_errormsg"); |
557 | 557 | } |
558 | 558 | $response = @stream_get_contents($fp); |
559 | 559 | if ($response === false) { |
560 | - ini_set('track_errors',$track); |
|
560 | + ini_set('track_errors', $track); |
|
561 | 561 | throw new \Exception("HTTP Error calling Kannel API - stream Error: $php_errormsg"); |
562 | 562 | } |
563 | - ini_set('track_errors',$track); |
|
563 | + ini_set('track_errors', $track); |
|
564 | 564 | return $response; |
565 | 565 | } else { |
566 | 566 | throw new \Exception("Kannel requires PHP5 with cURL or HTTP stream support"); |
@@ -624,7 +624,7 @@ discard block |
||
624 | 624 | * @author Martin Steel |
625 | 625 | */ |
626 | 626 | protected function is_assoc($array) { |
627 | - return (bool)count(array_filter(array_keys($array), 'is_string')); |
|
627 | + return (bool) count(array_filter(array_keys($array), 'is_string')); |
|
628 | 628 | } |
629 | 629 | |
630 | 630 | /** |
@@ -637,7 +637,7 @@ discard block |
||
637 | 637 | * @todo Take an optional country code and check that the number starts with it |
638 | 638 | */ |
639 | 639 | public static function is_valid_msisdn($val) { |
640 | - return preg_match( '/^[1-9][0-9]{7,12}$/', $val ); |
|
640 | + return preg_match('/^[1-9][0-9]{7,12}$/', $val); |
|
641 | 641 | } |
642 | 642 | |
643 | 643 | } |
@@ -213,7 +213,8 @@ |
||
213 | 213 | /** |
214 | 214 | * Returns a meeting "join" URL |
215 | 215 | * @param string The name of the meeting (usually the course code) |
216 | - * @return mixed The URL to join the meeting, or false on error |
|
216 | + * @param false|string $meetingId |
|
217 | + * @return false|null The URL to join the meeting, or false on error |
|
217 | 218 | * @todo implement moderator pass |
218 | 219 | * @assert ('') === false |
219 | 220 | * @assert ('abcdefghijklmnopqrstuvwxyzabcdefghijklmno') === false |
@@ -49,9 +49,9 @@ discard block |
||
49 | 49 | $om_user = $plugin->get('user'); |
50 | 50 | $om_pass = $plugin->get('pass'); |
51 | 51 | $accessUrl = api_get_access_url($_configuration['access_url']); |
52 | - $this->externalType = substr($accessUrl['url'], strpos($accessUrl['url'], '://')+3, -1); |
|
52 | + $this->externalType = substr($accessUrl['url'], strpos($accessUrl['url'], '://') + 3, -1); |
|
53 | 53 | if (strcmp($this->externalType, 'localhost') == 0) { |
54 | - $this->externalType = substr(api_get_path(WEB_PATH), strpos(api_get_path(WEB_PATH), '://')+3, -1); |
|
54 | + $this->externalType = substr(api_get_path(WEB_PATH), strpos(api_get_path(WEB_PATH), '://') + 3, -1); |
|
55 | 55 | } |
56 | 56 | $this->externalType = 'chamilolms.'.$this->externalType; |
57 | 57 | $this->table = \Database::get_main_table('plugin_openmeetings'); |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | // This fills the following attributes: status, name, comment, chamiloCourseId, chamiloSessionId |
162 | 162 | $room = new Room(); |
163 | 163 | $room->loadRoomId($meetingData['room_id']); |
164 | - $roomArray = (array)$room; |
|
164 | + $roomArray = (array) $room; |
|
165 | 165 | $roomArray['SID'] = $this->sessionId; |
166 | 166 | $roomId = $this->gateway->updateRoomWithModeration($room); |
167 | 167 | if ($roomId != $meetingData['room_id']) { |
@@ -176,7 +176,7 @@ discard block |
||
176 | 176 | $room->SID = $this->sessionId; |
177 | 177 | $room->name = $this->roomName; |
178 | 178 | //$room->roomtypes_id = $room->roomtypes_id; |
179 | - $room->comment = urlencode(get_lang('Course').': ' . $params['meeting_name'] . ' - '.$_configuration['software_name']); |
|
179 | + $room->comment = urlencode(get_lang('Course').': '.$params['meeting_name'].' - '.$_configuration['software_name']); |
|
180 | 180 | //$room->numberOfPartizipants = $room->numberOfPartizipants; |
181 | 181 | $room->ispublic = $room->getString('isPublic', 'false'); |
182 | 182 | //$room->appointment = $room->getString('appointment'); |
@@ -200,7 +200,7 @@ discard block |
||
200 | 200 | $params['room_id'] = $roomId; |
201 | 201 | $params['c_id'] = api_get_course_int_id(); |
202 | 202 | $params['session_id'] = api_get_session_id(); |
203 | - $params['record'] = ($room->allowRecording?1:0); |
|
203 | + $params['record'] = ($room->allowRecording ? 1 : 0); |
|
204 | 204 | |
205 | 205 | $id = \Database::insert($this->table, $params); |
206 | 206 | |
@@ -238,7 +238,7 @@ discard block |
||
238 | 238 | } |
239 | 239 | $params = array('room_id' => $meetingData['room_id']); |
240 | 240 | $returnVal = $this->setUserObjectAndGenerateRoomHashByURLAndRecFlag($params); |
241 | - $iframe = $this->url . "/?" ."secureHash=" . $returnVal; |
|
241 | + $iframe = $this->url."/?"."secureHash=".$returnVal; |
|
242 | 242 | printf("<iframe src='%s' width='%s' height = '%s' />", $iframe, "100%", 640); |
243 | 243 | } |
244 | 244 | |
@@ -346,7 +346,7 @@ discard block |
||
346 | 346 | $userId = $_SESSION['_user']['user_id']; |
347 | 347 | $systemType = 'Chamilo'; |
348 | 348 | $room_id = $params['room_id']; |
349 | - $becomeModerator = ( $this->isTeacher() ? 1 : 0 ); |
|
349 | + $becomeModerator = ($this->isTeacher() ? 1 : 0); |
|
350 | 350 | $allowRecording = 1; //Provisional |
351 | 351 | |
352 | 352 | $urlWsdl = $this->url."/services/UserService?wsdl"; |
@@ -420,7 +420,7 @@ discard block |
||
420 | 420 | error_log(__FILE__.'+'.__LINE__.' Meetings found: '.print_r($meetingDb, 1)); |
421 | 421 | $remoteMeeting = array(); |
422 | 422 | $meetingDb['created_at'] = api_get_local_time($meetingDb['created_at']); |
423 | - $meetingDb['closed_at'] = (!empty($meetingDb['closed_at']) ? api_get_local_time($meetingDb['closed_at']):''); |
|
423 | + $meetingDb['closed_at'] = (!empty($meetingDb['closed_at']) ? api_get_local_time($meetingDb['closed_at']) : ''); |
|
424 | 424 | // Fixed value for now |
425 | 425 | $meetingDb['participantCount'] = 40; |
426 | 426 | $rec = $this->gateway->getFlvRecordingByRoomId($meetingDb['room_id']); |
@@ -436,7 +436,7 @@ discard block |
||
436 | 436 | \Display::url('[.avi]', $link2, array('target' => '_blank')); |
437 | 437 | |
438 | 438 | } |
439 | - $item['show_links'] = implode('<br />', $links); |
|
439 | + $item['show_links'] = implode('<br />', $links); |
|
440 | 440 | |
441 | 441 | // The following code is currently commented because the web service |
442 | 442 | // says this is not allowed by the SOAP user. |
@@ -486,7 +486,7 @@ discard block |
||
486 | 486 | $remoteMeeting = $current_room; |
487 | 487 | */ |
488 | 488 | |
489 | - if (empty( $remoteMeeting )) { |
|
489 | + if (empty($remoteMeeting)) { |
|
490 | 490 | /* |
491 | 491 | error_log(__FILE__.'+'.__LINE__.' Empty remote Meeting for now'); |
492 | 492 | if ($meetingDb['status'] == 1 && $this->isTeacher()) { |
@@ -126,7 +126,7 @@ discard block |
||
126 | 126 | return false; |
127 | 127 | } |
128 | 128 | } |
129 | - */ |
|
129 | + */ |
|
130 | 130 | |
131 | 131 | /* |
132 | 132 | * Creating a Room for the meeting |
@@ -256,10 +256,10 @@ discard block |
||
256 | 256 | return true; |
257 | 257 | } |
258 | 258 | |
259 | - /** |
|
260 | - * Gets the password for a specific meeting for the current user |
|
261 | - * @return string A moderator password if user is teacher, or the course code otherwise |
|
262 | - */ |
|
259 | + /** |
|
260 | + * Gets the password for a specific meeting for the current user |
|
261 | + * @return string A moderator password if user is teacher, or the course code otherwise |
|
262 | + */ |
|
263 | 263 | public function getMeetingUserPassword() |
264 | 264 | { |
265 | 265 | if ($this->isTeacher()) { |
@@ -538,7 +538,7 @@ discard block |
||
538 | 538 | // |
539 | 539 | // } |
540 | 540 | // |
541 | - //$item['created_at'] = api_convert_and_format_date($meetingDb['created_at']); |
|
541 | + //$item['created_at'] = api_convert_and_format_date($meetingDb['created_at']); |
|
542 | 542 | // //created_at |
543 | 543 | // |
544 | 544 | // $item['publish_url'] = api_get_self().'?action=publish&id='.$meetingDb['id']; |
@@ -36,6 +36,11 @@ |
||
36 | 36 | private $_pass; |
37 | 37 | private $_url; |
38 | 38 | |
39 | + /** |
|
40 | + * @param string $host |
|
41 | + * @param string $user |
|
42 | + * @param string $pass |
|
43 | + */ |
|
39 | 44 | public function __construct($host, $user, $pass) |
40 | 45 | { |
41 | 46 | $this->_user = urlencode($user); |
@@ -47,8 +47,8 @@ discard block |
||
47 | 47 | $this->rest = new OpenMeetingsRestService(); |
48 | 48 | $err = $this->rest->getError(); |
49 | 49 | if ($err) { |
50 | - error_log('Constructor error: ' . $err); |
|
51 | - error_log('Debug: ' . $this->rest->getDebug());; |
|
50 | + error_log('Constructor error: '.$err); |
|
51 | + error_log('Debug: '.$this->rest->getDebug()); ; |
|
52 | 52 | exit(); |
53 | 53 | } |
54 | 54 | } |
@@ -59,7 +59,7 @@ discard block |
||
59 | 59 | */ |
60 | 60 | public function getRestUrl($name) |
61 | 61 | { |
62 | - return $this->getUrl() . "/services/" . $name . "/"; |
|
62 | + return $this->getUrl()."/services/".$name."/"; |
|
63 | 63 | } |
64 | 64 | |
65 | 65 | /** |
@@ -89,30 +89,30 @@ discard block |
||
89 | 89 | public function loginUser() |
90 | 90 | { |
91 | 91 | $returnValue = 0; |
92 | - $response = $this->rest->call($this->getRestUrl("UserService") . "getSession", "session_id"); |
|
92 | + $response = $this->rest->call($this->getRestUrl("UserService")."getSession", "session_id"); |
|
93 | 93 | |
94 | 94 | if ($this->rest->getError()) { |
95 | 95 | error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($response, 1)); |
96 | 96 | } else { |
97 | 97 | $err = $this->rest->getError(); |
98 | 98 | if ($err) { |
99 | - error_log('Error: ' . $err); |
|
99 | + error_log('Error: '.$err); |
|
100 | 100 | } else { |
101 | 101 | //error_log('getSession returned '.$response. ' - Storing as sessionId'); |
102 | 102 | $this->sessionId = $response; |
103 | 103 | |
104 | 104 | $url = $this->getRestUrl("UserService") |
105 | 105 | . "loginUser?" |
106 | - . "SID=" . $this->sessionId |
|
107 | - . "&username=" . $this->_user |
|
108 | - . "&userpass=" . $this->_pass; |
|
106 | + . "SID=".$this->sessionId |
|
107 | + . "&username=".$this->_user |
|
108 | + . "&userpass=".$this->_pass; |
|
109 | 109 | $result = $this->rest->call($url); |
110 | 110 | if ($this->rest->getError()) { |
111 | 111 | error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
112 | 112 | } else { |
113 | 113 | $err = $this->rest->getError(); |
114 | 114 | if ($err) { |
115 | - error_log('Error '. $err); |
|
115 | + error_log('Error '.$err); |
|
116 | 116 | } else { |
117 | 117 | $returnValue = $result; |
118 | 118 | } |
@@ -135,8 +135,8 @@ discard block |
||
135 | 135 | { |
136 | 136 | $err = $this->rest->getError(); |
137 | 137 | if ($err) { |
138 | - error_log('Constructor error: ' . $err); |
|
139 | - error_log('Debug: ' . $this->rest->getDebug()); |
|
138 | + error_log('Constructor error: '.$err); |
|
139 | + error_log('Debug: '.$this->rest->getDebug()); |
|
140 | 140 | exit(); |
141 | 141 | } |
142 | 142 | |
@@ -146,17 +146,17 @@ discard block |
||
146 | 146 | } |
147 | 147 | |
148 | 148 | $url = $this->getRestUrl($this->getRestUrl("RoomService") |
149 | - . "updateRoomWithModeration?SID=" . $this->sessionId |
|
150 | - . "&room_id=" . $room->room_id |
|
151 | - . "&name=" . urlencode($room->name) |
|
152 | - . "&roomtypes_id=" . $room->roomtypes_id |
|
153 | - . "&comment=" . $room->comment |
|
154 | - . "&numberOfPartizipants=" . $room->numberOfPartizipants |
|
149 | + . "updateRoomWithModeration?SID=".$this->sessionId |
|
150 | + . "&room_id=".$room->room_id |
|
151 | + . "&name=".urlencode($room->name) |
|
152 | + . "&roomtypes_id=".$room->roomtypes_id |
|
153 | + . "&comment=".$room->comment |
|
154 | + . "&numberOfPartizipants=".$room->numberOfPartizipants |
|
155 | 155 | . "&ispublic=false" |
156 | 156 | . "&appointment=false" |
157 | 157 | . "&isDemoRoom=false" |
158 | 158 | . "&demoTime=0" |
159 | - . "&isModeratedRoom=" . $this->var_to_str($isModeratedRoom)); |
|
159 | + . "&isModeratedRoom=".$this->var_to_str($isModeratedRoom)); |
|
160 | 160 | //error_log($url); |
161 | 161 | $result = $this->rest->call($url); |
162 | 162 | |
@@ -165,14 +165,14 @@ discard block |
||
165 | 165 | } else { |
166 | 166 | $err = $this->rest->getError(); |
167 | 167 | if ($err) { |
168 | - error_log('Error: ' . $err); |
|
168 | + error_log('Error: '.$err); |
|
169 | 169 | } else { |
170 | 170 | // echo '<h2>Result</h2><pre>'; print_r($result["return"]); echo '</pre>'; |
171 | 171 | //error_log('Room updated successfully '.print_r($result,1)); |
172 | 172 | return $result; |
173 | 173 | } |
174 | 174 | } |
175 | - return - 1; |
|
175 | + return -1; |
|
176 | 176 | } |
177 | 177 | |
178 | 178 | /** |
@@ -188,13 +188,13 @@ discard block |
||
188 | 188 | { |
189 | 189 | $result = $this->rest->call($this->getRestUrl("UserService") |
190 | 190 | . 'setUserObjectAndGenerateRecordingHashByURL?' |
191 | - . 'SID=' . $this->sessionId |
|
192 | - . '&username=' . urlencode($username) |
|
193 | - . '&firstname=' . urlencode($firstname) |
|
194 | - . '&lastname=' . urlencode($lastname) |
|
195 | - . '&externalUserId=' . $userId |
|
196 | - . '&externalUserType=' . urlencode($systemType) |
|
197 | - . '&recording_id=' . $recording_id, 'return'); |
|
191 | + . 'SID='.$this->sessionId |
|
192 | + . '&username='.urlencode($username) |
|
193 | + . '&firstname='.urlencode($firstname) |
|
194 | + . '&lastname='.urlencode($lastname) |
|
195 | + . '&externalUserId='.$userId |
|
196 | + . '&externalUserType='.urlencode($systemType) |
|
197 | + . '&recording_id='.$recording_id, 'return'); |
|
198 | 198 | |
199 | 199 | if ($result->fault) { |
200 | 200 | error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
@@ -206,7 +206,7 @@ discard block |
||
206 | 206 | return $result; |
207 | 207 | } |
208 | 208 | } |
209 | - return - 1; |
|
209 | + return -1; |
|
210 | 210 | } |
211 | 211 | |
212 | 212 | /** |
@@ -226,28 +226,28 @@ discard block |
||
226 | 226 | { |
227 | 227 | $err = $this->rest->getError(); |
228 | 228 | if ($err) { |
229 | - error_log('Constructor error: ' . $err); |
|
230 | - error_log('Debug: ' . $this->rest->getDebug());; |
|
229 | + error_log('Constructor error: '.$err); |
|
230 | + error_log('Debug: '.$this->rest->getDebug()); ; |
|
231 | 231 | exit(); |
232 | 232 | } |
233 | 233 | |
234 | 234 | $result = $this->rest->call($this->getRestUrl("UserService") |
235 | 235 | . "setUserObjectAndGenerateRoomHashByURLAndRecFlag?" |
236 | - . "SID=" . $this->sessionId |
|
237 | - . "&username=" . urlencode($username) |
|
238 | - . "&firstname=" . urlencode($firstname) |
|
239 | - . "&lastname=" . urlencode($lastname) |
|
240 | - . "&profilePictureUrl=" . urlencode($profilePictureUrl) |
|
241 | - . "&email=" . urlencode($email) |
|
242 | - . "&externalUserId=" . urlencode($userId) |
|
243 | - . "&externalUserType=" . urlencode($systemType) |
|
244 | - . "&room_id=" . urlencode($room_id) |
|
245 | - . "&becomeModeratorAsInt=" . $becomeModerator |
|
236 | + . "SID=".$this->sessionId |
|
237 | + . "&username=".urlencode($username) |
|
238 | + . "&firstname=".urlencode($firstname) |
|
239 | + . "&lastname=".urlencode($lastname) |
|
240 | + . "&profilePictureUrl=".urlencode($profilePictureUrl) |
|
241 | + . "&email=".urlencode($email) |
|
242 | + . "&externalUserId=".urlencode($userId) |
|
243 | + . "&externalUserType=".urlencode($systemType) |
|
244 | + . "&room_id=".urlencode($room_id) |
|
245 | + . "&becomeModeratorAsInt=".$becomeModerator |
|
246 | 246 | . "&showAudioVideoTestAsInt=1" |
247 | - . "&allowRecording=" . $this->var_to_str($allowRecording)); |
|
247 | + . "&allowRecording=".$this->var_to_str($allowRecording)); |
|
248 | 248 | |
249 | 249 | if ($result->fault) { |
250 | - error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result,1)); |
|
250 | + error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
|
251 | 251 | } else { |
252 | 252 | $err = $this->rest->getError(); |
253 | 253 | if ($err) { |
@@ -257,7 +257,7 @@ discard block |
||
257 | 257 | return $result; |
258 | 258 | } |
259 | 259 | } |
260 | - return - 1; |
|
260 | + return -1; |
|
261 | 261 | } |
262 | 262 | |
263 | 263 | /** |
@@ -268,15 +268,15 @@ discard block |
||
268 | 268 | { |
269 | 269 | $err = $this->rest->getError(); |
270 | 270 | if ($err) { |
271 | - error_log('Constructor error: ' . $err); |
|
272 | - error_log('Debug: ' . $this->rest->getDebug()); |
|
271 | + error_log('Constructor error: '.$err); |
|
272 | + error_log('Debug: '.$this->rest->getDebug()); |
|
273 | 273 | exit(); |
274 | 274 | } |
275 | 275 | $url = $this->getRestUrl("RoomService")."deleteRoom?SID=".$this->sessionId."&rooms_id=".$openmeetings->room_id; |
276 | 276 | $result = $this->rest->call($url); |
277 | 277 | |
278 | 278 | if ($result->fault) { |
279 | - error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result,1)); |
|
279 | + error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
|
280 | 280 | } else { |
281 | 281 | $err = $this->rest->getError(); |
282 | 282 | if ($err) { |
@@ -287,7 +287,7 @@ discard block |
||
287 | 287 | return $result; |
288 | 288 | } |
289 | 289 | } |
290 | - return - 1; |
|
290 | + return -1; |
|
291 | 291 | } |
292 | 292 | |
293 | 293 | /** |
@@ -297,20 +297,20 @@ discard block |
||
297 | 297 | { |
298 | 298 | $result = $this->rest->call($this->getRestUrl("UserService") |
299 | 299 | . "setUserObjectAndGenerateRoomHash?" |
300 | - . "SID=" . $this->sessionId |
|
301 | - . "&username=" . urlencode($username) |
|
302 | - . "&firstname=" . urlencode($firstname) |
|
303 | - . "&lastname=" . urlencode($lastname) |
|
304 | - . "&profilePictureUrl=" . urlencode($profilePictureUrl) |
|
305 | - . "&email=" . urlencode($email) |
|
306 | - . "&externalUserId=" . urlencode($externalUserId) |
|
307 | - . "&externalUserType=" . urlencode($externalUserType) |
|
308 | - . "&room_id=" . $room_id |
|
309 | - . "&becomeModeratorAsInt=" . $becomeModeratorAsInt |
|
310 | - . "&showAudioVideoTestAsInt=" . $showAudioVideoTestAsInt); |
|
300 | + . "SID=".$this->sessionId |
|
301 | + . "&username=".urlencode($username) |
|
302 | + . "&firstname=".urlencode($firstname) |
|
303 | + . "&lastname=".urlencode($lastname) |
|
304 | + . "&profilePictureUrl=".urlencode($profilePictureUrl) |
|
305 | + . "&email=".urlencode($email) |
|
306 | + . "&externalUserId=".urlencode($externalUserId) |
|
307 | + . "&externalUserType=".urlencode($externalUserType) |
|
308 | + . "&room_id=".$room_id |
|
309 | + . "&becomeModeratorAsInt=".$becomeModeratorAsInt |
|
310 | + . "&showAudioVideoTestAsInt=".$showAudioVideoTestAsInt); |
|
311 | 311 | |
312 | 312 | if ($result->getError()) { |
313 | - error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result,1)); |
|
313 | + error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
|
314 | 314 | } else { |
315 | 315 | $err = $this->rest->getError(); |
316 | 316 | if ($err) { |
@@ -320,7 +320,7 @@ discard block |
||
320 | 320 | return $result; |
321 | 321 | } |
322 | 322 | } |
323 | - return - 1; |
|
323 | + return -1; |
|
324 | 324 | } |
325 | 325 | |
326 | 326 | /** |
@@ -338,29 +338,29 @@ discard block |
||
338 | 338 | } |
339 | 339 | $url = $this->getRestUrl("RoomService") |
340 | 340 | . $service.'?' |
341 | - . 'SID=' . $room->SID |
|
342 | - . '&name=' . $room->name |
|
343 | - . '&roomtypes_id=' . $room->roomtypes_id |
|
344 | - . '&comment='. $room->comment |
|
345 | - . '&numberOfPartizipants=' . $room->numberOfPartizipants |
|
346 | - . '&ispublic=' . $this->var_to_str($room->ispublic) |
|
347 | - . '&appointment=' . $this->var_to_str($room->appointment) |
|
348 | - . '&isDemoRoom=' . $this->var_to_str($room->isDemoRoom) |
|
349 | - . '&demoTime=' . $room->demoTime |
|
350 | - . '&isModeratedRoom=' . $this->var_to_str($room->isModeratedRoom) |
|
351 | - . '&externalRoomType=' . $room->externalRoomType; |
|
341 | + . 'SID='.$room->SID |
|
342 | + . '&name='.$room->name |
|
343 | + . '&roomtypes_id='.$room->roomtypes_id |
|
344 | + . '&comment='.$room->comment |
|
345 | + . '&numberOfPartizipants='.$room->numberOfPartizipants |
|
346 | + . '&ispublic='.$this->var_to_str($room->ispublic) |
|
347 | + . '&appointment='.$this->var_to_str($room->appointment) |
|
348 | + . '&isDemoRoom='.$this->var_to_str($room->isDemoRoom) |
|
349 | + . '&demoTime='.$room->demoTime |
|
350 | + . '&isModeratedRoom='.$this->var_to_str($room->isModeratedRoom) |
|
351 | + . '&externalRoomType='.$room->externalRoomType; |
|
352 | 352 | if ($room->allowRecording) { |
353 | - $url .= '&allowUserQuestions=' . $this->var_to_str($room->allowUserQuestions) |
|
354 | - . '&isAudioOnly=' . $this->var_to_str($room->isAudioOnly) |
|
355 | - . '&waitForRecording=' . $this->var_to_str($room->waitForRecording) |
|
356 | - . '&allowRecording=' . $this->var_to_str($room->allowRecording); |
|
353 | + $url .= '&allowUserQuestions='.$this->var_to_str($room->allowUserQuestions) |
|
354 | + . '&isAudioOnly='.$this->var_to_str($room->isAudioOnly) |
|
355 | + . '&waitForRecording='.$this->var_to_str($room->waitForRecording) |
|
356 | + . '&allowRecording='.$this->var_to_str($room->allowRecording); |
|
357 | 357 | } elseif ($room->isAudioOnly) { |
358 | - $url .= '&isAudioOnly=' . $this->var_to_str($room->isAudioOnly); |
|
358 | + $url .= '&isAudioOnly='.$this->var_to_str($room->isAudioOnly); |
|
359 | 359 | } |
360 | 360 | $result = $this->rest->call($url); |
361 | 361 | |
362 | 362 | if ($this->rest->fault) { |
363 | - error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result,1)); |
|
363 | + error_log('Fault (Expect - The request contains an invalid SOAP body) '.print_r($result, 1)); |
|
364 | 364 | } else { |
365 | 365 | $err = $this->rest->getError(); |
366 | 366 | if ($err) { |
@@ -385,7 +385,7 @@ discard block |
||
385 | 385 | return false; |
386 | 386 | } |
387 | 387 | |
388 | - $url = $this->getRestUrl("RoomService") . "getRoomsWithCurrentUsersByListAndType?SID=" . $this->sessionId |
|
388 | + $url = $this->getRestUrl("RoomService")."getRoomsWithCurrentUsersByListAndType?SID=".$this->sessionId |
|
389 | 389 | . "&start=1&max=1000&orderby=name&asc=true&externalRoomType=chamilolms"; |
390 | 390 | //$url = $this->getRestUrl("RoomService") |
391 | 391 | // . "getRoomTypes?" |
@@ -396,7 +396,7 @@ discard block |
||
396 | 396 | $rooms = array(); |
397 | 397 | foreach ($result as $room) { |
398 | 398 | //error_log(__FILE__.'+'.__LINE__.': one room found on remote: '.print_r($room,1)); |
399 | - if ($room['externalRoomType'] == $type && count($room['currentusers']) > 0 ) { |
|
399 | + if ($room['externalRoomType'] == $type && count($room['currentusers']) > 0) { |
|
400 | 400 | $rooms[] = $room; |
401 | 401 | } |
402 | 402 | } |
@@ -418,7 +418,7 @@ discard block |
||
418 | 418 | |
419 | 419 | $url = $this->getRestUrl("RoomService") |
420 | 420 | . "getRoomById?" |
421 | - . "SID=" . $this->sessionId |
|
421 | + . "SID=".$this->sessionId |
|
422 | 422 | . "&rooms_id=".$roomId; |
423 | 423 | //error_log(__FILE__.'+'.__LINE__.' Calling WS: '.$url); |
424 | 424 | $result = $this->rest->call($url, "return"); |
@@ -432,8 +432,8 @@ discard block |
||
432 | 432 | { |
433 | 433 | $url = $this->getRestUrl("RoomService") |
434 | 434 | . "getFlvRecordingByExternalRoomType?" |
435 | - . "SID=" . $this->sessionId |
|
436 | - . "&externalRoomType=" . urlencode($this->config["moduleKey"]); |
|
435 | + . "SID=".$this->sessionId |
|
436 | + . "&externalRoomType=".urlencode($this->config["moduleKey"]); |
|
437 | 437 | |
438 | 438 | $result = $this->rest->call($url, "return"); |
439 | 439 | |
@@ -449,8 +449,8 @@ discard block |
||
449 | 449 | { |
450 | 450 | $url = $this->getRestUrl("RoomService") |
451 | 451 | . "getFlvRecordingByRoomId?" |
452 | - . "SID=" . $this->sessionId |
|
453 | - . "&roomId=" . urlencode($id); |
|
452 | + . "SID=".$this->sessionId |
|
453 | + . "&roomId=".urlencode($id); |
|
454 | 454 | |
455 | 455 | $result = $this->rest->call($url, "return"); |
456 | 456 | |
@@ -464,8 +464,8 @@ discard block |
||
464 | 464 | { |
465 | 465 | $url = $this->getRestUrl("RoomService") |
466 | 466 | . "getFlvRecordingByExternalUserId?" |
467 | - . "SID=" . $this->sessionId |
|
468 | - . "&externalUserId=" . $id; |
|
467 | + . "SID=".$this->sessionId |
|
468 | + . "&externalUserId=".$id; |
|
469 | 469 | |
470 | 470 | $result = $this->rest->call($url, "return"); |
471 | 471 |
@@ -351,9 +351,9 @@ |
||
351 | 351 | . '&externalRoomType=' . $room->externalRoomType; |
352 | 352 | if ($room->allowRecording) { |
353 | 353 | $url .= '&allowUserQuestions=' . $this->var_to_str($room->allowUserQuestions) |
354 | - . '&isAudioOnly=' . $this->var_to_str($room->isAudioOnly) |
|
355 | - . '&waitForRecording=' . $this->var_to_str($room->waitForRecording) |
|
356 | - . '&allowRecording=' . $this->var_to_str($room->allowRecording); |
|
354 | + . '&isAudioOnly=' . $this->var_to_str($room->isAudioOnly) |
|
355 | + . '&waitForRecording=' . $this->var_to_str($room->waitForRecording) |
|
356 | + . '&allowRecording=' . $this->var_to_str($room->allowRecording); |
|
357 | 357 | } elseif ($room->isAudioOnly) { |
358 | 358 | $url .= '&isAudioOnly=' . $this->var_to_str($room->isAudioOnly); |
359 | 359 | } |
@@ -27,6 +27,9 @@ discard block |
||
27 | 27 | */ |
28 | 28 | class OpenMeetingsRestService |
29 | 29 | { |
30 | + /** |
|
31 | + * @param string $request |
|
32 | + */ |
|
30 | 33 | function call($request, $returnAttribute = "return") |
31 | 34 | { |
32 | 35 | // This will allow you to view errors in the browser |
@@ -121,6 +124,9 @@ discard block |
||
121 | 124 | |
122 | 125 | } |
123 | 126 | |
127 | + /** |
|
128 | + * @param DOMDocument $node |
|
129 | + */ |
|
124 | 130 | function getArray($node) |
125 | 131 | { |
126 | 132 | if (is_null($node) || !is_object($node)) { |
@@ -40,31 +40,31 @@ discard block |
||
40 | 40 | // $request |
41 | 41 | |
42 | 42 | // Initialize the session by passing the request as a parameter |
43 | - $session = curl_init ( $request ); |
|
43 | + $session = curl_init($request); |
|
44 | 44 | |
45 | 45 | // Set curl options by passing session and flags |
46 | 46 | // CURLOPT_HEADER allows us to receive the HTTP header |
47 | - curl_setopt ( $session, CURLOPT_HEADER, true ); |
|
47 | + curl_setopt($session, CURLOPT_HEADER, true); |
|
48 | 48 | |
49 | 49 | // CURLOPT_RETURNTRANSFER will return the response |
50 | - curl_setopt ( $session, CURLOPT_RETURNTRANSFER, true ); |
|
50 | + curl_setopt($session, CURLOPT_RETURNTRANSFER, true); |
|
51 | 51 | |
52 | 52 | // Make the request |
53 | - $response = curl_exec ( $session ); |
|
53 | + $response = curl_exec($session); |
|
54 | 54 | |
55 | 55 | // Close the curl session |
56 | - curl_close ( $session ); |
|
56 | + curl_close($session); |
|
57 | 57 | |
58 | 58 | // Confirm that the request was transmitted to the OpenMeetings! Image Search Service |
59 | - if (! $response) { |
|
60 | - die ( "Request OpenMeetings! OpenMeetings Service failed and no response was returned in ".__CLASS__.'::'.__FUNCTION__.'()' ); |
|
59 | + if (!$response) { |
|
60 | + die ("Request OpenMeetings! OpenMeetings Service failed and no response was returned in ".__CLASS__.'::'.__FUNCTION__.'()'); |
|
61 | 61 | } |
62 | 62 | |
63 | 63 | // Create an array to store the HTTP response codes |
64 | - $status_code = array (); |
|
64 | + $status_code = array(); |
|
65 | 65 | |
66 | 66 | // Use regular expressions to extract the code from the header |
67 | - preg_match ( '/\d\d\d/', $response, $status_code ); |
|
67 | + preg_match('/\d\d\d/', $response, $status_code); |
|
68 | 68 | $bt = debug_backtrace(); |
69 | 69 | $caller = array_shift($bt); |
70 | 70 | $extra = ' (from '.$caller['file'].' at line '.$caller['line'].') '; |
@@ -74,24 +74,24 @@ discard block |
||
74 | 74 | // Success |
75 | 75 | break; |
76 | 76 | case 503 : |
77 | - error_log( 'Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 503. |
|
77 | + error_log('Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 503. |
|
78 | 78 | That means: Service unavailable. An internal problem prevented us from returning data to you.' ); |
79 | 79 | return false; |
80 | 80 | break; |
81 | 81 | case 403 : |
82 | - error_log( 'Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 403. |
|
82 | + error_log('Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 403. |
|
83 | 83 | That means: Forbidden. You do not have permission to access this resource, or are over your rate limit.' ); |
84 | 84 | return false; |
85 | 85 | break; |
86 | 86 | case 400 : |
87 | 87 | // You may want to fall through here and read the specific XML error |
88 | - error_log( 'Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 400. |
|
88 | + error_log('Your call to OpenMeetings Web Services '.$extra.' failed and returned an HTTP status of 400. |
|
89 | 89 | That means: Bad request. The parameters passed to the service did not match as expected. |
90 | 90 | The exact error is returned in the XML response.' ); |
91 | 91 | return false; |
92 | 92 | break; |
93 | 93 | default : |
94 | - error_log( 'Your call to OpenMeetings Web Services '.$extra.' returned an unexpected HTTP status of: ' . $status_code [0] . " Request " . $request ); |
|
94 | + error_log('Your call to OpenMeetings Web Services '.$extra.' returned an unexpected HTTP status of: '.$status_code [0]." Request ".$request); |
|
95 | 95 | return false; |
96 | 96 | } |
97 | 97 |
@@ -99,7 +99,7 @@ |
||
99 | 99 | /** |
100 | 100 | * Gets a string from a boolean attribute |
101 | 101 | * @param string $attribute Name of the attribute |
102 | - * @param mixed $voidReturn What to return if the value is not defined |
|
102 | + * @param string $voidReturn What to return if the value is not defined |
|
103 | 103 | * @return string The boolean value expressed as string ('true' or 'false') |
104 | 104 | */ |
105 | 105 | public function getString($attribute, $voidReturn = false) |
@@ -49,9 +49,9 @@ discard block |
||
49 | 49 | global $_configuration; |
50 | 50 | $this->name = 'C'.api_get_real_course_id().'-'.api_get_session_id(); |
51 | 51 | $accessUrl = api_get_access_url($_configuration['access_url']); |
52 | - $this->externalRoomType = substr($accessUrl['url'], strpos($accessUrl['url'],'://')+3,-1); |
|
52 | + $this->externalRoomType = substr($accessUrl['url'], strpos($accessUrl['url'], '://') + 3, -1); |
|
53 | 53 | if (strcmp($this->externalRoomType, 'localhost') == 0) { |
54 | - $this->externalRoomType = substr(api_get_path(WEB_PATH), strpos(api_get_path(WEB_PATH),'://')+3, -1); |
|
54 | + $this->externalRoomType = substr(api_get_path(WEB_PATH), strpos(api_get_path(WEB_PATH), '://') + 3, -1); |
|
55 | 55 | } |
56 | 56 | $this->externalRoomType = 'chamilolms.'.$this->externalRoomType; |
57 | 57 | } |
@@ -110,6 +110,6 @@ discard block |
||
110 | 110 | if (!isset($this->$attribute)) { |
111 | 111 | return $voidReturn; |
112 | 112 | } |
113 | - return $this->$attribute?'true':'false'; |
|
113 | + return $this->$attribute ? 'true' : 'false'; |
|
114 | 114 | } |
115 | 115 | } |
@@ -79,6 +79,7 @@ |
||
79 | 79 | * |
80 | 80 | * @param int Exception code |
81 | 81 | * @param string Message to display |
82 | + * @param integer $code |
|
82 | 83 | * @return PENSException Exception created |
83 | 84 | */ |
84 | 85 | public function __construct($code, $message = null) { |
@@ -90,7 +90,7 @@ |
||
90 | 90 | * Sets the message based on the code |
91 | 91 | */ |
92 | 92 | protected function setMessageBasedOnCode() { |
93 | - if(empty($this->message) && !empty(self::$_code_to_messages[$this->code])) { |
|
93 | + if (empty($this->message) && !empty(self::$_code_to_messages[$this->code])) { |
|
94 | 94 | $this->message = self::$_code_to_messages[$this->code]; |
95 | 95 | } |
96 | 96 | } |
@@ -37,62 +37,62 @@ |
||
37 | 37 | */ |
38 | 38 | class PENSException extends Exception { |
39 | 39 | |
40 | - /** |
|
41 | - * Array that provides an association between exception codes and messages |
|
42 | - * @var array |
|
43 | - */ |
|
44 | - protected static $_code_to_messages = array( |
|
45 | - 1101 => "Unable to parse PENS command", |
|
46 | - 1201 => "Attempt to pass an invalid argument", |
|
47 | - 1301 => "Unable to retrieve package", |
|
48 | - 1302 => "Unable to retrieve package via HTTPS", |
|
49 | - 1304 => "Unable to retrieve package via FTP", |
|
50 | - 1306 => "Unable to retrieve package via FTPS", |
|
51 | - 1310 => "Unable to retrieve package at specified URL due to error in URL or lack of response from URL", |
|
52 | - 1312 => "Unable to retrieve package at specified URL due to error with access credential for package URL", |
|
53 | - 1320 => "Expiration date is non-null and in an improper format", |
|
54 | - 1322 => "Current time indicates expiry date has passed", |
|
55 | - 1420 => "PENS version not supported", |
|
56 | - 1421 => "Command not supported", |
|
57 | - 1430 => "Package type not supported", |
|
58 | - // The following error code is not specified in the PENS specification and was added in this implementation |
|
59 | - 1431 => "Package format not supported", |
|
60 | - 1432 => "Internal package error", |
|
61 | - 1440 => "Insufficient host space/storage available", |
|
62 | - 1500 => "Unable to communicate with provided acknowledgement URL", |
|
63 | - 1510 => "Unsupported acknowledgement protocol", |
|
64 | - 1520 => "Unsupported alert protocol", |
|
65 | - 2001 => "PENS version invalid or not specified", |
|
66 | - 2002 => "PENS command invalid or not specified", |
|
67 | - 2003 => "package-type invalid or not specified", |
|
68 | - 2004 => "package-type-version invalid or not specified", |
|
69 | - 2005 => "package-format invalid or not specified", |
|
70 | - 2007 => "package-id invalid or not specified", |
|
71 | - 2008 => "package-url invalid or not specified", |
|
72 | - 2009 => "package-url-expiry date invalid or not specified", |
|
73 | - 2010 => "client submitting package invalid or not specified", |
|
74 | - 2011 => "receipt url invalid or not specified" |
|
75 | - ); |
|
40 | + /** |
|
41 | + * Array that provides an association between exception codes and messages |
|
42 | + * @var array |
|
43 | + */ |
|
44 | + protected static $_code_to_messages = array( |
|
45 | + 1101 => "Unable to parse PENS command", |
|
46 | + 1201 => "Attempt to pass an invalid argument", |
|
47 | + 1301 => "Unable to retrieve package", |
|
48 | + 1302 => "Unable to retrieve package via HTTPS", |
|
49 | + 1304 => "Unable to retrieve package via FTP", |
|
50 | + 1306 => "Unable to retrieve package via FTPS", |
|
51 | + 1310 => "Unable to retrieve package at specified URL due to error in URL or lack of response from URL", |
|
52 | + 1312 => "Unable to retrieve package at specified URL due to error with access credential for package URL", |
|
53 | + 1320 => "Expiration date is non-null and in an improper format", |
|
54 | + 1322 => "Current time indicates expiry date has passed", |
|
55 | + 1420 => "PENS version not supported", |
|
56 | + 1421 => "Command not supported", |
|
57 | + 1430 => "Package type not supported", |
|
58 | + // The following error code is not specified in the PENS specification and was added in this implementation |
|
59 | + 1431 => "Package format not supported", |
|
60 | + 1432 => "Internal package error", |
|
61 | + 1440 => "Insufficient host space/storage available", |
|
62 | + 1500 => "Unable to communicate with provided acknowledgement URL", |
|
63 | + 1510 => "Unsupported acknowledgement protocol", |
|
64 | + 1520 => "Unsupported alert protocol", |
|
65 | + 2001 => "PENS version invalid or not specified", |
|
66 | + 2002 => "PENS command invalid or not specified", |
|
67 | + 2003 => "package-type invalid or not specified", |
|
68 | + 2004 => "package-type-version invalid or not specified", |
|
69 | + 2005 => "package-format invalid or not specified", |
|
70 | + 2007 => "package-id invalid or not specified", |
|
71 | + 2008 => "package-url invalid or not specified", |
|
72 | + 2009 => "package-url-expiry date invalid or not specified", |
|
73 | + 2010 => "client submitting package invalid or not specified", |
|
74 | + 2011 => "receipt url invalid or not specified" |
|
75 | + ); |
|
76 | 76 | |
77 | - /** |
|
78 | - * Redefines the constructor so that code is the first argument |
|
79 | - * |
|
80 | - * @param int Exception code |
|
81 | - * @param string Message to display |
|
82 | - * @return PENSException Exception created |
|
83 | - */ |
|
84 | - public function __construct($code, $message = null) { |
|
85 | - parent::__construct($message, $code); |
|
86 | - $this->setMessageBasedOnCode(); |
|
87 | - } |
|
77 | + /** |
|
78 | + * Redefines the constructor so that code is the first argument |
|
79 | + * |
|
80 | + * @param int Exception code |
|
81 | + * @param string Message to display |
|
82 | + * @return PENSException Exception created |
|
83 | + */ |
|
84 | + public function __construct($code, $message = null) { |
|
85 | + parent::__construct($message, $code); |
|
86 | + $this->setMessageBasedOnCode(); |
|
87 | + } |
|
88 | 88 | |
89 | - /** |
|
90 | - * Sets the message based on the code |
|
91 | - */ |
|
92 | - protected function setMessageBasedOnCode() { |
|
93 | - if(empty($this->message) && !empty(self::$_code_to_messages[$this->code])) { |
|
94 | - $this->message = self::$_code_to_messages[$this->code]; |
|
95 | - } |
|
96 | - } |
|
89 | + /** |
|
90 | + * Sets the message based on the code |
|
91 | + */ |
|
92 | + protected function setMessageBasedOnCode() { |
|
93 | + if(empty($this->message) && !empty(self::$_code_to_messages[$this->code])) { |
|
94 | + $this->message = self::$_code_to_messages[$this->code]; |
|
95 | + } |
|
96 | + } |
|
97 | 97 | |
98 | 98 | } |
@@ -236,6 +236,7 @@ discard block |
||
236 | 236 | * @param PENSRequest Original collect request |
237 | 237 | * @param PENSResponse Reponse to send in the receipt or the alert |
238 | 238 | * @param string Mode (alert | receipt) |
239 | + * @param string $mode |
|
239 | 240 | * @return PENSResponse Response |
240 | 241 | */ |
241 | 242 | protected function sendAlertOrReceipt($request, $response, $mode) { |
@@ -283,6 +284,7 @@ discard block |
||
283 | 284 | * |
284 | 285 | * @param PENSRequest Original collect request |
285 | 286 | * @param PENSResponse Response to send in the receipt |
287 | + * @param PENSResponse $receipt |
|
286 | 288 | * @return PENSResponse Response |
287 | 289 | */ |
288 | 290 | protected function sendReceipt($request, $receipt) { |
@@ -294,6 +296,7 @@ discard block |
||
294 | 296 | * |
295 | 297 | * @param PENSRequest Original collect request |
296 | 298 | * @param string Path to the package on the hard drive |
299 | + * @param string $path_to_package |
|
297 | 300 | */ |
298 | 301 | protected function processPackage($request, $path_to_package) { |
299 | 302 | return $this->_package_handler->processPackage($request, $path_to_package); |
@@ -16,15 +16,15 @@ discard block |
||
16 | 16 | * along with php-pens. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | */ |
18 | 18 | |
19 | - /** |
|
20 | - * PENSServer |
|
21 | - * |
|
22 | - * Provides the PENSServer class |
|
23 | - * |
|
24 | - * @package PENS |
|
25 | - * @author Guillaume Viguier-Just <[email protected]> |
|
26 | - * @licence http://www.gnu.org/licenses/gpl.txt |
|
27 | - */ |
|
19 | + /** |
|
20 | + * PENSServer |
|
21 | + * |
|
22 | + * Provides the PENSServer class |
|
23 | + * |
|
24 | + * @package PENS |
|
25 | + * @author Guillaume Viguier-Just <[email protected]> |
|
26 | + * @licence http://www.gnu.org/licenses/gpl.txt |
|
27 | + */ |
|
28 | 28 | |
29 | 29 | require_once __DIR__ . '/pens_controller.php'; |
30 | 30 | require_once __DIR__ . '/pens_package_handler.php'; |
@@ -42,272 +42,272 @@ discard block |
||
42 | 42 | */ |
43 | 43 | class PENSServer extends PENSController { |
44 | 44 | |
45 | - /** |
|
46 | - * Instance of the PENSServer |
|
47 | - * @var PENSServer |
|
48 | - */ |
|
49 | - private static $_instance; |
|
45 | + /** |
|
46 | + * Instance of the PENSServer |
|
47 | + * @var PENSServer |
|
48 | + */ |
|
49 | + private static $_instance; |
|
50 | 50 | |
51 | - /** |
|
52 | - * Package handler |
|
53 | - * @var PENSPackageHandler |
|
54 | - */ |
|
55 | - protected $_package_handler = null; |
|
51 | + /** |
|
52 | + * Package handler |
|
53 | + * @var PENSPackageHandler |
|
54 | + */ |
|
55 | + protected $_package_handler = null; |
|
56 | 56 | |
57 | - /** |
|
58 | - * Private constructor |
|
59 | - */ |
|
60 | - private function __construct() { |
|
61 | - } |
|
57 | + /** |
|
58 | + * Private constructor |
|
59 | + */ |
|
60 | + private function __construct() { |
|
61 | + } |
|
62 | 62 | |
63 | - /** |
|
64 | - * Singleton method |
|
65 | - */ |
|
66 | - public static function singleton() { |
|
67 | - if(!isset(self::$_instance)) { |
|
68 | - $c = __CLASS__; |
|
69 | - self::$_instance = new $c; |
|
70 | - } |
|
71 | - return self::$_instance; |
|
72 | - } |
|
63 | + /** |
|
64 | + * Singleton method |
|
65 | + */ |
|
66 | + public static function singleton() { |
|
67 | + if(!isset(self::$_instance)) { |
|
68 | + $c = __CLASS__; |
|
69 | + self::$_instance = new $c; |
|
70 | + } |
|
71 | + return self::$_instance; |
|
72 | + } |
|
73 | 73 | |
74 | - /** |
|
75 | - * Prevent users to clone the instance |
|
76 | - */ |
|
77 | - public function __clone() { |
|
78 | - trigger_error('Clone is not allowed', E_USER_ERROR); |
|
79 | - } |
|
74 | + /** |
|
75 | + * Prevent users to clone the instance |
|
76 | + */ |
|
77 | + public function __clone() { |
|
78 | + trigger_error('Clone is not allowed', E_USER_ERROR); |
|
79 | + } |
|
80 | 80 | |
81 | - public function getPackageHandler() { |
|
82 | - return $this->_package_handler; |
|
83 | - } |
|
81 | + public function getPackageHandler() { |
|
82 | + return $this->_package_handler; |
|
83 | + } |
|
84 | 84 | |
85 | - /** |
|
86 | - * Sets the package handler. Does nothing if the argument is not an instance of PENSPackageHandler |
|
87 | - * |
|
88 | - * @param PENSPackageHandler Package handler |
|
89 | - */ |
|
90 | - public function setPackageHandler($package_handler) { |
|
91 | - if($package_handler instanceof PENSPackageHandler) { |
|
92 | - $this->_package_handler = $package_handler; |
|
93 | - } |
|
94 | - } |
|
85 | + /** |
|
86 | + * Sets the package handler. Does nothing if the argument is not an instance of PENSPackageHandler |
|
87 | + * |
|
88 | + * @param PENSPackageHandler Package handler |
|
89 | + */ |
|
90 | + public function setPackageHandler($package_handler) { |
|
91 | + if($package_handler instanceof PENSPackageHandler) { |
|
92 | + $this->_package_handler = $package_handler; |
|
93 | + } |
|
94 | + } |
|
95 | 95 | |
96 | - /** |
|
97 | - * Receives a collect request and treats it |
|
98 | - */ |
|
99 | - public function receiveCollect() { |
|
100 | - $request = null; |
|
101 | - try { |
|
102 | - // First, try to parse the request |
|
103 | - $request = $this->parseRequest(); |
|
104 | - if($request->getCommand() == "collect") { |
|
105 | - if(isset($_REQUEST['process'])) { |
|
106 | - // Collect the package and process it |
|
107 | - $receipt = null; |
|
108 | - $path_to_package = null; |
|
109 | - try { |
|
110 | - // Collect the package |
|
111 | - $path_to_package = $this->collectPackage($request); |
|
112 | - $receipt = new PENSResponse(0, "package successfully collected"); |
|
113 | - } catch(PENSException $e) { |
|
114 | - $receipt = new PENSResponse($e); |
|
115 | - } |
|
116 | - // Send receipt |
|
117 | - $response = $this->sendReceipt($request, $receipt); |
|
118 | - if(!is_null($response) && !is_null($path_to_package)) { |
|
119 | - if($response->getError() === 0) { |
|
120 | - // Process package |
|
121 | - $this->processPackage($request, $path_to_package); |
|
122 | - } |
|
123 | - unlink($path_to_package); |
|
124 | - } |
|
125 | - } else { |
|
126 | - // Then, send a success response to the client |
|
127 | - $this->sendResponse(new PENSResponse(0, "collect command received and understood")); |
|
128 | - // Send a request to process the package: fake multithreading |
|
129 | - $params = $_REQUEST; |
|
130 | - $params['process'] = 1; |
|
131 | - $scheme = "http"; |
|
132 | - if(!empty($_SERVER['HTTPS'])) { |
|
133 | - $scheme = "https"; |
|
134 | - } |
|
135 | - $ch = curl_init(); |
|
136 | - curl_setopt($ch, CURLOPT_URL, $scheme."://".$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI']); |
|
137 | - curl_setopt($ch, CURLOPT_POSTFIELDS, $params); |
|
138 | - curl_setopt($ch, CURLOPT_TIMEOUT, 1); |
|
139 | - curl_exec($ch); |
|
140 | - curl_close($ch); |
|
141 | - } |
|
142 | - } |
|
96 | + /** |
|
97 | + * Receives a collect request and treats it |
|
98 | + */ |
|
99 | + public function receiveCollect() { |
|
100 | + $request = null; |
|
101 | + try { |
|
102 | + // First, try to parse the request |
|
103 | + $request = $this->parseRequest(); |
|
104 | + if($request->getCommand() == "collect") { |
|
105 | + if(isset($_REQUEST['process'])) { |
|
106 | + // Collect the package and process it |
|
107 | + $receipt = null; |
|
108 | + $path_to_package = null; |
|
109 | + try { |
|
110 | + // Collect the package |
|
111 | + $path_to_package = $this->collectPackage($request); |
|
112 | + $receipt = new PENSResponse(0, "package successfully collected"); |
|
113 | + } catch(PENSException $e) { |
|
114 | + $receipt = new PENSResponse($e); |
|
115 | + } |
|
116 | + // Send receipt |
|
117 | + $response = $this->sendReceipt($request, $receipt); |
|
118 | + if(!is_null($response) && !is_null($path_to_package)) { |
|
119 | + if($response->getError() === 0) { |
|
120 | + // Process package |
|
121 | + $this->processPackage($request, $path_to_package); |
|
122 | + } |
|
123 | + unlink($path_to_package); |
|
124 | + } |
|
125 | + } else { |
|
126 | + // Then, send a success response to the client |
|
127 | + $this->sendResponse(new PENSResponse(0, "collect command received and understood")); |
|
128 | + // Send a request to process the package: fake multithreading |
|
129 | + $params = $_REQUEST; |
|
130 | + $params['process'] = 1; |
|
131 | + $scheme = "http"; |
|
132 | + if(!empty($_SERVER['HTTPS'])) { |
|
133 | + $scheme = "https"; |
|
134 | + } |
|
135 | + $ch = curl_init(); |
|
136 | + curl_setopt($ch, CURLOPT_URL, $scheme."://".$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI']); |
|
137 | + curl_setopt($ch, CURLOPT_POSTFIELDS, $params); |
|
138 | + curl_setopt($ch, CURLOPT_TIMEOUT, 1); |
|
139 | + curl_exec($ch); |
|
140 | + curl_close($ch); |
|
141 | + } |
|
142 | + } |
|
143 | 143 | |
144 | - } catch(PENSException $e) { |
|
145 | - // If we could not parse the request, send the error back to the client |
|
146 | - $this->sendResponse(new PENSResponse($e)); |
|
147 | - } |
|
148 | - } |
|
144 | + } catch(PENSException $e) { |
|
145 | + // If we could not parse the request, send the error back to the client |
|
146 | + $this->sendResponse(new PENSResponse($e)); |
|
147 | + } |
|
148 | + } |
|
149 | 149 | |
150 | - /** |
|
151 | - * Collects the package onto the local server |
|
152 | - * |
|
153 | - * @param PENSRequest request |
|
154 | - * @return string Path to the package on the hard drive |
|
155 | - * @throws PENSException if an exception occured |
|
156 | - */ |
|
157 | - protected function collectPackage($request) { |
|
158 | - $supported_package_types = $this->_package_handler->getSupportedPackageTypes(); |
|
159 | - if(!in_array($request->getPackageType(), $supported_package_types)) { |
|
160 | - throw new PENSException(1430); |
|
161 | - } |
|
162 | - $supported_package_formats = $this->_package_handler->getSupportedPackageFormats(); |
|
163 | - if(!in_array($request->getPackageFormat(), $supported_package_formats)) { |
|
164 | - throw new PENSException(1431); |
|
165 | - } |
|
166 | - if(!$this->isExpiryDateValid($request->getPackageUrlExpiry())) { |
|
167 | - throw new PENSException(1322); |
|
168 | - } |
|
150 | + /** |
|
151 | + * Collects the package onto the local server |
|
152 | + * |
|
153 | + * @param PENSRequest request |
|
154 | + * @return string Path to the package on the hard drive |
|
155 | + * @throws PENSException if an exception occured |
|
156 | + */ |
|
157 | + protected function collectPackage($request) { |
|
158 | + $supported_package_types = $this->_package_handler->getSupportedPackageTypes(); |
|
159 | + if(!in_array($request->getPackageType(), $supported_package_types)) { |
|
160 | + throw new PENSException(1430); |
|
161 | + } |
|
162 | + $supported_package_formats = $this->_package_handler->getSupportedPackageFormats(); |
|
163 | + if(!in_array($request->getPackageFormat(), $supported_package_formats)) { |
|
164 | + throw new PENSException(1431); |
|
165 | + } |
|
166 | + if(!$this->isExpiryDateValid($request->getPackageUrlExpiry())) { |
|
167 | + throw new PENSException(1322); |
|
168 | + } |
|
169 | 169 | |
170 | - // Try to download the package in the temporary directory |
|
171 | - $tmp = null; |
|
172 | - if(function_exists("sys_get_temp_dir")) { |
|
173 | - $tmp = sys_get_temp_dir(); |
|
174 | - } else { |
|
175 | - $tmp = "/tmp"; |
|
176 | - } |
|
177 | - $path_to_file = $tmp."/".$request->getFilename(); |
|
178 | - $fp = fopen($path_to_file, 'w'); |
|
179 | - $ch = curl_init(); |
|
180 | - curl_setopt($ch, CURLOPT_URL, $request->getPackageUrl()); |
|
181 | - curl_setopt($ch, CURLOPT_HEADER, false); |
|
182 | - curl_setopt($ch, CURLOPT_FILE, $fp); |
|
183 | - if(!is_null($request->getPackageUrlUserId())) { |
|
184 | - curl_setopt($ch, CURLOPT_USERPWD, $request->getPackageUrlUserId().":".$request->getPackageUrlPassword()); |
|
185 | - } |
|
186 | - if(curl_exec($ch) === false) { |
|
187 | - $errno = curl_errno($ch); |
|
188 | - curl_close($ch); |
|
189 | - // Error occured. Throw an exception |
|
190 | - switch($errno) { |
|
191 | - case CURLE_UNSUPPORTED_PROTOCOL: |
|
192 | - throw new PENSException(1301); |
|
193 | - break; |
|
194 | - case CURLE_URL_MALFORMAT: |
|
195 | - case CURLE_COULDNT_RESOLVE_PROXY: |
|
196 | - case CURLE_COULDNT_RESOLVE_HOST: |
|
197 | - case CURLE_COULDNT_CONNECT: |
|
198 | - case CURLE_OPERATION_TIMEOUT: |
|
199 | - case CURLE_REMOTE_FILE_NOT_FOUND: |
|
200 | - throw new PENSException(1310); |
|
201 | - break; |
|
202 | - case CURLE_REMOTE_ACCESS_DENIED: |
|
203 | - throw new PENSException(1312); |
|
204 | - break; |
|
205 | - default: |
|
206 | - throw new PENSException(1301); |
|
207 | - break; |
|
208 | - } |
|
209 | - return null; |
|
170 | + // Try to download the package in the temporary directory |
|
171 | + $tmp = null; |
|
172 | + if(function_exists("sys_get_temp_dir")) { |
|
173 | + $tmp = sys_get_temp_dir(); |
|
174 | + } else { |
|
175 | + $tmp = "/tmp"; |
|
176 | + } |
|
177 | + $path_to_file = $tmp."/".$request->getFilename(); |
|
178 | + $fp = fopen($path_to_file, 'w'); |
|
179 | + $ch = curl_init(); |
|
180 | + curl_setopt($ch, CURLOPT_URL, $request->getPackageUrl()); |
|
181 | + curl_setopt($ch, CURLOPT_HEADER, false); |
|
182 | + curl_setopt($ch, CURLOPT_FILE, $fp); |
|
183 | + if(!is_null($request->getPackageUrlUserId())) { |
|
184 | + curl_setopt($ch, CURLOPT_USERPWD, $request->getPackageUrlUserId().":".$request->getPackageUrlPassword()); |
|
185 | + } |
|
186 | + if(curl_exec($ch) === false) { |
|
187 | + $errno = curl_errno($ch); |
|
188 | + curl_close($ch); |
|
189 | + // Error occured. Throw an exception |
|
190 | + switch($errno) { |
|
191 | + case CURLE_UNSUPPORTED_PROTOCOL: |
|
192 | + throw new PENSException(1301); |
|
193 | + break; |
|
194 | + case CURLE_URL_MALFORMAT: |
|
195 | + case CURLE_COULDNT_RESOLVE_PROXY: |
|
196 | + case CURLE_COULDNT_RESOLVE_HOST: |
|
197 | + case CURLE_COULDNT_CONNECT: |
|
198 | + case CURLE_OPERATION_TIMEOUT: |
|
199 | + case CURLE_REMOTE_FILE_NOT_FOUND: |
|
200 | + throw new PENSException(1310); |
|
201 | + break; |
|
202 | + case CURLE_REMOTE_ACCESS_DENIED: |
|
203 | + throw new PENSException(1312); |
|
204 | + break; |
|
205 | + default: |
|
206 | + throw new PENSException(1301); |
|
207 | + break; |
|
208 | + } |
|
209 | + return null; |
|
210 | 210 | |
211 | - } else { |
|
212 | - curl_close($ch); |
|
213 | - return $path_to_file; |
|
214 | - } |
|
215 | - } |
|
211 | + } else { |
|
212 | + curl_close($ch); |
|
213 | + return $path_to_file; |
|
214 | + } |
|
215 | + } |
|
216 | 216 | |
217 | - /** |
|
218 | - * Verifies that the package url is not expired |
|
219 | - * |
|
220 | - * @param DateTime DateTime object to verify against current time |
|
221 | - */ |
|
222 | - protected function isExpiryDateValid($expiry) { |
|
223 | - date_default_timezone_set('UTC'); |
|
224 | - $current_time = time(); |
|
225 | - $expiry_time = strtotime($expiry->format(DateTime::ISO8601)); |
|
226 | - if($current_time > $expiry_time) { |
|
227 | - return false; |
|
228 | - } else { |
|
229 | - return true; |
|
230 | - } |
|
231 | - } |
|
217 | + /** |
|
218 | + * Verifies that the package url is not expired |
|
219 | + * |
|
220 | + * @param DateTime DateTime object to verify against current time |
|
221 | + */ |
|
222 | + protected function isExpiryDateValid($expiry) { |
|
223 | + date_default_timezone_set('UTC'); |
|
224 | + $current_time = time(); |
|
225 | + $expiry_time = strtotime($expiry->format(DateTime::ISO8601)); |
|
226 | + if($current_time > $expiry_time) { |
|
227 | + return false; |
|
228 | + } else { |
|
229 | + return true; |
|
230 | + } |
|
231 | + } |
|
232 | 232 | |
233 | - /** |
|
234 | - * Sends an alert or a receipt. Called by sendReceipt and sendAlert |
|
235 | - * |
|
236 | - * @param PENSRequest Original collect request |
|
237 | - * @param PENSResponse Reponse to send in the receipt or the alert |
|
238 | - * @param string Mode (alert | receipt) |
|
239 | - * @return PENSResponse Response |
|
240 | - */ |
|
241 | - protected function sendAlertOrReceipt($request, $response, $mode) { |
|
242 | - if($mode == "alert") { |
|
243 | - $url = $request->getAlerts(); |
|
244 | - } else { |
|
245 | - $url = $request->getReceipt(); |
|
246 | - } |
|
247 | - if(!empty($url)) { |
|
248 | - $url_components = parse_url($url); |
|
249 | - $scheme = $url_components["scheme"]; |
|
250 | - if($scheme == "mailto") { |
|
251 | - $to = $url_components["path"]; |
|
252 | - if($mode == "alert") { |
|
253 | - $subject = "PENS Alert for ".$request->getPackageId(); |
|
254 | - } else { |
|
255 | - $subject = "PENS Receipt for ".$request->getPackageId(); |
|
256 | - } |
|
257 | - $message = $response->__toString(); |
|
258 | - mail($to, $subject, $message); |
|
259 | - return new PENSResponse(0, ""); |
|
260 | - } else if($scheme == "http" || $scheme == "https") { |
|
261 | - if($mode == "alert") { |
|
262 | - $params = array_merge($request->getSendAlertArray(), $response->getArray()); |
|
263 | - } else { |
|
264 | - $params = array_merge($request->getSendReceiptArray(), $response->getArray()); |
|
265 | - } |
|
266 | - $ch = curl_init($url); |
|
267 | - curl_setopt($ch, CURLOPT_POST, true); |
|
268 | - curl_setopt($ch, CURLOPT_POSTFIELDS, $params); |
|
269 | - curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
|
270 | - $data = curl_exec($ch); |
|
271 | - curl_close($ch); |
|
272 | - if($data === false) { |
|
273 | - return null; |
|
274 | - } else { |
|
275 | - return new PENSResponse($data); |
|
276 | - } |
|
277 | - } |
|
278 | - } |
|
279 | - } |
|
233 | + /** |
|
234 | + * Sends an alert or a receipt. Called by sendReceipt and sendAlert |
|
235 | + * |
|
236 | + * @param PENSRequest Original collect request |
|
237 | + * @param PENSResponse Reponse to send in the receipt or the alert |
|
238 | + * @param string Mode (alert | receipt) |
|
239 | + * @return PENSResponse Response |
|
240 | + */ |
|
241 | + protected function sendAlertOrReceipt($request, $response, $mode) { |
|
242 | + if($mode == "alert") { |
|
243 | + $url = $request->getAlerts(); |
|
244 | + } else { |
|
245 | + $url = $request->getReceipt(); |
|
246 | + } |
|
247 | + if(!empty($url)) { |
|
248 | + $url_components = parse_url($url); |
|
249 | + $scheme = $url_components["scheme"]; |
|
250 | + if($scheme == "mailto") { |
|
251 | + $to = $url_components["path"]; |
|
252 | + if($mode == "alert") { |
|
253 | + $subject = "PENS Alert for ".$request->getPackageId(); |
|
254 | + } else { |
|
255 | + $subject = "PENS Receipt for ".$request->getPackageId(); |
|
256 | + } |
|
257 | + $message = $response->__toString(); |
|
258 | + mail($to, $subject, $message); |
|
259 | + return new PENSResponse(0, ""); |
|
260 | + } else if($scheme == "http" || $scheme == "https") { |
|
261 | + if($mode == "alert") { |
|
262 | + $params = array_merge($request->getSendAlertArray(), $response->getArray()); |
|
263 | + } else { |
|
264 | + $params = array_merge($request->getSendReceiptArray(), $response->getArray()); |
|
265 | + } |
|
266 | + $ch = curl_init($url); |
|
267 | + curl_setopt($ch, CURLOPT_POST, true); |
|
268 | + curl_setopt($ch, CURLOPT_POSTFIELDS, $params); |
|
269 | + curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
|
270 | + $data = curl_exec($ch); |
|
271 | + curl_close($ch); |
|
272 | + if($data === false) { |
|
273 | + return null; |
|
274 | + } else { |
|
275 | + return new PENSResponse($data); |
|
276 | + } |
|
277 | + } |
|
278 | + } |
|
279 | + } |
|
280 | 280 | |
281 | - /** |
|
282 | - * Sends a receipt. Returns a PENSResponse in case of success, null if a problem occured |
|
283 | - * |
|
284 | - * @param PENSRequest Original collect request |
|
285 | - * @param PENSResponse Response to send in the receipt |
|
286 | - * @return PENSResponse Response |
|
287 | - */ |
|
288 | - protected function sendReceipt($request, $receipt) { |
|
289 | - return $this->sendAlertOrReceipt($request, $receipt, "receipt"); |
|
290 | - } |
|
281 | + /** |
|
282 | + * Sends a receipt. Returns a PENSResponse in case of success, null if a problem occured |
|
283 | + * |
|
284 | + * @param PENSRequest Original collect request |
|
285 | + * @param PENSResponse Response to send in the receipt |
|
286 | + * @return PENSResponse Response |
|
287 | + */ |
|
288 | + protected function sendReceipt($request, $receipt) { |
|
289 | + return $this->sendAlertOrReceipt($request, $receipt, "receipt"); |
|
290 | + } |
|
291 | 291 | |
292 | - /** |
|
293 | - * Processes the package using the handler provided |
|
294 | - * |
|
295 | - * @param PENSRequest Original collect request |
|
296 | - * @param string Path to the package on the hard drive |
|
297 | - */ |
|
298 | - protected function processPackage($request, $path_to_package) { |
|
299 | - return $this->_package_handler->processPackage($request, $path_to_package); |
|
300 | - } |
|
292 | + /** |
|
293 | + * Processes the package using the handler provided |
|
294 | + * |
|
295 | + * @param PENSRequest Original collect request |
|
296 | + * @param string Path to the package on the hard drive |
|
297 | + */ |
|
298 | + protected function processPackage($request, $path_to_package) { |
|
299 | + return $this->_package_handler->processPackage($request, $path_to_package); |
|
300 | + } |
|
301 | 301 | |
302 | - /** |
|
303 | - * Sends an alert to the client. Returns a PENSResponse in case of success, null if a problem occured |
|
304 | - * |
|
305 | - * @param PENSRequest Original collect request |
|
306 | - * @param PENSResponse Response to send in the alert |
|
307 | - * @return PENSResponse Response |
|
308 | - */ |
|
309 | - public function sendAlert($request, $alert) { |
|
310 | - return $this->sendAlertOrReceipt($request, $alert, "alert"); |
|
311 | - } |
|
302 | + /** |
|
303 | + * Sends an alert to the client. Returns a PENSResponse in case of success, null if a problem occured |
|
304 | + * |
|
305 | + * @param PENSRequest Original collect request |
|
306 | + * @param PENSResponse Response to send in the alert |
|
307 | + * @return PENSResponse Response |
|
308 | + */ |
|
309 | + public function sendAlert($request, $alert) { |
|
310 | + return $this->sendAlertOrReceipt($request, $alert, "alert"); |
|
311 | + } |
|
312 | 312 | |
313 | 313 | } |
@@ -26,10 +26,10 @@ discard block |
||
26 | 26 | * @licence http://www.gnu.org/licenses/gpl.txt |
27 | 27 | */ |
28 | 28 | |
29 | -require_once __DIR__ . '/pens_controller.php'; |
|
30 | -require_once __DIR__ . '/pens_package_handler.php'; |
|
31 | -require_once __DIR__ . '/pens_exception.php'; |
|
32 | -require_once __DIR__ . '/pens_response.php'; |
|
29 | +require_once __DIR__.'/pens_controller.php'; |
|
30 | +require_once __DIR__.'/pens_package_handler.php'; |
|
31 | +require_once __DIR__.'/pens_exception.php'; |
|
32 | +require_once __DIR__.'/pens_response.php'; |
|
33 | 33 | |
34 | 34 | /** |
35 | 35 | * PENSServer |
@@ -64,7 +64,7 @@ discard block |
||
64 | 64 | * Singleton method |
65 | 65 | */ |
66 | 66 | public static function singleton() { |
67 | - if(!isset(self::$_instance)) { |
|
67 | + if (!isset(self::$_instance)) { |
|
68 | 68 | $c = __CLASS__; |
69 | 69 | self::$_instance = new $c; |
70 | 70 | } |
@@ -88,7 +88,7 @@ discard block |
||
88 | 88 | * @param PENSPackageHandler Package handler |
89 | 89 | */ |
90 | 90 | public function setPackageHandler($package_handler) { |
91 | - if($package_handler instanceof PENSPackageHandler) { |
|
91 | + if ($package_handler instanceof PENSPackageHandler) { |
|
92 | 92 | $this->_package_handler = $package_handler; |
93 | 93 | } |
94 | 94 | } |
@@ -101,8 +101,8 @@ discard block |
||
101 | 101 | try { |
102 | 102 | // First, try to parse the request |
103 | 103 | $request = $this->parseRequest(); |
104 | - if($request->getCommand() == "collect") { |
|
105 | - if(isset($_REQUEST['process'])) { |
|
104 | + if ($request->getCommand() == "collect") { |
|
105 | + if (isset($_REQUEST['process'])) { |
|
106 | 106 | // Collect the package and process it |
107 | 107 | $receipt = null; |
108 | 108 | $path_to_package = null; |
@@ -110,13 +110,13 @@ discard block |
||
110 | 110 | // Collect the package |
111 | 111 | $path_to_package = $this->collectPackage($request); |
112 | 112 | $receipt = new PENSResponse(0, "package successfully collected"); |
113 | - } catch(PENSException $e) { |
|
113 | + } catch (PENSException $e) { |
|
114 | 114 | $receipt = new PENSResponse($e); |
115 | 115 | } |
116 | 116 | // Send receipt |
117 | 117 | $response = $this->sendReceipt($request, $receipt); |
118 | - if(!is_null($response) && !is_null($path_to_package)) { |
|
119 | - if($response->getError() === 0) { |
|
118 | + if (!is_null($response) && !is_null($path_to_package)) { |
|
119 | + if ($response->getError() === 0) { |
|
120 | 120 | // Process package |
121 | 121 | $this->processPackage($request, $path_to_package); |
122 | 122 | } |
@@ -129,7 +129,7 @@ discard block |
||
129 | 129 | $params = $_REQUEST; |
130 | 130 | $params['process'] = 1; |
131 | 131 | $scheme = "http"; |
132 | - if(!empty($_SERVER['HTTPS'])) { |
|
132 | + if (!empty($_SERVER['HTTPS'])) { |
|
133 | 133 | $scheme = "https"; |
134 | 134 | } |
135 | 135 | $ch = curl_init(); |
@@ -141,7 +141,7 @@ discard block |
||
141 | 141 | } |
142 | 142 | } |
143 | 143 | |
144 | - } catch(PENSException $e) { |
|
144 | + } catch (PENSException $e) { |
|
145 | 145 | // If we could not parse the request, send the error back to the client |
146 | 146 | $this->sendResponse(new PENSResponse($e)); |
147 | 147 | } |
@@ -156,20 +156,20 @@ discard block |
||
156 | 156 | */ |
157 | 157 | protected function collectPackage($request) { |
158 | 158 | $supported_package_types = $this->_package_handler->getSupportedPackageTypes(); |
159 | - if(!in_array($request->getPackageType(), $supported_package_types)) { |
|
159 | + if (!in_array($request->getPackageType(), $supported_package_types)) { |
|
160 | 160 | throw new PENSException(1430); |
161 | 161 | } |
162 | 162 | $supported_package_formats = $this->_package_handler->getSupportedPackageFormats(); |
163 | - if(!in_array($request->getPackageFormat(), $supported_package_formats)) { |
|
163 | + if (!in_array($request->getPackageFormat(), $supported_package_formats)) { |
|
164 | 164 | throw new PENSException(1431); |
165 | 165 | } |
166 | - if(!$this->isExpiryDateValid($request->getPackageUrlExpiry())) { |
|
166 | + if (!$this->isExpiryDateValid($request->getPackageUrlExpiry())) { |
|
167 | 167 | throw new PENSException(1322); |
168 | 168 | } |
169 | 169 | |
170 | 170 | // Try to download the package in the temporary directory |
171 | 171 | $tmp = null; |
172 | - if(function_exists("sys_get_temp_dir")) { |
|
172 | + if (function_exists("sys_get_temp_dir")) { |
|
173 | 173 | $tmp = sys_get_temp_dir(); |
174 | 174 | } else { |
175 | 175 | $tmp = "/tmp"; |
@@ -180,14 +180,14 @@ discard block |
||
180 | 180 | curl_setopt($ch, CURLOPT_URL, $request->getPackageUrl()); |
181 | 181 | curl_setopt($ch, CURLOPT_HEADER, false); |
182 | 182 | curl_setopt($ch, CURLOPT_FILE, $fp); |
183 | - if(!is_null($request->getPackageUrlUserId())) { |
|
183 | + if (!is_null($request->getPackageUrlUserId())) { |
|
184 | 184 | curl_setopt($ch, CURLOPT_USERPWD, $request->getPackageUrlUserId().":".$request->getPackageUrlPassword()); |
185 | 185 | } |
186 | - if(curl_exec($ch) === false) { |
|
186 | + if (curl_exec($ch) === false) { |
|
187 | 187 | $errno = curl_errno($ch); |
188 | 188 | curl_close($ch); |
189 | 189 | // Error occured. Throw an exception |
190 | - switch($errno) { |
|
190 | + switch ($errno) { |
|
191 | 191 | case CURLE_UNSUPPORTED_PROTOCOL: |
192 | 192 | throw new PENSException(1301); |
193 | 193 | break; |
@@ -223,7 +223,7 @@ discard block |
||
223 | 223 | date_default_timezone_set('UTC'); |
224 | 224 | $current_time = time(); |
225 | 225 | $expiry_time = strtotime($expiry->format(DateTime::ISO8601)); |
226 | - if($current_time > $expiry_time) { |
|
226 | + if ($current_time > $expiry_time) { |
|
227 | 227 | return false; |
228 | 228 | } else { |
229 | 229 | return true; |
@@ -239,17 +239,17 @@ discard block |
||
239 | 239 | * @return PENSResponse Response |
240 | 240 | */ |
241 | 241 | protected function sendAlertOrReceipt($request, $response, $mode) { |
242 | - if($mode == "alert") { |
|
242 | + if ($mode == "alert") { |
|
243 | 243 | $url = $request->getAlerts(); |
244 | 244 | } else { |
245 | 245 | $url = $request->getReceipt(); |
246 | 246 | } |
247 | - if(!empty($url)) { |
|
247 | + if (!empty($url)) { |
|
248 | 248 | $url_components = parse_url($url); |
249 | 249 | $scheme = $url_components["scheme"]; |
250 | - if($scheme == "mailto") { |
|
250 | + if ($scheme == "mailto") { |
|
251 | 251 | $to = $url_components["path"]; |
252 | - if($mode == "alert") { |
|
252 | + if ($mode == "alert") { |
|
253 | 253 | $subject = "PENS Alert for ".$request->getPackageId(); |
254 | 254 | } else { |
255 | 255 | $subject = "PENS Receipt for ".$request->getPackageId(); |
@@ -257,8 +257,8 @@ discard block |
||
257 | 257 | $message = $response->__toString(); |
258 | 258 | mail($to, $subject, $message); |
259 | 259 | return new PENSResponse(0, ""); |
260 | - } else if($scheme == "http" || $scheme == "https") { |
|
261 | - if($mode == "alert") { |
|
260 | + } else if ($scheme == "http" || $scheme == "https") { |
|
261 | + if ($mode == "alert") { |
|
262 | 262 | $params = array_merge($request->getSendAlertArray(), $response->getArray()); |
263 | 263 | } else { |
264 | 264 | $params = array_merge($request->getSendReceiptArray(), $response->getArray()); |
@@ -269,7 +269,7 @@ discard block |
||
269 | 269 | curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
270 | 270 | $data = curl_exec($ch); |
271 | 271 | curl_close($ch); |
272 | - if($data === false) { |
|
272 | + if ($data === false) { |
|
273 | 273 | return null; |
274 | 274 | } else { |
275 | 275 | return new PENSResponse($data); |