nexus/vuefilemanager
2
0
Fork 0
mirror of https://github.com/VueFileManager/vuefilemanager.git synced 2026-04-28 19:10:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

implemented remote upload progress counter

Browse Source
This commit is contained in:
Čarodej
2022-04-25 10:13:10 +02:00
parent 6a9fa9ceec
commit 954f0e3361
10 changed files with 155 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Domain/Files/Actions/GetContentFromExternalSource.php
+36 -8
View File
@@ -1,4 +1,5 @@
<?php
namespace Domain\Files\Actions;
use Domain\Files\Events\NewFileWasStoredEvent;
@@ -18,18 +19,21 @@ class GetContentFromExternalSource
use QueueableAction;
public function __construct(
public ProcessFileAction $processFile,
public StoreFileExifMetadataAction $storeExifMetadata,
public MoveFileToFTPStorageAction $moveFileToFTPStorage,
public ProcessImageThumbnailAction $createImageThumbnail,
public ProcessFileAction $processFile,
public StoreFileExifMetadataAction $storeExifMetadata,
public MoveFileToFTPStorageAction $moveFileToFTPStorage,
public ProcessImageThumbnailAction $createImageThumbnail,
public MoveFileToExternalStorageAction $moveFileToExternalStorage,
) {
}
) {}
public function __invoke(
array $payload,
User $user,
User $user,
) {
$total = count($payload['urls']);
$processed = 0;
$failed = 0;
foreach ($payload['urls'] as $url) {
try {
// Get local disk instance
@@ -83,9 +87,33 @@ class GetContentFromExternalSource
default => null
};
// Increment processed items count
$processed++;
// Broadcast new file into the frontend
NewFileWasStoredEvent::dispatch(new FileResource($file));
NewFileWasStoredEvent::dispatch([
'progress' => [
'total' => $total,
'processed' => $processed,
'failed' => $failed,
],
'file' => new FileResource($file),
]);
} catch (ErrorException | Error $e) {
// Increment items count
$processed++;
$failed++;
// Broadcast new file into the frontend
NewFileWasStoredEvent::dispatch([
'progress' => [
'total' => $total,
'processed' => $processed,
'failed' => $failed,
],
'file' => null,
]);
Log::error("Remote upload failed as {$e->getMessage()}");
Log::error($e->getTraceAsString());
}
src/Domain/Files/Events/NewFileWasStoredEvent.php
+2 -2
View File
@@ -19,7 +19,7 @@ class NewFileWasStoredEvent implements ShouldBroadcastNow
* @return void
*/
public function __construct(
public FileResource $file,
public array $payload,
) {}
/**
@@ -35,6 +35,6 @@ class NewFileWasStoredEvent implements ShouldBroadcastNow
*/
public function broadcastOn(): PrivateChannel
{
return new PrivateChannel("App.Users.Models.User.{$this->file->user_id}");
return new PrivateChannel("App.Users.Models.User.{$this->payload['file']->user_id}");
}
}