| Total Complexity | 490 |
| Total Lines | 2863 |
| Duplicated Lines | 0 % |
| Changes | 2 | ||
| Bugs | 0 | Features | 0 |
Complex classes like HTTP_WebDAV_Server often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use HTTP_WebDAV_Server, and based on these observations, apply Extract Interface, too.
| 1 | <?php // $Id$ |
||
| 49 | class HTTP_WebDAV_Server |
||
| 50 | { |
||
| 51 | // {{{ Member Variables |
||
| 52 | |||
| 53 | /** |
||
| 54 | * complete URI for this request |
||
| 55 | * |
||
| 56 | * @var string |
||
| 57 | */ |
||
| 58 | var $uri; |
||
| 59 | |||
| 60 | /** |
||
| 61 | * base URI for this request |
||
| 62 | * |
||
| 63 | * @var string |
||
| 64 | */ |
||
| 65 | var $base_uri; |
||
| 66 | |||
| 67 | /** |
||
| 68 | * Set if client requires <D:href> to be a url (true) or a path (false). |
||
| 69 | * RFC 4918 allows both: http://www.webdav.org/specs/rfc4918.html#ELEMENT_href |
||
| 70 | * But some clients can NOT deal with one or the other! |
||
| 71 | * |
||
| 72 | * @var boolean |
||
| 73 | */ |
||
| 74 | var $client_require_href_as_url; |
||
| 75 | |||
| 76 | /** |
||
| 77 | * Set if client requires or does not allow namespace redundacy. |
||
| 78 | * The XML Namespace specification does allow both |
||
| 79 | * But some clients can NOT deal with one or the other! |
||
| 80 | * |
||
| 81 | * $this->crrnd === false: |
||
| 82 | * <D:multistatus xmlns:D="DAV:"> |
||
| 83 | * <D:response xmlns:ns0="urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/"> |
||
| 84 | * <D:href>/egroupware/webdav.php/home/ralf/</D:href> |
||
| 85 | * <D:propstat> |
||
| 86 | * <D:prop> |
||
| 87 | * <D:resourcetype><D:collection /></D:resourcetype> |
||
| 88 | * </D:prop> |
||
| 89 | * <D:status>HTTP/1.1 200 OK</D:status> |
||
| 90 | * </D:propstat> |
||
| 91 | * </D:response> |
||
| 92 | * </D:multistatus> |
||
| 93 | * |
||
| 94 | * $this->crrnd === true: |
||
| 95 | * <multistatus xmlns="DAV:"> |
||
| 96 | * <response xmlns:ns0="urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/"> |
||
| 97 | * <href>/egroupware/webdav.php/home/ralf/</href> |
||
| 98 | * <propstat> |
||
| 99 | * <prop> |
||
| 100 | * <resourcetype><collection /></resourcetype> |
||
| 101 | * </prop> |
||
| 102 | * <status>HTTP/1.1 200 OK</status> |
||
| 103 | * </propstat> |
||
| 104 | * </response> |
||
| 105 | * </multistatus> |
||
| 106 | * |
||
| 107 | * @var boolean (client_refuses_redundand_namespace_declarations) |
||
| 108 | */ |
||
| 109 | var $crrnd = false; |
||
| 110 | |||
| 111 | /** |
||
| 112 | |||
| 113 | |||
| 114 | /** |
||
| 115 | * URI path for this request |
||
| 116 | * |
||
| 117 | * @var string |
||
| 118 | */ |
||
| 119 | var $path; |
||
| 120 | |||
| 121 | /** |
||
| 122 | * Realm string to be used in authentification popups |
||
| 123 | * |
||
| 124 | * @var string |
||
| 125 | */ |
||
| 126 | var $http_auth_realm = "PHP WebDAV"; |
||
| 127 | |||
| 128 | /** |
||
| 129 | * String to be used in "X-Dav-Powered-By" header |
||
| 130 | * |
||
| 131 | * @var string |
||
| 132 | */ |
||
| 133 | var $dav_powered_by = ""; |
||
| 134 | |||
| 135 | /** |
||
| 136 | * Remember parsed If: (RFC2518/9.4) header conditions |
||
| 137 | * |
||
| 138 | * @var array |
||
| 139 | */ |
||
| 140 | var $_if_header_uris = array(); |
||
| 141 | |||
| 142 | /** |
||
| 143 | * HTTP response status/message |
||
| 144 | * |
||
| 145 | * @var string |
||
| 146 | */ |
||
| 147 | var $_http_status = "200 OK"; |
||
| 148 | |||
| 149 | /** |
||
| 150 | * encoding of property values passed in |
||
| 151 | * |
||
| 152 | * @var string |
||
| 153 | */ |
||
| 154 | var $_prop_encoding = "utf-8"; |
||
| 155 | |||
| 156 | /** |
||
| 157 | * Copy of $_SERVER superglobal array |
||
| 158 | * |
||
| 159 | * Derived classes may extend the constructor to |
||
| 160 | * modify its contents |
||
| 161 | * |
||
| 162 | * @var array |
||
| 163 | */ |
||
| 164 | var $_SERVER; |
||
| 165 | |||
| 166 | // }}} |
||
| 167 | |||
| 168 | // {{{ Constructor |
||
| 169 | |||
| 170 | /** |
||
| 171 | * Constructor |
||
| 172 | * |
||
| 173 | * @param void |
||
| 174 | */ |
||
| 175 | function __construct() |
||
| 183 | } |
||
| 184 | |||
| 185 | // }}} |
||
| 186 | |||
| 187 | // {{{ ServeRequest() |
||
| 188 | /** |
||
| 189 | * Serve WebDAV HTTP request |
||
| 190 | * |
||
| 191 | * dispatch WebDAV HTTP request to the apropriate method handler |
||
| 192 | * |
||
| 193 | * @param $prefix =null prefix filesystem path with given path, eg. "/webdav" for owncloud 4.5 remote.php |
||
|
|
|||
| 194 | * @return void |
||
| 195 | */ |
||
| 196 | function ServeRequest($prefix=null) |
||
| 197 | { |
||
| 198 | // prevent warning in litmus check 'delete_fragment' |
||
| 199 | if (strstr($this->_SERVER["REQUEST_URI"], '#')) { |
||
| 200 | $this->http_status("400 Bad Request"); |
||
| 201 | return; |
||
| 202 | } |
||
| 203 | |||
| 204 | // default is currently to use just the path, extending class can set $this->client_require_href_as_url depending on user-agent |
||
| 205 | if ($this->client_require_href_as_url) |
||
| 206 | { |
||
| 207 | // default uri is the complete request uri |
||
| 208 | $uri = (@$this->_SERVER["HTTPS"] === "on" ? "https:" : "http:") . '//'.$this->_SERVER['HTTP_HOST']; |
||
| 209 | } |
||
| 210 | $uri .= $this->_SERVER["SCRIPT_NAME"]; |
||
| 211 | |||
| 212 | // WebDAV has no concept of a query string and clients (including cadaver) |
||
| 213 | // seem to pass '?' unencoded, so we need to extract the path info out |
||
| 214 | // of the request URI ourselves |
||
| 215 | // if request URI contains a full url, remove schema and domain |
||
| 216 | $matches = null; |
||
| 217 | if (preg_match('|^https?://[^/]+(/.*)$|', $path_info=$this->_SERVER["REQUEST_URI"], $matches)) |
||
| 218 | { |
||
| 219 | $path_info = $matches[1]; |
||
| 220 | } |
||
| 221 | $path_info_raw = substr($path_info, strlen($this->_SERVER["SCRIPT_NAME"])); |
||
| 222 | |||
| 223 | // just in case the path came in empty ... |
||
| 224 | if (empty($path_info_raw)) { |
||
| 225 | $path_info_raw = "/"; |
||
| 226 | } |
||
| 227 | |||
| 228 | $path_info = self::_urldecode($path_info_raw); |
||
| 229 | |||
| 230 | if ($prefix && strpos($path_info, $prefix) === 0) |
||
| 231 | { |
||
| 232 | $uri .= $prefix; |
||
| 233 | list(,$path_info) = explode($prefix, $path_info, 2); |
||
| 234 | } |
||
| 235 | |||
| 236 | $this->base_uri = $uri; |
||
| 237 | $this->uri = $uri . $path_info; |
||
| 238 | |||
| 239 | // set path |
||
| 240 | // Vfs stores %, # and ? urlencoded, we do the encoding here on a central place |
||
| 241 | $this->path = strtr($path_info,array( |
||
| 242 | '%' => '%25', |
||
| 243 | '#' => '%23', |
||
| 244 | '?' => '%3F', |
||
| 245 | )); |
||
| 246 | if (!strlen($this->path)) { |
||
| 247 | if ($this->_SERVER["REQUEST_METHOD"] == "GET") { |
||
| 248 | // redirect clients that try to GET a collection |
||
| 249 | // WebDAV clients should never try this while |
||
| 250 | // regular HTTP clients might ... |
||
| 251 | header("Location: ".$this->base_uri."/"); |
||
| 252 | return; |
||
| 253 | } else { |
||
| 254 | // if a WebDAV client didn't give a path we just assume '/' |
||
| 255 | $this->path = "/"; |
||
| 256 | } |
||
| 257 | } |
||
| 258 | |||
| 259 | if (ini_get("magic_quotes_gpc")) { |
||
| 260 | $this->path = stripslashes($this->path); |
||
| 261 | } |
||
| 262 | |||
| 263 | |||
| 264 | // identify ourselves |
||
| 265 | if (empty($this->dav_powered_by)) { |
||
| 266 | header("X-Dav-Powered-By: PHP class: ".get_class($this)); |
||
| 267 | } else { |
||
| 268 | header("X-Dav-Powered-By: ".$this->dav_powered_by); |
||
| 269 | } |
||
| 270 | |||
| 271 | // check authentication |
||
| 272 | // for the motivation for not checking OPTIONS requests on / see |
||
| 273 | // http://pear.php.net/bugs/bug.php?id=5363 |
||
| 274 | if ( ( !(($this->_SERVER['REQUEST_METHOD'] == 'OPTIONS') && ($this->path == "/"))) |
||
| 275 | && (!$this->_check_auth())) { |
||
| 276 | // RFC2518 says we must use Digest instead of Basic |
||
| 277 | // but Microsoft Clients do not support Digest |
||
| 278 | // and we don't support NTLM and Kerberos |
||
| 279 | // so we are stuck with Basic here |
||
| 280 | header('WWW-Authenticate: Basic realm="'.($this->http_auth_realm).'"'); |
||
| 281 | |||
| 282 | // Windows seems to require this being the last header sent |
||
| 283 | // (changed according to PECL bug #3138) |
||
| 284 | $this->http_status('401 Unauthorized'); |
||
| 285 | |||
| 286 | return; |
||
| 287 | } |
||
| 288 | |||
| 289 | // check |
||
| 290 | if (! $this->_check_if_header_conditions()) { |
||
| 291 | return; |
||
| 292 | } |
||
| 293 | |||
| 294 | // detect requested method names |
||
| 295 | $method = strtolower($this->_SERVER["REQUEST_METHOD"]); |
||
| 296 | $wrapper = "http_".$method; |
||
| 297 | |||
| 298 | // activate HEAD emulation by GET if no HEAD method found |
||
| 299 | if ($method == "head" && !method_exists($this, "head")) { |
||
| 300 | $method = "get"; |
||
| 301 | } |
||
| 302 | |||
| 303 | if (method_exists($this, $wrapper) && ($method == "options" || method_exists($this, $method))) { |
||
| 304 | $this->$wrapper(); // call method by name |
||
| 305 | } else { // method not found/implemented |
||
| 306 | if ($this->_SERVER["REQUEST_METHOD"] == "LOCK") { |
||
| 307 | $error = '412 Precondition failed'; |
||
| 308 | } else { |
||
| 309 | $error = '405 Method not allowed'; |
||
| 310 | header("Allow: ".join(", ", $this->_allow())); // tell client what's allowed |
||
| 311 | } |
||
| 312 | $this->http_status($error); |
||
| 313 | echo "<html><head><title>Error $error</title></head>\n"; |
||
| 314 | echo "<body><h1>$error</h1>\n"; |
||
| 315 | echo "The requested could not by handled by this server.\n"; |
||
| 316 | echo '(URI ' . $this->_SERVER['REQUEST_URI'] . ")<br>\n<br>\n"; |
||
| 317 | echo "</body></html>\n"; |
||
| 318 | } |
||
| 319 | } |
||
| 320 | |||
| 321 | // }}} |
||
| 322 | |||
| 323 | // {{{ abstract WebDAV methods |
||
| 324 | |||
| 325 | // {{{ GET() |
||
| 326 | /** |
||
| 327 | * GET implementation |
||
| 328 | * |
||
| 329 | * overload this method to retrieve resources from your server |
||
| 330 | * <br> |
||
| 331 | * |
||
| 332 | * |
||
| 333 | * @abstract |
||
| 334 | * @param array &$params Array of input and output parameters |
||
| 335 | * <br><b>input</b><ul> |
||
| 336 | * <li> path - |
||
| 337 | * </ul> |
||
| 338 | * <br><b>output</b><ul> |
||
| 339 | * <li> size - |
||
| 340 | * </ul> |
||
| 341 | * @returns int HTTP-Statuscode |
||
| 342 | */ |
||
| 343 | |||
| 344 | /* abstract |
||
| 345 | function GET(&$params) |
||
| 346 | { |
||
| 347 | // dummy entry for PHPDoc |
||
| 348 | } |
||
| 349 | */ |
||
| 350 | |||
| 351 | // }}} |
||
| 352 | |||
| 353 | // {{{ PUT() |
||
| 354 | /** |
||
| 355 | * PUT implementation |
||
| 356 | * |
||
| 357 | * PUT implementation |
||
| 358 | * |
||
| 359 | * @abstract |
||
| 360 | * @param array &$params |
||
| 361 | * @returns int HTTP-Statuscode |
||
| 362 | */ |
||
| 363 | |||
| 364 | /* abstract |
||
| 365 | function PUT() |
||
| 366 | { |
||
| 367 | // dummy entry for PHPDoc |
||
| 368 | } |
||
| 369 | */ |
||
| 370 | |||
| 371 | // }}} |
||
| 372 | |||
| 373 | // {{{ COPY() |
||
| 374 | |||
| 375 | /** |
||
| 376 | * COPY implementation |
||
| 377 | * |
||
| 378 | * COPY implementation |
||
| 379 | * |
||
| 380 | * @abstract |
||
| 381 | * @param array &$params |
||
| 382 | * @returns int HTTP-Statuscode |
||
| 383 | */ |
||
| 384 | |||
| 385 | /* abstract |
||
| 386 | function COPY() |
||
| 387 | { |
||
| 388 | // dummy entry for PHPDoc |
||
| 389 | } |
||
| 390 | */ |
||
| 391 | |||
| 392 | // }}} |
||
| 393 | |||
| 394 | // {{{ MOVE() |
||
| 395 | |||
| 396 | /** |
||
| 397 | * MOVE implementation |
||
| 398 | * |
||
| 399 | * MOVE implementation |
||
| 400 | * |
||
| 401 | * @abstract |
||
| 402 | * @param array &$params |
||
| 403 | * @returns int HTTP-Statuscode |
||
| 404 | */ |
||
| 405 | |||
| 406 | /* abstract |
||
| 407 | function MOVE() |
||
| 408 | { |
||
| 409 | // dummy entry for PHPDoc |
||
| 410 | } |
||
| 411 | */ |
||
| 412 | |||
| 413 | // }}} |
||
| 414 | |||
| 415 | // {{{ DELETE() |
||
| 416 | |||
| 417 | /** |
||
| 418 | * DELETE implementation |
||
| 419 | * |
||
| 420 | * DELETE implementation |
||
| 421 | * |
||
| 422 | * @abstract |
||
| 423 | * @param array &$params |
||
| 424 | * @returns int HTTP-Statuscode |
||
| 425 | */ |
||
| 426 | |||
| 427 | /* abstract |
||
| 428 | function DELETE() |
||
| 429 | { |
||
| 430 | // dummy entry for PHPDoc |
||
| 431 | } |
||
| 432 | */ |
||
| 433 | // }}} |
||
| 434 | |||
| 435 | // {{{ PROPFIND() |
||
| 436 | |||
| 437 | /** |
||
| 438 | * PROPFIND implementation |
||
| 439 | * |
||
| 440 | * PROPFIND implementation |
||
| 441 | * |
||
| 442 | * @abstract |
||
| 443 | * @param array &$params |
||
| 444 | * @returns int HTTP-Statuscode |
||
| 445 | */ |
||
| 446 | |||
| 447 | /* abstract |
||
| 448 | function PROPFIND() |
||
| 449 | { |
||
| 450 | // dummy entry for PHPDoc |
||
| 451 | } |
||
| 452 | */ |
||
| 453 | |||
| 454 | // }}} |
||
| 455 | |||
| 456 | // {{{ PROPPATCH() |
||
| 457 | |||
| 458 | /** |
||
| 459 | * PROPPATCH implementation |
||
| 460 | * |
||
| 461 | * PROPPATCH implementation |
||
| 462 | * |
||
| 463 | * @abstract |
||
| 464 | * @param array &$params |
||
| 465 | * @returns int HTTP-Statuscode |
||
| 466 | */ |
||
| 467 | |||
| 468 | /* abstract |
||
| 469 | function PROPPATCH() |
||
| 470 | { |
||
| 471 | // dummy entry for PHPDoc |
||
| 472 | } |
||
| 473 | */ |
||
| 474 | // }}} |
||
| 475 | |||
| 476 | // {{{ LOCK() |
||
| 477 | |||
| 478 | /** |
||
| 479 | * LOCK implementation |
||
| 480 | * |
||
| 481 | * LOCK implementation |
||
| 482 | * |
||
| 483 | * @abstract |
||
| 484 | * @param array &$params |
||
| 485 | * @returns int HTTP-Statuscode |
||
| 486 | */ |
||
| 487 | |||
| 488 | /* abstract |
||
| 489 | function LOCK() |
||
| 490 | { |
||
| 491 | // dummy entry for PHPDoc |
||
| 492 | } |
||
| 493 | */ |
||
| 494 | // }}} |
||
| 495 | |||
| 496 | // {{{ UNLOCK() |
||
| 497 | |||
| 498 | /** |
||
| 499 | * UNLOCK implementation |
||
| 500 | * |
||
| 501 | * UNLOCK implementation |
||
| 502 | * |
||
| 503 | * @abstract |
||
| 504 | * @param array &$params |
||
| 505 | * @returns int HTTP-Statuscode |
||
| 506 | */ |
||
| 507 | |||
| 508 | /* abstract |
||
| 509 | function UNLOCK() |
||
| 510 | { |
||
| 511 | // dummy entry for PHPDoc |
||
| 512 | } |
||
| 513 | */ |
||
| 514 | // }}} |
||
| 515 | |||
| 516 | // {{{ ACL() |
||
| 517 | |||
| 518 | /** |
||
| 519 | * ACL implementation |
||
| 520 | * |
||
| 521 | * ACL implementation |
||
| 522 | * |
||
| 523 | * @abstract |
||
| 524 | * @param array &$params |
||
| 525 | * @returns int HTTP-Statuscode |
||
| 526 | */ |
||
| 527 | |||
| 528 | /* abstract |
||
| 529 | function ACL() |
||
| 530 | { |
||
| 531 | // dummy entry for PHPDoc |
||
| 532 | } |
||
| 533 | */ |
||
| 534 | // }}} |
||
| 535 | |||
| 536 | // }}} |
||
| 537 | |||
| 538 | // {{{ other abstract methods |
||
| 539 | |||
| 540 | // {{{ check_auth() |
||
| 541 | |||
| 542 | /** |
||
| 543 | * check authentication |
||
| 544 | * |
||
| 545 | * overload this method to retrieve and confirm authentication information |
||
| 546 | * |
||
| 547 | * @abstract |
||
| 548 | * @param string type Authentication type, e.g. "basic" or "digest" |
||
| 549 | * @param string username Transmitted username |
||
| 550 | * @param string passwort Transmitted password |
||
| 551 | * @returns bool Authentication status |
||
| 552 | */ |
||
| 553 | |||
| 554 | /* abstract |
||
| 555 | function checkAuth($type, $username, $password) |
||
| 556 | { |
||
| 557 | // dummy entry for PHPDoc |
||
| 558 | } |
||
| 559 | */ |
||
| 560 | |||
| 561 | // }}} |
||
| 562 | |||
| 563 | // {{{ checklock() |
||
| 564 | |||
| 565 | /** |
||
| 566 | * check lock status for a resource |
||
| 567 | * |
||
| 568 | * overload this method to return shared and exclusive locks |
||
| 569 | * active for this resource |
||
| 570 | * |
||
| 571 | * @abstract |
||
| 572 | * @param string resource Resource path to check |
||
| 573 | * @returns array An array of lock entries each consisting |
||
| 574 | * of 'type' ('shared'/'exclusive'), 'token' and 'timeout' |
||
| 575 | */ |
||
| 576 | |||
| 577 | /* abstract |
||
| 578 | function checklock($resource) |
||
| 579 | { |
||
| 580 | // dummy entry for PHPDoc |
||
| 581 | } |
||
| 582 | */ |
||
| 583 | |||
| 584 | // }}} |
||
| 585 | |||
| 586 | // }}} |
||
| 587 | |||
| 588 | // {{{ WebDAV HTTP method wrappers |
||
| 589 | |||
| 590 | // {{{ http_OPTIONS() |
||
| 591 | |||
| 592 | /** |
||
| 593 | * OPTIONS method handler |
||
| 594 | * |
||
| 595 | * The OPTIONS method handler creates a valid OPTIONS reply |
||
| 596 | * including Dav: and Allowed: headers |
||
| 597 | * based on the implemented methods found in the actual instance |
||
| 598 | * |
||
| 599 | * @param void |
||
| 600 | * @return void |
||
| 601 | */ |
||
| 602 | function http_OPTIONS() |
||
| 628 | } |
||
| 629 | |||
| 630 | // }}} |
||
| 631 | |||
| 632 | |||
| 633 | // {{{ http_PROPFIND() |
||
| 634 | |||
| 635 | /** |
||
| 636 | * Should the whole PROPFIND request (xml) be stored |
||
| 637 | * |
||
| 638 | * @var boolean |
||
| 639 | */ |
||
| 640 | var $store_request = false; |
||
| 641 | /** |
||
| 642 | * Content of (last) PROPFIND request |
||
| 643 | * |
||
| 644 | * @var string |
||
| 645 | */ |
||
| 646 | var $request; |
||
| 647 | |||
| 648 | /** |
||
| 649 | * PROPFIND method handler |
||
| 650 | * |
||
| 651 | * @param string $handler ='PROPFIND' allows to use method eg. for CalDAV REPORT |
||
| 652 | * @return void |
||
| 653 | */ |
||
| 654 | function http_PROPFIND($handler='PROPFIND') |
||
| 767 | } |
||
| 768 | |||
| 769 | /** |
||
| 770 | * Render (echo) XML for given multistatus responses |
||
| 771 | * |
||
| 772 | * @param array|Iterator $files |
||
| 773 | * @param array|string $props |
||
| 774 | */ |
||
| 775 | function multistatus_responses(&$files, $props, $initial_ns_hash=null, $initial_ns_defs=null) |
||
| 776 | { |
||
| 777 | if (!isset($initial_ns_hash)) $initial_ns_hash = array('DAV:' => 'D'); |
||
| 778 | if (!isset($initial_ns_defs)) $initial_ns_defs = 'xmlns:ns0="urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/"'; |
||
| 779 | |||
| 780 | // using an ArrayIterator to prevent foreach from copying the array, |
||
| 781 | // as we cant loop by reference, when an iterator is given in $files |
||
| 782 | if (is_array($files)) |
||
| 783 | { |
||
| 784 | $files = new ArrayIterator($files); |
||
| 785 | } |
||
| 786 | // support for "Prefer: depth-noroot" header on PROPFIND |
||
| 787 | $skip_root = $this->_SERVER['REQUEST_METHOD'] == 'PROPFIND' && |
||
| 788 | !isset($initial_ns_hash) && // multistatus_response calls itself, do NOT apply skip in that case |
||
| 789 | isset($this->_SERVER['HTTP_PREFER']) && in_array('depth-noroot', preg_split('/, ?/', $this->_SERVER['HTTP_PREFER'])); |
||
| 790 | |||
| 791 | // now we loop over all returned file entries |
||
| 792 | foreach ($files as $file) { |
||
| 793 | |||
| 794 | // skip first element (root), if requested by Prefer: depth-noroot |
||
| 795 | if ($skip_root) { |
||
| 796 | $skip_root = false; |
||
| 797 | continue; |
||
| 798 | } |
||
| 799 | |||
| 800 | // collect namespaces here |
||
| 801 | $ns_hash = $initial_ns_hash; |
||
| 802 | |||
| 803 | // Microsoft Clients need this special namespace for date and time values |
||
| 804 | $ns_defs = $initial_ns_defs; |
||
| 805 | |||
| 806 | // nothing to do if no properties were returend for a file |
||
| 807 | if (isset($file["props"]) && is_array($file["props"])) { |
||
| 808 | |||
| 809 | // now loop over all returned properties |
||
| 810 | foreach ($file["props"] as &$prop) { |
||
| 811 | // as a convenience feature we do not require that user handlers |
||
| 812 | // restrict returned properties to the requested ones |
||
| 813 | // here we strip all unrequested entries out of the response |
||
| 814 | |||
| 815 | // this can happen if we have allprop and prop in one propfind: |
||
| 816 | // <allprop /><prop><blah /></prop>, eg. blah is not automatic returned by allprop |
||
| 817 | switch(is_array($props) ? $props[0] : $props) { |
||
| 818 | case "all": |
||
| 819 | // nothing to remove |
||
| 820 | break; |
||
| 821 | |||
| 822 | case "names": |
||
| 823 | // only the names of all existing properties were requested |
||
| 824 | // so we remove all values |
||
| 825 | unset($prop["val"]); |
||
| 826 | break; |
||
| 827 | |||
| 828 | default: |
||
| 829 | $found = false; |
||
| 830 | |||
| 831 | // search property name in requested properties |
||
| 832 | foreach ((array)$props as $reqprop) { |
||
| 833 | if ( $reqprop["name"] == $prop["name"] |
||
| 834 | && @$reqprop["xmlns"] == $prop["ns"]) { |
||
| 835 | $found = true; |
||
| 836 | break; |
||
| 837 | } |
||
| 838 | } |
||
| 839 | |||
| 840 | // unset property and continue with next one if not found/requested |
||
| 841 | if (!$found) { |
||
| 842 | $prop=""; |
||
| 843 | continue(2); |
||
| 844 | } |
||
| 845 | break; |
||
| 846 | } |
||
| 847 | |||
| 848 | // namespace handling |
||
| 849 | if (empty($prop["ns"])) continue; // no namespace |
||
| 850 | $ns = $prop["ns"]; |
||
| 851 | //if ($ns == "DAV:") continue; // default namespace |
||
| 852 | if (isset($ns_hash[$ns])) continue; // already known |
||
| 853 | |||
| 854 | // register namespace |
||
| 855 | $ns_name = "ns".(count($ns_hash) + 1); |
||
| 856 | $ns_hash[$ns] = $ns_name; |
||
| 857 | $ns_defs .= " xmlns:$ns_name=\"$ns\""; |
||
| 858 | } |
||
| 859 | |||
| 860 | // we also need to add empty entries for properties that were requested |
||
| 861 | // but for which no values where returned by the user handler |
||
| 862 | if (is_array($props)) { |
||
| 863 | foreach ($props as $reqprop) { |
||
| 864 | if (!is_array($reqprop) || $reqprop['name']=="") continue; // skip empty entries, or 'all' if <allprop /> used together with <prop> |
||
| 865 | |||
| 866 | $found = false; |
||
| 867 | |||
| 868 | // check if property exists in result |
||
| 869 | foreach ($file["props"] as &$prop) { |
||
| 870 | if (is_array($prop) && $reqprop["name"] == $prop["name"] |
||
| 871 | && @$reqprop["xmlns"] == $prop["ns"]) { |
||
| 872 | $found = true; |
||
| 873 | break; |
||
| 874 | } |
||
| 875 | } |
||
| 876 | |||
| 877 | if (!$found) { |
||
| 878 | if ($reqprop["xmlns"]==="DAV:" && $reqprop["name"]==="lockdiscovery") { |
||
| 879 | // lockdiscovery is handled by the base class |
||
| 880 | $file["props"][] |
||
| 881 | = $this->mkprop("DAV:", |
||
| 882 | "lockdiscovery", |
||
| 883 | $this->lockdiscovery($file['path'])); |
||
| 884 | // only collect $file['noprops'] if we have NO Brief: t and NO Prefer: return=minimal HTTP Header |
||
| 885 | } elseif ((!isset($this->_SERVER['HTTP_BRIEF']) || $this->_SERVER['HTTP_BRIEF'] != 't') && |
||
| 886 | (!isset($this->_SERVER['HTTP_PREFER']) || !in_array('return=minimal', preg_split('/, ?/', $this->_SERVER['HTTP_PREFER'])))) { |
||
| 887 | // add empty value for this property |
||
| 888 | $file["noprops"][] = |
||
| 889 | $this->mkprop($reqprop["xmlns"], $reqprop["name"], ""); |
||
| 890 | |||
| 891 | // register property namespace if not known yet |
||
| 892 | if ($reqprop["xmlns"] != "DAV:" && !isset($ns_hash[$reqprop["xmlns"]])) { |
||
| 893 | $ns_name = "ns".(count($ns_hash) + 1); |
||
| 894 | $ns_hash[$reqprop["xmlns"]] = $ns_name; |
||
| 895 | $ns_defs .= " xmlns:$ns_name=\"$reqprop[xmlns]\""; |
||
| 896 | } |
||
| 897 | } |
||
| 898 | } |
||
| 899 | } |
||
| 900 | } |
||
| 901 | } |
||
| 902 | // ignore empty or incomplete entries |
||
| 903 | if (!is_array($file) || empty($file) || !isset($file["path"])) continue; |
||
| 904 | $path = $file['path']; |
||
| 905 | if (!is_string($path) || $path==="") continue; |
||
| 906 | |||
| 907 | if ($this->crrnd) |
||
| 908 | { |
||
| 909 | echo " <response $ns_defs>\n"; |
||
| 910 | } |
||
| 911 | else |
||
| 912 | { |
||
| 913 | echo " <D:response $ns_defs>\n"; |
||
| 914 | } |
||
| 915 | |||
| 916 | /* TODO right now the user implementation has to make sure |
||
| 917 | collections end in a slash, this should be done in here |
||
| 918 | by checking the resource attribute */ |
||
| 919 | $href_raw = $this->_mergePaths($this->base_uri, $path); |
||
| 920 | |||
| 921 | /* minimal urlencoding is needed for the resource path */ |
||
| 922 | $href = $this->_urlencode($href_raw); |
||
| 923 | |||
| 924 | if ($this->crrnd) |
||
| 925 | { |
||
| 926 | echo " <href>$href</href>\n"; |
||
| 927 | } |
||
| 928 | else |
||
| 929 | { |
||
| 930 | echo " <D:href>$href</D:href>\n"; |
||
| 931 | } |
||
| 932 | |||
| 933 | // report all found properties and their values (if any) |
||
| 934 | if (isset($file["props"]) && is_array($file["props"])) { |
||
| 935 | echo ' <'.($this->crrnd?'':'D:')."propstat>\n"; |
||
| 936 | echo ' <'.($this->crrnd?'':'D:')."prop>\n"; |
||
| 937 | |||
| 938 | foreach ($file["props"] as &$prop) { |
||
| 939 | |||
| 940 | if (!is_array($prop)) continue; |
||
| 941 | if (!isset($prop["name"])) continue; |
||
| 942 | |||
| 943 | if (!isset($prop["val"]) || $prop["val"] === "" || $prop["val"] === false) { |
||
| 944 | // empty properties (cannot use empty() for check as "0" is a legal value here) |
||
| 945 | if ($prop["ns"]=="DAV:") { |
||
| 946 | echo ' <'.($this->crrnd?'':'D:')."$prop[name]/>\n"; |
||
| 947 | } else if (!empty($prop["ns"])) { |
||
| 948 | echo " <".$ns_hash[$prop["ns"]].":$prop[name]/>\n"; |
||
| 949 | } else { |
||
| 950 | echo " <$prop[name] xmlns=\"\"/>"; |
||
| 951 | } |
||
| 952 | } |
||
| 953 | // multiple level of responses required for expand-property reports |
||
| 954 | elseif(isset($prop['props']) && is_array($prop['val'])) |
||
| 955 | { |
||
| 956 | if ($prop['ns'] && !isset($ns_hash[$prop['ns']])) { |
||
| 957 | $ns_name = "ns".(count($ns_hash) + 1); |
||
| 958 | $ns_hash[$prop['ns']] = $ns_name; |
||
| 959 | } |
||
| 960 | echo ' <'.$ns_hash[$prop['ns']].":$prop[name]>\n"; |
||
| 961 | $this->multistatus_responses($prop['val'], $prop['props'], $ns_hash, ''); |
||
| 962 | echo ' </'.$ns_hash[$prop['ns']].":$prop[name]>\n"; |
||
| 963 | } else if ($prop["ns"] == "DAV:") { |
||
| 964 | // some WebDAV properties need special treatment |
||
| 965 | switch ($prop["name"]) { |
||
| 966 | case "creationdate": |
||
| 967 | echo ' <'.($this->crrnd?'':'D:')."creationdate ns0:dt=\"dateTime.tz\">" |
||
| 968 | . gmdate("Y-m-d\\TH:i:s\\Z", $prop['val']) |
||
| 969 | . '</'.($this->crrnd?'':'D:')."creationdate>\n"; |
||
| 970 | break; |
||
| 971 | case "getlastmodified": |
||
| 972 | echo ' <'.($this->crrnd?'':'D:')."getlastmodified ns0:dt=\"dateTime.rfc1123\">" |
||
| 973 | . gmdate("D, d M Y H:i:s ", $prop['val']) |
||
| 974 | . "GMT</".($this->crrnd?'':'D:')."getlastmodified>\n"; |
||
| 975 | break; |
||
| 976 | case "supportedlock": |
||
| 977 | echo ' <'.($this->crrnd?'':'D:')."supportedlock>$prop[val]</".($this->crrnd?'':'D:')."supportedlock>\n"; |
||
| 978 | break; |
||
| 979 | case "lockdiscovery": |
||
| 980 | echo ' <'.($this->crrnd?'':'D:')."lockdiscovery>\n"; |
||
| 981 | echo $prop["val"]; |
||
| 982 | echo ' </'.($this->crrnd?'':'D:')."lockdiscovery>\n"; |
||
| 983 | break; |
||
| 984 | // the following are non-standard Microsoft extensions to the DAV namespace |
||
| 985 | case "lastaccessed": |
||
| 986 | echo ' <'.($this->crrnd?'':'D:')."lastaccessed ns0:dt=\"dateTime.rfc1123\">" |
||
| 987 | . gmdate("D, d M Y H:i:s ", $prop['val']) |
||
| 988 | . 'GMT</'.($this->crrnd?'':'D:')."lastaccessed>\n"; |
||
| 989 | break; |
||
| 990 | case "ishidden": |
||
| 991 | echo ' <'.($this->crrnd?'':'D:')."ishidden>" |
||
| 992 | . is_string($prop['val']) ? $prop['val'] : ($prop['val'] ? 'true' : 'false') |
||
| 993 | . '</'.($this->crrnd?'':'D:')."</D:ishidden>\n"; |
||
| 994 | break; |
||
| 995 | default: |
||
| 996 | $ns_defs = ''; |
||
| 997 | if (is_array($prop['val'])) |
||
| 998 | { |
||
| 999 | $hns_hash = $ns_hash; |
||
| 1000 | $val = $this->_hierarchical_prop_encode($prop['val'], 'DAV:', $ns_defs, $hns_hash); |
||
| 1001 | } elseif (isset($prop['raw'])) { |
||
| 1002 | $val = $this->_prop_encode('<![CDATA['.$prop['val'].']]>'); |
||
| 1003 | } else { |
||
| 1004 | $val = $this->_prop_encode(htmlspecialchars($prop['val'], ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8')); |
||
| 1005 | } |
||
| 1006 | echo ' <'.($this->crrnd?'':'D:')."$prop[name]$ns_defs>$val". |
||
| 1007 | '</'.($this->crrnd?'':'D:')."$prop[name]>\n"; |
||
| 1008 | break; |
||
| 1009 | } |
||
| 1010 | } else { |
||
| 1011 | // allow multiple values and attributes, required eg. for caldav:supported-calendar-component-set |
||
| 1012 | if ($prop['ns'] && is_array($prop['val'])) { |
||
| 1013 | if (!isset($ns_hash[$prop['ns']])) { |
||
| 1014 | $ns_name = "ns".(count($ns_hash) + 1); |
||
| 1015 | $ns_hash[$prop['ns']] = $ns_name; |
||
| 1016 | } |
||
| 1017 | $vals = $extra_ns = ''; |
||
| 1018 | foreach($prop['val'] as $subprop) |
||
| 1019 | { |
||
| 1020 | if ($subprop['ns'] && $subprop['ns'] != 'DAV:') { |
||
| 1021 | // register property namespace if not known yet |
||
| 1022 | if (!isset($ns_hash[$subprop['ns']])) { |
||
| 1023 | $ns_name = "ns".(count($ns_hash) + 1); |
||
| 1024 | $ns_hash[$subprop['ns']] = $ns_name; |
||
| 1025 | } else { |
||
| 1026 | $ns_name = $ns_hash[$subprop['ns']]; |
||
| 1027 | } |
||
| 1028 | if (strchr($extra_ns,$extra=' xmlns:'.$ns_name.'="'.$subprop['ns'].'"') === false) { |
||
| 1029 | $extra_ns .= $extra; |
||
| 1030 | } |
||
| 1031 | $ns_name .= ':'; |
||
| 1032 | } elseif ($subprop['ns'] == 'DAV:') { |
||
| 1033 | $ns_name = 'D:'; |
||
| 1034 | } else { |
||
| 1035 | $ns_name = ''; |
||
| 1036 | } |
||
| 1037 | $vals .= "<$ns_name$subprop[name]"; |
||
| 1038 | if (is_array($subprop['val'])) |
||
| 1039 | { |
||
| 1040 | if (isset($subprop['val'][0])) |
||
| 1041 | { |
||
| 1042 | $vals .= '>'; |
||
| 1043 | $vals .= $this->_hierarchical_prop_encode($subprop['val'], $subprop['ns'], $ns_defs, $ns_hash); |
||
| 1044 | $vals .= "</$ns_name$subprop[name]>"; |
||
| 1045 | } |
||
| 1046 | else // val contains only attributes, no value |
||
| 1047 | { |
||
| 1048 | foreach($subprop['val'] as $attr => $val) |
||
| 1049 | { |
||
| 1050 | $vals .= ' '.$attr.'="'.htmlspecialchars($val, ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8').'"'; |
||
| 1051 | } |
||
| 1052 | $vals .= '/>'; |
||
| 1053 | } |
||
| 1054 | } |
||
| 1055 | else |
||
| 1056 | { |
||
| 1057 | $vals .= '>'; |
||
| 1058 | if (isset($subprop['raw'])) { |
||
| 1059 | $vals .= '<![CDATA['.$subprop['val'].']]>'; |
||
| 1060 | } else { |
||
| 1061 | // do NOT urlencode mailto href, as no clients understands them |
||
| 1062 | if ($subprop['name'] == 'href' && strpos($subprop['val'], 'mailto:') !== 0) |
||
| 1063 | { |
||
| 1064 | $subprop['val'] = $this->_urlencode($subprop['val']); |
||
| 1065 | } |
||
| 1066 | $vals .= htmlspecialchars($subprop['val'], ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8'); |
||
| 1067 | } |
||
| 1068 | $vals .= "</$ns_name$subprop[name]>"; |
||
| 1069 | } |
||
| 1070 | } |
||
| 1071 | echo ' <'.$ns_hash[$prop['ns']].":$prop[name]$extra_ns>$vals</".$ns_hash[$prop['ns']].":$prop[name]>\n"; |
||
| 1072 | } else { |
||
| 1073 | if ($prop['raw']) |
||
| 1074 | { |
||
| 1075 | $val = '<![CDATA['.$prop['val'].']]>'; |
||
| 1076 | } else { |
||
| 1077 | $val = htmlspecialchars($prop['val'], ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8'); |
||
| 1078 | } |
||
| 1079 | $val = $this->_prop_encode($val); |
||
| 1080 | // properties from namespaces != "DAV:" or without any namespace |
||
| 1081 | if ($prop['ns']) { |
||
| 1082 | if ($this->crrnd) { |
||
| 1083 | echo " <$prop[name] xmlns=".'"'.$prop["ns"].'">' |
||
| 1084 | . $val . "</$prop[name]>\n"; |
||
| 1085 | } else { |
||
| 1086 | echo " <" . $ns_hash[$prop["ns"]] . ":$prop[name]>" |
||
| 1087 | . $val . '</'.$ns_hash[$prop['ns']].":$prop[name]>\n"; |
||
| 1088 | } |
||
| 1089 | } else { |
||
| 1090 | echo " <$prop[name] xmlns=\"\">$val</$prop[name]>\n"; |
||
| 1091 | } |
||
| 1092 | } |
||
| 1093 | } |
||
| 1094 | } |
||
| 1095 | |||
| 1096 | if ($this->crrnd) |
||
| 1097 | { |
||
| 1098 | echo " </prop>\n"; |
||
| 1099 | echo " <status>HTTP/1.1 200 OK</status>\n"; |
||
| 1100 | echo " </propstat>\n"; |
||
| 1101 | } |
||
| 1102 | else |
||
| 1103 | { |
||
| 1104 | echo " </D:prop>\n"; |
||
| 1105 | echo " <D:status>HTTP/1.1 200 OK</D:status>\n"; |
||
| 1106 | echo " </D:propstat>\n"; |
||
| 1107 | } |
||
| 1108 | } |
||
| 1109 | |||
| 1110 | // now report all properties requested but not found |
||
| 1111 | if (isset($file["noprops"])) { |
||
| 1112 | echo ' <'.($this->crrnd?'':'D:')."propstat>\n"; |
||
| 1113 | echo ' <'.($this->crrnd?'':'D:')."prop>\n"; |
||
| 1114 | |||
| 1115 | foreach ($file["noprops"] as &$prop) { |
||
| 1116 | if ($prop["ns"] == "DAV:") { |
||
| 1117 | echo ' <'.($this->crrnd?'':'D:')."$prop[name]/>\n"; |
||
| 1118 | } else if ($prop["ns"] == "") { |
||
| 1119 | echo " <$prop[name] xmlns=\"\"/>\n"; |
||
| 1120 | } else { |
||
| 1121 | echo " <" . $ns_hash[$prop["ns"]] . ":$prop[name]/>\n"; |
||
| 1122 | } |
||
| 1123 | } |
||
| 1124 | |||
| 1125 | if ($this->crrnd) |
||
| 1126 | { |
||
| 1127 | echo " </prop>\n"; |
||
| 1128 | echo " <status>HTTP/1.1 404 Not Found</status>\n"; |
||
| 1129 | echo " </propstat>\n"; |
||
| 1130 | } |
||
| 1131 | else |
||
| 1132 | { |
||
| 1133 | echo " </D:prop>\n"; |
||
| 1134 | echo " <D:status>HTTP/1.1 404 Not Found</D:status>\n"; |
||
| 1135 | echo " </D:propstat>\n"; |
||
| 1136 | } |
||
| 1137 | } |
||
| 1138 | |||
| 1139 | // 404 Not Found status element for WebDAV sync report |
||
| 1140 | if (!isset($file['props']) && !isset($file['noprops'])) |
||
| 1141 | { |
||
| 1142 | if ($this->crrnd) |
||
| 1143 | { |
||
| 1144 | echo " <status>HTTP/1.1 404 Not Found</status>\n"; |
||
| 1145 | } |
||
| 1146 | else |
||
| 1147 | { |
||
| 1148 | echo " <D:status>HTTP/1.1 404 Not Found</D:status>\n"; |
||
| 1149 | } |
||
| 1150 | } |
||
| 1151 | |||
| 1152 | echo ' </'.($this->crrnd?'':'D:')."response>\n"; |
||
| 1153 | } |
||
| 1154 | } |
||
| 1155 | |||
| 1156 | |||
| 1157 | // }}} |
||
| 1158 | |||
| 1159 | // {{{ http_PROPPATCH() |
||
| 1160 | |||
| 1161 | /** |
||
| 1162 | * PROPPATCH method handler |
||
| 1163 | * |
||
| 1164 | * @param void |
||
| 1165 | * @return void |
||
| 1166 | */ |
||
| 1167 | function http_PROPPATCH() |
||
| 1168 | { |
||
| 1169 | if ($this->_check_lock_status($this->path)) { |
||
| 1170 | $options = Array(); |
||
| 1171 | |||
| 1172 | $options["path"] = $this->path; |
||
| 1173 | |||
| 1174 | $propinfo = new _parse_proppatch("php://input", $this->store_request); |
||
| 1175 | if ($this->store_request) $this->request = $propinfo->request; |
||
| 1176 | |||
| 1177 | if (!$propinfo->success) { |
||
| 1178 | $this->http_status("400 Error"); |
||
| 1179 | return; |
||
| 1180 | } |
||
| 1181 | |||
| 1182 | $options['props'] = $propinfo->props; |
||
| 1183 | |||
| 1184 | $responsedescr = $this->PROPPATCH($options); |
||
| 1185 | |||
| 1186 | $this->http_status("207 Multi-Status"); |
||
| 1187 | header('Content-Type: text/xml; charset="utf-8"'); |
||
| 1188 | |||
| 1189 | echo "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"; |
||
| 1190 | |||
| 1191 | echo "<D:multistatus xmlns:D=\"DAV:\">\n"; |
||
| 1192 | echo ' <'.($this->crrnd?'':'D:')."response>\n"; |
||
| 1193 | echo ' <'.($this->crrnd?'':'D:')."href>".$this->_urlencode($this->_mergePaths($this->_SERVER["SCRIPT_NAME"], $this->path)).'</'.($this->crrnd?'':'D:')."href>\n"; |
||
| 1194 | |||
| 1195 | foreach ($options["props"] as $prop) { |
||
| 1196 | echo ' <'.($this->crrnd?'':'D:')."propstat>\n"; |
||
| 1197 | echo ' <'.($this->crrnd?'':'D:')."prop><$prop[name] xmlns=\"$prop[ns]\"/></".($this->crrnd?'':'D:')."prop>\n"; |
||
| 1198 | echo ' <'.($this->crrnd?'':'D:')."status>HTTP/1.1 $prop[status]</".($this->crrnd?'':'D:')."status>\n"; |
||
| 1199 | echo ' </'.($this->crrnd?'':'D:')."propstat>\n"; |
||
| 1200 | } |
||
| 1201 | |||
| 1202 | if ($responsedescr) { |
||
| 1203 | echo ' <'.($this->crrnd?'':'D:')."responsedescription>". |
||
| 1204 | $this->_prop_encode(htmlspecialchars($responsedescr, ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8')). |
||
| 1205 | '</'.($this->crrnd?'':'D:')."responsedescription>\n"; |
||
| 1206 | } |
||
| 1207 | |||
| 1208 | echo ' </'.($this->crrnd?'':'D:')."response>\n"; |
||
| 1209 | echo '</'.($this->crrnd?'':'D:')."multistatus>\n"; |
||
| 1210 | } else { |
||
| 1211 | $this->http_status("423 Locked"); |
||
| 1212 | } |
||
| 1213 | } |
||
| 1214 | |||
| 1215 | // }}} |
||
| 1216 | |||
| 1217 | |||
| 1218 | // {{{ http_MKCOL() |
||
| 1219 | |||
| 1220 | /** |
||
| 1221 | * MKCOL method handler |
||
| 1222 | * |
||
| 1223 | * @param void |
||
| 1224 | * @return void |
||
| 1225 | */ |
||
| 1226 | function http_MKCOL() |
||
| 1227 | { |
||
| 1228 | $options = Array(); |
||
| 1229 | |||
| 1230 | $options["path"] = $this->path; |
||
| 1231 | |||
| 1232 | $stat = $this->MKCOL($options); |
||
| 1233 | |||
| 1234 | $this->http_status($stat); |
||
| 1235 | } |
||
| 1236 | |||
| 1237 | // }}} |
||
| 1238 | |||
| 1239 | /** |
||
| 1240 | * Check or set if we want ot use compression as transfer encoding |
||
| 1241 | * |
||
| 1242 | * If we use compression via zlib.output_compression as transfer encoding, |
||
| 1243 | * we can NOT send Content-Length headers, as the have to reflect size |
||
| 1244 | * AFTER applying compression/transfer encoding. |
||
| 1245 | * |
||
| 1246 | * @param boolean $set =null |
||
| 1247 | * @return boolean true if we use compression, false otherwise |
||
| 1248 | */ |
||
| 1249 | public static function use_compression($set=null) |
||
| 1250 | { |
||
| 1251 | static $compression = null; |
||
| 1252 | if (isset($set)) |
||
| 1253 | { |
||
| 1254 | ini_set('zlib.output_compression', $compression=(boolean)$set); |
||
| 1255 | } |
||
| 1256 | elseif (!isset($compression)) |
||
| 1257 | { |
||
| 1258 | $compression = (boolean)ini_get('zlib.output_compression'); |
||
| 1259 | } |
||
| 1260 | //error_log(__METHOD__."(".array2string($set).") returning ".array2string($compression)); |
||
| 1261 | return $compression; |
||
| 1262 | } |
||
| 1263 | |||
| 1264 | // {{{ http_GET() |
||
| 1265 | |||
| 1266 | /** |
||
| 1267 | * GET method handler |
||
| 1268 | * |
||
| 1269 | * @param void |
||
| 1270 | * @return void |
||
| 1271 | */ |
||
| 1272 | function http_GET() |
||
| 1273 | { |
||
| 1274 | // TODO check for invalid stream |
||
| 1275 | $options = Array(); |
||
| 1276 | $options["path"] = $this->path; |
||
| 1277 | |||
| 1278 | $this->_get_ranges($options); |
||
| 1279 | |||
| 1280 | if (true === ($status = $this->GET($options))) { |
||
| 1281 | if (!headers_sent()) { |
||
| 1282 | $status = "200 OK"; |
||
| 1283 | |||
| 1284 | if (!isset($options['mimetype'])) { |
||
| 1285 | $options['mimetype'] = "application/octet-stream"; |
||
| 1286 | } |
||
| 1287 | // switching off zlib.output_compression for everything but text files, |
||
| 1288 | // as the double compression of zip files makes problems eg. with lighttpd |
||
| 1289 | // and anyway little sense with with other content like pictures |
||
| 1290 | if (substr($options['mimetype'],0,5) != 'text/') |
||
| 1291 | { |
||
| 1292 | self::use_compression(false); |
||
| 1293 | } |
||
| 1294 | header("Content-type: $options[mimetype]"); |
||
| 1295 | |||
| 1296 | if (isset($options['mtime'])) { |
||
| 1297 | header("Last-modified:".gmdate("D, d M Y H:i:s ", $options['mtime'])."GMT"); |
||
| 1298 | } |
||
| 1299 | // fix for IE and https, thanks to [email protected] |
||
| 1300 | // see http://us3.php.net/manual/en/function.header.php#83219 |
||
| 1301 | // and http://support.microsoft.com/kb/812935 |
||
| 1302 | header("Cache-Control: maxage=1"); //In seconds |
||
| 1303 | header("Pragma: public"); |
||
| 1304 | |||
| 1305 | if (isset($options['stream'])) { |
||
| 1306 | // GET handler returned a stream |
||
| 1307 | if (!empty($options['ranges']) && (0===fseek($options['stream'], 0, SEEK_SET))) { |
||
| 1308 | // partial request and stream is seekable |
||
| 1309 | |||
| 1310 | if (count($options['ranges']) === 1) { |
||
| 1311 | $range = $options['ranges'][0]; |
||
| 1312 | |||
| 1313 | if (isset($range['start'])) { |
||
| 1314 | fseek($options['stream'], $range['start'], SEEK_SET); |
||
| 1315 | if (feof($options['stream'])) { |
||
| 1316 | $this->http_status($status = "416 Requested range not satisfiable"); |
||
| 1317 | return; |
||
| 1318 | } |
||
| 1319 | |||
| 1320 | if (!empty($range['end'])) { |
||
| 1321 | $size = $range['end']-$range['start']+1; |
||
| 1322 | $this->http_status($status = "206 Partial content"); |
||
| 1323 | if (!self::use_compression()) header("Content-Length: $size"); |
||
| 1324 | header("Content-Range: bytes $range[start]-$range[end]/" |
||
| 1325 | . (isset($options['size']) ? $options['size'] : "*")); |
||
| 1326 | while ($size > 0 && !feof($options['stream'])) { |
||
| 1327 | $buffer = fread($options['stream'], $size < 8192 ? $size : 8192); |
||
| 1328 | $size -= self::bytes($buffer); |
||
| 1329 | echo $buffer; |
||
| 1330 | } |
||
| 1331 | } else { |
||
| 1332 | $this->http_status($status = "206 Partial content"); |
||
| 1333 | if (isset($options['size'])) { |
||
| 1334 | if (!self::use_compression()) header("Content-Length: ".($options['size'] - $range['start'])); |
||
| 1335 | header("Content-Range: bytes ".$range['start']."-". |
||
| 1336 | (isset($options['size']) ? $options['size']-1 : "")."/" |
||
| 1337 | . (isset($options['size']) ? $options['size'] : "*")); |
||
| 1338 | } |
||
| 1339 | fpassthru($options['stream']); |
||
| 1340 | } |
||
| 1341 | } else { |
||
| 1342 | if (!self::use_compression()) header("Content-length: ".$range['last']); |
||
| 1343 | fseek($options['stream'], -$range['last'], SEEK_END); |
||
| 1344 | fpassthru($options['stream']); |
||
| 1345 | } |
||
| 1346 | } else { |
||
| 1347 | $this->_multipart_byterange_header(); // init multipart |
||
| 1348 | foreach ($options['ranges'] as $range) { |
||
| 1349 | // TODO what if size unknown? 500? |
||
| 1350 | if (isset($range['start'])) { |
||
| 1351 | $from = $range['start']; |
||
| 1352 | $to = !empty($range['end']) ? $range['end'] : $options['size']-1; |
||
| 1353 | } else { |
||
| 1354 | $from = $options['size'] - $range['last']-1; |
||
| 1355 | $to = $options['size'] -1; |
||
| 1356 | } |
||
| 1357 | $total = isset($options['size']) ? $options['size'] : "*"; |
||
| 1358 | $size = $to - $from + 1; |
||
| 1359 | $this->_multipart_byterange_header($options['mimetype'], $from, $to, $total); |
||
| 1360 | |||
| 1361 | |||
| 1362 | fseek($options['stream'], $from, SEEK_SET); |
||
| 1363 | while ($size && !feof($options['stream'])) { |
||
| 1364 | $buffer = fread($options['stream'], 4096); |
||
| 1365 | $size -= self::bytes($buffer); |
||
| 1366 | echo $buffer; |
||
| 1367 | } |
||
| 1368 | } |
||
| 1369 | $this->_multipart_byterange_header(); // end multipart |
||
| 1370 | } |
||
| 1371 | } else { |
||
| 1372 | // normal request or stream isn't seekable, return full content |
||
| 1373 | if (isset($options['size']) && !self::use_compression()) { |
||
| 1374 | header("Content-Length: ".$options['size']); |
||
| 1375 | } |
||
| 1376 | fpassthru($options['stream']); |
||
| 1377 | return; // no more headers |
||
| 1378 | } |
||
| 1379 | } elseif (isset($options['data'])) { |
||
| 1380 | if (is_array($options['data'])) { |
||
| 1381 | // reply to partial request |
||
| 1382 | } else { |
||
| 1383 | if (!self::use_compression()) header("Content-Length: ".self::bytes($options['data'])); |
||
| 1384 | echo $options['data']; |
||
| 1385 | } |
||
| 1386 | } |
||
| 1387 | } |
||
| 1388 | } |
||
| 1389 | |||
| 1390 | if (!headers_sent()) { |
||
| 1391 | if (false === $status) { |
||
| 1392 | $this->http_status("404 not found"); |
||
| 1393 | } else { |
||
| 1394 | // TODO: check setting of headers in various code paths above |
||
| 1395 | $this->http_status("$status"); |
||
| 1396 | } |
||
| 1397 | } |
||
| 1398 | } |
||
| 1399 | |||
| 1400 | |||
| 1401 | /** |
||
| 1402 | * parse HTTP Range: header |
||
| 1403 | * |
||
| 1404 | * @param array options array to store result in |
||
| 1405 | * @return void |
||
| 1406 | */ |
||
| 1407 | function _get_ranges(&$options) |
||
| 1408 | { |
||
| 1409 | // process Range: header if present |
||
| 1410 | if (isset($this->_SERVER['HTTP_RANGE'])) { |
||
| 1411 | |||
| 1412 | // we only support standard "bytes" range specifications for now |
||
| 1413 | $matches = null; |
||
| 1414 | if (preg_match('/bytes\s*=\s*(.+)/', $this->_SERVER['HTTP_RANGE'], $matches)) { |
||
| 1415 | $options["ranges"] = array(); |
||
| 1416 | |||
| 1417 | // ranges are comma separated |
||
| 1418 | foreach (explode(",", $matches[1]) as $range) { |
||
| 1419 | // ranges are either from-to pairs or just end positions |
||
| 1420 | list($start, $end) = explode("-", $range); |
||
| 1421 | $options["ranges"][] = ($start==="") |
||
| 1422 | ? array("last"=>$end) |
||
| 1423 | : array("start"=>$start, "end"=>$end); |
||
| 1424 | } |
||
| 1425 | } |
||
| 1426 | } |
||
| 1427 | } |
||
| 1428 | |||
| 1429 | /** |
||
| 1430 | * generate separator headers for multipart response |
||
| 1431 | * |
||
| 1432 | * first and last call happen without parameters to generate |
||
| 1433 | * the initial header and closing sequence, all calls inbetween |
||
| 1434 | * require content mimetype, start and end byte position and |
||
| 1435 | * optionaly the total byte length of the requested resource |
||
| 1436 | * |
||
| 1437 | * @param string mimetype |
||
| 1438 | * @param int start byte position |
||
| 1439 | * @param int end byte position |
||
| 1440 | * @param int total resource byte size |
||
| 1441 | */ |
||
| 1442 | function _multipart_byterange_header($mimetype = false, $from = false, $to=false, $total=false) |
||
| 1443 | { |
||
| 1444 | if ($mimetype === false) { |
||
| 1445 | if (!isset($this->multipart_separator)) { |
||
| 1446 | // initial |
||
| 1447 | |||
| 1448 | // a little naive, this sequence *might* be part of the content |
||
| 1449 | // but it's really not likely and rather expensive to check |
||
| 1450 | $this->multipart_separator = "SEPARATOR_".md5(microtime()); |
||
| 1451 | |||
| 1452 | // generate HTTP header |
||
| 1453 | header("Content-type: multipart/byteranges; boundary=".$this->multipart_separator); |
||
| 1454 | } else { |
||
| 1455 | // final |
||
| 1456 | |||
| 1457 | // generate closing multipart sequence |
||
| 1458 | echo "\n--{$this->multipart_separator}--"; |
||
| 1459 | } |
||
| 1460 | } else { |
||
| 1461 | // generate separator and header for next part |
||
| 1462 | echo "\n--{$this->multipart_separator}\n"; |
||
| 1463 | echo "Content-type: $mimetype\n"; |
||
| 1464 | echo "Content-range: $from-$to/". ($total === false ? "*" : $total); |
||
| 1465 | echo "\n\n"; |
||
| 1466 | } |
||
| 1467 | } |
||
| 1468 | |||
| 1469 | |||
| 1470 | |||
| 1471 | // }}} |
||
| 1472 | |||
| 1473 | // {{{ http_HEAD() |
||
| 1474 | |||
| 1475 | /** |
||
| 1476 | * HEAD method handler |
||
| 1477 | * |
||
| 1478 | * @param void |
||
| 1479 | * @return void |
||
| 1480 | */ |
||
| 1481 | function http_HEAD() |
||
| 1482 | { |
||
| 1483 | $status = false; |
||
| 1484 | $options = Array(); |
||
| 1485 | $options["path"] = $this->path; |
||
| 1486 | |||
| 1487 | if (method_exists($this, "HEAD")) { |
||
| 1488 | $status = $this->head($options); |
||
| 1489 | } else if (method_exists($this, "GET")) { |
||
| 1490 | ob_start(); |
||
| 1491 | $status = $this->GET($options); |
||
| 1492 | if (!isset($options['size'])) { |
||
| 1493 | $options['size'] = ob_get_length(); |
||
| 1494 | } |
||
| 1495 | ob_end_clean(); |
||
| 1496 | } |
||
| 1497 | |||
| 1498 | if (!isset($options['mimetype'])) { |
||
| 1499 | $options['mimetype'] = "application/octet-stream"; |
||
| 1500 | } |
||
| 1501 | header("Content-type: $options[mimetype]"); |
||
| 1502 | |||
| 1503 | if (isset($options['mtime'])) { |
||
| 1504 | header("Last-modified:".gmdate("D, d M Y H:i:s ", $options['mtime'])."GMT"); |
||
| 1505 | } |
||
| 1506 | |||
| 1507 | if (isset($options['size'])) { |
||
| 1508 | header("Content-Length: ".$options['size']); |
||
| 1509 | } |
||
| 1510 | |||
| 1511 | if ($status === true) $status = "200 OK"; |
||
| 1512 | if ($status === false) $status = "404 Not found"; |
||
| 1513 | |||
| 1514 | $this->http_status($status); |
||
| 1515 | } |
||
| 1516 | |||
| 1517 | // }}} |
||
| 1518 | |||
| 1519 | // {{{ http_POST() |
||
| 1520 | |||
| 1521 | /** |
||
| 1522 | * POST method handler |
||
| 1523 | * |
||
| 1524 | * @param void |
||
| 1525 | * @return void |
||
| 1526 | */ |
||
| 1527 | function http_POST() |
||
| 1528 | { |
||
| 1529 | $status = '405 Method not allowed'; |
||
| 1530 | $options = Array(); |
||
| 1531 | $options['path'] = $this->path; |
||
| 1532 | |||
| 1533 | if (isset($this->_SERVER['CONTENT_LENGTH'])) |
||
| 1534 | { |
||
| 1535 | $options['content_length'] = $this->_SERVER['CONTENT_LENGTH']; |
||
| 1536 | } |
||
| 1537 | elseif (isset($this->_SERVER['X-Expected-Entity-Length'])) |
||
| 1538 | { |
||
| 1539 | // MacOS gives us that hint |
||
| 1540 | $options['content_length'] = $this->_SERVER['X-Expected-Entity-Length']; |
||
| 1541 | } |
||
| 1542 | |||
| 1543 | // get the Content-type |
||
| 1544 | if (isset($this->_SERVER["CONTENT_TYPE"])) { |
||
| 1545 | // for now we do not support any sort of multipart requests |
||
| 1546 | if (!strncmp($this->_SERVER["CONTENT_TYPE"], 'multipart/', 10)) { |
||
| 1547 | $this->http_status('501 not implemented'); |
||
| 1548 | echo 'The service does not support mulipart POST requests'; |
||
| 1549 | return; |
||
| 1550 | } |
||
| 1551 | $options['content_type'] = $this->_SERVER['CONTENT_TYPE']; |
||
| 1552 | } else { |
||
| 1553 | // default content type if none given |
||
| 1554 | $options['content_type'] = 'application/octet-stream'; |
||
| 1555 | } |
||
| 1556 | |||
| 1557 | $options['stream'] = fopen('php://input', 'r'); |
||
| 1558 | switch($this->_SERVER['HTTP_CONTENT_ENCODING']) |
||
| 1559 | { |
||
| 1560 | case 'gzip': |
||
| 1561 | case 'deflate': //zlib |
||
| 1562 | if (extension_loaded('zlib')) |
||
| 1563 | { |
||
| 1564 | stream_filter_append($options['stream'], 'zlib.inflate', STREAM_FILTER_READ); |
||
| 1565 | } |
||
| 1566 | } |
||
| 1567 | // store request in $this->request, if requested via $this->store_request |
||
| 1568 | if ($this->store_request) |
||
| 1569 | { |
||
| 1570 | $options['content'] = ''; |
||
| 1571 | while(!feof($options['stream'])) |
||
| 1572 | { |
||
| 1573 | $options['content'] .= fread($options['stream'],8192); |
||
| 1574 | } |
||
| 1575 | $this->request =& $options['content']; |
||
| 1576 | unset($options['stream']); |
||
| 1577 | } |
||
| 1578 | |||
| 1579 | /* RFC 2616 2.6 says: "The recipient of the entity MUST NOT |
||
| 1580 | ignore any Content-* (e.g. Content-Range) headers that it |
||
| 1581 | does not understand or implement and MUST return a 501 |
||
| 1582 | (Not Implemented) response in such cases." |
||
| 1583 | */ |
||
| 1584 | foreach ($this->_SERVER as $key => $val) { |
||
| 1585 | if (strncmp($key, 'HTTP_CONTENT', 11)) continue; |
||
| 1586 | switch ($key) { |
||
| 1587 | case 'HTTP_CONTENT_ENCODING': // RFC 2616 14.11 |
||
| 1588 | switch($this->_SERVER['HTTP_CONTENT_ENCODING']) |
||
| 1589 | { |
||
| 1590 | case 'gzip': |
||
| 1591 | case 'deflate': //zlib |
||
| 1592 | if (extension_loaded('zlib')) break; |
||
| 1593 | // fall through for no zlib support |
||
| 1594 | default: |
||
| 1595 | $this->http_status('415 Unsupported Media Type'); |
||
| 1596 | echo "The service does not support '$val' content encoding"; |
||
| 1597 | return; |
||
| 1598 | } |
||
| 1599 | break; |
||
| 1600 | |||
| 1601 | case 'HTTP_CONTENT_LANGUAGE': // RFC 2616 14.12 |
||
| 1602 | // we assume it is not critical if this one is ignored |
||
| 1603 | // in the actual POST implementation ... |
||
| 1604 | $options['content_language'] = $val; |
||
| 1605 | break; |
||
| 1606 | |||
| 1607 | case 'HTTP_CONTENT_LENGTH': |
||
| 1608 | // defined on IIS and has the same value as CONTENT_LENGTH |
||
| 1609 | break; |
||
| 1610 | |||
| 1611 | case 'HTTP_CONTENT_LOCATION': // RFC 2616 14.14 |
||
| 1612 | /* The meaning of the Content-Location header in PUT |
||
| 1613 | or POST requests is undefined; servers are free |
||
| 1614 | to ignore it in those cases. */ |
||
| 1615 | break; |
||
| 1616 | |||
| 1617 | case 'HTTP_CONTENT_RANGE': // RFC 2616 14.16 |
||
| 1618 | // single byte range requests are supported |
||
| 1619 | // the header format is also specified in RFC 2616 14.16 |
||
| 1620 | // TODO we have to ensure that implementations support this or send 501 instead |
||
| 1621 | $matches = null; |
||
| 1622 | if (!preg_match('@bytes\s+(\d+)-(\d+)/((\d+)|\*)@', $val, $matches)) { |
||
| 1623 | $this->http_status('400 bad request'); |
||
| 1624 | echo 'The service does only support single byte ranges'; |
||
| 1625 | return; |
||
| 1626 | } |
||
| 1627 | |||
| 1628 | $range = array('start'=>$matches[1], 'end'=>$matches[2]); |
||
| 1629 | if (is_numeric($matches[3])) { |
||
| 1630 | $range['total_length'] = $matches[3]; |
||
| 1631 | } |
||
| 1632 | $options['ranges'][] = $range; |
||
| 1633 | |||
| 1634 | // TODO make sure the implementation supports partial POST |
||
| 1635 | // this has to be done in advance to avoid data being overwritten |
||
| 1636 | // on implementations that do not support this ... |
||
| 1637 | break; |
||
| 1638 | |||
| 1639 | case 'HTTP_CONTENT_TYPE': |
||
| 1640 | // defined on IIS and has the same value as CONTENT_TYPE |
||
| 1641 | break; |
||
| 1642 | |||
| 1643 | case 'HTTP_CONTENT_MD5': // RFC 2616 14.15 |
||
| 1644 | // TODO: maybe we can just pretend here? |
||
| 1645 | $this->http_status('501 not implemented'); |
||
| 1646 | echo 'The service does not support content MD5 checksum verification'; |
||
| 1647 | return; |
||
| 1648 | |||
| 1649 | case 'HTTP_CONTENT_DISPOSITION': |
||
| 1650 | // do NOT care about Content-Disposition in POST requests required by CalDAV managed attachments |
||
| 1651 | break; |
||
| 1652 | |||
| 1653 | default: |
||
| 1654 | // any other unknown Content-* headers |
||
| 1655 | $this->http_status('501 not implemented'); |
||
| 1656 | echo "The service does not support '$key'"; |
||
| 1657 | return; |
||
| 1658 | } |
||
| 1659 | } |
||
| 1660 | |||
| 1661 | if (method_exists($this, 'POST')) { |
||
| 1662 | $status = $this->POST($options); |
||
| 1663 | |||
| 1664 | if ($status === false) { |
||
| 1665 | $status = '400 Something went wrong'; |
||
| 1666 | } else if ($status === true) { |
||
| 1667 | $status = '200 OK'; |
||
| 1668 | } else if (is_resource($status) && get_resource_type($status) == 'stream') { |
||
| 1669 | $stream = $status; |
||
| 1670 | |||
| 1671 | $status = empty($options['new']) ? '200 OK' : '201 Created'; |
||
| 1672 | |||
| 1673 | if (!empty($options['ranges'])) { |
||
| 1674 | // TODO multipart support is missing (see also above) |
||
| 1675 | if (0 == fseek($stream, $range[0]['start'], SEEK_SET)) { |
||
| 1676 | $length = $range[0]['end']-$range[0]['start']+1; |
||
| 1677 | if (!fwrite($stream, fread($options['stream'], $length))) { |
||
| 1678 | $status = '403 Forbidden'; |
||
| 1679 | } |
||
| 1680 | } else { |
||
| 1681 | $status = '403 Forbidden'; |
||
| 1682 | } |
||
| 1683 | } else { |
||
| 1684 | while (!feof($options['stream'])) { |
||
| 1685 | if (false === fwrite($stream, fread($options['stream'], 4096))) { |
||
| 1686 | $status = '403 Forbidden'; |
||
| 1687 | break; |
||
| 1688 | } |
||
| 1689 | } |
||
| 1690 | } |
||
| 1691 | fclose($stream); |
||
| 1692 | } |
||
| 1693 | } |
||
| 1694 | $this->http_status($status); |
||
| 1695 | } |
||
| 1696 | |||
| 1697 | // }}} |
||
| 1698 | |||
| 1699 | // {{{ http_PUT() |
||
| 1700 | |||
| 1701 | /** |
||
| 1702 | * PUT method handler |
||
| 1703 | * |
||
| 1704 | * @param void |
||
| 1705 | * @return void |
||
| 1706 | */ |
||
| 1707 | function http_PUT() |
||
| 1708 | { |
||
| 1709 | if ($this->_check_lock_status($this->path)) { |
||
| 1710 | $options = Array(); |
||
| 1711 | $options["path"] = $this->path; |
||
| 1712 | |||
| 1713 | if (isset($this->_SERVER['CONTENT_LENGTH'])) |
||
| 1714 | { |
||
| 1715 | $options['content_length'] = $this->_SERVER['CONTENT_LENGTH']; |
||
| 1716 | } |
||
| 1717 | elseif (isset($this->_SERVER['X-Expected-Entity-Length'])) |
||
| 1718 | { |
||
| 1719 | // MacOS gives us that hint |
||
| 1720 | $options['content_length'] = $this->_SERVER['X-Expected-Entity-Length']; |
||
| 1721 | } |
||
| 1722 | |||
| 1723 | // get the Content-type |
||
| 1724 | if (isset($this->_SERVER["CONTENT_TYPE"])) { |
||
| 1725 | // for now we do not support any sort of multipart requests |
||
| 1726 | if (!strncmp($this->_SERVER["CONTENT_TYPE"], "multipart/", 10)) { |
||
| 1727 | $this->http_status("501 not implemented"); |
||
| 1728 | echo "The service does not support multipart PUT requests"; |
||
| 1729 | return; |
||
| 1730 | } |
||
| 1731 | $options["content_type"] = $this->_SERVER["CONTENT_TYPE"]; |
||
| 1732 | } else { |
||
| 1733 | // default content type if none given |
||
| 1734 | $options["content_type"] = "application/octet-stream"; |
||
| 1735 | } |
||
| 1736 | |||
| 1737 | $options["stream"] = fopen("php://input", "r"); |
||
| 1738 | switch($this->_SERVER['HTTP_CONTENT_ENCODING']) |
||
| 1739 | { |
||
| 1740 | case 'gzip': |
||
| 1741 | case 'deflate': //zlib |
||
| 1742 | if (extension_loaded('zlib')) |
||
| 1743 | { |
||
| 1744 | stream_filter_append($options['stream'], 'zlib.inflate', STREAM_FILTER_READ); |
||
| 1745 | } |
||
| 1746 | } |
||
| 1747 | // store request in $this->request, if requested via $this->store_request |
||
| 1748 | if ($this->store_request) |
||
| 1749 | { |
||
| 1750 | $options['content'] = ''; |
||
| 1751 | while(!feof($options['stream'])) |
||
| 1752 | { |
||
| 1753 | $options['content'] .= fread($options['stream'],8192); |
||
| 1754 | } |
||
| 1755 | $this->request =& $options['content']; |
||
| 1756 | unset($options['stream']); |
||
| 1757 | } |
||
| 1758 | |||
| 1759 | /* RFC 2616 2.6 says: "The recipient of the entity MUST NOT |
||
| 1760 | ignore any Content-* (e.g. Content-Range) headers that it |
||
| 1761 | does not understand or implement and MUST return a 501 |
||
| 1762 | (Not Implemented) response in such cases." |
||
| 1763 | */ |
||
| 1764 | foreach ($this->_SERVER as $key => $val) { |
||
| 1765 | if (strncmp($key, "HTTP_CONTENT", 11)) continue; |
||
| 1766 | switch ($key) { |
||
| 1767 | case 'HTTP_CONTENT_ENCODING': // RFC 2616 14.11 |
||
| 1768 | switch($this->_SERVER['HTTP_CONTENT_ENCODING']) |
||
| 1769 | { |
||
| 1770 | case 'gzip': |
||
| 1771 | case 'deflate': //zlib |
||
| 1772 | if (extension_loaded('zlib')) break; |
||
| 1773 | // fall through for no zlib support |
||
| 1774 | default: |
||
| 1775 | $this->http_status('415 Unsupported Media Type'); |
||
| 1776 | echo "The service does not support '$val' content encoding"; |
||
| 1777 | return; |
||
| 1778 | } |
||
| 1779 | break; |
||
| 1780 | |||
| 1781 | case 'HTTP_CONTENT_LANGUAGE': // RFC 2616 14.12 |
||
| 1782 | // we assume it is not critical if this one is ignored |
||
| 1783 | // in the actual PUT implementation ... |
||
| 1784 | $options["content_language"] = $val; |
||
| 1785 | break; |
||
| 1786 | |||
| 1787 | case 'HTTP_CONTENT_LENGTH': |
||
| 1788 | // defined on IIS and has the same value as CONTENT_LENGTH |
||
| 1789 | break; |
||
| 1790 | |||
| 1791 | case 'HTTP_CONTENT_LOCATION': // RFC 2616 14.14 |
||
| 1792 | /* The meaning of the Content-Location header in PUT |
||
| 1793 | or POST requests is undefined; servers are free |
||
| 1794 | to ignore it in those cases. */ |
||
| 1795 | break; |
||
| 1796 | |||
| 1797 | case 'HTTP_CONTENT_RANGE': // RFC 2616 14.16 |
||
| 1798 | // single byte range requests are supported |
||
| 1799 | // the header format is also specified in RFC 2616 14.16 |
||
| 1800 | // TODO we have to ensure that implementations support this or send 501 instead |
||
| 1801 | $matches = null; |
||
| 1802 | if (!preg_match('@bytes\s+(\d+)-(\d+)/((\d+)|\*)@', $val, $matches)) { |
||
| 1803 | $this->http_status("400 bad request"); |
||
| 1804 | echo "The service does only support single byte ranges"; |
||
| 1805 | return; |
||
| 1806 | } |
||
| 1807 | |||
| 1808 | $range = array("start" => $matches[1], "end" => $matches[2]); |
||
| 1809 | if (is_numeric($matches[3])) { |
||
| 1810 | $range["total_length"] = $matches[3]; |
||
| 1811 | } |
||
| 1812 | |||
| 1813 | if (!isset($options['ranges'])) { |
||
| 1814 | $options['ranges'] = array(); |
||
| 1815 | } |
||
| 1816 | |||
| 1817 | $options["ranges"][] = $range; |
||
| 1818 | |||
| 1819 | // TODO make sure the implementation supports partial PUT |
||
| 1820 | // this has to be done in advance to avoid data being overwritten |
||
| 1821 | // on implementations that do not support this ... |
||
| 1822 | break; |
||
| 1823 | |||
| 1824 | case 'HTTP_CONTENT_TYPE': |
||
| 1825 | // defined on IIS and has the same value as CONTENT_TYPE |
||
| 1826 | break; |
||
| 1827 | |||
| 1828 | case 'HTTP_CONTENT_MD5': // RFC 2616 14.15 |
||
| 1829 | // TODO: maybe we can just pretend here? |
||
| 1830 | $this->http_status("501 not implemented"); |
||
| 1831 | echo "The service does not support content MD5 checksum verification"; |
||
| 1832 | return; |
||
| 1833 | |||
| 1834 | default: |
||
| 1835 | // any other unknown Content-* headers |
||
| 1836 | $this->http_status("501 not implemented"); |
||
| 1837 | echo "The service does not support '$key'"; |
||
| 1838 | return; |
||
| 1839 | } |
||
| 1840 | } |
||
| 1841 | |||
| 1842 | $stat = $this->PUT($options); |
||
| 1843 | |||
| 1844 | if ($stat === false) { |
||
| 1845 | $stat = "403 Forbidden"; |
||
| 1846 | } else if (is_resource($stat) && get_resource_type($stat) == "stream") { |
||
| 1847 | $stream = $stat; |
||
| 1848 | |||
| 1849 | $stat = $options["new"] ? "201 Created" : "204 No Content"; |
||
| 1850 | |||
| 1851 | if (!empty($options["ranges"])) { |
||
| 1852 | // TODO multipart support is missing (see also above) |
||
| 1853 | if (0 == fseek($stream, $options['ranges'][0]["start"], SEEK_SET)) { |
||
| 1854 | $length = $options['ranges'][0]["end"] - $options['ranges'][0]["start"]+1; |
||
| 1855 | |||
| 1856 | while (!feof($options['stream'])) { |
||
| 1857 | if ($length <= 0) { |
||
| 1858 | break; |
||
| 1859 | } |
||
| 1860 | |||
| 1861 | if ($length <= 8192) { |
||
| 1862 | $data = fread($options['stream'], $length); |
||
| 1863 | } else { |
||
| 1864 | $data = fread($options['stream'], 8192); |
||
| 1865 | } |
||
| 1866 | |||
| 1867 | if ($data === false) { |
||
| 1868 | $stat = "400 Bad request"; |
||
| 1869 | } elseif (strlen($data)) { |
||
| 1870 | if (false === fwrite($stream, $data)) { |
||
| 1871 | $stat = "403 Forbidden"; |
||
| 1872 | break; |
||
| 1873 | } |
||
| 1874 | $length -= strlen($data); |
||
| 1875 | } |
||
| 1876 | } |
||
| 1877 | } else { |
||
| 1878 | $stat = "403 Forbidden"; |
||
| 1879 | } |
||
| 1880 | } else { |
||
| 1881 | while (!feof($options["stream"])) { |
||
| 1882 | if (false === fwrite($stream, fread($options["stream"], 8192))) { |
||
| 1883 | $stat = "403 Forbidden"; |
||
| 1884 | break; |
||
| 1885 | } |
||
| 1886 | } |
||
| 1887 | } |
||
| 1888 | |||
| 1889 | fclose($stream); |
||
| 1890 | } |
||
| 1891 | |||
| 1892 | $this->http_status($stat); |
||
| 1893 | } else { |
||
| 1894 | $this->http_status("423 Locked"); |
||
| 1895 | } |
||
| 1896 | } |
||
| 1897 | |||
| 1898 | // }}} |
||
| 1899 | |||
| 1900 | |||
| 1901 | // {{{ http_DELETE() |
||
| 1902 | |||
| 1903 | /** |
||
| 1904 | * DELETE method handler |
||
| 1905 | * |
||
| 1906 | * @param void |
||
| 1907 | * @return void |
||
| 1908 | */ |
||
| 1909 | function http_DELETE() |
||
| 1910 | { |
||
| 1911 | // check RFC 2518 Section 9.2, last paragraph |
||
| 1912 | if (isset($this->_SERVER["HTTP_DEPTH"])) { |
||
| 1913 | if ($this->_SERVER["HTTP_DEPTH"] != "infinity") { |
||
| 1914 | if (stripos($_SERVER['HTTP_USER_AGENT'],'webdrive') !== false) |
||
| 1915 | { |
||
| 1916 | // pretend we didnt see it, as webdrive does not handle the depth parameter correctly while deleting collections |
||
| 1917 | } |
||
| 1918 | else |
||
| 1919 | { |
||
| 1920 | $this->http_status("400 Bad Request"); |
||
| 1921 | return; |
||
| 1922 | } |
||
| 1923 | } |
||
| 1924 | } |
||
| 1925 | |||
| 1926 | // check lock status |
||
| 1927 | if ($this->_check_lock_status($this->path)) { |
||
| 1928 | // ok, proceed |
||
| 1929 | $options = Array(); |
||
| 1930 | $options["path"] = $this->path; |
||
| 1931 | |||
| 1932 | $stat = $this->DELETE($options); |
||
| 1933 | |||
| 1934 | $this->http_status($stat); |
||
| 1935 | } else { |
||
| 1936 | // sorry, its locked |
||
| 1937 | $this->http_status("423 Locked"); |
||
| 1938 | } |
||
| 1939 | } |
||
| 1940 | |||
| 1941 | // }}} |
||
| 1942 | |||
| 1943 | // {{{ http_COPY() |
||
| 1944 | |||
| 1945 | /** |
||
| 1946 | * COPY method handler |
||
| 1947 | * |
||
| 1948 | * @param void |
||
| 1949 | * @return void |
||
| 1950 | */ |
||
| 1951 | function http_COPY() |
||
| 1952 | { |
||
| 1953 | // no need to check source lock status here |
||
| 1954 | // destination lock status is always checked by the helper method |
||
| 1955 | $this->_copymove("copy"); |
||
| 1956 | } |
||
| 1957 | |||
| 1958 | // }}} |
||
| 1959 | |||
| 1960 | // {{{ http_MOVE() |
||
| 1961 | |||
| 1962 | /** |
||
| 1963 | * MOVE method handler |
||
| 1964 | * |
||
| 1965 | * @param void |
||
| 1966 | * @return void |
||
| 1967 | */ |
||
| 1968 | function http_MOVE() |
||
| 1969 | { |
||
| 1970 | if ($this->_check_lock_status($this->path)) { |
||
| 1971 | // destination lock status is always checked by the helper method |
||
| 1972 | $this->_copymove("move"); |
||
| 1973 | } else { |
||
| 1974 | $this->http_status("423 Locked"); |
||
| 1975 | } |
||
| 1976 | } |
||
| 1977 | |||
| 1978 | // }}} |
||
| 1979 | |||
| 1980 | |||
| 1981 | // {{{ http_LOCK() |
||
| 1982 | |||
| 1983 | /** |
||
| 1984 | * LOCK method handler |
||
| 1985 | * |
||
| 1986 | * @param void |
||
| 1987 | * @return void |
||
| 1988 | */ |
||
| 1989 | function http_LOCK() |
||
| 1990 | { |
||
| 1991 | $options = Array(); |
||
| 1992 | $options["path"] = $this->path; |
||
| 1993 | |||
| 1994 | if (isset($this->_SERVER['HTTP_DEPTH'])) { |
||
| 1995 | $options["depth"] = $this->_SERVER["HTTP_DEPTH"]; |
||
| 1996 | } else { |
||
| 1997 | $options["depth"] = "infinity"; |
||
| 1998 | } |
||
| 1999 | |||
| 2000 | if (isset($this->_SERVER["HTTP_TIMEOUT"])) { |
||
| 2001 | $options["timeout"] = explode(",", $this->_SERVER["HTTP_TIMEOUT"]); |
||
| 2002 | } |
||
| 2003 | |||
| 2004 | if (empty($this->_SERVER['CONTENT_LENGTH']) && !empty($this->_SERVER['HTTP_IF'])) { |
||
| 2005 | // check if locking is possible |
||
| 2006 | if (!$this->_check_lock_status($this->path)) { |
||
| 2007 | $this->http_status("423 Locked"); |
||
| 2008 | return; |
||
| 2009 | } |
||
| 2010 | |||
| 2011 | // refresh lock |
||
| 2012 | $options["locktoken"] = substr($this->_SERVER['HTTP_IF'], 2, -2); |
||
| 2013 | $options["update"] = $options["locktoken"]; |
||
| 2014 | |||
| 2015 | // setting defaults for required fields, LOCK() SHOULD overwrite these |
||
| 2016 | $options['owner'] = "unknown"; |
||
| 2017 | $options['scope'] = "exclusive"; |
||
| 2018 | $options['type'] = "write"; |
||
| 2019 | |||
| 2020 | |||
| 2021 | $stat = $this->LOCK($options); |
||
| 2022 | } else { |
||
| 2023 | // extract lock request information from request XML payload |
||
| 2024 | $lockinfo = new _parse_lockinfo("php://input"); |
||
| 2025 | if (!$lockinfo->success) { |
||
| 2026 | $this->http_status("400 bad request"); |
||
| 2027 | } |
||
| 2028 | |||
| 2029 | // check if locking is possible |
||
| 2030 | if (!$this->_check_lock_status($this->path, $lockinfo->lockscope === "shared")) { |
||
| 2031 | $this->http_status("423 Locked"); |
||
| 2032 | return; |
||
| 2033 | } |
||
| 2034 | |||
| 2035 | // new lock |
||
| 2036 | $options["scope"] = $lockinfo->lockscope; |
||
| 2037 | $options["type"] = $lockinfo->locktype; |
||
| 2038 | // Todo: lockinfo::owner still contains D:href opening and closing tags, maybe they should be removed here with strip_tags |
||
| 2039 | $options["owner"] = $lockinfo->owner; |
||
| 2040 | $options["locktoken"] = $this->_new_locktoken(); |
||
| 2041 | |||
| 2042 | $stat = $this->LOCK($options); |
||
| 2043 | } |
||
| 2044 | |||
| 2045 | if (is_bool($stat)) { |
||
| 2046 | $http_stat = $stat ? "200 OK" : "423 Locked"; |
||
| 2047 | } else { |
||
| 2048 | $http_stat = (string)$stat; |
||
| 2049 | } |
||
| 2050 | $this->http_status($http_stat); |
||
| 2051 | |||
| 2052 | if ($http_stat{0} == 2) { // 2xx states are ok |
||
| 2053 | if ($options["timeout"]) { |
||
| 2054 | // if multiple timeout values were given we take the first only |
||
| 2055 | if (is_array($options["timeout"])) { |
||
| 2056 | reset($options["timeout"]); |
||
| 2057 | $options["timeout"] = current($options["timeout"]); |
||
| 2058 | } |
||
| 2059 | // if the timeout is numeric only we need to reformat it |
||
| 2060 | if (is_numeric($options["timeout"])) { |
||
| 2061 | // more than a million is considered an absolute timestamp |
||
| 2062 | // less is more likely a relative value |
||
| 2063 | if ($options["timeout"]>1000000) { |
||
| 2064 | $timeout = "Second-".($options['timeout']-time()); |
||
| 2065 | } else { |
||
| 2066 | $timeout = "Second-$options[timeout]"; |
||
| 2067 | } |
||
| 2068 | } else { |
||
| 2069 | // non-numeric values are passed on verbatim, |
||
| 2070 | // no error checking is performed here in this case |
||
| 2071 | // TODO: send "Infinite" on invalid timeout strings? |
||
| 2072 | $timeout = $options["timeout"]; |
||
| 2073 | } |
||
| 2074 | } else { |
||
| 2075 | $timeout = "Infinite"; |
||
| 2076 | } |
||
| 2077 | |||
| 2078 | header('Content-Type: text/xml; charset="utf-8"'); |
||
| 2079 | header("Lock-Token: <$options[locktoken]>"); |
||
| 2080 | echo "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"; |
||
| 2081 | echo "<D:prop xmlns:D=\"DAV:\">\n"; |
||
| 2082 | echo ' <'.($this->crrnd?'':'D:')."lockdiscovery>\n"; |
||
| 2083 | echo ' <'.($this->crrnd?'':'D:')."activelock>\n"; |
||
| 2084 | echo ' <'.($this->crrnd?'':'D:')."lockscope><D:$options[scope]/></".($this->crrnd?'':'D:')."lockscope>\n"; |
||
| 2085 | echo ' <'.($this->crrnd?'':'D:')."locktype><D:$options[type]/></".($this->crrnd?'':'D:')."locktype>\n"; |
||
| 2086 | echo ' <'.($this->crrnd?'':'D:')."depth>$options[depth]</".($this->crrnd?'':'D:')."depth>\n"; |
||
| 2087 | echo ' <'.($this->crrnd?'':'D:')."owner>$options[owner]</".($this->crrnd?'':'D:')."owner>\n"; |
||
| 2088 | echo ' <'.($this->crrnd?'':'D:')."timeout>$timeout</".($this->crrnd?'':'D:')."timeout>\n"; |
||
| 2089 | echo ' <'.($this->crrnd?'':'D:')."locktoken><D:href>$options[locktoken]</D:href></".($this->crrnd?'':'D:')."locktoken>\n"; |
||
| 2090 | echo ' </'.($this->crrnd?'':'D:')."activelock>\n"; |
||
| 2091 | echo ' </'.($this->crrnd?'':'D:')."lockdiscovery>\n"; |
||
| 2092 | echo '</'.($this->crrnd?'':'D:')."prop>\n\n"; |
||
| 2093 | } |
||
| 2094 | } |
||
| 2095 | |||
| 2096 | |||
| 2097 | // }}} |
||
| 2098 | |||
| 2099 | // {{{ http_UNLOCK() |
||
| 2100 | |||
| 2101 | /** |
||
| 2102 | * UNLOCK method handler |
||
| 2103 | * |
||
| 2104 | * @param void |
||
| 2105 | * @return void |
||
| 2106 | */ |
||
| 2107 | function http_UNLOCK() |
||
| 2108 | { |
||
| 2109 | $options = Array(); |
||
| 2110 | $options["path"] = $this->path; |
||
| 2111 | |||
| 2112 | if (isset($this->_SERVER['HTTP_DEPTH'])) { |
||
| 2113 | $options["depth"] = $this->_SERVER["HTTP_DEPTH"]; |
||
| 2114 | } else { |
||
| 2115 | $options["depth"] = "infinity"; |
||
| 2116 | } |
||
| 2117 | |||
| 2118 | // strip surrounding <> |
||
| 2119 | $options["token"] = substr(trim($this->_SERVER["HTTP_LOCK_TOKEN"]), 1, -1); |
||
| 2120 | |||
| 2121 | // call user method |
||
| 2122 | $stat = $this->UNLOCK($options); |
||
| 2123 | |||
| 2124 | $this->http_status($stat); |
||
| 2125 | } |
||
| 2126 | |||
| 2127 | // }}} |
||
| 2128 | |||
| 2129 | // {{{ http_ACL() |
||
| 2130 | |||
| 2131 | /** |
||
| 2132 | * ACL method handler |
||
| 2133 | * |
||
| 2134 | * @param void |
||
| 2135 | * @return void |
||
| 2136 | */ |
||
| 2137 | function http_ACL() |
||
| 2138 | { |
||
| 2139 | $options = Array(); |
||
| 2140 | $options['path'] = $this->path; |
||
| 2141 | $options['errors'] = array(); |
||
| 2142 | |||
| 2143 | if (isset($this->_SERVER['HTTP_DEPTH'])) { |
||
| 2144 | $options['depth'] = $this->_SERVER['HTTP_DEPTH']; |
||
| 2145 | } else { |
||
| 2146 | $options['depth'] = 'infinity'; |
||
| 2147 | } |
||
| 2148 | |||
| 2149 | // call user method |
||
| 2150 | $status = $this->ACL($options); |
||
| 2151 | |||
| 2152 | // now we generate the reply header ... |
||
| 2153 | $this->http_status($status); |
||
| 2154 | $content = ''; |
||
| 2155 | |||
| 2156 | if (is_array($options['errors']) && count($options['errors'])) { |
||
| 2157 | header('Content-Type: text/xml; charset="utf-8"'); |
||
| 2158 | // ... and payload |
||
| 2159 | $content .= "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"; |
||
| 2160 | $content .= "<D:error xmlns:D=\"DAV:\"> \n"; |
||
| 2161 | foreach ($options['errors'] as $violation) { |
||
| 2162 | $content .= '<'.($this->crrnd?'':'D:')."$violation/>\n"; |
||
| 2163 | } |
||
| 2164 | $content .= '</'.($this->crrnd?'':'D:')."error>\n"; |
||
| 2165 | } |
||
| 2166 | if (!self::use_compression()) header("Content-Length: ".self::bytes($content)); |
||
| 2167 | if ($content) echo $options['content']; |
||
| 2168 | } |
||
| 2169 | |||
| 2170 | // }}} |
||
| 2171 | |||
| 2172 | // }}} |
||
| 2173 | |||
| 2174 | // {{{ _copymove() |
||
| 2175 | |||
| 2176 | function _copymove($what) |
||
| 2177 | { |
||
| 2178 | $options = Array(); |
||
| 2179 | $options["path"] = $this->path; |
||
| 2180 | |||
| 2181 | if (isset($this->_SERVER["HTTP_DEPTH"])) { |
||
| 2182 | $options["depth"] = $this->_SERVER["HTTP_DEPTH"]; |
||
| 2183 | } else { |
||
| 2184 | $options["depth"] = "infinity"; |
||
| 2185 | } |
||
| 2186 | |||
| 2187 | $http_header_host = preg_replace("/:80$/", "", $this->_SERVER["HTTP_HOST"]); |
||
| 2188 | |||
| 2189 | $url = parse_url($this->_SERVER["HTTP_DESTINATION"]); |
||
| 2190 | // Vfs stores %, # and ? urlencoded, we do the encoding here on a central place |
||
| 2191 | $path = strtr(self::_urldecode($url["path"]), array( |
||
| 2192 | '%' => '%25', |
||
| 2193 | '#' => '%23', |
||
| 2194 | '?' => '%3F', |
||
| 2195 | )); |
||
| 2196 | //error_log(__METHOD__."(".array2string($what).") parse_url(HTTP_DESTINATION=".array2string($this->_SERVER["HTTP_DESTINATION"]).")=".array2string($url)." --> ".array2string($path)); |
||
| 2197 | |||
| 2198 | if (isset($url["host"])) { |
||
| 2199 | // TODO check url scheme, too |
||
| 2200 | $http_host = $url["host"]; |
||
| 2201 | if (isset($url["port"]) && $url["port"] != 80) |
||
| 2202 | $http_host.= ":".$url["port"]; |
||
| 2203 | } else { |
||
| 2204 | // only path given, set host to self |
||
| 2205 | $http_host = $http_header_host; |
||
| 2206 | } |
||
| 2207 | |||
| 2208 | if ($http_host == $http_header_host && |
||
| 2209 | !strncmp($this->_SERVER["SCRIPT_NAME"], $path, |
||
| 2210 | strlen($this->_SERVER["SCRIPT_NAME"]))) { |
||
| 2211 | $options["dest"] = substr($path, strlen($this->_SERVER["SCRIPT_NAME"])); |
||
| 2212 | if (!$this->_check_lock_status($options["dest"])) { |
||
| 2213 | $this->http_status("423 Locked"); |
||
| 2214 | return; |
||
| 2215 | } |
||
| 2216 | |||
| 2217 | } else { |
||
| 2218 | $options["dest_url"] = $this->_SERVER["HTTP_DESTINATION"]; |
||
| 2219 | } |
||
| 2220 | |||
| 2221 | // see RFC 2518 Sections 9.6, 8.8.4 and 8.9.3 |
||
| 2222 | if (isset($this->_SERVER["HTTP_OVERWRITE"])) { |
||
| 2223 | $options["overwrite"] = $this->_SERVER["HTTP_OVERWRITE"] == "T"; |
||
| 2224 | } else { |
||
| 2225 | $options["overwrite"] = true; |
||
| 2226 | } |
||
| 2227 | |||
| 2228 | $stat = $this->$what($options); |
||
| 2229 | $this->http_status($stat); |
||
| 2230 | } |
||
| 2231 | |||
| 2232 | // }}} |
||
| 2233 | |||
| 2234 | // {{{ _allow() |
||
| 2235 | |||
| 2236 | /** |
||
| 2237 | * check for implemented HTTP methods |
||
| 2238 | * |
||
| 2239 | * @param void |
||
| 2240 | * @return array something |
||
| 2241 | */ |
||
| 2242 | function _allow() |
||
| 2243 | { |
||
| 2244 | // OPTIONS is always there |
||
| 2245 | $allow = array("OPTIONS" =>"OPTIONS"); |
||
| 2246 | |||
| 2247 | // all other METHODS need both a http_method() wrapper |
||
| 2248 | // and a method() implementation |
||
| 2249 | // the base class supplies wrappers only |
||
| 2250 | foreach (get_class_methods($this) as $method) { |
||
| 2251 | if (!strncmp("http_", $method, 5)) { |
||
| 2252 | $method = strtoupper(substr($method, 5)); |
||
| 2253 | if (method_exists($this, $method)) { |
||
| 2254 | $allow[$method] = $method; |
||
| 2255 | } |
||
| 2256 | } |
||
| 2257 | } |
||
| 2258 | |||
| 2259 | // we can emulate a missing HEAD implemetation using GET |
||
| 2260 | if (isset($allow["GET"])) |
||
| 2261 | $allow["HEAD"] = "HEAD"; |
||
| 2262 | |||
| 2263 | // no LOCK without checklok() |
||
| 2264 | if (!method_exists($this, "checklock")) { |
||
| 2265 | unset($allow["LOCK"]); |
||
| 2266 | unset($allow["UNLOCK"]); |
||
| 2267 | } |
||
| 2268 | |||
| 2269 | return $allow; |
||
| 2270 | } |
||
| 2271 | |||
| 2272 | // }}} |
||
| 2273 | |||
| 2274 | /** |
||
| 2275 | * helper for property element creation |
||
| 2276 | * |
||
| 2277 | * @param string XML namespace (optional) |
||
| 2278 | * @param string property name |
||
| 2279 | * @param string property value |
||
| 2280 | * @praram boolen property raw-flag |
||
| 2281 | * @return array property array |
||
| 2282 | */ |
||
| 2283 | public static function mkprop() |
||
| 2284 | { |
||
| 2285 | $args = func_get_args(); |
||
| 2286 | switch (count($args)) { |
||
| 2287 | case 4: |
||
| 2288 | return array('ns' => $args[0], |
||
| 2289 | 'name' => $args[1], |
||
| 2290 | 'val' => $args[2], |
||
| 2291 | 'raw' => true); |
||
| 2292 | case 3: |
||
| 2293 | return array('ns' => $args[0], |
||
| 2294 | 'name' => $args[1], |
||
| 2295 | 'val' => $args[2]); |
||
| 2296 | default: |
||
| 2297 | return array('ns' => 'DAV:', |
||
| 2298 | 'name' => $args[0], |
||
| 2299 | 'val' => $args[1]); |
||
| 2300 | } |
||
| 2301 | } |
||
| 2302 | |||
| 2303 | // {{{ _check_auth |
||
| 2304 | |||
| 2305 | /** |
||
| 2306 | * check authentication if check is implemented |
||
| 2307 | * |
||
| 2308 | * @param void |
||
| 2309 | * @return bool true if authentication succeded or not necessary |
||
| 2310 | */ |
||
| 2311 | function _check_auth() |
||
| 2312 | { |
||
| 2313 | if (method_exists($this, "checkAuth")) { |
||
| 2314 | // PEAR style method name |
||
| 2315 | return $this->checkAuth(@$this->_SERVER["AUTH_TYPE"], |
||
| 2316 | @$this->_SERVER["PHP_AUTH_USER"], |
||
| 2317 | @$this->_SERVER["PHP_AUTH_PW"]); |
||
| 2318 | } else if (method_exists($this, "check_auth")) { |
||
| 2319 | // old (pre 1.0) method name |
||
| 2320 | return $this->check_auth(@$this->_SERVER["AUTH_TYPE"], |
||
| 2321 | @$this->_SERVER["PHP_AUTH_USER"], |
||
| 2322 | @$this->_SERVER["PHP_AUTH_PW"]); |
||
| 2323 | } else { |
||
| 2324 | // no method found -> no authentication required |
||
| 2325 | return true; |
||
| 2326 | } |
||
| 2327 | } |
||
| 2328 | |||
| 2329 | // }}} |
||
| 2330 | |||
| 2331 | // {{{ UUID stuff |
||
| 2332 | |||
| 2333 | /** |
||
| 2334 | * generate Unique Universal IDentifier for lock token |
||
| 2335 | * |
||
| 2336 | * @param void |
||
| 2337 | * @return string a new UUID |
||
| 2338 | */ |
||
| 2339 | public static function _new_uuid() |
||
| 2340 | { |
||
| 2341 | // use uuid extension from PECL if available |
||
| 2342 | if (function_exists("uuid_create")) { |
||
| 2343 | return uuid_create(); |
||
| 2344 | } |
||
| 2345 | |||
| 2346 | // fallback |
||
| 2347 | $uuid = md5(microtime().getmypid()); // this should be random enough for now |
||
| 2348 | |||
| 2349 | // set variant and version fields for 'true' random uuid |
||
| 2350 | $uuid{12} = "4"; |
||
| 2351 | $n = 8 + (ord($uuid{16}) & 3); |
||
| 2352 | $hex = "0123456789abcdef"; |
||
| 2353 | $uuid{16} = $hex{$n}; |
||
| 2354 | |||
| 2355 | // return formated uuid |
||
| 2356 | return substr($uuid, 0, 8)."-" |
||
| 2357 | . substr($uuid, 8, 4)."-" |
||
| 2358 | . substr($uuid, 12, 4)."-" |
||
| 2359 | . substr($uuid, 16, 4)."-" |
||
| 2360 | . substr($uuid, 20); |
||
| 2361 | } |
||
| 2362 | |||
| 2363 | /** |
||
| 2364 | * create a new opaque lock token as defined in RFC2518 |
||
| 2365 | * |
||
| 2366 | * @param void |
||
| 2367 | * @return string new RFC2518 opaque lock token |
||
| 2368 | */ |
||
| 2369 | public static function _new_locktoken() |
||
| 2370 | { |
||
| 2371 | return "opaquelocktoken:".self::_new_uuid(); |
||
| 2372 | } |
||
| 2373 | |||
| 2374 | // }}} |
||
| 2375 | |||
| 2376 | // {{{ WebDAV If: header parsing |
||
| 2377 | |||
| 2378 | /** |
||
| 2379 | * |
||
| 2380 | * |
||
| 2381 | * @param string header string to parse |
||
| 2382 | * @param int current parsing position |
||
| 2383 | * @return array next token (type and value) |
||
| 2384 | */ |
||
| 2385 | function _if_header_lexer($string, &$pos) |
||
| 2386 | { |
||
| 2387 | // skip whitespace |
||
| 2388 | while (ctype_space($string{$pos})) { |
||
| 2389 | ++$pos; |
||
| 2390 | } |
||
| 2391 | |||
| 2392 | // already at end of string? |
||
| 2393 | if (strlen($string) <= $pos) { |
||
| 2394 | return false; |
||
| 2395 | } |
||
| 2396 | |||
| 2397 | // get next character |
||
| 2398 | $c = $string{$pos++}; |
||
| 2399 | |||
| 2400 | // now it depends on what we found |
||
| 2401 | switch ($c) { |
||
| 2402 | case "<": |
||
| 2403 | // URIs are enclosed in <...> |
||
| 2404 | $pos2 = strpos($string, ">", $pos); |
||
| 2405 | $uri = substr($string, $pos, $pos2 - $pos); |
||
| 2406 | $pos = $pos2 + 1; |
||
| 2407 | return array("URI", $uri); |
||
| 2408 | |||
| 2409 | case "[": |
||
| 2410 | //Etags are enclosed in [...] |
||
| 2411 | if ($string{$pos} == "W") { |
||
| 2412 | $type = "ETAG_WEAK"; |
||
| 2413 | $pos += 2; |
||
| 2414 | } else { |
||
| 2415 | $type = "ETAG_STRONG"; |
||
| 2416 | } |
||
| 2417 | $pos2 = strpos($string, "]", $pos); |
||
| 2418 | $etag = substr($string, $pos + 1, $pos2 - $pos - 2); |
||
| 2419 | $pos = $pos2 + 1; |
||
| 2420 | return array($type, $etag); |
||
| 2421 | |||
| 2422 | case "N": |
||
| 2423 | // "N" indicates negation |
||
| 2424 | $pos += 2; |
||
| 2425 | return array("NOT", "Not"); |
||
| 2426 | |||
| 2427 | default: |
||
| 2428 | // anything else is passed verbatim char by char |
||
| 2429 | return array("CHAR", $c); |
||
| 2430 | } |
||
| 2431 | } |
||
| 2432 | |||
| 2433 | /** |
||
| 2434 | * parse If: header |
||
| 2435 | * |
||
| 2436 | * @param string header string |
||
| 2437 | * @return array URIs and their conditions |
||
| 2438 | */ |
||
| 2439 | function _if_header_parser($str) |
||
| 2440 | { |
||
| 2441 | $pos = 0; |
||
| 2442 | $len = strlen($str); |
||
| 2443 | $uris = array(); |
||
| 2444 | |||
| 2445 | // parser loop |
||
| 2446 | while ($pos < $len) { |
||
| 2447 | // get next token |
||
| 2448 | $token = $this->_if_header_lexer($str, $pos); |
||
| 2449 | |||
| 2450 | // check for URI |
||
| 2451 | if ($token[0] == "URI") { |
||
| 2452 | $uri = $token[1]; // remember URI |
||
| 2453 | $token = $this->_if_header_lexer($str, $pos); // get next token |
||
| 2454 | } else { |
||
| 2455 | $uri = ""; |
||
| 2456 | } |
||
| 2457 | |||
| 2458 | // sanity check |
||
| 2459 | if ($token[0] != "CHAR" || $token[1] != "(") { |
||
| 2460 | return false; |
||
| 2461 | } |
||
| 2462 | |||
| 2463 | $list = array(); |
||
| 2464 | $level = 1; |
||
| 2465 | $not = ""; |
||
| 2466 | while ($level) { |
||
| 2467 | $token = $this->_if_header_lexer($str, $pos); |
||
| 2468 | if ($token[0] == "NOT") { |
||
| 2469 | $not = "!"; |
||
| 2470 | continue; |
||
| 2471 | } |
||
| 2472 | switch ($token[0]) { |
||
| 2473 | case "CHAR": |
||
| 2474 | switch ($token[1]) { |
||
| 2475 | case "(": |
||
| 2476 | $level++; |
||
| 2477 | break; |
||
| 2478 | case ")": |
||
| 2479 | $level--; |
||
| 2480 | break; |
||
| 2481 | default: |
||
| 2482 | return false; |
||
| 2483 | } |
||
| 2484 | break; |
||
| 2485 | |||
| 2486 | case "URI": |
||
| 2487 | $list[] = $not."<$token[1]>"; |
||
| 2488 | break; |
||
| 2489 | |||
| 2490 | case "ETAG_WEAK": |
||
| 2491 | $list[] = $not."[W/'$token[1]']>"; |
||
| 2492 | break; |
||
| 2493 | |||
| 2494 | case "ETAG_STRONG": |
||
| 2495 | $list[] = $not."['$token[1]']>"; |
||
| 2496 | break; |
||
| 2497 | |||
| 2498 | default: |
||
| 2499 | return false; |
||
| 2500 | } |
||
| 2501 | $not = ""; |
||
| 2502 | } |
||
| 2503 | |||
| 2504 | if (@is_array($uris[$uri])) { |
||
| 2505 | $uris[$uri] = array_merge($uris[$uri], $list); |
||
| 2506 | } else { |
||
| 2507 | $uris[$uri] = $list; |
||
| 2508 | } |
||
| 2509 | } |
||
| 2510 | |||
| 2511 | return $uris; |
||
| 2512 | } |
||
| 2513 | |||
| 2514 | /** |
||
| 2515 | * check if conditions from "If:" headers are meat |
||
| 2516 | * |
||
| 2517 | * the "If:" header is an extension to HTTP/1.1 |
||
| 2518 | * defined in RFC 2518 section 9.4 |
||
| 2519 | * |
||
| 2520 | * @param void |
||
| 2521 | * @return void |
||
| 2522 | */ |
||
| 2523 | function _check_if_header_conditions() |
||
| 2524 | { |
||
| 2525 | if (isset($this->_SERVER["HTTP_IF"])) { |
||
| 2526 | $this->_if_header_uris = |
||
| 2527 | $this->_if_header_parser($this->_SERVER["HTTP_IF"]); |
||
| 2528 | |||
| 2529 | foreach ($this->_if_header_uris as $uri => $conditions) { |
||
| 2530 | if ($uri == "") { |
||
| 2531 | $uri = $this->uri; |
||
| 2532 | } |
||
| 2533 | // all must match |
||
| 2534 | $state = true; |
||
| 2535 | foreach ($conditions as $condition) { |
||
| 2536 | // lock tokens may be free form (RFC2518 6.3) |
||
| 2537 | // but if opaquelocktokens are used (RFC2518 6.4) |
||
| 2538 | // we have to check the format (litmus tests this) |
||
| 2539 | if (!strncmp($condition, "<opaquelocktoken:", strlen("<opaquelocktoken"))) { |
||
| 2540 | if (!preg_match('/^<opaquelocktoken:[[:xdigit:]]{8}-[[:xdigit:]]{4}-[[:xdigit:]]{4}-[[:xdigit:]]{4}-[[:xdigit:]]{12}>$/', $condition)) { |
||
| 2541 | $this->http_status("423 Locked"); |
||
| 2542 | return false; |
||
| 2543 | } |
||
| 2544 | } |
||
| 2545 | if (!$this->_check_uri_condition($uri, $condition)) { |
||
| 2546 | $this->http_status("412 Precondition failed"); |
||
| 2547 | $state = false; |
||
| 2548 | break; |
||
| 2549 | } |
||
| 2550 | } |
||
| 2551 | |||
| 2552 | // any match is ok |
||
| 2553 | if ($state == true) { |
||
| 2554 | return true; |
||
| 2555 | } |
||
| 2556 | } |
||
| 2557 | return false; |
||
| 2558 | } |
||
| 2559 | return true; |
||
| 2560 | } |
||
| 2561 | |||
| 2562 | /** |
||
| 2563 | * Check a single URI condition parsed from an if-header |
||
| 2564 | * |
||
| 2565 | * Check a single URI condition parsed from an if-header |
||
| 2566 | * |
||
| 2567 | * @abstract |
||
| 2568 | * @param string $uri URI to check |
||
| 2569 | * @param string $condition Condition to check for this URI |
||
| 2570 | * @returns bool Condition check result |
||
| 2571 | */ |
||
| 2572 | function _check_uri_condition($uri, $condition) |
||
| 2573 | { |
||
| 2574 | unset($uri); // not used, but required by function signature |
||
| 2575 | // not really implemented here, |
||
| 2576 | // implementations must override |
||
| 2577 | |||
| 2578 | // a lock token can never be from the DAV: scheme |
||
| 2579 | // litmus uses DAV:no-lock in some tests |
||
| 2580 | if (!strncmp("<DAV:", $condition, 5)) { |
||
| 2581 | return false; |
||
| 2582 | } |
||
| 2583 | |||
| 2584 | return true; |
||
| 2585 | } |
||
| 2586 | |||
| 2587 | |||
| 2588 | /** |
||
| 2589 | * |
||
| 2590 | * |
||
| 2591 | * @param string path of resource to check |
||
| 2592 | * @param bool exclusive lock? |
||
| 2593 | */ |
||
| 2594 | function _check_lock_status($path, $exclusive_only = false) |
||
| 2595 | { |
||
| 2596 | // FIXME depth -> ignored for now |
||
| 2597 | if (method_exists($this, "checkLock")) { |
||
| 2598 | // is locked? |
||
| 2599 | $lock = $this->checkLock($path); |
||
| 2600 | |||
| 2601 | // ... and lock is not owned? |
||
| 2602 | if (is_array($lock) && count($lock)) { |
||
| 2603 | // FIXME doesn't check uri restrictions yet |
||
| 2604 | if (!isset($this->_SERVER["HTTP_IF"]) || !strstr($this->_SERVER["HTTP_IF"], $lock["token"])) { |
||
| 2605 | if (!$exclusive_only || ($lock["scope"] !== "shared")) |
||
| 2606 | return false; |
||
| 2607 | } |
||
| 2608 | } |
||
| 2609 | } |
||
| 2610 | return true; |
||
| 2611 | } |
||
| 2612 | |||
| 2613 | |||
| 2614 | // }}} |
||
| 2615 | |||
| 2616 | |||
| 2617 | /** |
||
| 2618 | * Generate lockdiscovery reply from checklock() result |
||
| 2619 | * |
||
| 2620 | * @param string resource path to check |
||
| 2621 | * @return string lockdiscovery response |
||
| 2622 | */ |
||
| 2623 | function lockdiscovery($path) |
||
| 2624 | { |
||
| 2625 | // no lock support without checklock() method |
||
| 2626 | if (!method_exists($this, "checklock")) { |
||
| 2627 | return ""; |
||
| 2628 | } |
||
| 2629 | |||
| 2630 | // collect response here |
||
| 2631 | $activelocks = ""; |
||
| 2632 | |||
| 2633 | // get checklock() reply |
||
| 2634 | $lock = $this->checklock($path); |
||
| 2635 | |||
| 2636 | // generate <activelock> block for returned data |
||
| 2637 | if (is_array($lock) && count($lock)) { |
||
| 2638 | // check for 'timeout' or 'expires' |
||
| 2639 | if (!empty($lock["expires"])) { |
||
| 2640 | $timeout = "Second-".($lock["expires"] - time()); |
||
| 2641 | } else if (!empty($lock["timeout"])) { |
||
| 2642 | $timeout = "Second-$lock[timeout]"; |
||
| 2643 | } else { |
||
| 2644 | $timeout = "Infinite"; |
||
| 2645 | } |
||
| 2646 | |||
| 2647 | // genreate response block |
||
| 2648 | if ($this->crrnd) |
||
| 2649 | { |
||
| 2650 | $activelocks.= " |
||
| 2651 | <activelock> |
||
| 2652 | <lockscope><$lock[scope]/></lockscope> |
||
| 2653 | <locktype><$lock[type]/></locktype> |
||
| 2654 | <depth>$lock[depth]</depth> |
||
| 2655 | <owner>$lock[owner]</owner> |
||
| 2656 | <timeout>$timeout</timeout> |
||
| 2657 | <locktoken><href>$lock[token]</href></locktoken> |
||
| 2658 | </activelock> |
||
| 2659 | "; |
||
| 2660 | } |
||
| 2661 | else |
||
| 2662 | { |
||
| 2663 | $activelocks.= " |
||
| 2664 | <D:activelock> |
||
| 2665 | <D:lockscope><D:$lock[scope]/></D:lockscope> |
||
| 2666 | <D:locktype><D:$lock[type]/></D:locktype> |
||
| 2667 | <D:depth>$lock[depth]</D:depth> |
||
| 2668 | <D:owner>$lock[owner]</D:owner> |
||
| 2669 | <D:timeout>$timeout</D:timeout> |
||
| 2670 | <D:locktoken><D:href>$lock[token]</D:href></D:locktoken> |
||
| 2671 | </D:activelock> |
||
| 2672 | "; |
||
| 2673 | } |
||
| 2674 | } |
||
| 2675 | |||
| 2676 | // return generated response |
||
| 2677 | //error_log(__METHOD__."\n".print_r($activelocks,true)); |
||
| 2678 | return $activelocks; |
||
| 2679 | } |
||
| 2680 | |||
| 2681 | /** |
||
| 2682 | * set HTTP return status and mirror it in a private header |
||
| 2683 | * |
||
| 2684 | * @param string status code and message |
||
| 2685 | * @return void |
||
| 2686 | */ |
||
| 2687 | function http_status($status) |
||
| 2688 | { |
||
| 2689 | // simplified success case |
||
| 2690 | if ($status === true) { |
||
| 2691 | $status = "200 OK"; |
||
| 2692 | } |
||
| 2693 | |||
| 2694 | // remember status |
||
| 2695 | $this->_http_status = $status; |
||
| 2696 | |||
| 2697 | // generate HTTP status response |
||
| 2698 | header("HTTP/1.1 $status"); |
||
| 2699 | header("X-WebDAV-Status: $status", true); |
||
| 2700 | } |
||
| 2701 | |||
| 2702 | /** |
||
| 2703 | * private URL encoding |
||
| 2704 | * |
||
| 2705 | * We use now full url-encoding as required by WebDAV RFC and many clients. |
||
| 2706 | * Formerly HTTP_WebDAV_Server used to encode only: " %&<>+" |
||
| 2707 | * |
||
| 2708 | * @param string URL to encode |
||
| 2709 | * @return string encoded URL |
||
| 2710 | */ |
||
| 2711 | public static function _urlencode($url) |
||
| 2712 | { |
||
| 2713 | return strtr(rawurlencode($url),array( |
||
| 2714 | '%2F' => '/', |
||
| 2715 | '%3A' => ':', |
||
| 2716 | )); |
||
| 2717 | } |
||
| 2718 | |||
| 2719 | /** |
||
| 2720 | * private version of PHP urldecode |
||
| 2721 | * |
||
| 2722 | * not really needed but added for completenes |
||
| 2723 | * |
||
| 2724 | * @param string URL to decode |
||
| 2725 | * @return string decoded URL |
||
| 2726 | */ |
||
| 2727 | public static function _urldecode($path) |
||
| 2728 | { |
||
| 2729 | return rawurldecode($path); |
||
| 2730 | } |
||
| 2731 | |||
| 2732 | /** |
||
| 2733 | * Encode a hierarchical properties like: |
||
| 2734 | * |
||
| 2735 | * <D:supported-report-set> |
||
| 2736 | * <supported-report> |
||
| 2737 | * <report> |
||
| 2738 | * <addressbook-query xmlns='urn:ietf:params:xml:ns:carddav'/> |
||
| 2739 | * </report> |
||
| 2740 | * </supported-report> |
||
| 2741 | * <supported-report> |
||
| 2742 | * <report> |
||
| 2743 | * <addressbook-multiget xmlns='urn:ietf:params:xml:ns:carddav'/> |
||
| 2744 | * </report> |
||
| 2745 | * </supported-report> |
||
| 2746 | * </D:supported-report-set> |
||
| 2747 | * |
||
| 2748 | * @param array $props |
||
| 2749 | * @param string $ns |
||
| 2750 | * @param strin $ns_defs |
||
| 2751 | * @param array $ns_hash |
||
| 2752 | * @return string |
||
| 2753 | */ |
||
| 2754 | function _hierarchical_prop_encode(array $props, $ns, &$ns_defs, array &$ns_hash) |
||
| 2755 | { |
||
| 2756 | $ret = ''; |
||
| 2757 | |||
| 2758 | //error_log(__METHOD__.'('.array2string($props).')'); |
||
| 2759 | if (isset($props['name'])) $props = array($props); |
||
| 2760 | |||
| 2761 | foreach($props as $prop) |
||
| 2762 | { |
||
| 2763 | if (!isset($ns_hash[$prop['ns']])) // unknown namespace |
||
| 2764 | { |
||
| 2765 | // register namespace |
||
| 2766 | $ns_name = 'ns'.(count($ns_hash) + 1); |
||
| 2767 | $ns_hash[$prop['ns']] = $ns_name; |
||
| 2768 | $ns_defs .= ' xmlns:'.$ns_name.'="'.$prop['ns'].'"'; |
||
| 2769 | } |
||
| 2770 | if (is_array($prop['val'])) |
||
| 2771 | { |
||
| 2772 | $subprop = $prop['val']; |
||
| 2773 | if (isset($subprop['ns']) || isset($subprop[0]['ns'])) |
||
| 2774 | { |
||
| 2775 | $ret .= '<'.($prop['ns'] == $ns ? ($this->crrnd ? '' : $ns_hash[$ns].':') : $ns_hash[$prop['ns']].':').$prop['name']. |
||
| 2776 | (empty($prop['val']) ? '/>' : '>'.$this->_hierarchical_prop_encode($prop['val'], $prop['ns'], $ns_defs, $ns_hash). |
||
| 2777 | '</'.($prop['ns'] == $ns ? ($this->crrnd ? '' : $ns_hash[$ns].':') : ($this->crrnd ? '' : $ns_hash[$prop['ns']].':')).$prop['name'].'>'); |
||
| 2778 | } |
||
| 2779 | else // val contains only attributes, no value |
||
| 2780 | { |
||
| 2781 | $vals = ''; |
||
| 2782 | |||
| 2783 | foreach($subprop as $attr => $val) |
||
| 2784 | { |
||
| 2785 | $vals .= ' '.$attr.'="'.htmlspecialchars($val, ENT_NOQUOTES|ENT_XML1|ENT_DISALLOWED, 'utf-8').'"'; |
||
| 2786 | } |
||
| 2787 | |||
| 2788 | $ret .= '<'.($prop['ns'] == $ns ? ($this->crrnd ? '' : $ns_hash[$ns].':') : $ns_hash[$prop['ns']].':').$prop['name']. |
||
| 2789 | $vals .'/>'; |
||
| 2790 | } |
||
| 2791 | } |
||
| 2792 | else |
||
| 2793 | { |
||
| 2794 | if (empty($prop['val'])) |
||
| 2795 | { |
||
| 2796 | $val = ''; |
||
| 2797 | } |
||
| 2798 | else |
||
| 2799 | { |
||
| 2800 | if(isset($prop['raw'])) |
||
| 2801 | { |
||
| 2802 | $val = $this->_prop_encode('<![CDATA['.$prop['val'].']]>'); |
||
| 2803 | } else { |
||
| 2804 | $val = $this->_prop_encode(htmlspecialchars($prop['val'], ENT_NOQUOTES, 'utf-8')); |
||
| 2805 | // do NOT urlencode mailto href, as no clients understands them |
||
| 2806 | if ($prop['name'] == 'href' && stripos($val, 'mailto:') !== 0) |
||
| 2807 | { |
||
| 2808 | $val = $this->_urlencode($val); |
||
| 2809 | } |
||
| 2810 | } |
||
| 2811 | } |
||
| 2812 | |||
| 2813 | $ret .= '<'.($prop['ns'] == $ns ? ($this->crrnd ? '' : $ns_hash[$ns].':') : $ns_hash[$prop['ns']].':').$prop['name']. |
||
| 2814 | (empty($prop['val']) ? ' />' : '>'.$val.'</'. |
||
| 2815 | ($prop['ns'] == $ns ? ($this->crrnd ? '' : $ns_hash[$ns].':') : ($this->crrnd ? '' : $ns_hash[$prop['ns']].':')).$prop['name'].'>'); |
||
| 2816 | } |
||
| 2817 | } |
||
| 2818 | |||
| 2819 | //error_log(__METHOD__.'('.array2string($props).") crrnd=$this->crrnd returning ".array2string($ret)); |
||
| 2820 | return $ret; |
||
| 2821 | } |
||
| 2822 | |||
| 2823 | /** |
||
| 2824 | * UTF-8 encode property values if not already done so |
||
| 2825 | * |
||
| 2826 | * @param string text to encode |
||
| 2827 | * @return string utf-8 encoded text |
||
| 2828 | */ |
||
| 2829 | function _prop_encode($text) |
||
| 2830 | { |
||
| 2831 | //error_log( __METHOD__."\n" .print_r($text,true)); |
||
| 2832 | //error_log("prop-encode:" . print_r($this->_prop_encoding,true)); |
||
| 2833 | |||
| 2834 | switch (strtolower($this->_prop_encoding)) { |
||
| 2835 | case "utf-8": |
||
| 2836 | //error_log( __METHOD__."allready encoded\n" .print_r($text,true)); |
||
| 2837 | return $text; |
||
| 2838 | case "iso-8859-1": |
||
| 2839 | case "iso-8859-15": |
||
| 2840 | case "latin-1": |
||
| 2841 | default: |
||
| 2842 | error_log( __METHOD__."utf8 encode\n" .print_r(utf8_encode($text),true)); |
||
| 2843 | return utf8_encode($text); |
||
| 2844 | } |
||
| 2845 | } |
||
| 2846 | |||
| 2847 | /** |
||
| 2848 | * Slashify - make sure path ends in a slash |
||
| 2849 | * |
||
| 2850 | * @param string directory path |
||
| 2851 | * @returns string directory path wiht trailing slash |
||
| 2852 | */ |
||
| 2853 | public static function _slashify($path) |
||
| 2854 | { |
||
| 2855 | //error_log(__METHOD__." called with $path"); |
||
| 2856 | if ($path[self::bytes($path)-1] != '/') { |
||
| 2857 | //error_log(__METHOD__." added slash at the end of path"); |
||
| 2858 | $path = $path."/"; |
||
| 2859 | } |
||
| 2860 | return $path; |
||
| 2861 | } |
||
| 2862 | |||
| 2863 | /** |
||
| 2864 | * Unslashify - make sure path doesn't in a slash |
||
| 2865 | * |
||
| 2866 | * @param string directory path |
||
| 2867 | * @returns string directory path wihtout trailing slash |
||
| 2868 | */ |
||
| 2869 | public static function _unslashify($path) |
||
| 2877 | } |
||
| 2878 | |||
| 2879 | /** |
||
| 2880 | * Merge two paths, make sure there is exactly one slash between them |
||
| 2881 | * |
||
| 2882 | * @param string parent path |
||
| 2883 | * @param string child path |
||
| 2884 | * @return string merged path |
||
| 2885 | */ |
||
| 2886 | public static function _mergePaths($parent, $child) |
||
| 2887 | { |
||
| 2888 | //error_log("merge called :\n$parent \n$child\n" . function_backtrace()); |
||
| 2889 | //error_log("merge :\n".print_r($this->_mergePaths($this->_SERVER["SCRIPT_NAME"], $this->path)true)); |
||
| 2890 | if ($child{0} == '/') { |
||
| 2891 | return self::_unslashify($parent).$child; |
||
| 2892 | } else { |
||
| 2893 | return self::_slashify($parent).$child; |
||
| 2894 | } |
||
| 2895 | } |
||
| 2896 | |||
| 2897 | /** |
||
| 2898 | * mbstring.func_overload save strlen version: counting the bytes not the chars |
||
| 2899 | * |
||
| 2900 | * @param string $str |
||
| 2901 | * @return int |
||
| 2902 | */ |
||
| 2903 | public static function bytes($str) |
||
| 2912 | } |
||
| 2913 | } |
||
| 2914 | |||
| 2915 | /* |
||
| 2916 | * Local variables: |
||
| 2917 | * tab-width: 4 |
||
| 2918 | * c-basic-offset: 4 |
||
| 2919 | * End: |
||
| 2920 | */ |
||
| 2921 |