1
0
Fork 0
mirror of https://github.com/archtechx/tenancy.git synced 2025-12-13 19:44:04 +00:00

Merge branch 'master' into storage-url-conflict-resolution

This commit is contained in:
lukinovec 2022-09-22 14:04:14 +02:00
commit 9206dafd28
109 changed files with 1147 additions and 754 deletions

View file

@ -1,32 +1,91 @@
name: CI name: CI
env: env:
COMPOSE_INTERACTIVE_NO_CLI: 1
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
on: on:
push: push:
branches: [ master ]
pull_request: pull_request:
branches: [ master ] branches: [ master ]
jobs: jobs:
tests: tests:
runs-on: ubuntu-latest runs-on: ubuntu-latest
container: archtechx/tenancy:latest
strategy: strategy:
matrix: matrix:
php: ["8.1"] laravel: ['^9.0']
laravel: ["^9.0"]
steps: steps:
- uses: actions/checkout@v2 - name: Checkout
- name: Start docker containers uses: actions/checkout@v2
run: PHP_VERSION=${{ matrix.php }} docker-compose up -d
- name: Install dependencies - name: Install Composer dependencies
run: docker-compose exec -T test composer require --no-interaction "laravel/framework:${{ matrix.laravel }}" run: |
composer require "laravel/framework:${{ matrix.laravel }}" --no-interaction --no-update
composer update --prefer-dist --no-interaction
- name: Run tests - name: Run tests
run: ./test run: ./vendor/bin/pest
env:
DB_PASSWORD: password
DB_USERNAME: root
DB_DATABASE: main
TENANCY_TEST_MYSQL_HOST: mysql
TENANCY_TEST_PGSQL_HOST: postgres
TENANCY_TEST_REDIS_HOST: redis
TENANCY_TEST_SQLSRV_HOST: mssql
- name: Upload coverage to Codecov
uses: codecov/codecov-action@v2
with:
token: 24382d15-84e7-4a55-bea4-c4df96a24a9b
services:
postgres:
image: postgres:latest
env:
POSTGRES_PASSWORD: password
POSTGRES_USER: root
POSTGRES_DB: main
ports:
- 5432/tcp
options: --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 3
mysql:
image: mysql:5.7
env:
MYSQL_ALLOW_EMPTY_PASSWORD: false
MYSQL_ROOT_PASSWORD: password
MYSQL_DATABASE: main
ports:
- 3306/tcp
options: --health-cmd="mysqladmin ping" --health-interval=10s --health-timeout=5s --health-retries=3
mysql2:
image: mysql:5.7
env:
MYSQL_ALLOW_EMPTY_PASSWORD: false
MYSQL_ROOT_PASSWORD: password
MYSQL_DATABASE: main
ports:
- 3306/tcp
options: --health-cmd="mysqladmin ping" --health-interval=10s --health-timeout=5s --health-retries=3
mssql:
image: mcr.microsoft.com/mssql/server:2019-latest
ports:
- 1433/tcp
env:
ACCEPT_EULA: Y
SA_PASSWORD: P@ssword
options: --health-cmd "echo quit | /opt/mssql-tools/bin/sqlcmd -S 127.0.0.1 -l 1 -U sa -P P@ssword"
redis:
image: redis
ports:
- 6379/tcp
options: --health-cmd="redis-cli ping" --health-interval=10s --health-timeout=5s --health-retries=3
php-cs-fixer: php-cs-fixer:
name: Code style (php-cs-fixer) name: Code style (php-cs-fixer)

View file

@ -8,8 +8,24 @@ php-cs-fixer will fix code style violations in your pull requests.
Run `composer docker-up` to start the containers. Then run `composer test` to run the tests. Run `composer docker-up` to start the containers. Then run `composer test` to run the tests.
If you need to pass additional flags to phpunit, use `./test --foo` instead of `composer test --foo`. Composer scripts unfortunately don't pass CLI arguments.
When you're done testing, run `composer docker-down` to shut down the containers. When you're done testing, run `composer docker-down` to shut down the containers.
### Docker on M1 ### Docker on M1
Run `composer docker-m1` to symlink `docker-compose-m1.override.yml` to `docker-compose.override.yml`. This will reconfigure a few services in the docker compose config to be compatible with M1. Run `composer docker-m1` to symlink `docker-compose-m1.override.yml` to `docker-compose.override.yml`. This will reconfigure a few services in the docker compose config to be compatible with M1.
### Coverage reports
To run tests and generate coverage reports, use `composer test-full`.
To view the coverage reports in your browser, use `composer coverage` (works on macOS; on other operating systems you can manually open `coverage/phpunit/html/index.html` in your browser).
### Rebuilding containers
If you need to rebuild the container for any reason (e.g. a change in `Dockerfile`), you can use `composer docker-rebuild`.
## PHPStan
Use `composer phpstan` to run our phpstan suite.

View file

@ -1,59 +1,42 @@
ARG PHP_VERSION=7.4 # add amd64 platform to support Mac M1
ARG PHP_TARGET=php:${PHP_VERSION}-cli FROM --platform=linux/amd64 shivammathur/node:latest-amd64
FROM --platform=linux/amd64 ${PHP_TARGET} ARG PHP_VERSION=8.1
ARG COMPOSER_TARGET=2.0.3
WORKDIR /var/www/html WORKDIR /var/www/html
LABEL org.opencontainers.image.source=https://github.com/stancl/tenancy \
org.opencontainers.image.vendor="Samuel Štancl" \
org.opencontainers.image.licenses="MIT" \
org.opencontainers.image.title="PHP ${PHP_VERSION} with modules for laravel support" \
org.opencontainers.image.description="PHP ${PHP_VERSION} with a set of php/os packages suitable for running Laravel apps"
# our default timezone and langauge # our default timezone and langauge
ENV TZ=Europe/London ENV TZ=Europe/London
ENV LANG=en_GB.UTF-8 ENV LANG=en_GB.UTF-8
# Note: we only install reliable/core 1st-party php extensions here. # install MYSSQL ODBC Driver
# If your app needs custom ones install them in the apps own
# Dockerfile _and pin the versions_! Eg:
# RUN pecl install memcached-2.2.0 && docker-php-ext-enable memcached
RUN apt-get update \ RUN apt-get update \
&& apt-get install -y gnupg2 \ && apt-get install -y gnupg2 \
&& curl https://packages.microsoft.com/keys/microsoft.asc | apt-key add - \ && curl https://packages.microsoft.com/keys/microsoft.asc | apt-key add - \
&& curl https://packages.microsoft.com/config/debian/11/prod.list > /etc/apt/sources.list.d/mssql-release.list \ && curl https://packages.microsoft.com/config/ubuntu/20.04/prod.list > /etc/apt/sources.list.d/mssql-release.list \
&& apt-get update \ && apt-get update \
&& ACCEPT_EULA=Y apt-get install -y unixodbc-dev msodbcsql17 && ACCEPT_EULA=Y apt-get install -y unixodbc-dev msodbcsql17
RUN apt-get install -y --no-install-recommends locales apt-transport-https libfreetype6-dev libjpeg62-turbo-dev libpng-dev libgmp-dev libldap2-dev netcat curl mariadb-client sqlite3 libsqlite3-dev libpq-dev libzip-dev unzip vim-tiny gosu git # set PHP version
RUN update-alternatives --set php /usr/bin/php$PHP_VERSION \
&& update-alternatives --set phar /usr/bin/phar$PHP_VERSION \
&& update-alternatives --set phar.phar /usr/bin/phar.phar$PHP_VERSION \
&& update-alternatives --set phpize /usr/bin/phpize$PHP_VERSION \
&& update-alternatives --set php-config /usr/bin/php-config$PHP_VERSION
RUN apt-get update \
&& apt-get install -y --no-install-recommends libhiredis0.14 libjemalloc2 liblua5.1-0 lua-bitop lua-cjson redis redis-server redis-tools
RUN pecl install redis-5.3.7 sqlsrv pdo_sqlsrv pcov \
&& printf "; priority=20\nextension=redis.so\n" > /etc/php/$PHP_VERSION/mods-available/redis.ini \
&& printf "; priority=20\nextension=sqlsrv.so\n" > /etc/php/$PHP_VERSION/mods-available/sqlsrv.ini \
&& printf "; priority=30\nextension=pdo_sqlsrv.so\n" > /etc/php/$PHP_VERSION/mods-available/pdo_sqlsrv.ini \
&& printf "; priority=40\nextension=pcov.so\n" > /etc/php/$PHP_VERSION/mods-available/pcov.ini \
&& phpenmod -v $PHP_VERSION redis sqlsrv pdo_sqlsrv pcov
# install composer
COPY --from=composer:latest /usr/bin/composer /usr/local/bin/composer
RUN docker-php-ext-configure pgsql -with-pgsql=/usr/local/pgsql \
# && if [ "${PHP_VERSION}" = "7.4" ]; then docker-php-ext-configure gd --with-freetype --with-jpeg; else docker-php-ext-configure gd --with-freetype-dir=/usr/include/ --with-jpeg-dir=/usr/include/; fi \
&& docker-php-ext-install -j$(nproc) gd pdo pdo_mysql pdo_pgsql pdo_sqlite pgsql zip gmp bcmath pcntl ldap sysvmsg exif \
# install the redis php extension
&& pecl install redis-5.3.7 \
&& docker-php-ext-enable redis \
# install the pcov extention
&& pecl install pcov \
&& docker-php-ext-enable pcov \
&& echo "pcov.enabled = 1" > /usr/local/etc/php/conf.d/pcov.ini \
# install sqlsrv
&& pecl install sqlsrv pdo_sqlsrv \
&& docker-php-ext-enable sqlsrv pdo_sqlsrv
# clear the apt cache
RUN rm -rf /var/lib/apt/lists/* \
&& rm -rf /var/lib/apt/lists/* \
# install composer
&& curl -o /tmp/composer-setup.php https://getcomposer.org/installer \
&& curl -o /tmp/composer-setup.sig https://composer.github.io/installer.sig \
&& php -r "if (hash('SHA384', file_get_contents('/tmp/composer-setup.php')) !== trim(file_get_contents('/tmp/composer-setup.sig'))) { unlink('/tmp/composer-setup.php'); echo 'Invalid installer' . PHP_EOL; exit(1); }" \
&& php /tmp/composer-setup.php --version=${COMPOSER_TARGET} --no-ansi --install-dir=/usr/local/bin --filename=composer --snapshot \
&& rm -f /tmp/composer-setup.*
# set the system timezone # set the system timezone
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime \ RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime \
&& echo $TZ > /etc/timezone && echo $TZ > /etc/timezone

View file

@ -58,22 +58,22 @@ return [
* TenantDatabaseManagers are classes that handle the creation & deletion of tenant databases. * TenantDatabaseManagers are classes that handle the creation & deletion of tenant databases.
*/ */
'managers' => [ 'managers' => [
'sqlite' => Stancl\Tenancy\TenantDatabaseManagers\SQLiteDatabaseManager::class, 'sqlite' => Stancl\Tenancy\Database\TenantDatabaseManagers\SQLiteDatabaseManager::class,
'mysql' => Stancl\Tenancy\TenantDatabaseManagers\MySQLDatabaseManager::class, 'mysql' => Stancl\Tenancy\Database\TenantDatabaseManagers\MySQLDatabaseManager::class,
'pgsql' => Stancl\Tenancy\TenantDatabaseManagers\PostgreSQLDatabaseManager::class, 'pgsql' => Stancl\Tenancy\Database\TenantDatabaseManagers\PostgreSQLDatabaseManager::class,
'sqlsrv' => Stancl\Tenancy\TenantDatabaseManagers\MicrosoftSQLDatabaseManager::class, 'sqlsrv' => Stancl\Tenancy\Database\TenantDatabaseManagers\MicrosoftSQLDatabaseManager::class,
/** /**
* Use this database manager for MySQL to have a DB user created for each tenant database. * Use this database manager for MySQL to have a DB user created for each tenant database.
* You can customize the grants given to these users by changing the $grants property. * You can customize the grants given to these users by changing the $grants property.
*/ */
// 'mysql' => Stancl\Tenancy\TenantDatabaseManagers\PermissionControlledMySQLDatabaseManager::class, // 'mysql' => Stancl\Tenancy\Database\TenantDatabaseManagers\PermissionControlledMySQLDatabaseManager::class,
/** /**
* Disable the pgsql manager above, and enable the one below if you * Disable the pgsql manager above, and enable the one below if you
* want to separate tenant DBs by schemas rather than databases. * want to separate tenant DBs by schemas rather than databases.
*/ */
// 'pgsql' => Stancl\Tenancy\TenantDatabaseManagers\PostgreSQLSchemaManager::class, // Separate by schema instead of database // 'pgsql' => Stancl\Tenancy\Database\TenantDatabaseManagers\PostgreSQLSchemaManager::class, // Separate by schema instead of database
], ],
], ],

View file

