messages.php

Go to the documentation of this file.

<?PHP
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 * This file is part of Travelsized CMS
 *              A content management system with modules, based on wiki syntax
 *
 * Author: Dan Jensen <admin@leinir.dk>
 * Copyright 2003/2004
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * The GNU General Public License is available at: http://www.gnu.org/copyleft/
 * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */

function sendMessage($username, $subject, $message, $from, $messagetype = "email") {
        switch( $messagetype )
        {
        default: // Email
                if( mail( getUserInfo( $username, "email" ), $subject, $message, "From: " . getUserInfo( $from, "name") . " <" . getUserInfo( $from, "email" ) . ">" . "\r\n" . "X-Mailer: PHP/" . phpversion() ) )
                        return true;
        }
        
        
        return false; // If we get to here, that means the message was not accepted for delivery
}

class subscriptionsManager extends lockableClass
{
        var $subscriptions;                
        var $updates;                      
        
        var $filename = "";
        var $updatesFilename = "";
        
        function subscriptionsManager()
        {
                global $setup_folder;
                $this->lockfile = "$setup_folder/subscriptions.lock";
                $this->filename = "$setup_folder/subscriptions.php";
                $this->updatesFilename = "$setup_folder/updates.php";
                
                $this->load();
                
                if( $_REQUEST["globalID"] != "" )
                {
                        if( $_REQUEST["subscribe"] == "yes" )
                                $this->subscribe( currentUser(), $_REQUEST["globalID"] );
                        else if( $_REQUEST["subscribe"] == "no" )
                                $this->unsubscribe( currentUser(), $_REQUEST["globalID"] );
                }
        }
        
        function load()
        {
                if( file_exists( $this->filename ) )
                        include $this->filename;
                if( ! is_array( $subscriptions ) )
                        $this->subscriptions = array();
                else
                        $this->subscriptions = $subscriptions;
                
                if( file_exists( $this->updatesFilename ) )
                        include $this->updatesFilename;
                if( ! is_array( $updates ) )
                        $this->updates = array();
                else
                        $this->updates = $updates;
                
                return true;
        }
        
        function save()
        {
                if( file_exists( $this->filename ) )
                        unlink( $this->filename );
                
                $returnval = file_put_contents( $this->filename, array_export( $this->subscriptions, "subscriptions" ) );
                
                if( file_exists( $this->updatesFilename ) )
                        unlink( $this->updatesFilename );
                
                $returnval = file_put_contents( $this->updatesFilename, array_export( $this->updates, "updates" ) );
                
                return $returnval;
        }
        
        function isSubscribed( $username, $globalID )
        {
                if( array_key_exists( $globalID, $this->subscriptions ) )
                        if( array_key_exists( $username, $this->subscriptions[$globalID] ) )
                                return true;
                
                return false;
        }
        
        function parentSubscribed( $username, $globalID )
        {
                if( $globalID == "" )
                        return false;
                
                $parentID = substr( $globalID, 0, strrpos( $globalID, "/" ) );
                if( $this->isSubscribed( $username, $parentID ) )
                        return true;
                
                return $this->parentSubscribed( $username, $parentID );
        }
        
        function subscribe( $username, $globalID, $subscriptiontype = "email" )
        {
                $returnval = false;
                if( $this->lock() )
                {
                        $this->load();
                        $this->subscriptions[$globalID][$username][$subscriptiontype] = true;
                        $returnval = $this->save();
                        $this->unlock();
                }
                return $returnval;
        }
        
        function unsubscribe( $username, $globalID, $subscriptiontype = "" )
        {
                $returnval = false;
                if( $this->lock() )
                {
                        if( $subscriptiontype == "" )
                                unset( $this->subscriptions[$globalID][$username] );
                        else
                                unset( $this->subscriptions[$globalID][$username][$subscriptiontype] );
                        
                        foreach( $this->subscriptions as $globalID => $value )
                        {
                                if( count( $value ) < 1 )
                                        unset( $this->subscriptions[$globalID] );
                        }
                        $returnval = $this->save();
                        $this->unlock();
                }
                
                return $returnval;
        }
        
        function unsubscribeAll( $username )
        {
                $returnval = false;
                if( $this->lock() )
                {
                        foreach( $this->subscriptions as $key => $value )
                        {
                                if( array_key_exists( $username, $value ) )
                                        unset( $this->subscriptions[$key][$username] );
                        }
                        $returnval = $this->save();
                        $this->unlock();
                }
                return $returnval;
        }
        
        function listUserSubscriptions( $username )
        {
                $theSubscriptions = array();
                
                foreach( $this->subscriptions as $key => $value )
                {
                        if( array_key_exists( $username, $value ) )
                        {
                                foreach( $value[$username] as $subscriptiontype => $irrelevant )
                                {
                                        $theSubscriptions[$globalID][] = $subscriptiontype;
                                }
                        }
                }
                
                return $theSubscriptions;
        }
        
