_darcs/pristine/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
 124 class AjaxWebChannel extends WebChannel {
 125
 126     function output($user, $text) {
 127         common_start_html('text/xml;charset=utf-8', true);
 128         common_element_start('head');
 129         common_element('title', null, _('Command results'));
 130         common_element_end('head');
 131         common_element_start('body');
 132         common_element('p', array('id' => 'command_result'), $text);
 133         common_element_end('body');
 134         common_element_end('html');
 135     }
 136
 137     function error($user, $text) {
 138         common_start_html('text/xml;charset=utf-8', true);
 139         common_element_start('head');
 140         common_element('title', null, _('Ajax Error'));
 141         common_element_end('head');
 142         common_element_start('body');
 143         common_element('p', array('id' => 'error'), $text);
 144         common_element_end('body');
 145         common_element_end('html');
 146     }
 147 }
 148
 149
 150 class MailChannel extends Channel {
 151
 152     var $addr = null;
 153
 154     function source() {
 155         return 'mail';
 156     }
 157
 158     function __construct($addr=null) {
 159         $this->addr = $addr;
 160     }
 161
 162     function on($user) {
 163         return $this->set_notify($user, 1);
 164     }
 165
 166     function off($user) {
 167         return $this->set_notify($user, 0);
 168     }
 169
 170     function output($user, $text) {
 171
 172         $headers['From'] = $user->incomingemail;
 173         $headers['To'] = $this->addr;
 174
 175         $headers['Subject'] = _('Command complete');
 176
 177         return mail_send(array($this->addr), $headers, $text);
 178     }
 179
 180     function error($user, $text) {
 181
 182         $headers['From'] = $user->incomingemail;
 183         $headers['To'] = $this->addr;
 184
 185         $headers['Subject'] = _('Command failed');
 186
 187         return mail_send(array($this->addr), $headers, $text);
 188     }
 189
 190     function set_notify($user, $value) {
 191         $orig = clone($user);
 192         $user->smsnotify = $value;
 193         $result = $user->update($orig);
 194         if (!$result) {
 195             common_log_db_error($user, 'UPDATE', __FILE__);
 196             return false;
 197         }
 198         return true;
 199     }
 200 }