Skip to content

fix(facebook): use rupload upload_url for story video transfer #360

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
Cryptoom wants to merge 3 commits into from
+280 −205
Closed

fix(facebook): use rupload upload_url for story video transfer #360

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
51ee7fa
fix(facebook): use rupload upload_url for story video transfer
Cryptoom Sep 16, 2026
299cc9c
Trim the story rupload comments down to the code.
Sep 18, 2026
25e9dc7
Share the Facebook rupload flow between Reels and Stories
Sep 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
217 changes: 124 additions & 93 deletions app/Services/Social/FacebookPublisher.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

namespace App\Services\Social;

use App\Dto\MediaItem;
use App\Enums\PostPlatform\ContentType;
use App\Enums\SocialAccount\Platform;
use App\Exceptions\Social\ErrorCategory;
Expand Down Expand Up @@ -53,8 +54,8 @@ public function publish(PostPlatform $postPlatform): array
$aspectRatio = data_get($postPlatform->meta, 'aspect_ratio');

return match ($contentType) {
ContentType::FacebookReel => $this->publishReel($pageId, $accessToken, $content, $media->first()),
ContentType::FacebookStory => $this->publishStory($pageId, $accessToken, $media->first()),
ContentType::FacebookReel => $this->publishReel($pageId, $accessToken, $content, $this->requireVideo($media->first(), 'Reels')),
ContentType::FacebookStory => $this->publishStory($pageId, $accessToken, $this->requireVideo($media->first(), 'Stories')),
ContentType::FacebookPost => $this->publishPost($pageId, $accessToken, $content, $media, $aspectRatio),
default => throw new FacebookPublishException(
userMessage: "Unsupported Facebook content type: {$contentType?->value}",
Expand Down Expand Up @@ -265,10 +266,61 @@ private function publishVideoPost(string $pageId, string $accessToken, ?string $
];
}

private function publishReel(string $pageId, string $accessToken, ?string $content, $media): array
private function publishReel(string $pageId, string $accessToken, ?string $content, MediaItem $media): array
{
// Phase 1 (start) — graph endpoint returns video_id + upload_url.
$startResponse = $this->facebookHttp()->post("{$this->baseUrl}/{$pageId}/video_reels", [
$finishPayload = ['video_state' => 'PUBLISHED'];

if ($content !== null && $content !== '') {
$finishPayload['description'] = $content;
}

[$videoId, $finishData] = $this->publishResumableVideo($pageId, $accessToken, 'video_reels', $media, $finishPayload);
$reelId = data_get($finishData, 'id', $videoId);

return [
'id' => $reelId,
'url' => "https://www.facebook.com/reel/{$reelId}",
];
}

private function publishStory(string $pageId, string $accessToken, MediaItem $media): array
{
[$videoId, $finishData] = $this->publishResumableVideo($pageId, $accessToken, 'video_stories', $media);
$storyId = data_get($finishData, 'post_id', $videoId);

return [
'id' => $storyId,
'url' => "https://www.facebook.com/stories/{$pageId}/{$storyId}",
];
}

private function requireVideo(?MediaItem $media, string $format): MediaItem
{
if ($media === null || ! $media->isVideo()) {
throw new FacebookPublishException(
userMessage: "Facebook {$format} require a video file.",
category: ErrorCategory::MediaFormat,
);
}

return $media;
}

/**
* Meta's resumable video flow shared by Reels and Stories: `start` on the
* Graph edge hands back a rupload `upload_url`, the bytes go there, and
* `finish` on the same edge publishes. Transferring through the Graph edge
* instead of the `upload_url` leaves the session empty and `finish` fails
* with error 6000.
*
* @param array<string, string> $finishPayload
* @return array{0: string, 1: array<string, mixed>}
*/
private function publishResumableVideo(string $pageId, string $accessToken, string $edge, MediaItem $media, array $finishPayload = []): array
{
$endpoint = "{$this->baseUrl}/{$pageId}/{$edge}";

$startResponse = $this->facebookHttp()->post($endpoint, [
'upload_phase' => 'start',
'access_token' => $accessToken,
]);
Expand All @@ -281,22 +333,42 @@ private function publishReel(string $pageId, string $accessToken, ?string $conte
$videoId = data_get($startData, 'video_id');
$uploadUrl = data_get($startData, 'upload_url');

if (! $videoId || ! $uploadUrl) {
if (! filled($videoId) || ! is_string($uploadUrl) || ! filled($uploadUrl)) {
throw new FacebookPublishException(
userMessage: 'Facebook did not return upload_url for reel start.',
userMessage: 'Facebook did not start the video upload. Please try again.',
category: ErrorCategory::ServerError,
platformErrorCode: null,
rawResponse: $startResponse->body(),
);
}

// Phase 2 (transfer, local-file flow) — download our hosted
// media then POST raw bytes to upload_url with the Offset and
// file_size headers Facebook requires (the docs describe a
// hosted-file shortcut with `file_url` in the body, but rupload
// rejects it with "Header Offset not convertable to unsigned
// long" — the headers are required either way).
$tempFile = tempnam(sys_get_temp_dir(), 'fb_reel_');
$this->uploadVideoToRupload($uploadUrl, $accessToken, $media);

$finishResponse = $this->facebookHttp()->post($endpoint, [
'upload_phase' => 'finish',
'video_id' => $videoId,
'access_token' => $accessToken,
...$finishPayload,
]);

if ($finishResponse->failed()) {
$this->handleApiError($finishResponse);
}

return [(string) $videoId, $finishResponse->json() ?? []];
}

private function uploadVideoToRupload(string $uploadUrl, string $accessToken, MediaItem $media): void
{
$this->assertRuploadUrl($uploadUrl);

$tempFile = tempnam(sys_get_temp_dir(), 'fb_rupload_');

if ($tempFile === false) {
throw new FacebookPublishException(
userMessage: 'Could not prepare the Facebook video for upload.',
category: ErrorCategory::ServerError,
);
}

try {
$download = Http::withOptions(['sink' => $tempFile])
Expand All @@ -305,16 +377,30 @@ private function publishReel(string $pageId, string $accessToken, ?string $conte

if ($download->failed()) {
throw new FacebookPublishException(
userMessage: 'Could not download media for Facebook reel.',
userMessage: 'Could not download media for Facebook.',
category: ErrorCategory::ServerError,
platformErrorCode: (string) $download->status(),
rawResponse: null,
);
}

$fileSize = filesize($tempFile);

if ($fileSize === false || $fileSize < 1) {
throw new FacebookPublishException(
userMessage: 'The downloaded Facebook video is empty.',
category: ErrorCategory::MediaFormat,
);
}

$stream = fopen($tempFile, 'rb');

if ($stream === false) {
throw new FacebookPublishException(
userMessage: 'Could not prepare the Facebook video for upload.',
category: ErrorCategory::ServerError,
);
}

try {
$uploadResponse = Http::withHeaders([
'Authorization' => "OAuth {$accessToken}",
Expand All @@ -331,95 +417,40 @@ private function publishReel(string $pageId, string $accessToken, ?string $conte
}

if ($uploadResponse->failed()) {
Log::error('Facebook rupload transfer failed', [
'body' => $this->redactResponseBody($uploadResponse->body()),
]);
$this->handleApiError($uploadResponse);
}

if (data_get($uploadResponse->json(), 'success') !== true) {
throw new FacebookPublishException(
userMessage: 'Facebook did not accept the video upload. Please try again.',
category: ErrorCategory::ServerError,
rawResponse: $uploadResponse->body(),
);
}
} finally {
if (! unlink($tempFile)) {
Log::warning('Facebook reel temp file cleanup failed', ['path' => $tempFile]);
if (file_exists($tempFile) && ! unlink($tempFile)) {
Log::warning('Facebook rupload temp file cleanup failed', ['path' => $tempFile]);
}
}

// Phase 3 (finish) — publish the reel.
$finishPayload = [
'upload_phase' => 'finish',
'video_id' => $videoId,
'video_state' => 'PUBLISHED',
'access_token' => $accessToken,
];

if ($content !== null && $content !== '') {
$finishPayload['description'] = $content;
}

$finishResponse = $this->facebookHttp()->post("{$this->baseUrl}/{$pageId}/video_reels", $finishPayload);

if ($finishResponse->failed()) {
$this->handleApiError($finishResponse);
}

$finishData = $finishResponse->json();
$reelId = $finishData['id'] ?? $videoId;

return [
'id' => $reelId,
'url' => "https://www.facebook.com/reel/{$reelId}",
];
}

private function publishStory(string $pageId, string $accessToken, $media): array
private function assertRuploadUrl(string $uploadUrl): void
{
if (! $media->isVideo()) {
throw new FacebookPublishException(
userMessage: 'Facebook Stories require a video file.',
category: ErrorCategory::MediaFormat,
);
}

$response = $this->facebookHttp()->post("{$this->baseUrl}/{$pageId}/video_stories", [
'upload_phase' => 'start',
'access_token' => $accessToken,
]);
$parts = parse_url($uploadUrl);
$scheme = data_get($parts, 'scheme');
$host = data_get($parts, 'host');
$allowedHost = config('trypost.platforms.facebook.rupload_host');

if ($response->failed()) {
$this->handleApiError($response);
}

$videoId = $response->json()['video_id'] ?? null;

if (! $videoId) {
if ($scheme !== 'https' || $host !== $allowedHost) {
throw new FacebookPublishException(
userMessage: 'Facebook did not accept the story video. Please try again.',
userMessage: 'Facebook returned an invalid upload URL.',
category: ErrorCategory::ServerError,
rawResponse: $uploadUrl,
);
}

$transferResponse = $this->facebookHttp()->post("{$this->baseUrl}/{$videoId}", [
'upload_phase' => 'transfer',
'video_file_chunk' => $media->url,
'access_token' => $accessToken,
]);

if ($transferResponse->failed()) {
Log::error('Facebook video story transfer failed', ['body' => $this->redactResponseBody($transferResponse->body())]);
$this->handleApiError($transferResponse);
}

$finishResponse = $this->facebookHttp()->post("{$this->baseUrl}/{$pageId}/video_stories", [
'upload_phase' => 'finish',
'video_id' => $videoId,
'access_token' => $accessToken,
]);

if ($finishResponse->failed()) {
$this->handleApiError($finishResponse);
}

$storyId = $finishResponse->json()['post_id'] ?? $videoId;

return [
'id' => $storyId,
'url' => "https://www.facebook.com/stories/{$pageId}/{$storyId}",
];
}

private function handleApiError(Response $response): never
Expand Down
1 change: 1 addition & 0 deletions config/trypost.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -201,6 +201,7 @@
'facebook' => [
'enabled' => env('FACEBOOK_ENABLED', true),
'graph_api' => env('FACEBOOK_GRAPH_API', 'https://graph.facebook.com/v25.0'),
'rupload_host' => env('FACEBOOK_RUPLOAD_HOST', 'rupload.facebook.com'),
],
'instagram' => [
'enabled' => env('INSTAGRAM_ENABLED', true),
Expand Down
Loading