lib/webdavlib.php

   1 <?php
   2
   3 // This file is part of Moodle - http://moodle.org/
   4 //
   5 // Moodle is free software: you can redistribute it and/or modify
   6 // it under the terms of the GNU General Public License as published by
   7 // the Free Software Foundation, either version 3 of the License, or
   8 // (at your option) any later version.
   9 //
  10 // Moodle is distributed in the hope that it will be useful,
  11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13 // GNU General Public License for more details.
  14 //
  15 // You should have received a copy of the GNU General Public License
  16 // along with Moodle.  If not, see <http://www.gnu.org/licenses/>.
  17
  18 /**
  19  * A Moodle-modified WebDAV client, based on
  20  * webdav_client v0.1.5, a php based webdav client class.
  21  * class webdav client. a php based nearly RFC 2518 conforming client.
  22  *
  23  * This class implements methods to get access to an webdav server.
  24  * Most of the methods are returning boolean false on error, an integer status (http response status) on success
  25  * or an array in case of a multistatus response (207) from the webdav server. Look at the code which keys are used in arrays.
  26  * It's your responsibility to handle the webdav server responses in an proper manner.
  27  * Please notice that all Filenames coming from or going to the webdav server should be UTF-8 encoded (see RFC 2518).
  28  * This class tries to convert all you filenames into utf-8 when it's needed.
  29  *
  30  * Moodle modifications:
  31  * * Moodle 3.4: Add support for OAuth 2 bearer token-based authentication
  32  *
  33  * @package moodlecore
  34  * @author Christian Juerges <christian.juerges@xwave.ch>, Xwave GmbH, Josefstr. 92, 8005 Zuerich - Switzerland
  35  * @copyright (C) 2003/2004, Christian Juerges
  36  * @license http://opensource.org/licenses/lgpl-license.php GNU Lesser General Public License
  37  */
  38
  39 class webdav_client {
  40
  41     /**#@+
  42      * @access private
  43      * @var string
  44      */
  45     private $_debug = false;
  46     private $sock;
  47     private $_server;
  48     private $_protocol = 'HTTP/1.1';
  49     private $_port = 80;
  50     private $_socket = '';
  51     private $_path ='/';
  52     private $_auth = false;
  53     private $_user;
  54     private $_pass;
  55
  56     private $_socket_timeout = 5;
  57     private $_errno;
  58     private $_errstr;
  59     private $_user_agent = 'Moodle WebDav Client';
  60     private $_crlf = "\r\n";
  61     private $_req;
  62     private $_resp_status;
  63     private $_parser;
  64     private $_parserid;
  65     private $_xmltree;
  66     private $_tree;
  67     private $_ls = array();
  68     private $_ls_ref;
  69     private $_ls_ref_cdata;
  70     private $_delete = array();
  71     private $_delete_ref;
  72     private $_delete_ref_cdata;
  73     private $_lock = array();
  74     private $_lock_ref;
  75     private $_lock_rec_cdata;
  76     private $_null = NULL;
  77     private $_header='';
  78     private $_body='';
  79     private $_connection_closed = false;
  80     private $_maxheaderlenth = 65536;
  81     private $_digestchallenge = null;
  82     private $_cnonce = '';
  83     private $_nc = 0;
  84
  85     /**
  86      * OAuth token used for bearer auth.
  87      * @var string
  88      */
  89     private $oauthtoken;
  90
  91     /**#@-*/
  92
  93     /**
  94      * Constructor - Initialise class variables
  95      * @param string $server Hostname of the server to connect to
  96      * @param string $user Username (for basic/digest auth, see $auth)
  97      * @param string $pass Password (for basic/digest auth, see $auth)
  98      * @param bool $auth Authentication type; one of ['basic', 'digest', 'bearer']
  99      * @param string $socket Used protocol for fsockopen, usually: '' (empty) or 'ssl://'
 100      * @param string $oauthtoken OAuth 2 bearer token (for bearer auth, see $auth)
 101      */
 102     public function __construct($server = '', $user = '', $pass = '', $auth = false, $socket = '', $oauthtoken = '') {
 103         if (!empty($server)) {
 104             $this->_server = $server;
 105         }
 106         if (!empty($user) && !empty($pass)) {
 107             $this->user = $user;
 108             $this->pass = $pass;
 109         }
 110         $this->_auth = $auth;
 111         $this->_socket = $socket;
 112         if ($auth == 'bearer') {
 113             $this->oauthtoken = $oauthtoken;
 114         }
 115     }
 116     public function __set($key, $value) {
 117         $property = '_' . $key;
 118         $this->$property = $value;
 119     }
 120
 121     /**
 122      * Set which HTTP protocol will be used.
 123      * Value 1 defines that HTTP/1.1 should be used (Keeps Connection to webdav server alive).
 124      * Otherwise HTTP/1.0 will be used.
 125      * @param int version
 126      */
 127     function set_protocol($version) {
 128         if ($version == 1) {
 129             $this->_protocol = 'HTTP/1.1';
 130         } else {
 131             $this->_protocol = 'HTTP/1.0';
 132         }
 133     }
 134
 135     /**
 136      * Convert ISO 8601 Date and Time Profile used in RFC 2518 to an unix timestamp.
 137      * @access private
 138      * @param string iso8601
 139      * @return unixtimestamp on sucess. Otherwise false.
 140      */
 141     function iso8601totime($iso8601) {
 142         /*
 143
 144          date-time       = full-date "T" full-time
 145
 146          full-date       = date-fullyear "-" date-month "-" date-mday
 147          full-time       = partial-time time-offset
 148
 149          date-fullyear   = 4DIGIT
 150          date-month      = 2DIGIT  ; 01-12
 151          date-mday       = 2DIGIT  ; 01-28, 01-29, 01-30, 01-31 based on
 152          month/year
 153          time-hour       = 2DIGIT  ; 00-23
 154          time-minute     = 2DIGIT  ; 00-59
 155          time-second     = 2DIGIT  ; 00-59, 00-60 based on leap second rules
 156          time-secfrac    = "." 1*DIGIT
 157          time-numoffset  = ("+" / "-") time-hour ":" time-minute
 158          time-offset     = "Z" / time-numoffset
 159
 160          partial-time    = time-hour ":" time-minute ":" time-second
 161                                             [time-secfrac]
 162          */
 163
 164         $regs = array();
 165         /*         [1]        [2]        [3]        [4]        [5]        [6]  */
 166         if (preg_match('/^([0-9]{4})-([0-9]{2})-([0-9]{2})T([0-9]{2}):([0-9]{2}):([0-9]{2})Z$/', $iso8601, $regs)) {
 167             return mktime($regs[4],$regs[5], $regs[6], $regs[2], $regs[3], $regs[1]);
 168         }
 169         // to be done: regex for partial-time...apache webdav mod never returns partial-time
 170
 171         return false;
 172     }
 173
 174     /**
 175      * Open's a socket to a webdav server
 176      * @return bool true on success. Otherwise false.
 177      */
 178     function open() {
 179         // let's try to open a socket
 180         $this->_error_log('open a socket connection');
 181         $this->sock = fsockopen($this->_socket . $this->_server, $this->_port, $this->_errno, $this->_errstr, $this->_socket_timeout);
 182         core_php_time_limit::raise(30);
 183         if (is_resource($this->sock)) {
 184             socket_set_blocking($this->sock, true);
 185             $this->_connection_closed = false;
 186             $this->_error_log('socket is open: ' . $this->sock);
 187             return true;
 188         } else {
 189             $this->_error_log("$this->_errstr ($this->_errno)\n");
 190             return false;
 191         }
 192     }
 193
 194     /**
 195      * Closes an open socket.
 196      */
 197     function close() {
 198         $this->_error_log('closing socket ' . $this->sock);
 199         $this->_connection_closed = true;
 200         fclose($this->sock);
 201     }
 202
 203     /**
 204      * Check's if server is a webdav compliant server.
 205      * True if server returns a DAV Element in Header and when
 206      * schema 1,2 is supported.
 207      * @return bool true if server is webdav server. Otherwise false.
 208      */
 209     function check_webdav() {
 210         $resp = $this->options();
 211         if (!$resp) {
 212             return false;
 213         }
 214         $this->_error_log($resp['header']['DAV']);
 215         // check schema
 216         if (preg_match('/1,2/', $resp['header']['DAV'])) {
 217             return true;
 218         }
 219         // otherwise return false
 220         return false;
 221     }
 222
 223
 224     /**
 225      * Get options from webdav server.
 226      * @return array with all header fields returned from webdav server. false if server does not speak http.
 227      */
 228     function options() {
 229         $this->header_unset();
 230         $this->create_basic_request('OPTIONS');
 231         $this->send_request();
 232         $this->get_respond();
 233         $response = $this->process_respond();
 234         // validate the response ...
 235         // check http-version
 236         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 237             $response['status']['http-version'] == 'HTTP/1.0') {
 238                 return $response;
 239             }
 240         $this->_error_log('Response was not even http');
 241         return false;
 242
 243     }
 244
 245     /**
 246      * Public method mkcol
 247      *
 248      * Creates a new collection/directory on a webdav server
 249      * @param string path
 250      * @return int status code received as response from webdav server (see rfc 2518)
 251      */
 252     function mkcol($path) {
 253         $this->_path = $this->translate_uri($path);
 254         $this->header_unset();
 255         $this->create_basic_request('MKCOL');
 256         $this->send_request();
 257         $this->get_respond();
 258         $response = $this->process_respond();
 259         // validate the response ...
 260         // check http-version
 261         $http_version = $response['status']['http-version'];
 262         if ($http_version == 'HTTP/1.1' || $http_version == 'HTTP/1.0') {
 263             /** seems to be http ... proceed
 264              * just return what server gave us
 265              * rfc 2518 says:
 266              * 201 (Created) - The collection or structured resource was created in its entirety.
 267              * 403 (Forbidden) - This indicates at least one of two conditions:
 268              *    1) the server does not allow the creation of collections at the given location in its namespace, or
 269              *    2) the parent collection of the Request-URI exists but cannot accept members.
 270              * 405 (Method Not Allowed) - MKCOL can only be executed on a deleted/non-existent resource.
 271              * 409 (Conflict) - A collection cannot be made at the Request-URI until one or more intermediate
 272              *                  collections have been created.
 273              * 415 (Unsupported Media Type)- The server does not support the request type of the body.
 274              * 507 (Insufficient Storage) - The resource does not have sufficient space to record the state of the
 275              *                              resource after the execution of this method.
 276              */
 277             return $response['status']['status-code'];
 278         }
 279
 280     }
 281
 282     /**
 283      * Public method get
 284      *
 285      * Gets a file from a webdav collection.
 286      * @param string $path the path to the file on the webdav server
 287      * @param string &$buffer the buffer to store the data in
 288      * @param resource $fp optional if included, the data is written directly to this resource and not to the buffer
 289      * @return string|bool status code and &$buffer (by reference) with response data from server on success. False on error.
 290      */
 291     function get($path, &$buffer, $fp = null) {
 292         $this->_path = $this->translate_uri($path);
 293         $this->header_unset();
 294         $this->create_basic_request('GET');
 295         $this->send_request();
 296         $this->get_respond($fp);
 297         $response = $this->process_respond();
 298
 299         $http_version = $response['status']['http-version'];
 300         // validate the response
 301         // check http-version
 302         if ($http_version == 'HTTP/1.1' || $http_version == 'HTTP/1.0') {
 303                 // seems to be http ... proceed
 304                 // We expect a 200 code
 305                 if ($response['status']['status-code'] == 200 ) {
 306                     if (!is_null($fp)) {
 307                         $stat = fstat($fp);
 308                         $this->_error_log('file created with ' . $stat['size'] . ' bytes.');
 309                     } else {
 310                         $this->_error_log('returning buffer with ' . strlen($response['body']) . ' bytes.');
 311                         $buffer = $response['body'];
 312                     }
 313                 }
 314                 return $response['status']['status-code'];
 315             }
 316         // ups: no http status was returned ?
 317         return false;
 318     }
 319
 320     /**
 321      * Public method put
 322      *
 323      * Puts a file into a collection.
 324      *  Data is putted as one chunk!
 325      * @param string path, string data
 326      * @return int status-code read from webdavserver. False on error.
 327      */
 328     function put($path, $data ) {
 329         $this->_path = $this->translate_uri($path);
 330         $this->header_unset();
 331         $this->create_basic_request('PUT');
 332         // add more needed header information ...
 333         $this->header_add('Content-length: ' . strlen($data));
 334         $this->header_add('Content-type: application/octet-stream');
 335         // send header
 336         $this->send_request();
 337         // send the rest (data)
 338         fputs($this->sock, $data);
 339         $this->get_respond();
 340         $response = $this->process_respond();
 341
 342         // validate the response
 343         // check http-version
 344         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 345             $response['status']['http-version'] == 'HTTP/1.0') {
 346                 // seems to be http ... proceed
 347                 // We expect a 200 or 204 status code
 348                 // see rfc 2068 - 9.6 PUT...
 349                 // print 'http ok<br>';
 350                 return $response['status']['status-code'];
 351             }
 352         // ups: no http status was returned ?
 353         return false;
 354     }
 355
 356     /**
 357      * Public method put_file
 358      *
 359      * Read a file as stream and puts it chunk by chunk into webdav server collection.
 360      *
 361      * Look at php documenation for legal filenames with fopen();
 362      * The filename will be translated into utf-8 if not allready in utf-8.
 363      *
 364      * @param string targetpath, string filename
 365      * @return int status code. False on error.
 366      */
 367     function put_file($path, $filename) {
 368         // try to open the file ...
 369
 370
 371         $handle = @fopen ($filename, 'r');
 372
 373         if ($handle) {
 374             // $this->sock = pfsockopen ($this->_server, $this->_port, $this->_errno, $this->_errstr, $this->_socket_timeout);
 375             $this->_path = $this->translate_uri($path);
 376             $this->header_unset();
 377             $this->create_basic_request('PUT');
 378             // add more needed header information ...
 379             $this->header_add('Content-length: ' . filesize($filename));
 380             $this->header_add('Content-type: application/octet-stream');
 381             // send header
 382             $this->send_request();
 383             while (!feof($handle)) {
 384                 fputs($this->sock,fgets($handle,4096));
 385             }
 386             fclose($handle);
 387             $this->get_respond();
 388             $response = $this->process_respond();
 389
 390             // validate the response
 391             // check http-version
 392             if ($response['status']['http-version'] == 'HTTP/1.1' ||
 393                 $response['status']['http-version'] == 'HTTP/1.0') {
 394                     // seems to be http ... proceed
 395                     // We expect a 200 or 204 status code
 396                     // see rfc 2068 - 9.6 PUT...
 397                     // print 'http ok<br>';
 398                     return $response['status']['status-code'];
 399                 }
 400             // ups: no http status was returned ?
 401             return false;
 402         } else {
 403             $this->_error_log('put_file: could not open ' . $filename);
 404             return false;
 405         }
 406
 407     }
 408
 409     /**
 410      * Public method get_file
 411      *
 412      * Gets a file from a collection into local filesystem.
 413      *
 414      * fopen() is used.
 415      * @param string $srcpath
 416      * @param string $localpath
 417      * @return bool true on success. false on error.
 418      */
 419     function get_file($srcpath, $localpath) {
 420
 421         $localpath = $this->utf_decode_path($localpath);
 422
 423         $handle = fopen($localpath, 'wb');
 424         if ($handle) {
 425             $unused = '';
 426             $ret = $this->get($srcpath, $unused, $handle);
 427             fclose($handle);
 428             if ($ret) {
 429                 return true;
 430             }
 431         }
 432         return false;
 433     }
 434
 435     /**
 436      * Public method copy_file
 437      *
 438      * Copies a file on a webdav server
 439      *
 440      * Duplicates a file on the webdav server (serverside).
 441      * All work is done on the webdav server. If you set param overwrite as true,
 442      * the target will be overwritten.
 443      *
 444      * @param string src_path, string dest_path, bool overwrite
 445      * @return int status code (look at rfc 2518). false on error.
 446      */
 447     function copy_file($src_path, $dst_path, $overwrite) {
 448         $this->_path = $this->translate_uri($src_path);
 449         $this->header_unset();
 450         $this->create_basic_request('COPY');
 451         $this->header_add(sprintf('Destination: http://%s%s', $this->_server, $this->translate_uri($dst_path)));
 452         if ($overwrite) {
 453             $this->header_add('Overwrite: T');
 454         } else {
 455             $this->header_add('Overwrite: F');
 456         }
 457         $this->header_add('');
 458         $this->send_request();
 459         $this->get_respond();
 460         $response = $this->process_respond();
 461         // validate the response ...
 462         // check http-version
 463         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 464             $response['status']['http-version'] == 'HTTP/1.0') {
 465          /* seems to be http ... proceed
 466              just return what server gave us (as defined in rfc 2518) :
 467              201 (Created) - The source resource was successfully copied. The copy operation resulted in the creation of a new resource.
 468              204 (No Content) - The source resource was successfully copied to a pre-existing destination resource.
 469              403 (Forbidden) - The source and destination URIs are the same.
 470              409 (Conflict) - A resource cannot be created at the destination until one or more intermediate collections have been created.
 471              412 (Precondition Failed) - The server was unable to maintain the liveness of the properties listed in the propertybehavior XML element
 472                      or the Overwrite header is "F" and the state of the destination resource is non-null.
 473              423 (Locked) - The destination resource was locked.
 474              502 (Bad Gateway) - This may occur when the destination is on another server and the destination server refuses to accept the resource.
 475              507 (Insufficient Storage) - The destination resource does not have sufficient space to record the state of the resource after the
 476                      execution of this method.
 477           */
 478                 return $response['status']['status-code'];
 479             }
 480         return false;
 481     }
 482
 483     /**
 484      * Public method copy_coll
 485      *
 486      * Copies a collection on a webdav server
 487      *
 488      * Duplicates a collection on the webdav server (serverside).
 489      * All work is done on the webdav server. If you set param overwrite as true,
 490      * the target will be overwritten.
 491      *
 492      * @param string src_path, string dest_path, bool overwrite
 493      * @return int status code (look at rfc 2518). false on error.
 494      */
 495     function copy_coll($src_path, $dst_path, $overwrite) {
 496         $this->_path = $this->translate_uri($src_path);
 497         $this->header_unset();
 498         $this->create_basic_request('COPY');
 499         $this->header_add(sprintf('Destination: http://%s%s', $this->_server, $this->translate_uri($dst_path)));
 500         $this->header_add('Depth: Infinity');
 501
 502         $xml  = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>\r\n";
 503         $xml .= "<d:propertybehavior xmlns:d=\"DAV:\">\r\n";
 504         $xml .= "  <d:keepalive>*</d:keepalive>\r\n";
 505         $xml .= "</d:propertybehavior>\r\n";
 506
 507         $this->header_add('Content-length: ' . strlen($xml));
 508         $this->header_add('Content-type: application/xml');
 509         $this->send_request();
 510         // send also xml
 511         fputs($this->sock, $xml);
 512         $this->get_respond();
 513         $response = $this->process_respond();
 514         // validate the response ...
 515         // check http-version
 516         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 517             $response['status']['http-version'] == 'HTTP/1.0') {
 518          /* seems to be http ... proceed
 519              just return what server gave us (as defined in rfc 2518) :
 520              201 (Created) - The source resource was successfully copied. The copy operation resulted in the creation of a new resource.
 521              204 (No Content) - The source resource was successfully copied to a pre-existing destination resource.
 522              403 (Forbidden) - The source and destination URIs are the same.
 523              409 (Conflict) - A resource cannot be created at the destination until one or more intermediate collections have been created.
 524              412 (Precondition Failed) - The server was unable to maintain the liveness of the properties listed in the propertybehavior XML element
 525                      or the Overwrite header is "F" and the state of the destination resource is non-null.
 526              423 (Locked) - The destination resource was locked.
 527              502 (Bad Gateway) - This may occur when the destination is on another server and the destination server refuses to accept the resource.
 528              507 (Insufficient Storage) - The destination resource does not have sufficient space to record the state of the resource after the
 529                      execution of this method.
 530           */
 531                 return $response['status']['status-code'];
 532             }
 533         return false;
 534     }
 535
 536     /**
 537      * Public method move
 538      *
 539      * Moves a file or collection on webdav server (serverside)
 540      *
 541      * If you set param overwrite as true, the target will be overwritten.
 542      *
 543      * @param string src_path, string dest_path, bool overwrite
 544      * @return int status code (look at rfc 2518). false on error.
 545      */
 546     // --------------------------------------------------------------------------
 547     // public method move
 548     // move/rename a file/collection on webdav server
 549     function move($src_path,$dst_path, $overwrite) {
 550
 551         $this->_path = $this->translate_uri($src_path);
 552         $this->header_unset();
 553
 554         $this->create_basic_request('MOVE');
 555         $this->header_add(sprintf('Destination: http://%s%s', $this->_server, $this->translate_uri($dst_path)));
 556         if ($overwrite) {
 557             $this->header_add('Overwrite: T');
 558         } else {
 559             $this->header_add('Overwrite: F');
 560         }
 561         $this->header_add('');
 562
 563         $this->send_request();
 564         $this->get_respond();
 565         $response = $this->process_respond();
 566         // validate the response ...
 567         // check http-version
 568         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 569             $response['status']['http-version'] == 'HTTP/1.0') {
 570             /* seems to be http ... proceed
 571                 just return what server gave us (as defined in rfc 2518) :
 572                 201 (Created) - The source resource was successfully moved, and a new resource was created at the destination.
 573                 204 (No Content) - The source resource was successfully moved to a pre-existing destination resource.
 574                 403 (Forbidden) - The source and destination URIs are the same.
 575                 409 (Conflict) - A resource cannot be created at the destination until one or more intermediate collections have been created.
 576                 412 (Precondition Failed) - The server was unable to maintain the liveness of the properties listed in the propertybehavior XML element
 577                          or the Overwrite header is "F" and the state of the destination resource is non-null.
 578                 423 (Locked) - The source or the destination resource was locked.
 579                 502 (Bad Gateway) - This may occur when the destination is on another server and the destination server refuses to accept the resource.
 580
 581                 201 (Created) - The collection or structured resource was created in its entirety.
 582                 403 (Forbidden) - This indicates at least one of two conditions: 1) the server does not allow the creation of collections at the given
 583                                                  location in its namespace, or 2) the parent collection of the Request-URI exists but cannot accept members.
 584                 405 (Method Not Allowed) - MKCOL can only be executed on a deleted/non-existent resource.
 585                 409 (Conflict) - A collection cannot be made at the Request-URI until one or more intermediate collections have been created.
 586                 415 (Unsupported Media Type)- The server does not support the request type of the body.
 587                 507 (Insufficient Storage) - The resource does not have sufficient space to record the state of the resource after the execution of this method.
 588              */
 589                 return $response['status']['status-code'];
 590             }
 591         return false;
 592     }
 593
 594     /**
 595      * Public method lock
 596      *
 597      * Locks a file or collection.
 598      *
 599      * Lock uses this->_user as lock owner.
 600      *
 601      * @param string path
 602      * @return int status code (look at rfc 2518). false on error.
 603      */
 604     function lock($path) {
 605         $this->_path = $this->translate_uri($path);
 606         $this->header_unset();
 607         $this->create_basic_request('LOCK');
 608         $this->header_add('Timeout: Infinite');
 609         $this->header_add('Content-type: text/xml');
 610         // create the xml request ...
 611         $xml =  "<?xml version=\"1.0\" encoding=\"utf-8\" ?>\r\n";
 612         $xml .= "<D:lockinfo xmlns:D='DAV:'\r\n>";
 613         $xml .= "  <D:lockscope><D:exclusive/></D:lockscope>\r\n";
 614         $xml .= "  <D:locktype><D:write/></D:locktype>\r\n";
 615         $xml .= "  <D:owner>\r\n";
 616         $xml .= "    <D:href>".($this->_user)."</D:href>\r\n";
 617         $xml .= "  </D:owner>\r\n";
 618         $xml .= "</D:lockinfo>\r\n";
 619         $this->header_add('Content-length: ' . strlen($xml));
 620         $this->send_request();
 621         // send also xml
 622         fputs($this->sock, $xml);
 623         $this->get_respond();
 624         $response = $this->process_respond();
 625         // validate the response ... (only basic validation)
 626         // check http-version
 627         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 628             $response['status']['http-version'] == 'HTTP/1.0') {
 629             /* seems to be http ... proceed
 630             rfc 2518 says:
 631             200 (OK) - The lock request succeeded and the value of the lockdiscovery property is included in the body.
 632             412 (Precondition Failed) - The included lock token was not enforceable on this resource or the server could not satisfy the
 633                      request in the lockinfo XML element.
 634             423 (Locked) - The resource is locked, so the method has been rejected.
 635              */
 636
 637                 switch($response['status']['status-code']) {
 638                 case 200:
 639                     // collection was successfully locked... see xml response to get lock token...
 640                     if (strcmp($response['header']['Content-Type'], 'text/xml; charset="utf-8"') == 0) {
 641                         // ok let's get the content of the xml stuff
 642                         $this->_parser = xml_parser_create_ns();
 643                         $this->_parserid = (int) $this->_parser;
 644                         // forget old data...
 645                         unset($this->_lock[$this->_parserid]);
 646                         unset($this->_xmltree[$this->_parserid]);
 647                         xml_parser_set_option($this->_parser,XML_OPTION_SKIP_WHITE,0);
 648                         xml_parser_set_option($this->_parser,XML_OPTION_CASE_FOLDING,0);
 649                         xml_set_object($this->_parser, $this);
 650                         xml_set_element_handler($this->_parser, "_lock_startElement", "_endElement");
 651                         xml_set_character_data_handler($this->_parser, "_lock_cdata");
 652
 653                         if (!xml_parse($this->_parser, $response['body'])) {
 654                             die(sprintf("XML error: %s at line %d",
 655                                 xml_error_string(xml_get_error_code($this->_parser)),
 656                                 xml_get_current_line_number($this->_parser)));
 657                         }
 658
 659                         // Free resources
 660                         xml_parser_free($this->_parser);
 661                         // add status code to array
 662                         $this->_lock[$this->_parserid]['status'] = 200;
 663                         return $this->_lock[$this->_parserid];
 664
 665                     } else {
 666                         print 'Missing Content-Type: text/xml header in response.<br>';
 667                     }
 668                     return false;
 669
 670                 default:
 671                     // hmm. not what we expected. Just return what we got from webdav server
 672                     // someone else has to handle it.
 673                     $this->_lock['status'] = $response['status']['status-code'];
 674                     return $this->_lock;
 675                 }
 676             }
 677
 678
 679     }
 680
 681
 682     /**
 683      * Public method unlock
 684      *
 685      * Unlocks a file or collection.
 686      *
 687      * @param string path, string locktoken
 688      * @return int status code (look at rfc 2518). false on error.
 689      */
 690     function unlock($path, $locktoken) {
 691         $this->_path = $this->translate_uri($path);
 692         $this->header_unset();
 693         $this->create_basic_request('UNLOCK');
 694         $this->header_add(sprintf('Lock-Token: <%s>', $locktoken));
 695         $this->send_request();
 696         $this->get_respond();
 697         $response = $this->process_respond();
 698         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 699             $response['status']['http-version'] == 'HTTP/1.0') {
 700             /* seems to be http ... proceed
 701             rfc 2518 says:
 702             204 (OK) - The 204 (No Content) status code is used instead of 200 (OK) because there is no response entity body.
 703              */
 704                 return $response['status']['status-code'];
 705             }
 706         return false;
 707     }
 708
 709     /**
 710      * Public method delete
 711      *
 712      * deletes a collection/directory on a webdav server
 713      * @param string path
 714      * @return int status code (look at rfc 2518). false on error.
 715      */
 716     function delete($path) {
 717         $this->_path = $this->translate_uri($path);
 718         $this->header_unset();
 719         $this->create_basic_request('DELETE');
 720         /* $this->header_add('Content-Length: 0'); */
 721         $this->header_add('');
 722         $this->send_request();
 723         $this->get_respond();
 724         $response = $this->process_respond();
 725
 726         // validate the response ...
 727         // check http-version
 728         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 729             $response['status']['http-version'] == 'HTTP/1.0') {
 730                 // seems to be http ... proceed
 731                 // We expect a 207 Multi-Status status code
 732                 // print 'http ok<br>';
 733
 734                 switch ($response['status']['status-code']) {
 735                 case 207:
 736                     // collection was NOT deleted... see xml response for reason...
 737                     // next there should be a Content-Type: text/xml; charset="utf-8" header line
 738                     if (strcmp($response['header']['Content-Type'], 'text/xml; charset="utf-8"') == 0) {
 739                         // ok let's get the content of the xml stuff
 740                         $this->_parser = xml_parser_create_ns();
 741                         $this->_parserid = (int) $this->_parser;
 742                         // forget old data...
 743                         unset($this->_delete[$this->_parserid]);
 744                         unset($this->_xmltree[$this->_parserid]);
 745                         xml_parser_set_option($this->_parser,XML_OPTION_SKIP_WHITE,0);
 746                         xml_parser_set_option($this->_parser,XML_OPTION_CASE_FOLDING,0);
 747                         xml_set_object($this->_parser, $this);
 748                         xml_set_element_handler($this->_parser, "_delete_startElement", "_endElement");
 749                         xml_set_character_data_handler($this->_parser, "_delete_cdata");
 750
 751                         if (!xml_parse($this->_parser, $response['body'])) {
 752                             die(sprintf("XML error: %s at line %d",
 753                                 xml_error_string(xml_get_error_code($this->_parser)),
 754                                 xml_get_current_line_number($this->_parser)));
 755                         }
 756
 757                         print "<br>";
 758
 759                         // Free resources
 760                         xml_parser_free($this->_parser);
 761                         $this->_delete[$this->_parserid]['status'] = $response['status']['status-code'];
 762                         return $this->_delete[$this->_parserid];
 763
 764                     } else {
 765                         print 'Missing Content-Type: text/xml header in response.<br>';
 766                     }
 767                     return false;
 768
 769                 default:
 770                     // collection or file was successfully deleted
 771                     $this->_delete['status'] = $response['status']['status-code'];
 772                     return $this->_delete;
 773
 774
 775                 }
 776             }
 777
 778     }
 779
 780     /**
 781      * Public method ls
 782      *
 783      * Get's directory information from webdav server into flat a array using PROPFIND
 784      *
 785      * All filenames are UTF-8 encoded.
 786      * Have a look at _propfind_startElement what keys are used in array returned.
 787      * @param string path
 788      * @return array dirinfo, false on error
 789      */
 790     function ls($path) {
 791
 792         if (trim($path) == '') {
 793             $this->_error_log('Missing a path in method ls');
 794             return false;
 795         }
 796         $this->_path = $this->translate_uri($path);
 797
 798         $this->header_unset();
 799         $this->create_basic_request('PROPFIND');
 800         $this->header_add('Depth: 1');
 801         $this->header_add('Content-type: application/xml');
 802         // create profind xml request...
 803         $xml  = <<<EOD
 804 <?xml version="1.0" encoding="utf-8"?>
 805 <propfind xmlns="DAV:"><prop>
 806 <getcontentlength xmlns="DAV:"/>
 807 <getlastmodified xmlns="DAV:"/>
 808 <executable xmlns="http://apache.org/dav/props/"/>
 809 <resourcetype xmlns="DAV:"/>
 810 <checked-in xmlns="DAV:"/>
 811 <checked-out xmlns="DAV:"/>
 812 </prop></propfind>
 813 EOD;
 814         $this->header_add('Content-length: ' . strlen($xml));
 815         $this->send_request();
 816         $this->_error_log($xml);
 817         fputs($this->sock, $xml);
 818         $this->get_respond();
 819         $response = $this->process_respond();
 820         // validate the response ... (only basic validation)
 821         // check http-version
 822         if ($response['status']['http-version'] == 'HTTP/1.1' ||
 823             $response['status']['http-version'] == 'HTTP/1.0') {
 824                 // seems to be http ... proceed
 825                 // We expect a 207 Multi-Status status code
 826                 // print 'http ok<br>';
 827                 if (strcmp($response['status']['status-code'],'207') == 0 ) {
 828                     // ok so far
 829                     // next there should be a Content-Type: text/xml; charset="utf-8" header line
 830                     if (preg_match('#(application|text)/xml;\s?charset=[\'\"]?utf-8[\'\"]?#i', $response['header']['Content-Type'])) {
 831                         // ok let's get the content of the xml stuff
 832                         $this->_parser = xml_parser_create_ns('UTF-8');
 833                         $this->_parserid = (int) $this->_parser;
 834                         // forget old data...
 835                         unset($this->_ls[$this->_parserid]);
 836                         unset($this->_xmltree[$this->_parserid]);
 837                         xml_parser_set_option($this->_parser,XML_OPTION_SKIP_WHITE,0);
 838                         xml_parser_set_option($this->_parser,XML_OPTION_CASE_FOLDING,0);
 839                         // xml_parser_set_option($this->_parser,XML_OPTION_TARGET_ENCODING,'UTF-8');
 840                         xml_set_object($this->_parser, $this);
 841                         xml_set_element_handler($this->_parser, "_propfind_startElement", "_endElement");
 842                         xml_set_character_data_handler($this->_parser, "_propfind_cdata");
 843
 844
 845                         if (!xml_parse($this->_parser, $response['body'])) {
 846                             die(sprintf("XML error: %s at line %d",
 847                                 xml_error_string(xml_get_error_code($this->_parser)),
 848                                 xml_get_current_line_number($this->_parser)));
 849                         }
 850
 851                         // Free resources
 852                         xml_parser_free($this->_parser);
 853                         $arr = $this->_ls[$this->_parserid];
 854                         return $arr;
 855                     } else {
 856                         $this->_error_log('Missing Content-Type: text/xml header in response!!');
 857                         return false;
 858                     }
 859                 } else {
 860                     // return status code ...
 861                     return $response['status']['status-code'];
 862                 }
 863             }
 864
 865         // response was not http
 866         $this->_error_log('Ups in method ls: error in response from server');
 867         return false;
 868     }
 869
 870
 871     /**
 872      * Public method gpi
 873      *
 874      * Get's path information from webdav server for one element.
 875      *
 876      * @param string path
 877      * @return array dirinfo. false on error
 878      */
 879     function gpi($path) {
 880
 881         // split path by last "/"
 882         $path = rtrim($path, "/");
 883         $item = basename($path);
 884         $dir  = dirname($path);
 885
 886         $list = $this->ls($dir);
 887
 888         // be sure it is an array
 889         if (is_array($list)) {
 890             foreach($list as $e) {
 891
 892                 $fullpath = urldecode($e['href']);
 893                 $filename = basename($fullpath);
 894
 895                 if ($filename == $item && $filename != "" and $fullpath != $dir."/") {
 896                     return $e;
 897                 }
 898             }
 899         }
 900         return false;
 901     }
 902
 903     /**
 904      * Public method is_file
 905      *
 906      * Gathers whether a path points to a file or not.
 907      *
 908      * @param string path
 909      * @return bool true or false
 910      */
 911     function is_file($path) {
 912
 913         $item = $this->gpi($path);
 914
 915         if ($item === false) {
 916             return false;
 917         } else {
 918             return ($item['resourcetype'] != 'collection');
 919         }
 920     }
 921
 922     /**
 923      * Public method is_dir
 924      *
 925      * Gather whether a path points to a directory
 926      * @param string path
 927      * return bool true or false
 928      */
 929     function is_dir($path) {
 930
 931         // be sure path is utf-8
 932         $item = $this->gpi($path);
 933
 934         if ($item === false) {
 935             return false;
 936         } else {
 937             return ($item['resourcetype'] == 'collection');
 938         }
 939     }
 940
 941
 942     /**
 943      * Public method mput
 944      *
 945      * Puts multiple files and/or directories onto a webdav server.
 946      *
 947      * Filenames should be allready UTF-8 encoded.
 948      * Param fileList must be in format array("localpath" => "destpath").
 949      *
 950      * @param array filelist
 951      * @return bool true on success. otherwise int status code on error
 952      */
 953     function mput($filelist) {
 954
 955         $result = true;
 956
 957         foreach ($filelist as $localpath => $destpath) {
 958
 959             $localpath = rtrim($localpath, "/");
 960             $destpath  = rtrim($destpath, "/");
 961
 962             // attempt to create target path
 963             if (is_dir($localpath)) {
 964                 $pathparts = explode("/", $destpath."/ "); // add one level, last level will be created as dir
 965             } else {
 966                 $pathparts = explode("/", $destpath);
 967             }
 968             $checkpath = "";
 969             for ($i=1; $i<sizeof($pathparts)-1; $i++) {
 970                 $checkpath .= "/" . $pathparts[$i];
 971                 if (!($this->is_dir($checkpath))) {
 972
 973                     $result &= ($this->mkcol($checkpath) == 201 );
 974                 }
 975             }
 976
 977             if ($result) {
 978                 // recurse directories
 979                 if (is_dir($localpath)) {
 980                     if (!$dp = opendir($localpath)) {
 981                         $this->_error_log("Could not open localpath for reading");
 982                         return false;
 983                     }
 984                     $fl = array();
 985                     while($filename = readdir($dp)) {
 986                         if ((is_file($localpath."/".$filename) || is_dir($localpath."/".$filename)) && $filename!="." && $filename != "..") {
 987                             $fl[$localpath."/".$filename] = $destpath."/".$filename;
 988                         }
 989                     }
 990                     $result &= $this->mput($fl);
 991                 } else {
 992                     $result &= ($this->put_file($destpath, $localpath) == 201);
 993                 }
 994             }
 995         }
 996         return $result;
 997     }
 998
 999     /**
1000      * Public method mget
1001      *
1002      * Gets multiple files and directories.
1003      *
1004      * FileList must be in format array("remotepath" => "localpath").
1005      * Filenames are UTF-8 encoded.
1006      *
1007      * @param array filelist
1008      * @return bool true on succes, other int status code on error
1009      */
1010     function mget($filelist) {
1011
1012         $result = true;
1013
1014         foreach ($filelist as $remotepath => $localpath) {
1015
1016             $localpath   = rtrim($localpath, "/");
1017             $remotepath  = rtrim($remotepath, "/");
1018
1019             // attempt to create local path
1020             if ($this->is_dir($remotepath)) {
1021                 $pathparts = explode("/", $localpath."/ "); // add one level, last level will be created as dir
1022             } else {
1023                 $pathparts = explode("/", $localpath);
1024             }
1025             $checkpath = "";
1026             for ($i=1; $i<sizeof($pathparts)-1; $i++) {
1027                 $checkpath .= "/" . $pathparts[$i];
1028                 if (!is_dir($checkpath)) {
1029
1030                     $result &= mkdir($checkpath);
1031                 }
1032             }
1033
1034             if ($result) {
1035                 // recurse directories
1036                 if ($this->is_dir($remotepath)) {
1037                     $list = $this->ls($remotepath);
1038
1039                     $fl = array();
1040                     foreach($list as $e) {
1041                         $fullpath = urldecode($e['href']);
1042                         $filename = basename($fullpath);
1043                         if ($filename != '' and $fullpath != $remotepath . '/') {
1044                             $fl[$remotepath."/".$filename] = $localpath."/".$filename;
1045                         }
1046                     }
1047                     $result &= $this->mget($fl);
1048                 } else {
1049                     $result &= ($this->get_file($remotepath, $localpath));
1050                 }
1051             }
1052         }
1053         return $result;
1054     }
1055
1056     // --------------------------------------------------------------------------
1057     // private xml callback and helper functions starting here
1058     // --------------------------------------------------------------------------
1059
1060
1061     /**
1062      * Private method _endelement
1063      *
1064      * a generic endElement method  (used for all xml callbacks).
1065      *
1066      * @param resource parser, string name
1067      * @access private
1068      */
1069
1070     private function _endElement($parser, $name) {
1071         // end tag was found...
1072         $parserid = (int) $parser;
1073         $this->_xmltree[$parserid] = substr($this->_xmltree[$parserid],0, strlen($this->_xmltree[$parserid]) - (strlen($name) + 1));
1074     }
1075
1076     /**
1077      * Private method _propfind_startElement
1078      *
1079      * Is needed by public method ls.
1080      *
1081      * Generic method will called by php xml_parse when a xml start element tag has been detected.
1082      * The xml tree will translated into a flat php array for easier access.
1083      * @param resource parser, string name, string attrs
1084      * @access private
1085      */
1086     private function _propfind_startElement($parser, $name, $attrs) {
1087         // lower XML Names... maybe break a RFC, don't know ...
1088         $parserid = (int) $parser;
1089
1090         $propname = strtolower($name);
1091         if (!empty($this->_xmltree[$parserid])) {
1092             $this->_xmltree[$parserid] .= $propname . '_';
1093         } else {
1094             $this->_xmltree[$parserid] = $propname . '_';
1095         }
1096
1097         // translate xml tree to a flat array ...
1098         switch($this->_xmltree[$parserid]) {
1099         case 'dav::multistatus_dav::response_':
1100             // new element in mu
1101             $this->_ls_ref =& $this->_ls[$parserid][];
1102             break;
1103         case 'dav::multistatus_dav::response_dav::href_':
1104             $this->_ls_ref_cdata = &$this->_ls_ref['href'];
1105             break;
1106         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::creationdate_':
1107             $this->_ls_ref_cdata = &$this->_ls_ref['creationdate'];
1108             break;
1109         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::getlastmodified_':
1110             $this->_ls_ref_cdata = &$this->_ls_ref['lastmodified'];
1111             break;
1112         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::getcontenttype_':
1113             $this->_ls_ref_cdata = &$this->_ls_ref['getcontenttype'];
1114             break;
1115         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::getcontentlength_':
1116             $this->_ls_ref_cdata = &$this->_ls_ref['getcontentlength'];
1117             break;
1118         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::depth_':
1119             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_depth'];
1120             break;
1121         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::owner_dav::href_':
1122             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_owner'];
1123             break;
1124         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::owner_':
1125             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_owner'];
1126             break;
1127         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::timeout_':
1128             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_timeout'];
1129             break;
1130         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::locktoken_dav::href_':
1131             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_token'];
1132             break;
1133         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::lockdiscovery_dav::activelock_dav::locktype_dav::write_':
1134             $this->_ls_ref_cdata = &$this->_ls_ref['activelock_type'];
1135             $this->_ls_ref_cdata = 'write';
1136             $this->_ls_ref_cdata = &$this->_null;
1137             break;
1138         case 'dav::multistatus_dav::response_dav::propstat_dav::prop_dav::resourcetype_dav::collection_':
1139             $this->_ls_ref_cdata = &$this->_ls_ref['resourcetype'];
1140             $this->_ls_ref_cdata = 'collection';
1141             $this->_ls_ref_cdata = &$this->_null;
1142             break;
1143         case 'dav::multistatus_dav::response_dav::propstat_dav::status_':
1144             $this->_ls_ref_cdata = &$this->_ls_ref['status'];
1145             break;
1146
1147         default:
1148             // handle unknown xml elements...
1149             $this->_ls_ref_cdata = &$this->_ls_ref[$this->_xmltree[$parserid]];
1150         }
1151     }
1152
1153     /**
1154      * Private method _propfind_cData
1155      *
1156      * Is needed by public method ls.
1157      *
1158      * Will be called by php xml_set_character_data_handler() when xml data has to be handled.
1159      * Stores data found into class var _ls_ref_cdata
1160      * @param resource parser, string cdata
1161      * @access private
1162      */
1163     private function _propfind_cData($parser, $cdata) {
1164         if (trim($cdata) <> '') {
1165             // cdata must be appended, because sometimes the php xml parser makes multiple calls
1166             // to _propfind_cData before the xml end tag was reached...
1167             $this->_ls_ref_cdata .= $cdata;
1168         } else {
1169             // do nothing
1170         }
1171     }
1172
1173     /**
1174      * Private method _delete_startElement
1175      *
1176      * Is used by public method delete.
1177      *
1178      * Will be called by php xml_parse.
1179      * @param resource parser, string name, string attrs)
1180      * @access private
1181      */
1182     private function _delete_startElement($parser, $name, $attrs) {
1183         // lower XML Names... maybe break a RFC, don't know ...
1184         $parserid = (int) $parser;
1185         $propname = strtolower($name);
1186         $this->_xmltree[$parserid] .= $propname . '_';
1187
1188         // translate xml tree to a flat array ...
1189         switch($this->_xmltree[$parserid]) {
1190         case 'dav::multistatus_dav::response_':
1191             // new element in mu
1192             $this->_delete_ref =& $this->_delete[$parserid][];
1193             break;
1194         case 'dav::multistatus_dav::response_dav::href_':
1195             $this->_delete_ref_cdata = &$this->_ls_ref['href'];
1196             break;
1197
1198         default:
1199             // handle unknown xml elements...
1200             $this->_delete_cdata = &$this->_delete_ref[$this->_xmltree[$parserid]];
1201         }
1202     }
1203
1204
1205     /**
1206      * Private method _delete_cData
1207      *
1208      * Is used by public method delete.
1209      *
1210      * Will be called by php xml_set_character_data_handler() when xml data has to be handled.
1211      * Stores data found into class var _delete_ref_cdata
1212      * @param resource parser, string cdata
1213      * @access private
1214      */
1215     private function _delete_cData($parser, $cdata) {
1216         if (trim($cdata) <> '') {
1217             $this->_delete_ref_cdata .= $cdata;
1218         } else {
1219             // do nothing
1220         }
1221     }
1222
1223
1224     /**
1225      * Private method _lock_startElement
1226      *
1227      * Is needed by public method lock.
1228      *
1229      * Mmethod will called by php xml_parse when a xml start element tag has been detected.
1230      * The xml tree will translated into a flat php array for easier access.
1231      * @param resource parser, string name, string attrs
1232      * @access private
1233      */
1234     private function _lock_startElement($parser, $name, $attrs) {
1235         // lower XML Names... maybe break a RFC, don't know ...
1236         $parserid = (int) $parser;
1237         $propname = strtolower($name);
1238         $this->_xmltree[$parserid] .= $propname . '_';
1239
1240         // translate xml tree to a flat array ...
1241         /*
1242         dav::prop_dav::lockdiscovery_dav::activelock_dav::depth_=
1243         dav::prop_dav::lockdiscovery_dav::activelock_dav::owner_dav::href_=
1244         dav::prop_dav::lockdiscovery_dav::activelock_dav::timeout_=
1245         dav::prop_dav::lockdiscovery_dav::activelock_dav::locktoken_dav::href_=
1246          */
1247         switch($this->_xmltree[$parserid]) {
1248         case 'dav::prop_dav::lockdiscovery_dav::activelock_':
1249             // new element
1250             $this->_lock_ref =& $this->_lock[$parserid][];
1251             break;
1252         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::locktype_dav::write_':
1253             $this->_lock_ref_cdata = &$this->_lock_ref['locktype'];
1254             $this->_lock_cdata = 'write';
1255             $this->_lock_cdata = &$this->_null;
1256             break;
1257         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::lockscope_dav::exclusive_':
1258             $this->_lock_ref_cdata = &$this->_lock_ref['lockscope'];
1259             $this->_lock_ref_cdata = 'exclusive';
1260             $this->_lock_ref_cdata = &$this->_null;
1261             break;
1262         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::depth_':
1263             $this->_lock_ref_cdata = &$this->_lock_ref['depth'];
1264             break;
1265         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::owner_dav::href_':
1266             $this->_lock_ref_cdata = &$this->_lock_ref['owner'];
1267             break;
1268         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::timeout_':
1269             $this->_lock_ref_cdata = &$this->_lock_ref['timeout'];
1270             break;
1271         case 'dav::prop_dav::lockdiscovery_dav::activelock_dav::locktoken_dav::href_':
1272             $this->_lock_ref_cdata = &$this->_lock_ref['locktoken'];
1273             break;
1274         default:
1275             // handle unknown xml elements...
1276             $this->_lock_cdata = &$this->_lock_ref[$this->_xmltree[$parserid]];
1277
1278         }
1279     }
1280
1281     /**
1282      * Private method _lock_cData
1283      *
1284      * Is used by public method lock.
1285      *
1286      * Will be called by php xml_set_character_data_handler() when xml data has to be handled.
1287      * Stores data found into class var _lock_ref_cdata
1288      * @param resource parser, string cdata
1289      * @access private
1290      */
1291     private function _lock_cData($parser, $cdata) {
1292         $parserid = (int) $parser;
1293         if (trim($cdata) <> '') {
1294             // $this->_error_log(($this->_xmltree[$parserid]) . '='. htmlentities($cdata));
1295             $this->_lock_ref_cdata .= $cdata;
1296         } else {
1297             // do nothing
1298         }
1299     }
1300
1301
1302     /**
1303      * Private method header_add
1304      *
1305      * extends class var array _req
1306      * @param string string
1307      * @access private
1308      */
1309     private function header_add($string) {
1310         $this->_req[] = $string;
1311     }
1312
1313     /**
1314      * Private method header_unset
1315      *
1316      * unsets class var array _req
1317      * @access private
1318      */
1319
1320     private function header_unset() {
1321         unset($this->_req);
1322     }
1323
1324     /**
1325      * Private method create_basic_request
1326      *
1327      * creates by using private method header_add an general request header.
1328      * @param string method
1329      * @access private
1330      */
1331     private function create_basic_request($method) {
1332         $this->header_add(sprintf('%s %s %s', $method, $this->_path, $this->_protocol));
1333         $this->header_add(sprintf('Host: %s:%s', $this->_server, $this->_port));
1334         //$request .= sprintf('Connection: Keep-Alive');
1335         $this->header_add(sprintf('User-Agent: %s', $this->_user_agent));
1336         $this->header_add('Connection: TE');
1337         $this->header_add('TE: Trailers');
1338         if ($this->_auth == 'basic') {
1339             $this->header_add(sprintf('Authorization: Basic %s', base64_encode("$this->_user:$this->_pass")));
1340         } else if ($this->_auth == 'digest') {
1341             if ($signature = $this->digest_signature($method)){
1342                 $this->header_add($signature);
1343             }
1344         } else if ($this->_auth == 'bearer') {
1345             $this->header_add(sprintf('Authorization: Bearer %s', $this->oauthtoken));
1346         }
1347     }
1348
1349     /**
1350      * Reads the header, stores the challenge information
1351      *
1352      * @return void
1353      */
1354     private function digest_auth() {
1355
1356         $headers = array();
1357         $headers[] = sprintf('%s %s %s', 'HEAD', $this->_path, $this->_protocol);
1358         $headers[] = sprintf('Host: %s:%s', $this->_server, $this->_port);
1359         $headers[] = sprintf('User-Agent: %s', $this->_user_agent);
1360         $headers = implode("\r\n", $headers);
1361         $headers .= "\r\n\r\n";
1362         fputs($this->sock, $headers);
1363
1364         // Reads the headers.
1365         $i = 0;
1366         $header = '';
1367         do {
1368             $header .= fread($this->sock, 1);
1369             $i++;
1370         } while (!preg_match('/\\r\\n\\r\\n$/', $header, $matches) && $i < $this->_maxheaderlenth);
1371
1372         // Analyse the headers.
1373         $digest = array();
1374         $splitheaders = explode("\r\n", $header);
1375         foreach ($splitheaders as $line) {
1376             if (!preg_match('/^WWW-Authenticate: Digest/', $line)) {
1377                 continue;
1378             }
1379             $line = substr($line, strlen('WWW-Authenticate: Digest '));
1380             $params = explode(',', $line);
1381             foreach ($params as $param) {
1382                 list($key, $value) = explode('=', trim($param), 2);
1383                 $digest[$key] = trim($value, '"');
1384             }
1385             break;
1386         }
1387
1388         $this->_digestchallenge = $digest;
1389     }
1390
1391     /**
1392      * Generates the digest signature
1393      *
1394      * @return string signature to add to the headers
1395      * @access private
1396      */
1397     private function digest_signature($method) {
1398         if (!$this->_digestchallenge) {
1399             $this->digest_auth();
1400         }
1401
1402         $signature = array();
1403         $signature['username'] = '"' . $this->_user . '"';
1404         $signature['realm'] = '"' . $this->_digestchallenge['realm'] . '"';
1405         $signature['nonce'] = '"' . $this->_digestchallenge['nonce'] . '"';
1406         $signature['uri'] = '"' . $this->_path . '"';
1407
1408         if (isset($this->_digestchallenge['algorithm']) && $this->_digestchallenge['algorithm'] != 'MD5') {
1409             $this->_error_log('Algorithm other than MD5 are not supported');
1410             return false;
1411         }
1412
1413         $a1 = $this->_user . ':' . $this->_digestchallenge['realm'] . ':' . $this->_pass;
1414         $a2 = $method . ':' . $this->_path;
1415
1416         if (!isset($this->_digestchallenge['qop'])) {
1417             $signature['response'] = '"' . md5(md5($a1) . ':' . $this->_digestchallenge['nonce'] . ':' . md5($a2)) . '"';
1418         } else {
1419             // Assume QOP is auth
1420             if (empty($this->_cnonce)) {
1421                 $this->_cnonce = random_string();
1422                 $this->_nc = 0;
1423             }
1424             $this->_nc++;
1425             $nc = sprintf('%08d', $this->_nc);
1426             $signature['cnonce'] = '"' . $this->_cnonce . '"';
1427             $signature['nc'] = '"' . $nc . '"';
1428             $signature['qop'] = '"' . $this->_digestchallenge['qop'] . '"';
1429             $signature['response'] = '"' . md5(md5($a1) . ':' . $this->_digestchallenge['nonce'] . ':' .
1430                     $nc . ':' . $this->_cnonce . ':' . $this->_digestchallenge['qop'] . ':' . md5($a2)) . '"';
1431         }
1432
1433         $response = array();
1434         foreach ($signature as $key => $value) {
1435             $response[] = "$key=$value";
1436         }
1437         return 'Authorization: Digest ' . implode(', ', $response);
1438     }
1439
1440     /**
1441      * Private method send_request
1442      *
1443      * Sends a ready formed http/webdav request to webdav server.
1444      *
1445      * @access private
1446      */
1447     private function send_request() {
1448         // check if stream is declared to be open
1449         // only logical check we are not sure if socket is really still open ...
1450         if ($this->_connection_closed) {
1451             // reopen it
1452             // be sure to close the open socket.
1453             $this->close();
1454             $this->reopen();
1455         }
1456
1457         // convert array to string
1458         $buffer = implode("\r\n", $this->_req);
1459         $buffer .= "\r\n\r\n";
1460         $this->_error_log($buffer);
1461         fputs($this->sock, $buffer);
1462     }
1463
1464     /**
1465      * Private method get_respond
1466      *
1467      * Reads the response from the webdav server.
1468      *
1469      * Stores data into class vars _header for the header data and
1470      * _body for the rest of the response.
1471      * This routine is the weakest part of this class, because it very depends how php does handle a socket stream.
1472      * If the stream is blocked for some reason php is blocked as well.
1473      * @access private
1474      * @param resource $fp optional the file handle to write the body content to (stored internally in the '_body' if not set)
1475      */
1476     private function get_respond($fp = null) {
1477         $this->_error_log('get_respond()');
1478         // init vars (good coding style ;-)
1479         $buffer = '';
1480         $header = '';
1481         // attention: do not make max_chunk_size to big....
1482         $max_chunk_size = 8192;
1483         // be sure we got a open ressource
1484         if (! $this->sock) {
1485             $this->_error_log('socket is not open. Can not process response');
1486             return false;
1487         }
1488
1489         // following code maybe helps to improve socket behaviour ... more testing needed
1490         // disabled at the moment ...
1491         // socket_set_timeout($this->sock,1 );
1492         // $socket_state = socket_get_status($this->sock);
1493
1494         // read stream one byte by another until http header ends
1495         $i = 0;
1496         $matches = array();
1497         do {
1498             $header.=fread($this->sock, 1);
1499             $i++;
1500         } while (!preg_match('/\\r\\n\\r\\n$/',$header, $matches) && $i < $this->_maxheaderlenth);
1501
1502         $this->_error_log($header);
1503
1504         if (preg_match('/Connection: close\\r\\n/', $header)) {
1505             // This says that the server will close connection at the end of this stream.
1506             // Therefore we need to reopen the socket, before are sending the next request...
1507             $this->_error_log('Connection: close found');
1508             $this->_connection_closed = true;
1509         } else if (preg_match('@^HTTP/1\.(1|0) 401 @', $header)) {
1510             $this->_error_log('The server requires an authentication');
1511         }
1512
1513         // check how to get the data on socket stream
1514         // chunked or content-length (HTTP/1.1) or
1515         // one block until feof is received (HTTP/1.0)
1516         switch(true) {
1517         case (preg_match('/Transfer\\-Encoding:\\s+chunked\\r\\n/',$header)):
1518             $this->_error_log('Getting HTTP/1.1 chunked data...');
1519             do {
1520                 $byte = '';
1521                 $chunk_size='';
1522                 do {
1523                     $chunk_size.=$byte;
1524                     $byte=fread($this->sock,1);
1525                     // check what happens while reading, because I do not really understand how php reads the socketstream...
1526                     // but so far - it seems to work here - tested with php v4.3.1 on apache 1.3.27 and Debian Linux 3.0 ...
1527                     if (strlen($byte) == 0) {
1528                         $this->_error_log('get_respond: warning --> read zero bytes');
1529                     }
1530                 } while ($byte!="\r" and strlen($byte)>0);      // till we match the Carriage Return
1531                 fread($this->sock, 1);                           // also drop off the Line Feed
1532                 $chunk_size=hexdec($chunk_size);                // convert to a number in decimal system
1533                 if ($chunk_size > 0) {
1534                     $read = 0;
1535                     // Reading the chunk in one bite is not secure, we read it byte by byte.
1536                     while ($read < $chunk_size) {
1537                         $chunk = fread($this->sock, 1);
1538                         self::update_file_or_buffer($chunk, $fp, $buffer);
1539                         $read++;
1540                     }
1541                 }
1542                 fread($this->sock, 2);                            // ditch the CRLF that trails the chunk
1543             } while ($chunk_size);                            // till we reach the 0 length chunk (end marker)
1544             break;
1545
1546             // check for a specified content-length
1547         case preg_match('/Content\\-Length:\\s+([0-9]*)\\r\\n/',$header,$matches):
1548             $this->_error_log('Getting data using Content-Length '. $matches[1]);
1549
1550             // check if we the content data size is small enough to get it as one block
1551             if ($matches[1] <= $max_chunk_size ) {
1552                 // only read something if Content-Length is bigger than 0
1553                 if ($matches[1] > 0 ) {
1554                     $chunk = fread($this->sock, $matches[1]);
1555                     $loadsize = strlen($chunk);
1556                     //did we realy get the full length?
1557                     if ($loadsize < $matches[1]) {
1558                         $max_chunk_size = $loadsize;
1559                         do {
1560                             $mod = $max_chunk_size % ($matches[1] - strlen($chunk));
1561                             $chunk_size = ($mod == $max_chunk_size ? $max_chunk_size : $matches[1] - strlen($chunk));
1562                             $chunk .= fread($this->sock, $chunk_size);
1563                             $this->_error_log('mod: ' . $mod . ' chunk: ' . $chunk_size . ' total: ' . strlen($chunk));
1564                         } while (strlen($chunk) < $matches[1]);
1565                     }
1566                     self::update_file_or_buffer($chunk, $fp, $buffer);
1567                     break;
1568                 } else {
1569                     $buffer = '';
1570                     break;
1571                 }
1572             }
1573
1574             // data is to big to handle it as one. Get it chunk per chunk...
1575             //trying to get the full length of max_chunk_size
1576             $chunk = fread($this->sock, $max_chunk_size);
1577             $loadsize = strlen($chunk);
1578             self::update_file_or_buffer($chunk, $fp, $buffer);
1579             if ($loadsize < $max_chunk_size) {
1580                 $max_chunk_size = $loadsize;
1581             }
1582             do {
1583                 $mod = $max_chunk_size % ($matches[1] - $loadsize);
1584                 $chunk_size = ($mod == $max_chunk_size ? $max_chunk_size : $matches[1] - $loadsize);
1585                 $chunk = fread($this->sock, $chunk_size);
1586                 self::update_file_or_buffer($chunk, $fp, $buffer);
1587                 $loadsize += strlen($chunk);
1588                 $this->_error_log('mod: ' . $mod . ' chunk: ' . $chunk_size . ' total: ' . $loadsize);
1589             } while ($matches[1] > $loadsize);
1590             break;
1591
1592             // check for 204 No Content
1593             // 204 responds have no body.
1594             // Therefore we do not need to read any data from socket stream.
1595         case preg_match('/HTTP\/1\.1\ 204/',$header):
1596             // nothing to do, just proceed
1597             $this->_error_log('204 No Content found. No further data to read..');
1598             break;
1599         default:
1600             // just get the data until foef appears...
1601             $this->_error_log('reading until feof...' . $header);
1602             socket_set_timeout($this->sock, 0, 0);
1603             while (!feof($this->sock)) {
1604                 $chunk = fread($this->sock, 4096);
1605                 self::update_file_or_buffer($chunk, $fp, $buffer);
1606             }
1607             // renew the socket timeout...does it do something ???? Is it needed. More debugging needed...
1608             socket_set_timeout($this->sock, $this->_socket_timeout, 0);
1609         }
1610
1611         $this->_header = $header;
1612         $this->_body = $buffer;
1613         // $this->_buffer = $header . "\r\n\r\n" . $buffer;
1614         $this->_error_log($this->_header);
1615         $this->_error_log($this->_body);
1616
1617     }
1618
1619     /**
1620      * Write the chunk to the file if $fp is set, otherwise append the data to the buffer
1621      * @param string $chunk the data to add
1622      * @param resource $fp the file handle to write to (or null)
1623      * @param string &$buffer the buffer to append to (if $fp is null)
1624      */
1625     static private function update_file_or_buffer($chunk, $fp, &$buffer) {
1626         if ($fp) {
1627             fwrite($fp, $chunk);
1628         } else {
1629             $buffer .= $chunk;
1630         }
1631     }
1632
1633     /**
1634      * Private method process_respond
1635      *
1636      * Processes the webdav server respond and detects its components (header, body).
1637      * and returns data array structure.
1638      * @return array ret_struct
1639      * @access private
1640      */
1641     private function process_respond() {
1642         $lines = explode("\r\n", $this->_header);
1643         $header_done = false;
1644         // $this->_error_log($this->_buffer);
1645         // First line should be a HTTP status line (see http://www.w3.org/Protocols/rfc2616/rfc2616-sec6.html#sec6)
1646         // Format is: HTTP-Version SP Status-Code SP Reason-Phrase CRLF
1647         list($ret_struct['status']['http-version'],
1648             $ret_struct['status']['status-code'],
1649             $ret_struct['status']['reason-phrase']) = explode(' ', $lines[0],3);
1650
1651         // print "HTTP Version: '$http_version' Status-Code: '$status_code' Reason Phrase: '$reason_phrase'<br>";
1652         // get the response header fields
1653         // See http://www.w3.org/Protocols/rfc2616/rfc2616-sec6.html#sec6
1654         for($i=1; $i<count($lines); $i++) {
1655             if (rtrim($lines[$i]) == '' && !$header_done) {
1656                 $header_done = true;
1657                 // print "--- response header end ---<br>";
1658
1659             }
1660             if (!$header_done ) {
1661                 // store all found headers in array ...
1662                 list($fieldname, $fieldvalue) = explode(':', $lines[$i]);
1663                 // check if this header was allready set (apache 2.0 webdav module does this....).
1664                 // If so we add the the value to the end the fieldvalue, separated by comma...
1665                 if (empty($ret_struct['header'])) {
1666                     $ret_struct['header'] = array();
1667                 }
1668                 if (empty($ret_struct['header'][$fieldname])) {
1669                     $ret_struct['header'][$fieldname] = trim($fieldvalue);
1670                 } else {
1671                     $ret_struct['header'][$fieldname] .= ',' . trim($fieldvalue);
1672                 }
1673             }
1674         }
1675         // print 'string len of response_body:'. strlen($response_body);
1676         // print '[' . htmlentities($response_body) . ']';
1677         $ret_struct['body'] = $this->_body;
1678         $this->_error_log('process_respond: ' . var_export($ret_struct,true));
1679         return $ret_struct;
1680
1681     }
1682
1683     /**
1684      * Private method reopen
1685      *
1686      * Reopens a socket, if 'connection: closed'-header was received from server.
1687      *
1688      * Uses public method open.
1689      * @access private
1690      */
1691     private function reopen() {
1692         // let's try to reopen a socket
1693         $this->_error_log('reopen a socket connection');
1694         return $this->open();
1695     }
1696
1697
1698     /**
1699      * Private method translate_uri
1700      *
1701      * translates an uri to raw url encoded string.
1702      * Removes any html entity in uri
1703      * @param string uri
1704      * @return string translated_uri
1705      * @access private
1706      */
1707     private function translate_uri($uri) {
1708         // remove all html entities...
1709         $native_path = html_entity_decode($uri);
1710         $parts = explode('/', $native_path);
1711         for ($i = 0; $i < count($parts); $i++) {
1712             // check if part is allready utf8
1713             if (iconv('UTF-8', 'UTF-8', $parts[$i]) == $parts[$i]) {
1714                 $parts[$i] = rawurlencode($parts[$i]);
1715             } else {
1716                 $parts[$i] = rawurlencode(utf8_encode($parts[$i]));
1717             }
1718         }
1719         return implode('/', $parts);
1720     }
1721
1722     /**
1723      * Private method utf_decode_path
1724      *
1725      * decodes a UTF-8 encoded string
1726      * @return string decodedstring
1727      * @access private
1728      */
1729     private function utf_decode_path($path) {
1730         $fullpath = $path;
1731         if (iconv('UTF-8', 'UTF-8', $fullpath) == $fullpath) {
1732             $this->_error_log("filename is utf-8. Needs conversion...");
1733             $fullpath = utf8_decode($fullpath);
1734         }
1735         return $fullpath;
1736     }
1737
1738     /**
1739      * Private method _error_log
1740      *
1741      * a simple php error_log wrapper.
1742      * @param string err_string
1743      * @access private
1744      */
1745     private function _error_log($err_string) {
1746         if ($this->_debug) {
1747             error_log($err_string);
1748         }
1749     }
1750 }