mailmanspip.class.php

Go to the documentation of this file.

<?php
/* Copyright (C) 2002-2003  Rodolphe Quiedeville    <rodolphe@quiedeville.org>
 * Copyright (C) 2002-2003  Jean-Louis Bergamo      <jlb@j1b.org>
 * Copyright (C) 2004-2013  Laurent Destailleur     <eldy@users.sourceforge.net>
 * Copyright (C) 2004       Sebastien Di Cintio     <sdicintio@ressource-toi.org>
 * Copyright (C) 2004       Benoit Mortier          <benoit.mortier@opensides.be>
 * Copyright (C) 2009       Regis Houssin           <regis.houssin@inodbox.com>
 * Copyright (C) 2012       Marcos García           <marcosgdf@gmail.com>
 * Copyright (C) 2018       Frédéric France         <frederic.france@netlogic.fr>
 *
 * 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 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <https://www.gnu.org/licenses/>.
 */

require_once DOL_DOCUMENT_ROOT.'/core/class/commonobject.class.php';
require_once DOL_DOCUMENT_ROOT.'/categories/class/categorie.class.php';
require_once DOL_DOCUMENT_ROOT.'/core/lib/functions2.lib.php';
require_once DOL_DOCUMENT_ROOT.'/core/lib/date.lib.php';


class MailmanSpip
{
  public $db;

  public $error = '';

  public $errors = array();

  public $mladded_ok;
  public $mladded_ko;
  public $mlremoved_ok;
  public $mlremoved_ko;


  public function __construct($db)
  {
    $this->db = $db;
  }

  public function isSpipEnabled()
  {
    if (defined("ADHERENT_USE_SPIP") && (ADHERENT_USE_SPIP == 1)) {
      return true;
    }

    return false;
  }

  public function checkSpipConfig()
  {
    if (defined('ADHERENT_SPIP_SERVEUR') && defined('ADHERENT_SPIP_USER') && defined('ADHERENT_SPIP_PASS') && defined('ADHERENT_SPIP_DB')) {
      if (ADHERENT_SPIP_SERVEUR != '' && ADHERENT_SPIP_USER != '' && ADHERENT_SPIP_PASS != '' && ADHERENT_SPIP_DB != '') {
        return true;
      }
    }

    return false;
  }

  public function connectSpip()
  {
    $resource = getDoliDBInstance('mysql', ADHERENT_SPIP_SERVEUR, ADHERENT_SPIP_USER, ADHERENT_SPIP_PASS, ADHERENT_SPIP_DB, ADHERENT_SPIP_PORT);

    if ($resource->ok) {
      return $resource;
    }

    dol_syslog('Error when connecting to SPIP '.ADHERENT_SPIP_SERVEUR.' '.ADHERENT_SPIP_USER.' '.ADHERENT_SPIP_PASS.' '.ADHERENT_SPIP_DB, LOG_ERR);

    return false;
  }

