From 3d7b3c428b9e51b6c40953168c49291417cccc45 Mon Sep 17 00:00:00 2001 From: ct Date: Thu, 3 Jul 2025 20:05:53 +0800 Subject: [PATCH] Update --- .../Commands/CleanupExpiredExportTokens.php | 61 ++++++++++++++++++ app/Http/Controllers/UserExportController.php | 48 +++++++++++--- app/Models/ExportToken.php | 63 +++++++++++++++++++ ...7_03_104651_create_export_tokens_table.php | 36 +++++++++++ .../video-download/video-download-modal.jsx | 35 +++++++---- resources/js/stores/UserStore.js | 14 ++++- 6 files changed, 233 insertions(+), 24 deletions(-) create mode 100644 app/Console/Commands/CleanupExpiredExportTokens.php create mode 100644 app/Models/ExportToken.php create mode 100644 database/migrations/2025_07_03_104651_create_export_tokens_table.php diff --git a/app/Console/Commands/CleanupExpiredExportTokens.php b/app/Console/Commands/CleanupExpiredExportTokens.php new file mode 100644 index 0000000..c181085 --- /dev/null +++ b/app/Console/Commands/CleanupExpiredExportTokens.php @@ -0,0 +1,61 @@ +info('Starting cleanup of expired export tokens...'); + + // Get all expired and unused tokens + $expiredTokens = ExportToken::expiredAndUnused()->get(); + + if ($expiredTokens->isEmpty()) { + $this->info('No expired tokens found.'); + return; + } + + $this->info('Found ' . $expiredTokens->count() . ' expired tokens to process.'); + + $restoredCredits = 0; + + DB::transaction(function () use ($expiredTokens, &$restoredCredits) { + foreach ($expiredTokens as $token) { + if ($token->is_premium && $token->credits_reserved > 0) { + // Restore credits to user + $token->user->user_usage()->increment('non_watermark_videos_left', $token->credits_reserved); + $restoredCredits += $token->credits_reserved; + + $this->info("Restored {$token->credits_reserved} credits to user {$token->user_id}"); + } + + // Delete the expired token + $token->delete(); + } + }); + + $this->info("Cleanup completed. Restored {$restoredCredits} credits and deleted {$expiredTokens->count()} expired tokens."); + } +} \ No newline at end of file diff --git a/app/Http/Controllers/UserExportController.php b/app/Http/Controllers/UserExportController.php index 128d96e..21d4586 100644 --- a/app/Http/Controllers/UserExportController.php +++ b/app/Http/Controllers/UserExportController.php @@ -2,16 +2,16 @@ namespace App\Http\Controllers; +use App\Models\ExportToken; use Illuminate\Http\Request; use Illuminate\Support\Facades\Auth; +use Illuminate\Support\Str; class UserExportController extends Controller { public function premiumExportRequest(Request $request) { - $user = Auth::user(); - $user->load('user_usage'); if ($user->user_usage->non_watermark_videos_left <= 0) { @@ -22,10 +22,27 @@ public function premiumExportRequest(Request $request) ]); } + // Immediately consume the credit and create token + $user->user_usage->update([ + 'non_watermark_videos_left' => $user->user_usage->non_watermark_videos_left - 1, + ]); + + // Create export token (expires in 30 minutes) + $token = ExportToken::create([ + 'user_id' => $user->id, + 'token' => Str::uuid()->toString(), + 'is_premium' => true, + 'credits_reserved' => 1, + 'expires_at' => now()->addMinutes(30), + ]); + + $user->user_usage->refresh(); + return response()->json([ 'success' => [ 'data' => [ 'user_usage' => $user->user_usage, + 'export_token' => $token->token, ], ], ]); @@ -33,23 +50,36 @@ public function premiumExportRequest(Request $request) public function premiumExportComplete(Request $request) { - $user = Auth::user(); + $request->validate([ + 'export_token' => 'required|string', + ]); + $user = Auth::user(); $user->load('user_usage'); - if ($user->user_usage->non_watermark_videos_left <= 0) { + // Find the token + $token = ExportToken::where('token', $request->export_token) + ->where('user_id', $user->id) + ->first(); + + if (!$token) { return response()->json([ 'error' => [ - 'message' => 'You have no credits left to export.', + 'message' => 'Invalid export token.', ], ]); } - $user->user_usage->update([ - 'non_watermark_videos_left' => $user->user_usage->non_watermark_videos_left - 1, - ]); + if (!$token->isValid()) { + return response()->json([ + 'error' => [ + 'message' => 'Export token has expired or already been used.', + ], + ]); + } - $user->user_usage->refresh(); + // Mark token as used + $token->markAsUsed(); return response()->json([ 'success' => [ diff --git a/app/Models/ExportToken.php b/app/Models/ExportToken.php new file mode 100644 index 0000000..4f43a14 --- /dev/null +++ b/app/Models/ExportToken.php @@ -0,0 +1,63 @@ + 'boolean', + 'expires_at' => 'datetime', + 'used_at' => 'datetime', + ]; + + public function user(): BelongsTo + { + return $this->belongsTo(User::class); + } + + public function isExpired(): bool + { + return $this->expires_at->isPast(); + } + + public function isUsed(): bool + { + return !is_null($this->used_at); + } + + public function isValid(): bool + { + return !$this->isExpired() && !$this->isUsed(); + } + + public function markAsUsed(): void + { + $this->update(['used_at' => now()]); + } + + public function scopeExpiredAndUnused($query) + { + return $query->where('expires_at', '<', now()) + ->whereNull('used_at'); + } + + public function scopeForUser($query, $userId) + { + return $query->where('user_id', $userId); + } +} \ No newline at end of file diff --git a/database/migrations/2025_07_03_104651_create_export_tokens_table.php b/database/migrations/2025_07_03_104651_create_export_tokens_table.php new file mode 100644 index 0000000..c0d9902 --- /dev/null +++ b/database/migrations/2025_07_03_104651_create_export_tokens_table.php @@ -0,0 +1,36 @@ +id(); + $table->foreignId('user_id')->constrained()->onDelete('cascade'); + $table->uuid('token')->unique(); + $table->boolean('is_premium')->default(false); + $table->integer('credits_reserved')->default(1); + $table->timestamp('expires_at'); + $table->timestamp('used_at')->nullable(); + $table->timestamps(); + + $table->index(['user_id', 'expires_at']); + $table->index('expires_at'); + }); + } + + /** + * Reverse the migrations. + */ + public function down(): void + { + Schema::dropIfExists('export_tokens'); + } +}; diff --git a/resources/js/modules/editor/partials/canvas/video-download/video-download-modal.jsx b/resources/js/modules/editor/partials/canvas/video-download/video-download-modal.jsx index 19827f3..095aac7 100644 --- a/resources/js/modules/editor/partials/canvas/video-download/video-download-modal.jsx +++ b/resources/js/modules/editor/partials/canvas/video-download/video-download-modal.jsx @@ -4,7 +4,7 @@ import { Progress } from '@/components/ui/progress'; import { Spinner } from '@/components/ui/spinner.js'; import { Textarea } from '@/components/ui/textarea'; import useUserStore from '@/stores/UserStore'; -import { Clock10Icon, Download, Droplets } from 'lucide-react'; +import { Clock10Icon, Download } from 'lucide-react'; import { useEffect, useRef, useState } from 'react'; const VideoDownloadModal = ({ @@ -24,6 +24,7 @@ const VideoDownloadModal = ({ const [estimatedTimeRemaining, setEstimatedTimeRemaining] = useState(null); const [status, setStatus] = useState('start'); // 'start', 'processing', 'complete' const [downloadState, setDownloadState] = useState('idle'); // 'idle', 'downloading', 'downloaded' + const [exportToken, setExportToken] = useState(null); const exportStartTime = useRef(null); const lastProgressTime = useRef(null); @@ -105,6 +106,10 @@ const VideoDownloadModal = ({ } if (response?.success) { + // Store the export token + const token = response.success.data.export_token; + console.log('Received export token:', token); + setExportToken(token); // Continue with export if successful setStatus('processing'); handleDownloadButton(); @@ -124,6 +129,7 @@ const VideoDownloadModal = ({ setIsPremiumExport(false); setEstimatedTimeRemaining(null); setStatus('start'); + setExportToken(null); exportStartTime.current = null; lastProgressTime.current = null; lastProgress.current = 0; @@ -135,11 +141,14 @@ const VideoDownloadModal = ({ if (status === 'processing' && exportProgress >= 100) { setStatus('complete'); // Call premiumExportComplete immediately when export completes - if (isPremiumExport) { - premiumExportComplete(); + if (isPremiumExport && exportToken) { + console.log('Calling premiumExportComplete with token:', exportToken); + premiumExportComplete(exportToken); + } else if (isPremiumExport && !exportToken) { + console.error('Premium export completed but no token available'); } } - }, [exportProgress, status, isPremiumExport, premiumExportComplete]); + }, [exportProgress, status, isPremiumExport, exportToken, premiumExportComplete]); // Calculate estimated time remaining based on progress speed useEffect(() => { @@ -291,10 +300,10 @@ const VideoDownloadModal = ({
- {isPremiumExport ? : } +
-

