<?php
    /* Require configuration */
    require_once("config.php");
    /* Require libraries */
    require_once("SimplePie/simplepie.inc");
    /* Require database */
    require_once("db.php");
    /* Require statistic functions */
    require_once("statistics.php");
    class Suckr {
        
        public $out = "";
        
        function suckBlogs() {
            $statistics = new Statistics;
            $post_stat_id = $statistics->performSuck("post");
            $comment_stat_id = $statistics->performSuck("comment");
            global $db;
            $now = time();
            $query = "(SELECT posts, comments, course_guid, 'Nameless' as fullname, course_blog as blog, start_agregate as start FROM ".DB_PREFIX."educourses WHERE !deleted AND start_agregate<=".$now." AND stop_agregate>=".$now.") union all (SELECT p.posts as posts, p.comments as comments, p.course_guid as course_guid, CONCAT(p.firstname, ' ', p.lastname) as fullname, blog, c.start_agregate as start FROM ".DB_PREFIX."participants p LEFT JOIN ".DB_PREFIX."educourses c ON p.course_guid=c.course_guid WHERE c.start_agregate<=".$now." AND c.stop_agregate>=".$now.")";
            $result = $db->query($query);
            $posts_count = 0;
            $comments_count = 0;
            if(mysql_num_rows($result)) {
                while($feed = mysql_fetch_assoc($result)) {
                    $this->out .= "<h3>Course: ".$feed['blog']." (".$feed['course_guid'].") by ".$feed['fullname']."</h3>";
                    $posts_count = $posts_count + $this->suckFeed($feed['posts'], $feed['course_guid'], $feed['fullname'], $feed['start'], "post");
                    $comments_count = $comments_count + $this->suckFeed($feed['comments'], $feed['course_guid'], $feed['fullname'], $feed['start'], "comment");
                }
            }
            $log = $statistics->writeLog($this->out);
            if ($log) {
                $statistics->completeSuck($post_stat_id, $posts_count, $log);
                $statistics->completeSuck($comment_stat_id, $comments_count, $log);
            }
            if (!SILENT_MODE) {
                echo $this->out;
            }
        }
        
        function suckFeed($feed_url, $course, $author, $start, $type="post") {
            global $db;
 	    $feed_url = str_replace("https://", "http://", $feed_url);

            $feed = new SimplePie();
		    $feed->set_feed_url($feed_url);
			$feed->enable_cache(false);
		    $feed->set_output_encoding('UTF-8');
		    $feed->init();
		    $feed->handle_content_type();
		    $success = 0;
		    		
		    //XXX We do not handleerrors here, as invalid XML is processed fine, but might raise errors
		    //TODO Think about preprocessing Feed before giving it to SimplePie parser
		    //if ($feed->error()) error_log('Problems with RSS feed: ' . $feed->error());
		    $items = $feed->get_items(0, 0);
		   
			foreach ($items as $item) {
			    $title = $item->get_title();
			    $link = $item->get_permalink();
			    $date = $item->get_date('U');
			    $content = $item->get_content();
			    $base = $item->get_base();
			    $author_name = $author;
	            $f_author = $item->get_author();
	            $blogger_id = 0;
	            $f_author_name = 0;
	            $hidden = 0;
	            $status = "<span style='color:red'>was not added or updated in database due unknown problem</span>";
                if ($start>$date) {
                    $status = "<span style='color:red'>was not suitable, it has been written earlier than course started</span>";
                } else if (!strcmp(substr($item->get_description(), 0, 5), "[...]"))   {                      
                    $status = "<span style='color:red'>was not suitable, it is probably pingback</span>";
                } else {   
	                if (is_object($f_author)) {
	                    $f_author_name = $f_author->get_name();
	                    if (!$f_author_name) $f_author_name = 0;
	                    preg_match('@^(?:http://www.blogger.com/profile/)?([^/]+)@i', $f_author->get_link(), $matches);	                
	                    if (count($matches)>1 && is_numeric($matches[1])) {
	                        $blogger_id = $matches[1];
	                    }
	                }
                    if ($title && $link && $date && $content) {
                        if ($type=="post") {
                            preg_match('/This is your first post./', $content, $matches);
                            if (count($matches)>0 && (strcmp($matches[0], "This is your first post.") === 0)) {
                                $status .= " this is probably wordpress default post, and will be hidden";
                                $hidden = 1;
							}
							// See if posts exists, get hidden value if true
							$exists = $this->getHiddenByLink($link, $course);
							if (!$exists === false) {
								$hidden = $exists->hidden;
							}
                            $post_written = $this->writePost($title, $link, $base, $date, $content, $author_name, $blogger_id, $hidden);
                            $post_rel_written = $this->writePostRelation($course, $link, $hidden);
                            if ($post_written && $post_rel_written) {
                                $success++;
                                $status = "<span style='color:green'>was added or updated in database</span>";
                            }
                        } else {
                            preg_match('/Hi, this is a comment./', $content, $matches);
                            if (count($matches)>0 && (strcmp($matches[0], "Hi, this is a comment.") === 0)) {
                                $status .= " this is probably wordpress default comment, and will be hidden";
                                $hidden = 1;
							}
							// See if comment exists, get hidden value if true
							$exists = $this->getHiddenByLink($link, $course, 'comment');
							if (!$exists === false) {
								$hidden = $exists->hidden;
							}

                            // Check if post is already hidden, set the same for comment
                            if (!$hidden) {
                                $tmp_post_link = $db->getPostLinkByCommentLink($link);
                                if ($tmp_post_link) {
                                    $tmp_exists = $this->getHiddenByLink($tmp_post_link, $course, 'post');
                                    if (!$tmp_exists === false) {
                                        $hidden = $tmp_exists->hidden;
                                    }
                                }
                            }
                            $comment_written = $this->writeComment($title, $link, $base, $date, $content, $f_author_name, $blogger_id, $hidden);
                            $comment_rel_written = $this->writeCommentRelation($course, $link, $hidden);
                            if ($comment_written && $comment_rel_written) {
                                $success++;
                                $status = "<span style='color:green'>was added or updated in database</span>";
                            }
                        }
                    } else {
                        $status = "<span style='color:red'>was not added or updated in database because missing data: ";
                        if (!$title) $status .= "TITLE ";
                        if (!$link) $status .= "LINK ";
                        if (!$date) $status .= "DATE ";
                        if (!$content) $status .= "CONTENT ";
                        $status .= "</span>";    
                    }
                }
                $this->out .= "Related ".$type.": ".$link." - ".$status."<br />";
			}
		    // destroy feed
		    $feed->__destruct();
		    unset($feed);
		    return $success;
        }
        
        function writePostRelation($course, $link, $hidden) {
            global $db;
            $query = "INSERT IGNORE into ".DB_PREFIX."course_rels_posts (course_guid, link, hidden) values (".$course.", '".$link."', ".$hidden.")";
            return $db->query($query);  
        }
        
        function writeCommentRelation($course, $link, $hidden) {
            global $db;
            $query = "INSERT IGNORE into ".DB_PREFIX."course_rels_comments (course_guid, link, hidden) values (".$course.", '".$link."',".$hidden.")";
            return $db->query($query);  
        }
        
        function writePost($title, $link, $base, $date, $content, $author_name, $blogger_id, $hidden) {
            global $db;
            $data = array(
                'link' => $link,
                'base' => $base,
                'title' => $title,
                'date' => $date,
                'content' => $content,
                'author' => $author_name,
                'blogger_id' => $blogger_id,
                'modified' => 'NOW()'
            );
            return $db->insert(DB_PREFIX."posts", $data, array('link', 'base'));
        }
        
        function writeComment($title, $link, $base, $date, $content, $author_name, $blogger_id, $hidden) {
            global $db;
            $pre_query = "SELECT id, author FROM ".DB_PREFIX."posts WHERE '".$link."' LIKE CONCAT(link,'%')";
            $pre_result = $db->query($pre_query);
            $pre_res = mysql_fetch_array($pre_result);
            $data = array(
                'link' => $link,
                'base' => $base,
                'title' => $title,
                'date' => $date,
                'content' => $content,
                'author' => $author_name,
                'blogger_id' => $blogger_id,
                'post_id' => $pre_res['id'],
                'post_author' => $pre_res['author'],
                'modified' => 'NOW()'
            );
            return $db->insert(DB_PREFIX."comments", $data, array('link', 'base'));
		}

		// Returns object with attribute "hidden" or false
		function getHiddenByLink($link, $course_id, $type = 'post') {
			global $db;
			if (!$link || !in_array($type, array('post', 'comment'))) {
				return false;
			}
			$query = "SELECT hidden FROM ".DB_PREFIX."course_rels_".$type."s WHERE link = '".$link."' AND course_guid=".$course_id;
			$result = $db->query($query);
			if ($result) {
				return mysql_fetch_object($result);
			}

			return false;
		}
    
    }
?>