diff options
| author | Paul S. Owen <psotfx@users.sourceforge.net> | 2003-09-07 13:51:53 +0000 |
|---|---|---|
| committer | Paul S. Owen <psotfx@users.sourceforge.net> | 2003-09-07 13:51:53 +0000 |
| commit | 12c44058fdcf603853f6b0f43cba20ff4e424ffd (patch) | |
| tree | e0f1829ec73eef54a5109cabd501c12dee9835a6 /phpBB/includes/functions_jabber.php | |
| parent | fe70cdf4ce641dd95891de22ec2cb1829743bed1 (diff) | |
| download | forums-12c44058fdcf603853f6b0f43cba20ff4e424ffd.tar forums-12c44058fdcf603853f6b0f43cba20ff4e424ffd.tar.gz forums-12c44058fdcf603853f6b0f43cba20ff4e424ffd.tar.bz2 forums-12c44058fdcf603853f6b0f43cba20ff4e424ffd.tar.xz forums-12c44058fdcf603853f6b0f43cba20ff4e424ffd.zip | |
Re-add transport and other methods
git-svn-id: file:///svn/phpbb/trunk@4475 89ea8834-ac86-4346-8a33-228a782c2dd0
Diffstat (limited to 'phpBB/includes/functions_jabber.php')
| -rw-r--r-- | phpBB/includes/functions_jabber.php | 119 |
1 files changed, 118 insertions, 1 deletions
diff --git a/phpBB/includes/functions_jabber.php b/phpBB/includes/functions_jabber.php index 8059f55589..6ed843878a 100644 --- a/phpBB/includes/functions_jabber.php +++ b/phpBB/includes/functions_jabber.php @@ -135,11 +135,53 @@ class Jabber $this->CONNECTOR->CloseSocket(); } + function CruiseControl($seconds = -1) + { + $count = 0; + + while ($count != $seconds) + { + $this->Listen(); + + do + { + $packet = $this->GetFirstFromQueue(); + + if ($packet) + { + $this->CallHandler($packet); + } + + } + while (count($this->packet_queue) > 1); + + $count += 0.25; + usleep(250000); + + if ($this->last_ping_time != date('H:i')) + { + // Modified by Nathan Fritz + if ($this->returned_keep_alive == FALSE) + { + $this->connected = FALSE; + $this->AddToLog('EVENT: Disconnected'); + } + + $this->returned_keep_alive = FALSE; + $this->keep_alive_id = 'keep_alive_' . time(); + $this->SendPacket("<iq id='{$this->keep_alive_id}'/>", 'CruiseControl'); + $this->last_ping_time = date("H:i"); + } + } + + return TRUE; + } + function SendAuth() { $this->auth_id = 'auth_' . md5(time() . $_SERVER['REMOTE_ADDR']); - $this->resource = 'Class.Jabber.PHP ' . md5($this->auth_id); +// $this->resource = 'Class.Jabber.PHP ' . md5($this->auth_id); $this->jid = "{$this->username}@{$this->server}/{$this->resource}"; // request available authentication methods @@ -224,6 +266,81 @@ class Jabber return ($this->CONNECTOR->WriteToSocket($xml)) ? TRUE : FALSE; } + // get the transport registration fields + // method written by Steve Blinch, http://www.blitzaffe.com + function TransportRegistrationDetails($transport) + { + $this->txnid++; + $packet = $this->SendIq($transport, 'get', "reg_{$this->txnid}", "jabber:iq:register", NULL, $this->jid); + + if ($packet) + { + $res = array(); + + foreach ($packet['iq']['#']['query'][0]['#'] as $element => $data) + { + if ($element != 'instructions' && $element != 'key') + { + $res[] = $element; + } + } + + return $res; + } + else + { + return 3; + } + } + + // register with the transport + // method written by Steve Blinch, http://www.blitzaffe.com + function TransportRegistration($transport, $details) + { + $this->txnid++; + $packet = $this->SendIq($transport, 'get', "reg_{$this->txnid}", "jabber:iq:register", NULL, $this->jid); + + if ($packet) + { + $key = $this->GetInfoFromIqKey($packet); // just in case a key was passed back from the server + unset($packet); + + $payload = ($key) ? "<key>$key</key>\n" : ''; + foreach ($details as $element => $value) + { + $payload .= "<$element>$value</$element>\n"; + } + + $packet = $this->SendIq($transport, 'set', "reg_{$this->txnid}", "jabber:iq:register", $payload); + + if ($this->GetInfoFromIqType($packet) == 'result') + { + if (isset($packet['iq']['#']['query'][0]['#']['registered'][0]['#'])) + { + $return_code = 1; + } + else + { + $return_code = 2; + } + } + elseif ($this->GetInfoFromIqType($packet) == 'error') + { + if (isset($packet['iq']['#']['error'][0]['#'])) + { + $return_code = "Error " . $packet['iq']['#']['error'][0]['@']['code'] . ": " . $packet['iq']['#']['error'][0]['#']; + $this->AddToLog('ERROR: TransportRegistration()'); + } + } + + return $return_code; + } + else + { + return 3; + } + } + function Listen() { unset($incoming); |