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                 }
  90         }
  91 }
  92
  93
  94 class WebChannel extends Channel {
  95
  96         function source() {
  97                 return 'web';
  98         }
  99
 100         function on($user) {
 101                 return false;
 102         }
 103
 104         function off($user) {
 105                 return false;
 106         }
 107
 108         function output($user, $text) {
 109                 # XXX: buffer all output and send it at the end
 110                 # XXX: even better, redirect to appropriate page
 111                 #      depending on what command was run
 112                 common_show_header(_('Command results'));
 113                 common_element('p', NULL, $text);
 114                 common_show_footer();
 115         }
 116
 117         function error($user, $text) {
 118                 common_user_error($text);
 119         }
 120 }
 121
 122 class MailChannel extends Channel {
 123
 124         var $addr = NULL;
 125
 126         function source() {
 127                 return 'mail';
 128         }
 129
 130         function __construct($addr=NULL) {
 131                 $this->addr = $addr;
 132         }
 133
 134         function on($user) {
 135                 return $this->set_notify($user, 1);
 136         }
 137
 138         function off($user) {
 139                 return $this->set_notify($user, 0);
 140         }
 141
 142         function output($user, $text) {
 143
 144                 $headers['From'] = $user->incomingemail;
 145                 $headers['To'] = $this->addr;
 146
 147                 $headers['Subject'] = _('Command complete');
 148
 149                 return mail_send(array($this->addr), $headers, $text);
 150         }
 151
 152         function error($user, $text) {
 153
 154                 $headers['From'] = $user->incomingemail;
 155                 $headers['To'] = $this->addr;
 156
 157                 $headers['Subject'] = _('Command failed');
 158
 159                 return mail_send(array($this->addr), $headers, $text);
 160         }
 161
 162         function set_notify($user, $value) {
 163                 $orig = clone($user);
 164                 $user->smsnotify = $value;
 165                 $result = $user->update($orig);
 166                 if (!$result) {
 167                         common_log_db_error($user, 'UPDATE', __FILE__);
 168                         return false;
 169                 }
 170                 return true;
 171         }
 172 }