Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 1c79e0d9 authored by Akhil's avatar Akhil 🙂
Browse files

shop acc service added

parent b9746ae7

lib/Controller/UserController.php

+8 −0
Original line number Diff line number Diff line
@@ -34,6 +34,14 @@ class UserController extends ApiController 
        $this->config = $config;

    }



    /**

     * @NoAdminRequired

     */



    public function setShopDeleteInfo(bool $deleteShopAccount, string $shopEmailPostDelete) {



    }

    

    /**

     * @CORS

     * @PublicPage

lib/Listeners/BeforeUserDeletedListener.php

+1 −11
Original line number Diff line number Diff line
@@ -14,7 +14,7 @@ use OCP\IConfig; 
use OCP\User\Events\BeforeUserDeletedEvent;

use OCA\EcloudAccounts\Service\LDAPConnectionService;



require_once 'curl.class.php';

require_once '../curl.class.php';



class BeforeUserDeletedListener implements IEventListener

{
@@ -27,16 +27,6 @@ class BeforeUserDeletedListener implements IEventListener 
        $this->logger = $logger;

        $this->config = $config;

        $this->LDAPConnectionService = $LDAPConnectionService;





        $wordPressUsername = getenv("WP_SHOP_USERNAME");

        $wordPressPassword = getenv("WP_SHOP_PASS");

        $wordPressUrl = getenv("WP_SHOP_URL");



        $this->wordPressUserUrl = $wordPressUrl . "/wp-json/wp/v2/users";

        $this->wordPressCredentials = base64_encode($wordPressUsername . ":" . $wordPressPassword);

        $this->wordPressReassignUserId = getenv('WP_REASSIGN_USER_ID');



    }

lib/Listeners/UserDeletedListener.php

+1 −1
Original line number Diff line number Diff line
@@ -14,7 +14,7 @@ use OCP\ILogger; 
use OCP\User\Events\UserDeletedEvent;

use OCA\EcloudAccounts\Service\LDAPConnectionService;



require_once 'curl.class.php';

require_once '../curl.class.php';



class UserDeletedListener implements IEventListener

{

lib/Service/ShopAccountService.php

0 → 100644
+114 −0
Original line number Diff line number Diff line 
<?php





namespace OCA\EcloudAccounts\Service;



use OCP\IConfig;



require_once '../curl.class.php';



class ShopAccountService {



    private $config;

    private $appName;



    public function __construct($appName, IConfig $config)

    {



        $shopUsername = getenv("WP_SHOP_USERNAME");

        $shopPassword = getenv("WP_SHOP_PASS");

        $shopUrl = getenv("WP_SHOP_URL");



        $this->appName = $appName;

        $this->shopUserUrl = $shopUrl . "/wp-json/wp/v2/users";

        $this->shopCredentials = base64_encode($shopUsername . ":" . $shopPassword);

        $this->shopReassignUserId = getenv('WP_REASSIGN_USER_ID');

        $this->config = $config;

    }



    public function setShopDeletePreference($userId, bool $delete) {

        $this->config->setUserValue($userId, $this->appName, 'delete_shop_account', $delete);

    }



    public function setShopEmailPostDelete($userId, string $shopEmailPostDelete) {

        $this->config->setUserValue($userId, $this->appName, 'shop_email_post_delete', $shopEmailPostDelete);

    }



    public function getShopDeletePreference($userId) {

        return $this->config->getUserValue($userId, $this->appName, 'delete_shop_account', true);

    }



    public function getShopEmailPreference($userId) {

        $recoveryEmail = $this->config->getUserValue($userId, 'email-recovery', 'recovery-email');



        return $this->config->getUserValue($userId, $this->appName, 'shop_email_post_delete', $recoveryEmail);  

    }



    private function getUsersFromShop(string $searchTerm): ?array

    {

        $curl = new Curl();

        $headers = [

            "cache-control: no-cache",

            "content-type: application/json",

            "Authorization: Basic " . $this->shopCredentials

        ];

        

        try {

            $answer = $curl->get($this->shopUserUrl, ['search' => $searchTerm], $headers);

            return json_decode($answer, true);

        }

        catch(Exception $e) {

            $this->logger->error('There was an issue querying shop for users');

            $this->logger->logException($e, ['app' => Application::APP_ID]);

        }

    }



    private function getUserFromShop(string $email) {

        $users = $this->getUsersFromShop($email);

        if(empty($users)) {

            return;

        }

        if(count($users) > 1) {

            $this->logger->error('More than one user in WP results when deleting user with email ' . $email);

            return;

        }

        return $users[0];



    }



    private function deleteUserFromShop(string $email) {

        $user = $this->getUserFromShop($email);

    

        if($user && $this->isUserOIDC($user)) {

            $curl = new Curl();

            

            $headers = [

                "cache-control: no-cache",

                "content-type: application/json",

                "Authorization: Basic " . $this->shopCredentials

            ];

            $params = [

                'force' => true,

                'reassign' => $this->shopReassignUserId

            ];

            $deleteUrl = $this->shopUserUrl . '/' . $user['id'];



            try {

                $answer = $curl->delete($deleteUrl, $params, $headers);

                $answer = json_decode($answer, true);



                if(!$answer['deleted']) {

                    throw new Exception("User not deleted at WP ". $user['id'] );

                }

            }

            catch(Exception $e) {

                $this->logger->error('Error deleting user at WP with ID ' . $user['id']);

                $this->logger->logException($e, ['app' => Application::APP_ID]);

            }

        }

    } 



    private function isUserOIDC(array $user) {

        return !empty($user['openid-connect-generic-last-user-claim']);

    }

}
 
 No newline at end of file

lib/Listeners/curl.class.php→lib/curl.class.php

+0 −0

File moved.

View file