Merge pull request #8826 from annando/fix-logging
Replace deprecated Logger calls
This commit is contained in:
commit
dc5838ecf9
|
@ -1244,7 +1244,7 @@ function api_media_upload()
|
||||||
"image_type" => $media["type"],
|
"image_type" => $media["type"],
|
||||||
"friendica_preview_url" => $media["preview"]];
|
"friendica_preview_url" => $media["preview"]];
|
||||||
|
|
||||||
Logger::log("Media uploaded: " . print_r($returndata, true), Logger::DEBUG);
|
Logger::info('Media uploaded', ['return' => $returndata]);
|
||||||
|
|
||||||
return ["media" => $returndata];
|
return ["media" => $returndata];
|
||||||
}
|
}
|
||||||
|
@ -2233,12 +2233,7 @@ function api_statuses_user_timeline($type)
|
||||||
throw new ForbiddenException();
|
throw new ForbiddenException();
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log(
|
Logger::info('api_statuses_user_timeline', ['api_user' => api_user(), 'user_info' => $user_info, '_REQUEST' => $_REQUEST]);
|
||||||
"api_statuses_user_timeline: api_user: ". api_user() .
|
|
||||||
"\nuser_info: ".print_r($user_info, true) .
|
|
||||||
"\n_REQUEST: ".print_r($_REQUEST, true),
|
|
||||||
Logger::DEBUG
|
|
||||||
);
|
|
||||||
|
|
||||||
$since_id = $_REQUEST['since_id'] ?? 0;
|
$since_id = $_REQUEST['since_id'] ?? 0;
|
||||||
$max_id = $_REQUEST['max_id'] ?? 0;
|
$max_id = $_REQUEST['max_id'] ?? 0;
|
||||||
|
|
|
@ -214,7 +214,7 @@ function dfrn_confirm_post(App $a, $handsfree = null)
|
||||||
$params['page'] = 2;
|
$params['page'] = 2;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('Confirm: posting data to ' . $dfrn_confirm . ': ' . print_r($params, true), Logger::DATA);
|
Logger::debug('Confirm: posting data', ['confirm' => $dfrn_confirm, 'parameter' => $params]);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
*
|
*
|
||||||
|
@ -372,9 +372,9 @@ function dfrn_confirm_post(App $a, $handsfree = null)
|
||||||
$forum = (($page == 1) ? 1 : 0);
|
$forum = (($page == 1) ? 1 : 0);
|
||||||
$prv = (($page == 2) ? 1 : 0);
|
$prv = (($page == 2) ? 1 : 0);
|
||||||
|
|
||||||
Logger::log('dfrn_confirm: requestee contacted: ' . $node);
|
Logger::notice('requestee contacted', ['node' => $node]);
|
||||||
|
|
||||||
Logger::log('dfrn_confirm: request: POST=' . print_r($_POST, true), Logger::DATA);
|
Logger::debug('request', ['POST' => $_POST]);
|
||||||
|
|
||||||
// If $aes_key is set, both of these items require unpacking from the hex transport encoding.
|
// If $aes_key is set, both of these items require unpacking from the hex transport encoding.
|
||||||
|
|
||||||
|
|
|
@ -379,7 +379,7 @@ function dfrn_poll_post(App $a)
|
||||||
// NOTREACHED
|
// NOTREACHED
|
||||||
} else {
|
} else {
|
||||||
// Update the writable flag if it changed
|
// Update the writable flag if it changed
|
||||||
Logger::log('dfrn_poll: post request feed: ' . print_r($_POST, true), Logger::DATA);
|
Logger::debug('post request feed', ['post' => $_POST]);
|
||||||
if ($dfrn_version >= 2.21) {
|
if ($dfrn_version >= 2.21) {
|
||||||
if ($perm === 'rw') {
|
if ($perm === 'rw') {
|
||||||
$writable = 1;
|
$writable = 1;
|
||||||
|
@ -521,7 +521,7 @@ function dfrn_poll_content(App $a)
|
||||||
if (strlen($s) && strstr($s, '<?xml')) {
|
if (strlen($s) && strstr($s, '<?xml')) {
|
||||||
$xml = XML::parseString($s);
|
$xml = XML::parseString($s);
|
||||||
|
|
||||||
Logger::log('dfrn_poll: profile: parsed xml: ' . print_r($xml, true), Logger::DATA);
|
Logger::debug(' profile: parsed', ['xml' => $xml]);
|
||||||
|
|
||||||
Logger::log('dfrn_poll: secure profile: challenge: ' . $xml->challenge . ' expecting ' . $hash);
|
Logger::log('dfrn_poll: secure profile: challenge: ' . $xml->challenge . ' expecting ' . $hash);
|
||||||
Logger::log('dfrn_poll: secure profile: sec: ' . $xml->sec . ' expecting ' . $sec);
|
Logger::log('dfrn_poll: secure profile: sec: ' . $xml->sec . ' expecting ' . $sec);
|
||||||
|
|
|
@ -66,7 +66,7 @@ function events_init(App $a)
|
||||||
function events_post(App $a)
|
function events_post(App $a)
|
||||||
{
|
{
|
||||||
|
|
||||||
Logger::log('post: ' . print_r($_REQUEST, true), Logger::DATA);
|
Logger::debug('post', ['request' => $_REQUEST]);
|
||||||
|
|
||||||
if (!local_user()) {
|
if (!local_user()) {
|
||||||
return;
|
return;
|
||||||
|
|
|
@ -120,7 +120,7 @@ function salmon_post(App $a, $xml = '') {
|
||||||
$m = Strings::base64UrlDecode($key_info[1]);
|
$m = Strings::base64UrlDecode($key_info[1]);
|
||||||
$e = Strings::base64UrlDecode($key_info[2]);
|
$e = Strings::base64UrlDecode($key_info[2]);
|
||||||
|
|
||||||
Logger::log('key details: ' . print_r($key_info,true), Logger::DEBUG);
|
Logger::info('key details', ['info' => $key_info]);
|
||||||
|
|
||||||
$pubkey = Crypto::meToPem($m, $e);
|
$pubkey = Crypto::meToPem($m, $e);
|
||||||
|
|
||||||
|
|
|
@ -183,7 +183,7 @@ function settings_post(App $a)
|
||||||
intval($mail_pubmail),
|
intval($mail_pubmail),
|
||||||
intval(local_user())
|
intval(local_user())
|
||||||
);
|
);
|
||||||
Logger::log("mail: updating mailaccount. Response: ".print_r($r, true));
|
Logger::notice('updating mailaccount', ['response' => $r]);
|
||||||
$r = q("SELECT * FROM `mailacct` WHERE `uid` = %d LIMIT 1",
|
$r = q("SELECT * FROM `mailacct` WHERE `uid` = %d LIMIT 1",
|
||||||
intval(local_user())
|
intval(local_user())
|
||||||
);
|
);
|
||||||
|
|
|
@ -506,14 +506,14 @@ class BBCode
|
||||||
$Image->scaleDown(640);
|
$Image->scaleDown(640);
|
||||||
$new_width = $Image->getWidth();
|
$new_width = $Image->getWidth();
|
||||||
$new_height = $Image->getHeight();
|
$new_height = $Image->getHeight();
|
||||||
Logger::log('scale_external_images: ' . $orig_width . '->' . $new_width . 'w ' . $orig_height . '->' . $new_height . 'h' . ' match: ' . $mtch[0], Logger::DEBUG);
|
Logger::info('External images scaled', ['orig_width' => $orig_width, 'new_width' => $new_width, 'orig_height' => $orig_height, 'new_height' => $new_height, 'match' => $mtch[0]]);
|
||||||
$s = str_replace(
|
$s = str_replace(
|
||||||
$mtch[0],
|
$mtch[0],
|
||||||
'[img=' . $new_width . 'x' . $new_height. ']' . $mtch[1] . '[/img]'
|
'[img=' . $new_width . 'x' . $new_height. ']' . $mtch[1] . '[/img]'
|
||||||
. "\n",
|
. "\n",
|
||||||
$s
|
$s
|
||||||
);
|
);
|
||||||
Logger::log('scale_external_images: new string: ' . $s, Logger::DEBUG);
|
Logger::info('New string', ['image' => $s]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -541,7 +541,7 @@ class BBCode
|
||||||
// than the maximum, then don't waste time looking for the images
|
// than the maximum, then don't waste time looking for the images
|
||||||
if ($maxlen && (strlen($body) > $maxlen)) {
|
if ($maxlen && (strlen($body) > $maxlen)) {
|
||||||
|
|
||||||
Logger::log('the total body length exceeds the limit', Logger::DEBUG);
|
Logger::info('the total body length exceeds the limit', ['maxlen' => $maxlen, 'body_len' => strlen($body)]);
|
||||||
|
|
||||||
$orig_body = $body;
|
$orig_body = $body;
|
||||||
$new_body = '';
|
$new_body = '';
|
||||||
|
@ -561,7 +561,7 @@ class BBCode
|
||||||
|
|
||||||
if (($textlen + $img_start) > $maxlen) {
|
if (($textlen + $img_start) > $maxlen) {
|
||||||
if ($textlen < $maxlen) {
|
if ($textlen < $maxlen) {
|
||||||
Logger::log('the limit happens before an embedded image', Logger::DEBUG);
|
Logger::info('the limit happens before an embedded image');
|
||||||
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
||||||
$textlen = $maxlen;
|
$textlen = $maxlen;
|
||||||
}
|
}
|
||||||
|
@ -575,7 +575,7 @@ class BBCode
|
||||||
|
|
||||||
if (($textlen + $img_end) > $maxlen) {
|
if (($textlen + $img_end) > $maxlen) {
|
||||||
if ($textlen < $maxlen) {
|
if ($textlen < $maxlen) {
|
||||||
Logger::log('the limit happens before the end of a non-embedded image', Logger::DEBUG);
|
Logger::info('the limit happens before the end of a non-embedded image');
|
||||||
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
||||||
$textlen = $maxlen;
|
$textlen = $maxlen;
|
||||||
}
|
}
|
||||||
|
@ -598,11 +598,11 @@ class BBCode
|
||||||
|
|
||||||
if (($textlen + strlen($orig_body)) > $maxlen) {
|
if (($textlen + strlen($orig_body)) > $maxlen) {
|
||||||
if ($textlen < $maxlen) {
|
if ($textlen < $maxlen) {
|
||||||
Logger::log('the limit happens after the end of the last image', Logger::DEBUG);
|
Logger::info('the limit happens after the end of the last image');
|
||||||
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
$new_body = $new_body . substr($orig_body, 0, $maxlen - $textlen);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
Logger::log('the text size with embedded images extracted did not violate the limit', Logger::DEBUG);
|
Logger::info('the text size with embedded images extracted did not violate the limit');
|
||||||
$new_body = $new_body . $orig_body;
|
$new_body = $new_body . $orig_body;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -926,10 +926,10 @@ class Contact
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
} elseif (!isset($contact['url'])) {
|
} elseif (!isset($contact['url'])) {
|
||||||
Logger::log('Empty contact: ' . json_encode($contact) . ' - ' . System::callstack(20), Logger::DEBUG);
|
Logger::info('Empty contact', ['contact' => $contact, 'callstack' => System::callstack(20)]);
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('Contact '.$contact['id'].' is marked for archival', Logger::DEBUG);
|
Logger::info('Contact is marked for archival', ['id' => $contact['id']]);
|
||||||
|
|
||||||
// Contact already archived or "self" contact? => nothing to do
|
// Contact already archived or "self" contact? => nothing to do
|
||||||
if ($contact['archive'] || $contact['self']) {
|
if ($contact['archive'] || $contact['self']) {
|
||||||
|
@ -988,7 +988,7 @@ class Contact
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('Contact '.$contact['id'].' is marked as vital again', Logger::DEBUG);
|
Logger::info('Contact is marked as vital again', ['id' => $contact['id']]);
|
||||||
|
|
||||||
if (!isset($contact['url']) && !empty($contact['id'])) {
|
if (!isset($contact['url']) && !empty($contact['id'])) {
|
||||||
$fields = ['id', 'url', 'batch'];
|
$fields = ['id', 'url', 'batch'];
|
||||||
|
@ -1489,7 +1489,7 @@ class Contact
|
||||||
*/
|
*/
|
||||||
public static function getIdForURL($url, $uid = 0, $no_update = false, $default = [], $in_loop = false)
|
public static function getIdForURL($url, $uid = 0, $no_update = false, $default = [], $in_loop = false)
|
||||||
{
|
{
|
||||||
Logger::log("Get contact data for url " . $url . " and user " . $uid . " - " . System::callstack(), Logger::DEBUG);
|
Logger::info('Get contact data', ['url' => $url, 'user' => $uid]);
|
||||||
|
|
||||||
$contact_id = 0;
|
$contact_id = 0;
|
||||||
|
|
||||||
|
|
|
@ -2167,9 +2167,9 @@ class Item
|
||||||
$distributed = self::insert($item, $notify, true);
|
$distributed = self::insert($item, $notify, true);
|
||||||
|
|
||||||
if (!$distributed) {
|
if (!$distributed) {
|
||||||
Logger::log("Distributed public item " . $itemid . " for user " . $uid . " wasn't stored", Logger::DEBUG);
|
Logger::info("Distributed public item wasn't stored", ['id' => $itemid, 'user' => $uid]);
|
||||||
} else {
|
} else {
|
||||||
Logger::log("Distributed public item " . $itemid . " for user " . $uid . " with id " . $distributed, Logger::DEBUG);
|
Logger::info('Distributed public item was stored', ['id' => $itemid, 'user' => $uid, 'stored' => $distributed]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2233,7 +2233,7 @@ class Item
|
||||||
|
|
||||||
$public_shadow = self::insert($item, false, true);
|
$public_shadow = self::insert($item, false, true);
|
||||||
|
|
||||||
Logger::log("Stored public shadow for thread ".$itemid." under id ".$public_shadow, Logger::DEBUG);
|
Logger::info('Stored public shadow', ['thread' => $itemid, 'id' => $public_shadow]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2291,7 +2291,7 @@ class Item
|
||||||
|
|
||||||
$public_shadow = self::insert($item, false, true);
|
$public_shadow = self::insert($item, false, true);
|
||||||
|
|
||||||
Logger::log("Stored public shadow for comment ".$item['uri']." under id ".$public_shadow, Logger::DEBUG);
|
Logger::info('Stored public shadow', ['uri' => $item['uri'], 'id' => $public_shadow]);
|
||||||
|
|
||||||
// If this was a comment to a Diaspora post we don't get our comment back.
|
// If this was a comment to a Diaspora post we don't get our comment back.
|
||||||
// This means that we have to distribute the comment by ourselves.
|
// This means that we have to distribute the comment by ourselves.
|
||||||
|
@ -2602,29 +2602,29 @@ class Item
|
||||||
|
|
||||||
// Prevent the forwarding of posts that are forwarded
|
// Prevent the forwarding of posts that are forwarded
|
||||||
if (!empty($datarray["extid"]) && ($datarray["extid"] == Protocol::DFRN)) {
|
if (!empty($datarray["extid"]) && ($datarray["extid"] == Protocol::DFRN)) {
|
||||||
Logger::log('Already forwarded', Logger::DEBUG);
|
Logger::info('Already forwarded');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Prevent to forward already forwarded posts
|
// Prevent to forward already forwarded posts
|
||||||
if ($datarray["app"] == DI::baseUrl()->getHostname()) {
|
if ($datarray["app"] == DI::baseUrl()->getHostname()) {
|
||||||
Logger::log('Already forwarded (second test)', Logger::DEBUG);
|
Logger::info('Already forwarded (second test)');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Only forward posts
|
// Only forward posts
|
||||||
if ($datarray["verb"] != Activity::POST) {
|
if ($datarray["verb"] != Activity::POST) {
|
||||||
Logger::log('No post', Logger::DEBUG);
|
Logger::info('No post');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (($contact['network'] != Protocol::FEED) && ($datarray['private'] == self::PRIVATE)) {
|
if (($contact['network'] != Protocol::FEED) && ($datarray['private'] == self::PRIVATE)) {
|
||||||
Logger::log('Not public', Logger::DEBUG);
|
Logger::info('Not public');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
$datarray2 = $datarray;
|
$datarray2 = $datarray;
|
||||||
Logger::log('remote-self start - Contact '.$contact['url'].' - '.$contact['remote_self'].' Item '.print_r($datarray, true), Logger::DEBUG);
|
Logger::info('remote-self start', ['contact' => $contact['url'], 'remote_self'=> $contact['remote_self'], 'item' => $datarray]);
|
||||||
if ($contact['remote_self'] == 2) {
|
if ($contact['remote_self'] == 2) {
|
||||||
$self = DBA::selectFirst('contact', ['id', 'name', 'url', 'thumb'],
|
$self = DBA::selectFirst('contact', ['id', 'name', 'url', 'thumb'],
|
||||||
['uid' => $contact['uid'], 'self' => true]);
|
['uid' => $contact['uid'], 'self' => true]);
|
||||||
|
@ -2663,7 +2663,7 @@ class Item
|
||||||
if ($contact['network'] != Protocol::FEED) {
|
if ($contact['network'] != Protocol::FEED) {
|
||||||
// Store the original post
|
// Store the original post
|
||||||
$result = self::insert($datarray2);
|
$result = self::insert($datarray2);
|
||||||
Logger::log('remote-self post original item - Contact '.$contact['url'].' return '.$result.' Item '.print_r($datarray2, true), Logger::DEBUG);
|
Logger::info('remote-self post original item', ['contact' => $contact['url'], 'result'=> $result, 'item' => $datarray2]);
|
||||||
} else {
|
} else {
|
||||||
$datarray["app"] = "Feed";
|
$datarray["app"] = "Feed";
|
||||||
$result = true;
|
$result = true;
|
||||||
|
@ -2695,7 +2695,7 @@ class Item
|
||||||
return $s;
|
return $s;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('check for photos', Logger::DEBUG);
|
Logger::info('check for photos');
|
||||||
$site = substr(DI::baseUrl(), strpos(DI::baseUrl(), '://'));
|
$site = substr(DI::baseUrl(), strpos(DI::baseUrl(), '://'));
|
||||||
|
|
||||||
$orig_body = $s;
|
$orig_body = $s;
|
||||||
|
@ -2709,7 +2709,7 @@ class Item
|
||||||
$img_st_close++; // make it point to AFTER the closing bracket
|
$img_st_close++; // make it point to AFTER the closing bracket
|
||||||
$image = substr($orig_body, $img_start + $img_st_close, $img_len);
|
$image = substr($orig_body, $img_start + $img_st_close, $img_len);
|
||||||
|
|
||||||
Logger::log('found photo ' . $image, Logger::DEBUG);
|
Logger::info('found photo', ['image' => $image]);
|
||||||
|
|
||||||
if (stristr($image, $site . '/photo/')) {
|
if (stristr($image, $site . '/photo/')) {
|
||||||
// Only embed locally hosted photos
|
// Only embed locally hosted photos
|
||||||
|
@ -2748,7 +2748,7 @@ class Item
|
||||||
$photo_img = Photo::getImageForPhoto($photo);
|
$photo_img = Photo::getImageForPhoto($photo);
|
||||||
// If a custom width and height were specified, apply before embedding
|
// If a custom width and height were specified, apply before embedding
|
||||||
if (preg_match("/\[img\=([0-9]*)x([0-9]*)\]/is", substr($orig_body, $img_start, $img_st_close), $match)) {
|
if (preg_match("/\[img\=([0-9]*)x([0-9]*)\]/is", substr($orig_body, $img_start, $img_st_close), $match)) {
|
||||||
Logger::log('scaling photo', Logger::DEBUG);
|
Logger::info('scaling photo');
|
||||||
|
|
||||||
$width = intval($match[1]);
|
$width = intval($match[1]);
|
||||||
$height = intval($match[2]);
|
$height = intval($match[2]);
|
||||||
|
@ -2759,9 +2759,9 @@ class Item
|
||||||
$data = $photo_img->asString();
|
$data = $photo_img->asString();
|
||||||
$type = $photo_img->getType();
|
$type = $photo_img->getType();
|
||||||
|
|
||||||
Logger::log('replacing photo', Logger::DEBUG);
|
Logger::info('replacing photo');
|
||||||
$image = 'data:' . $type . ';base64,' . base64_encode($data);
|
$image = 'data:' . $type . ';base64,' . base64_encode($data);
|
||||||
Logger::log('replaced: ' . $image, Logger::DATA);
|
Logger::debug('replaced', ['image' => $image]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -3141,7 +3141,7 @@ class Item
|
||||||
if (!$onlyshadow) {
|
if (!$onlyshadow) {
|
||||||
$result = DBA::insert('thread', $item);
|
$result = DBA::insert('thread', $item);
|
||||||
|
|
||||||
Logger::log("Add thread for item ".$itemid." - ".print_r($result, true), Logger::DEBUG);
|
Logger::info('Add thread', ['item' => $itemid, 'result' => $result]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -3171,20 +3171,20 @@ class Item
|
||||||
|
|
||||||
$result = DBA::update('thread', $fields, ['iid' => $itemid]);
|
$result = DBA::update('thread', $fields, ['iid' => $itemid]);
|
||||||
|
|
||||||
Logger::log("Update thread for item ".$itemid." - guid ".$item["guid"]." - ".(int)$result, Logger::DEBUG);
|
Logger::info('Update thread', ['item' => $itemid, 'guid' => $item["guid"], 'result' => $result]);
|
||||||
}
|
}
|
||||||
|
|
||||||
private static function deleteThread($itemid, $itemuri = "")
|
private static function deleteThread($itemid, $itemuri = "")
|
||||||
{
|
{
|
||||||
$item = DBA::selectFirst('thread', ['uid'], ['iid' => $itemid]);
|
$item = DBA::selectFirst('thread', ['uid'], ['iid' => $itemid]);
|
||||||
if (!DBA::isResult($item)) {
|
if (!DBA::isResult($item)) {
|
||||||
Logger::log('No thread found for id '.$itemid, Logger::DEBUG);
|
Logger::info('No thread found', ['id' => $itemid]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
$result = DBA::delete('thread', ['iid' => $itemid], ['cascade' => false]);
|
$result = DBA::delete('thread', ['iid' => $itemid], ['cascade' => false]);
|
||||||
|
|
||||||
Logger::log("deleteThread: Deleted thread for item ".$itemid." - ".print_r($result, true), Logger::DEBUG);
|
Logger::info('Deleted thread', ['item' => $itemid, 'result' => $result]);
|
||||||
|
|
||||||
if ($itemuri != "") {
|
if ($itemuri != "") {
|
||||||
$condition = ["`uri` = ? AND NOT `deleted` AND NOT (`uid` IN (?, 0))", $itemuri, $item["uid"]];
|
$condition = ["`uri` = ? AND NOT `deleted` AND NOT (`uid` IN (?, 0))", $itemuri, $item["uid"]];
|
||||||
|
|
|
@ -202,7 +202,7 @@ class Summary extends BaseAdmin
|
||||||
}
|
}
|
||||||
DBA::close($pageFlagsCountStmt);
|
DBA::close($pageFlagsCountStmt);
|
||||||
|
|
||||||
Logger::log('accounts: ' . print_r($accounts, true), Logger::DATA);
|
Logger::debug('accounts', ['accounts' => $accounts]);
|
||||||
|
|
||||||
$pending = Register::getPendingCount();
|
$pending = Register::getPendingCount();
|
||||||
|
|
||||||
|
|
|
@ -148,7 +148,7 @@ class Receive extends BaseModule
|
||||||
}
|
}
|
||||||
|
|
||||||
self::$logger->info('Diaspora: Post decoded.');
|
self::$logger->info('Diaspora: Post decoded.');
|
||||||
self::$logger->debug('Diaspora: Decoded message.', ['msg' => print_r($msg, true)]);
|
self::$logger->debug('Diaspora: Decoded message.', ['msg' => $msg]);
|
||||||
|
|
||||||
if (!is_array($msg)) {
|
if (!is_array($msg)) {
|
||||||
throw new HTTPException\InternalServerErrorException('Message is not an array.');
|
throw new HTTPException\InternalServerErrorException('Message is not an array.');
|
||||||
|
|
|
@ -42,9 +42,9 @@ class Magic extends BaseModule
|
||||||
{
|
{
|
||||||
$a = DI::app();
|
$a = DI::app();
|
||||||
$ret = ['success' => false, 'url' => '', 'message' => ''];
|
$ret = ['success' => false, 'url' => '', 'message' => ''];
|
||||||
Logger::log('magic mdule: invoked', Logger::DEBUG);
|
Logger::info('magic mdule: invoked');
|
||||||
|
|
||||||
Logger::log('args: ' . print_r($_REQUEST, true), Logger::DATA);
|
Logger::debug('args', ['request' => $_REQUEST]);
|
||||||
|
|
||||||
$addr = $_REQUEST['addr'] ?? '';
|
$addr = $_REQUEST['addr'] ?? '';
|
||||||
$dest = $_REQUEST['dest'] ?? '';
|
$dest = $_REQUEST['dest'] ?? '';
|
||||||
|
@ -73,7 +73,7 @@ class Magic extends BaseModule
|
||||||
return $ret;
|
return $ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('Contact is already authenticated', Logger::DEBUG);
|
Logger::info('Contact is already authenticated');
|
||||||
System::externalRedirect($dest);
|
System::externalRedirect($dest);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -76,8 +76,7 @@ class Owa extends BaseModule
|
||||||
$verified = HTTPSignature::verifyMagic($contact['pubkey']);
|
$verified = HTTPSignature::verifyMagic($contact['pubkey']);
|
||||||
|
|
||||||
if ($verified && $verified['header_signed'] && $verified['header_valid']) {
|
if ($verified && $verified['header_signed'] && $verified['header_valid']) {
|
||||||
Logger::log('OWA header: ' . print_r($verified, true), Logger::DATA);
|
Logger::debug('OWA header', ['addr' => $contact['addr'], 'data' => $verified]);
|
||||||
Logger::log('OWA success: ' . $contact['addr'], Logger::DATA);
|
|
||||||
|
|
||||||
$ret['success'] = true;
|
$ret['success'] = true;
|
||||||
$token = Strings::getRandomHex(32);
|
$token = Strings::getRandomHex(32);
|
||||||
|
@ -94,10 +93,10 @@ class Owa extends BaseModule
|
||||||
openssl_public_encrypt($token, $result, $contact['pubkey']);
|
openssl_public_encrypt($token, $result, $contact['pubkey']);
|
||||||
$ret['encrypted_token'] = Strings::base64UrlEncode($result);
|
$ret['encrypted_token'] = Strings::base64UrlEncode($result);
|
||||||
} else {
|
} else {
|
||||||
Logger::log('OWA fail: ' . $contact['id'] . ' ' . $contact['addr'] . ' ' . $contact['url'], Logger::DEBUG);
|
Logger::info('OWA fail', ['id' => $contact['id'], 'addr' => $contact['addr'], 'url' => $contact['url']]);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
Logger::log('Contact not found: ' . $handle, Logger::DEBUG);
|
Logger::info('Contact not found', ['handle' => $handle]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -131,7 +131,7 @@ class CurlResult
|
||||||
$this->errorNumber = $errorNumber;
|
$this->errorNumber = $errorNumber;
|
||||||
$this->error = $error;
|
$this->error = $error;
|
||||||
|
|
||||||
Logger::log($url . ': ' . $this->returnCode . " " . $result, Logger::DATA);
|
Logger::debug('construct', ['url' => $url, 'returncode' => $this->returnCode, 'result' => $result]);
|
||||||
|
|
||||||
$this->parseBodyHeader($result);
|
$this->parseBodyHeader($result);
|
||||||
$this->checkSuccess();
|
$this->checkSuccess();
|
||||||
|
@ -167,7 +167,7 @@ class CurlResult
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!$this->isSuccess) {
|
if (!$this->isSuccess) {
|
||||||
Logger::error('error', ['url' => $this->url, 'code' => $this->returnCode, 'error' => $this->error, 'callstack' => System::callstack(20)]);
|
Logger::notice('http error', ['url' => $this->url, 'code' => $this->returnCode, 'error' => $this->error, 'callstack' => System::callstack(20)]);
|
||||||
Logger::debug('debug', ['info' => $this->info]);
|
Logger::debug('debug', ['info' => $this->info]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -51,12 +51,12 @@ class FKOAuth1 extends OAuthServer
|
||||||
*/
|
*/
|
||||||
public function loginUser($uid)
|
public function loginUser($uid)
|
||||||
{
|
{
|
||||||
Logger::log("FKOAuth1::loginUser $uid");
|
Logger::notice("FKOAuth1::loginUser $uid");
|
||||||
$a = DI::app();
|
$a = DI::app();
|
||||||
$record = DBA::selectFirst('user', [], ['uid' => $uid, 'blocked' => 0, 'account_expired' => 0, 'account_removed' => 0, 'verified' => 1]);
|
$record = DBA::selectFirst('user', [], ['uid' => $uid, 'blocked' => 0, 'account_expired' => 0, 'account_removed' => 0, 'verified' => 1]);
|
||||||
|
|
||||||
if (!DBA::isResult($record)) {
|
if (!DBA::isResult($record)) {
|
||||||
Logger::log('FKOAuth1::loginUser failure: ' . print_r($_SERVER, true), Logger::DEBUG);
|
Logger::info('FKOAuth1::loginUser failure', ['server' => $_SERVER]);
|
||||||
header('HTTP/1.0 401 Unauthorized');
|
header('HTTP/1.0 401 Unauthorized');
|
||||||
die('This api requires login');
|
die('This api requires login');
|
||||||
}
|
}
|
||||||
|
|
|
@ -30,9 +30,9 @@ use Friendica\Core\Protocol;
|
||||||
use Friendica\Core\System;
|
use Friendica\Core\System;
|
||||||
use Friendica\Database\DBA;
|
use Friendica\Database\DBA;
|
||||||
use Friendica\DI;
|
use Friendica\DI;
|
||||||
use Friendica\Model\Contact;
|
|
||||||
use Friendica\Model\GServer;
|
use Friendica\Model\GServer;
|
||||||
use Friendica\Model\Profile;
|
use Friendica\Model\Profile;
|
||||||
|
use Friendica\Model\User;
|
||||||
use Friendica\Protocol\ActivityNamespace;
|
use Friendica\Protocol\ActivityNamespace;
|
||||||
use Friendica\Protocol\ActivityPub;
|
use Friendica\Protocol\ActivityPub;
|
||||||
use Friendica\Protocol\Email;
|
use Friendica\Protocol\Email;
|
||||||
|
@ -177,7 +177,7 @@ class Probe
|
||||||
$host_url = $host;
|
$host_url = $host;
|
||||||
}
|
}
|
||||||
} elseif ($curlResult->isTimeout()) {
|
} elseif ($curlResult->isTimeout()) {
|
||||||
Logger::info('Probing timeout', ['url' => $ssl_url], Logger::DEBUG);
|
Logger::info('Probing timeout', ['url' => $ssl_url]);
|
||||||
self::$istimeout = true;
|
self::$istimeout = true;
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
@ -186,7 +186,7 @@ class Probe
|
||||||
$curlResult = Network::curl($url, false, ['timeout' => $xrd_timeout, 'accept_content' => 'application/xrd+xml']);
|
$curlResult = Network::curl($url, false, ['timeout' => $xrd_timeout, 'accept_content' => 'application/xrd+xml']);
|
||||||
$connection_error = ($curlResult->getErrorNumber() == CURLE_COULDNT_CONNECT) || ($curlResult->getReturnCode() == 0);
|
$connection_error = ($curlResult->getErrorNumber() == CURLE_COULDNT_CONNECT) || ($curlResult->getReturnCode() == 0);
|
||||||
if ($curlResult->isTimeout()) {
|
if ($curlResult->isTimeout()) {
|
||||||
Logger::info('Probing timeout', ['url' => $url], Logger::DEBUG);
|
Logger::info('Probing timeout', ['url' => $url]);
|
||||||
self::$istimeout = true;
|
self::$istimeout = true;
|
||||||
return [];
|
return [];
|
||||||
} elseif ($connection_error && $ssl_connection_error) {
|
} elseif ($connection_error && $ssl_connection_error) {
|
||||||
|
@ -199,13 +199,13 @@ class Probe
|
||||||
$host_url = 'http://'.$host;
|
$host_url = 'http://'.$host;
|
||||||
}
|
}
|
||||||
if (!is_object($xrd)) {
|
if (!is_object($xrd)) {
|
||||||
Logger::log("No xrd object found for ".$host, Logger::DEBUG);
|
Logger::info('No xrd object found', ['host' => $host]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
$links = XML::elementToArray($xrd);
|
$links = XML::elementToArray($xrd);
|
||||||
if (!isset($links["xrd"]["link"])) {
|
if (!isset($links["xrd"]["link"])) {
|
||||||
Logger::log("No xrd data found for ".$host, Logger::DEBUG);
|
Logger::info('No xrd data found', ['host' => $host]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -229,7 +229,7 @@ class Probe
|
||||||
|
|
||||||
self::$baseurl = $host_url;
|
self::$baseurl = $host_url;
|
||||||
|
|
||||||
Logger::log("Probing successful for ".$host, Logger::DEBUG);
|
Logger::info('Probing successful', ['host' => $host]);
|
||||||
|
|
||||||
return $lrdd;
|
return $lrdd;
|
||||||
}
|
}
|
||||||
|
@ -260,7 +260,7 @@ class Probe
|
||||||
$profile_link = '';
|
$profile_link = '';
|
||||||
|
|
||||||
$links = self::lrdd($webbie);
|
$links = self::lrdd($webbie);
|
||||||
Logger::log('webfingerDfrn: '.$webbie.':'.print_r($links, true), Logger::DATA);
|
Logger::debug('Result', ['url' => $webbie, 'links' => $links]);
|
||||||
if (!empty($links) && is_array($links)) {
|
if (!empty($links) && is_array($links)) {
|
||||||
foreach ($links as $link) {
|
foreach ($links as $link) {
|
||||||
if ($link['@attributes']['rel'] === ActivityNamespace::DFRN) {
|
if ($link['@attributes']['rel'] === ActivityNamespace::DFRN) {
|
||||||
|
@ -294,7 +294,7 @@ class Probe
|
||||||
$webfinger = $data['webfinger'];
|
$webfinger = $data['webfinger'];
|
||||||
|
|
||||||
if (empty($webfinger["links"])) {
|
if (empty($webfinger["links"])) {
|
||||||
Logger::log("No webfinger links found for ".$uri, Logger::DEBUG);
|
Logger::info('No webfinger links found', ['uri' => $uri]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -892,7 +892,7 @@ class Probe
|
||||||
}
|
}
|
||||||
if (!empty($json['public_forum'])) {
|
if (!empty($json['public_forum'])) {
|
||||||
$data['community'] = $json['public_forum'];
|
$data['community'] = $json['public_forum'];
|
||||||
$data['account-type'] = Contact::PAGE_COMMUNITY;
|
$data['account-type'] = User::PAGE_FLAGS_COMMUNITY;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!empty($json['profile'])) {
|
if (!empty($json['profile'])) {
|
||||||
|
@ -948,7 +948,7 @@ class Probe
|
||||||
$webfinger = json_decode($data, true);
|
$webfinger = json_decode($data, true);
|
||||||
if (!empty($webfinger)) {
|
if (!empty($webfinger)) {
|
||||||
if (!isset($webfinger["links"])) {
|
if (!isset($webfinger["links"])) {
|
||||||
Logger::log("No json webfinger links for ".$url, Logger::DEBUG);
|
Logger::info('No json webfinger links', ['url' => $url]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
return $webfinger;
|
return $webfinger;
|
||||||
|
@ -957,13 +957,13 @@ class Probe
|
||||||
// If it is not JSON, maybe it is XML
|
// If it is not JSON, maybe it is XML
|
||||||
$xrd = XML::parseString($data, true);
|
$xrd = XML::parseString($data, true);
|
||||||
if (!is_object($xrd)) {
|
if (!is_object($xrd)) {
|
||||||
Logger::log("No webfinger data retrievable for ".$url, Logger::DEBUG);
|
Logger::info('No webfinger data retrievable', ['url' => $url]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
$xrd_arr = XML::elementToArray($xrd);
|
$xrd_arr = XML::elementToArray($xrd);
|
||||||
if (!isset($xrd_arr["xrd"]["link"])) {
|
if (!isset($xrd_arr["xrd"]["link"])) {
|
||||||
Logger::log("No XML webfinger links for ".$url, Logger::DEBUG);
|
Logger::info('No XML webfinger links', ['url' => $url]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1014,13 +1014,13 @@ class Probe
|
||||||
}
|
}
|
||||||
$content = $curlResult->getBody();
|
$content = $curlResult->getBody();
|
||||||
if (!$content) {
|
if (!$content) {
|
||||||
Logger::log("Empty body for ".$noscrape_url, Logger::DEBUG);
|
Logger::info('Empty body', ['url' => $noscrape_url]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
$json = json_decode($content, true);
|
$json = json_decode($content, true);
|
||||||
if (!is_array($json)) {
|
if (!is_array($json)) {
|
||||||
Logger::log("No json data for ".$noscrape_url, Logger::DEBUG);
|
Logger::info('No json data', ['url' => $noscrape_url]);
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1134,7 +1134,7 @@ class Probe
|
||||||
{
|
{
|
||||||
$data = [];
|
$data = [];
|
||||||
|
|
||||||
Logger::log("Check profile ".$profile_link, Logger::DEBUG);
|
Logger::info('Check profile', ['link' => $profile_link]);
|
||||||
|
|
||||||
// Fetch data via noscrape - this is faster
|
// Fetch data via noscrape - this is faster
|
||||||
$noscrape_url = str_replace(["/hcard/", "/profile/"], "/noscrape/", $profile_link);
|
$noscrape_url = str_replace(["/hcard/", "/profile/"], "/noscrape/", $profile_link);
|
||||||
|
@ -1168,7 +1168,7 @@ class Probe
|
||||||
$prof_data["fn"] = $data['name'] ?? null;
|
$prof_data["fn"] = $data['name'] ?? null;
|
||||||
$prof_data["key"] = $data['pubkey'] ?? null;
|
$prof_data["key"] = $data['pubkey'] ?? null;
|
||||||
|
|
||||||
Logger::log("Result for profile ".$profile_link.": ".print_r($prof_data, true), Logger::DEBUG);
|
Logger::debug('Result', ['link' => $profile_link, 'data' => $prof_data]);
|
||||||
|
|
||||||
return $prof_data;
|
return $prof_data;
|
||||||
}
|
}
|
||||||
|
@ -1919,7 +1919,7 @@ class Probe
|
||||||
}
|
}
|
||||||
|
|
||||||
$msgs = Email::poll($mbox, $uri);
|
$msgs = Email::poll($mbox, $uri);
|
||||||
Logger::log('searching '.$uri.', '.count($msgs).' messages found.', Logger::DEBUG);
|
Logger::info('Messages found', ['uri' => $uri, 'count' => count($msgs)]);
|
||||||
|
|
||||||
if (!count($msgs)) {
|
if (!count($msgs)) {
|
||||||
return [];
|
return [];
|
||||||
|
@ -2002,7 +2002,7 @@ class Probe
|
||||||
|
|
||||||
$fixed = $scheme.$host.$port.$path.$query.$fragment;
|
$fixed = $scheme.$host.$port.$path.$query.$fragment;
|
||||||
|
|
||||||
Logger::log('Base: '.$base.' - Avatar: '.$avatar.' - Fixed: '.$fixed, Logger::DATA);
|
Logger::debug('Avatar fixed', ['base' => $base, 'avatar' => $avatar, 'fixed' => $fixed]);
|
||||||
|
|
||||||
return $fixed;
|
return $fixed;
|
||||||
}
|
}
|
||||||
|
|
|
@ -456,7 +456,6 @@ class Image
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Logger::log('exif: ' . print_r($exif,true));
|
|
||||||
return $exif;
|
return $exif;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -219,7 +219,7 @@ class Processor
|
||||||
{
|
{
|
||||||
$owner = Contact::getIdForURL($activity['actor']);
|
$owner = Contact::getIdForURL($activity['actor']);
|
||||||
|
|
||||||
Logger::log('Deleting item ' . $activity['object_id'] . ' from ' . $owner, Logger::DEBUG);
|
Logger::info('Deleting item', ['object' => $activity['object_id'], 'owner' => $owner]);
|
||||||
Item::markForDeletion(['uri' => $activity['object_id'], 'owner-id' => $owner]);
|
Item::markForDeletion(['uri' => $activity['object_id'], 'owner-id' => $owner]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -336,7 +336,7 @@ class Processor
|
||||||
}
|
}
|
||||||
|
|
||||||
$event_id = Event::store($event);
|
$event_id = Event::store($event);
|
||||||
Logger::log('Event '.$event_id.' was stored', Logger::DEBUG);
|
Logger::info('Event was stored', ['id' => $event_id]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -487,7 +487,8 @@ class Processor
|
||||||
|
|
||||||
$item['created'] = DateTimeFormat::utc($activity['published']);
|
$item['created'] = DateTimeFormat::utc($activity['published']);
|
||||||
$item['edited'] = DateTimeFormat::utc($activity['updated']);
|
$item['edited'] = DateTimeFormat::utc($activity['updated']);
|
||||||
$item['guid'] = $activity['diaspora:guid'] ?: $activity['sc:identifier'] ?: self::getGUIDByURL($item['uri']);
|
$guid = $activity['sc:identifier'] ?: self::getGUIDByURL($item['uri']);
|
||||||
|
$item['guid'] = $activity['diaspora:guid'] ?: $guid;
|
||||||
|
|
||||||
$item['uri-id'] = ItemURI::insert(['uri' => $item['uri'], 'guid' => $item['guid']]);
|
$item['uri-id'] = ItemURI::insert(['uri' => $item['uri'], 'guid' => $item['guid']]);
|
||||||
|
|
||||||
|
@ -560,7 +561,7 @@ class Processor
|
||||||
$author = APContact::getByURL($item['owner-link'], false);
|
$author = APContact::getByURL($item['owner-link'], false);
|
||||||
// We send automatic follow requests for reshared messages. (We don't need though for forum posts)
|
// We send automatic follow requests for reshared messages. (We don't need though for forum posts)
|
||||||
if ($author['type'] != 'Group') {
|
if ($author['type'] != 'Group') {
|
||||||
Logger::log('Send follow request for ' . $item['uri'] . ' (' . $stored . ') to ' . $item['author-link'], Logger::DEBUG);
|
Logger::info('Send follow request', ['uri' => $item['uri'], 'stored' => $stored, 'to' => $item['author-link']]);
|
||||||
ActivityPub\Transmitter::sendFollowObject($item['uri'], $item['author-link']);
|
ActivityPub\Transmitter::sendFollowObject($item['uri'], $item['author-link']);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -803,7 +804,7 @@ class Processor
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::log('Updating profile for ' . $activity['object_id'], Logger::DEBUG);
|
Logger::info('Updating profile', ['object' => $activity['object_id']]);
|
||||||
Contact::updateFromProbeByURL($activity['object_id'], true);
|
Contact::updateFromProbeByURL($activity['object_id'], true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -816,12 +817,12 @@ class Processor
|
||||||
public static function deletePerson($activity)
|
public static function deletePerson($activity)
|
||||||
{
|
{
|
||||||
if (empty($activity['object_id']) || empty($activity['actor'])) {
|
if (empty($activity['object_id']) || empty($activity['actor'])) {
|
||||||
Logger::log('Empty object id or actor.', Logger::DEBUG);
|
Logger::info('Empty object id or actor.');
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($activity['object_id'] != $activity['actor']) {
|
if ($activity['object_id'] != $activity['actor']) {
|
||||||
Logger::log('Object id does not match actor.', Logger::DEBUG);
|
Logger::info('Object id does not match actor.');
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -831,7 +832,7 @@ class Processor
|
||||||
}
|
}
|
||||||
DBA::close($contacts);
|
DBA::close($contacts);
|
||||||
|
|
||||||
Logger::log('Deleted contact ' . $activity['object_id'], Logger::DEBUG);
|
Logger::info('Deleted contact', ['object' => $activity['object_id']]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -850,7 +851,7 @@ class Processor
|
||||||
|
|
||||||
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
||||||
if (empty($cid)) {
|
if (empty($cid)) {
|
||||||
Logger::log('No contact found for ' . $activity['actor'], Logger::DEBUG);
|
Logger::info('No contact found', ['actor' => $activity['actor']]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -865,7 +866,7 @@ class Processor
|
||||||
|
|
||||||
$condition = ['id' => $cid];
|
$condition = ['id' => $cid];
|
||||||
DBA::update('contact', $fields, $condition);
|
DBA::update('contact', $fields, $condition);
|
||||||
Logger::log('Accept contact request from contact ' . $cid . ' for user ' . $uid, Logger::DEBUG);
|
Logger::info('Accept contact request', ['contact' => $cid, 'user' => $uid]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -884,7 +885,7 @@ class Processor
|
||||||
|
|
||||||
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
||||||
if (empty($cid)) {
|
if (empty($cid)) {
|
||||||
Logger::log('No contact found for ' . $activity['actor'], Logger::DEBUG);
|
Logger::info('No contact found', ['actor' => $activity['actor']]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -892,9 +893,9 @@ class Processor
|
||||||
|
|
||||||
if (DBA::exists('contact', ['id' => $cid, 'rel' => Contact::SHARING])) {
|
if (DBA::exists('contact', ['id' => $cid, 'rel' => Contact::SHARING])) {
|
||||||
Contact::remove($cid);
|
Contact::remove($cid);
|
||||||
Logger::log('Rejected contact request from contact ' . $cid . ' for user ' . $uid . ' - contact had been removed.', Logger::DEBUG);
|
Logger::info('Rejected contact request - contact removed', ['contact' => $cid, 'user' => $uid]);
|
||||||
} else {
|
} else {
|
||||||
Logger::log('Rejected contact request from contact ' . $cid . ' for user ' . $uid . '.', Logger::DEBUG);
|
Logger::info('Rejected contact request', ['contact' => $cid, 'user' => $uid]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -941,7 +942,7 @@ class Processor
|
||||||
|
|
||||||
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
$cid = Contact::getIdForURL($activity['actor'], $uid);
|
||||||
if (empty($cid)) {
|
if (empty($cid)) {
|
||||||
Logger::log('No contact found for ' . $activity['actor'], Logger::DEBUG);
|
Logger::info('No contact found', ['actor' => $activity['actor']]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -953,7 +954,7 @@ class Processor
|
||||||
}
|
}
|
||||||
|
|
||||||
Contact::removeFollower($owner, $contact);
|
Contact::removeFollower($owner, $contact);
|
||||||
Logger::log('Undo following request from contact ' . $cid . ' for user ' . $uid, Logger::DEBUG);
|
Logger::info('Undo following request', ['contact' => $cid, 'user' => $uid]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -1341,7 +1341,7 @@ class DFRN
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
Logger::log('dfrn_deliver: ' . "SENDING: " . print_r($postvars, true), Logger::DATA);
|
Logger::debug('dfrn_deliver', ['post' => $postvars]);
|
||||||
|
|
||||||
$postResult = Network::post($contact['notify'], $postvars);
|
$postResult = Network::post($contact['notify'], $postvars);
|
||||||
|
|
||||||
|
|
|
@ -293,37 +293,6 @@ class Diaspora
|
||||||
return $contacts;
|
return $contacts;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* repairs a signature that was double encoded
|
|
||||||
*
|
|
||||||
* The function is unused at the moment. It was copied from the old implementation.
|
|
||||||
*
|
|
||||||
* @param string $signature The signature
|
|
||||||
* @param string $handle The handle of the signature owner
|
|
||||||
* @param integer $level This value is only set inside this function to avoid endless loops
|
|
||||||
*
|
|
||||||
* @return string the repaired signature
|
|
||||||
* @throws \Exception
|
|
||||||
*/
|
|
||||||
private static function repairSignature($signature, $handle = "", $level = 1)
|
|
||||||
{
|
|
||||||
if ($signature == "") {
|
|
||||||
return ($signature);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (base64_encode(base64_decode(base64_decode($signature))) == base64_decode($signature)) {
|
|
||||||
$signature = base64_decode($signature);
|
|
||||||
Logger::log("Repaired double encoded signature from Diaspora/Hubzilla handle ".$handle." - level ".$level, Logger::DEBUG);
|
|
||||||
|
|
||||||
// Do a recursive call to be able to fix even multiple levels
|
|
||||||
if ($level < 10) {
|
|
||||||
$signature = self::repairSignature($signature, $handle, ++$level);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return($signature);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* verify the envelope and return the verified data
|
* verify the envelope and return the verified data
|
||||||
*
|
*
|
||||||
|
@ -542,7 +511,7 @@ class Diaspora
|
||||||
$basedom = XML::parseString($xml);
|
$basedom = XML::parseString($xml);
|
||||||
|
|
||||||
if (!is_object($basedom)) {
|
if (!is_object($basedom)) {
|
||||||
Logger::log("XML is not parseable.");
|
Logger::notice('XML is not parseable.');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
$children = $basedom->children('https://joindiaspora.com/protocol');
|
$children = $basedom->children('https://joindiaspora.com/protocol');
|
||||||
|
@ -556,7 +525,7 @@ class Diaspora
|
||||||
} else {
|
} else {
|
||||||
// This happens with posts from a relais
|
// This happens with posts from a relais
|
||||||
if (empty($privKey)) {
|
if (empty($privKey)) {
|
||||||
Logger::log("This is no private post in the old format", Logger::DEBUG);
|
Logger::info('This is no private post in the old format');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -575,7 +544,7 @@ class Diaspora
|
||||||
|
|
||||||
$decrypted = self::aesDecrypt($outer_key, $outer_iv, $ciphertext);
|
$decrypted = self::aesDecrypt($outer_key, $outer_iv, $ciphertext);
|
||||||
|
|
||||||
Logger::log('decrypted: '.$decrypted, Logger::DEBUG);
|
Logger::info('decrypted', ['data' => $decrypted]);
|
||||||
$idom = XML::parseString($decrypted);
|
$idom = XML::parseString($decrypted);
|
||||||
|
|
||||||
$inner_iv = base64_decode($idom->iv);
|
$inner_iv = base64_decode($idom->iv);
|
||||||
|
@ -724,7 +693,7 @@ class Diaspora
|
||||||
|
|
||||||
$type = $fields->getName();
|
$type = $fields->getName();
|
||||||
|
|
||||||
Logger::log("Received message type ".$type." from ".$sender." for user ".$importer["uid"], Logger::DEBUG);
|
Logger::info('Received message', ['type' => $type, 'sender' => $sender, 'user' => $importer["uid"]]);
|
||||||
|
|
||||||
switch ($type) {
|
switch ($type) {
|
||||||
case "account_migration":
|
case "account_migration":
|
||||||
|
@ -816,7 +785,7 @@ class Diaspora
|
||||||
$data = XML::parseString($msg["message"]);
|
$data = XML::parseString($msg["message"]);
|
||||||
|
|
||||||
if (!is_object($data)) {
|
if (!is_object($data)) {
|
||||||
Logger::log("No valid XML ".$msg["message"], Logger::DEBUG);
|
Logger::info('No valid XML', ['message' => $msg['message']]);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -928,7 +897,7 @@ class Diaspora
|
||||||
if (isset($parent_author_signature)) {
|
if (isset($parent_author_signature)) {
|
||||||
$key = self::key($msg["author"]);
|
$key = self::key($msg["author"]);
|
||||||
if (empty($key)) {
|
if (empty($key)) {
|
||||||
Logger::log("No key found for parent author ".$msg["author"], Logger::DEBUG);
|
Logger::info('No key found for parent', ['author' => $msg["author"]]);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -940,7 +909,7 @@ class Diaspora
|
||||||
|
|
||||||
$key = self::key($fields->author);
|
$key = self::key($fields->author);
|
||||||
if (empty($key)) {
|
if (empty($key)) {
|
||||||
Logger::log("No key found for author ".$fields->author, Logger::DEBUG);
|
Logger::info('No key found', ['author' => $fields->author]);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -994,7 +963,7 @@ class Diaspora
|
||||||
}
|
}
|
||||||
|
|
||||||
if (DBA::isResult($person)) {
|
if (DBA::isResult($person)) {
|
||||||
Logger::debug("In cache " . print_r($person, true));
|
Logger::debug('In cache', ['person' => $person]);
|
||||||
|
|
||||||
if (is_null($update)) {
|
if (is_null($update)) {
|
||||||
// update record occasionally so it doesn't get stale
|
// update record occasionally so it doesn't get stale
|
||||||
|
@ -1108,7 +1077,7 @@ class Diaspora
|
||||||
*/
|
*/
|
||||||
public static function urlFromContactGuid($fcontact_guid)
|
public static function urlFromContactGuid($fcontact_guid)
|
||||||
{
|
{
|
||||||
Logger::log("fcontact guid is ".$fcontact_guid, Logger::DEBUG);
|
Logger::info('fcontact', ['guid' => $fcontact_guid]);
|
||||||
|
|
||||||
$r = q(
|
$r = q(
|
||||||
"SELECT `url` FROM `fcontact` WHERE `url` != '' AND `network` = '%s' AND `guid` = '%s'",
|
"SELECT `url` FROM `fcontact` WHERE `url` != '' AND `network` = '%s' AND `guid` = '%s'",
|
||||||
|
@ -3427,7 +3396,7 @@ class Diaspora
|
||||||
"profile" => $profile,
|
"profile" => $profile,
|
||||||
"signature" => $signature];
|
"signature" => $signature];
|
||||||
|
|
||||||
Logger::log("Send account migration ".print_r($message, true), Logger::DEBUG);
|
Logger::info('Send account migration', ['msg' => $message]);
|
||||||
|
|
||||||
return self::buildAndTransmit($owner, $contact, "account_migration", $message);
|
return self::buildAndTransmit($owner, $contact, "account_migration", $message);
|
||||||
}
|
}
|
||||||
|
@ -3471,7 +3440,7 @@ class Diaspora
|
||||||
"following" => "true",
|
"following" => "true",
|
||||||
"sharing" => "true"];
|
"sharing" => "true"];
|
||||||
|
|
||||||
Logger::log("Send share ".print_r($message, true), Logger::DEBUG);
|
Logger::info('Send share', ['msg' => $message]);
|
||||||
|
|
||||||
return self::buildAndTransmit($owner, $contact, "contact", $message);
|
return self::buildAndTransmit($owner, $contact, "contact", $message);
|
||||||
}
|
}
|
||||||
|
@ -3492,7 +3461,7 @@ class Diaspora
|
||||||
"following" => "false",
|
"following" => "false",
|
||||||
"sharing" => "false"];
|
"sharing" => "false"];
|
||||||
|
|
||||||
Logger::log("Send unshare ".print_r($message, true), Logger::DEBUG);
|
Logger::info('Send unshare', ['msg' => $message]);
|
||||||
|
|
||||||
return self::buildAndTransmit($owner, $contact, "contact", $message);
|
return self::buildAndTransmit($owner, $contact, "contact", $message);
|
||||||
}
|
}
|
||||||
|
@ -4054,7 +4023,7 @@ class Diaspora
|
||||||
|
|
||||||
$message["parent_author_signature"] = self::signature($owner, $message);
|
$message["parent_author_signature"] = self::signature($owner, $message);
|
||||||
|
|
||||||
Logger::log("Relayed data ".print_r($message, true), Logger::DEBUG);
|
Logger::info('Relayed data', ['msg' => $message]);
|
||||||
|
|
||||||
return self::buildAndTransmit($owner, $contact, $type, $message, $public_batch, $item["guid"]);
|
return self::buildAndTransmit($owner, $contact, $type, $message, $public_batch, $item["guid"]);
|
||||||
}
|
}
|
||||||
|
@ -4089,7 +4058,7 @@ class Diaspora
|
||||||
"target_guid" => $item['guid'],
|
"target_guid" => $item['guid'],
|
||||||
"target_type" => $target_type];
|
"target_type" => $target_type];
|
||||||
|
|
||||||
Logger::log("Got message ".print_r($message, true), Logger::DEBUG);
|
Logger::info('Got message', ['msg' => $message]);
|
||||||
|
|
||||||
return self::buildAndTransmit($owner, $contact, $msg_type, $message, $public_batch, $item["guid"]);
|
return self::buildAndTransmit($owner, $contact, $msg_type, $message, $public_batch, $item["guid"]);
|
||||||
}
|
}
|
||||||
|
@ -4330,7 +4299,7 @@ class Diaspora
|
||||||
{
|
{
|
||||||
$owner = User::getOwnerDataById($uid);
|
$owner = User::getOwnerDataById($uid);
|
||||||
if (empty($owner)) {
|
if (empty($owner)) {
|
||||||
Logger::log("No owner post, so not storing signature", Logger::DEBUG);
|
Logger::info('No owner post, so not storing signature');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -4361,7 +4330,7 @@ class Diaspora
|
||||||
{
|
{
|
||||||
$owner = User::getOwnerDataById($uid);
|
$owner = User::getOwnerDataById($uid);
|
||||||
if (empty($owner)) {
|
if (empty($owner)) {
|
||||||
Logger::log("No owner post, so not storing signature", Logger::DEBUG);
|
Logger::info('No owner post, so not storing signature');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -556,7 +556,7 @@ class Feed
|
||||||
$items[] = $item;
|
$items[] = $item;
|
||||||
break;
|
break;
|
||||||
} else {
|
} else {
|
||||||
Logger::info("Stored feed: " . print_r($item, true));
|
Logger::info('Stored feed', ['item' => $item]);
|
||||||
|
|
||||||
$notify = Item::isRemoteSelf($contact, $item);
|
$notify = Item::isRemoteSelf($contact, $item);
|
||||||
|
|
||||||
|
|
|
@ -116,7 +116,7 @@ class PortableContact
|
||||||
|
|
||||||
$j = json_decode($s, true);
|
$j = json_decode($s, true);
|
||||||
|
|
||||||
Logger::log('load: json: ' . print_r($j, true), Logger::DATA);
|
Logger::debug('load', ['json' => $j]);
|
||||||
|
|
||||||
if (!isset($j['entry'])) {
|
if (!isset($j['entry'])) {
|
||||||
return;
|
return;
|
||||||
|
|
|
@ -78,7 +78,7 @@ class Salmon
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
Logger::log('Key located: ' . print_r($ret, true));
|
Logger::notice('Key located', ['ret' => $ret]);
|
||||||
|
|
||||||
if (count($ret) == 1) {
|
if (count($ret) == 1) {
|
||||||
// We only found one one key so we don't care if the hash matches.
|
// We only found one one key so we don't care if the hash matches.
|
||||||
|
|
|
@ -393,7 +393,7 @@ class Crypto
|
||||||
// log the offending call so we can track it down
|
// log the offending call so we can track it down
|
||||||
if (!openssl_public_encrypt($key, $k, $pubkey)) {
|
if (!openssl_public_encrypt($key, $k, $pubkey)) {
|
||||||
$x = debug_backtrace();
|
$x = debug_backtrace();
|
||||||
Logger::log('RSA failed. ' . print_r($x[0], true));
|
Logger::notice('RSA failed', ['trace' => $x[0]]);
|
||||||
}
|
}
|
||||||
|
|
||||||
$result['alg'] = $alg;
|
$result['alg'] = $alg;
|
||||||
|
|
Loading…
Reference in a new issue