Exporting {isPremiumExport ? 'without watermark' : ''}

+

Exporting...

Please do not close this window while the export is in progress. @@ -314,7 +323,7 @@ const VideoDownloadModal = ({ {formatTimeRemaining(estimatedTimeRemaining)}

) : ( - exportProgress > 5 && ( + exportProgress != null && (
Calculating time remaining...
@@ -330,8 +339,8 @@ const VideoDownloadModal = ({
-

Export Complete!

-

Your video has been successfully exported.

+

Done!

+

Your video is now ready.

diff --git a/resources/js/stores/UserStore.js b/resources/js/stores/UserStore.js index c48797f..4d82b4f 100644 --- a/resources/js/stores/UserStore.js +++ b/resources/js/stores/UserStore.js @@ -68,6 +68,10 @@ const useUserStore = create( }); } + if (response?.data?.success?.message) { + toast.success(response.data.success.message); + } + if (response?.data?.error?.message) { toast.error(response.data.error.message); } @@ -78,9 +82,11 @@ const useUserStore = create( } }, - premiumExportComplete: async () => { + premiumExportComplete: async (exportToken) => { try { - const response = await axiosInstance.post(route('api.user.premium_export.complete')); + const response = await axiosInstance.post(route('api.user.premium_export.complete'), { + export_token: exportToken, + }); if (response?.data?.success?.data?.user_usage) { set({ @@ -88,6 +94,10 @@ const useUserStore = create( }); } + if (response?.data?.success?.message) { + toast.success(response.data.success.message); + } + if (response?.data?.error?.message) { toast.error(response.data.error.message); }