id = $channel->id;
$this->site = $channel->site;
$this->file = $channel->file;
$this->url = $channel->url;
$this->contact = $channel->contact;
$this->timestamp = $channel->timestamp;
// Check to see whether we have to update our headlines first:
if (time() - $this->timestamp > $timout) $this->url2sql();
// Read headlines:
$result = db_query("SELECT * FROM headlines WHERE id = $this->id ORDER BY number");
while ($headline = db_fetch_object($result)) {
array_push($this->headlines, "link\">$headline->title");
}
}
else {
$this->site = $site;
$this->url = $url;
$this->file = $file;
$this->contact = $contact;
}
}
function rdf2sql($timout = 10) {
if ($this->file) {
// Decode URL:
$url = parse_url($this->file);
$host = $url[host];
$port = $url[port] ? $url[port] : 80;
$path = $url[path];
// print "
Debug: $url - $host - $port - $path
";
// Retrieve data from website:
$fp = fsockopen($host, $port, &$errno, &$errstr, $timout);
if ($fp) {
// Get data from URL:
fputs($fp, "GET $path HTTP/1.0\n");
fputs($fp, "User-Agent: headline grabber\n");
fputs($fp, "Host: ". $host ."\n");
fputs($fp, "Accept: */*\n\n");
while(!feof($fp)) $data .= fgets($fp, 128);
// print "
$data
";
if (strstr($data, "200 OK")) {
// Remove existing entries:
$result = db_query("DELETE FROM headlines WHERE id = $this->id");
// Strip all 'junk':
$data = ereg_replace("", "", $data);
$data = ereg_replace("", $data);
$number = 0;
for (reset($items); $item = current($items); next($items)) {
// Extract data:
$link = ereg_replace(".*", "", $item);
$link = ereg_replace(".*", "", $link);
$title = ereg_replace(".*", "", $item);
$title = ereg_replace(".*", "", $title);
// Clean headlines:
$title = stripslashes($title);
// Count the number of stories:
$number += 1;
// Insert item in database:
$result = db_query("INSERT INTO headlines (id, title, link, number) VALUES('". check_input($this->id) ."', '". check_input($title) ."', '". check_input($link) ."', '". check_input($number) ."')");
}
// Mark channels as being updated:
$result = db_query("UPDATE channel SET timestamp = '". time() ."' WHERE id = $this->id");
$this->timestamp = time();
}
else print "RDF parser: 404 error?
$data
";
}
}
}
function rss2sql($timout = 10) {
print "backend->rss2sql : TODO ";
}
function xml2sql($timout = 10) {
print "backend->xml2sql : TODO ";
}
function url2sql($timout = 10) {
if (strstr($this->file, ".rdf")) $this->rdf2sql($timout);
if (strstr($this->file, ".rss")) $this->rss2sql($timout);
if (strstr($this->file, ".xml")) $this->xml2sql($timout);
}
function displayHeadlines($timout = 1800) {
global $theme;
// Get channel info:
$result = db_query("SELECT * FROM channel WHERE site = '$this->site'");
if ($this->id) {
// Check to see whether we have to update our headlines first:
if (time() - $this->timestamp > $timout) $this->url2sql();
// Grab headlines from database:
$result = db_query("SELECT * FROM headlines WHERE id = $this->id ORDER BY number");
while ($headline = db_fetch_object($result)) {
$content .= "