clones/friendica-addons
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

pumpio: endless loop in comment completetion should be solved. Bug when registering should be solved as well.

This commit is contained in:
Michael Vogel 2013-09-27 23:33:35 +02:00
parent 1f8617d372
commit e912b1fd2e
3 changed files with 49 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
jappixmini/jappixmini.php
View File

@ -498,11 +498,12 @@ function jappixmini_script(&$a,&$s) {
// get nickname // get nickname
$r = q("SELECT `username` FROM `user` WHERE `uid`=$uid"); $r = q("SELECT `username` FROM `user` WHERE `uid`=$uid");
$nickname = json_encode($r[0]["username"]); $nickname = json_encode($r[0]["username"]);
$groupchats = get_config('jappixmini','groupchats');
// add javascript to start Jappix Mini // add javascript to start Jappix Mini
$a->page['htmlhead'] .= "<script type=\"text/javascript\"> $a->page['htmlhead'] .= "<script type=\"text/javascript\">
jQuery(document).ready(function() { jQuery(document).ready(function() {
jappixmini_addon_start('$server', '$username', '$proxy', '$bosh', $encrypt, '$password', $nickname, $contacts_json, '$contacts_hash', $autoapprove, $autosubscribe); jappixmini_addon_start('$server', '$username', '$proxy', '$bosh', $encrypt, '$password', $nickname, $contacts_json, '$contacts_hash', $autoapprove, $autosubscribe, $groupchats);
}); });
</script>"; </script>";

3
jappixmini/lib.js
View File

@ -236,7 +236,7 @@ function jappixmini_addon_subscribe() {
sendSubscribe(xid, "subscribe"); sendSubscribe(xid, "subscribe");
} }
function jappixmini_addon_start(server, username, proxy, bosh, encrypted, password, nickname, contacts, contacts_hash, autoapprove, autosubscribe) { function jappixmini_addon_start(server, username, proxy, bosh, encrypted, password, nickname, contacts, contacts_hash, autoapprove, autosubscribe, groupchats) {
var handler = function(password){ var handler = function(password){
// check if settings have changed, reinitialize jappix mini if this is the case // check if settings have changed, reinitialize jappix mini if this is the case
var settings_identifier = str_sha1(server); var settings_identifier = str_sha1(server);
@ -261,6 +261,7 @@ function jappixmini_addon_start(server, username, proxy, bosh, encrypted, passwo
HOST_BOSH = bosh; HOST_BOSH = bosh;
// start jappix mini // start jappix mini
MINI_GROUPCHATS = groupchats;
MINI_NICKNAME = nickname; MINI_NICKNAME = nickname;
LOCK_HOST = "off"; LOCK_HOST = "off";
launchMini(true, false, server, username, password); launchMini(true, false, server, username, password);

71
pumpio/pumpio.php
View File

@ -39,6 +39,11 @@ function pumpio_content(&$a) {
return ''; return '';
} }
if (function_exists("apc_delete")) {
$toDelete = new APCIterator('user', APC_ITER_VALUE);
apc_delete($toDelete);
}
if (isset($a->argv[1])) if (isset($a->argv[1]))
switch ($a->argv[1]) { switch ($a->argv[1]) {
case "connect": case "connect":
@ -54,7 +59,7 @@ function pumpio_content(&$a) {
return $o; return $o;
} }
function pumpio_registerclient($a, $host) { function pumpio_registerclient(&$a, $host) {
$url = "https://".$host."/api/client/register"; $url = "https://".$host."/api/client/register";
@ -89,7 +94,7 @@ function pumpio_registerclient($a, $host) {
return(false); return(false);
} }
function pumpio_connect($a) { function pumpio_connect(&$a) {
// Start a session. This is necessary to hold on to a few keys the callback script will also need // Start a session. This is necessary to hold on to a few keys the callback script will also need
session_start(); session_start();
@ -99,16 +104,23 @@ function pumpio_connect($a) {
$hostname = get_pconfig(local_user(), 'pumpio','host'); $hostname = get_pconfig(local_user(), 'pumpio','host');
if ((($consumer_key == "") OR ($consumer_secret == "")) AND ($hostname != "")) { if ((($consumer_key == "") OR ($consumer_secret == "")) AND ($hostname != "")) {
logger("pumpio_connect: register client");
$clientdata = pumpio_registerclient($a, $hostname); $clientdata = pumpio_registerclient($a, $hostname);
set_pconfig(local_user(), 'pumpio','consumer_key', $clientdata->client_id); set_pconfig(local_user(), 'pumpio','consumer_key', $clientdata->client_id);
set_pconfig(local_user(), 'pumpio','consumer_secret', $clientdata->client_secret); set_pconfig(local_user(), 'pumpio','consumer_secret', $clientdata->client_secret);
$consumer_key = get_pconfig(local_user(), 'pumpio','consumer_key'); $consumer_key = get_pconfig(local_user(), 'pumpio','consumer_key');
$consumer_secret = get_pconfig(local_user(), 'pumpio','consumer_secret'); $consumer_secret = get_pconfig(local_user(), 'pumpio','consumer_secret');
logger("pumpio_connect: ckey: ".$consumer_key." csecrect: ".$consumer_secret);
} }
if (($consumer_key == "") OR ($consumer_secret == "")) if (($consumer_key == "") OR ($consumer_secret == "")) {
return; logger("pumpio_connect: ".sprintf("Unable to register the client at the pump.io server '%s'.", $hostname));
$o .= sprintf(t("Unable to register the client at the pump.io server '%s'."), $hostname);
return($o);
}
// The callback URL is the script that gets called after the user authenticates with pumpio // The callback URL is the script that gets called after the user authenticates with pumpio
$callback_url = $a->get_baseurl()."/pumpio/connect"; $callback_url = $a->get_baseurl()."/pumpio/connect";
@ -134,6 +146,7 @@ function pumpio_connect($a) {
if (($success = $client->Initialize())) { if (($success = $client->Initialize())) {
if (($success = $client->Process())) { if (($success = $client->Process())) {
if (strlen($client->access_token)) { if (strlen($client->access_token)) {
logger("pumpio_connect: otoken: ".$client->access_token." osecrect: ".$client->access_token_secret);
set_pconfig(local_user(), "pumpio", "oauth_token", $client->access_token); set_pconfig(local_user(), "pumpio", "oauth_token", $client->access_token);
set_pconfig(local_user(), "pumpio", "oauth_token_secret", $client->access_token_secret); set_pconfig(local_user(), "pumpio", "oauth_token_secret", $client->access_token_secret);
} }
@ -146,7 +159,8 @@ function pumpio_connect($a) {
if($success) { if($success) {
$o .= t("You are now authenticated to pumpio."); $o .= t("You are now authenticated to pumpio.");
$o .= '<br /><a href="'.$a->get_baseurl().'/settings/connectors">'.t("return to the connector page").'</a>'; $o .= '<br /><a href="'.$a->get_baseurl().'/settings/connectors">'.t("return to the connector page").'</a>';
} } else
$o = 'Could not connect to pumpio. Refresh the page or try again later.';
return($o); return($o);
} }
@ -481,7 +495,7 @@ function pumpio_send(&$a,&$b) {
} }
} }
function pumpio_action($a, $uid, $uri, $action, $content) { function pumpio_action(&$a, $uid, $uri, $action, $content) {
// Don't do likes and other stuff if you don't import the timeline // Don't do likes and other stuff if you don't import the timeline
if (!get_pconfig($uid,'pumpio','import')) if (!get_pconfig($uid,'pumpio','import'))
@ -552,7 +566,7 @@ function pumpio_action($a, $uid, $uri, $action, $content) {
} }
function pumpio_cron($a,$b) { function pumpio_cron(&$a,$b) {
$last = get_config('pumpio','last_poll'); $last = get_config('pumpio','last_poll');
$poll_interval = intval(get_config('pumpio','poll_interval')); $poll_interval = intval(get_config('pumpio','poll_interval'));
@ -601,7 +615,7 @@ function pumpio_cron($a,$b) {
set_config('pumpio','last_poll', time()); set_config('pumpio','last_poll', time());
} }
function pumpio_fetchtimeline($a, $uid) { function pumpio_fetchtimeline(&$a, $uid) {
$ckey = get_pconfig($uid, 'pumpio', 'consumer_key'); $ckey = get_pconfig($uid, 'pumpio', 'consumer_key');
$csecret = get_pconfig($uid, 'pumpio', 'consumer_secret'); $csecret = get_pconfig($uid, 'pumpio', 'consumer_secret');
$otoken = get_pconfig($uid, 'pumpio', 'oauth_token'); $otoken = get_pconfig($uid, 'pumpio', 'oauth_token');
@ -966,17 +980,17 @@ function pumpio_dodelete(&$a, $uid, $self, $post, $own_id) {
return drop_item($r[0]["id"], $false); return drop_item($r[0]["id"], $false);
} }
function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id) { function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id, $threadcompletion = false) {
require_once('include/items.php'); require_once('include/items.php');
if (($post->verb == "like") OR ($post->verb == "favorite")) if (($post->verb == "like") OR ($post->verb == "favorite"))
return pumpio_dolike(&$a, $uid, $self, $post, $own_id); return pumpio_dolike($a, $uid, $self, $post, $own_id);
if (($post->verb == "unlike") OR ($post->verb == "unfavorite")) if (($post->verb == "unlike") OR ($post->verb == "unfavorite"))
return pumpio_dounlike(&$a, $uid, $self, $post, $own_id); return pumpio_dounlike($a, $uid, $self, $post, $own_id);
if ($post->verb == "delete") if ($post->verb == "delete")
return pumpio_dodelete(&$a, $uid, $self, $post, $own_id); return pumpio_dodelete($a, $uid, $self, $post, $own_id);
if ($post->verb != "update") { if ($post->verb != "update") {
// Two queries for speed issues // Two queries for speed issues
@ -1068,7 +1082,7 @@ function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id) {
$reply->published = $post->object->inReplyTo->published; $reply->published = $post->object->inReplyTo->published;
$reply->received = $post->object->inReplyTo->updated; $reply->received = $post->object->inReplyTo->updated;
$reply->url = $post->object->inReplyTo->url; $reply->url = $post->object->inReplyTo->url;
pumpio_dopost(&$a, $client, $uid, $self, $reply, $own_id); pumpio_dopost($a, $client, $uid, $self, $reply, $own_id);
$postarray['parent-uri'] = $post->object->inReplyTo->id; $postarray['parent-uri'] = $post->object->inReplyTo->id;
} }
@ -1125,6 +1139,7 @@ function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id) {
if ($post->object->objectType == "comment") { if ($post->object->objectType == "comment") {
if ($threadcompletion)
pumpio_fetchallcomments($a, $uid, $postarray['parent-uri']); pumpio_fetchallcomments($a, $uid, $postarray['parent-uri']);
$user = q("SELECT * FROM `user` WHERE `uid` = %d AND `account_expired` = 0 LIMIT 1", $user = q("SELECT * FROM `user` WHERE `uid` = %d AND `account_expired` = 0 LIMIT 1",
@ -1182,7 +1197,7 @@ function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id) {
return $top_item; return $top_item;
} }
function pumpio_fetchinbox($a, $uid) { function pumpio_fetchinbox(&$a, $uid) {
$ckey = get_pconfig($uid, 'pumpio', 'consumer_key'); $ckey = get_pconfig($uid, 'pumpio', 'consumer_key');
$csecret = get_pconfig($uid, 'pumpio', 'consumer_secret'); $csecret = get_pconfig($uid, 'pumpio', 'consumer_secret');
@ -1220,13 +1235,13 @@ function pumpio_fetchinbox($a, $uid) {
if (count($posts)) if (count($posts))
foreach ($posts as $post) { foreach ($posts as $post) {
$last_id = $post->id; $last_id = $post->id;
pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id); pumpio_dopost($a, $client, $uid, $self, $post, $own_id);
} }
set_pconfig($uid,'pumpio','last_id', $last_id); set_pconfig($uid,'pumpio','last_id', $last_id);
} }
function pumpio_getallusers($a, $uid) { function pumpio_getallusers(&$a, $uid) {
$ckey = get_pconfig($uid, 'pumpio', 'consumer_key'); $ckey = get_pconfig($uid, 'pumpio', 'consumer_key');
$csecret = get_pconfig($uid, 'pumpio', 'consumer_secret'); $csecret = get_pconfig($uid, 'pumpio', 'consumer_secret');
$otoken = get_pconfig($uid, 'pumpio', 'oauth_token'); $otoken = get_pconfig($uid, 'pumpio', 'oauth_token');
@ -1281,15 +1296,17 @@ function pumpio_queue_hook(&$a,&$b) {
if(! count($r)) if(! count($r))
continue; continue;
$user = $r[0]; $userdata = $r[0];
$oauth_token = get_pconfig($user['uid'], "pumpio", "oauth_token"); //logger('pumpio_queue: fetching userdata '.print_r($userdata, true));
$oauth_token_secret = get_pconfig($user['uid'], "pumpio", "oauth_token_secret");
$consumer_key = get_pconfig($user['uid'], "pumpio","consumer_key");
$consumer_secret = get_pconfig($user['uid'], "pumpio","consumer_secret");
$host = get_pconfig($user['uid'], "pumpio", "host"); $oauth_token = get_pconfig($userdata['uid'], "pumpio", "oauth_token");
$user = get_pconfig($user['uid'], "pumpio", "user"); $oauth_token_secret = get_pconfig($userdata['uid'], "pumpio", "oauth_token_secret");
$consumer_key = get_pconfig($userdata['uid'], "pumpio","consumer_key");
$consumer_secret = get_pconfig($userdata['uid'], "pumpio","consumer_secret");
$host = get_pconfig($userdata['uid'], "pumpio", "host");
$user = get_pconfig($userdata['uid'], "pumpio", "user");
$success = false; $success = false;
@ -1326,7 +1343,7 @@ function pumpio_queue_hook(&$a,&$b) {
} else } else
logger('pumpio_queue: send '.$username.': '.$url.' general error: ' . print_r($user,true)); logger('pumpio_queue: send '.$username.': '.$url.' general error: ' . print_r($user,true));
} else } else
logger("pumpio_queue: Error getting tokens for user ".$user['uid']); logger("pumpio_queue: Error getting tokens for user ".$userdata['uid']);
if (!$success) { if (!$success) {
logger('pumpio_queue: delayed'); logger('pumpio_queue: delayed');
@ -1335,7 +1352,7 @@ function pumpio_queue_hook(&$a,&$b) {
} }
} }
function pumpio_getreceiver($a, $b) { function pumpio_getreceiver(&$a, $b) {
$receiver = array(); $receiver = array();
@ -1420,7 +1437,7 @@ function pumpio_getreceiver($a, $b) {
return $receiver; return $receiver;
} }
function pumpio_fetchallcomments($a, $uid, $id) { function pumpio_fetchallcomments(&$a, $uid, $id) {
$ckey = get_pconfig($uid, 'pumpio', 'consumer_key'); $ckey = get_pconfig($uid, 'pumpio', 'consumer_key');
$csecret = get_pconfig($uid, 'pumpio', 'consumer_secret'); $csecret = get_pconfig($uid, 'pumpio', 'consumer_secret');
$otoken = get_pconfig($uid, 'pumpio', 'oauth_token'); $otoken = get_pconfig($uid, 'pumpio', 'oauth_token');
@ -1510,7 +1527,7 @@ function pumpio_fetchallcomments($a, $uid, $id) {
$post->object = $item; $post->object = $item;
logger("pumpio_fetchallcomments: posting comment ".$post->object->id); logger("pumpio_fetchallcomments: posting comment ".$post->object->id);
pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id); pumpio_dopost($a, $client, $uid, $self, $post, $own_id, false);
} }
} }