]> git.mxchange.org Git - friendica-addons.git/commitdiff
Replace call for Logger with DI::logger() in tumblr addon
authorArt4 <art4@wlabs.de>
Fri, 24 Jan 2025 11:57:12 +0000 (11:57 +0000)
committerArt4 <art4@wlabs.de>
Fri, 24 Jan 2025 11:57:12 +0000 (11:57 +0000)
tumblr/tumblr.php

index 12f13aa8fffecbac88f609a71f8cb4b50b7068e6..819c0ca5c4100e6fb9ca00343343020a81d651d3 100644 (file)
@@ -14,7 +14,6 @@ use Friendica\Content\Text\NPF;
 use Friendica\Core\Cache\Enum\Duration;
 use Friendica\Core\Config\Util\ConfigFileManager;
 use Friendica\Core\Hook;
-use Friendica\Core\Logger;
 use Friendica\Core\Protocol;
 use Friendica\Core\Renderer;
 use Friendica\Core\System;
@@ -60,7 +59,7 @@ function tumblr_install()
        Hook::register('check_item_notification', __FILE__, 'tumblr_check_item_notification');
        Hook::register('probe_detect',            __FILE__, 'tumblr_probe_detect');
        Hook::register('item_by_link',            __FILE__, 'tumblr_item_by_link');
-       Logger::info('installed tumblr');
+       DI::logger()->info('installed tumblr');
 }
 
 function tumblr_load_config(ConfigFileManager $loader)
@@ -121,16 +120,16 @@ function tumblr_item_by_link(array &$hookData)
                return;
        }
 
