Файловый менеджер

Файловый менеджер - Редактировать - /var/www/xthruster/html/wp-content/plugins/google-site-kit/third-party/google/apiclient/src/Http/MediaFileUpload.php

Назад
<?php /** * Copyright 2012 Google Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. / namespace Google\Site_Kit_Dependencies\Google\Http; use Google\Site_Kit_Dependencies\Google\Client; use Google\Site_Kit_Dependencies\Google\Exception as GoogleException; use Google\Site_Kit_Dependencies\GuzzleHttp\Psr7; use Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Request; use Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Uri; use Google\Site_Kit_Dependencies\Psr\Http\Message\RequestInterface; /* * Manage large file uploads, which may be media but can be any type * of sizable data. / class MediaFileUpload { const UPLOAD_MEDIA_TYPE = 'media'; const UPLOAD_MULTIPART_TYPE = 'multipart'; const UPLOAD_RESUMABLE_TYPE = 'resumable'; /* @var string $mimeType / private $mimeType; /* @var string $data / private $data; /* @var bool $resumable / private $resumable; /* @var int $chunkSize / private $chunkSize; /* @var int $size / private $size; /* @var string $resumeUri / private $resumeUri; /* @var int $progress / private $progress; /* @var Client / private $client; /* @var RequestInterface / private $request; /* @var string / private $boundary; // @phpstan-ignore-line /* * Result code from last HTTP call * @var int / private $httpResultCode; /* * @param Client $client * @param RequestInterface $request * @param string $mimeType * @param string $data The bytes you want to upload. * @param bool $resumable * @param int $chunkSize File will be uploaded in chunks of this many bytes. * only used if resumable=True / public function __construct(\Google\Site_Kit_Dependencies\Google\Client $client, \Google\Site_Kit_Dependencies\Psr\Http\Message\RequestInterface $request, $mimeType, $data, $resumable = \false, $chunkSize = 0) { $this->client = $client; $this->request = $request; $this->mimeType = $mimeType; $this->data = $data; $this->resumable = $resumable; $this->chunkSize = $chunkSize; $this->progress = 0; $this->process(); } /* * Set the size of the file that is being uploaded. * @param int $size - int file size in bytes / public function setFileSize($size) { $this->size = $size; } /* * Return the progress on the upload * @return int progress in bytes uploaded. / public function getProgress() { return $this->progress; } /* * Send the next part of the file to upload. * @param string\|bool $chunk Optional. The next set of bytes to send. If false will * use $data passed at construct time. / public function nextChunk($chunk = \false) { $resumeUri = $this->getResumeUri(); if (\false == $chunk) { $chunk = \substr($this->data, $this->progress, $this->chunkSize); } $lastBytePos = $this->progress + \strlen($chunk) - 1; $headers = ['content-range' => "bytes {$this->progress}-{$lastBytePos}/{$this->size}", 'content-length' => (string) \strlen($chunk), 'expect' => '']; $request = new \Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Request('PUT', $resumeUri, $headers, \Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Utils::streamFor($chunk)); return $this->makePutRequest($request); } /* * Return the HTTP result code from the last call made. * @return int code / public function getHttpResultCode() { return $this->httpResultCode; } /* * Sends a PUT-Request to google drive and parses the response, * setting the appropiate variables from the response() * * @param RequestInterface $request the Request which will be send * * @return false\|mixed false when the upload is unfinished or the decoded http response * / private function makePutRequest(\Google\Site_Kit_Dependencies\Psr\Http\Message\RequestInterface $request) { $response = $this->client->execute($request); $this->httpResultCode = $response->getStatusCode(); if (308 == $this->httpResultCode) { // Track the amount uploaded. $range = $response->getHeaderLine('range'); if ($range) { $range_array = \explode('-', $range); $this->progress = (int) $range_array[1] + 1; } // Allow for changing upload URLs. $location = $response->getHeaderLine('location'); if ($location) { $this->resumeUri = $location; } // No problems, but upload not complete. return \false; } return \Google\Site_Kit_Dependencies\Google\Http\REST::decodeHttpResponse($response, $this->request); } /* * Resume a previously unfinished upload * @param string $resumeUri the resume-URI of the unfinished, resumable upload. / public function resume($resumeUri) { $this->resumeUri = $resumeUri; $headers = ['content-range' => "bytes /{$this->size}", 'content-length' => '0']; $httpRequest = new \Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Request('PUT', $this->resumeUri, $headers); return $this->makePutRequest($httpRequest); } /** * @return RequestInterface * @visible for testing / private function process() { $this->transformToUploadUrl(); $request = $this->request; $postBody = ''; $contentType = \false; $meta = \json_decode((string) $request->getBody(), \true); $uploadType = $this->getUploadType($meta); $request = $request->withUri(\Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Uri::withQueryValue($request->getUri(), 'uploadType', $uploadType)); $mimeType = $this->mimeType ?: $request->getHeaderLine('content-type'); if (self::UPLOAD_RESUMABLE_TYPE == $uploadType) { $contentType = $mimeType; $postBody = \is_string($meta) ? $meta : \json_encode($meta); } elseif (self::UPLOAD_MEDIA_TYPE == $uploadType) { $contentType = $mimeType; $postBody = $this->data; } elseif (self::UPLOAD_MULTIPART_TYPE == $uploadType) { // This is a multipart/related upload. $boundary = $this->boundary ?: \mt_rand(); $boundary = \str_replace('"', '', $boundary); $contentType = 'multipart/related; boundary=' . $boundary; $related = "--{$boundary}\r\n"; $related .= "Content-Type: application/json; charset=UTF-8\r\n"; $related .= "\r\n" . \json_encode($meta) . "\r\n"; $related .= "--{$boundary}\r\n"; $related .= "Content-Type: {$mimeType}\r\n"; $related .= "Content-Transfer-Encoding: base64\r\n"; $related .= "\r\n" . \base64_encode($this->data) . "\r\n"; $related .= "--{$boundary}--"; $postBody = $related; } $request = $request->withBody(\Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Utils::streamFor($postBody)); if ($contentType) { $request = $request->withHeader('content-type', $contentType); } return $this->request = $request; } /* * Valid upload types: * - resumable (UPLOAD_RESUMABLE_TYPE) * - media (UPLOAD_MEDIA_TYPE) * - multipart (UPLOAD_MULTIPART_TYPE) * @param string\|false $meta * @return string * @visible for testing */ public function getUploadType($meta) { if ($this->resumable) { return self::UPLOAD_RESUMABLE_TYPE; } if (\false == $meta && $this->data) { return self::UPLOAD_MEDIA_TYPE; } return self::UPLOAD_MULTIPART_TYPE; } public function getResumeUri() { if (null === $this->resumeUri) { $this->resumeUri = $this->fetchResumeUri(); } return $this->resumeUri; } private function fetchResumeUri() { $body = $this->request->getBody(); $headers = ['content-type' => 'application/json; charset=UTF-8', 'content-length' => $body->getSize(), 'x-upload-content-type' => $this->mimeType, 'x-upload-content-length' => $this->size, 'expect' => '']; foreach ($headers as $key => $value) { $this->request = $this->request->withHeader($key, $value); } $response = $this->client->execute($this->request, \false); $location = $response->getHeaderLine('location'); $code = $response->getStatusCode(); if (200 == $code && \true == $location) { return $location; } $message = $code; $body = \json_decode((string) $this->request->getBody(), \true); if (isset($body['error']['errors'])) { $message .= ': '; foreach ($body['error']['errors'] as $error) { $message .= "{$error['domain']}, {$error['message']};"; } $message = \rtrim($message, ';'); } $error = "Failed to start the resumable upload (HTTP {$message})"; $this->client->getLogger()->error($error); throw new \Google\Site_Kit_Dependencies\Google\Exception($error); } private function transformToUploadUrl() { $parts = \parse_url((string) $this->request->getUri()); if (!isset($parts['path'])) { $parts['path'] = ''; } $parts['path'] = '/upload' . $parts['path']; $uri = \Google\Site_Kit_Dependencies\GuzzleHttp\Psr7\Uri::fromParts($parts); $this->request = $this->request->withUri($uri); } public function setChunkSize($chunkSize) { $this->chunkSize = $chunkSize; } public function getRequest() { return $this->request; } }

| ver. 1.4 | Github | . | PHP 7.4.3-4ubuntu2.24 | Генерация страницы: 0 | proxy | phpinfo | Настройка