feat(connections): add reusable authorization connections system

backend/Actions/ACPT/ACPTController.php

@@ -6,35 +6,22 @@
 
 namespace BitApps\Integrations\Actions\ACPT;
 
-use BitApps\Integrations\Core\Util\HttpHelper;
+use BitApps\Integrations\Authorization\AuthorizationType;
 use WP_Error;
 
 /**
  * Provide functionality for ACPT integration
  */
 class ACPTController
 {
-    protected $_defaultHeader;
-
-    public function authentication($fieldsRequestParams)
-    {
-        $this->checkValidation($fieldsRequestParams);
-        $this->setHeaders($fieldsRequestParams->api_key);
-
-        $apiEndpoint = $fieldsRequestParams->base_url . '/wp-json/acpt/v1/taxonomy';
-        $response = HttpHelper::get($apiEndpoint, null, $this->_defaultHeader);
-
-        if (is_wp_error($response) || HttpHelper::$responseCode != 200) {
-            wp_send_json_error(
-                !empty($response->message)
-                    ? $response->message
-                    : __('Please enter valid Api key-secret', 'bit-integrations'),
-                HttpHelper::$responseCode
-            );
-        }
-
-        wp_send_json_success(__('Authentication successful', 'bit-integrations'), 200);
-    }
+    public static array $authConfig = [
+        'authType' => AuthorizationType::API_KEY,
+        'slug'     => 'acpt',
+        'fields'   => [
+            'api_key'  => 'value',
+            'base_url' => 'base_url',
+        ],
+    ];
 
     public function execute($integrationData, $fieldValues)
     {
@@ -59,20 +46,4 @@ public function execute($integrationData, $fieldValues)
 
         return $acptApiResponse;
     }
-
-    private function checkValidation($fieldsRequestParams, $customParam = '**')
-    {
-        if (empty($fieldsRequestParams->base_url) || empty($fieldsRequestParams->api_key) || empty($customParam)) {
-            wp_send_json_error(__('Requested parameter is empty', 'bit-integrations'), 400);
-        }
-    }
-
-    private function setHeaders($apiKey)
-    {
-        $this->_defaultHeader = [
-            'acpt-api-key' => $apiKey,
-            'Content-Type' => 'application/json',
-            'accept'       => 'application/json',
-        ];
-    }
 }

backend/Actions/ACPT/Routes.php

@@ -6,5 +6,3 @@
 
 use BitApps\Integrations\Actions\ACPT\ACPTController;
 use BitApps\Integrations\Core\Util\Route;
-
-Route::post('acpt_authentication', [ACPTController::class, 'authentication']);

backend/Actions/AcademyLms/AcademyLmsController.php

@@ -20,22 +20,6 @@ public function __construct($integrationID)
         $this->_integrationID = $integrationID;
     }
 
