# media-cloud-sync/1.3.11/includes/base/logger.php

Media Cloud Sync, version 1.3.11. 229 lines.

- Page: https://pluginprobe.com/plugins/media-cloud-sync/1.3.11/code/includes/base/logger.php
- Raw: https://pluginprobe.com/plugins/media-cloud-sync/1.3.11/raw/includes/base/logger.php
- Modified: 2025-11-22T11:39:02+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/media-cloud-sync/1.3.11/code/includes/base/logger.php#L10-L20`.

```php
<?php
namespace Dudlewebs\WPMCS;

defined('ABSPATH') || exit;

class Logger {
    private static $instance = null;
    private $log_dir;
    private $log_file;

    private function __construct() {
        $upload_dir   = wp_upload_dir();
        $this->log_dir = trailingslashit($upload_dir['basedir']) . Schema::getConstant('UPLOADS');

        if (!file_exists($this->log_dir)) {
            wp_mkdir_p($this->log_dir);
        }

        $this->log_file = $this->log_dir . '/sync-log.json';
    }

    /**
     * Singleton instance
     */
    public static function instance() {
        if (self::$instance === null) {
            self::$instance = new self();
        }
        return self::$instance;
    }

    /**
     * Add or update a log entry
     */
    public function add_log($type, $media_id, $source_type, $log = []) {
        $entry = [
            'time'        => current_time('mysql'),
            'type'        => $type,
            'media_id'    => $media_id,
            'source_type' => $source_type,
        ];

        $this->append_log($entry, $log);
    }

    /**
     * Append log using file-based indexing
     */
    private function append_log($entry, $log=[]) {
        $logs = [];

        if (file_exists($this->log_file)) {
            $content = file_get_contents($this->log_file);
            $logs    = json_decode($content, true) ?: [];
        }

        // Unique key per media/type/source
        $key = $entry['media_id'] . '|' . $entry['type'] . '|' . $entry['source_type'];

        if (isset($logs[$key])) {
            if (!isset($logs[$key]['logs']) || !is_array($logs[$key]['logs'])) {
                $logs[$key]['logs'] = [];
            }
            $logs[$key]['logs'][] = $log;
            $logs[$key]['time'] = $entry['time'] ?? current_time('mysql');
        } else {
            $logs[$key] = $entry;
            $logs[$key]['logs'][] = $log;
        }

        file_put_contents($this->log_file, wp_json_encode($logs));
    }

    /**
     * Get log by media ID, type, and source type
     */
    public function get_log($type, $media_id, $source_type) {
        if (!file_exists($this->log_file)) return [];

        $key = $media_id . '|' . $type . '|' . $source_type;
        return json_decode(file_get_contents($this->log_file), true)[$key] ?? [];
    }

    /**
     * Get all logs (numeric array, supports pagination)
     */
    public function get_all_logs($page = null, $per_page = null) {
        if (!file_exists($this->log_file))  {
            return [
                'logs'        => [],
                'total'       => 0,
                'total_pages' => 0,
                'page'        => 1,
                'per_page'    => $per_page ?:1,
            ];
        }

        $logs = array_values(json_decode(file_get_contents($this->log_file), true) ?: []);

        $total = count($logs);

        if ($page === null || $per_page === null) {
            return [
                'logs'        => $logs,
                'total'       => $total,
                'total_pages' => 1,
                'page'        => 1,
                'per_page'    => $total,
            ];
        }

        $total_pages = (int) ceil($total / $per_page);
        $page = max(1, (int) $page);
        $offset = ($page - 1) * $per_page;

        return [
            'logs'        => array_slice($logs, $offset, $per_page),
            'total'       => $total,
            'total_pages' => $total_pages,
            'page'        => $page,
            'per_page'    => $per_page,
        ];
    }

    /**
     * Get logs by type (supports pagination)
     */
    public function get_logs_by_type($type, $page = null, $per_page = null) {
        if (!file_exists($this->log_file)) {
            return [
                'logs'        => [],
                'total'       => 0,
                'total_pages' => 0,
                'page'        => 1,
                'per_page'    => $per_page ?:1,
            ];
        };
        
        $all_logs = json_decode(file_get_contents($this->log_file) ?: '[]', true) ?: [];

        $logs = array_values(array_filter($all_logs, function($log) use ($type) {
            return isset($log['type']) && $log['type'] === $type;
        }));

        $total = count($logs);

        if ($page === null || $per_page === null) {
            return [
                'logs'        => $logs,
                'total'       => $total,
                'total_pages' => 1,
                'page'        => 1,
                'per_page'    => $total,
            ];
        }

       
        $total_pages = (int) ceil($total / $per_page);
        $page = max(1, (int) $page);
        $offset = ($page - 1) * $per_page;

        return [
            'logs'        => array_slice($logs, $offset, $per_page),
            'total'       => $total,
            'total_pages' => $total_pages,
            'page'        => $page,
            'per_page'    => $per_page,
        ];
    }
    

    /**
     * Remove logs by type
     */
    public function remove_logs_by_type($type) {
        if (!file_exists($this->log_file)) return;

        $logs = json_decode(file_get_contents($this->log_file), true) ?: [];

        foreach ($logs as $key => $log) {
            if (isset($log['type']) && $log['type'] === $type) {
                unset($logs[$key]);
            }
        }

        file_put_contents($this->log_file, wp_json_encode($logs));
    }

    /**
     * Remove logs by media ID, type, and source type
     */
    public function remove_log($type, $media_id, $source_type) {
        if (!file_exists($this->log_file)) return;

        $logs = json_decode(file_get_contents($this->log_file), true) ?: [];

        $key = $media_id . '|' . $type . '|' . $source_type;

        if (isset($logs[$key])) {
            unset($logs[$key]);
        }

        file_put_contents($this->log_file, wp_json_encode($logs));
    }

    /**
     * Remove Log by media ID & source type
     */
    public function remove_log_by_media_id($media_id, $source_type) {
        if (!file_exists($this->log_file)) return;

        $logs = json_decode(file_get_contents($this->log_file), true) ?: [];

        $new_log = array_filter($logs, function($log) use ($media_id, $source_type) {
            return $log['media_id'] !== $media_id || $log['source_type'] !== $source_type;
        });

        file_put_contents($this->log_file, wp_json_encode($new_log));
    }

    /**
     * Clear all logs
     */
    public function clear_logs() {
        if (file_exists($this->log_file)) {
            unlink($this->log_file);
        }
    }
}
```