Add caching experiment users

Modules/AbRouter/Console/RunUsersExperimentsIndexer.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Modules\AbRouter\Console;
+
+use Illuminate\Console\Command;
+use Modules\AbRouter\Models\Events\Event;
+use Modules\AbRouter\Models\RelatedUsers\RelatedUser;
+use Exception;
+use Modules\AbRouter\Services\UsersExperiments\ProcessAllUsersExperimentsService;
+
+class RunUsersExperimentsIndexer extends Command
+{
+    /**
+     * The console command name.
+     *
+     * @var string
+     */
+    protected $name = 'abrouter:users-experiments-indexer';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '';
+
+    /**
+     * @throws Exception
+     */
+    public function handle()
+    {
+        /**
+         * @var ProcessAllUsersExperimentsService $processAllUsersExperiments
+         */
+        $processAllUsersExperiments = app()->make(ProcessAllUsersExperimentsService::class);
+        $processAllUsersExperiments->processAll();
+    }
+}

Modules/AbRouter/Http/Controllers/ExperimentsController.php

@@ -3,6 +3,7 @@
 namespace Modules\AbRouter\Http\Controllers;
 
 use AbRouter\JsonApiFormatter\DataSource\DataProviders\SimpleDataProvider;
+use Illuminate\Http\Response;
 use Laravel\Passport\Token;
 use Illuminate\Http\Request;
 use Illuminate\Routing\Controller;
@@ -17,6 +18,7 @@
 use Modules\AbRouter\Http\Transformers\Experiments\SimpleRunTransformer;
 use Modules\AbRouter\Http\Transformers\Experiments\UserExperimentsTransformer;
 use Modules\AbRouter\Models\Experiments\Experiment;
+use Modules\AbRouter\Repositories\AllUsersExperimentsHotStorageRepository;
 use Modules\AbRouter\Repositories\Experiments\ExperimentBranchUserRepository;
 use Modules\AbRouter\Repositories\Experiments\ExperimentUsersRepository;
 use Modules\AbRouter\Services\Experiment\ExperimentService;
