Skip to content

Commit

Permalink
Merge pull request #34 from biigle/patch-1
Browse files Browse the repository at this point in the history
Fix delete job again
  • Loading branch information
mzur authored Jul 1, 2024
2 parents 6cedad0 + 669ca61 commit 15f5929
Show file tree
Hide file tree
Showing 6 changed files with 16 additions and 17 deletions.
14 changes: 7 additions & 7 deletions src/Jobs/DeleteStorageRequestFile.php
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@ class DeleteStorageRequestFile extends Job implements ShouldQueue
use InteractsWithQueue, Batchable;

/**
* File that should be deleted
* ID of the file that should be deleted
*/
public $file;
public $fileId;

/**
* Path of the file to be deleted.
Expand Down Expand Up @@ -60,7 +60,7 @@ class DeleteStorageRequestFile extends Job implements ShouldQueue
*/
public function __construct(StorageRequestFile $file)
{
$this->file = $file;
$this->fileId = $file->id;
$this->path = $file->path;
$this->oldRetryCount = $file->retry_count;
$request = $file->request;
Expand All @@ -80,10 +80,10 @@ public function __construct(StorageRequestFile $file)
*/
public function handle()
{
$fileExists = $this->file && $this->file->exists();
$file = StorageRequestFile::find($this->fileId);

// Do not delete files when delete-request is outdated
if ($fileExists && $this->oldRetryCount != $this->file->refresh()->retry_count) {
if ($file && $this->oldRetryCount != $file->retry_count) {
return;
}

Expand Down Expand Up @@ -117,8 +117,8 @@ public function handle()
}
}

if ($fileExists) {
$this->file->delete();
if ($file) {
$file->delete();
}
}
}
2 changes: 1 addition & 1 deletion tests/Console/Commands/PruneExpiredStorageRequestsTest.php
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ public function testHandle()

Bus::assertBatched(function (PendingBatch $batch) use ($file1) {
$this->assertEquals(1, $batch->jobs->count());
$this->assertEquals($file1->path, $batch->jobs->first()->file->path);
$this->assertEquals($file1->id, $batch->jobs->first()->fileId);
return true;
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -352,7 +352,7 @@ public function testDestroy()

Bus::assertBatched(function (PendingBatch $batch) use ($file) {
$this->assertEquals(1, $batch->jobs->count());
$this->assertEquals($file->path, $batch->jobs->first()->file->path);
$this->assertEquals($file->id, $batch->jobs->first()->fileId);
return true;
});
$this->assertNull($request->fresh());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,8 @@ public function testDestory()
$this->assertNull($file1->fresh());
$this->assertNotNull($file2->fresh());

Queue::assertPushed(function (DeleteStorageRequestFile $job) {
$this->assertSame('a/a.jpg', $job->file->path);
Queue::assertPushed(function (DeleteStorageRequestFile $job) use ($file1) {
$this->assertSame($file1->id, $job->fileId);

return true;
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ public function testStoreChunkTooLargeQuota()
->assertStatus(422);

Bus::assertDispatched(function (DeleteStorageRequestFile $job) {
$this->assertSame('test.jpg', $job->file->path);
$this->assertSame('test.jpg', $job->path);
$this->assertSame([0], $job->chunks);

return true;
Expand Down Expand Up @@ -420,7 +420,7 @@ public function testStoreChunkTooLargeFile()


Bus::assertDispatched(function (DeleteStorageRequestFile $job) {
$this->assertSame('test.jpg', $job->file->path);
$this->assertSame('test.jpg', $job->path);
$this->assertSame([0], $job->chunks);

return true;
Expand Down Expand Up @@ -794,12 +794,11 @@ public function testDestory()

$this->assertNotNull($file->fresh());

Bus::assertDispatched(function (DeleteStorageRequestFile $job) {
$this->assertSame('a.jpg', $job->file->path);
Bus::assertDispatched(function (DeleteStorageRequestFile $job) use ($file) {
$this->assertSame($file->id, $job->fileId);

return true;
});

}

public function testDestoryLastFile()
Expand Down
2 changes: 1 addition & 1 deletion tests/StorageRequestTest.php
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public function testDeleteApprovedFiles()
$this->model->delete();
Bus::assertBatched(function (PendingBatch $batch) use ($file) {
$this->assertEquals(1, $batch->jobs->count());
$this->assertEquals($file->path, $batch->jobs->first()->file->path);
$this->assertEquals($file->id, $batch->jobs->first()->fileId);
return true;
});
}
Expand Down

0 comments on commit 15f5929

Please sign in to comment.