haheute/friendica-addons
1
0
Fork 0
forked from friendica/friendica-addons
Code Pull requests Activity

pumpio: Mirror activated - not running by now

Browse source
This commit is contained in:
Michael Vogel 2013-05-09 15:08:08 +02:00
parent 1ce7483327
commit f74f3fae83
2 changed files with 26 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pumpio/pumpio.css
View file

@ -1,11 +1,11 @@
#pumpio-public-label, #pumpio-enable-label, #pumpio-username-label, #pumpio-servername-label, #pumpio-bydefault-label { #pumpio-mirror-label,#pumpio-public-label, #pumpio-enable-label, #pumpio-username-label, #pumpio-servername-label, #pumpio-bydefault-label {
float: left; float: left;
width: 200px; width: 200px;
margin-top: 10px; margin-top: 10px;
} }
#pumpio-public, #pumpio-checkbox, #pumpio-username, #pumpio-servername, #pumpio-bydefault { #pumpio-mirror,#pumpio-public, #pumpio-checkbox, #pumpio-username, #pumpio-servername, #pumpio-bydefault {
float: left; float: left;
margin-top: 10px; margin-top: 10px;
} }

31
pumpio/pumpio.php
View file

@ -192,6 +192,9 @@ function pumpio_settings(&$a,&$s) {
$public_enabled = get_pconfig(local_user(),'pumpio','public'); $public_enabled = get_pconfig(local_user(),'pumpio','public');
$public_checked = (($public_enabled) ? ' checked="checked" ' : ''); $public_checked = (($public_enabled) ? ' checked="checked" ' : '');
$mirror_enabled = get_pconfig(local_user(),'pumpio','mirror');
$mirror_checked = (($mirror_enabled) ? ' checked="checked" ' : '');
$servername = get_pconfig(local_user(), "pumpio", "host"); $servername = get_pconfig(local_user(), "pumpio", "host");
$username = get_pconfig(local_user(), "pumpio", "user"); $username = get_pconfig(local_user(), "pumpio", "user");
@ -230,6 +233,11 @@ function pumpio_settings(&$a,&$s) {
$s .= '<input id="pumpio-public" type="checkbox" name="pumpio_public" value="1" ' . $public_checked . '/>'; $s .= '<input id="pumpio-public" type="checkbox" name="pumpio_public" value="1" ' . $public_checked . '/>';
$s .= '</div><div class="clear"></div>'; $s .= '</div><div class="clear"></div>';
$s .= '<div id="pumpio-mirror-wrapper">';
$s .= '<label id="pumpio-mirror-label" for="pumpio-mirror">' . t('Mirror all public posts') . '</label>';
$s .= '<input id="pumpio-mirror" type="checkbox" name="pumpio_mirror" value="1" ' . $mirror_checked . '/>';
$s .= '</div><div class="clear"></div>';
$oauth_token = get_pconfig(local_user(), "pumpio", "oauth_token"); $oauth_token = get_pconfig(local_user(), "pumpio", "oauth_token");
$oauth_token_secret = get_pconfig(local_user(), "pumpio", "oauth_token_secret"); $oauth_token_secret = get_pconfig(local_user(), "pumpio", "oauth_token_secret");
@ -255,6 +263,7 @@ function pumpio_settings_post(&$a,&$b) {
set_pconfig(local_user(),'pumpio','host',$_POST['pumpio_host']); set_pconfig(local_user(),'pumpio','host',$_POST['pumpio_host']);
set_pconfig(local_user(),'pumpio','user',$_POST['pumpio_user']); set_pconfig(local_user(),'pumpio','user',$_POST['pumpio_user']);
set_pconfig(local_user(),'pumpio','public',$_POST['pumpio_public']); set_pconfig(local_user(),'pumpio','public',$_POST['pumpio_public']);
set_pconfig(local_user(),'pumpio','mirror',$_POST['pumpio_mirror']);
set_pconfig(local_user(),'pumpio','post_by_default',intval($_POST['pumpio_bydefault'])); set_pconfig(local_user(),'pumpio','post_by_default',intval($_POST['pumpio_bydefault']));
} }
@ -374,7 +383,7 @@ function pumpio_cron($a,$b) {
} }
logger('pumpio: cron_start'); logger('pumpio: cron_start');
$r = q("SELECT * FROM `pconfig` WHERE `cat` = 'pumpio' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() "); $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'pumpio' AND `k` = 'mirror' AND `v` = '1' ORDER BY RAND() ");
if(count($r)) { if(count($r)) {
foreach($r as $rr) { foreach($r as $rr) {
logger('pumpio: fetching for user '.$rr['uid']); logger('pumpio: fetching for user '.$rr['uid']);
@ -392,7 +401,7 @@ function pumpio_fetchtimeline($a, $uid) {
$csecret = get_pconfig($uid, 'pumpio', 'consumersecret'); $csecret = get_pconfig($uid, 'pumpio', 'consumersecret');
$otoken = get_pconfig($uid, 'pumpio', 'oauthtoken'); $otoken = get_pconfig($uid, 'pumpio', 'oauthtoken');
$osecret = get_pconfig($uid, 'pumpio', 'oauthsecret'); $osecret = get_pconfig($uid, 'pumpio', 'oauthsecret');
$lastid = get_pconfig($uid, 'pumpio', 'lastid'); $lastdate = get_pconfig($uid, 'pumpio', 'lastdate');
$hostname = get_pconfig($uid, 'pumpio','host'); $hostname = get_pconfig($uid, 'pumpio','host');
$username = get_pconfig($uid, "pumpio", "user"); $username = get_pconfig($uid, "pumpio", "user");
@ -420,16 +429,22 @@ function pumpio_fetchtimeline($a, $uid) {
'https://'.$hostname.'/api/user/'.$username.'/feed/major', 'https://'.$hostname.'/api/user/'.$username.'/feed/major',
'GET', array(), array('FailOnAccessError'=>true), $user); 'GET', array(), array('FailOnAccessError'=>true), $user);
$posts = array_reverse($items); $posts = array_reverse($user->items);
$initiallastdate = $lastdate;
$lastdate = 0;
if (count($posts)) { if (count($posts)) {
foreach ($posts as $post) { foreach ($posts as $post) {
if ($post->id_str > $lastid) // To-Do if (strtotime($post->published) <= $initiallastdate)
$lastid = $post->id_str; // To-Do
if ($first_time)
continue; continue;
if ($lastdate < strtotime($post->published))
$lastdate = strtotime($post->published);
//if ($first_time)
// continue;
if (!strpos($post->source, $application_name)) { if (!strpos($post->source, $application_name)) {
require_once('include/html2bbcode.php'); require_once('include/html2bbcode.php');
@ -451,4 +466,6 @@ function pumpio_fetchtimeline($a, $uid) {
} }
} }
if ($lastdate != 0)
set_pconfig($uid,'pumpio','lastdate', $lastdate);
} }