178 lines
5.5 KiB
PHP
Executable File
178 lines
5.5 KiB
PHP
Executable File
<?php
|
|
/**
|
|
* Copyright 2017 Facebook, Inc.
|
|
*
|
|
* You are hereby granted a non-exclusive, worldwide, royalty-free license to
|
|
* use, copy, modify, and distribute this software in source code or binary
|
|
* form for use in connection with the web services and APIs provided by
|
|
* Facebook.
|
|
*
|
|
* As with any software that integrates with the Facebook platform, your use
|
|
* of this software is subject to the Facebook Developer Principles and
|
|
* Policies [http://developers.facebook.com/policy/]. This copyright notice
|
|
* shall be included in all copies or substantial portions of the software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
|
|
* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
|
* DEALINGS IN THE SOFTWARE.
|
|
*
|
|
*/
|
|
namespace Facebook\FileUpload;
|
|
|
|
use Facebook\Authentication\AccessToken;
|
|
use Facebook\Exceptions\FacebookResponseException;
|
|
use Facebook\Exceptions\FacebookResumableUploadException;
|
|
use Facebook\Exceptions\FacebookSDKException;
|
|
use Facebook\FacebookApp;
|
|
use Facebook\FacebookClient;
|
|
use Facebook\FacebookRequest;
|
|
|
|
/**
|
|
* Class FacebookResumableUploader
|
|
*
|
|
* @package Facebook
|
|
*/
|
|
class FacebookResumableUploader
|
|
{
|
|
/**
|
|
* @var FacebookApp
|
|
*/
|
|
protected $app;
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
protected $accessToken;
|
|
|
|
/**
|
|
* @var FacebookClient The Facebook client service.
|
|
*/
|
|
protected $client;
|
|
|
|
/**
|
|
* @var string Graph version to use for this request.
|
|
*/
|
|
protected $graphVersion;
|
|
|
|
/**
|
|
* @param FacebookApp $app
|
|
* @param FacebookClient $client
|
|
* @param AccessToken|string|null $accessToken
|
|
* @param string $graphVersion
|
|
*/
|
|
public function __construct(FacebookApp $app, FacebookClient $client, $accessToken, $graphVersion)
|
|
{
|
|
$this->app = $app;
|
|
$this->client = $client;
|
|
$this->accessToken = $accessToken;
|
|
$this->graphVersion = $graphVersion;
|
|
}
|
|
|
|
/**
|
|
* Upload by chunks - start phase
|
|
*
|
|
* @param string $endpoint
|
|
* @param FacebookFile $file
|
|
*
|
|
* @return FacebookTransferChunk
|
|
*
|
|
* @throws FacebookSDKException
|
|
*/
|
|
public function start($endpoint, FacebookFile $file)
|
|
{
|
|
$params = [
|
|
'upload_phase' => 'start',
|
|
'file_size' => $file->getSize(),
|
|
];
|
|
$response = $this->sendUploadRequest($endpoint, $params);
|
|
|
|
return new FacebookTransferChunk($file, $response['upload_session_id'], $response['video_id'], $response['start_offset'], $response['end_offset']);
|
|
}
|
|
|
|
/**
|
|
* Upload by chunks - transfer phase
|
|
*
|
|
* @param string $endpoint
|
|
* @param FacebookTransferChunk $chunk
|
|
* @param boolean $allowToThrow
|
|
*
|
|
* @return FacebookTransferChunk
|
|
*
|
|
* @throws FacebookResponseException
|
|
*/
|
|
public function transfer($endpoint, FacebookTransferChunk $chunk, $allowToThrow = false)
|
|
{
|
|
$params = [
|
|
'upload_phase' => 'transfer',
|
|
'upload_session_id' => $chunk->getUploadSessionId(),
|
|
'start_offset' => $chunk->getStartOffset(),
|
|
'video_file_chunk' => $chunk->getPartialFile(),
|
|
];
|
|
|
|
try {
|
|
$response = $this->sendUploadRequest($endpoint, $params);
|
|
} catch (FacebookResponseException $e) {
|
|
$preException = $e->getPrevious();
|
|
if ($allowToThrow || !$preException instanceof FacebookResumableUploadException) {
|
|
throw $e;
|
|
}
|
|
|
|
if (null !== $preException->getStartOffset() && null !== $preException->getEndOffset()) {
|
|
return new FacebookTransferChunk(
|
|
$chunk->getFile(),
|
|
$chunk->getUploadSessionId(),
|
|
$chunk->getVideoId(),
|
|
$preException->getStartOffset(),
|
|
$preException->getEndOffset()
|
|
);
|
|
}
|
|
|
|
// Return the same chunk entity so it can be retried.
|
|
return $chunk;
|
|
}
|
|
|
|
return new FacebookTransferChunk($chunk->getFile(), $chunk->getUploadSessionId(), $chunk->getVideoId(), $response['start_offset'], $response['end_offset']);
|
|
}
|
|
|
|
/**
|
|
* Upload by chunks - finish phase
|
|
*
|
|
* @param string $endpoint
|
|
* @param string $uploadSessionId
|
|
* @param array $metadata The metadata associated with the file.
|
|
*
|
|
* @return boolean
|
|
*
|
|
* @throws FacebookSDKException
|
|
*/
|
|
public function finish($endpoint, $uploadSessionId, $metadata = [])
|
|
{
|
|
$params = array_merge($metadata, [
|
|
'upload_phase' => 'finish',
|
|
'upload_session_id' => $uploadSessionId,
|
|
]);
|
|
$response = $this->sendUploadRequest($endpoint, $params);
|
|
|
|
return $response['success'];
|
|
}
|
|
|
|
/**
|
|
* Helper to make a FacebookRequest and send it.
|
|
*
|
|
* @param string $endpoint The endpoint to POST to.
|
|
* @param array $params The params to send with the request.
|
|
*
|
|
* @return array
|
|
*/
|
|
private function sendUploadRequest($endpoint, $params = [])
|
|
{
|
|
$request = new FacebookRequest($this->app, $this->accessToken, 'POST', $endpoint, $params, null, $this->graphVersion);
|
|
|
|
return $this->client->sendRequest($request)->getDecodedBody();
|
|
}
|
|
}
|