Steaming API in PHP using codebird

Dhuberry · 2017-02-02T11:35:35.392Z

Hi,
I would like to collect tweets lively using PHP and I want to store it in MongoDB datastore.
I have MongoDB connectivity to PHP and I created Webpage to simply display the tweets. I already worked in twitter4j package now I am using codebird for PHP. While I am working in JAVA, I don’t have any difficulty in storing tweets to db and also in JSON format.
But in PHP I don’t get correct format, here is my code for streaming api,

<?php
require_once 'src/codebird.php';
\Codebird\Codebird::setConsumerKey('***', '***');
$cb = \Codebird\Codebird::getInstance();
$cb->setToken("***", "***");

function some_callback($message)
{
    var_dump('inside callback');
    if ($message !== null) {
        print_r($message);
        flush();
    }
//1 minute window
   if(time()-$GLOBALS['time_start']>=60){
   return true;
}
    return false;
}
$cb->setStreamingCallback('some_callback');
$reply = $cb->statuses_filter('track=Windows');

If I execute this code, it will not return tweets in Json format. I want my tweets in json format to store in mongodb.
And what this ‘track=Windows’ means?
Please, Help me.

Prabha.

andypiper · 2017-02-02T14:22:39.619Z

The track parameter specifies what term you want to filter from the stream. I assume you’ve used this in your Java code?

When you say this is not returning results in JSON format, what kind of data is it actually returning?

Dhuberry · 2017-02-02T14:31:40.509Z

Hi Andy,
Yes, I have used in Java, in this case, windows is my search term.
My json result look like this,

string(15) "inside callback" string(15) "inside callback"

andypiper · 2017-02-02T15:21:05.323Z

That looks like $message is a PHP object populated from the JSON. You’ll need to serialise it back into a JSON string in your PHP code.

Dhuberry · 2017-02-02T15:22:12.944Z

I tried these codes to return back,

//$cb->setReturnFormat(CODEBIRD_RETURNFORMAT_JSON);
$reply1 = json_encode(explode(’ ', $reply));
print_r($reply1);

Xeoncross · 2017-02-02T21:00:12.788Z

Like @andypiper said, the library decoded the result to a PHP object and you can easily convert it back.

$json = json_encode($message);
// You can see it with
// print $json . PHP_EOL;

Dhuberry · 2017-02-06T09:43:51.633Z

I tried json_encode(), but I got the same result.

Dhuberry · 2017-02-06T09:54:51.353Z

Is there any sample code for MongoDB and codebird connectivity.
I have searched many resources but no luck.
Help Please!!!

andypiper · 2017-02-06T12:06:17.050Z

This code works just fine for me, it prints out each message as both a PHP object and as a JSON string (obviously minus the configuration part with keys from the top of the file).

function some_callback($message)
{
    if ($message !== null) {
        print_r($message); // dumps out the object
	$json = json_encode($message); // converts the object to JSON
	print $json . PHP_EOL; // prints out the JSON
        flush(); 
    }

   // run for one minute
   if(time()-$GLOBALS['time_start']>=60){
   return true;
}
    return false;
}

$cb->setStreamingCallback('some_callback');
$GLOBALS['time_start'] = time(); // do not use GLOBALS in production
$reply = $cb->statuses_filter('track=Windows');

For MongoDB, this would be just a PHP + Mongo question rather than anything to do with Twitter or Codebird. I’d start with the very good PHP documentation on the topic.

Dhuberry · 2017-02-06T12:07:10.477Z

Thank you andy, it works for me now!!!