- json_decode: documentation ( source)
- serialize: documentation ( source)
<?php
include('start.php');
require_once('lib/Phirehose/Phirehose.php');
class FilterTrackConsumer extends Phirehose {
public $db;
public function setDB(&$db) {
$this->db = $db;
}
public function enqueueStatus($status) {
$tweets = new Tweets($this->db);
$data = json_decode($status, true);
$user_id = $data['user']['id'];
if($user_id) {
$raw_tweet = serialize($data);
$tweets->insertNewTweet($user_id, $raw_tweet);
}
}
}
$sc = new FilterTrackConsumer('John_Gald', 'yjdsqgfhjkm', Phirehose::METHOD_FILTER);
$sc->setDB($db);
$twitterIds = $users->getTwitterIds();
$sc->setFollow($twitterIds);
$sc->consume();
?>