  private function callMailman($object, $url, $list)
  {
    global $conf;

    //Patterns that are going to be replaced with their original value
    $patterns = array(
      '%LISTE%',
      '%EMAIL%',
      '%PASSWORD%',
      '%MAILMAN_ADMINPW%'
    );
    $replace = array(
      $list,
      $object->email,
      $object->pass,
      $conf->global->ADHERENT_MAILMAN_ADMINPW
    );

    $curl_url = str_replace($patterns, $replace, $url);
    dol_syslog('Calling Mailman: '.$curl_url);

    $result = getURLContent($curl_url);

    return $result['content'];
  }

  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function add_to_spip($object)
  {
    // phpcs:enable
    dol_syslog(get_class($this)."::add_to_spip");

    if ($this->isSpipEnabled()) {
      if ($this->checkSpipConfig()) {
        $mydb = $this->connectSpip();

        if ($mydb) {
          require_once DOL_DOCUMENT_ROOT.'/core/lib/security2.lib.php';
          $mdpass = dol_hash($object->pass);
          $htpass = crypt($object->pass, makesalt());
          $query = "INSERT INTO spip_auteurs (nom, email, login, pass, htpass, alea_futur, statut) VALUES(\"".dolGetFirstLastname($object->firstname, $object->lastname)."\",\"".$object->email."\",\"".$object->login."\",\"$mdpass\",\"$htpass\",FLOOR(32000*RAND()),\"1comite\")";

          $result = $mydb->query($query);

          $mydb->close();

          if ($result) {
            return 1;
          } else {
            $this->error = $mydb->lasterror();
          }
        } else {
          $this->error = 'Failed to connect to SPIP';
        }
      } else {
        $this->error = 'BadSPIPConfiguration';
      }
    } else {
      $this->error = 'SPIPNotEnabled';
    }

    return 0;
  }

  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function del_to_spip($object)
  {
    // phpcs:enable
    dol_syslog(get_class($this)."::del_to_spip");

    if ($this->isSpipEnabled()) {
      if ($this->checkSpipConfig()) {
        $mydb = $this->connectSpip();

        if ($mydb) {
          $query = "DELETE FROM spip_auteurs WHERE login = '".$mydb->escape($object->login)."'";

          $result = $mydb->query($query);

          $mydb->close();

          if ($result) {
            return 1;
          } else {
            $this->error = $mydb->lasterror();
          }
        } else {
          $this->error = 'Failed to connect to SPIP';
        }
      } else {
        $this->error = 'BadSPIPConfiguration';
      }
    } else {
      $this->error = 'SPIPNotEnabled';
    }

    return 0;
  }

  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function is_in_spip($object)
  {
    // phpcs:enable
    if ($this->isSpipEnabled()) {
      if ($this->checkSpipConfig()) {
        $mydb = $this->connectSpip();

        if ($mydb) {
          $query = "SELECT login FROM spip_auteurs WHERE login = '".$mydb->escape($object->login)."'";

          $result = $mydb->query($query);

          if ($result) {
            if ($mydb->num_rows($result)) {
              // nous avons au moins une reponse
              $mydb->close();
              return 1;
            } else {
              // nous n'avons pas de reponse => n'existe pas
              $mydb->close();
              return 0;
            }
          } else {
            $this->error = $mydb->lasterror();
            $mydb->close();
          }
        } else {
          $this->error = 'Failed to connect to SPIP';
        }
      } else {
        $this->error = 'BadSPIPConfiguration';
      }
    } else {
      $this->error = 'SPIPNotEnabled';
    }

    return -1;
  }

  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function add_to_mailman($object, $listes = '')
  {
    // phpcs:enable
    global $conf, $langs, $user;

    dol_syslog(get_class($this)."::add_to_mailman");

    $this->mladded_ok = array();
    $this->mladded_ko = array();

    if (!function_exists("curl_init")) {
      $langs->load("errors");
      $this->error = $langs->trans("ErrorFunctionNotAvailableInPHP", "curl_init");
      return -1;
    }

    if ($conf->adherent->enabled) { // Synchro for members
      if (!empty($conf->global->ADHERENT_MAILMAN_URL)) {
        if ($listes == '' && !empty($conf->global->ADHERENT_MAILMAN_LISTS)) {
          $lists = explode(',', $conf->global->ADHERENT_MAILMAN_LISTS);
        } else {
          $lists = explode(',', $listes);
        }

        $categstatic = new Categorie($this->db);

        foreach ($lists as $list) {
          // Filter on type something (ADHERENT_MAILMAN_LISTS = "mailinglist0,TYPE:typevalue:mailinglist1,CATEG:categvalue:mailinglist2")
          $tmp = explode(':', $list);
          if (!empty($tmp[2])) {
            $list = $tmp[2];
            if ($object->element == 'member' && $tmp[0] == 'TYPE' && $object->type != $tmp[1]) {    // Filter on member type label
              dol_syslog("We ignore list ".$list." because object member type ".$object->type." does not match ".$tmp[1], LOG_DEBUG);
              continue;
            }
            if ($object->element == 'member' && $tmp[0] == 'CATEG' && !in_array($tmp[1], $categstatic->containing($object->id, 'member', 'label'))) {    // Filter on member category
              dol_syslog("We ignore list ".$list." because object member is not into category ".$tmp[1], LOG_DEBUG);
              continue;
            }
          }

          //We call Mailman to subscribe the user
          $result = $this->callMailman($object, $conf->global->ADHERENT_MAILMAN_URL, $list);

          if ($result === false) {
            $this->mladded_ko[$list] = $object->email;
            return -2;
          } else {
            $this->mladded_ok[$list] = $object->email;
          }
        }
        return count($lists);
      } else {
        $this->error = "ADHERENT_MAILMAN_URL not defined";
        return -1;
      }
    }
  }

  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function del_to_mailman($object, $listes = '')
  {
    // phpcs:enable
    global $conf, $langs, $user;

    dol_syslog(get_class($this)."::del_to_mailman");

    $this->mlremoved_ok = array();
    $this->mlremoved_ko = array();

    if (!function_exists("curl_init")) {
      $langs->load("errors");
      $this->error = $langs->trans("ErrorFunctionNotAvailableInPHP", "curl_init");
      return -1;
    }

    if ($conf->adherent->enabled) { // Synchro for members
      if (!empty($conf->global->ADHERENT_MAILMAN_UNSUB_URL)) {
        if ($listes == '' && !empty($conf->global->ADHERENT_MAILMAN_LISTS)) {
          $lists = explode(',', $conf->global->ADHERENT_MAILMAN_LISTS);
        } else {
          $lists = explode(',', $listes);
        }

        $categstatic = new Categorie($this->db);

        foreach ($lists as $list) {
          // Filter on type something (ADHERENT_MAILMAN_LISTS = "mailinglist0,TYPE:typevalue:mailinglist1,CATEG:categvalue:mailinglist2")
          $tmp = explode(':', $list);
          if (!empty($tmp[2])) {
            $list = $tmp[2];
            if ($object->element == 'member' && $tmp[0] == 'TYPE' && $object->type != $tmp[1]) {    // Filter on member type label
              dol_syslog("We ignore list ".$list." because object member type ".$object->type." does not match ".$tmp[1], LOG_DEBUG);
              continue;
            }
            if ($object->element == 'member' && $tmp[0] == 'CATEG' && !in_array($tmp[1], $categstatic->containing($object->id, 'member', 'label'))) {    // Filter on member category
              dol_syslog("We ignore list ".$list." because object member is not into category ".$tmp[1], LOG_DEBUG);
              continue;
            }
          }

          //We call Mailman to unsubscribe the user
          $result = $this->callMailman($object, $conf->global->ADHERENT_MAILMAN_UNSUB_URL, $list);

          if ($result === false) {
            $this->mlremoved_ko[$list] = $object->email;
            return -2;
          } else {
            $this->mlremoved_ok[$list] = $object->email;
          }
        }
        return count($lists);
      } else {
        $this->error = "ADHERENT_MAILMAN_UNSUB_URL not defined";
        return -1;
      }
    }
  }
}