Twitter to syslog streamer

twitstream.php

<?php
/*
This has been used for testing a logstash install and searching infrastructure. It is a quick and dirty implementation of the twitter streaming api. A better way would be to do it with curl with callback handlers. Normal curl wont work as the stream doesn't have a proper end.
*/


set_time_limit(0);

$query_data = array('track' => '#devops', 'stall_warnings' => 'true');
$user = 'twitteraccount';     // replace with your account
$pass = 'twitterpassword';     // replace with your account

openlog("Twitstream", LOG_PID, LOG_LOCAL0);


$fp = fsockopen("ssl://stream.twitter.com", 443, $errno, $errstr, 30);
if(!$fp){
        print "$errstr ($errno)\n";
} else {
        $request = "GET /1/statuses/filter.json?" . http_build_query($query_data) . " HTTP/1.1\r\n";
        $request .= "Host: stream.twitter.com\r\n";
        $request .= "Authorization: Basic " . base64_encode($user . ':' . $pass) . "\r\n\r\n";
        fwrite($fp, $request);
        while(!feof($fp)){
                $json = fgets($fp);
                $data = json_decode($json, true);
                if($data){
                        //
                        unset($data['entities']);
                        $data['user']='@'.$data['user']['screen_name'].', '.$data['user']['name'].' - '.$data['user']['location'];
                        print_r($data);
                        syslog(LOG_INFO,json_encode($data));
                        //
                }
        }
        fclose($fp);
}