classes/Channel.php

   1 <?php
   2 /*
   3  * Laconica - a distributed open-source microblogging tool
   4  * Copyright (C) 2008, Controlez-Vous, Inc.
   5  *
   6  * This program is free software: you can redistribute it and/or modify
   7  * it under the terms of the GNU Affero General Public License as published by
   8  * the Free Software Foundation, either version 3 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU Affero General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Affero General Public License
  17  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18  */
  19
  20 if (!defined('LACONICA')) { exit(1); }
  21
  22 class Channel {
  23
  24         function on($user) {
  25                 return false;
  26         }
  27
  28         function off($user) {
  29                 return false;
  30         }
  31
  32         function output($user, $text) {
  33                 return false;
  34         }
  35
  36         function error($user, $text) {
  37                 return false;
  38         }
  39
  40         function source() {
  41                 return NULL;
  42         }
  43 }
  44
  45 class XMPPChannel extends Channel {
  46
  47         var $conn = NULL;
  48
  49         function source() {
  50                 return 'xmpp';
  51         }
  52
  53         function __construct($conn) {
  54                 $this->conn = $conn;
  55         }
  56
  57         function on($user) {
  58                 return $this->set_notify($user, 1);
  59         }
  60
  61         function off($user) {
  62                 return $this->set_notify($user, 0);
  63         }
  64
  65         function output($user, $text) {
  66                 $text = '['.common_config('site', 'name') . '] ' . $text;
  67                 jabber_send_message($user->jabber, $text);
  68         }
  69
  70         function error($user, $text) {
  71                 $text = '['.common_config('site', 'name') . '] ' . $text;
  72                 jabber_send_message($user->jabber, $text);
  73         }
  74
  75         function set_notify(&$user, $notify) {
  76                 $orig = clone($user);
  77                 $user->jabbernotify = $notify;
  78                 $result = $user->update($orig);
  79                 if (!$result) {
  80                         $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
  81                         common_log(LOG_ERR,
  82                                            'Could not set notify flag to ' . $notify .
  83                                            ' for user ' . common_log_objstring($user) .
  84                                            ': ' . $last_error->message);
  85                         return false;
  86                 } else {
  87                         common_log(LOG_INFO,
  88                                            'User ' . $user->nickname . ' set notify flag to ' . $notify);
  89                         return true;
  90                 }
  91         }
  92 }
  93
  94
  95 class WebChannel extends Channel {
  96
  97         function source() {
  98                 return 'web';
  99         }
 100
 101         function on($user) {
 102                 return false;
 103         }
 104
 105         function off($user) {
 106                 return false;
 107         }
 108
 109         function output($user, $text) {
 110                 # XXX: buffer all output and send it at the end
 111                 # XXX: even better, redirect to appropriate page
 112                 #      depending on what command was run
 113                 common_show_header(_('Command results'));
 114                 common_element('p', NULL, $text);
 115                 common_show_footer();
 116         }
 117
 118         function error($user, $text) {
 119                 common_user_error($text);
 120         }
 121 }
 122
 123 class MailChannel extends Channel {
 124
 125         var $addr = NULL;
 126
 127         function source() {
 128                 return 'mail';
 129         }
 130
 131         function __construct($addr=NULL) {
 132                 $this->addr = $addr;
 133         }
 134
 135         function on($user) {
 136                 return $this->set_notify($user, 1);
 137         }
 138
 139         function off($user) {
 140                 return $this->set_notify($user, 0);
 141         }
 142
 143         function output($user, $text) {
 144
 145                 $headers['From'] = $user->incomingemail;
 146                 $headers['To'] = $this->addr;
 147
 148                 $headers['Subject'] = _('Command complete');
 149
 150                 return mail_send(array($this->addr), $headers, $text);
 151         }
 152
 153         function error($user, $text) {
 154
 155                 $headers['From'] = $user->incomingemail;
 156                 $headers['To'] = $this->addr;
 157
 158                 $headers['Subject'] = _('Command failed');
 159
 160                 return mail_send(array($this->addr), $headers, $text);
 161         }
 162
 163         function set_notify($user, $value) {
 164                 $orig = clone($user);
 165                 $user->smsnotify = $value;
 166                 $result = $user->update($orig);
 167                 if (!$result) {
 168                         common_log_db_error($user, 'UPDATE', __FILE__);
 169                         return false;
 170                 }
 171                 return true;
 172         }
 173 }