X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=classes%2FChannel.php;h=87f02b31679257cc34fb670168c326c1b018e8ba;hb=4f3d1e93e97365deac2366bfe422e8301d773a25;hp=f2e7ad34f2b08890a7c41943b09e7ee72206705b;hpb=c8fd8fa00f30cb2862a6feb32bc1b7d3a394c565;p=quix0rs-gnu-social.git

diff --git a/classes/Channel.php b/classes/Channel.php
index f2e7ad34f2..87f02b3167 100644
--- a/classes/Channel.php
+++ b/classes/Channel.php
@@ -22,14 +22,152 @@ if (!defined('LACONICA')) { exit(1); }
 class Channel {
 	
 	function on($user) {
+		return false;
 	}
 
 	function off($user) {
+		return false;
 	}
 
-	function output($user) {
+	function output($user, $text) {
+		return false;
 	}
 	
-	function error($user) {
+	function error($user, $text) {
+		return false;
 	}
-}
\ No newline at end of file
+	
+	function source() {
+		return NULL;
+	}
+}
+
+class XMPPChannel extends Channel {
+
+	var $conn = NULL;
+	
+	function source() {
+		return 'xmpp';
+	}
+	
+	function __construct($conn) {
+		$this->conn = $conn;
+	}
+	
+	function on($user) {
+		return $this->set_notify($user, 1);
+	}
+	
+	function off($user) {
+		return $this->set_notify($user, 0);
+	}
+
+	function output($user, $text) {
+		$text = '['.common_config('site', 'name') . '] ' . $text;
+		jabber_send_message($user->jabber, $text);
+	}
+	
+	function error($user, $text) {
+		$text = '['.common_config('site', 'name') . '] ' . $text;
+		jabber_send_message($user->jabber, $text);
+	}
+	
+	function set_notify(&$user, $notify) {
+		$orig = clone($user);
+		$user->jabbernotify = $notify;
+		$result = $user->update($orig);
+		if (!$result) {
+			$last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
+			common_log(LOG_ERR,
+					   'Could not set notify flag to ' . $notify .
+					   ' for user ' . common_log_objstring($user) .
+					   ': ' . $last_error->message);
+			return false;
+		} else {
+			common_log(LOG_INFO,
+					   'User ' . $user->nickname . ' set notify flag to ' . $notify);
+			return true;
+		}
+	}
+}
+
+
+class WebChannel extends Channel {
+
+	function source() {
+		return 'web';
+	}
+	
+	function on($user) {
+		return false;
+	}
+	
+	function off($user) {
+		return false;
+	}
+
+	function output($user, $text) {
+		# XXX: buffer all output and send it at the end
+		# XXX: even better, redirect to appropriate page
+		#      depending on what command was run
+		common_show_header(_('Command results'));
+		common_element('p', NULL, $text);
+		common_show_footer();
+	}
+	
+	function error($user, $text) {
+		common_user_error($text);
+	}
+}
+
+class MailChannel extends Channel {
+
+	var $addr = NULL;
+
+	function source() {
+		return 'mail';
+	}
+	
+	function __construct($addr=NULL) {
+		$this->addr = $addr;
+	}
+	
+	function on($user) {
+		return $this->set_notify($user, 1);
+	}
+	
+	function off($user) {
+		return $this->set_notify($user, 0);
+	}
+
+	function output($user, $text) {
+
+		$headers['From'] = $user->incomingemail;
+		$headers['To'] = $this->addr;
+		
+		$headers['Subject'] = _('Command complete');
+
+		return mail_send(array($this->addr), $headers, $text);
+	}
+	
+	function error($user, $text) {
+		
+		$headers['From'] = $user->incomingemail;
+		$headers['To'] = $this->addr;
+		
+		$headers['Subject'] = _('Command failed');
+
+		return mail_send(array($this->addr), $headers, $text);
+	}
+	
+	function set_notify($user, $value) {
+		$orig = clone($user);
+		$user->smsnotify = $value;
+		$result = $user->update($orig);
+		if (!$result) {
+			common_log_db_error($user, 'UPDATE', __FILE__);
+			return false;
+		}
+		return true;
+	}
+}