X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=lib%2Fbtr%2Firc.php;fp=lib%2Fbtr%2Firc.php;h=8af22098e1e5d6f878b89b3fc129590410fb9842;hb=f5fd15396636986e7447993a66b8a4084a93dabb;hp=0000000000000000000000000000000000000000;hpb=5735fce9818606a36ff3ebbbf902030bcd46c506;p=m6w6%2Fbtr

diff --git a/lib/btr/irc.php b/lib/btr/irc.php
new file mode 100755
index 0000000..8af2209
--- /dev/null
+++ b/lib/btr/irc.php
@@ -0,0 +1,88 @@
+<?php
+
+function fatal() {
+	if (func_num_args()) {
+		$args = func_get_args();
+	} elseif (($error = error_get_last())) {
+		$args = ["%s", $error["message"]];
+	}
+	
+	if (!empty($args)) {
+		if (count($args) === 1 && is_numeric($args[0])) {
+			array_unshift($args, "Got signal %d");
+		}
+		trigger_error(call_user_func_array("sprintf", $args), E_USER_ERROR);
+	}
+	
+	exit;
+}
+
+function mkfifo($path) {
+	if (!isfifo($path, $stat)) {
+		$stat and unlink($path);
+		if (!posix_mkfifo($path, 0660)) {
+			return false;
+		}
+	}
+	return fopen($path, "r+");
+}
+
+function isfifo($path, &$stat = null) {
+	return ($stat = @stat($path)) && ($stat["mode"] & POSIX_S_IFIFO);
+}
+
+class Client
+{
+	protected $session;
+	protected $channel;
+	protected $keyword;
+	protected $joined;
+	protected $queue = array();
+	
+	function __construct($url, callable $onJoin) {
+		if (!$url = parse_url($url)) {
+			fatal("could not parse url: '%s'", $url);
+		}
+		
+		$this->session = $session = new irc\client\Session(
+			$url["user"],
+			$url["user"],
+			$url["user"]
+		);
+		
+		@list($this->channel, $this->keyword) = 
+			explode(" ", $url["fragment"]);
+		
+		$session->onConnect = $session->onPart = function($origin, array $args) {
+			$this->joined = false;
+			$this->session->doJoin("#".$this->channel, $this->keyword);
+		};
+		$session->onJoin = function($origin, array $args) use ($onJoin) {
+			$this->joined = true;
+			$onJoin($this, $origin, $args);
+		};
+		$session->doConnect(false, $url["host"], @$url["port"]?:6667, @$url["pass"]);
+	}
+	
+	function send($message = null) {
+		if (isset($message)) {
+			$this->queue[] = $message;
+		}
+		
+		if ($this->joined) {
+			while ($this->queue) {
+				$this->session->doMsg("#".$this->channel, array_shift($this->queue));
+			}
+		}
+	}
+	
+	function getSession() {
+		return $this->session;
+	}
+}
+
+if (!extension_loaded("ircclient")) {
+	fatal("ext/ircclient not loaded");
+}
+
+# vim: noet