Chamilo\CoreBundle\Command\AzureSyncUsersCommand::execute()

Complexity

Conditions	11
Paths	42

Size

Total Lines	95
Code Lines	51

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);

        $io->title('Synchronizing users from Azure.');

        /** @var array<string, int> $azureCreatedUserIdList */
        $azureCreatedUserIdList = [];

        try {
            foreach ($this->getAzureUsers() as $azureUserInfo) {
                try {
                    $user = $this->azureHelper->registerUser($azureUserInfo);
                } catch (NonUniqueResultException $e) {
                    $io->warning($e->getMessage());

                    continue;
                }

                $azureCreatedUserIdList[$azureUserInfo['id']] = $user->getId();

                $io->text(
                    sprintf('User (ID %d) with received info: %s ', $user->getId(), serialize($azureUserInfo))
                );
            }
        } catch (Exception $e) {
            $io->error($e->getMessage());

            return Command::INVALID;
        }

        $io->section('Updating users status');

        $roleGroups = $this->getGroupUidByRole();
        $roleActions = $this->getUpdateActionByRole();

        foreach ($roleGroups as $userRole => $groupUid) {
            try {
                $azureGroupMembersInfo = iterator_to_array($this->getAzureGroupMembers($groupUid));
            } catch (Exception $e) {
                $io->warning($e->getMessage());

                continue;
            }

            $azureGroupMembersUids = array_column($azureGroupMembersInfo, 'id');

            foreach ($azureGroupMembersUids as $azureGroupMembersUid) {
                $userId = $azureCreatedUserIdList[$azureGroupMembersUid] ?? null;

                if (!$userId) {
                    continue;
                }

                if (isset($roleActions[$userRole])) {
                    $user = $this->userRepository->find($userId);

                    $roleActions[$userRole]($user);

                    $io->text(
                        sprintf('User (ID %d) status %s', $userId, $userRole)
                    );
                }
            }

            $this->entityManager->flush();
        }

        if ($this->providerParams['deactivate_nonexisting_users']
            && !$this->providerParams['script_users_delta']
        ) {
            $io->section('Trying deactivate non-existing users in Azure');

            $users = $this->userRepository->findByAuthsource(UserAuthSource::AZURE);

            $chamiloUserIdList = array_map(
                fn(User $user) => $user->getId(),
                $users
            );

            $nonExistingUsers = array_diff($chamiloUserIdList, $azureCreatedUserIdList);

            $this->userRepository->deactivateUsers($nonExistingUsers);

            $io->text(
                sprintf(
                    'Deactivated users IDs: %s',
                    implode(', ', $nonExistingUsers)
                )
            );
        }

        $io->success('You have a new command! Now make it your own! Pass --help to see your options.');

        return Command::SUCCESS;
    }