EVOLUTION-MANAGER
Edit File: class.u.gdrive.php
<?php defined("ABSPATH") or die(""); if (DUP_PRO_U::PHP53()) { require_once (DUPLICATOR_PRO_PLUGIN_PATH . '/classes/entities/class.system.global.entity.php'); require_once (DUPLICATOR_PRO_PLUGIN_PATH . '/classes/utilities/class.u.php'); require_once (DUPLICATOR_PRO_PLUGIN_PATH . '/classes/utilities/class.u.string.php'); require_once (DUPLICATOR_PRO_PLUGIN_PATH . '/lib/google/apiclient/autoload.php'); require_once (DUPLICATOR_PRO_PLUGIN_PATH . '/lib/google/class.enhanced.google.media.file.upload.php'); DUP_PRO_U::init(); class DUP_PRO_GDriveClient_UploadInfo { public $resume_uri = ''; public $next_offset = 0; public $error_details = null; public $is_complete = false; } class DUP_PRO_GDrive_U { const RedirectUri = 'urn:ietf:wg:oauth:2.0:oob'; // Special URI indicating that user should copy and paste const UploadChunkSizeBytes = 1048576; // 2097152; static $Scopes; public static function init() { // The drive.file scope limits access to just those files created by the plugin self::$Scopes = array('https://www.googleapis.com/auth/drive.file', 'profile', 'email'); } public static function get_directory_view_link($google_service_drive, $directory) { $directory_id = DUP_PRO_GDrive_U::get_directory_id($google_service_drive, $directory); if($directory_id != null) { $directory_metadata = DUP_PRO_GDrive_U::get_file_metadata_by_id($google_service_drive, $directory_id); if ($directory_metadata != null) { DUP_PRO_LOG::trace("Directory link = " . $directory_metadata->alternateLink); return $directory_metadata->alternateLink; } else { DUP_PRO_LOG::trace("Directory link for $directory not found"); return null; } } else { DUP_PRO_LOG::trace("Directory id for $directory not found"); return null; } } public static function get_file_metadata_by_id($google_service_drive, $file_id) { try { $file_metadata = $google_service_drive->files->get($file_id); } catch (Exception $ex) { DUP_PRO_LOG::trace("Problems retrieving metadata for file $file_id"); } return $file_metadata; } public static function delete_file($google_service_drive, $file_id) { $success = false; /* @var $google_service_drive Duplicator_Pro_Google_Service_Drive */ try { $google_service_drive->files->delete($file_id); $success = true; DUP_PRO_LOG::trace("Delete of Google Drive file $file_id succeeded"); } catch (Exception $ex) { DUP_PRO_LOG::trace("Exception when trying to delete Google Drive file id $file_id"); } return $success; } // Retrieve files in a given directory orderd by creation date public static function get_files_in_directory($google_service_drive, $directory_id) { $file_items = null; $parameters = array('orderBy' => 'createdTime', 'q' => "'$directory_id' in parents and trashed=false"); try { $file_list = $google_service_drive->files->listFiles($parameters); $file_items = $file_list->getFiles(); } catch (Exception $ex) { DUP_PRO_LOG::trace("Error retrieving file list for directory ID $directory_id " . $ex->getMessage()); } return $file_items; } public static function get_file($google_service_drive, $filename, $directory_id) { DUP_PRO_LOG::trace("get_file for $filename $directory_id"); $file_id = null; $file_items = self::get_files_in_directory($google_service_drive, $directory_id); if($file_items != null) { foreach ($file_items as $drive_file) { /* @var $drive_file Duplicator_Pro_Google_Service_Drive_DriveFile */ $google_filename = $drive_file->getName(); if($google_filename == $filename) { $file_id = $drive_file->getId(); break; } } } else { DUP_PRO_LOG::trace("files in directory $directory_id are null"); } return $file_id; } public static function get_directory_id($google_service_drive, $path, $autocreate = true) { $path = str_replace('\\', '/', $path); $path = rtrim($path, '/'); $directory_parts = explode('/', $path); $parent_id = 'root'; try { foreach ($directory_parts as $subdirectory) { $parameters = array(); $parameters['q'] = "'$parent_id' in parents and mimeType = 'application/vnd.google-apps.folder' and trashed=false"; $file_list = $google_service_drive->files->listFiles($parameters); $folder_id = ''; //DUP_PRO_LOG::traceObject('#### file_list', $file_list); //$items = $file_list->getItems(); $items = $file_list->getFiles(); foreach ($items as $drive_file) { /* @var $drive_file Duplicator_Pro_Google_Service_Drive_DriveFile */ if ($drive_file->name == $subdirectory) { $folder_id = $drive_file->id; break; } else { DUP_PRO_LOG::trace("{$drive_file->name} doesnt equal $subdirectory"); } } if ($folder_id == '') { if($autocreate) { DUP_PRO_LOG::trace("Creating new folder " . $subdirectory); // Folder wasn't present so we have to create one $folder_file = new Duplicator_Pro_Google_Service_Drive_DriveFile(); $folder_file->setName($subdirectory); $folder_file->setMimeType('application/vnd.google-apps.folder'); $folder_file->setParents(array($parent_id)); $created_file = $google_service_drive->files->create($folder_file, array('mimeType' => 'application/vnd.google-apps.folder')); $folder_id = $created_file->id; } else { // Doesn't exist $parent_id = null; } } $parent_id = $folder_id; } } catch (Exception $ex) { DUP_PRO_LOG::trace("Got error when trying to get directory id for $path: " . $ex->getMessage()); $parent_id = null; } return $parent_id; } // Upload a file all in one shot // returns null if error, Duplicator_Pro_Google_Service_Drive_DriveFile if success public static function upload_file($google_client, $src_file_path, $parent_file_id, $dest_file_name = '') { /* @var $google_Client Duplicator_Pro_Google_Client */ $drive_file = null; /* @var $google_service_drive Duplicator_Pro_Google_Service_Drive */ try { $mime_type = 'application/octet-stream'; $google_service_drive = new Duplicator_Pro_Google_Service_Drive($google_client); $upload_file = new Duplicator_Pro_Google_Service_Drive_DriveFile(); //$upload_file->setTitle(basename($src_file_path)); if (empty($dest_file_name)) { $dest_file_name = basename($src_file_path); } $upload_file->setName($dest_file_name); $upload_file->setMimeType($mime_type); $upload_file->setParents(array($parent_file_id)); try { $data = file_get_contents($src_file_path); if ($data !== false) { // DUP_PRO_LOG::traceObject("file to upload", $upload_file) /* @var $drive_file Duplicator_Pro_Google_Service_Drive_DriveFile */ $drive_file = $google_service_drive->files->create($upload_file, array('data' => $data, 'uploadType' => 'media')); } else { DUP_PRO_LOG::trace("Couldn't read file contents from $src_file_path when attempting Google Drive Upload"); } } catch (Exception $ex) { DUP_PRO_LOG::trace("Exception from Google drive insert of $src_file_path " . $ex->getMessage()); } if (isset($drive_file) == false) { DUP_PRO_LOG::trace("File returned from Google drive insert of $src_file_path is null."); } } catch (Exception $ex) { DUP_PRO_LOG::trace("Error uploading $src_file_path to Google Drive"); } return $drive_file; } // Will either upload it successfully or populate $upload_info->error_details public static function upload_file_chunk($google_client, $src_file_path, $parent_file_id, $upload_chunk_size = self::UploadChunkSizeBytes, $max_upload_time_in_sec = 10, $next_offset = 0, $resume_uri = null, $server_load_delay = 0) { /* @var $google_client Duplicator_Pro_Google_Client */ $upload_info = new DUP_PRO_GDriveClient_UploadInfo(); try { if (file_exists($src_file_path) == false) { $upload_info->error_details = "$src_file_path doesn't exist!"; } $google_service_drive = new Duplicator_Pro_Google_Service_Drive($google_client); $google_client->setDefer(true); $upload_file = new Duplicator_Pro_Google_Service_Drive_DriveFile(); $upload_file->name = basename($src_file_path); $upload_file->setMimeType('application/octet-stream'); $upload_file->setParents(array($parent_file_id)); $request = $google_service_drive->files->create($upload_file); if ($resume_uri == null) { $resume_uri = false; } $media_file_upload = new DUP_Pro_EnhancedGoogleMediaFileUpload($google_client, $request, 'binary/octet-stream', null, true, $upload_chunk_size, false, $next_offset, $resume_uri); $media_file_upload->setFileSize(filesize($src_file_path)); // Upload the various chunks. $status will be false until the process is complete. $handle = fopen($src_file_path, "rb"); if ($handle != false) { fseek($handle, $next_offset); $start_time = time(); $time_passed = 0; while (!$upload_info->is_complete && !feof($handle) && ($time_passed < $max_upload_time_in_sec)) { if($server_load_delay !== 0) { usleep($server_load_delay); } $chunk = self::read_file_chunk($handle, $upload_chunk_size); $upload_info->is_complete = ($media_file_upload->nextChunk($chunk) !== false); $upload_info->resume_uri = $media_file_upload->resumeUri; $upload_info->next_offset = $media_file_upload->getNextOffset(); fseek($handle, $upload_info->next_offset); $time_passed = time() - $start_time; } if ($upload_info->is_complete) { DUP_PRO_LOG::trace("Upload info is complete!"); } fclose($handle); } else { $upload_info->error_details = "Error opening $src_file_path"; } } catch (Exception $ex) { $message = $ex->getMessage(); $upload_info->error_details = "Error uploading to Google Drive: " . $message; if(DUP_PRO_STR::contains($message, 'storage quota has been exceeded')) { /* @var $system_global DUP_PRO_System_Global_Entity */ $system_global = DUP_PRO_System_Global_Entity::get_instance(); $system_global->add_recommended_text_fix(DUP_PRO_U::esc_html__('Google Drive out of storage space'), DUP_PRO_U::esc_html__('Free up space on Google Drive or increase storage quota.')); $system_global->save(); } } $google_client->setDefer(false); return $upload_info; } static function download_file($google_client, $google_file, $local_filepath, $overwrite_local = true) { /* @var $google_client Duplicator_Pro_Google_Client */ /* @var $google_file Duplicator_Pro_Google_Service_Drive_DriveFile */ $success = false; if ($overwrite_local || (file_exists($local_filepath) === false)) { $google_service_drive = new Duplicator_Pro_Google_Service_Drive($google_client); $file_contents = $google_service_drive->files->get($google_file->id, array('alt' => 'media' )); if (@file_put_contents($local_filepath, $file_contents) === FALSE) { DUP_PRO_LOG::trace("Problem writing downloaded file from $remote_filepath to $local_filepath!"); } else { $success = true; } } else { DUP_PRO_LOG::trace("Attempted to download a file to $local_filepath but that file already exists!"); } return $success; } static function read_file_chunk($handle, $chunk_size) { $byte_count = 0; $giant_chunk = ""; while (!feof($handle)) { // fread will never return more than 8192 bytes if the stream is read buffered and it does not represent a plain file $chunk = fread($handle, 8192); $byte_count += strlen($chunk); $giant_chunk .= $chunk; if ($byte_count >= $chunk_size) { return $giant_chunk; } } return $giant_chunk; } // Array(email, familyName, givenName,...) public static function get_user_info($google_client) { $userInfoService = new Duplicator_Pro_Google_Service_Oauth2($google_client); $userInfo = null; try { $userInfo = $userInfoService->userinfo->get(); return $userInfo; } catch (Duplicator_Pro_Google_Exception $e) { DUP_PRO_LOG::trace("Error retrieving user information"); } if ($userInfo != null && $userInfo->getId() == null) { $userInfo = null; } return $userInfo; } public static function get_binary_self_value() { return 'jfds2!x4'; } public static function get_binary_extraction_value() { return 'kkd23p'; } public static function get_raw_google_client() { $client = new Duplicator_Pro_Google_Client(); $global = DUP_PRO_Global_Entity::get_instance(); $io = $client->getIo(); $setopts = array(); if (is_a($io, 'Duplicator_Pro_Google_IO_Curl')) { $setopts[CURLOPT_SSL_VERIFYPEER] = $global->ssl_disableverify ? false : true; $setopts[CURLOPT_SSL_VERIFYHOST] = $global->ssl_disableverify ? 0 : 2; if (!$global->ssl_useservercerts) { $setopts[CURLOPT_CAINFO] = DUPLICATOR_PRO_CERT_PATH; $setopts[CURLOPT_CAPATH] = DUPLICATOR_PRO_CERT_PATH; } // Raise the timeout from the default of 15 $setopts[CURLOPT_TIMEOUT] = 360; $setopts[CURLOPT_CONNECTTIMEOUT] = 180; if ($global->ipv4_only) $setopts[CURLOPT_IPRESOLVE] = CURL_IPRESOLVE_V4; } elseif (is_a($io, 'Duplicator_Pro_Google_IO_Stream')) { $setopts['timeout'] = 360; // https://wiki.php.net/rfc/tls-peer-verification - before PHP 5.6, there is no default CA file if (!$global->ssl_useservercerts || (version_compare(PHP_VERSION, '5.6.0', '<'))) $setopts['cafile'] = DUPLICATOR_PRO_CERT_PATH; if ($global->ssl_disableverify) $setopts['disable_verify_peer'] = true; } $io->setOptions($setopts); $sv = self::get_binary_self_value(); $ev = self::get_binary_extraction_value(); $ci = DUP_PRO_Crypt_Blowfish::decrypt('EQNJ53++6/40fuF5ke+IaQ==', $sv); $cs = DUP_PRO_Crypt_Blowfish::decrypt('ui25chqoBexPt6QDi9qmGg==', $ev); $ci = trim($ci); $cs = trim($cs); if (($ci != $cs) || ($ci != "x93fdf8")) { $ci = self::get_cj1() . self::get_cj2(); $cs = self::get_ct1() . self::get_ct2(); } $client->setClientId($ci); $client->setAccessType('offline'); $client->setClientSecret($cs); $client->setScopes(self::$Scopes); $client->setRedirectUri(self::RedirectUri); return $client; } private static function get_cj1() { return base64_decode('MTMwOTA5MDkxOTkzLTZlMzFpNHN2cW9uaG9iMmRz'); } private static function get_cj2() { return base64_decode('a2Zkc2R2cThvbWxnN3RlLmFwcHMuZ29vZ2xldXNlcmNvbnRlbnQuY29t'); } private static function get_ct1() { return base64_decode('SVltaThQVnlzblFNbGo3'); } private static function get_ct2() { return base64_decode('dHhuakgzN09t'); } } DUP_PRO_GDrive_U::init(); }