@ -18,10 +18,10 @@
"php": "^8.1", "php": "^8.1",
"ext-json": "*", "ext-json": "*",
"illuminate/support": "^9.0", "illuminate/support": "^9.0",
"facade/ignition-contracts": "^1.0", "spatie/ignition": "^1.4",
"ramsey/uuid": "^4.0", "ramsey/uuid": "^4.0",
"stancl/jobpipeline": "^1.6", "stancl/jobpipeline": "^1.0",
"stancl/virtualcolumn": "^1.2" "stancl/virtualcolumn": "^1.0"
}, },
"require-dev": { "require-dev": {
"laravel/framework": "^9.0", "laravel/framework": "^9.0",
@ -29,7 +29,8 @@
"league/flysystem-aws-s3-v3": "^3.0", "league/flysystem-aws-s3-v3": "^3.0",
"doctrine/dbal": "^2.10", "doctrine/dbal": "^2.10",
"spatie/valuestore": "^1.2.5", "spatie/valuestore": "^1.2.5",
"pestphp/pest": "^1.21" "pestphp/pest": "^1.21",
"nunomaduro/larastan": "^1.0"
}, },
"autoload": { "autoload": {
"psr-4": { "psr-4": {
@ -60,7 +61,10 @@
"docker-down": "PHP_VERSION=8.1 docker-compose down", "docker-down": "PHP_VERSION=8.1 docker-compose down",
"docker-rebuild": "PHP_VERSION=8.1 docker-compose up -d --no-deps --build", "docker-rebuild": "PHP_VERSION=8.1 docker-compose up -d --no-deps --build",
"docker-m1": "ln -s docker-compose-m1.override.yml docker-compose.override.yml", "docker-m1": "ln -s docker-compose-m1.override.yml docker-compose.override.yml",
"test": "PHP_VERSION=8.1 ./test" "coverage": "open coverage/phpunit/html/index.html",
"phpstan": "vendor/bin/phpstan",
"test": "PHP_VERSION=8.1 ./test --no-coverage",
"test-full": "PHP_VERSION=8.1 ./test"
}, },
"minimum-stability": "dev", "minimum-stability": "dev",
"prefer-stable": true, "prefer-stable": true,

View file

@ -12,6 +12,8 @@ services:
condition: service_healthy condition: service_healthy
redis: redis:
condition: service_healthy condition: service_healthy
# mssql:
# condition: service_healthy
volumes: volumes:
- .:/var/www/html:delegated - .:/var/www/html:delegated
environment: environment:
@ -74,4 +76,8 @@ services:
environment: environment:
- ACCEPT_EULA=Y - ACCEPT_EULA=Y
- SA_PASSWORD=P@ssword # todo reuse values from env above - SA_PASSWORD=P@ssword # todo reuse values from env above
# todo missing health check healthcheck:
test: /opt/mssql-tools/bin/sqlcmd -S localhost -U sa -P P@ssword -Q "SELECT 1" -b -o /dev/null
interval: 10s
timeout: 10s
retries: 10

25
phpstan.neon Normal file
View file

@ -0,0 +1,25 @@
includes:
- ./vendor/nunomaduro/larastan/extension.neon
parameters:
paths:
- src
# - tests
level: 8
universalObjectCratesClasses:
- Illuminate\Routing\Route
ignoreErrors:
-
message: '#Cannot access offset (.*?) on Illuminate\\Contracts\\Foundation\\Application#'
paths:
- src/TenancyServiceProvider.php
-
message: '#invalid type Laravel\\Telescope\\IncomingEntry#'
paths:
- src/Features/TelescopeTags.php
checkMissingIterableValueType: false
treatPhpDocTypesAsCertain: false

View file

@ -6,7 +6,7 @@ namespace Stancl\Tenancy\Bootstrappers;
use Stancl\Tenancy\Contracts\TenancyBootstrapper; use Stancl\Tenancy\Contracts\TenancyBootstrapper;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Database\DatabaseManager; use Stancl\Tenancy\Database\DatabaseManager;
use Stancl\Tenancy\Exceptions\TenantDatabaseDoesNotExistException; use Stancl\Tenancy\Exceptions\TenantDatabaseDoesNotExistException;

View file

@ -0,0 +1,42 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Bootstrappers\Integrations;
use Illuminate\Contracts\Config\Repository;
use Stancl\Tenancy\Contracts\TenancyBootstrapper;
use Stancl\Tenancy\Contracts\Tenant;
class ScoutTenancyBootstrapper implements TenancyBootstrapper
{
/** @var Repository */
protected $config;
/** @var string */
protected $originalScoutPrefix;
public function __construct(Repository $config)
{
$this->config = $config;
}
public function bootstrap(Tenant $tenant)
{
if (! isset($this->originalScoutPrefix)) {
$this->originalScoutPrefix = $this->config->get('scout.prefix');
}
$this->config->set('scout.prefix', $this->getTenantPrefix($tenant));
}
public function revert()
{
$this->config->set('scout.prefix', $this->originalScoutPrefix);
}
protected function getTenantPrefix(Tenant $tenant): string
{
return (string) $tenant->getTenantKey();
}
}

View file

@ -6,6 +6,8 @@ namespace Stancl\Tenancy;
use Illuminate\Cache\CacheManager as BaseCacheManager; use Illuminate\Cache\CacheManager as BaseCacheManager;
// todo move to Cache namespace?
class CacheManager extends BaseCacheManager class CacheManager extends BaseCacheManager
{ {
/** /**
@ -26,7 +28,7 @@ class CacheManager extends BaseCacheManager
} }
$names = $parameters[0]; $names = $parameters[0];
$names = (array) $names; // cache()->tags('foo') https://laravel.com/docs/5.7/cache#removing-tagged-cache-items $names = (array) $names; // cache()->tags('foo') https://laravel.com/docs/9.x/cache#removing-tagged-cache-items
return $this->store()->tags(array_merge($tags, $names)); return $this->store()->tags(array_merge($tags, $names));
} }

View file

@ -5,6 +5,9 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Commands; namespace Stancl\Tenancy\Commands;
use Illuminate\Console\Command; use Illuminate\Console\Command;
use Illuminate\Contracts\Console\Kernel;
use Symfony\Component\Console\Input\ArgvInput;
use Symfony\Component\Console\Output\ConsoleOutput;
class Run extends Command class Run extends Command
{ {
@ -20,36 +23,35 @@ class Run extends Command
* *
* @var string * @var string
*/ */
protected $signature = "tenants:run {commandname : The command's name.} protected $signature = 'tenants:run {commandname : The artisan command.}
{--tenants=* : The tenant(s) to run the command for. Default: all} {--tenants=* : The tenant(s) to run the command for. Default: all}';
{--argument=* : The arguments to pass to the command. Default: none}
{--option=* : The options to pass to the command. Default: none}";
/** /**
* Execute the console command. * Execute the console command.
*/ */
public function handle() public function handle()
{ {
tenancy()->runForMultiple($this->option('tenants'), function ($tenant) { $argvInput = $this->ArgvInput();
tenancy()->runForMultiple($this->option('tenants'), function ($tenant) use ($argvInput) {
$this->line("Tenant: {$tenant->getTenantKey()}"); $this->line("Tenant: {$tenant->getTenantKey()}");
$callback = function ($prefix = '') { $this->getLaravel()
return function ($arguments, $argument) use ($prefix) { ->make(Kernel::class)
[$key, $value] = explode('=', $argument, 2); ->handle($argvInput, new ConsoleOutput);
$arguments[$prefix . $key] = $value;
return $arguments;
};
};
// Turns ['foo=bar', 'abc=xyz=zzz'] into ['foo' => 'bar', 'abc' => 'xyz=zzz']
$arguments = array_reduce($this->option('argument'), $callback(), []);
// Turns ['foo=bar', 'abc=xyz=zzz'] into ['--foo' => 'bar', '--abc' => 'xyz=zzz']
$options = array_reduce($this->option('option'), $callback('--'), []);
// Run command
$this->call($this->argument('commandname'), array_merge($arguments, $options));
}); });
} }
/**
* Get command as ArgvInput instance.
*/
protected function ArgvInput(): ArgvInput
{
// Convert string command to array
$subCommand = explode(' ', $this->argument('commandname'));
// Add "artisan" as first parameter because ArgvInput expects "artisan" as first parameter and later removes it
array_unshift($subCommand, 'artisan');
return new ArgvInput($subCommand);
}
} }

View file

@ -0,0 +1,72 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Concerns;
use Closure;
use Stancl\Tenancy\Enums\LogMode;
use Stancl\Tenancy\Events\Contracts\TenancyEvent;
use Stancl\Tenancy\Tenancy;
// todo finish this feature
/**
* @mixin Tenancy
*/
trait Debuggable
{
protected LogMode $logMode = LogMode::NONE;
protected array $eventLog = [];
public function log(LogMode $mode = LogMode::SILENT): static
{
$this->eventLog = [];
$this->logMode = $mode;
return $this;
}
public function logMode(): LogMode
{
return $this->logMode;
}
public function getLog(): array
{
return $this->eventLog;
}
public function logEvent(TenancyEvent $event): static
{
$this->eventLog[] = ['time' => now(), 'event' => $event::class, 'tenant' => $this->tenant];
return $this;
}
public function dump(Closure $dump = null): static
{
$dump ??= dd(...);
// Dump the log if we were already logging in silent mode
// Otherwise start logging in instant mode
match ($this->logMode) {
LogMode::NONE => $this->log(LogMode::INSTANT),
LogMode::SILENT => $dump($this->eventLog),
LogMode::INSTANT => null,
};
return $this;
}
public function dd(Closure $dump = null): void
{
$dump ??= dd(...);
if ($this->logMode === LogMode::SILENT) {
$dump($this->eventLog);
} else {
$dump($this);
}
}
}

View file

@ -7,6 +7,8 @@ namespace Stancl\Tenancy\Contracts;
use Illuminate\Database\Eloquent\Collection; use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\Relations\BelongsToMany; use Illuminate\Database\Eloquent\Relations\BelongsToMany;
// todo move all resource syncing-related things to a separate namespace?
/** /**
* @property-read Tenant[]|Collection $tenants * @property-read Tenant[]|Collection $tenants
*/ */

View file

@ -8,11 +8,11 @@ interface Syncable
{ {
public function getGlobalIdentifierKeyName(): string; public function getGlobalIdentifierKeyName(): string;
public function getGlobalIdentifierKey(); public function getGlobalIdentifierKey(): string|int;
public function getCentralModelName(): string; public function getCentralModelName(): string;
public function getSyncedAttributeNames(): array; public function getSyncedAttributeNames(): array;
public function triggerSyncEvent(); public function triggerSyncEvent(): void;
} }

View file

@ -4,11 +4,11 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Contracts; namespace Stancl\Tenancy\Contracts;
use Closure;
/** /**
* @see \Stancl\Tenancy\Database\Models\Tenant * @see \Stancl\Tenancy\Database\Models\Tenant
* *
* @method __call(string $method, array $parameters) IDE support. This will be a model.
* @method static __callStatic(string $method, array $parameters) IDE support. This will be a model.
* @mixin \Illuminate\Database\Eloquent\Model * @mixin \Illuminate\Database\Eloquent\Model
*/ */
interface Tenant interface Tenant
@ -17,14 +17,14 @@ interface Tenant
public function getTenantKeyName(): string; public function getTenantKeyName(): string;
/** Get the value of the key used for identifying the tenant. */ /** Get the value of the key used for identifying the tenant. */
public function getTenantKey(); public function getTenantKey(): int|string;
/** Get the value of an internal key. */ /** Get the value of an internal key. */
public function getInternal(string $key); public function getInternal(string $key): mixed;
/** Set the value of an internal key. */ /** Set the value of an internal key. */
public function setInternal(string $key, $value); public function setInternal(string $key, mixed $value): static;
/** Run a callback in this tenant's environment. */ /** Run a callback in this tenant's environment. */
public function run(callable $callback); public function run(Closure $callback): mixed;
} }

View file

@ -5,7 +5,49 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Contracts; namespace Stancl\Tenancy\Contracts;
use Exception; use Exception;
use Spatie\Ignition\Contracts\BaseSolution;
use Spatie\Ignition\Contracts\ProvidesSolution;
abstract class TenantCouldNotBeIdentifiedException extends Exception abstract class TenantCouldNotBeIdentifiedException extends Exception implements ProvidesSolution
{ {
/** Default solution title. */
protected string $solutionTitle = 'Tenant could not be identified';
/** Default solution description. */
protected string $solutionDescription = 'Are you sure this tenant exists?';
/** Set the message. */
protected function tenantCouldNotBeIdentified(string $how): static
{
$this->message = 'Tenant could not be identified ' . $how;
return $this;
}
/** Set the solution title. */
protected function title(string $solutionTitle): static
{
$this->solutionTitle = $solutionTitle;
return $this;
}
/** Set the solution description. */
protected function description(string $solutionDescription): static
{
$this->solutionDescription = $solutionDescription;
return $this;
}
/** Get the Ignition description. */
public function getSolution(): BaseSolution
{
return BaseSolution::create($this->solutionTitle)
->setSolutionDescription($this->solutionDescription)
->setDocumentationLinks([
'Tenants' => 'https://tenancyforlaravel.com/docs/v3/tenants',
'Tenant Identification' => 'https://tenancyforlaravel.com/docs/v3/tenant-identification',
]);
}
} }

View file

@ -11,5 +11,5 @@ interface TenantResolver
* *
* @throws TenantCouldNotBeIdentifiedException * @throws TenantCouldNotBeIdentifiedException
*/ */
public function resolve(...$args): Tenant; public function resolve(mixed ...$args): Tenant;
} }

View file

@ -1,15 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Contracts;
use Stancl\Tenancy\DatabaseConfig;
interface TenantWithDatabase extends Tenant
{
public function database(): DatabaseConfig;
/** Get an internal key. */
public function getInternal(string $key);
}

View file

