#!/usr/bin/env php

 <?php

 /*

  * Update Majordomo mailinglists with data from egroupware

  * Each mailinglist is filled with users from one egroupware group.

  *

  * Copyright 2010  Philipp Wagner <mail@philipp-wagner.com>

  *

  * 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 <http://www.gnu.org/licenses/>.

  */

 require_once 'lib/Config.php';

 require_once 'lib/RpcService.php';

 require_once 'lib/WhoJob.php';

 require_once 'lib/SubscribeJob.php';

 require_once 'lib/UnsubscribeJob.php';

 // config

 $config = &Config::getInstance();

 $config->setConfigFile('config.ini');

 /**

  * Wait max. 120s for a result of $job

  * 

  * @param Job $job

  * @param string $uuid

  * @return mixed

  */

 function wait_for_results(Job &$job)

 {

     $cnt = 0;

     echo '(I) Waiting for response ';

     do {

         $res = $job->checkResults();

         echo '.';

         if ($res['status'] === Job::STATUS_NOT_READY) {

             sleep(1);

         }

     } while ($cnt++ < 120 && $res['status'] === Job::STATUS_NOT_READY);

     echo " done\n";

     return $res;

 }

 function p_mysql_query($query)

 {

     if (!($res = mysql_query($query))) {

         echo "Query failed! Query was: $query\n".

           "MySQL error message was: ".mysql_error()."\n";

     }

     return $res;

 }

 if (!mysql_connect($config->getValue('egroupware/db_server'), 

                    $config->getValue('egroupware/db_user'),

                    $config->getValue('egroupware/db_password'))) {

     echo 'DB connection failed.';

     exit(1);

 }

 if (!mysql_select_db($config->getValue('egroupware/db_database'))) {

     echo 'Unable to select DB.';

     exit(1);

 }

 $lists = $config->getValue(('egroupware-lists'));

 foreach ($lists as $listName => $groupId) {

     echo "(I) Processing list $listName\n";

     $q = "SELECT account_lid, n_family, n_given, contact_email

           FROM `egw_acl`

           LEFT JOIN egw_accounts ON acl_account = account_id

           LEFT JOIN egw_addressbook USING(account_id)

           WHERE acl_appname = 'phpgw_group' AND

                 `acl_location` = '-$groupId'";

     ($res = p_mysql_query($q)) || exit(1);

     $users = array();

     while ($user = mysql_fetch_array($res, MYSQL_ASSOC)) {

         $users[] = $user['contact_email'];

     }

     // get existing users on list (3 tries)

     $success = true;

     $cnt = 1;

     do {

         echo "(I) Getting existing users on the list (try $cnt)\n";

         $wj = new WhoJob;

         $uuid = $wj->go(array('list' => $listName));

         echo "(I) Executing job with ID $uuid.\n";

         $res = wait_for_results($wj);

         if ($res['status'] !== Job::STATUS_SUCCESS) {

             $success = false;

             echo "(E) Getting all users from list $listName failed.\n";

         } else {

             $existingUsers = $res['result'];

         }

     } while ($cnt++ < 4 && !$success);

     if (!$success) {

         echo "(E) Unable to get existing users from list in 3 tries, giving up.\n";

         continue;

     }

     // unsubscribe existing users

     if (empty($existingUsers)) {

         echo "(I) No existing users to unsubscribe.\n";

     } else {

         $success = true;

         $cnt = 1;

         do {

             echo "(I) Unsubscribing existing users (try $cnt)\n";

             $uj = new UnsubscribeJob;

             $params = array(

                 'list' => $listName,

                 'users' => $existingUsers

             );

             $uuid = $uj->go($params);

             echo "(I) Executing job with ID $uuid.\n";

             $res = wait_for_results($uj);

             if ($res['status'] !== Job::STATUS_SUCCESS) {

                 $success = false;

                 echo "(E) Unsubscribing all users from $listName failed.\n";

                 var_dump($res);

             }

         } while ($cnt++ < 4 && !$success);

         if (!$success) {

             echo "(E) Unable to unsubscribe users from list in 3 tries, giving up.\n";

             continue;

         }

     }

     // subscribe new users

     if (empty($users)) {

         echo "(I) No new users to subscribe.\n";

     } else {

         $success = true;

         $cnt = 1;

         do {

             echo "(I) Subscribing new users\n";

             $sj = new SubscribeJob;

             $params = array(

                 'list' => $listName,

                 'users' => $users

             );

             $uuid = $sj->go($params);

             echo "(I) Executing job with ID $uuid.\n";

             $res = wait_for_results($sj);

             if ($res['status'] !== Job::STATUS_SUCCESS) {

                 $success = false;

                 echo "(E) Subscribing new users to $listName failed.\n";

                 var_dump($res);

             }

         } while ($cnt++ < 4 && !$success);

         if (!$success) {

             echo "(E) Houston, we have a problem. All users unsubscribed, ".

                  "but unable to subscribe the new ones. List empty?! ".

                  "Stopping update! Manual intervention required.\n";

             exit(1);

         }

     }

 }

 echo "(I) All lists updated!\n";