archtechx/tenancy
1
0
Fork 0
mirror of https://github.com/archtechx/tenancy.git synced 2026-02-06 02:24:04 +00:00
Code Activity

Setting $deleteWhenCannotIdentify property deletes the job if it could not be initialized

Browse source 
Signed-off-by: michael.lundb <>
This commit is contained in:
michael.lundb 2022-02-22 13:14:14 +01:00
parent 5b9b384526
commit e28060f4fd
2 changed files with 84 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

46
tests/QueueTest.php
View file

@ -244,6 +244,30 @@ class QueueTest extends TestCase
$this->assertSame('The current tenant id is: acme', $this->valuestore->get('tenant_id'));
}
/** @test */
public function job_can_be_when_not_initialized_inside_queues()
{
$tenant = Tenant::create([
'id' => 'acme',
]);
tenancy()->initialize($tenant);
dispatch(new TestJobDeleted($this->valuestore));
$this->assertEquals(1, \Illuminate\Support\Facades\Queue::size());
$this->assertFalse($this->valuestore->has('tenant_id'));
tenancy()->end();
$tenant->delete();
$this->artisan('queue:work --once');
$this->assertFalse($this->valuestore->has('tenant_id'));
$this->assertEquals(0, \Illuminate\Support\Facades\Queue::size());
}
}
class TestJob implements ShouldQueue
@ -281,3 +305,25 @@ class TestJob implements ShouldQueue
}
}
}
class TestJobDeleted implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var Valuestore */
protected $valuestore;
public $deleteWhenCannotIdentify = true;
public function __construct(Valuestore $valuestore)
{
$this->valuestore = $valuestore;
}
public function handle()
{
$this->valuestore->put('tenant_id', tenant('id'));
}
}