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

Change terminology to pending

This commit is contained in:
j.stein 2022-02-09 22:55:03 +01:00
parent c8eadeb363
commit 500b2538fc
20 changed files with 387 additions and 385 deletions

View file

@ -7,24 +7,24 @@ namespace Stancl\Tenancy\Commands;
use Illuminate\Console\Command;
use Illuminate\Database\Eloquent\Builder;
class ClearReadiedTenants extends Command
class ClearPendingTenants extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'tenants:readied-clear
{--all : Override the default settings and deletes all readied tenants}
{--older-days= : Deletes all readied older than the amount of days}
{--older-hours= : Deletes all readied older than the amount of hours}';
protected $signature = 'tenants:pending-clear
{--all : Override the default settings and deletes all pending tenants}
{--older-days= : Deletes all pending older than the amount of days}
{--older-hours= : Deletes all pending older than the amount of hours}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Removes any readied tenants';
protected $description = 'Removes any pending tenants';
/**
* Execute the console command.
@ -33,7 +33,7 @@ class ClearReadiedTenants extends Command
*/
public function handle()
{
$this->info('Cleaning readied tenants.');
$this->info('Cleaning pending tenants.');
$expireDate = now();
// At the end, we will check if the value has been changed by comparing the two dates
@ -41,27 +41,27 @@ class ClearReadiedTenants extends Command
// If the all option is given, skip the expiry date configuration
if (! $this->option('all')) {
if ($olderThanDays = $this->option('older-days') ?? config('tenancy.readied.older_than_days')) {
if ($olderThanDays = $this->option('older-days') ?? config('tenancy.pending.older_than_days')) {
$expireDate->subDays($olderThanDays);
}
if ($olderThanHours = $this->option('older-hours') ?? config('tenancy.readied.older_than_hours')) {
if ($olderThanHours = $this->option('older-hours') ?? config('tenancy.pending.older_than_hours')) {
$expireDate->subHours($olderThanHours);
}
}
$readiedTenantsDeletedCount = tenancy()
$deletedPendingCount = tenancy()
->query()
->onlyReadied()
->onlyPending()
->when($savedExpiredDate->notEqualTo($expireDate), function (Builder $query) use ($expireDate) {
$query->where('data->readied', '<', $expireDate->timestamp);
$query->where('data->pending_since', '<', $expireDate->timestamp);
})
->get()
->each // This makes sure the events or triggered on the model
->delete()
->count();
$this->info("$readiedTenantsDeletedCount readied tenant(s) deleted.");
$this->info("$deletedPendingCount pending tenant(s) deleted.");
}
}

View file

@ -0,0 +1,64 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Commands;
use Illuminate\Console\Command;
class CreatePendingTenants extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'tenants:pending {--count= The number of tenant to be in a pending state}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Deploy tenants until the pending count is achieved.';
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
$this->info('Deploying pendgin tenants.');
$pendingObjectifCount = (int)config('tenancy.pending.count');
$pendingCurrentCount = $this->getPendingTenantCount();
$deployedCount = 0;
while ($pendingCurrentCount < $pendingObjectifCount) {
tenancy()->model()::createPending();
// We update the number of pending tenants every time with a query to get a live count.
// this prevents to deploy too many tenants if pending tenants are being created simultaneous somewhere else
// during the runtime of this command.
$pendingCurrentCount = $this->getPendingTenantCount();
$deployedCount++;
}
$this->info("$deployedCount tenants deployed, $pendingObjectifCount tenant(s) are ready to be used.");
return self::SUCCESS;
}
/**
* Calculates the number of pending tenants currently deployed
* @return int
*/
private function getPendingTenantCount(): int
{
return tenancy()
->query()
->onlyPending()
->count();
}
}

View file

@ -1,62 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Commands;
use Illuminate\Console\Command;
class CreateReadiedTenants extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'tenants:readied {--count= The number of tenant to be in a readied state}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Deploy tenants until the readied count is achieved.';
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
$this->info('Deploying readied tenants.');
$readiedCountObjectif = (int)config('tenancy.readied.count');
$readiedTenantCount = $this->getReadiedTenantCount();
$deployedCount = 0;
while ($readiedTenantCount < $readiedCountObjectif) {
tenancy()->model()::createReadied();
// We update the number of readied tenant every time with a query to get a live count.
// this prevents to deploy too many tenants if readied tenants have been deployed
// while this command is running.
$readiedTenantCount = $this->getReadiedTenantCount();
$deployedCount++;
}
$this->info("$deployedCount tenants deployed, $readiedCountObjectif tenant(s) are ready to be used.");
}
/**
* Calculates the number of readied tenants currently deployed
* @return int
*/
private function getReadiedTenantCount(): int
{
return tenancy()
->query()
->onlyReadied()
->count();
}
}

