<?php

if(!@mkdir('lockdir')){
    print 'lockdir exists or isn\'t writable';
    exit;
}


if (!extension_loaded('mysql')){
    dl('mysql.so');
}

set_time_limit (0);
ignore_user_abort(true);

require_once('conf.php');

require_once('inc/common.php');
require_once('inc/HTTPClient.php');
require_once('inc/FeedParser.php');

$sql   = 'SELECT * FROM lalina_feeds';
$feeds = runSQL($sql);

foreach($feeds as $feed){
    print $feed['url'];
    $enc = '';
    $data = getFeed($feed,$enc);
print "data: ".strlen($data)."\n";
    if($data){
        $rss = new FeedParser($data,$enc);
print "parsed\n";
        updateFeedItems($feed,$rss);
print "updated\n";
    } 
    print "\n";
}


rmdir('lockdir');

//---------------------------------

function updateFeedItems($feed,$rss){
    if(empty($feed['name']) && !empty($rss->title)){
        $sql = "UPDATE lalina_feeds
                   SET name = '".addslashes($rss->title)."'
                 WHERE   id = '".addslashes($feed['id'])."'";
        runSQL($sql);
    }


    foreach($rss->items as $item){
        $sql = "INSERT IGNORE INTO lalina_items
                   SET feed_id = '".$feed['id']."',
                           url = '".addslashes($item['link'])."',
                         title = '".addslashes($item['title'])."',
                          body = '".addslashes($item['body'])."',
                            dt = FROM_UNIXTIME(".addslashes($item['datetime']).")";
        runSQL($sql);
        print ".";
        flush();
    }
}

function getFeed($feed,&$enc){
    $http = new DokuHTTPClient();
    $http->timeout = 45;

    // prepare conditional request
    if($feed['lastmod']){
        $http->headers['If-Modified-Since'] = $feed['lastmod'];
    }
    if($feed['etag']){
        $http->headers['If-None-Match'] = $feed['etag'];
    }

print "sending request\n";
    // send request
    $http->sendRequest($feed['url']);
print "sending request done\n";

    if($http->error){
        print "ERROR ".$http->error."\n";
    }

    // check status
    if($http->status != 200){
        return '';
    }

    // save headers
    if($http->resp_headers['last-modified']){
        $sql = "UPDATE lalina_feeds SET lastmod = '".
               addslashes($http->resp_headers['last-modified']).
               "' WHERE id = ".$feed['id'];
        runSQL($sql);
    }

    if($http->resp_headers['etag']){
        $sql = "UPDATE lalina_feeds SET etag = '".
               addslashes($http->resp_headers['etag']).
               "' WHERE id = ".$feed['id'];
        runSQL($sql);
    }

    $ctype = $http->resp_headers['content-type'];
    if(preg_match('/charset=([\w\-]+)/i',$ctype,$match)){
        $enc = $match[1];
    }

    // return data
    return $http->resp_body;
}


//Setup VIM: ex: et ts=4 enc=utf-8 :
?>