        function renameGlobalID( $renameFrom, $renameTo )
        {
                $returnval = false;
                if( $this->lock() )
                {
                        $this->load();
                        
                        if( array_key_exists( $renameFrom, $this->subscriptions ) )
                        {
                                $tempSubscriptions = $this->subscriptions[$renameFrom];
                                unset( $this->subscriptions[$renameFrom] );
                                $this->subscriptions[$renameTo] = $tempSubscriptions;
                        }
                        
                        foreach( $this->updates as $key => $value )
                                if( $value["globalID"] == $renameFrom )
                                        $this->updates[$key]["globalID"] = $renameTo;
                        
                        $returnval = $this->save();
                        $this->unlock();
                }
                return $returnval;
        }
        
        function removeGlobalID( $globalID, $notify = false )
        {
                $returnval = false;
                if( $this->lock() )
                {
                        if( is_string( $notify ) )
                        {
                                foreach( $this->subscriptions[$globalID] as $username => $user )
                                {
                                        foreach( $user as $subscriptiontype => $irrelevant )
                                                sendMessage( $username, i18n("Subscription item removed"), i18n("The item ##0## has been removed, and your subscription removed. Message as follows: ##1##", array( $globalID, $notify ) ), "admin", $subscriptiontype );
                                }
                        }
                        
                        unset( $this->subscriptions[$globalID] );
                        
                        foreach( $this->updates as $key => $value )
                                if( $value["globalID"] == $globalID )
                                        unset($this->updates[$key]);
                        
                        $returnval = $this->save();
                        $this->unlock();
                }
                return $returnval;
        }
        
        function listSubscribers( $globalID )
        {
                $theSubscribers = array();
                
                if( array_key_exists( $globalID, $this->subscriptions ) )
                {
                        foreach( $this->subscriptions[$globalID] as $username => $irellevant )
                                $theSubscribers[] = $username;
                }
                
                return $theSubscribers;
        }
        
        function notifySubscribers( $globalID, $subject, $message )
        {
                $success = true;
                
                if( array_key_exists( $globalID, $this->subscriptions ) )
                {
                        foreach( $this->subscriptions[$globalID] as $username => $user )
                        {
                                foreach( $user as $subscriptiontype => $irrelevant )
                                        if( ! $this->parentSubscribed( $username, $globalID ) && ! sendMessage( $username, $subject, $message, "admin", $subscriptiontype ) )
                                                $success = false;
                        }
                }
                
                $parentID = substr( $globalID, 0, strrpos( $globalID, "/" ) );
                if( $parentID != "" )
                        $this->notifySubscribers( $parentID, $subject, $message );
                
                return $success;
        }
        
        function handle( $globalID, $owner, $viewLevel, $subject = "", $message = "" )
        {
                $timestamp = time();
                
                if( $subject == "" )
                        $subject = i18n( "Update on ##0##", array( $globalID ) );
                
                if( $message == "" )
                        $message = i18n( "The item ##0## has been updated on ##1##", array( $globalID, formatTime( $timestamp ) ) );
                
                if( $this->lock() )
                {
                        $this->load();
                        $this->updates[] = array(
                                "timestamp" => $timestamp,
                                "globalID" => $globalID,
                                "subject" => $subject,
                                "message" => $message,
                                "owner" => $owner,
                                "viewLevel" => $viewLevel
                                );
                        
                        while( count( $this->updates ) > 10000 )
                                array_shift( $this->updates );
                        
                        $this->save();
                        $this->unlock();
                }
                
                return $this->notifySubscribers( $globalID, $subject, $message );
        }
        
        function renderSubscribeControl( $globalID, $dataOnly = false, $extraClass = "" )
        {
                if( $this->parentSubscribed( currentUser(), $globalID ) )
                        return "<span class=\"subscriptioncontrol command-disabled\">" . i18n("(Parent subscribed)") . "</span>";
                else
                {
                        if( $this->isSubscribed( currentUser(), $globalID ) )
                        {
                                $subscribe = "no";
                                $title = i18n("Unsubscribe");
                                $description = i18n("Unsubscribe from ##0##", array($globalID) );
                        }
                        else
                        {
                                $subscribe = "yes";
                                $title = i18n("Subscribe");
                                $description = i18n("Subscribe to ##0##", array($globalID) );
                        }
                        
                        $url = thisPageURL( false, true, array( "subscribe" => $subscribe ) );
                        
                        if( isAuth() )
                                $renderedControl = drawCommand( $title, $description, $url, $extraClass );
                        
                        return $dataOnly ? array( $title, $description, $url ) : "<span class=\"subscriptioncontrol\">" . $renderedControl . "</span>";
                }
        }
}
?>

---