forked from friendica/deprecated-addons
94 lines
3.2 KiB
PHP
94 lines
3.2 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
require_once 'AppDotNet.php';
|
||
|
|
require_once 'EZsettings.php';
|
||
|
|
|
||
|
|
$app = new AppDotNet($app_clientId,$app_clientSecret);
|
||
|
|
|
||
|
|
// You need an app token to consume the stream, get the token returned by App.net
|
||
|
|
// (this also sets the token)
|
||
|
|
$token = $app->getAppAccessToken();
|
||
|
|
|
||
|
|
// getting a 400 error
|
||
|
|
// 1. first check to make sure you set your app_clientId & app_clientSecret correctly
|
||
|
|
// if that doesn't fix it, try this
|
||
|
|
// 2. It's possible you have hit your stream limit (5 stream per app)
|
||
|
|
// uncomment this to clear all the streams you've previously created
|
||
|
|
//$app->deleteAllStreams();
|
||
|
|
|
||
|
|
// create a stream
|
||
|
|
// if you already have a stream you can skip this step
|
||
|
|
// this stream is going to consume posts and stars (but not follows)
|
||
|
|
$stream = $app->createStream(array('post','star','user_follow'));
|
||
|
|
|
||
|
|
// you might want to save $stream['endpoint'] or $stream['id'] for later so
|
||
|
|
// you don't have to re-create the stream
|
||
|
|
print "stream id [".$stream['id']."]\n";
|
||
|
|
//$stream = $app->getStream(XXX);
|
||
|
|
|
||
|
|
// we need to create a callback function that will do something with posts/stars
|
||
|
|
// when they're received from the stream. This function should accept one single
|
||
|
|
// parameter that will be the php object containing the meta / data for the event.
|
||
|
|
|
||
|
|
/*
|
||
|
|
[meta] => Array
|
||
|
|
(
|
||
|
|
[timestamp] => 1352147672891
|
||
|
|
[type] => post/star/etc...
|
||
|
|
[id] => 1399341
|
||
|
|
)
|
||
|
|
// data is as you would expect it
|
||
|
|
*/
|
||
|
|
function handleEvent($event) {
|
||
|
|
global $counters;
|
||
|
|
$json=json_encode($event['data']);
|
||
|
|
$counters[$event['meta']['type']]++;
|
||
|
|
switch ($event['meta']['type']) {
|
||
|
|
case 'post':
|
||
|
|
print $event['meta']['is_deleted']?'p':'P';
|
||
|
|
break;
|
||
|
|
case 'star':
|
||
|
|
print $event['meta']['is_deleted']?'_':'*';
|
||
|
|
break;
|
||
|
|
case 'user_follow':
|
||
|
|
print $event['meta']['is_deleted']?'f':'F';
|
||
|
|
break;
|
||
|
|
case 'stream_marker':
|
||
|
|
print $event['meta']['is_deleted']?'/':'=';
|
||
|
|
break;
|
||
|
|
case 'message':
|
||
|
|
print $event['meta']['is_deleted']?'m':'M';
|
||
|
|
break;
|
||
|
|
case 'channel':
|
||
|
|
print $event['meta']['is_deleted']?'c':'C';
|
||
|
|
break;
|
||
|
|
case 'channel_subscription':
|
||
|
|
print $event['meta']['is_deleted']?'f':'F';
|
||
|
|
break;
|
||
|
|
default:
|
||
|
|
print "Unknwon type [".$event['meta']['type']."]\n";
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// register that function as the stream handler
|
||
|
|
$app->registerStreamFunction('handleEvent');
|
||
|
|
|
||
|
|
// open the stream for reading
|
||
|
|
$app->openStream($stream['endpoint']);
|
||
|
|
|
||
|
|
// now we want to process the stream. We have two options. If all we're doing
|
||
|
|
// in this script is processing the stream, we can just call:
|
||
|
|
// $app->processStreamForever();
|
||
|
|
// otherwise you can create a loop, and call $app->processStream($milliseconds)
|
||
|
|
// intermittently, like:
|
||
|
|
while (true) {
|
||
|
|
$counters=array('post'=>0,'star'=>0,'user_follow'=>0,'stream_marker'=>0,'message'=>0,'channel'=>0,'channel_subscription'=>0);
|
||
|
|
// now we're going to process the stream for awhile (60 seconds)
|
||
|
|
$app->processStream(60*1000000);
|
||
|
|
echo "\n";
|
||
|
|
// show some stats
|
||
|
|
echo date('H:i')." [",$counters['post'],"]posts [",$counters['star'],"]stars [",$counters['user_follow'],"]follow [",$counters['stream_marker'],"]mrkrs [",$counters['message'],"]msgs /min\n";
|
||
|
|
// then do something else...
|
||
|
|
}
|
||
|
|
?>
|