Mageia/Data/Cron.php

<?php

/**
*/
abstract class Mageia_Data_Cron
{
    function __construct($spec, $ts, $appdir, $logtmpdir)
    {
        $this->name     = $spec[0];
        $this->user     = $spec[1];
        $this->host     = $spec[2];
        $this->day_YMD  = date('Y-m-d', $ts);
        $this->day_AL   = date('d/M/Y', $ts);
        $this->appdir   = $appdir;

        $filename       = sprintf('%s_%s.log', $this->host, $this->day_YMD);
        $this->log_file = sprintf('%s/%s/%s', $this->appdir, $logtmpdir, $filename);

        $this->clean_log_file = $this->log_file . '.clean';
        $this->final_log      = sprintf('%s/final/%s/%s', $this->appdir, $this->name, $filename);
    }

    public final function run()
    {
        $this->fetch_log();
        $this->digest_log($this->log_file, $this->clean_log_file);
        $this->move_log();
        $this->cleanup();
    }
    
    private final function fetch_log()
    {
        $cmd = sprintf('ssh %s@%s grep "%s" /var/log/httpd/%s-access_log > %s',
            $this->user,
            $this->host,
            $this->day_AL,
            $this->host,
            $this->log_file
        );
        echo sprintf("Grep logs on %s for %s on %s...\n", $this->host, $this->name, $this->day_AL);
        exec($cmd, $out, $ret);
        if ($ret > 0) {
            die("Failed: $ret. Aborting.\n");
        }
    }

    public abstract function digest_log();

    /**
    */
    private final function move_log()
    {
        if (file_exists($this->clean_log_file)) {
            rename($this->clean_log_file, $this->final_log);
            echo "Publish.";
        }
        echo "\n";
    }

    /**
    */
    private final function cleanup()
    {
        file_exists($this->log_file) ? unlink($this->log_file) : null;
    }
}
1	<?php
2
3	/**
4	*/
5	abstract class Mageia_Data_Cron
6	{
7	function __construct($spec, $ts, $appdir, $logtmpdir)
8	{
9	$this->name = $spec[0];
10	$this->user = $spec[1];
11	$this->host = $spec[2];
12	$this->day_YMD = date('Y-m-d', $ts);
13	$this->day_AL = date('d/M/Y', $ts);
14	$this->appdir = $appdir;
15
16	$filename = sprintf('%s_%s.log', $this->host, $this->day_YMD);
17	$this->log_file = sprintf('%s/%s/%s', $this->appdir, $logtmpdir, $filename);
18
19	$this->clean_log_file = $this->log_file . '.clean';
20	$this->final_log = sprintf('%s/final/%s/%s', $this->appdir, $this->name, $filename);
21	}
22
23	public final function run()
24	{
25	$this->fetch_log();
26	$this->digest_log($this->log_file, $this->clean_log_file);
27	$this->move_log();
28	$this->cleanup();
29	}
30
31	private final function fetch_log()
32	{
33	$cmd = sprintf('ssh %s@%s grep "%s" /var/log/httpd/%s-access_log > %s',
34	$this->user,
35	$this->host,
36	$this->day_AL,
37	$this->host,
38	$this->log_file
39	);
40	echo sprintf("Grep logs on %s for %s on %s...\n", $this->host, $this->name, $this->day_AL);
41	exec($cmd, $out, $ret);
42	if ($ret > 0) {
43	die("Failed: $ret. Aborting.\n");
44	}
45	}
46
47	public abstract function digest_log();
48
49	/**
50	*/
51	private final function move_log()
52	{
53	if (file_exists($this->clean_log_file)) {
54	rename($this->clean_log_file, $this->final_log);
55	echo "Publish.";
56	}
57	echo "\n";
58	}
59
60	/**
61	*/
62	private final function cleanup()
63	{
64	file_exists($this->log_file) ? unlink($this->log_file) : null;
65	}
66	}