limit rss streams to 100 items by default

[quix0rs-gnu-social.git] / xmppdaemon.php

diff --git a/xmppdaemon.php b/xmppdaemon.php
old mode 100644 (file)
new mode 100755 (executable)
index eab79a0..afe248c
--- a/xmppdaemon.php
+++ b/xmppdaemon.php
@@ -1,3 +1,4 @@
+#!/usr/bin/env php
 <?php
 /*
  * Laconica - a distributed open-source microblogging tool
@@ -27,27 +28,41 @@ define('INSTALLDIR', dirname(__FILE__));
 define('LACONICA', true);
 
 require_once(INSTALLDIR . '/lib/common.php');
-require_once('xmpp.php');
+require_once(INSTALLDIR . '/lib/jabber.php');
+
+# This is kind of clunky; we create a class to call the global functions
+# in jabber.php, which create a new XMPP class. A more elegant (?) solution
+# might be to use make this a subclass of XMPP.
 
 class XMPPDaemon {
 
-       function XMPPDaemon() {
-               static $attrs = array('server', 'port', 'user', 'password',
-                                          'resource');
+       function XMPPDaemon($resource=NULL) {
+               static $attrs = array('server', 'port', 'user', 'password', 'host');
 
                foreach ($attrs as $attr)
                {
                        $this->$attr = common_config('xmpp', $attr);
                }
+
+               if ($resource) {
+                       $this->resource = $resource;
+               } else {
+                       $this->resource = common_config('xmpp', 'resource') . 'daemon';
+               }
+
+               $this->log(LOG_INFO, "{$this->user}@{$this->server}/{$this->resource}");
        }
 
        function connect() {
-               $this->conn = new XMPP($this->server, $this->port, $this->user,
-                                                          $this->password, $this->resource);
+               $connect_to = ($this->host) ? $this->host : $this->server;
+
+               $this->log(LOG_INFO, "Connecting to $connect_to on port $this->port");
+
+               $this->conn = jabber_connect($this->resource);
+
                if (!$this->conn) {
                        return false;
                }
-               $this->conn->connect();
                return !$this->conn->disconnected;
        }
 
@@ -57,6 +72,7 @@ class XMPPDaemon {
                                                                                                                'end_stream', 'session_start'));
                        foreach($payloads as $event) {
                                $pl = $event[1];
+                               $this->log(LOG_DEBUG, "Received '$event[0]': " . print_r($pl, TRUE));
                                switch($event[0]) {
                                 case 'message':
                                        $this->handle_message($pl);
@@ -72,10 +88,35 @@ class XMPPDaemon {
                }
        }
 
+       function get_user($from) {
+               $user = User::staticGet('jabber', jabber_normalize_jid($from));
+               return $user;
+       }
+
+       function get_confirmation($from) {
+               $confirm = new Confirm_address();
+               $confirm->address = $from;
+               $confirm->address_type = 'jabber';
+               if ($confirm->find(TRUE)) {
+                       return $confirm;
+               } else {
+                       return NULL;
+               }
+       }
+
        function handle_message(&$pl) {
-               $user = User::staticGet('jabber', $pl['from']);
+               if ($pl['type'] != 'chat') {
+                       return;
+               }
+               if (strlen($pl['body']) == 0) {
+                       return;
+               }
+
+               $from = jabber_normalize_jid($pl['from']);
+               $user = $this->get_user($from);
+
                if (!$user) {
-                       $this->log(LOG_WARNING, 'Message from unknown user ' . $pl['from']);
+                       $this->log(LOG_WARNING, 'Message from unknown user ' . $from);
                        return;
                }
                if ($this->handle_command($user, $pl['body'])) {
@@ -141,34 +182,65 @@ class XMPPDaemon {
                                           ': ' . $last_error->message);
                        return;
                }
+               $notice->query('COMMIT');
                common_broadcast_notice($notice);
                $this->log(LOG_INFO,
                                   'Added notice ' . $notice->id . ' from user ' . $user->nickname);
        }
 
        function handle_presence(&$pl) {
-               $user = User::staticGet('jabber', $pl['from']);
-               if (!$user) {
-                       $this->log(LOG_WARNING, 'Message from unknown user ' . $pl['from']);
-                       return;
-               }
-               if ($user->updatefrompresence) {
-                       $this->add_notice($user, $pl);
+               $from = jabber_normalize_jid($pl['from']);
+               switch ($pl['type']) {
+                       case 'subscribe':
+                           # We let anyone subscribe
+                               $this->subscribed($from);
+                               $this->log(LOG_INFO,
+                                  'Accepted subscription from ' . $from);
+                               break;
+                       case 'subscribed':
+                       case 'unsubscribed':
+                       case 'unsubscribe':
+                               $this->log(LOG_INFO,
+                                  'Ignoring  "' . $pl['type'] . '" from ' . $from);
+                               break;
+                       default:
+                               if (!$pl['type']) {
+                                       $user = User::staticGet('jabber', $from);
+                                       if (!$user) {
+                                               $this->log(LOG_WARNING, 'Message from unknown user ' . $from);
+                                               return;
+                                       }
+                                       if ($user->updatefrompresence) {
+                                               $this->log(LOG_INFO, 'Updating ' . $user->nickname .
+                                                                                        ' status from presence.');
+                                               $this->add_notice($user, $pl);
+                                       }
+                               }
+                               break;
                }
        }
 
-       function handle_session(&$pl) {
-               $conn->presence($status="Send me a message to post a notice");
-       }
-
        function log($level, $msg) {
                common_log($level, 'XMPPDaemon('.$this->resource.'): '.$msg);
        }
+
+       function subscribed($to) {
+               jabber_special_presence('subscribed', $to);
+       }
+
+       function set_status($status) {
+               $this->log(LOG_INFO, 'Setting status to "' . $status . '"');
+               jabber_send_presence($status);
+       }
 }
 
-$daemon = new XMPPDaemon();
+$resource = ($argc > 1) ? $argv[1] : NULL;
+
+$daemon = new XMPPDaemon($resource);
 
 if ($daemon->connect()) {
+       $daemon->set_status("Send me a message to post a notice");
        $daemon->handle();
 }
+
 ?>