* * See the enclosed file COPYING for license information (LGPL). If you * did not receive this file, see http://www.fsf.org/copyleft/lgpl.html. * * @author Anthony Mills * @author Karsten Fourmont * * @version $Revision$ * @since Horde 3.0 * @package Horde_SyncML */ class Horde_SyncML_ContentHandler { /** * Output ContentHandler used to output XML events. * @var object $_output */ var $_output; /** * @var integer $_xmlStack */ var $_xmlStack = 1; /** * @var string $_chars */ var $_chars; function setOutput(&$output) { $this->_output = &$output; } function startElement($uri, $element, $attrs) { $this->_xmlStack++; } function endElement($uri, $element) { if (isset($this->_chars)) { unset($this->_chars); } $this->_xmlStack--; } function characters($str) { if (isset($this->_chars)) { $this->_chars = $this->_chars . $str; } else { $this->_chars = $str; } } } /** * Defined in SyncML Representation Protocol, version 1.1 5.2.2 * * @package Horde_SyncML */ class Horde_SyncML_SyncMLHdr extends Horde_SyncML_ContentHandler { /** * Used to specify if in Source tag. Defined in SyncML * Representation Protocol, version 1.1 5.1.20. * * @var boolean $_isSource */ var $_isSource = false; /** * Defined in SyncML Representation Protocol, version 1.1 * 5.1.9. User name. * * @var string $_locName */ var $_locName; /** * Defined in SyncML Representation Protocol, version 1.1 5.1.18 * * @var string $_sessionID */ var $_sessionID; /** * Defined in SyncML Representation Protocol, version 1.1. Must * be 1.0 (0) or 1.1 (1). * * @var string $_version */ var $_version; /** * Defined in SyncML Representation Protocol, version 1.1 5.1.12 * * @var string $_msgID */ var $_msgID; /** * Defined in SyncML Representation Protocol, version 1.1 5.1.10 * * @var string $_targetURI */ var $_targetURI; /** * Defined in SyncML Representation Protocol, version 1.1 5.1.10, * 5.1.20 * * @var string $_sourceURI */ var $_sourceURI; var $_isCred; var $_credData; var $_credFormat; var $_credType; function getStateFromSession($sourceURI, $locName, $sessionID) { // Remove any existing session since we'll be contructing a // custom session id. session_destroy(); // Reload the Horde SessionHandler if necessary. Horde::setupSessionHandler(); // It would seem multisync does not send the user name once it // has been authorized. Make sure we have a valid session id. session_id('syncml' . preg_replace('/[^a-zA-Z0-9]/', '', $sourceURI . $sessionID)); @session_start(); Horde::logMessage('SyncML: session id = ' . session_id(), __FILE__, __LINE__, PEAR_LOG_DEBUG); if (!isset($_SESSION['SyncML.state'])) { // Create a new state if one does not already exist. Horde::logMessage('SyncML: new session state', __FILE__, __LINE__, PEAR_LOG_DEBUG); # LK $_SESSION['SyncML.state'] = &new Horde_SyncML_State($sourceURI, $locName, $sessionID); $_SESSION['SyncML.state'] = &new EGW_SyncML_State($sourceURI, $locName, $sessionID); } if($_SESSION['SyncML.state']->_isAuthorized) Horde::logMessage('SyncML: is session authorized', __FILE__, __LINE__, PEAR_LOG_DEBUG); return $_SESSION['SyncML.state']; } function startElement($uri, $element, $attrs) { parent::startElement($uri, $element, $attrs); switch ($this->_xmlStack) { case 3: if ($element == 'Source') { // $this->_isSource = true; } elseif ($element == 'Cred') { $this->_isCred = true; } break; } } function endElement($uri, $element) { switch ($this->_xmlStack) { case 2: /* $str = 'localname=' . $this->_locName; $str .= ' version=' . $this->_version; $str .= ' msgid=' . $this->_msgID; $str .= ' source=' . $this->_sourceURI; $str .= ' target=' . $this->_targetURI; $str .= ' sessionID=' . $this->_sessionID; */ // // Find the state. $state = $this->getStateFromSession($this->_sourceURI, $this->_locName, $this->_sessionID); $state->setVersion($this->_version); $state->setMsgID($this->_msgID); $state->setTargetURI($this->_targetURI); if(isset($this->_credData) && isset($this->_locName) && !$state->isAuthorized()) { $state->setPassword($this->_credData); $state->setLocName($this->_locName); } #$str = 'authorized=' . $state->isAuthorized(); #$str .= ' version=' . $state->getVersion(); #$str .= ' msgid=' . $state->getMsgID(); #$str .= ' source=' . $state->getSourceURI(); #$str .= ' target=' . $state->getTargetURI(); #$str .= ' locName=' . $state->getLocName(); $_SESSION['SyncML.state'] = $state; #Horde::logMessage('SymcML: session id 2 =' . session_id(), __FILE__, __LINE__, PEAR_LOG_DEBUG); // Got the state; now write our SyncHdr header. $this->outputSyncHdr($this->_output); break; case 3: if ($element == 'VerProto') { // if (trim($this->_chars) == 'SyncML/1.1') { $this->_version = 1; } else { $this->_version = 0; } } elseif ($element == 'SessionID') { // $this->_sessionID = trim($this->_chars); } elseif ($element == 'MsgID') { // $this->_msgID = intval(trim($this->_chars)); } elseif ($element == 'Source') { // $this->_isSource = false; } elseif ($element == 'Cred') { // $this->_isCred = false; //multisync does not specify the cred format //if ($this->_credFormat == 'b64') { $this->_credData = base64_decode($this->_credData); //} $tmp = split(':', $this->_credData); // set only if not set by LocName already if(!isset($this->_locName)) { $this->_locName = $tmp[0]; } $this->_credData = $tmp[1]; Horde::logMessage('SyncML: $this->_locName: ' . $this->_locName, __FILE__, __LINE__, PEAR_LOG_DEBUG); } break; case 4: if ($element == 'LocURI') { if ($this->_isSource) { // $this->_sourceURI = trim($this->_chars); } else { // $this->_targetURI = trim($this->_chars); } } elseif ($element == 'LocName') { if ($this->_isSource) { // $this->_locName = trim($this->_chars); } } elseif ($element == 'Data') { // if ($this->_isCred) { $this->_credData = trim($this->_chars); } } break; case 5: if ($this->_isCred) { if ($element == 'Format') { // $this->_credFormat = trim($this->_chars); } elseif ($element == 'Type') { // $this->_credType = trim($this->_chars); } } break; } parent::endElement($uri, $element); } function outputSyncHdr(&$output) { $attrs = array(); $state = $_SESSION['SyncML.state']; $uri = $state->getURI(); $uriMeta = $state->getURIMeta(); $output->startElement($uri, 'SyncHdr', $attrs); $output->startElement($uri, 'VerDTD', $attrs); $chars = ($this->_version == 1) ? '1.1' : '1.0'; $output->characters($chars); $output->endElement($uri, 'VerDTD'); $output->startElement($uri, 'VerProto', $attrs); $chars = ($this->_version == 1) ? 'SyncML/1.1' : 'SyncML/1.0'; $output->characters($chars); $output->endElement($uri, 'VerProto'); $output->startElement($uri, 'SessionID', $attrs); $output->characters($this->_sessionID); $output->endElement($uri, 'SessionID'); $output->startElement($uri, 'MsgID', $attrs); $output->characters($this->_msgID); $output->endElement($uri, 'MsgID'); $output->startElement($uri, 'Target', $attrs); $output->startElement($uri, 'LocURI', $attrs); $output->characters($this->_sourceURI); $output->endElement($uri, 'LocURI'); $output->endElement($uri, 'Target'); $output->startElement($uri, 'Source', $attrs); $output->startElement($uri, 'LocURI', $attrs); $output->characters($this->_targetURI); $output->endElement($uri, 'LocURI'); $output->endElement($uri, 'Source'); #if(!strpos($this->_targetURI,'syncit')) #{ # $output->startElement($uri, 'RespURI', $attrs); # $output->characters($this->_targetURI.'?syncid='.$GLOBALS['sessionid'].'-'.$GLOBALS['phpgw_info']['user']['kp3']); # $output->characters($this->_targetURI.'?after=20040101T133000Z-syncid=lars'); # $output->characters($this->_targetURI.'?sincit=10'); # $output->characters('http://192.168.4.227/horde/rpc.php?after=20040101T133000Z-username=lars'); # $output->endElement($uri, 'RespURI'); #} /* $output->startElement($uri, 'Meta', $attrs); // Dummy Max MsqSize, this is just put in to make the packet // work, it is not a real value. $output->startElement($uriMeta, 'MaxMsgSize', $attrs); $chars = '50000'; $output->characters($chars); $output->endElement($uriMeta, 'MaxMsgSize'); // Dummy MaxObjSize, this is just put in to make the packet // work, it is not a real value. $output->startElement($uriMeta, 'MaxObjSize', $attrs); $chars = '4000000'; $output->characters($chars); $output->endElement($uriMeta, 'MaxObjSize'); $output->endElement($uri, 'Meta'); */ $output->endElement($uri, 'SyncHdr'); } function getSourceURI() { return $this->_sourceURI; } function getLocName() { return $this->_locName; } function getSessionID() { return $this->_sessionID; } function getVersion() { return $this->_version; } function getMsgID() { return $this->_msgID; } function getTargetURI() { return $this->_targetURI; } function opaque($o) { } } /** * Defined in SyncML Representation Protocol, version 1.1 5.2.3 * * @package Horde_SyncML */ class Horde_SyncML_SyncMLBody extends Horde_SyncML_ContentHandler { var $_currentCmdID = 1; var $_currentCommand; var $_actionCommands = false; var $_clientSentFinal = false; function startElement($uri, $element, $attrs) { parent::startElement($uri, $element, $attrs); switch ($this->_xmlStack) { case 2: $state = & $_SESSION['SyncML.state']; $this->_actionCommands = false; // so far, we have not seen commands that require action from our side // $this->_output->startElement($uri, $element, $attrs); if($state->getLocName()) { // Right our status about the header. $status = &new Horde_SyncML_Command_Status(($state->isAuthorized()) ? RESPONSE_AUTHENTICATION_ACCEPTED : RESPONSE_INVALID_CREDENTIALS, 'SyncHdr'); } else { // Request credentials if not sent so far $status = &new Horde_SyncML_Command_Status(RESPONSE_MISSING_CREDENTIALS, 'SyncHdr'); } $status->setSourceRef($state->getSourceURI()); $status->setTargetRef($state->getTargetURI()); $status->setCmdRef(0); /*$str = 'authorized=' . $state->isAuthorized(); $str .= ' version=' . $state->getVersion(); $str .= ' msgid=' . $state->getMsgID(); $str .= ' source=' . $state->getSourceURI(); $str .= ' target=' . $state->getTargetURI(); */ $this->_currentCmdID = $status->output($this->_currentCmdID, $this->_output); break; case 3: $state = & $_SESSION['SyncML.state']; // <[Command]> $this->_currentCommand = Horde_SyncML_Command::factory($element); $this->_currentCommand->startElement($uri, $element, $attrs); if ($element != 'Status' && $element != 'Map' && $element != 'Final') { // We've got to do something! This can't be the last // packet. $this->_actionCommands = true; Horde::logMessage("SyncML: found action commands <$element> " . $this->_actionCommands, __FILE__, __LINE__, PEAR_LOG_INFO); } switch($element) { # case 'Final': # if($state->getClientSyncStatus() == 1) # { # $state->setClientSyncStatus(2); # } # break; case 'Sync': $state->setSyncStatus(CLIENT_SYNC_STARTED); Horde::logMessage('SyncML: syncStatus(client sync started) ' . $state->getSyncStatus(), __FILE__, __LINE__, PEAR_LOG_INFO); break; } break; default: // <...> $this->_currentCommand->startElement($uri, $element, $attrs); break; } } function endElement($uri, $element) { switch ($this->_xmlStack) { case 2: // $state = & $_SESSION['SyncML.state']; // send the sync reply // we do still have some data to send OR // we should reply to the Sync command $sync = &new Horde_SyncML_Command_Sync(); $this->_currentCmdID = $sync->syncToClient($this->_currentCmdID, $this->_output); // send the Final tag if possible if($state->getSyncStatus() != SERVER_SYNC_DATA_PENDING && $state->getSyncStatus() != CLIENT_SYNC_STARTED) { $final = &new Horde_SyncML_Command_Final(); $this->_currentCmdID = $final->output($this->_currentCmdID, $this->_output); } $this->_output->endElement($uri, $element); Horde::logMessage('SyncML: syncStatus ' . $state->getSyncStatus() .'actionCommands: '.$this->_actionCommands, __FILE__, __LINE__, PEAR_LOG_INFO); if (!$this->_actionCommands && $state->getSyncStatus() == SERVER_SYNC_FINNISHED) { // this packet did not contain any real actions, just status and map. // This means, we're through! The session can be closed and // the Anchors saved for the next Sync $state = & $_SESSION['SyncML.state']; Horde::logMessage('SyncML: sync' . session_id() . ' completed successfully!', __FILE__, __LINE__, PEAR_LOG_INFO); $state->writeSyncSummary(); $log = $state->getLog(); $s=""; foreach($log as $k => $v) { $s .= " $k=$v"; } Horde::logMessage('SyncML: summary:' . $s, __FILE__, __LINE__, PEAR_LOG_INFO); // session can be closed here! #session_unset(); #session_destroy(); } if (!$this->_actionCommands && $state->getSyncStatus() == SERVER_SYNC_FINNISHED && $this->_clientSentFinal) { Horde::logMessage('SyncML: destroying sync session '.session_id(), __FILE__, __LINE__, PEAR_LOG_INFO); // session can be closed here! session_unset(); session_destroy(); } break; case 3: // $state = & $_SESSION['SyncML.state']; // this should be moved to case 2: if($element == 'Final') { // make sure that we request devinfo, if we not have them already if(!$state->getClientDeviceInfo()) { $attrs = array(); $this->_output->startElement($state->getURI(), 'Get', $attrs); $this->_output->startElement($state->getURI(), 'CmdID', $attrs); $this->_output->characters($this->_currentCmdID); $this->_currentCmdID++; $this->_output->endElement($state->getURI(), 'CmdID'); $this->_output->startElement($state->getURI(), 'Meta', $attrs); $this->_output->startElement($state->getURIMeta(), 'Type', $attrs); $this->_output->characters('application/vnd.syncml-devinf+xml'); $this->_output->endElement($state->getURIMeta(), 'Type'); $this->_output->endElement($state->getURI(), 'Meta'); $this->_output->startElement($state->getURI(), 'Item', $attrs); $this->_output->startElement($state->getURI(), 'Target', $attrs); $this->_output->startElement($state->getURI(), 'LocURI', $attrs); $this->_output->characters(($state->getVersion() == 0) ? './devinf10' : './devinf11'); $this->_output->endElement($state->getURI(), 'LocURI'); $this->_output->endElement($state->getURI(), 'Target'); $this->_output->endElement($state->getURI(), 'Item'); $this->_output->endElement($state->getURI(), 'Get'); } } $this->_currentCommand->endElement($uri, $element); switch($element) { case 'Final': if($state->getSyncStatus() == CLIENT_SYNC_STARTED) { $state->setSyncStatus(CLIENT_SYNC_FINNISHED); Horde::logMessage('SyncML: syncStatus(client sync finnished) ' . $state->getSyncStatus(), __FILE__, __LINE__, PEAR_LOG_INFO); } $this->_clientSentFinal = true; Horde::logMessage('SyncML: Sync _syncTag = '. $state->getSyncStatus(), __FILE__, __LINE__, PEAR_LOG_INFO); break; default: $this->_currentCmdID = $this->_currentCommand->output($this->_currentCmdID, $this->_output); break; } unset($this->_currentCommand); break; default: // $this->_currentCommand->endElement($uri, $element); break; } parent::endElement($uri, $element); } function characters($str) { if (isset($this->_currentCommand)) { $this->_currentCommand->characters($str); } } }