@@ -157,9 +159,20 @@ public function deleteUserFromExperiment(
     public function allUsersExperiments(
         ExperimentUsersRepository $repository,
         AuthDecorator $authDecorator,
-        AllUsersExperimentsTransformer $allUsersExperimentsTransformer
+        AllUsersExperimentsTransformer $allUsersExperimentsTransformer,
+        AllUsersExperimentsHotStorageRepository $allUsersExperimentsHotStorageRepository
     ) {
         $ownerId = $authDecorator->get()->getId();
+        if ($allUsersExperimentsHotStorageRepository->get($ownerId)) {
+            return response([
+                'status' => false,
+                'message' => 'Calculating, try in 5 minutes',
+                'data' => [
+                    'retryIn' => 300,
+                ],
+                Response::HTTP_PROCESSING
+            ]);
+        }
 
         return $allUsersExperimentsTransformer->getAllUsersExperiments(
             $repository->getAllUsersExperiments($ownerId)

Modules/AbRouter/Managers/AllUsersExperimentsHotStorageManager.php

@@ -0,0 +1,30 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\AbRouter\Managers;
+
+use Illuminate\Support\Collection;
+use Modules\AbRouter\Transformers\HotKvStorageKeysTransformer;
+
+class AllUsersExperimentsHotStorageManager
+{
+    private HotKvStorageManager $hotKvStorageManager;
+
+    private HotKvStorageKeysTransformer $hotKvStorageKeysTransformer;
+
+    public function __construct(
+        HotKvStorageManager $hotKvStorageManager,
+        HotKvStorageKeysTransformer $hotKvStorageKeysTransformer
+    ) {
+        $this->hotKvStorageManager = $hotKvStorageManager;
+        $this->hotKvStorageKeysTransformer = $hotKvStorageKeysTransformer;
+    }
+
+    public function store(int $ownerId, Collection $collection)
+    {
+        $this->hotKvStorageManager->store(
+            $this->hotKvStorageKeysTransformer->getAllUsersKey($ownerId),
+            serialize($collection)
+        );
+    }
+}

Modules/AbRouter/Managers/HotKvStorageManager.php

@@ -0,0 +1,14 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\AbRouter\Managers;
+
+use Illuminate\Support\Facades\Redis;
+
+class HotKvStorageManager
+{
+    public function store(string $key, string $data): bool
+    {
+        return Redis::connection()->client()->set($key, $data);
+    }
+}

Modules/AbRouter/Providers/AbRouterServiceProvider.php

@@ -5,7 +5,10 @@
 use Illuminate\Support\Facades\View;
 use Illuminate\Support\ServiceProvider;
 use Illuminate\Database\Eloquent\Factory;
+use Modules\AbRouter\Console\CreateDatabase;
+use Modules\AbRouter\Console\DropDatabase;
 use Modules\AbRouter\Console\FillOwnerIdExperimentUserBranches;
+use Modules\AbRouter\Console\MigrateTemporaryUser;
 
 class AbRouterServiceProvider extends ServiceProvider
 {
@@ -21,9 +24,9 @@ public function boot()
         $this->registerConfig();
         $this->registerViews();
         $this->registerFactories();
-        $this->commands([\Modules\AbRouter\Console\CreateDatabase::class]);
-        $this->commands([\Modules\AbRouter\Console\DropDatabase::class]);
-        $this->commands([\Modules\AbRouter\Console\MigrateTemporaryUser::class]);
+        $this->commands([CreateDatabase::class]);
+        $this->commands([DropDatabase::class]);
+        $this->commands([MigrateTemporaryUser::class]);
         $this->commands([FillOwnerIdExperimentUserBranches::class]);
 
         $this->loadMigrationsFrom(module_path('AbRouter', 'Database/Migrations'));
@@ -37,6 +40,7 @@ public function boot()
     public function register()
     {
         $this->app->register(RouteServiceProvider::class);
+        $this->app->register(KernelProvider::class);
     }
 
     /**

Modules/AbRouter/Providers/KernelProvider.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Modules\AbRouter\Providers;
+
+use Illuminate\Console\Scheduling\Schedule;
+use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
+use Modules\AbRouter\Services\UsersExperiments\ProcessAllUsersExperimentsService;
+
+class KernelProvider extends ConsoleKernel
+{
+    protected function schedule(Schedule $schedule)
+    {
+        $schedule->call(function () {
+            /**
+             * @var ProcessAllUsersExperimentsService $processAllUsersExperiments
+             */
+            $processAllUsersExperiments = app()->make(ProcessAllUsersExperimentsService::class);
+            $processAllUsersExperiments->processAll();
+        })->everyThirtyMinutes();
+    }
+}

Modules/AbRouter/Repositories/AllUsersExperimentsHotStorageRepository.php

@@ -0,0 +1,32 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\AbRouter\Repositories;
+
+use Illuminate\Support\Collection;
+use Modules\AbRouter\Transformers\HotKvStorageKeysTransformer;
+
+class AllUsersExperimentsHotStorageRepository
+{
+    private HotKvStorageRepository $hotKvStorageRepository;
+
+    private HotKvStorageKeysTransformer $hotKvStorageKeysTransformer;
+
+    public function __construct(
+        HotKvStorageRepository $hotKvStorageRepository,
+        HotKvStorageKeysTransformer $hotKvStorageKeysTransformer
+    ) {
+        $this->hotKvStorageRepository = $hotKvStorageRepository;
+        $this->hotKvStorageKeysTransformer = $hotKvStorageKeysTransformer;
+    }
+
+    public function get(int $ownerId): ?Collection
+    {
+        $data = $this->hotKvStorageRepository->get($this->hotKvStorageKeysTransformer->getAllUsersKey($ownerId));
+        if (empty($data)) {
+            return null;
+        }
+
+        return unserialize($data);
+    }
+}

Modules/AbRouter/Repositories/HotKvStorageRepository.php

@@ -0,0 +1,18 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\AbRouter\Repositories;
+
+use Illuminate\Support\Facades\Redis;
+
+class HotKvStorageRepository
+{
+    /**
+     * @param string $key
+     * @return false|mixed|string
+     */
+    public function get(string $key)
+    {
+        return Redis::connection()->client()->get($key);
+    }
+}

