s

✏️ Editing: XAGIO_OnedriveClient.php

<?php
if (!defined('ABSPATH'))
    exit; // Exit if accessed directly

if (!class_exists('XAGIO_OnedriveClient')) {
    class XAGIO_OnedriveClient
    {
        // Set the chunk size to 50 MB (50 × 1024 × 1024 bytes)
        const UPLOAD_CHUNK_SIZE = 52428800;

/** App Setting **/
        private $appParams;
        private $accessToken;

/** Microsoft Graph root URL and version **/
        const GRAPH_URL = "https://graph.microsoft.com/v1.0";

/** Authorization URL **/
        const AUTH_URL = "https://login.microsoftonline.com/common/oauth2/v2.0/";

public function __construct()
        {
            $this->appParams   = [
                'client_id'     => XAGIO_ONEDRIVE_KEY,
                'client_secret' => XAGIO_ONEDRIVE_SECRET
            ];
            $this->accessToken = null;
        }

public function SetAccessToken($token)
        {
            $this->accessToken = $token;
        }

public function renewAccessToken()
        {
            if (null === $this->appParams['client_id']) {
                throw new XAGIO_OnedriveException('The client ID must be set to call renewAccessToken()');
            }
            if (null === $this->accessToken['refresh_token']) {
                throw new XAGIO_OnedriveException('The refresh token is not set or no permission for \'wl.offline_access\' was given to renew the token');
            }

$at = $this->authCall('token', array(
                'client_id'     => $this->appParams['client_id'],
                'client_secret' => $this->appParams['client_secret'],
                'refresh_token' => $this->accessToken['refresh_token'],
                'grant_type'    => 'refresh_token'
            ));

if (empty($at)) {
                throw new XAGIO_OnedriveException('Could not get access token!');
            }

if (isset($at['error'])) {
                throw new XAGIO_OnedriveException(esc_html($at['error_description']));
            }

$BACKUP_SETTINGS             = get_option("XAGIO_BACKUP_SETTINGS");
            $BACKUP_SETTINGS['onedrive'] = $at;
            update_option('XAGIO_BACKUP_SETTINGS', $BACKUP_SETTINGS);

$this->accessToken = $at;
        }

/** API Functions **/

public function CreateFolder()
        {
            $folder = $this->apiCall('/drive/root:/xagio:/children', 'GET');
            if (isset($folder['error'])) {
                // Folder doesn't exist; create it.
                return $this->apiCall('/drive/root/children', 'POST', array(
                    "name"   => "xagio",
                    "folder" => array()
                ));
            } else {
                return false;
            }
        }

public function GetFileFolder($location)
        {
            return $this->apiCall($location, 'GET');
        }

/**
         * Starts an upload by:
         * - Creating an upload session with OneDrive.
         * - Storing the upload details as an option.
         * - Scheduling a WP Cron event to process the file upload in chunks.
         */
        public function upload($source_file = '', $createID = 0)
        {
            if (!file_exists($source_file)) {
                return array('error' => 'Source file does not exist.');
            }

// Get the filename and file size.
            $filename  = basename($source_file);
            $file_size = filesize($source_file);

// Create an upload session.
            $session = $this->apiCall('/drive/root:/xagio/' . $filename . ':/createUploadSession', 'POST', array(
                "item" => array(
                    "@microsoft.graph.conflictBehavior" => "rename",
                    "name"                              => $filename
                )
            ));

if (empty($session) || !isset($session['uploadUrl'])) {
                return array('error' => 'Failed to create upload session');
            }

$upload_url = $session['uploadUrl'];

// Save the job details as an option.
            $upload_data = array(
                $source_file,
                $upload_url,
                0,
                $file_size,
                $createID
            );

// Schedule a WP Cron event to process the upload.
            if (!wp_next_scheduled('XAGIO_OnedriveClient_Process_Upload', $upload_data)) {
                wp_schedule_single_event(time() + 10, 'XAGIO_OnedriveClient_Process_Upload', $upload_data);
            }

return true;
        }

/** Helper Functions **/

private function authCall($path, $request_data = null)
        {
            $url     = self::AUTH_URL . $path;
            $headers = array(
                'Content-Type' => 'application/x-www-form-urlencoded'
            );
            $args    = array(
                'method'     => 'POST',
                'headers'    => $headers,
                'body'       => http_build_query($request_data),
                'timeout'    => 400,
                'sslverify'  => false,
                'cookies'    => array(),
                'user-agent' => 'Xagio (SSL Connection)'
            );

$response = wp_remote_post($url, $args);