}
}
+ public function shutdown() {
+ if($this->client->connected()) {
+ if(($this->flags & self::FLAG_P10SESSION)) {
+ $this->send("SQ", "Shutdown requested.");
+ }
+ $this->client->disconnect();
+ }
+ }
+
public function setUplinkHost($host, $port, $ssl = false, $bind = null) {
$this->setSetting("host", $host);
$this->setSetting("port", $port);
case "W":
$this->recv_whois($from, $arguments);
break;
+ case "A":
+ $this->recv_away($from, $arguments);
+ break;
+ case "M":
+ case "OM":
+ $this->recv_mode($from, $arguments);
+ break;
//default
default:
//unknown cmd
$this->server->addServer($new_server);
$this->flags |= self::FLAG_P10SESSION | self::FLAG_BURST_PENDING;
if($this->eventHandler)
- $this->eventHandler->event_server($new_server, !($this->flags & self::FLAG_CONNECTED));
+ $this->eventHandler->event_newserver($new_server, !($this->flags & self::FLAG_CONNECTED));
} else {
//another server got a new slave server ^^
$server = P10_Server::getServerByNum($from);
$new_server = new P10_Server($args[0], substr($args[5],0,2), $server, $args[2], $args[3], $args[7]);
$server->addServer($new_server);
if($this->eventHandler)
- $this->eventHandler->event_server($new_server, !($this->flags & self::FLAG_CONNECTED));
+ $this->eventHandler->event_newserver($new_server, !($this->flags & self::FLAG_CONNECTED));
}
}
private function recv_ping($from, $args) {
$this->send("Z", $args[0]); //simply PONG
+ P10_Channel::recheckAllChannels();
}
private function recv_nick($from, $args) {
$users = explode(",",$userstr);
$isop = false; $isvoice = false;
foreach($users as $user) {
+ if($user == "") continue;
$uexp = explode(":", $user);
if(strlen($uexp[0]) != 5) {
trigger_error("burst parse error: '".$uexp[0]."' is not an user numeric.", E_USER_ERROR);
return;
}
if($this->eventHandler) {
- if($args[0] == "#") {
+ if($args[0][0] == "#") {
$channel = P10_Channel::getChannelByName($args[0]);
if($channel == null)
$channel = new P10_Channel($args[0]);
return;
}
if($this->eventHandler) {
- if($args[0] == "#") {
+ if($args[0][0] == "#") {
$channel = P10_Channel::getChannelByName($args[0]);
if($channel == null)
$channel = new P10_Channel($args[0]);
$this->send("318", $from, $args[1]);
}
+ private function recv_away($from, $args) {
+ $user = P10_User::getUserByNum($from);
+ if($user == null) {
+ trigger_error("Server tries to send an away command from an user that does not exist or was not found on recv_away.", E_USER_ERROR);
+ return;
+ }
+ if(count($args) > 0) {
+ $user->setAway($args[0]);
+ } else {
+ $user->setAway(null);
+ }
+ }
+
+ private function recv_mode($from, $args) {
+ $user = P10_User::getUserByNum($from);
+ if($user == null) {
+ trigger_error("Server tries to send a modechange from an user that does not exist or was not found on recv_mode.", E_USER_ERROR);
+ return;
+ }
+ $modes = implode(" ",array_slice($args,1));
+ if($args[0][0] == "#") {
+ $channel = P10_Channel::getChannelByName($args[0]);
+ if($channel == null)
+ $channel = new P10_Channel($args[0]);
+ $channel->getModes()->setModes($modes);
+ if($this->eventHandler)
+ $this->eventHandler->event_chanmode($user, $channel, $modes);
+ } else {
+ $targetUser = P10_User::getUserByNum($args[0]);
+ if($targetUser == null) {
+ trigger_error("Server tries to send a mode to an user that does not exist or was not found on recv_mode.", E_USER_ERROR);
+ return;
+ }
+ $targetUser->getModes()->setModes($modes);
+ if($this->eventHandler)
+ $this->eventHandler->event_usermode($targetUser, $modes);
+ }
+ }
+
/********************************************************************************************
* SERVER FUNCTIONS *
********************************************************************************************/
$numeric = substr($this->server->getNumeric(),0,2).Numerics::intToNum($this->last_local_numeric, 3);
}
$this->last_local_numeric++;
+ $modes = new P10_UserModeSet($modes);
$user = new P10_User($nick, $numeric, $this->server, time(), $ident, $host, $ip, $realname, $modes);
if(($this->flags & self::FLAG_CONNECTED)) {
$ip = Numerics::numericFromIP($user->getIP());
}
}
- public function join($user, $chanName) {
+ public function join($user, $chanName, $privs = 0) {
if(!is_a($user, "P10_User") || !($user->getServer() === $this->server))
return ERR_INVALID_USER;
if($chanName[0] != "#")
$channel->joinUser($user);
if(($this->flags & self::FLAG_CONNECTED))
$this->send("J", $user->getNumeric(), $chanName, time(), 0);
+ if($privs != 0) {
+ $channel->setUserPrivs($user, $privs);
+ if(($this->flags & self::FLAG_CONNECTED)) {
+ $modestr = "+".(($privs & P10_Channel::USERPRIV_OPED) ? "o" : "").(($privs & P10_Channel::USERPRIV_VOICE) ? "v" : "");
+ $modestr .= (($privs & P10_Channel::USERPRIV_OPED) ? " ".$user->getNumeric() : "");
+ $modestr .= (($privs & P10_Channel::USERPRIV_VOICE) ? " ".$user->getNumeric() : "");
+ $this->send("OM", $user->getNumeric(), $chanName, $modestr);
+ }
+ }
if($this->eventHandler)
$this->eventHandler->event_join($user, $channel, false);
}