Modules/AbRouter/Repositories/Users/UsersRepository.php

@@ -0,0 +1,26 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\AbRouter\Repositories\Users;
+
+use App\Models\User;
+use Illuminate\Support\Collection;
+use Modules\Core\Repositories\BaseRepository;
+
+class UsersRepository extends BaseRepository
+{
+    public function getUsersWithExperimentExists(): Collection
+    {
+        return $this
+            ->query()
+            ->select('users.*')
+            ->join('experiments', 'users.id', '=', 'experiments.owner_id')
+            ->whereNotNull('experiments.id')
+            ->get();
+    }
+
+    protected function getModel()
+    {
+        return new User();
+    }
+}

Modules/AbRouter/Services/UsersExperiments/ProcessAllUsersExperimentsService.php

@@ -0,0 +1,30 @@
+<?php
+declare(strict_types =1);
+
+namespace Modules\AbRouter\Services\UsersExperiments;
+
+use App\Models\User;
+use Modules\AbRouter\Repositories\Users\UsersRepository;
+
+class ProcessAllUsersExperimentsService
+{
+    private ProcessUsersExperimentsService $processUsersExperimentsService;
+
+    private UsersRepository $usersRepository;
+
+    public function __construct(
+        ProcessUsersExperimentsService $processUsersExperimentsService,
+        UsersRepository $usersRepository
+    ) {
+        $this->processUsersExperimentsService = $processUsersExperimentsService;
+        $this->usersRepository = $usersRepository;
+    }
+
+    public function processAll(): void
+    {
+        $allUsers = $this->usersRepository->getUsersWithExperimentExists();
+        $allUsers->each(function (User $user) {
+            $this->processUsersExperimentsService->processByOwnerId($user->id);
+        });
+    }
+}

Modules/AbRouter/Services/UsersExperiments/ProcessUsersExperimentsService.php

@@ -0,0 +1,35 @@
+<?php
+declare(strict_types =1);
+
+namespace Modules\AbRouter\Services\UsersExperiments;
+
+use Modules\AbRouter\Managers\AllUsersExperimentsHotStorageManager;
+use Modules\AbRouter\Repositories\Experiments\ExperimentUsersRepository;
+use Modules\AbRouter\Transformers\AllUsersExperimentsTransformer;
+
+class ProcessUsersExperimentsService
+{
+    private ExperimentUsersRepository $experimentUsersRepository;
+
+    private AllUsersExperimentsTransformer $allUsersExperimentsTransformer;
+
+    private AllUsersExperimentsHotStorageManager $allUsersExperimentsHotStorageManager;
+
+    public function __construct(
+        ExperimentUsersRepository $experimentUsersRepository,
+        AllUsersExperimentsTransformer $allUsersExperimentsTransformer,
+        AllUsersExperimentsHotStorageManager $allUsersExperimentsHotStorageManager
+    ) {
+        $this->experimentUsersRepository = $experimentUsersRepository;
+        $this->allUsersExperimentsTransformer = $allUsersExperimentsTransformer;
+        $this->allUsersExperimentsHotStorageManager = $allUsersExperimentsHotStorageManager;
+    }
+
+    public function processByOwnerId(int $ownerId): void
+    {
+        $allUsersExperiments = $this->allUsersExperimentsTransformer->getAllUsersExperiments(
+            $this->experimentUsersRepository->getAllUsersExperiments($ownerId)
+        );
+        $this->allUsersExperimentsHotStorageManager->store($ownerId, collect($allUsersExperiments));
+    }
+}

Modules/AbRouter/Transformers/AllUsersExperimentsTransformer.php

@@ -23,7 +23,7 @@ public function getAllUsersExperiments(Collection $usersExperiments): array
         return $allUsersExperiments;
     }
 
-    public function getExperiments(Collection $experimentUsers): array
+    private function getExperiments(Collection $experimentUsers): array
     {
         $experiments = [];
 

Modules/AbRouter/Transformers/HotKvStorageKeysTransformer.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Modules\AbRouter\Transformers;
+
+class HotKvStorageKeysTransformer
+{
+    public function getAllUsersKey(int $ownerId): string
+    {
+        return sprintf('all-users-'  . $ownerId);
+    }
+}