View file

@ -0,0 +1,90 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\Concerns;
use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Events\PullingPendingTenant;
use Stancl\Tenancy\Events\PendingTenantPulled;
use Stancl\Tenancy\Events\CreatingPendingTenant;
use Stancl\Tenancy\Events\PendingTenantCreated;
/**
* @property $pending_since
*
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder withPending(bool $withPending = true)
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder onlyPending()
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder withoutPending()
*/
trait HasPending
{
/**
* Boot the has pending trait for a model.
*
* @return void
*/
public static function bootHasPending()
{
static::addGlobalScope(new PendingScope());
}
/**
* Initialize the has pending trait for an instance.
*
* @return void
*/
public function initializeHasPending()
{
$this->casts['pending_since'] = 'timestamp';
}
/**
* Determine if the model instance is in a pending state.
*
* @return bool
*/
public function pending()
{
return !is_null($this->pending_since);
}
public static function createPending($attributes = []): void
{
$tenant = static::create($attributes);
event(new CreatingPendingTenant($tenant));
// We add the pending value only after the model has then been created.
// this ensures the model is not marked as pending until the migrations, seeders, etc. are done
$tenant->update([
'pending_since' => now()->timestamp
]);
event(new PendingTenantCreated($tenant));
}
public static function pullPendingTenant(bool $firstOrCreate = false): ?Tenant
{
if (!static::onlyPending()->exists()) {
if (!$firstOrCreate) {
return null;
}
static::createPending();
}
// At this point we can guarantee a pending tenant is free and can be called.
$tenant = static::onlyPending()->first();
event(new PullingPendingTenant($tenant));
$tenant->update([
'pending_since' => null
]);
event(new PendingTenantPulled($tenant));
return $tenant;
}
}

View file