@ -4,22 +4,26 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Controllers; namespace Stancl\Tenancy\Controllers;
use Closure;
use Illuminate\Routing\Controller; use Illuminate\Routing\Controller;
use Throwable;
class TenantAssetsController extends Controller class TenantAssetsController extends Controller
{ {
public static $tenancyMiddleware = 'Stancl\Tenancy\Middleware\InitializeTenancyByDomain'; public static string|array|Closure $tenancyMiddleware = Stancl\Tenancy\Middleware\InitializeTenancyByDomain::class;
public function __construct() public function __construct()
{ {
$this->middleware(static::$tenancyMiddleware); $this->middleware(static::$tenancyMiddleware);
} }
public function asset($path) public function asset(string $path = null)
{ {
abort_if($path === null, 404);
try { try {
return response()->file(storage_path("app/public/$path")); return response()->file(storage_path("app/public/$path"));
} catch (\Throwable $th) { } catch (Throwable) {
abort(404); abort(404);
} }
} }

View file

@ -10,7 +10,7 @@ trait BelongsToPrimaryModel
{ {
abstract public function getRelationshipToPrimaryModel(): string; abstract public function getRelationshipToPrimaryModel(): string;
public static function bootBelongsToPrimaryModel() public static function bootBelongsToPrimaryModel(): void
{ {
static::addGlobalScope(new ParentModelScope); static::addGlobalScope(new ParentModelScope);
} }

View file

@ -19,7 +19,7 @@ trait BelongsToTenant
return $this->belongsTo(config('tenancy.tenant_model'), BelongsToTenant::$tenantIdColumn); return $this->belongsTo(config('tenancy.tenant_model'), BelongsToTenant::$tenantIdColumn);
} }
public static function bootBelongsToTenant() public static function bootBelongsToTenant(): void
{ {
static::addGlobalScope(new TenantScope); static::addGlobalScope(new TenantScope);

View file

@ -6,7 +6,7 @@ namespace Stancl\Tenancy\Database\Concerns;
trait ConvertsDomainsToLowercase trait ConvertsDomainsToLowercase
{ {
public static function bootConvertsDomainsToLowercase() public static function bootConvertsDomainsToLowercase(): void
{ {
static::saving(function ($model) { static::saving(function ($model) {
$model->domain = strtolower($model->domain); $model->domain = strtolower($model->domain);

View file

@ -2,9 +2,9 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Concerns; namespace Stancl\Tenancy\Database\Concerns;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
trait CreatesDatabaseUsers trait CreatesDatabaseUsers
{ {

View file

@ -8,7 +8,7 @@ use Stancl\Tenancy\Exceptions\DomainOccupiedByOtherTenantException;
trait EnsuresDomainIsNotOccupied trait EnsuresDomainIsNotOccupied
{ {
public static function bootEnsuresDomainIsNotOccupied() public static function bootEnsuresDomainIsNotOccupied(): void
{ {
static::saving(function ($self) { static::saving(function ($self) {
if ($domain = $self->newQuery()->where('domain', $self->domain)->first()) { if ($domain = $self->newQuery()->where('domain', $self->domain)->first()) {

View file

@ -8,7 +8,7 @@ use Stancl\Tenancy\Contracts\UniqueIdentifierGenerator;
trait GeneratesIds trait GeneratesIds
{ {
public static function bootGeneratesIds() public static function bootGeneratesIds(): void
{ {
static::creating(function (self $model) { static::creating(function (self $model) {
if (! $model->getKey() && $model->shouldGenerateId()) { if (! $model->getKey() && $model->shouldGenerateId()) {

View file

@ -4,8 +4,8 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Database\Concerns; namespace Stancl\Tenancy\Database\Concerns;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\DatabaseConfig; use Stancl\Tenancy\Database\DatabaseConfig;
trait HasDatabase trait HasDatabase
{ {

View file

@ -2,6 +2,8 @@
declare(strict_types=1); declare(strict_types=1);
// todo not sure if this should be in Database\
namespace Stancl\Tenancy\Database\Concerns; namespace Stancl\Tenancy\Database\Concerns;
use Stancl\Tenancy\Contracts\Domain; use Stancl\Tenancy\Contracts\Domain;

View file

@ -6,26 +6,20 @@ namespace Stancl\Tenancy\Database\Concerns;
trait HasInternalKeys trait HasInternalKeys
{ {
/** /** Get the internal prefix. */
* Get the internal prefix.
*/
public static function internalPrefix(): string public static function internalPrefix(): string
{ {
return 'tenancy_'; return 'tenancy_';
} }
/** /** Get an internal key. */
* Get an internal key. public function getInternal(string $key): mixed
*/
public function getInternal(string $key)
{ {
return $this->getAttribute(static::internalPrefix() . $key); return $this->getAttribute(static::internalPrefix() . $key);
} }
/** /** Set internal key. */
* Set internal key. public function setInternal(string $key, mixed $value): static
*/
public function setInternal(string $key, $value)
{ {
$this->setAttribute(static::internalPrefix() . $key, $value); $this->setAttribute(static::internalPrefix() . $key, $value);

View file

@ -16,7 +16,7 @@ trait InvalidatesResolverCache
Resolvers\RequestDataTenantResolver::class, Resolvers\RequestDataTenantResolver::class,
]; ];
public static function bootInvalidatesResolverCache() public static function bootInvalidatesResolverCache(): void
{ {
static::saved(function (Tenant $tenant) { static::saved(function (Tenant $tenant) {
foreach (static::$resolvers as $resolver) { foreach (static::$resolvers as $resolver) {

View file

@ -19,7 +19,7 @@ trait InvalidatesTenantsResolverCache
Resolvers\RequestDataTenantResolver::class, Resolvers\RequestDataTenantResolver::class,
]; ];
public static function bootInvalidatesTenantsResolverCache() public static function bootInvalidatesTenantsResolverCache(): void
{ {
static::saved(function (Model $model) { static::saved(function (Model $model) {
foreach (static::$resolvers as $resolver) { foreach (static::$resolvers as $resolver) {

View file

@ -10,7 +10,7 @@ use Stancl\Tenancy\Events\SyncedResourceSaved;
trait ResourceSyncing trait ResourceSyncing
{ {
public static function bootResourceSyncing() public static function bootResourceSyncing(): void
{ {
static::saved(function (Syncable $model) { static::saved(function (Syncable $model) {
/** @var ResourceSyncing $model */ /** @var ResourceSyncing $model */
@ -27,7 +27,7 @@ trait ResourceSyncing
}); });
} }
public function triggerSyncEvent() public function triggerSyncEvent(): void
{ {
/** @var Syncable $this */ /** @var Syncable $this */
event(new SyncedResourceSaved($this, tenant())); event(new SyncedResourceSaved($this, tenant()));

View file

@ -4,15 +4,17 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Database\Concerns; namespace Stancl\Tenancy\Database\Concerns;
use Closure;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
trait TenantRun trait TenantRun
{ {
/** /**
* Run a callback in this tenant's context. * Run a callback in this tenant's context.
* Atomic, safely reverts to previous context. *
* This method is atomic and safely reverts to the previous context.
*/ */
public function run(callable $callback) public function run(Closure $callback): mixed
{ {
/** @var Tenant $this */ /** @var Tenant $this */
$originalTenant = tenant(); $originalTenant = tenant();

View file

@ -2,15 +2,18 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Contracts; namespace Stancl\Tenancy\Database\Contracts;
use Stancl\Tenancy\DatabaseConfig; use Stancl\Tenancy\Database\DatabaseConfig;
interface ManagesDatabaseUsers extends TenantDatabaseManager interface ManagesDatabaseUsers extends TenantDatabaseManager
{ {
/** Create a database user. */
public function createUser(DatabaseConfig $databaseConfig): bool; public function createUser(DatabaseConfig $databaseConfig): bool;
/** Delete a database user. */
public function deleteUser(DatabaseConfig $databaseConfig): bool; public function deleteUser(DatabaseConfig $databaseConfig): bool;
/** Does a database user exist? */
public function userExists(string $username): bool; public function userExists(string $username): bool;
} }

View file

@ -2,30 +2,22 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Contracts; namespace Stancl\Tenancy\Database\Contracts;
use Stancl\Tenancy\Exceptions\NoConnectionSetException; use Stancl\Tenancy\Database\Exceptions\NoConnectionSetException;
interface TenantDatabaseManager interface TenantDatabaseManager
{ {
/** /** Create a database. */
* Create a database.
*/
public function createDatabase(TenantWithDatabase $tenant): bool; public function createDatabase(TenantWithDatabase $tenant): bool;
/** /** Delete a database. */
* Delete a database.
*/
public function deleteDatabase(TenantWithDatabase $tenant): bool; public function deleteDatabase(TenantWithDatabase $tenant): bool;
/** /** Does a database exist? */
* Does a database exist.
*/
public function databaseExists(string $name): bool; public function databaseExists(string $name): bool;
/** /** Construct a DB connection config array. */
* Make a DB connection config array.
*/
public function makeConnectionConfig(array $baseConfig, string $databaseName): array; public function makeConnectionConfig(array $baseConfig, string $databaseName): array;
/** /**

View file

@ -0,0 +1,13 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\Contracts;
use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Database\DatabaseConfig;
interface TenantWithDatabase extends Tenant
{
public function database(): DatabaseConfig;
}

View file

@ -2,29 +2,27 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy; namespace Stancl\Tenancy\Database;
use Closure;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Hash; use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Str; use Illuminate\Support\Str;
use Stancl\Tenancy\Contracts\ManagesDatabaseUsers; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase as Tenant;
use Stancl\Tenancy\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase as Tenant;
use Stancl\Tenancy\Exceptions\DatabaseManagerNotRegisteredException;
class DatabaseConfig class DatabaseConfig
{ {
/** @var Tenant|Model */ /** The tenant whose database we're dealing with. */
public $tenant; public Tenant&Model $tenant;
/** @var callable */ /** Database username generator (can be set by the developer.) */
public static $usernameGenerator; public static Closure|null $usernameGenerator = null;
/** @var callable */ /** Database password generator (can be set by the developer.) */
public static $passwordGenerator; public static Closure|null $passwordGenerator = null;
/** @var callable */ /** Database name generator (can be set by the developer.) */
public static $databaseNameGenerator; public static Closure|null $databaseNameGenerator = null;
public static function __constructStatic(): void public static function __constructStatic(): void
{ {
@ -48,17 +46,17 @@ class DatabaseConfig
$this->tenant = $tenant; $this->tenant = $tenant;
} }
public static function generateDatabaseNamesUsing(callable $databaseNameGenerator): void public static function generateDatabaseNamesUsing(Closure $databaseNameGenerator): void
{ {
static::$databaseNameGenerator = $databaseNameGenerator; static::$databaseNameGenerator = $databaseNameGenerator;
} }
public static function generateUsernamesUsing(callable $usernameGenerator): void public static function generateUsernamesUsing(Closure $usernameGenerator): void
{ {
static::$usernameGenerator = $usernameGenerator; static::$usernameGenerator = $usernameGenerator;
} }
public static function generatePasswordsUsing(callable $passwordGenerator): void public static function generatePasswordsUsing(Closure $passwordGenerator): void
{ {
static::$passwordGenerator = $passwordGenerator; static::$passwordGenerator = $passwordGenerator;
} }
@ -85,7 +83,7 @@ class DatabaseConfig
{ {
$this->tenant->setInternal('db_name', $this->getName() ?? (static::$databaseNameGenerator)($this->tenant)); $this->tenant->setInternal('db_name', $this->getName() ?? (static::$databaseNameGenerator)($this->tenant));
if ($this->manager() instanceof ManagesDatabaseUsers) { if ($this->manager() instanceof Contracts\ManagesDatabaseUsers) {
$this->tenant->setInternal('db_username', $this->getUsername() ?? (static::$usernameGenerator)($this->tenant)); $this->tenant->setInternal('db_username', $this->getUsername() ?? (static::$usernameGenerator)($this->tenant));
$this->tenant->setInternal('db_password', $this->getPassword() ?? (static::$passwordGenerator)($this->tenant)); $this->tenant->setInternal('db_password', $this->getPassword() ?? (static::$passwordGenerator)($this->tenant));
} }
@ -142,20 +140,18 @@ class DatabaseConfig
}, []); }, []);
} }
/** /** Get the TenantDatabaseManager for this tenant's connection. */
* Get the TenantDatabaseManager for this tenant's connection. public function manager(): Contracts\TenantDatabaseManager
*/
public function manager(): TenantDatabaseManager
{ {
$driver = config("database.connections.{$this->getTemplateConnectionName()}.driver"); $driver = config("database.connections.{$this->getTemplateConnectionName()}.driver");
$databaseManagers = config('tenancy.database.managers'); $databaseManagers = config('tenancy.database.managers');
if (! array_key_exists($driver, $databaseManagers)) { if (! array_key_exists($driver, $databaseManagers)) {
throw new DatabaseManagerNotRegisteredException($driver); throw new Exceptions\DatabaseManagerNotRegisteredException($driver);
} }
/** @var TenantDatabaseManager $databaseManager */ /** @var Contracts\TenantDatabaseManager $databaseManager */
$databaseManager = app($databaseManagers[$driver]); $databaseManager = app($databaseManagers[$driver]);
$databaseManager->setConnection($this->getTemplateConnectionName()); $databaseManager->setConnection($this->getTemplateConnectionName());

View file

@ -7,12 +7,8 @@ namespace Stancl\Tenancy\Database;
use Illuminate\Config\Repository; use Illuminate\Config\Repository;
use Illuminate\Contracts\Foundation\Application; use Illuminate\Contracts\Foundation\Application;
use Illuminate\Database\DatabaseManager as BaseDatabaseManager; use Illuminate\Database\DatabaseManager as BaseDatabaseManager;
use Stancl\Tenancy\Contracts\ManagesDatabaseUsers;
use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException; use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Exceptions\DatabaseManagerNotRegisteredException;
use Stancl\Tenancy\Exceptions\TenantDatabaseAlreadyExistsException;
use Stancl\Tenancy\Exceptions\TenantDatabaseUserAlreadyExistsException;
/** /**
* @internal Class is subject to breaking changes in minor and patch versions. * @internal Class is subject to breaking changes in minor and patch versions.
@ -38,7 +34,7 @@ class DatabaseManager
/** /**
* Connect to a tenant's database. * Connect to a tenant's database.
*/ */
public function connectToTenant(TenantWithDatabase $tenant) public function connectToTenant(TenantWithDatabase $tenant): void
{ {
$this->purgeTenantConnection(); $this->purgeTenantConnection();
$this->createTenantConnection($tenant); $this->createTenantConnection($tenant);
@ -48,7 +44,7 @@ class DatabaseManager
/** /**
* Reconnect to the default non-tenant connection. * Reconnect to the default non-tenant connection.
*/ */
public function reconnectToCentral() public function reconnectToCentral(): void
{ {
$this->purgeTenantConnection(); $this->purgeTenantConnection();
$this->setDefaultConnection($this->config->get('tenancy.database.central_connection')); $this->setDefaultConnection($this->config->get('tenancy.database.central_connection'));
@ -57,7 +53,7 @@ class DatabaseManager
/** /**
* Change the default database connection config. * Change the default database connection config.
*/ */
public function setDefaultConnection(string $connection) public function setDefaultConnection(string $connection): void
{ {
$this->config['database.default'] = $connection; $this->config['database.default'] = $connection;
$this->database->setDefaultConnection($connection); $this->database->setDefaultConnection($connection);
@ -66,7 +62,7 @@ class DatabaseManager
/** /**
* Create the tenant database connection. * Create the tenant database connection.
*/ */
public function createTenantConnection(TenantWithDatabase $tenant) public function createTenantConnection(TenantWithDatabase $tenant): void
{ {
$this->config['database.connections.tenant'] = $tenant->database()->connection(); $this->config['database.connections.tenant'] = $tenant->database()->connection();
} }
@ -74,7 +70,7 @@ class DatabaseManager
/** /**
* Purge the tenant database connection. * Purge the tenant database connection.
*/ */
public function purgeTenantConnection() public function purgeTenantConnection(): void
{ {
if (array_key_exists('tenant', $this->database->getConnections())) { if (array_key_exists('tenant', $this->database->getConnections())) {
$this->database->purge('tenant'); $this->database->purge('tenant');
@ -95,11 +91,11 @@ class DatabaseManager
$manager = $tenant->database()->manager(); $manager = $tenant->database()->manager();
if ($manager->databaseExists($database = $tenant->database()->getName())) { if ($manager->databaseExists($database = $tenant->database()->getName())) {
throw new TenantDatabaseAlreadyExistsException($database); throw new Exceptions\TenantDatabaseAlreadyExistsException($database);
} }
if ($manager instanceof ManagesDatabaseUsers && $manager->userExists($username = $tenant->database()->getUsername())) { if ($manager instanceof Contracts\ManagesDatabaseUsers && $manager->userExists($username = $tenant->database()->getUsername())) {
throw new TenantDatabaseUserAlreadyExistsException($username); throw new Exceptions\TenantDatabaseUserAlreadyExistsException($username);
} }
} }
} }

View file

@ -0,0 +1,15 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\Exceptions;
use Exception;
class DatabaseManagerNotRegisteredException extends Exception
{
public function __construct(string $driver)
{
parent::__construct("Database manager for driver $driver is not registered.");
}
}

View file

@ -2,13 +2,13 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Database\Exceptions;
use Exception; use Exception;
class NoConnectionSetException extends Exception class NoConnectionSetException extends Exception
{ {
public function __construct($manager) public function __construct(string $manager)
{ {
parent::__construct("No connection was set on this $manager instance."); parent::__construct("No connection was set on this $manager instance.");
} }

View file

@ -2,24 +2,20 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Database\Exceptions;
use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException; use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException;
class TenantDatabaseAlreadyExistsException extends TenantCannotBeCreatedException class TenantDatabaseAlreadyExistsException extends TenantCannotBeCreatedException
{ {
/** @var string */ public function __construct(
protected $database; protected string $database,
) {
parent::__construct();
}
public function reason(): string public function reason(): string
{ {
return "Database {$this->database} already exists."; return "Database {$this->database} already exists.";
} }
public function __construct(string $database)
{
$this->database = $database;
parent::__construct();
}
} }

View file

@ -2,13 +2,13 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Database\Exceptions;
use Exception; use Exception;
class TenantDatabaseDoesNotExistException extends Exception class TenantDatabaseDoesNotExistException extends Exception
{ {
public function __construct($database) public function __construct(string $database)
{ {
parent::__construct("Database $database does not exist."); parent::__construct("Database $database does not exist.");
} }

View file

@ -2,24 +2,20 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Database\Exceptions;
use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException; use Stancl\Tenancy\Contracts\TenantCannotBeCreatedException;
class TenantDatabaseUserAlreadyExistsException extends TenantCannotBeCreatedException class TenantDatabaseUserAlreadyExistsException extends TenantCannotBeCreatedException
{ {
/** @var string */ public function __construct(
protected $user; protected string $user,
) {
parent::__construct();
}
public function reason(): string public function reason(): string
{ {
return "Database user {$this->user} already exists."; return "Database user {$this->user} already exists.";
} }
public function __construct(string $user)
{
parent::__construct();
$this->user = $user;
}
} }

View file

@ -5,6 +5,7 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Database\Models; namespace Stancl\Tenancy\Database\Models;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Relations\BelongsTo;
use Stancl\Tenancy\Contracts; use Stancl\Tenancy\Contracts;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Database\Concerns; use Stancl\Tenancy\Database\Concerns;
@ -25,7 +26,7 @@ class Domain extends Model implements Contracts\Domain
protected $guarded = []; protected $guarded = [];
public function tenant() public function tenant(): BelongsTo
{ {
return $this->belongsTo(config('tenancy.tenant_model')); return $this->belongsTo(config('tenancy.tenant_model'));
} }

View file

@ -5,17 +5,20 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Database\Models; namespace Stancl\Tenancy\Database\Models;
use Carbon\Carbon; use Carbon\Carbon;
use Illuminate\Contracts\Auth\StatefulGuard;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Str; use Illuminate\Support\Str;
use Stancl\Tenancy\Database\Concerns\CentralConnection; use Stancl\Tenancy\Database\Concerns\CentralConnection;
use Stancl\Tenancy\Exceptions\StatefulGuardRequiredException;
/** /**
* @param string $token * @property string $token
* @param string $tenant_id * @property string $tenant_id
* @param string $user_id * @property string $user_id
* @param string $auth_guard * @property string $auth_guard
* @param string $redirect_url * @property string $redirect_url
* @param Carbon $created_at * @property Carbon $created_at
*/ */
class ImpersonationToken extends Model class ImpersonationToken extends Model
{ {
@ -35,14 +38,18 @@ class ImpersonationToken extends Model
'created_at', 'created_at',
]; ];
public static function boot() public static function booted(): void
{ {
parent::boot();
static::creating(function ($model) { static::creating(function ($model) {
$authGuard = $model->auth_guard ?? config('auth.defaults.guard');
if (! Auth::guard($authGuard) instanceof StatefulGuard) {
throw new StatefulGuardRequiredException($authGuard);
}
$model->created_at = $model->created_at ?? $model->freshTimestamp(); $model->created_at = $model->created_at ?? $model->freshTimestamp();
$model->token = $model->token ?? Str::random(128); $model->token = $model->token ?? Str::random(128);
$model->auth_guard = $model->auth_guard ?? config('auth.defaults.guard'); $model->auth_guard = $authGuard;
}); });
} }
} }

View file

@ -39,7 +39,7 @@ class Tenant extends Model implements Contracts\Tenant
return 'id'; return 'id';
} }
public function getTenantKey() public function getTenantKey(): int|string
{ {
return $this->getAttribute($this->getTenantKeyName()); return $this->getAttribute($this->getTenantKeyName());
} }

View file

@ -9,10 +9,8 @@ use Stancl\Tenancy\Contracts\Syncable;
class TenantPivot extends Pivot class TenantPivot extends Pivot
{ {
public static function boot() public static function booted(): void
{ {
parent::boot();
static::saved(function (self $pivot) { static::saved(function (self $pivot) {
$parent = $pivot->pivotParent; $parent = $pivot->pivotParent;

View file

@ -10,7 +10,7 @@ use Illuminate\Database\Eloquent\Scope;
class ParentModelScope implements Scope class ParentModelScope implements Scope
{ {
public function apply(Builder $builder, Model $model) public function apply(Builder $builder, Model $model): void
{ {
if (! tenancy()->initialized) { if (! tenancy()->initialized) {
return; return;

View file

@ -4,6 +4,7 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Database; namespace Stancl\Tenancy\Database;
use Closure;
use Illuminate\Database\Eloquent\Collection; use Illuminate\Database\Eloquent\Collection;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
@ -16,7 +17,7 @@ use Stancl\Tenancy\Contracts\Tenant;
*/ */
class TenantCollection extends Collection class TenantCollection extends Collection
{ {
public function runForEach(callable $callable): self public function runForEach(Closure $callable): self
{ {
tenancy()->runForMultiple($this->items, $callable); tenancy()->runForMultiple($this->items, $callable);

View file

@ -0,0 +1,29 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class MicrosoftSQLDatabaseManager extends TenantDatabaseManager
{
public function createDatabase(TenantWithDatabase $tenant): bool
{
$database = $tenant->database()->getName();
$charset = $this->database()->getConfig('charset');
$collation = $this->database()->getConfig('collation'); // todo check why these are not used
return $this->database()->statement("CREATE DATABASE [{$database}]");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE [{$tenant->database()->getName()}]");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT name FROM master.sys.databases WHERE name = '$name'");
}
}

View file

@ -0,0 +1,29 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class MySQLDatabaseManager extends TenantDatabaseManager
{
public function createDatabase(TenantWithDatabase $tenant): bool
{
$database = $tenant->database()->getName();
$charset = $this->database()->getConfig('charset');
$collation = $this->database()->getConfig('collation');
return $this->database()->statement("CREATE DATABASE `{$database}` CHARACTER SET `$charset` COLLATE `$collation`");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE `{$tenant->database()->getName()}`");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = '$name'");
}
}

View file

@ -2,11 +2,11 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers; namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Stancl\Tenancy\Concerns\CreatesDatabaseUsers; use Stancl\Tenancy\Database\Concerns\CreatesDatabaseUsers;
use Stancl\Tenancy\Contracts\ManagesDatabaseUsers; use Stancl\Tenancy\Database\Contracts\ManagesDatabaseUsers;
use Stancl\Tenancy\DatabaseConfig; use Stancl\Tenancy\Database\DatabaseConfig;
class PermissionControlledMySQLDatabaseManager extends MySQLDatabaseManager implements ManagesDatabaseUsers class PermissionControlledMySQLDatabaseManager extends MySQLDatabaseManager implements ManagesDatabaseUsers
{ {
@ -54,11 +54,4 @@ class PermissionControlledMySQLDatabaseManager extends MySQLDatabaseManager impl
{ {
return (bool) $this->database()->select("SELECT count(*) FROM mysql.user WHERE user = '$username'")[0]->{'count(*)'}; return (bool) $this->database()->select("SELECT count(*) FROM mysql.user WHERE user = '$username'")[0]->{'count(*)'};
} }
public function makeConnectionConfig(array $baseConfig, string $databaseName): array
{
$baseConfig['database'] = $databaseName;
return $baseConfig;
}
} }

View file

@ -0,0 +1,25 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class PostgreSQLDatabaseManager extends TenantDatabaseManager
{
public function createDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("CREATE DATABASE \"{$tenant->database()->getName()}\" WITH TEMPLATE=template0");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE \"{$tenant->database()->getName()}\"");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT datname FROM pg_database WHERE datname = '$name'");
}
}

View file

@ -2,33 +2,12 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers; namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Illuminate\Database\Connection; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Illuminate\Support\Facades\DB;
use Stancl\Tenancy\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Exceptions\NoConnectionSetException;
class PostgreSQLSchemaManager implements TenantDatabaseManager class PostgreSQLSchemaManager extends TenantDatabaseManager
{ {
/** @var string */
protected $connection;
protected function database(): Connection
{
if ($this->connection === null) {
throw new NoConnectionSetException(static::class);
}
return DB::connection($this->connection);
}
public function setConnection(string $connection): void
{
$this->connection = $connection;
}
public function createDatabase(TenantWithDatabase $tenant): bool public function createDatabase(TenantWithDatabase $tenant): bool
{ {
return $this->database()->statement("CREATE SCHEMA \"{$tenant->database()->getName()}\""); return $this->database()->statement("CREATE SCHEMA \"{$tenant->database()->getName()}\"");

View file

@ -2,10 +2,11 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers; namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Stancl\Tenancy\Contracts\TenantDatabaseManager; use Stancl\Tenancy\Database\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Throwable;
class SQLiteDatabaseManager implements TenantDatabaseManager class SQLiteDatabaseManager implements TenantDatabaseManager
{ {
@ -13,7 +14,7 @@ class SQLiteDatabaseManager implements TenantDatabaseManager
{ {
try { try {
return file_put_contents(database_path($tenant->database()->getName()), ''); return file_put_contents(database_path($tenant->database()->getName()), '');
} catch (\Throwable $th) { } catch (Throwable) {
return false; return false;
} }
} }
@ -22,7 +23,7 @@ class SQLiteDatabaseManager implements TenantDatabaseManager
{ {
try { try {
return unlink(database_path($tenant->database()->getName())); return unlink(database_path($tenant->database()->getName()));
} catch (\Throwable $th) { } catch (Throwable) {
return false; return false;
} }
} }

View file

@ -0,0 +1,37 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Database\TenantDatabaseManagers;
use Illuminate\Database\Connection;
use Illuminate\Support\Facades\DB;
use Stancl\Tenancy\Database\Contracts\TenantDatabaseManager as Contract;
use Stancl\Tenancy\Database\Exceptions\NoConnectionSetException;
abstract class TenantDatabaseManager implements Contract // todo better naming?
{
/** The database connection to the server. */
protected string $connection;
protected function database(): Connection
{
if (! isset($this->connection)) {
throw new NoConnectionSetException(static::class);
}
return DB::connection($this->connection);
}
public function setConnection(string $connection): void
{
$this->connection = $connection;
}
public function makeConnectionConfig(array $baseConfig, string $databaseName): array
{
$baseConfig['database'] = $databaseName;
return $baseConfig;
}
}

12
src/Enums/LogMode.php Normal file
View file

@ -0,0 +1,12 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Enums;
enum LogMode
{
case NONE;
case SILENT;
case INSTANT;
}

View file

@ -5,7 +5,7 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Events; namespace Stancl\Tenancy\Events;
use Stancl\Tenancy\Contracts\Syncable; use Stancl\Tenancy\Contracts\Syncable;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class SyncedResourceChangedInForeignDatabase class SyncedResourceChangedInForeignDatabase
{ {

View file

@ -6,17 +6,16 @@ namespace Stancl\Tenancy\Events;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Stancl\Tenancy\Contracts\Syncable; use Stancl\Tenancy\Contracts\Syncable;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class SyncedResourceSaved class SyncedResourceSaved
{ {
/** @var Syncable|Model */ public Syncable&Model $model;
public $model;
/** @var TenantWithDatabase|Model|null */ /** @var (TenantWithDatabase&Model)|null */
public $tenant; public TenantWithDatabase|null $tenant;
public function __construct(Syncable $model, ?TenantWithDatabase $tenant) public function __construct(Syncable $model, TenantWithDatabase|null $tenant)
{ {
$this->model = $model; $this->model = $model;
$this->tenant = $tenant; $this->tenant = $tenant;

View file

@ -1,13 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions;
class DatabaseManagerNotRegisteredException extends \Exception
{
public function __construct($driver)
{
parent::__construct("Database manager for driver $driver is not registered.");
}
}

View file

@ -0,0 +1,15 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions;
use Exception;
class StatefulGuardRequiredException extends Exception
{
public function __construct(string $guardName)
{
parent::__construct("Cannot use a non-stateful guard ('$guardName'). A guard implementing the Illuminate\\Contracts\\Auth\\StatefulGuard interface is required.");
}
}

View file

@ -1,28 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions;
use Facade\IgnitionContracts\BaseSolution;
use Facade\IgnitionContracts\ProvidesSolution;
use Facade\IgnitionContracts\Solution;
use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException;
// todo: in v4 this should be suffixed with Exception
class TenantCouldNotBeIdentifiedById extends TenantCouldNotBeIdentifiedException implements ProvidesSolution
{
public function __construct($tenant_id)
{
parent::__construct("Tenant could not be identified with tenant_id: $tenant_id");
}
public function getSolution(): Solution
{
return BaseSolution::create('Tenant could not be identified with that ID')
->setSolutionDescription('Are you sure the ID is correct and the tenant exists?')
->setDocumentationLinks([
'Initializing Tenants' => 'https://tenancyforlaravel.com/docs/v3/tenants',
]);
}
}

View file

@ -0,0 +1,20 @@
<?php
declare(strict_types=1);
// todo perhaps create Identification namespace
namespace Stancl\Tenancy\Exceptions;
use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException;
class TenantCouldNotBeIdentifiedByIdException extends TenantCouldNotBeIdentifiedException
{
public function __construct(int|string $tenant_id)
{
$this
->tenantCouldNotBeIdentified("by tenant id: $tenant_id")
->title('Tenant could not be identified with that ID')
->description('Are you sure the ID is correct and the tenant exists?');
}
}

View file

@ -4,24 +4,15 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Exceptions;
use Facade\IgnitionContracts\BaseSolution;
use Facade\IgnitionContracts\ProvidesSolution;
use Facade\IgnitionContracts\Solution;
use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException; use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException;
class TenantCouldNotBeIdentifiedByPathException extends TenantCouldNotBeIdentifiedException implements ProvidesSolution class TenantCouldNotBeIdentifiedByPathException extends TenantCouldNotBeIdentifiedException
{ {
public function __construct($tenant_id) public function __construct(int|string $tenant_id)
{ {
parent::__construct("Tenant could not be identified on path with tenant_id: $tenant_id"); $this
} ->tenantCouldNotBeIdentified("on path with tenant id: $tenant_id")
->title('Tenant could not be identified on this path')
public function getSolution(): Solution ->description('Did you forget to create a tenant for this path?');
{
return BaseSolution::create('Tenant could not be identified on this path')
->setSolutionDescription('Did you forget to create a tenant for this path?')
->setDocumentationLinks([
'Creating Tenants' => 'https://tenancyforlaravel.com/docs/v3/tenants/',
]);
} }
} }

View file

@ -4,24 +4,15 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Exceptions;
use Facade\IgnitionContracts\BaseSolution;
use Facade\IgnitionContracts\ProvidesSolution;
use Facade\IgnitionContracts\Solution;
use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException; use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException;
class TenantCouldNotBeIdentifiedByRequestDataException extends TenantCouldNotBeIdentifiedException implements ProvidesSolution class TenantCouldNotBeIdentifiedByRequestDataException extends TenantCouldNotBeIdentifiedException
{ {
public function __construct($tenant_id) public function __construct(mixed $payload)
{ {
parent::__construct("Tenant could not be identified by request data with payload: $tenant_id"); $this
} ->tenantCouldNotBeIdentified("by request data with payload: $payload")
->title('Tenant could not be identified using this request data')
public function getSolution(): Solution ->description('Did you forget to create a tenant with this id?');
{
return BaseSolution::create('Tenant could not be identified with this request data')
->setSolutionDescription('Did you forget to create a tenant with this id?')
->setDocumentationLinks([
'Creating Tenants' => 'https://tenancyforlaravel.com/docs/v3/tenants/',
]);
} }
} }

View file

@ -4,24 +4,15 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Exceptions; namespace Stancl\Tenancy\Exceptions;
use Facade\IgnitionContracts\BaseSolution;
use Facade\IgnitionContracts\ProvidesSolution;
use Facade\IgnitionContracts\Solution;
use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException; use Stancl\Tenancy\Contracts\TenantCouldNotBeIdentifiedException;
class TenantCouldNotBeIdentifiedOnDomainException extends TenantCouldNotBeIdentifiedException implements ProvidesSolution class TenantCouldNotBeIdentifiedOnDomainException extends TenantCouldNotBeIdentifiedException
{ {
public function __construct($domain) public function __construct(string $domain)
{ {
parent::__construct("Tenant could not be identified on domain $domain"); $this
} ->tenantCouldNotBeIdentified("on domain $domain")
->title('Tenant could not be identified on this domain')
public function getSolution(): Solution ->description('Did you forget to create a tenant for this domain?');
{
return BaseSolution::create('Tenant could not be identified on this domain')
->setSolutionDescription('Did you forget to create a tenant for this domain?')
->setDocumentationLinks([
'Creating Tenants' => 'https://tenancyforlaravel.com/docs/v3/tenants/',
]);
} }
} }

View file

@ -14,12 +14,16 @@ class CrossDomainRedirect implements Feature
{ {
RedirectResponse::macro('domain', function (string $domain) { RedirectResponse::macro('domain', function (string $domain) {
/** @var RedirectResponse $this */ /** @var RedirectResponse $this */
// replace first occurance of hostname fragment with $domain
$url = $this->getTargetUrl(); $url = $this->getTargetUrl();
/**
* The original hostname in the redirect response.
*
* @var string $hostname
*/
$hostname = parse_url($url, PHP_URL_HOST); $hostname = parse_url($url, PHP_URL_HOST);
$position = strpos($url, $hostname);
$this->setTargetUrl(substr_replace($url, $domain, $position, strlen($hostname))); $this->setTargetUrl((string) str($url)->replace($hostname, $domain));
return $this; return $this;
}); });

View file

@ -6,6 +6,7 @@ namespace Stancl\Tenancy\Features;
use Illuminate\Contracts\Config\Repository; use Illuminate\Contracts\Config\Repository;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Event; use Illuminate\Support\Facades\Event;
use Stancl\Tenancy\Contracts\Feature; use Stancl\Tenancy\Contracts\Feature;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
@ -18,8 +19,7 @@ class TenantConfig implements Feature
/** @var Repository */ /** @var Repository */
protected $config; protected $config;
/** @var array */ public array $originalConfig = [];
public $originalConfig = [];
public static $storageToConfigMap = [ public static $storageToConfigMap = [
// 'paypal_api_key' => 'services.paypal.api_key', // 'paypal_api_key' => 'services.paypal.api_key',
@ -45,19 +45,19 @@ class TenantConfig implements Feature
{ {
/** @var Tenant|Model $tenant */ /** @var Tenant|Model $tenant */
foreach (static::$storageToConfigMap as $storageKey => $configKey) { foreach (static::$storageToConfigMap as $storageKey => $configKey) {
$override = $tenant->getAttribute($storageKey); $override = Arr::get($tenant, $storageKey);
if (! is_null($override)) { if (! is_null($override)) {
if (is_array($configKey)) { if (is_array($configKey)) {
foreach ($configKey as $key) { foreach ($configKey as $key) {
$this->originalConfig[$key] = $this->originalConfig[$key] ?? $this->config[$key]; $this->originalConfig[$key] = $this->originalConfig[$key] ?? $this->config->get($key);
$this->config[$key] = $override; $this->config->set($key, $override);
} }
} else { } else {
$this->originalConfig[$configKey] = $this->originalConfig[$configKey] ?? $this->config[$configKey]; $this->originalConfig[$configKey] = $this->originalConfig[$configKey] ?? $this->config->get($configKey);
$this->config[$configKey] = $override; $this->config->set($configKey, $override);
} }
} }
} }
@ -66,7 +66,7 @@ class TenantConfig implements Feature
public function unsetTenantConfig(): void public function unsetTenantConfig(): void
{ {
foreach ($this->originalConfig as $key => $value) { foreach ($this->originalConfig as $key => $value) {
$this->config[$key] = $value; $this->config->set($key, $value);
} }
} }
} }

View file

@ -13,9 +13,10 @@ use Stancl\Tenancy\Tenancy;
class UniversalRoutes implements Feature class UniversalRoutes implements Feature
{ {
public static $middlewareGroup = 'universal'; public static string $middlewareGroup = 'universal';
public static $identificationMiddlewares = [ // todo docblock
public static array $identificationMiddlewares = [
Middleware\InitializeTenancyByDomain::class, Middleware\InitializeTenancyByDomain::class,
Middleware\InitializeTenancyBySubdomain::class, Middleware\InitializeTenancyBySubdomain::class,
]; ];
@ -39,7 +40,7 @@ class UniversalRoutes implements Feature
} }
} }
public static function routeHasMiddleware(Route $route, $middleware): bool public static function routeHasMiddleware(Route $route, string $middleware): bool
{ {
if (in_array($middleware, $route->middleware(), true)) { if (in_array($middleware, $route->middleware(), true)) {
return true; return true;

View file

@ -4,7 +4,6 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Features; namespace Stancl\Tenancy\Features;
use Carbon\Carbon;
use Illuminate\Http\RedirectResponse; use Illuminate\Http\RedirectResponse;
use Illuminate\Support\Facades\Auth; use Illuminate\Support\Facades\Auth;
use Stancl\Tenancy\Contracts\Feature; use Stancl\Tenancy\Contracts\Feature;
@ -14,7 +13,8 @@ use Stancl\Tenancy\Tenancy;
class UserImpersonation implements Feature class UserImpersonation implements Feature
{ {
public static $ttl = 60; // seconds /** The lifespan of impersonation tokens (in seconds). */
public static int $ttl = 60;
public function bootstrap(Tenancy $tenancy): void public function bootstrap(Tenancy $tenancy): void
{ {
@ -28,25 +28,21 @@ class UserImpersonation implements Feature
}); });
} }
/** /** Impersonate a user and get an HTTP redirect response. */
* Impersonate a user and get an HTTP redirect response. public static function makeResponse(string|ImpersonationToken $token, int $ttl = null): RedirectResponse
*
* @param string|ImpersonationToken $token
* @param int $ttl
*/
public static function makeResponse($token, int $ttl = null): RedirectResponse
{ {
/** @var ImpersonationToken $token */
$token = $token instanceof ImpersonationToken ? $token : ImpersonationToken::findOrFail($token); $token = $token instanceof ImpersonationToken ? $token : ImpersonationToken::findOrFail($token);
$ttl ??= static::$ttl;
if (((string) $token->tenant_id) !== ((string) tenant()->getTenantKey())) { $tokenExpired = $token->created_at->diffInSeconds(now()) > $ttl;
abort(403);
}
$ttl = $ttl ?? static::$ttl; abort_if($tokenExpired, 403);
if ($token->created_at->diffInSeconds(Carbon::now()) > $ttl) { $tokenTenantId = (string) $token->tenant_id;
abort(403); $currentTenantId = (string) tenant()->getTenantKey();
}
abort_unless($tokenTenantId === $currentTenantId, 403);
Auth::guard($token->auth_guard)->loginUsingId($token->user_id); Auth::guard($token->auth_guard)->loginUsingId($token->user_id);

View file

@ -10,7 +10,7 @@ use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels; use Illuminate\Queue\SerializesModels;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Database\DatabaseManager; use Stancl\Tenancy\Database\DatabaseManager;
use Stancl\Tenancy\Events\CreatingDatabase; use Stancl\Tenancy\Events\CreatingDatabase;
use Stancl\Tenancy\Events\DatabaseCreated; use Stancl\Tenancy\Events\DatabaseCreated;
@ -19,12 +19,9 @@ class CreateDatabase implements ShouldQueue
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var TenantWithDatabase|Model */ public function __construct(
protected $tenant; protected TenantWithDatabase&Model $tenant,
) {
public function __construct(TenantWithDatabase $tenant)
{
$this->tenant = $tenant;
} }
public function handle(DatabaseManager $databaseManager) public function handle(DatabaseManager $databaseManager)

View file

@ -6,10 +6,11 @@ namespace Stancl\Tenancy\Jobs;
use Illuminate\Bus\Queueable; use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels; use Illuminate\Queue\SerializesModels;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Events\DatabaseDeleted; use Stancl\Tenancy\Events\DatabaseDeleted;
use Stancl\Tenancy\Events\DeletingDatabase; use Stancl\Tenancy\Events\DeletingDatabase;
@ -17,15 +18,12 @@ class DeleteDatabase implements ShouldQueue
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var TenantWithDatabase */ public function __construct(
protected $tenant; protected TenantWithDatabase&Model $tenant,
) {
public function __construct(TenantWithDatabase $tenant)
{
$this->tenant = $tenant;
} }
public function handle() public function handle(): void
{ {
event(new DeletingDatabase($this->tenant)); event(new DeletingDatabase($this->tenant));

View file

@ -5,24 +5,26 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Jobs; namespace Stancl\Tenancy\Jobs;
use Illuminate\Bus\Queueable; use Illuminate\Bus\Queueable;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels; use Illuminate\Queue\SerializesModels;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Concerns\HasDomains;
use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class DeleteDomains class DeleteDomains
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var TenantWithDatabase */ /** @var TenantWithDatabase&Model&HasDomains */ // todo unresolvable type for phpstan
protected $tenant; protected TenantWithDatabase&Model $tenant;
public function __construct(TenantWithDatabase $tenant) public function __construct(TenantWithDatabase&Model $tenant)
{ {
$this->tenant = $tenant; $this->tenant = $tenant;
} }
public function handle() public function handle(): void
{ {
$this->tenant->domains->each->delete(); $this->tenant->domains->each->delete();
} }

View file

@ -6,30 +6,23 @@ namespace Stancl\Tenancy\Jobs;
use Illuminate\Bus\Queueable; use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels; use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Artisan; use Illuminate\Support\Facades\Artisan;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class MigrateDatabase implements ShouldQueue class MigrateDatabase implements ShouldQueue
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var TenantWithDatabase */ public function __construct(
protected $tenant; protected TenantWithDatabase&Model $tenant,
) {
public function __construct(TenantWithDatabase $tenant)
{
$this->tenant = $tenant;
} }
/** public function handle(): void
* Execute the job.
*
* @return void
*/
public function handle()
{ {
Artisan::call('tenants:migrate', [ Artisan::call('tenants:migrate', [
'--tenants' => [$this->tenant->getTenantKey()], '--tenants' => [$this->tenant->getTenantKey()],

View file

@ -6,30 +6,23 @@ namespace Stancl\Tenancy\Jobs;
use Illuminate\Bus\Queueable; use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels; use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Artisan; use Illuminate\Support\Facades\Artisan;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
class SeedDatabase implements ShouldQueue class SeedDatabase implements ShouldQueue
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/** @var TenantWithDatabase */ public function __construct(
protected $tenant; protected TenantWithDatabase&Model $tenant,
) {
public function __construct(TenantWithDatabase $tenant)
{
$this->tenant = $tenant;
} }
/** public function handle(): void
* Execute the job.
*
* @return void
*/
public function handle()
{ {
Artisan::call('tenants:seed', [ Artisan::call('tenants:seed', [
'--tenants' => [$this->tenant->getTenantKey()], '--tenants' => [$this->tenant->getTenantKey()],

View file

@ -10,7 +10,7 @@ use Stancl\Tenancy\Events\TenancyInitialized;
class BootstrapTenancy class BootstrapTenancy
{ {
public function handle(TenancyInitialized $event) public function handle(TenancyInitialized $event): void
{ {
event(new BootstrappingTenancy($event->tenancy)); event(new BootstrappingTenancy($event->tenancy));

View file

@ -17,7 +17,7 @@ class CreateTenantConnection
$this->database = $database; $this->database = $database;
} }
public function handle(TenantEvent $event) public function handle(TenantEvent $event): void
{ {
$this->database->createTenantConnection($event->tenant); $this->database->createTenantConnection($event->tenant);
} }

View file

@ -11,9 +11,9 @@ use Illuminate\Contracts\Queue\ShouldQueue;
*/ */
abstract class QueueableListener implements ShouldQueue abstract class QueueableListener implements ShouldQueue
{ {
public static $shouldQueue = false; public static bool $shouldQueue = false;
public function shouldQueue($event) public function shouldQueue($event): bool
{ {
if (static::$shouldQueue) { if (static::$shouldQueue) {
return true; return true;

View file

@ -10,11 +10,11 @@ use Stancl\Tenancy\Events\TenancyEnded;
class RevertToCentralContext class RevertToCentralContext
{ {
public function handle(TenancyEnded $event) public function handle(TenancyEnded $event): void
{ {
event(new RevertingToCentralContext($event->tenancy)); event(new RevertingToCentralContext($event->tenancy));
foreach ($event->tenancy->getBootstrappers() as $bootstrapper) { foreach (array_reverse($event->tenancy->getBootstrappers()) as $bootstrapper) {
$bootstrapper->revert(); $bootstrapper->revert();
} }

View file

@ -4,6 +4,7 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Listeners; namespace Stancl\Tenancy\Listeners;
use Illuminate\Database\Eloquent\Collection as EloquentCollection;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Relations\Pivot; use Illuminate\Database\Eloquent\Relations\Pivot;
use Stancl\Tenancy\Contracts\SyncMaster; use Stancl\Tenancy\Contracts\SyncMaster;
@ -13,9 +14,9 @@ use Stancl\Tenancy\Exceptions\ModelNotSyncMasterException;
class UpdateSyncedResource extends QueueableListener class UpdateSyncedResource extends QueueableListener
{ {
public static $shouldQueue = false; public static bool $shouldQueue = false;
public function handle(SyncedResourceSaved $event) public function handle(SyncedResourceSaved $event): void
{ {
$syncedAttributes = $event->model->only($event->model->getSyncedAttributeNames()); $syncedAttributes = $event->model->only($event->model->getSyncedAttributeNames());
@ -29,7 +30,7 @@ class UpdateSyncedResource extends QueueableListener
$this->updateResourceInTenantDatabases($tenants, $event, $syncedAttributes); $this->updateResourceInTenantDatabases($tenants, $event, $syncedAttributes);
} }
protected function getTenantsForCentralModel($centralModel) protected function getTenantsForCentralModel($centralModel): EloquentCollection
{ {
if (! $centralModel instanceof SyncMaster) { if (! $centralModel instanceof SyncMaster) {
// If we're trying to use a tenant User model instead of the central User model, for example. // If we're trying to use a tenant User model instead of the central User model, for example.
@ -45,7 +46,7 @@ class UpdateSyncedResource extends QueueableListener
return $centralModel->tenants; return $centralModel->tenants;
} }
protected function updateResourceInCentralDatabaseAndGetTenants($event, $syncedAttributes) protected function updateResourceInCentralDatabaseAndGetTenants($event, $syncedAttributes): EloquentCollection
{ {
/** @var Model|SyncMaster $centralModel */ /** @var Model|SyncMaster $centralModel */
$centralModel = $event->model->getCentralModelName()::where($event->model->getGlobalIdentifierKeyName(), $event->model->getGlobalIdentifierKey()) $centralModel = $event->model->getCentralModelName()::where($event->model->getGlobalIdentifierKeyName(), $event->model->getGlobalIdentifierKey())
@ -85,7 +86,7 @@ class UpdateSyncedResource extends QueueableListener
}); });
} }
protected function updateResourceInTenantDatabases($tenants, $event, $syncedAttributes) protected function updateResourceInTenantDatabases($tenants, $event, $syncedAttributes): void
{ {
tenancy()->runForMultiple($tenants, function ($tenant) use ($event, $syncedAttributes) { tenancy()->runForMultiple($tenants, function ($tenant) use ($event, $syncedAttributes) {
// Forget instance state and find the model, // Forget instance state and find the model,

View file

@ -7,6 +7,9 @@ namespace Stancl\Tenancy\Middleware;
use Closure; use Closure;
use Illuminate\Http\Request; use Illuminate\Http\Request;
use Illuminate\Routing\Route; use Illuminate\Routing\Route;
use Illuminate\Support\Facades\Event;
use Illuminate\Support\Facades\URL;
use Stancl\Tenancy\Events\InitializingTenancy;
use Stancl\Tenancy\Exceptions\RouteIsMissingTenantParameterException; use Stancl\Tenancy\Exceptions\RouteIsMissingTenantParameterException;
use Stancl\Tenancy\Resolvers\PathTenantResolver; use Stancl\Tenancy\Resolvers\PathTenantResolver;
use Stancl\Tenancy\Tenancy; use Stancl\Tenancy\Tenancy;
@ -37,6 +40,11 @@ class InitializeTenancyByPath extends IdentificationMiddleware
// We don't want to initialize tenancy if the tenant is // We don't want to initialize tenancy if the tenant is
// simply injected into some route controller action. // simply injected into some route controller action.
if ($route->parameterNames()[0] === PathTenantResolver::$tenantParameterName) { if ($route->parameterNames()[0] === PathTenantResolver::$tenantParameterName) {
// Set tenant as a default parameter for the URLs in the current request
Event::listen(InitializingTenancy::class, function (InitializingTenancy $event) {
URL::defaults([PathTenantResolver::$tenantParameterName => $event->tenancy->tenant->getTenantKey()]);
});
return $this->initializeTenancy( return $this->initializeTenancy(
$request, $request,
$next, $next,

View file

@ -11,14 +11,11 @@ use Stancl\Tenancy\Contracts\TenantResolver;
abstract class CachedTenantResolver implements TenantResolver abstract class CachedTenantResolver implements TenantResolver
{ {
/** @var bool */ public static bool $shouldCache = false; // todo docblocks for these
public static $shouldCache = false;
/** @var int */ public static int $cacheTTL = 3600; // seconds
public static $cacheTTL = 3600; // seconds
/** @var string|null */ public static string|null $cacheStore = null; // default
public static $cacheStore = null; // default
/** @var Repository */ /** @var Repository */
protected $cache; protected $cache;
@ -28,7 +25,7 @@ abstract class CachedTenantResolver implements TenantResolver
$this->cache = $cache->store(static::$cacheStore); $this->cache = $cache->store(static::$cacheStore);
} }
public function resolve(...$args): Tenant public function resolve(mixed ...$args): Tenant
{ {
if (! static::$shouldCache) { if (! static::$shouldCache) {
return $this->resolveWithoutCache(...$args); return $this->resolveWithoutCache(...$args);
@ -61,12 +58,12 @@ abstract class CachedTenantResolver implements TenantResolver
} }
} }
public function getCacheKey(...$args): string public function getCacheKey(mixed ...$args): string
{ {
return '_tenancy_resolver:' . static::class . ':' . json_encode($args); return '_tenancy_resolver:' . static::class . ':' . json_encode($args);
} }
abstract public function resolveWithoutCache(...$args): Tenant; abstract public function resolveWithoutCache(mixed ...$args): Tenant;
public function resolved(Tenant $tenant, ...$args): void public function resolved(Tenant $tenant, ...$args): void
{ {

View file

@ -11,31 +11,22 @@ use Stancl\Tenancy\Exceptions\TenantCouldNotBeIdentifiedOnDomainException;
class DomainTenantResolver extends Contracts\CachedTenantResolver class DomainTenantResolver extends Contracts\CachedTenantResolver
{ {
/** /** The model representing the domain that the tenant was identified on. */
* The model representing the domain that the tenant was identified on. public static Domain $currentDomain; // todo |null?
*
* @var Domain
*/
public static $currentDomain;
/** @var bool */ public static bool $shouldCache = false;
public static $shouldCache = false;
/** @var int */ public static int $cacheTTL = 3600; // seconds
public static $cacheTTL = 3600; // seconds
/** @var string|null */ public static string|null $cacheStore = null; // default
public static $cacheStore = null; // default
public function resolveWithoutCache(...$args): Tenant public function resolveWithoutCache(mixed ...$args): Tenant
{ {
$domain = $args[0]; $domain = $args[0];
/** @var Tenant|null $tenant */ /** @var Tenant|null $tenant */
$tenant = config('tenancy.tenant_model')::query() $tenant = config('tenancy.tenant_model')::query()
->whereHas('domains', function (Builder $query) use ($domain) { ->whereHas('domains', fn (Builder $query) => $query->where('domain', $domain))
$query->where('domain', $domain);
})
->with('domains') ->with('domains')
->first(); ->first();

View file

@ -10,18 +10,15 @@ use Stancl\Tenancy\Exceptions\TenantCouldNotBeIdentifiedByPathException;
class PathTenantResolver extends Contracts\CachedTenantResolver class PathTenantResolver extends Contracts\CachedTenantResolver
{ {
public static $tenantParameterName = 'tenant'; public static string $tenantParameterName = 'tenant';
/** @var bool */ public static bool $shouldCache = false;
public static $shouldCache = false;
/** @var int */ public static int $cacheTTL = 3600; // seconds
public static $cacheTTL = 3600; // seconds
/** @var string|null */ public static string|null $cacheStore = null; // default
public static $cacheStore = null; // default
public function resolveWithoutCache(...$args): Tenant public function resolveWithoutCache(mixed ...$args): Tenant
{ {
/** @var Route $route */ /** @var Route $route */
$route = $args[0]; $route = $args[0];

View file

@ -9,16 +9,13 @@ use Stancl\Tenancy\Exceptions\TenantCouldNotBeIdentifiedByRequestDataException;
class RequestDataTenantResolver extends Contracts\CachedTenantResolver class RequestDataTenantResolver extends Contracts\CachedTenantResolver
{ {
/** @var bool */ public static bool $shouldCache = false;
public static $shouldCache = false;
/** @var int */ public static int $cacheTTL = 3600; // seconds
public static $cacheTTL = 3600; // seconds
/** @var string|null */ public static string|null $cacheStore = null; // default
public static $cacheStore = null; // default
public function resolveWithoutCache(...$args): Tenant public function resolveWithoutCache(mixed ...$args): Tenant
{ {
$payload = $args[0]; $payload = $args[0];

View file

@ -4,41 +4,45 @@ declare(strict_types=1);
namespace Stancl\Tenancy; namespace Stancl\Tenancy;
use Closure;
use Illuminate\Database\Eloquent\Builder; use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Traits\Macroable; use Illuminate\Support\Traits\Macroable;
use Stancl\Tenancy\Concerns\Debuggable;
use Stancl\Tenancy\Contracts\TenancyBootstrapper; use Stancl\Tenancy\Contracts\TenancyBootstrapper;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Exceptions\TenantCouldNotBeIdentifiedById; use Stancl\Tenancy\Exceptions\TenantCouldNotBeIdentifiedByIdException;
class Tenancy class Tenancy
{ {
use Macroable; use Macroable, Debuggable;
/** @var Tenant|Model|null */
public $tenant;
/** @var callable|null */
public $getBootstrappersUsing = null;
/** @var bool */
public $initialized = false;
/** /**
* Initializes the tenant. * The current tenant.
* @param Tenant|int|string $tenant *
* @var (Tenant&Model)|null
*/ */
public function initialize($tenant): void public ?Tenant $tenant = null;
// todo docblock
public ?Closure $getBootstrappersUsing = null;
/** Is tenancy fully initialized? */
public bool $initialized = false; // todo document the difference between $tenant being set and $initialized being true (e.g. end of initialize() method)
/** Initialize tenancy for the passed tenant. */
public function initialize(Tenant|int|string $tenant): void
{ {
if (! is_object($tenant)) { if (! is_object($tenant)) {
$tenantId = $tenant; $tenantId = $tenant;
$tenant = $this->find($tenantId); $tenant = $this->find($tenantId);
if (! $tenant) { if (! $tenant) {
throw new TenantCouldNotBeIdentifiedById($tenantId); throw new TenantCouldNotBeIdentifiedByIdException($tenantId);
} }
} }
// todo0 for phpstan this should be $this->tenant?, but first I want to clean up the $initialized logic and explore removing the property
if ($this->initialized && $this->tenant->getTenantKey() === $tenant->getTenantKey()) { if ($this->initialized && $this->tenant->getTenantKey() === $tenant->getTenantKey()) {
return; return;
} }
@ -59,17 +63,19 @@ class Tenancy
public function end(): void public function end(): void
{ {
event(new Events\EndingTenancy($this));
if (! $this->initialized) { if (! $this->initialized) {
return; return;
} }
event(new Events\EndingTenancy($this));
// todo find a way to refactor these two methods
event(new Events\TenancyEnded($this)); event(new Events\TenancyEnded($this));
$this->initialized = false;
$this->tenant = null; $this->tenant = null;
$this->initialized = false;
} }
/** @return TenancyBootstrapper[] */ /** @return TenancyBootstrapper[] */
@ -84,29 +90,28 @@ class Tenancy
return array_map('app', $resolve($this->tenant)); return array_map('app', $resolve($this->tenant));
} }
public function query(): Builder public static function query(): Builder
{ {
return $this->model()->query(); return static::model()->query();
} }
/** @return Tenant|Model */ public static function model(): Tenant&Model
public function model()
{ {
$class = config('tenancy.tenant_model'); $class = config('tenancy.tenant_model');
return new $class; return new $class;
} }
public function find($id): ?Tenant public static function find(int|string $id): Tenant|null
{ {
return $this->model()->where($this->model()->getTenantKeyName(), $id)->first(); return static::model()->where(static::model()->getTenantKeyName(), $id)->first();
} }
/** /**
* Run a callback in the central context. * Run a callback in the central context.
* Atomic, safely reverts to previous context. * Atomic, safely reverts to previous context.
*/ */
public function central(callable $callback) public function central(Closure $callback)
{ {
$previousTenant = $this->tenant; $previousTenant = $this->tenant;
@ -128,9 +133,8 @@ class Tenancy
* More performant than running $tenant->run() one by one. * More performant than running $tenant->run() one by one.
* *
* @param Tenant[]|\Traversable|string[]|null $tenants * @param Tenant[]|\Traversable|string[]|null $tenants
* @return void
*/ */
public function runForMultiple($tenants, callable $callback) public function runForMultiple($tenants, Closure $callback): void
{ {
// Convert null to all tenants // Convert null to all tenants
$tenants = is_null($tenants) ? $this->model()->cursor() : $tenants; $tenants = is_null($tenants) ? $this->model()->cursor() : $tenants;
@ -142,7 +146,7 @@ class Tenancy
$tenants = is_string($tenants) ? [$tenants] : $tenants; $tenants = is_string($tenants) ? [$tenants] : $tenants;
// Use all tenants if $tenants is falsey // Use all tenants if $tenants is falsey
$tenants = $tenants ?: $this->model()->cursor(); $tenants = $tenants ?: $this->model()->cursor(); // todo0 phpstan thinks this isn't needed, but tests fail without it
$originalTenant = $this->tenant; $originalTenant = $this->tenant;

View file

@ -5,17 +5,18 @@ declare(strict_types=1);
namespace Stancl\Tenancy; namespace Stancl\Tenancy;
use Illuminate\Cache\CacheManager; use Illuminate\Cache\CacheManager;
use Illuminate\Support\Facades\Event;
use Illuminate\Support\ServiceProvider; use Illuminate\Support\ServiceProvider;
use Stancl\Tenancy\Bootstrappers\FilesystemTenancyBootstrapper; use Stancl\Tenancy\Bootstrappers\FilesystemTenancyBootstrapper;
use Stancl\Tenancy\Contracts\Domain; use Stancl\Tenancy\Contracts\Domain;
use Stancl\Tenancy\Contracts\Tenant; use Stancl\Tenancy\Contracts\Tenant;
use Stancl\Tenancy\Enums\LogMode;
use Stancl\Tenancy\Events\Contracts\TenancyEvent;
use Stancl\Tenancy\Resolvers\DomainTenantResolver; use Stancl\Tenancy\Resolvers\DomainTenantResolver;
class TenancyServiceProvider extends ServiceProvider class TenancyServiceProvider extends ServiceProvider
{ {
/** /* Register services. */
* Register services.
*/
public function register(): void public function register(): void
{ {
$this->mergeConfigFrom(__DIR__ . '/../assets/config.php', 'tenancy'); $this->mergeConfigFrom(__DIR__ . '/../assets/config.php', 'tenancy');
@ -72,9 +73,7 @@ class TenancyServiceProvider extends ServiceProvider
}); });
} }
/** /* Bootstrap services. */
* Bootstrap services.
*/
public function boot(): void public function boot(): void
{ {
$this->commands([ $this->commands([
@ -113,6 +112,18 @@ class TenancyServiceProvider extends ServiceProvider
$this->loadRoutesFrom(__DIR__ . '/../assets/routes.php'); $this->loadRoutesFrom(__DIR__ . '/../assets/routes.php');
} }
Event::listen('Stancl\\Tenancy\\Events\\*', function (string $name, array $data) {
$event = $data[0];
if ($event instanceof TenancyEvent) {
match (tenancy()->logMode()) {
LogMode::SILENT => tenancy()->logEvent($event),
LogMode::INSTANT => dump($event), // todo0 perhaps still log
default => null,
};
}
});
$this->app->singleton('globalUrl', function ($app) { $this->app->singleton('globalUrl', function ($app) {
if ($app->bound(FilesystemTenancyBootstrapper::class)) { if ($app->bound(FilesystemTenancyBootstrapper::class)) {
$instance = clone $app['url']; $instance = clone $app['url'];

View file

@ -1,57 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers;
use Illuminate\Database\Connection;
use Illuminate\Support\Facades\DB;
use Stancl\Tenancy\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Exceptions\NoConnectionSetException;
class MicrosoftSQLDatabaseManager implements TenantDatabaseManager
{
/** @var string */
protected $connection;
protected function database(): Connection
{
if ($this->connection === null) {
throw new NoConnectionSetException(static::class);
}
return DB::connection($this->connection);
}
public function setConnection(string $connection): void
{
$this->connection = $connection;
}
public function createDatabase(TenantWithDatabase $tenant): bool
{
$database = $tenant->database()->getName();
$charset = $this->database()->getConfig('charset');
$collation = $this->database()->getConfig('collation');
return $this->database()->statement("CREATE DATABASE [{$database}]");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE [{$tenant->database()->getName()}]");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT name FROM master.sys.databases WHERE name = '$name'");
}
public function makeConnectionConfig(array $baseConfig, string $databaseName): array
{
$baseConfig['database'] = $databaseName;
return $baseConfig;
}
}

View file

@ -1,57 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers;
use Illuminate\Database\Connection;
use Illuminate\Support\Facades\DB;
use Stancl\Tenancy\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Exceptions\NoConnectionSetException;
class MySQLDatabaseManager implements TenantDatabaseManager
{
/** @var string */
protected $connection;
protected function database(): Connection
{
if ($this->connection === null) {
throw new NoConnectionSetException(static::class);
}
return DB::connection($this->connection);
}
public function setConnection(string $connection): void
{
$this->connection = $connection;
}
public function createDatabase(TenantWithDatabase $tenant): bool
{
$database = $tenant->database()->getName();
$charset = $this->database()->getConfig('charset');
$collation = $this->database()->getConfig('collation');
return $this->database()->statement("CREATE DATABASE `{$database}` CHARACTER SET `$charset` COLLATE `$collation`");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE `{$tenant->database()->getName()}`");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = '$name'");
}
public function makeConnectionConfig(array $baseConfig, string $databaseName): array
{
$baseConfig['database'] = $databaseName;
return $baseConfig;
}
}

View file

@ -1,53 +0,0 @@
<?php
declare(strict_types=1);
namespace Stancl\Tenancy\TenantDatabaseManagers;
use Illuminate\Database\Connection;
use Illuminate\Support\Facades\DB;
use Stancl\Tenancy\Contracts\TenantDatabaseManager;
use Stancl\Tenancy\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Exceptions\NoConnectionSetException;
class PostgreSQLDatabaseManager implements TenantDatabaseManager
{
/** @var string */
protected $connection;
protected function database(): Connection
{
if ($this->connection === null) {
throw new NoConnectionSetException(static::class);
}
return DB::connection($this->connection);
}
public function setConnection(string $connection): void
{
$this->connection = $connection;
}
public function createDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("CREATE DATABASE \"{$tenant->database()->getName()}\" WITH TEMPLATE=template0");
}
public function deleteDatabase(TenantWithDatabase $tenant): bool
{
return $this->database()->statement("DROP DATABASE \"{$tenant->database()->getName()}\"");
}
public function databaseExists(string $name): bool
{
return (bool) $this->database()->select("SELECT datname FROM pg_database WHERE datname = '$name'");
}
public function makeConnectionConfig(array $baseConfig, string $databaseName): array
{
$baseConfig['database'] = $databaseName;
return $baseConfig;
}
}

View file

@ -7,6 +7,8 @@ namespace Stancl\Tenancy;
use Ramsey\Uuid\Uuid; use Ramsey\Uuid\Uuid;
use Stancl\Tenancy\Contracts\UniqueIdentifierGenerator; use Stancl\Tenancy\Contracts\UniqueIdentifierGenerator;
// todo move to separate namespace
class UUIDGenerator implements UniqueIdentifierGenerator class UUIDGenerator implements UniqueIdentifierGenerator
{ {
public static function generate($resource): string public static function generate($resource): string

View file

@ -15,15 +15,14 @@ if (! function_exists('tenancy')) {
if (! function_exists('tenant')) { if (! function_exists('tenant')) {
/** /**
* Get a key from the current tenant's storage. * Get the current tenant or a key from the current tenant's properties.
* *
* @param string|null $key
* @return Tenant|null|mixed * @return Tenant|null|mixed
*/ */
function tenant($key = null) function tenant(string $key = null): mixed
{ {
if (! app()->bound(Tenant::class)) { if (! app()->bound(Tenant::class)) {
return; return null;
} }
if (is_null($key)) { if (is_null($key)) {
@ -35,15 +34,15 @@ if (! function_exists('tenant')) {
} }
if (! function_exists('tenant_asset')) { if (! function_exists('tenant_asset')) {
/** @return string */ // todo docblock
function tenant_asset($asset) function tenant_asset(string|null $asset): string
{ {
return route('stancl.tenancy.asset', ['path' => $asset]); return route('stancl.tenancy.asset', ['path' => $asset]);
} }
} }
if (! function_exists('global_asset')) { if (! function_exists('global_asset')) {
function global_asset($asset) function global_asset(string $asset) // todo types, also inside the globalUrl implementation
{ {
return app('globalUrl')->asset($asset); return app('globalUrl')->asset($asset);
} }
@ -57,13 +56,17 @@ if (! function_exists('global_cache')) {
} }
if (! function_exists('tenant_route')) { if (! function_exists('tenant_route')) {
function tenant_route(string $domain, $route, $parameters = [], $absolute = true) function tenant_route(string $domain, string $route, array $parameters = [], bool $absolute = true): string
{ {
// replace first occurance of hostname fragment with $domain
$url = route($route, $parameters, $absolute); $url = route($route, $parameters, $absolute);
$hostname = parse_url($url, PHP_URL_HOST);
$position = strpos($url, $hostname);
return substr_replace($url, $domain, $position, strlen($hostname)); /**
* The original hostname in the generated route.
*
* @var string $hostname
*/
$hostname = parse_url($url, PHP_URL_HOST);
return (string) str($url)->replace($hostname, $domain);
} }
} }

View file

@ -16,6 +16,7 @@ use Stancl\Tenancy\Listeners\BootstrapTenancy;
use Stancl\Tenancy\Listeners\RevertToCentralContext; use Stancl\Tenancy\Listeners\RevertToCentralContext;
use Stancl\Tenancy\Tests\Etc\ExampleSeeder; use Stancl\Tenancy\Tests\Etc\ExampleSeeder;
use Stancl\Tenancy\Tests\Etc\Tenant; use Stancl\Tenancy\Tests\Etc\Tenant;
use Stancl\Tenancy\Tests\Etc\User;
beforeEach(function () { beforeEach(function () {
Event::listen(TenantCreated::class, JobPipeline::make([CreateDatabase::class])->send(function (TenantCreated $event) { Event::listen(TenantCreated::class, JobPipeline::make([CreateDatabase::class])->send(function (TenantCreated $event) {
@ -183,7 +184,7 @@ test('run command with array of tenants works', function () {
$tenantId2 = Tenant::create()->getTenantKey(); $tenantId2 = Tenant::create()->getTenantKey();
Artisan::call('tenants:migrate-fresh'); Artisan::call('tenants:migrate-fresh');
pest()->artisan("tenants:run foo --tenants=$tenantId1 --tenants=$tenantId2 --argument='a=foo' --option='b=bar' --option='c=xyz'") pest()->artisan("tenants:run --tenants=$tenantId1 --tenants=$tenantId2 'foo foo --b=bar --c=xyz'")
->expectsOutput('Tenant: ' . $tenantId1) ->expectsOutput('Tenant: ' . $tenantId1)
->expectsOutput('Tenant: ' . $tenantId2); ->expectsOutput('Tenant: ' . $tenantId2);
}); });
@ -225,6 +226,29 @@ test('link command works with a specified tenant', function() {
$this->assertDirectoryDoesNotExist(public_path("public-$tenantKey")); $this->assertDirectoryDoesNotExist(public_path("public-$tenantKey"));
}); });
test('run command works when sub command asks questions and accepts arguments', function () {
$tenant = Tenant::create();
$id = $tenant->getTenantKey();
Artisan::call('tenants:migrate');
pest()->artisan("tenants:run --tenants=$id 'user:addwithname Abrar' ")
->expectsQuestion('What is your email?', 'email@localhost')
->expectsOutput("Tenant: $id")
->expectsOutput("User created: Abrar(email@localhost)");
// Assert we are in central context
expect(tenancy()->initialized)->toBeFalse();
// Assert user was created in tenant context
tenancy()->initialize($tenant);
$user = User::first();
// Assert user is same as provided using the command
expect($user->name)->toBe('Abrar');
expect($user->email)->toBe('email@localhost');
});
// todo@tests // todo@tests
function runCommandWorks(): void function runCommandWorks(): void
{ {
@ -232,7 +256,7 @@ function runCommandWorks(): void
Artisan::call('tenants:migrate', ['--tenants' => [$id]]); Artisan::call('tenants:migrate', ['--tenants' => [$id]]);
pest()->artisan("tenants:run foo --tenants=$id --argument='a=foo' --option='b=bar' --option='c=xyz'") pest()->artisan("tenants:run --tenants=$id 'foo foo --b=bar --c=xyz' ")
->expectsOutput("User's name is Test command") ->expectsOutput("User's name is Test command")
->expectsOutput('foo') ->expectsOutput('foo')
->expectsOutput('xyz'); ->expectsOutput('xyz');

View file

@ -9,7 +9,7 @@ use Stancl\Tenancy\Events\TenantCreated;
use Stancl\Tenancy\Jobs\CreateDatabase; use Stancl\Tenancy\Jobs\CreateDatabase;
use Stancl\Tenancy\Jobs\MigrateDatabase; use Stancl\Tenancy\Jobs\MigrateDatabase;
use Stancl\Tenancy\Jobs\SeedDatabase; use Stancl\Tenancy\Jobs\SeedDatabase;
use Stancl\Tenancy\TenantDatabaseManagers\MySQLDatabaseManager; use Stancl\Tenancy\Database\TenantDatabaseManagers\MySQLDatabaseManager;
use Stancl\Tenancy\Tests\Etc\Tenant; use Stancl\Tenancy\Tests\Etc\Tenant;
use Illuminate\Foundation\Auth\User as Authenticable; use Illuminate\Foundation\Auth\User as Authenticable;
use Stancl\Tenancy\Tests\Etc\TestSeeder; use Stancl\Tenancy\Tests\Etc\TestSeeder;

View file

@ -11,11 +11,11 @@ use Stancl\Tenancy\Contracts\ManagesDatabaseUsers;
use Stancl\Tenancy\Events\DatabaseCreated; use Stancl\Tenancy\Events\DatabaseCreated;
use Stancl\Tenancy\Events\TenancyInitialized; use Stancl\Tenancy\Events\TenancyInitialized;
use Stancl\Tenancy\Events\TenantCreated; use Stancl\Tenancy\Events\TenantCreated;
use Stancl\Tenancy\Exceptions\TenantDatabaseUserAlreadyExistsException; use Stancl\Tenancy\Database\Exceptions\TenantDatabaseUserAlreadyExistsException;
use Stancl\Tenancy\Jobs\CreateDatabase; use Stancl\Tenancy\Jobs\CreateDatabase;
use Stancl\Tenancy\Listeners\BootstrapTenancy; use Stancl\Tenancy\Listeners\BootstrapTenancy;
use Stancl\Tenancy\TenantDatabaseManagers\MySQLDatabaseManager; use Stancl\Tenancy\Database\TenantDatabaseManagers\MySQLDatabaseManager;
use Stancl\Tenancy\TenantDatabaseManagers\PermissionControlledMySQLDatabaseManager; use Stancl\Tenancy\Database\TenantDatabaseManagers\PermissionControlledMySQLDatabaseManager;
use Stancl\Tenancy\Tests\Etc\Tenant; use Stancl\Tenancy\Tests\Etc\Tenant;
beforeEach(function () { beforeEach(function () {

68
tests/DebuggableTest.php Normal file
View file

@ -0,0 +1,68 @@
<?php
use Stancl\Tenancy\Enums\LogMode;
use Stancl\Tenancy\Events\EndingTenancy;
use Stancl\Tenancy\Events\InitializingTenancy;
use Stancl\Tenancy\Events\TenancyEnded;
use Stancl\Tenancy\Events\TenancyInitialized;
use Stancl\Tenancy\Tests\Etc\Tenant;
test('tenancy can log events silently', function () {
tenancy()->log(LogMode::SILENT);
$tenant = Tenant::create();
tenancy()->initialize($tenant);
tenancy()->end();
assertTenancyInitializedAndEnded(tenancy()->getLog(), $tenant);
});
test('tenancy logs event silently by default', function () {
tenancy()->log();
expect(tenancy()->logMode())->toBe(LogMode::SILENT);
});
test('the log can be dumped', function (string $method) {
tenancy()->log();
$tenant = Tenant::create();
tenancy()->initialize($tenant);
tenancy()->end();
$output = [];
tenancy()->$method(function ($data) use (&$output) {
$output = $data;
});
assertTenancyInitializedAndEnded($output, $tenant);
})->with([
'dump',
'dd',
]);
test('tenancy can log events immediately', function () {
// todo implement
pest()->markTestIncomplete();
});
// todo test the different behavior of the methods in different contexts, or get rid of the logic and simplify it
function assertTenancyInitializedAndEnded(array $log, Tenant $tenant): void
{
expect($log)->toHaveCount(4);
expect($log[0]['event'])->toBe(InitializingTenancy::class);
expect($log[0]['tenant'])->toBe($tenant);
expect($log[1]['event'])->toBe(TenancyInitialized::class);
expect($log[1]['tenant'])->toBe($tenant);
expect($log[2]['event'])->toBe(EndingTenancy::class);
expect($log[2]['tenant'])->toBe($tenant);
expect($log[3]['event'])->toBe(TenancyEnded::class);
expect($log[3]['tenant'])->toBe($tenant);
}

View file

@ -2,12 +2,13 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Tests\Etc; namespace Stancl\Tenancy\Tests\Etc\Console;
use Illuminate\Console\Command; use Illuminate\Console\Command;
use Illuminate\Support\Str; use Illuminate\Support\Str;
use Stancl\Tenancy\Concerns\HasATenantsOption; use Stancl\Tenancy\Concerns\HasATenantsOption;
use Stancl\Tenancy\Concerns\TenantAwareCommand; use Stancl\Tenancy\Concerns\TenantAwareCommand;
use Stancl\Tenancy\Tests\Etc\User;
class AddUserCommand extends Command class AddUserCommand extends Command
{ {

View file

@ -2,7 +2,7 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Tests\Etc; namespace Stancl\Tenancy\Tests\Etc\Console;
use Orchestra\Testbench\Foundation\Console\Kernel; use Orchestra\Testbench\Foundation\Console\Kernel;
@ -10,6 +10,7 @@ class ConsoleKernel extends Kernel
{ {
protected $commands = [ protected $commands = [
ExampleCommand::class, ExampleCommand::class,
ExampleQuestionCommand::class,
AddUserCommand::class, AddUserCommand::class,
]; ];
} }

View file

@ -2,7 +2,7 @@
declare(strict_types=1); declare(strict_types=1);
namespace Stancl\Tenancy\Tests\Etc; namespace Stancl\Tenancy\Tests\Etc\Console;
use Illuminate\Console\Command; use Illuminate\Console\Command;

View file

@ -0,0 +1,46 @@
<?php
namespace Stancl\Tenancy\Tests\Etc\Console;
use Illuminate\Console\Command;
use Illuminate\Support\Str;
use Stancl\Tenancy\Tests\Etc\User;
class ExampleQuestionCommand extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'user:addwithname {name}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Command description';
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$email = $this->ask('What is your email?');
User::create([
'name' => $this->argument('name'),
'email' => $email,
'email_verified_at' => now(),
'password' => '$2y$10$92IXUNpkjO0rOQ5byMi.Ye4oKoEa3Ro9llC/.og/at2.uheWG/igi', // password
'remember_token' => Str::random(10),
]);
$this->line("User created: ". $this->argument('name') . "($email)");
return 0;
}
}

View file

@ -4,7 +4,7 @@ declare(strict_types=1);
namespace Stancl\Tenancy\Tests\Etc; namespace Stancl\Tenancy\Tests\Etc;
use Stancl\Tenancy\Contracts\TenantWithDatabase; use Stancl\Tenancy\Database\Contracts\TenantWithDatabase;
use Stancl\Tenancy\Database\Concerns\HasDatabase; use Stancl\Tenancy\Database\Concerns\HasDatabase;
use Stancl\Tenancy\Database\Concerns\HasDomains; use Stancl\Tenancy\Database\Concerns\HasDomains;
use Stancl\Tenancy\Database\Models; use Stancl\Tenancy\Database\Models;

Some files were not shown because too many files have changed in this diff Show more