getTimezone()->getName() . "\n"); // echo($date->format($atom_format) . "\n"); return $date; } return NULL; } debug("Feed=$url\n"); debug("Queue=$queue\n"); debug("State=$state_file\n"); $state = NULL; if(is_readable($state_file)) { $state = file($state_file, FILE_IGNORE_NEW_LINES); $state = parse_date($state[0]); if(!$state) { echo("Unable to parse current state file.\n"); print_r(DateTime::getLastErrors()); } } $newest = NULL; libxml_use_internal_errors(true); $sxe = simplexml_load_file($url); if (!$sxe) { echo "Failed loading XML from $url\n"; foreach(libxml_get_errors() as $error) { echo $error->message, "\n"; } exit(1); } foreach($sxe->entry as $entry) { $id = $entry->id; $title = $entry->title; $published = $entry->published; $updated = $entry->updated; if($updated == NULL) { $updated = $published; } $updated = parse_date($updated); # echo "updated=" . $updated->format($format) . "\n"; if(!isset($id)) { echo "Invalid atom entry, missing from ."; continue; } if($updated === FALSE) { echo "Invalid atom entry, missing/invalid or from .\n"; continue; } if($state != NULL && $state >= $updated) { # echo "old entry: $id\n"; continue; } echo "New entry: $id\n"; if($newest == NULL || $newest < $updated) { $newest = $updated; } // TODO: think about encoding // $entry_file = tmpfile() or exit("Unable to open temporary file"); $entry_file = fopen("/tmp/mq/tmp-entry", "w"); fwrite($entry_file, $entry->asXML()) or exit("Unable to write xml"); $stat = fstat($entry_file); fseek($entry_file, 0); $headers = array( "Content-Length: " . $stat["size"], "Content-Type: application/atom+xml;type=entry" ); $curl = curl_init() or exit("Unable to allocate cURL object"); curl_setopt($curl, CURLOPT_URL, $queue); curl_setopt($curl, CURLOPT_VERBOSE, TRUE); curl_setopt($curl, CURLOPT_INFILE, $entry_file); curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST"); curl_setopt($curl, CURLOPT_HTTPHEADER, $headers); curl_exec($curl) or exit("Error while executing cURL"); // TODO: if success, pick out Location headers. fclose($entry_file); curl_close($curl); } if(isset($newest)) { file_put_contents($state_file, $newest->format($atom_format) . "\n"); } ?>