-    /**
-     * Process ajax request for generate_token
-     *
-     * @return JSON zoho crm api response and status
-     */
-    public static function Authorization()
-    {
-        include_once ABSPATH . 'wp-admin/includes/plugin.php';
-        if (is_plugin_active('academy/academy.php')) {
-            wp_send_json_success(true, 200);
-        }
-
-        // translators: %s: Plugin name
-        wp_send_json_error(wp_sprintf(__('%s must be activated!', 'bit-integrations'), 'Academy Lms'));
-    }
-
     public static function getAllLesson()
     {
         if (!class_exists('Academy')) {

backend/Actions/AcademyLms/Routes.php

@@ -7,6 +7,5 @@
 use BitApps\Integrations\Actions\AcademyLms\AcademyLmsController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('academy_lms_authorize', [AcademyLmsController::class, 'Authorization']);
 Route::get('academy_lms_all_course', [AcademyLmsController::class, 'getAllCourse']);
 Route::get('academy_lms_all_lesson', [AcademyLmsController::class, 'getAllLesson']);

backend/Actions/ActiveCampaign/ActiveCampaignController.php

@@ -6,6 +6,7 @@
 
 namespace BitApps\Integrations\Actions\ActiveCampaign;
 
+use BitApps\Integrations\Authorization\AuthorizationType;
 use BitApps\Integrations\Core\Util\HttpHelper;
 use WP_Error;
 
@@ -14,6 +15,15 @@
  */
 class ActiveCampaignController
 {
+    public static array $authConfig = [
+        'authType' => AuthorizationType::API_KEY,
+        'slug'     => 'activecampaign',
+        'fields'   => [
+            'api_key' => 'value',
+            'api_url' => 'api_url',
+        ],
+    ];
+
     private $_integrationID;
 
     public function __construct($integrationID)
@@ -26,42 +36,6 @@ public static function _apiEndpoint($api_url, $method)
         return "{$api_url}/api/3/{$method}/";
     }
 
-    /**
-     * Process ajax request
-     *
-     * @param $requestsParams Params to authorize
-     *
-     * @return JSON Active Campaign api response and status
-     */
-    public static function activeCampaignAuthorize($requestsParams)
-    {
-        if (
-            empty($requestsParams->api_key)
-            || empty($requestsParams->api_url)
-        ) {
-            wp_send_json_error(
-                __(
-                    'Requested parameter is empty',
-                    'bit-integrations'
-                ),
-                400
-            );
-        }
-
-        $apiEndpoint = self::_apiEndpoint($requestsParams->api_url, 'accounts');
-        $authorizationHeader['Api-Token'] = $requestsParams->api_key;
-        $apiResponse = HttpHelper::get($apiEndpoint, null, $authorizationHeader);
-
-        if (is_wp_error($apiResponse) || empty($apiResponse)) {
-            wp_send_json_error(
-                empty($apiResponse) ? 'Unknown' : $apiResponse,
-                400
-            );
-        }
-
-        wp_send_json_success(true);
-    }
-
     /**
      * Process ajax request for refresh lists
      *

backend/Actions/ActiveCampaign/Routes.php

@@ -7,7 +7,6 @@
 use BitApps\Integrations\Actions\ActiveCampaign\ActiveCampaignController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('aCampaign_authorize', [ActiveCampaignController::class, 'activeCampaignAuthorize']);
 Route::post('aCampaign_headers', [ActiveCampaignController::class, 'activeCampaignHeaders']);
 Route::post('aCampaign_lists', [ActiveCampaignController::class, 'activeCampaignLists']);
 Route::post('aCampaign_accounts', [ActiveCampaignController::class, 'activeCampaignAccounts']);

backend/Actions/Acumbamail/AcumbamailController.php

@@ -6,6 +6,7 @@
 
 namespace BitApps\Integrations\Actions\Acumbamail;
 
+use BitApps\Integrations\Authorization\AuthorizationType;
 use BitApps\Integrations\Core\Util\HttpHelper;
 use WP_Error;
 
@@ -14,6 +15,14 @@
  */
 class AcumbamailController
 {
+    public static array $authConfig = [
+        'authType' => AuthorizationType::API_KEY,
+        'slug'     => 'acumbamail',
+        'fields'   => [
+            'auth_token' => 'value',
+        ],
+    ];
+
     private $baseUrl = 'https://acumbamail.com/api/1/';
 
     public function fetchAllLists($requestParams)
@@ -46,32 +55,6 @@ public function fetchAllLists($requestParams)
         }
     }
 
-    public function acumbamailAuthAndFetchSubscriberList($requestParams)
-    {
-        if (empty($requestParams->auth_token)) {
-            wp_send_json_error(
-                __(
-                    'Requested parameter is empty',
-                    'bit-integrations'
-                ),
-                400
-            );
-        }
-        $apiEndpoints = $this->baseUrl . 'getSubscribers/';
-
-        $requestParams = [
-            'auth_token' => $requestParams->auth_token,
-        ];
-
-        $response = HttpHelper::post($apiEndpoints, $requestParams);
-
-        if ($response == 'Unauthorized' || $response == 'This endpoint is not available for non-paying customers' || $response == 'Your auth token has expired check /apidoc/ for the new one') {
-            wp_send_json_error($response, 400);
-        } else {
-            wp_send_json_success($response, 200);
-        }
-    }
-
     public function acumbamailRefreshFields($refreshFieldsRequestParams)
     {
         if (empty($refreshFieldsRequestParams->auth_token) || empty($refreshFieldsRequestParams->list_id)) {

backend/Actions/Acumbamail/Routes.php

@@ -7,6 +7,5 @@
 use BitApps\Integrations\Actions\Acumbamail\AcumbamailController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('acumbamail_authorization_and_fetch_subscriber_list', [AcumbamailController::class, 'acumbamailAuthAndFetchSubscriberList']);
 Route::post('acumbamail_fetch_all_list', [AcumbamailController::class, 'fetchAllLists']);
 Route::post('acumbamail_refresh_fields', [AcumbamailController::class, 'acumbamailRefreshFields']);

backend/Actions/Affiliate/AffiliateController.php

@@ -30,16 +30,6 @@ public static function pluginActive($option = null)
         return false;
     }
 
-    public static function authorizeAffiliate()
-    {
-        include_once ABSPATH . 'wp-admin/includes/plugin.php';
-        if (self::pluginActive()) {
-            wp_send_json_success(true, 200);
-        }
-        // translators: %s: Plugin name
-        wp_send_json_error(wp_sprintf(__('%s must be activated!', 'bit-integrations'), 'Affiliate'));
-    }
-
     public static function getAllAffiliate()
     {
         $cache_key = Config::withPrefix('affiliate_wp_all_affiliates');

backend/Actions/Affiliate/Routes.php

@@ -7,5 +7,4 @@
 use BitApps\Integrations\Actions\Affiliate\AffiliateController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('affiliate_authorize', [AffiliateController::class, 'authorizeAffiliate']);
 Route::post('affiliate_fetch_all_affiliate', [AffiliateController::class, 'getAllAffiliate']);

backend/Actions/AgiledCRM/AgiledCRMController.php

@@ -6,6 +6,7 @@
 
 namespace BitApps\Integrations\Actions\AgiledCRM;
 
+use BitApps\Integrations\Authorization\AuthorizationType;
 use BitApps\Integrations\Core\Util\HttpHelper;
 use WP_Error;
 
@@ -14,29 +15,16 @@
  */
 class AgiledCRMController
 {
-    protected $_defaultHeader;
-
-    public function authentication($fieldsRequestParams)
-    {
-        if (empty($fieldsRequestParams->auth_token) || empty($fieldsRequestParams->brand)) {
-            wp_send_json_error(__('Requested parameter is empty', 'bit-integrations'), 400);
-        }
+    public static array $authConfig = [
+        'authType' => AuthorizationType::API_KEY,
+        'slug'     => 'agiledcrm',
+        'fields'   => [
+            'auth_token' => 'value',
+            'brand'      => 'brand',
+        ],
+    ];
 
-        $brand = $fieldsRequestParams->brand;
-        $apiKey = $fieldsRequestParams->auth_token;
-        $apiEndpoint = "https://my.agiled.app/api/v1/users?api_token={$apiKey}";
-        $header = [
-            'Brand' => $brand
-        ];
-
-        $response = HttpHelper::get($apiEndpoint, null, $header);
-
-        if (isset($response->data[0]->id)) {
-            wp_send_json_success(__('Authentication successful', 'bit-integrations'), 200);
-        } else {
-            wp_send_json_error(__('Please enter valid Brand name & API key', 'bit-integrations'), 400);
-        }
-    }
+    protected $_defaultHeader;
 
     public function getAllOwners($fieldsRequestParams)
     {

backend/Actions/AgiledCRM/Routes.php

@@ -7,7 +7,6 @@
 use BitApps\Integrations\Actions\AgiledCRM\AgiledCRMController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('agiled_authentication', [AgiledCRMController::class, 'authentication']);
 Route::post('agiled_fetch_all_owners', [AgiledCRMController::class, 'getAllOwners']);
 Route::post('agiled_fetch_all_accounts', [AgiledCRMController::class, 'getAllAccounts']);
 Route::post('agiled_fetch_all_sources', [AgiledCRMController::class, 'getAllSources']);

backend/Actions/Airtable/AirtableController.php

@@ -6,6 +6,7 @@
 
 namespace BitApps\Integrations\Actions\Airtable;
 
+use BitApps\Integrations\Authorization\AuthorizationType;
 use BitApps\Integrations\Core\Util\HttpHelper;
 use WP_Error;
 
@@ -14,9 +15,17 @@
  */
 class AirtableController
 {
+    public static array $authConfig = [
+        'authType' => AuthorizationType::BEARER_TOKEN,
+        'slug'     => 'airtable',
+        'fields'   => [
+            'auth_token' => 'token',
+        ],
+    ];
+
     protected $_defaultHeader;
 
-    public function authentication($fieldsRequestParams)
+    public function fetchAllBases($fieldsRequestParams)
     {
         if (empty($fieldsRequestParams->auth_token)) {
             wp_send_json_error(__('Requested parameter is empty', 'bit-integrations'), 400);
@@ -31,6 +40,7 @@ public function authentication($fieldsRequestParams)
         $response = HttpHelper::get($apiEndpoint, null, $header);
 
         if (isset($response->bases)) {
+            $bases = [];
             foreach ($response->bases as $base) {
                 if ($base->permissionLevel === 'create') {
                     $bases[] = [
@@ -61,6 +71,7 @@ public function getAllTables($fieldsRequestParams)
         $response = HttpHelper::get($apiEndpoint, null, $header);
 
         if (isset($response->tables)) {
+            $tables = [];
             foreach ($response->tables as $table) {
                 $tables[] = [
                     'id'   => $table->id,
@@ -91,6 +102,7 @@ public function getAllFields($fieldsRequestParams)
         $acceptedTypes = ['singleLineText', 'multilineText', 'singleSelect', 'multipleSelects', 'multipleAttachments', 'date', 'phoneNumber', 'email', 'url', 'number', 'currency', 'percent', 'duration', 'rating', 'barcode'];
 
         if (isset($response->tables)) {
+            $fields = [];
             foreach ($response->tables as $table) {
                 if ($table->id === $tableId) {
                     foreach ($table->fields as $field) {

backend/Actions/Airtable/Routes.php

@@ -7,6 +7,6 @@
 use BitApps\Integrations\Actions\Airtable\AirtableController;
 use BitApps\Integrations\Core\Util\Route;
 
-Route::post('airtable_authentication', [AirtableController::class, 'authentication']);
+Route::post('airtable_fetch_all_bases', [AirtableController::class, 'fetchAllBases']);
 Route::post('airtable_fetch_all_tables', [AirtableController::class, 'getAllTables']);
 Route::post('airtable_fetch_all_fields', [AirtableController::class, 'getAllFields']);