AlternC/src/do_actions.php

#!/usr/bin/php -q
<?php
/*
   $Id: do_actions.php,v 1.0 2013/04/19 13:40:32 axel Exp $
   ----------------------------------------------------------------------
   AlternC - Web Hosting System
   Copyright (C) 2002 by the AlternC Development Team.
   http://alternc.org/
   ----------------------------------------------------------------------
   Based on:
   Valentin Lacambre's web hosting softwares: http://altern.org/
   ----------------------------------------------------------------------
   LICENSE

   This program is free software; you can redistribute it and/or
   modify it under the terms of the GNU General Public License (GPL)
   as published by the Free Software Foundation; either version 2
   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.

   To read the license please visit http://www.gnu.org/copyleft/gpl.html
   ----------------------------------------------------------------------
   Original Author of file: Axel Roger
   Purpose of file: Do planed actions on files/directories.
   ----------------------------------------------------------------------
 */
/**
 * This script check the MySQL DB for actions to do, and do them one by one.
 *
 * @copyright AlternC-Team 2002-2013 http://alternc.org/
 */

// Put this var to 1 if you want to enable debug prints
$debug=1;

// Debug function that print infos
function d($mess){
  global $debug;
  if ($debug == 1)
    echo "$mess\n";
}

require_once("/usr/share/alternc/panel/class/config_nochk.php");

$LOCK_FILE='/var/run/alternc/do_actions_cron.lock';
$SCRIPT='/usr/bin/php do_actions.php';
$MY_PID=getmypid();

// Check if script isn't already running
if (file_exists($LOCK_FILE) !== false){
    d("Lock file already exists. ");
    // Check if file is in process list
    $PID=file_get_contents($LOCK_FILE);
    d("My PID is $MY_PID, PID in the lock file is $PID");
    if ($PID == exec("pidof $SCRIPT | tr ' ' '\n' | grep -v $MY_PID")){
      // Previous cron is not finished yet, just exit
      d("Previous cron is already running, we just exit and let it finish :-)");
      exit(0);
    }else{
      // Previous cron failed!
      d("No process with PID $PID found! Previous cron failed...\nRemoving lock file and trying to process the failed action...");
      // Delete the lock and continue to the next action
      unlink($LOCK_FILE);

      // Lock with the current script's PID
      d("Lock the script...");
      if (file_put_contents($LOCK_FILE,$MY_PID) === false){
        die("Cannot open/write $LOCK_FILE");
      }

      // Get the action that was processing when previous script failed
      while($cc=$action->get_job()){
        $c=$cc[0];
        // We can resume these types of action, so we reset the job to process it later
        d("Previous job was the n°".$c["id"]." : '".$c["type"]."'");
        if($c["type"] == "CREATE_FILE" || $c["type"] == "CREATE_DIR" || $c["type"] == "DELETE"){
          d("Reset of the job! So it will be resumed...");
          $action->reset_job($c["id"]);
        }else{
          // We can't resume the others types, notify the fail and finish this action
          d("Can't resume the job, finishing it with a fail status.");
          if(!$action->finish($c["id"],"Fail: Previous script crashed while processing this action, cannot resume it.")){
            d("FINISH FAILED!");
            break; // Else we go into an infinite loop... AAAAHHHHHH
          }
        }
      }
    }
}else{
  // Lock with the current script's PID
  d("Lock the script...");
  if (file_put_contents($LOCK_FILE,$MY_PID) === false){
    die("Cannot open/write $LOCK_FILE");
  }
}

//We get the next action to do
while ($rr=$action->get_action()){
  $r=$rr[0];
  $return="OK";
  // We lock the action
  d("-----------\nBeginning action n°".$r["id"]);
  $action->begin($r["id"]);
  // We process it
  $params=unserialize($r["parameters"]);
  // Remove all previous error message...
  @trigger_error("");
  // We exec with the specified user
  d("Executing action '".$r["type"]."' with user '".$r["user"]."'");
  // For now, this script only work for user 'root'
  if($r["user"] != "root"){
    if(exec("su ".$r["user"])){ // TODO
      d("Login successfull, now processing the action...");
    }else{
      d("Error: cannot login as ".$r["user"]);
      if(!$action->finish($r["id"],"Fail: Cannot login as user ".$r["user"])){
        d("FINISH FAILED!");
        break; // Else we go into an infinite loop... AAAAHHHHHH
      }
      continue;
    }
  }
  switch ($r["type"]){
    case "CREATE_FILE" :
      @file_put_contents($params["file"],$params["content"]);
      break;
    case "CREATE_DIR" :
      // Create the directory and make parent directories as needed
      @mkdir($params["dir"],0777,true);
      break;
    case "DELETE" :
      // Delete file/directory and its contents recursively
      @exec("rm -rf ".$params["dir"]." 2>&1", $output);
      break;
    case "MOVE" :
      // If destination dir does not exists, create it
      if(!is_dir($params["dst"]))
        @mkdir($params["dst"],0777,true);
      @exec("mv -f ".$params["src"]." ".$params["dst"]." 2>&1", $output);
      break;
    case "PERMFIX" :
      // TODO 
      break;
    default :
      $output=array("Fail: Sorry dude, i don't know this type of action");
      break;
  }
  // Get the last error if exists.
  if(isset($output[0]))
    $return=$output[0];
  else
    if($error=error_get_last())
      if($error["message"]!="")
        $return=$error["message"];
  // We finished the action, notify the DB.
  d("Finishing... return value is : $return\n");
  if(!$action->finish($r["id"],addslashes($return))){
    d("FINISH FAILED!");
    break; // Else we go into an infinite loop... AAAAHHHHHH
  }
}

// Unlock the script
d("Unlock the script...");
unlink($LOCK_FILE);

// Exit this script
exit(0);
?>