-       Logger::debug('Found tumblr post', ['url' => $hookData['uri'], 'blog' => $matches[1], 'id' => $matches[2]]);
+       DI::logger()->debug('Found tumblr post', ['url' => $hookData['uri'], 'blog' => $matches[1], 'id' => $matches[2]]);
 
        $parameters = ['id' => $matches[2], 'reblog_info' => false, 'notes_info' => false, 'npf' => false];
        $result = tumblr_get($hookData['uid'], 'blog/' . $matches[1] . '/posts', $parameters);
        if ($result->meta->status > 399) {
-               Logger::notice('Error fetching status', ['meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'blog' => $matches[1], 'id' => $matches[2]]);
+               DI::logger()->notice('Error fetching status', ['meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'blog' => $matches[1], 'id' => $matches[2]]);
                return [];
        }
 
-       Logger::debug('Got post', ['blog' => $matches[1], 'id' => $matches[2], 'result' => $result->response->posts]);
+       DI::logger()->debug('Got post', ['blog' => $matches[1], 'id' => $matches[2], 'result' => $result->response->posts]);
        if (!empty($result->response->posts)) {
                $hookData['item_id'] = tumblr_process_post($result->response->posts[0], $hookData['uid'], Item::PR_FETCHED);
                Item::incrementInbound(Protocol::TUMBLR);
@@ -159,20 +158,20 @@ function tumblr_follow(array &$hook_data)
                return;
        }
 
-       Logger::debug('Check if contact is Tumblr', ['url' => $hook_data['url']]);
+       DI::logger()->debug('Check if contact is Tumblr', ['url' => $hook_data['url']]);
 
        $fields = tumblr_get_contact_by_url($hook_data['url'], $uid);
        if (empty($fields)) {
-               Logger::debug('Contact is not a Tumblr contact', ['url' => $hook_data['url']]);
+               DI::logger()->debug('Contact is not a Tumblr contact', ['url' => $hook_data['url']]);
                return;
        }
 
        $result = tumblr_post($uid, 'user/follow', ['url' => $fields['url']]);
        if ($result->meta->status <= 399) {
                $hook_data['contact'] = $fields;
-               Logger::debug('Successfully start following', ['url' => $fields['url']]);
+               DI::logger()->debug('Successfully start following', ['url' => $fields['url']]);
        } else {
-               Logger::notice('Following failed', ['meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'url' => $fields['url']]);
+               DI::logger()->notice('Following failed', ['meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'url' => $fields['url']]);
        }
 }
 
@@ -415,11 +414,11 @@ function tumblr_cron()
        if ($last) {
                $next = $last + ($poll_interval * 60);
                if ($next > time()) {
-                       Logger::notice('poll interval not reached');
+                       DI::logger()->notice('poll interval not reached');
                        return;
                }
        }
-       Logger::notice('cron_start');
+       DI::logger()->notice('cron_start');
 
        $abandon_days = intval(DI::config()->get('system', 'account_abandon_days'));
        if ($abandon_days < 1) {
@@ -432,30 +431,30 @@ function tumblr_cron()
        foreach ($pconfigs as $pconfig) {
                if ($abandon_days != 0) {
                        if (!DBA::exists('user', ["`uid` = ? AND `login_date` >= ?", $pconfig['uid'], $abandon_limit])) {
-                               Logger::notice('abandoned account: timeline from user will not be imported', ['user' => $pconfig['uid']]);
+                               DI::logger()->notice('abandoned account: timeline from user will not be imported', ['user' => $pconfig['uid']]);
                                continue;
                        }
                }
 
-               Logger::notice('importing timeline - start', ['user' => $pconfig['uid']]);
+               DI::logger()->notice('importing timeline - start', ['user' => $pconfig['uid']]);
                tumblr_fetch_dashboard($pconfig['uid'], $last);
                tumblr_fetch_tags($pconfig['uid'], $last);
-               Logger::notice('importing timeline - done', ['user' => $pconfig['uid']]);
+               DI::logger()->notice('importing timeline - done', ['user' => $pconfig['uid']]);
        }
 
        $last_clean = DI::keyValue()->get('tumblr_last_clean');
        if (empty($last_clean) || ($last_clean + 86400 < time())) {
-               Logger::notice('Start contact cleanup');
+               DI::logger()->notice('Start contact cleanup');
                $contacts = DBA::select('account-user-view', ['id', 'pid'], ["`network` = ? AND `uid` != ? AND `rel` = ?", Protocol::TUMBLR, 0, Contact::NOTHING]);
                while ($contact = DBA::fetch($contacts)) {
                        Worker::add(Worker::PRIORITY_LOW, 'MergeContact', $contact['pid'], $contact['id'], 0);
                }
                DBA::close($contacts);
                DI::keyValue()->set('tumblr_last_clean', time());
-               Logger::notice('Contact cleanup done');
+               DI::logger()->notice('Contact cleanup done');
        }
 
-       Logger::notice('cron_end');
+       DI::logger()->notice('cron_end');
 
        DI::keyValue()->set('tumblr_last_poll', time());
 }
@@ -478,7 +477,7 @@ function tumblr_hook_fork(array &$b)
        if (DI::pConfig()->get($post['uid'], 'tumblr', 'import')) {
                // Don't post if it isn't a reply to a tumblr post
                if (($post['gravity'] != Item::GRAVITY_PARENT) && !Post::exists(['id' => $post['parent'], 'network' => Protocol::TUMBLR])) {
-                       Logger::notice('No tumblr parent found', ['item' => $post['id']]);
+                       DI::logger()->notice('No tumblr parent found', ['item' => $post['id']]);
                        $b['execute'] = false;
                        return;
                }
@@ -525,20 +524,20 @@ function tumblr_send(array &$b)
        }
 
        if ($b['gravity'] != Item::GRAVITY_PARENT) {
-               Logger::debug('Got comment', ['item' => $b]);
+               DI::logger()->debug('Got comment', ['item' => $b]);
 
                $parent = tumblr_get_post_from_uri($b['thr-parent']);
                if (empty($parent)) {
-                       Logger::notice('No tumblr post', ['thr-parent' => $b['thr-parent']]);
+                       DI::logger()->notice('No tumblr post', ['thr-parent' => $b['thr-parent']]);
                        return;
                }
 
-               Logger::debug('Parent found', ['parent' => $parent]);
+               DI::logger()->debug('Parent found', ['parent' => $parent]);
 
                $page = tumblr_get_page($b['uid']);
 
                if ($b['gravity'] == Item::GRAVITY_COMMENT) {
-                       Logger::notice('Commenting is not supported (yet)');
+                       DI::logger()->notice('Commenting is not supported (yet)');
                } else {
                        if (($b['verb'] == Activity::LIKE) && !$b['deleted']) {
                                $params = ['id' => $parent['id'], 'reblog_key' => $parent['reblog_key']];
@@ -562,12 +561,12 @@ function tumblr_send(array &$b)
                        }
 
                        if ($result->meta->status < 400) {
-                               Logger::info('Successfully performed activity', ['verb' => $b['verb'], 'deleted' => $b['deleted'], 'meta' => $result->meta, 'response' => $result->response]);
+                               DI::logger()->info('Successfully performed activity', ['verb' => $b['verb'], 'deleted' => $b['deleted'], 'meta' => $result->meta, 'response' => $result->response]);
                                if (!$b['deleted'] && !empty($result->response->id_string)) {
                                        Item::update(['extid' => 'tumblr::' . $result->response->id_string], ['guid' => $b['guid']]);
                                }
                        } else {
-                               Logger::notice('Error while performing activity', ['verb' => $b['verb'], 'deleted' => $b['deleted'], 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
+                               DI::logger()->notice('Error while performing activity', ['verb' => $b['verb'], 'deleted' => $b['deleted'], 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
                        }
                }
                return;
@@ -665,9 +664,9 @@ function tumblr_send_legacy(array $b)
        $result = tumblr_post($b['uid'], 'blog/' . $page . '/post', $params);
 
        if ($result->meta->status < 400) {
-               Logger::info('Success (legacy)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response]);
+               DI::logger()->info('Success (legacy)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response]);
        } else {
-               Logger::notice('Error posting blog (legacy)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
+               DI::logger()->notice('Error posting blog (legacy)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
        }
 }
 
@@ -676,7 +675,7 @@ function tumblr_send_npf(array $post): bool
        $page = tumblr_get_page($post['uid']);
 
        if (empty($page)) {
-               Logger::notice('Missing page, post will not be send to Tumblr.', ['uid' => $post['uid'], 'page' => $page, 'id' => $post['id']]);
+               DI::logger()->notice('Missing page, post will not be send to Tumblr.', ['uid' => $post['uid'], 'page' => $page, 'id' => $post['id']]);
                // "true" is returned, since the legacy function will fail as well.
                return true;
        }
@@ -707,10 +706,10 @@ function tumblr_send_npf(array $post): bool
        $result = tumblr_post($post['uid'], 'blog/' . $page . '/posts', $params);
 
        if ($result->meta->status < 400) {
-               Logger::info('Success (NPF)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response]);
+               DI::logger()->info('Success (NPF)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response]);
                return true;
        } else {
-               Logger::notice('Error posting blog (NPF)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
+               DI::logger()->notice('Error posting blog (NPF)', ['blog' => $page, 'meta' => $result->meta, 'response' => $result->response, 'errors' => $result->errors, 'params' => $params]);
                return false;
        }
 }
@@ -747,10 +746,10 @@ function tumblr_fetch_tags(int $uid, int $last_poll)
                foreach (array_reverse($data->response) as $post) {
                        $id = tumblr_process_post($post, $uid, Item::PR_TAG, $last_poll);
                        if (!empty($id)) {
-                               Logger::debug('Tag post imported', ['tag' => $tag, 'id' => $id]);
+                               DI::logger()->debug('Tag post imported', ['tag' => $tag, 'id' => $id]);
                                $post = Post::selectFirst(['uri-id'], ['id' => $id]);
                                $stored = Post\Category::storeFileByURIId($post['uri-id'], $uid, Post\Category::SUBCRIPTION, $tag);
-                               Logger::debug('Stored tag subscription for user', ['uri-id' => $post['uri-id'], 'uid' => $uid, 'tag' => $tag, 'stored' => $stored]);
+                               DI::logger()->debug('Stored tag subscription for user', ['uri-id' => $post['uri-id'], 'uid' => $uid, 'tag' => $tag, 'stored' => $stored]);
                                Item::incrementInbound(Protocol::TUMBLR);
                        }
                }
@@ -775,7 +774,7 @@ function tumblr_fetch_dashboard(int $uid, int $last_poll)
 
        $dashboard = tumblr_get($uid, 'user/dashboard', $parameters);
        if ($dashboard->meta->status > 399) {
-               Logger::notice('Error fetching dashboard', ['meta' => $dashboard->meta, 'response' => $dashboard->response, 'errors' => $dashboard->errors]);
+               DI::logger()->notice('Error fetching dashboard', ['meta' => $dashboard->meta, 'response' => $dashboard->response, 'errors' => $dashboard->errors]);
                return [];
        }
 
@@ -788,7 +787,7 @@ function tumblr_fetch_dashboard(int $uid, int $last_poll)
                        $last = $post->id;
                }
 
-               Logger::debug('Importing post', ['uid' => $uid, 'created' => date(DateTimeFormat::MYSQL, $post->timestamp), 'id' => $post->id_string]);
+               DI::logger()->debug('Importing post', ['uid' => $uid, 'created' => date(DateTimeFormat::MYSQL, $post->timestamp), 'id' => $post->id_string]);
 
                tumblr_process_post($post, $uid, Item::PR_NONE, $last_poll);
                Item::incrementInbound(Protocol::TUMBLR);
@@ -1063,7 +1062,7 @@ function tumblr_get_type_replacement(array $data, string $plink): string
                        }
 
                default:
-                       Logger::notice('Unknown type', ['type' => $data['type'], 'data' => $data, 'plink' => $plink]);
+                       DI::logger()->notice('Unknown type', ['type' => $data['type'], 'data' => $data, 'plink' => $plink]);
                        $body = '';
        }
 
@@ -1118,9 +1117,9 @@ function tumblr_get_contact(stdClass $blog, int $uid): array
                        $cid = $contact['id'];
                        Contact::update($fields, ['id' => $cid], true);
                }
-               Logger::debug('Get user contact', ['id' => $cid, 'uid' => $uid, 'update' => $update]);
+               DI::logger()->debug('Get user contact', ['id' => $cid, 'uid' => $uid, 'update' => $update]);
        } else {
-               Logger::debug('Get public contact', ['id' => $cid, 'uid' => $uid, 'update' => $update]);
+               DI::logger()->debug('Get public contact', ['id' => $cid, 'uid' => $uid, 'update' => $update]);
        }
 
        if (!empty($avatar)) {
@@ -1156,13 +1155,13 @@ function tumblr_get_contact_fields(stdClass $blog, int $uid, bool $update): arra
        ];
 
        if (!$update) {
-               Logger::debug('Got contact fields', ['uid' => $uid, 'url' => $fields['url']]);
+               DI::logger()->debug('Got contact fields', ['uid' => $uid, 'url' => $fields['url']]);
                return $fields;
        }
 
        $info = tumblr_get($uid, 'blog/' . $blog->uuid . '/info');
        if ($info->meta->status > 399) {
-               Logger::notice('Error fetching blog info', ['meta' => $info->meta, 'response' => $info->response, 'errors' => $info->errors]);
+               DI::logger()->notice('Error fetching blog info', ['meta' => $info->meta, 'response' => $info->response, 'errors' => $info->errors]);
                return $fields;
        }
        Item::incrementInbound(Protocol::TUMBLR);
@@ -1184,7 +1183,7 @@ function tumblr_get_contact_fields(stdClass $blog, int $uid, bool $update): arra
 
        $fields['header'] = $info->response->blog->theme->header_image_focused;
 
-       Logger::debug('Got updated contact fields', ['uid' => $uid, 'url' => $fields['url']]);
+       DI::logger()->debug('Got updated contact fields', ['uid' => $uid, 'url' => $fields['url']]);
        return $fields;
 }
 
@@ -1226,7 +1225,7 @@ function tumblr_get_blogs(int $uid): array
 {
        $userinfo = tumblr_get($uid, 'user/info');
        if ($userinfo->meta->status > 399) {
-               Logger::notice('Error fetching blogs', ['meta' => $userinfo->meta, 'response' => $userinfo->response, 'errors' => $userinfo->errors]);
+               DI::logger()->notice('Error fetching blogs', ['meta' => $userinfo->meta, 'response' => $userinfo->response, 'errors' => $userinfo->errors]);
                return [];
        }
 
@@ -1282,15 +1281,15 @@ function tumblr_get_contact_by_url(string $url, int $uid): ?array
                return null;
        }
 
-       Logger::debug('Update Tumblr blog data', ['url' => $url, 'blog' => $blog, 'uid' => $uid]);
+       DI::logger()->debug('Update Tumblr blog data', ['url' => $url, 'blog' => $blog, 'uid' => $uid]);
 
        $info = tumblr_get($uid, 'blog/' . $blog . '/info');
        if ($info->meta->status > 399) {
-               Logger::notice('Error fetching blog info', ['meta' => $info->meta, 'response' => $info->response, 'errors' => $info->errors, 'blog' => $blog, 'uid' => $uid]);
+               DI::logger()->notice('Error fetching blog info', ['meta' => $info->meta, 'response' => $info->response, 'errors' => $info->errors, 'blog' => $blog, 'uid' => $uid]);
                return null;
        }
 
-       Logger::debug('Got data', ['blog' => $blog, 'meta' => $info->meta]);
+       DI::logger()->debug('Got data', ['blog' => $blog, 'meta' => $info->meta]);
        Item::incrementInbound(Protocol::TUMBLR);
 
        $baseurl = 'https://tumblr.com';
@@ -1419,7 +1418,7 @@ function tumblr_get_token(int $uid, string $code = ''): string
        $refresh_token = DI::pConfig()->get($uid, 'tumblr', 'refresh_token');
 
        if (empty($code) && !empty($access_token) && ($expires_at > (time()))) {
-               Logger::debug('Got token', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
+               DI::logger()->debug('Got token', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
                return $access_token;
        }
 
@@ -1431,11 +1430,11 @@ function tumblr_get_token(int $uid, string $code = ''): string
        if (empty($refresh_token) && empty($code)) {
                $result = tumblr_exchange_token($uid);
                if (empty($result->refresh_token)) {
-                       Logger::info('Invalid result while exchanging token', ['uid' => $uid]);
+                       DI::logger()->info('Invalid result while exchanging token', ['uid' => $uid]);
                        return '';
                }
                $expires_at = time() + $result->expires_in;
-               Logger::debug('Updated token from OAuth1 to OAuth2', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
+               DI::logger()->debug('Updated token from OAuth1 to OAuth2', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
        } else {
                if (!empty($code)) {
                        $parameters['code']       = $code;
@@ -1447,18 +1446,18 @@ function tumblr_get_token(int $uid, string $code = ''): string
 
                $curlResult = DI::httpClient()->post('https://api.tumblr.com/v2/oauth2/token', $parameters);
                if (!$curlResult->isSuccess()) {
-                       Logger::info('Error fetching token', ['uid' => $uid, 'code' => $code, 'result' => $curlResult->getBodyString(), 'parameters' => $parameters]);
+                       DI::logger()->info('Error fetching token', ['uid' => $uid, 'code' => $code, 'result' => $curlResult->getBodyString(), 'parameters' => $parameters]);
                        return '';
                }
 
                $result = json_decode($curlResult->getBodyString());
                if (empty($result)) {
-                       Logger::info('Invalid result when updating token', ['uid' => $uid]);
+                       DI::logger()->info('Invalid result when updating token', ['uid' => $uid]);
                        return '';
                }
 
                $expires_at = time() + $result->expires_in;
-               Logger::debug('Renewed token', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
+               DI::logger()->debug('Renewed token', ['uid' => $uid, 'expires_at' => date('c', $expires_at)]);
        }
 
        DI::pConfig()->set($uid, 'tumblr', 'access_token', $result->access_token);
@@ -1502,7 +1501,7 @@ function tumblr_exchange_token(int $uid): stdClass
                $response = $client->post('oauth2/exchange', ['auth' => 'oauth']);
                return json_decode($response->getBody()->getContents());
        } catch (RequestException $exception) {
-               Logger::notice('Exchange failed', ['code' => $exception->getCode(), 'message' => $exception->getMessage()]);
+               DI::logger()->notice('Exchange failed', ['code' => $exception->getCode(), 'message' => $exception->getMessage()]);
                return new stdClass;
        }
 }