@ -8,7 +8,7 @@ use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Scope;
class ReadiedScope implements Scope
class PendingScope implements Scope
{
/**
@ -16,7 +16,7 @@ class ReadiedScope implements Scope
*
* @var string[]
*/
protected $extensions = ['WithReadied', 'WithoutReadied', 'OnlyReadied'];
protected $extensions = ['WithPending', 'WithoutPending', 'OnlyPending'];
/**
* Apply the scope to a given Eloquent query builder.
@ -27,8 +27,8 @@ class ReadiedScope implements Scope
*/
public function apply(Builder $builder, Model $model)
{
$builder->when(!config('tenancy.readied.include_in_queries'), function (Builder $builder){
$builder->whereNull('data->readied');
$builder->when(!config('tenancy.pending.include_in_queries'), function (Builder $builder){
$builder->whereNull('data->pending_since');
});
}
@ -45,16 +45,16 @@ class ReadiedScope implements Scope
}
}
/**
* Add the with-readied extension to the builder.
* Add the with-pending extension to the builder.
*
* @param \Illuminate\Database\Eloquent\Builder $builder
* @return void
*/
protected function addWithReadied(Builder $builder)
protected function addWithPending(Builder $builder)
{
$builder->macro('withReadied', function (Builder $builder, $withReadied = true) {
if (! $withReadied) {
return $builder->withoutReadied();
$builder->macro('withPending', function (Builder $builder, $withPending = true) {
if (! $withPending) {
return $builder->withoutPending();
}
return $builder->withoutGlobalScope($this);
@ -62,32 +62,32 @@ class ReadiedScope implements Scope
}
/**
* Add the without-readied extension to the builder.
* Add the without-pending extension to the builder.
*
* @param \Illuminate\Database\Eloquent\Builder $builder
* @return void
*/
protected function addWithoutReadied(Builder $builder)
protected function addWithoutPending(Builder $builder)
{
$builder->macro('withoutReadied', function (Builder $builder) {
$builder->macro('withoutPending', function (Builder $builder) {
$builder->withoutGlobalScope($this)->whereNull('data->readied');
$builder->withoutGlobalScope($this)->whereNull('data->pending_since');
return $builder;
});
}
/**
* Add the only-readied extension to the builder.
* Add the only-pending extension to the builder.
*
* @param \Illuminate\Database\Eloquent\Builder $builder
* @return void
*/
protected function addOnlyReadied(Builder $builder)
protected function addOnlyPending(Builder $builder)
{
$builder->macro('onlyReadied', function (Builder $builder) {
$builder->macro('onlyPending', function (Builder $builder) {
$builder->withoutGlobalScope($this)->whereNotNull('data->readied');
$builder->withoutGlobalScope($this)->whereNotNull('data->pending_since');
return $builder;
});

View file

@ -1,90 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\Concerns;
use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Events\PullingReadiedTenant;
use Stancl\Tenancy\Events\ReadiedTenantPulled;
use Stancl\Tenancy\Events\ReadyingTenant;
use Stancl\Tenancy\Events\TenantReadied;
/**
* @property $readied
*
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder withReadied(bool $withReadied = true)
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder onlyReadied()
* @method static static|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder withoutReadied()
*/
trait WithReadied
{
/**
* Boot the readied trait for a model.
*
* @return void
*/
public static function bootWithReadied()
{
static::addGlobalScope(new ReadiedScope());
}
/**
* Initialize the readied trait for an instance.
*
* @return void
*/
public function initializeWithReadied()
{
$this->casts['readied'] = 'timestamp';
}
/**
* Determine if the model instance is in a readied state.
*
* @return bool
*/
public function readied()
{
return !is_null($this->readied);
}
public static function createReadied($attributes = []): void
{
$tenant = static::create($attributes);
event(new ReadyingTenant($tenant));
// We add the readied value only after the model has then been created.
// this ensures the model is not marked as readied until the migrations, seeders, etc. are done
$tenant->update([
'readied' => now()->timestamp
]);
event(new TenantReadied($tenant));
}
public static function pullReadiedTenant(bool $firstOrCreate = false): ?Tenant
{
if (!static::onlyReadied()->exists()) {
if (!$firstOrCreate) {
return null;
}
static::createReadied();
}
// At this point we can guarantee a readied tenant is free and can be called
$tenant = static::onlyReadied()->first();
event(new PullingReadiedTenant($tenant));
$tenant->update([
'readied' => null
]);
event(new ReadiedTenantPulled($tenant));
return $tenant;
}
}

View file

@ -27,7 +27,7 @@ class Tenant extends Model implements Contracts\Tenant
Concerns\HasInternalKeys,
Concerns\TenantRun,
Concerns\InvalidatesResolverCache,
Concerns\WithReadied;
Concerns\HasPending;
protected $table = 'tenants';
protected $primaryKey = 'id';

View file

@ -4,6 +4,6 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Events;
class TenantReadied extends Contracts\TenantEvent
class CreatingPendingTenant extends Contracts\TenantEvent
{
}

View file

@ -4,6 +4,6 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Events;
class PullingReadiedTenant extends Contracts\TenantEvent
class PendingTenantCreated extends Contracts\TenantEvent
{
}

View file

@ -4,6 +4,6 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Events;
class ReadiedTenantPulled extends Contracts\TenantEvent
class PendingTenantPulled extends Contracts\TenantEvent
{
}

View file

@ -4,6 +4,6 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Events;
class ReadyingTenant extends Contracts\TenantEvent
class PullingPendingTenant extends Contracts\TenantEvent
{
}

View file

@ -12,7 +12,7 @@ use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Artisan;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
class ClearReadiedTenants implements ShouldQueue
class ClearPendingTenants implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
@ -23,6 +23,6 @@ class ClearReadiedTenants implements ShouldQueue
*/
public function handle()
{
Artisan::call('tenants:readied-clear');
Artisan::call(\Stancl\Tenancy\Commands\ClearPendingTenants::class);
}
}

View file

@ -12,7 +12,7 @@ use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Artisan;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
class CreateReadiedTenants implements ShouldQueue
class CreatePendingTenants implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
@ -23,6 +23,6 @@ class CreateReadiedTenants implements ShouldQueue
*/
public function handle()
{
Artisan::call('tenants:readied');
Artisan::call(\Stancl\Tenancy\Commands\CreatePendingTenants::class);
}
}

View file

@ -89,8 +89,8 @@ class TenancyServiceProvider extends ServiceProvider
Commands\Rollback::class,
Commands\TenantList::class,
Commands\MigrateFresh::class,
Commands\CreateReadiedTenants::class,
Commands\ClearReadiedTenants::class,
Commands\CreatePendingTenants::class,
Commands\ClearPendingTenants::class,
]);
$this->publishes([