PluginProbe
Bit Form – Contact Form, Payment Forms, Multi Step Forms, Calculator & Custom Form Builder / 3.3.1
Bit Form – Contact Form, Payment Forms, Multi Step Forms, Calculator & Custom Form Builder v3.3.1
3.3.1 V-3.3.0 3.2.2 3.2.1 3.2.0 3.1.4 3.1.3 3.1.2 3.1.1 3.1.0 V3.0.3 V3.0.2 -3.0.1 V_3.0.0 1.1.1 1.1.8 1.2 1.3 1.4 1.4.18 1.5.2 1.9 2.0 2.10.0 2.10.1 All 138 releases
← All changes | includes/Core/Integration/Integrations.php +312 -132 1.4.183.3.1 View file →
@@ -5,165 +5,345 @@
5 5 * @package BitForms
6 6 */
7 7
8 8 namespace BitCode\BitForm\Core\Integration;
9 +
9 10 use BitCode\BitForm\Core\Database\FormEntryModel;
10 11 use BitCode\BitForm\Core\Database\FormModel;
12 +use BitCode\BitForm\Core\Util\ApiResponse;
13 +use BitCode\BitForm\Core\Util\IpTool;
14 +use BitCode\BitForm\Core\Util\Log;
15 +use BitCode\BitForm\Core\Util\SmartTags;
16 +use BitCode\BitForm\Core\Util\Utilities;
11 17 /**
12 18 * Provides details of available integration and helps to
13 19 * execute available integrations
14 20 */
15 21
16 -use WP_Error;
17 22 use FilesystemIterator;
18 23
19 24 final class Integrations
20 25 {
21 - public $integrations = array();
26 + public $integrations = [];
27 + private static $_instance = null;
22 28
23 - /**
24 - * Undocumented function
25 - *
26 - * @return all
27 - */
28 - public function getAllIntegrations()
29 - {
30 - return $this->allIntegrations();
29 + /**
30 + * Undocumented function
31 + */
32 + public static function getInstance()
33 + {
34 + if (null === self::$_instance) {
35 + self::$_instance = new Integrations();
31 36 }
32 - /**
33 - * Undocumented function
34 - *
35 - * @return void
36 - */
37 - protected function allIntegrations()
38 - {
39 - $dirs = new FilesystemIterator(__DIR__);
40 - foreach ($dirs as $dirInfo) {
41 - if ($dirInfo->isDir()) {
42 - $integartionBaseName = basename($dirInfo);
43 - if (
44 - file_exists(__DIR__ . '/' . $integartionBaseName)
45 - && file_exists(__DIR__ . '/' . $integartionBaseName . '/' . $integartionBaseName . 'Handler.php')
46 - ) {
47 - $integrations[] = $integartionBaseName;
48 - }
49 - }
37 + return self::$_instance;
38 + }
39 +
40 + /**
41 + * Undocumented function
42 + *
43 + * @return array
44 + */
45 + public function getAllIntegrations()
46 + {
47 + return $this->allIntegrations();
48 + }
49 +
50 + /**
51 + * Undocumented function
52 + *
53 + * @return array
54 + */
55 + protected function allIntegrations()
56 + {
57 + $dirs = new FilesystemIterator(__DIR__);
58 + foreach ($dirs as $dirInfo) {
59 + if ($dirInfo->isDir()) {
60 + $integrationsBaseName = basename($dirInfo);
61 + if (
62 + file_exists(__DIR__ . '/' . $integrationsBaseName)
63 + && file_exists(__DIR__ . '/' . $integrationsBaseName . '/' . $integrationsBaseName . 'Handler.php')
64 + ) {
65 + $integrations[] = $integrationsBaseName;
50 66 }
51 - return $integrations;
67 + }
52 68 }
53 - /**
54 - * Checks a Integration Exists or not
55 - *
56 - * @param String $name Name of Integration
57 - * @return boolean
58 - */
59 - protected static function isExists($name)
60 - {
61 - if (file_exists(__DIR__ . '/' . $name) && file_exists(__DIR__ . '/' . $name . '/' . $name . 'Handler.php')) {
62 - return __NAMESPACE__ . "\\{$name}\\{$name}Handler";
63 - } else if (class_exists("BitCode\\BitFormPro\\Integration\\{$name}\\{$name}Handler")) {
64 - return "BitCode\\BitFormPro\\Integration\\{$name}\\{$name}Handler";
65 - } else {
66 - return false;
67 - }
69 + return $integrations;
70 + }
71 +
72 + /**
73 + * Checks a Integration Exists or not
74 + *
75 + * @param string $name Name of Integration
76 + * @return boolean | string
77 + */
78 + protected static function isExists($name)
79 + {
80 + $path = Utilities::getRealPath(__DIR__, $name);
81 + if (!empty($path) && $fileName = Utilities::getRealPath(__DIR__ . "/{$path}", "{$name}Handler.php")) {
82 + $className = Utilities::getFileNameExceptExtension($fileName);
83 + return __NAMESPACE__ . "\\{$path}\\{$className}";
68 84 }
69 - /**
70 - * This function helps to get single intgration information
71 - *
72 - * @return bool setIntegration()
73 - */
74 - public function getIntegration($integartionBaseName)
75 - {
76 - return $this->setIntegration($integartionBaseName);
85 +
86 + if (!defined('BITFORMPRO_PLUGIN_DIR_PATH')) {
87 + return false;
77 88 }
78 89
79 - public function registerAjax()
80 - {
81 - $dirs = new FilesystemIterator(__DIR__);
82 - foreach ($dirs as $dirInfo) {
83 - if ($dirInfo->isDir()) {
84 - $integartionBaseName = basename($dirInfo);
85 - if (
86 - file_exists(__DIR__ . '/' . $integartionBaseName)
87 - && file_exists(__DIR__ . '/' . $integartionBaseName . '/' . $integartionBaseName . 'Handler.php')
88 - ) {
89 - $integration = __NAMESPACE__ . "\\{$integartionBaseName}\\{$integartionBaseName}Handler";
90 - if (method_exists($integration, 'registerAjax')) {
91 - $integration::registerAjax();
92 - // (new $integration(0, 0))->registerAjax();
93 - }
94 - /* $handler = new $integration($integrationID, $formID);
95 - $handler->execute($integrationHandler, $integrationDetails, $fieldValues); */
96 - }
97 - }
90 + $proPath = BITFORMPRO_PLUGIN_DIR_PATH . '/includes/Integration';
91 + $proNamespace = 'BitCode\\BitFormPro\\Integration';
92 + $path = Utilities::getRealPath($proPath, $name);
93 + if (!empty($path) && $fileName = Utilities::getRealPath("{$proPath}/{$path}", "{$name}Handler.php")) {
94 + $className = Utilities::getFileNameExceptExtension($fileName);
95 + return "{$proNamespace}\\{$path}\\{$className}";
96 + }
97 +
98 + return false;
99 + }
100 +
101 + /**
102 + * This function helps to get single integration information
103 + *
104 + * @return bool setIntegration()
105 + */
106 + public function getIntegration($integrationBaseName)
107 + {
108 + return $this->setIntegration($integrationBaseName);
109 + }
110 +
111 + public function registerAjax()
112 + {
113 + $dirs = new FilesystemIterator(__DIR__);
114 + foreach ($dirs as $dirInfo) {
115 + if ($dirInfo->isDir()) {
116 + $integrationBaseName = basename($dirInfo);
117 + if (
118 + file_exists(__DIR__ . '/' . $integrationBaseName)
119 + && file_exists(__DIR__ . '/' . $integrationBaseName . '/' . $integrationBaseName . 'Handler.php')
120 + ) {
121 + $integration = __NAMESPACE__ . "\\{$integrationBaseName}\\{$integrationBaseName}Handler";
122 + if (method_exists($integration, 'registerAjax')) {
123 + $integration::registerAjax();
124 + // (new $integration(0, 0))->registerAjax();
125 + }
126 + /* $handler = new $integration($integrationID, $formID);
127 + $handler->execute($integrationHandler, $integrationDetails, $fieldValues); */
98 128 }
129 + }
99 130 }
131 + }
100 132
101 - protected static function entryDeleted($formId,$entryId){
102 - $formModel = new FormModel();
103 - $formContent = $formModel->get(
104 - [
105 - "id",
106 - "form_content",
107 - ],
108 - array(
109 - 'id' => $formId,
110 - )
133 + protected static function entryDeleted($formId, $entryId)
134 + {
135 + $formModel = new FormModel();
136 + $formContent = $formModel->get(
137 + [
138 + 'id',
139 + 'form_content',
140 + ],
141 + [
142 + 'id' => $formId,
143 + ]
144 + );
145 + if (!is_wp_error($formContent)) {
146 + $content = \json_decode($formContent[0]->form_content);
147 + if (isset($content->additional->enabled->submission)) {
148 + global $wpdb;
149 + $prefix = $wpdb->prefix;
150 + $formEntryModel = new FormEntryModel();
151 + $formEntryModel->bulkDelete(
152 + [
153 + "`{$prefix}bitforms_form_entries`.`id`" => $entryId,
154 + "`{$prefix}bitforms_form_entries`.`form_id`" => $formId,
155 + ]
111 156 );
112 - if(!is_wp_error($formContent)){
113 - $content = \json_decode($formContent[0]->form_content);
114 - if(isset($content->additional->enabled->submission)){
115 - global $wpdb;
116 - $prefix = $wpdb->prefix;
117 - $formEntryModel = new FormEntryModel();
118 - $formEntryModel->bulkDelete(
119 - array(
120 - "`{$prefix}bitforms_form_entries`.`id`" => $entryId,
121 - "`{$prefix}bitforms_form_entries`.`form_id`" => $formId,
122 - )
123 - );
124 - }
157 + }
158 + }
159 + }
160 +
161 + public static function specialTagFields($fieldMap)
162 + {
163 + $specialTagFieldValue = [];
164 +
165 + foreach ($fieldMap as $value) {
166 + $triggerValue = $value->formField;
167 + $specialTagFieldValue[$value->formField] = SmartTags::getSmartTagValue($triggerValue);
168 + }
169 + return $specialTagFieldValue;
170 + }
171 +
172 + /**
173 + * This function helps to execute Integration
174 + *
175 + * @param array $integrations List of integration to execute.
176 + * Element will be json string like {"id":1}
177 + * @param array $fieldValues Values of submitted fields
178 + * @param integer $formID ID of current form
179 + *
180 + * @return void Nothing to return
181 + */
182 + public static function executeIntegrations($integrations, $fieldValues, $formID, $logID = null, $entryID = 0)
183 + {
184 + $integrationHandler = new IntegrationHandler($formID);
185 + $logResponse = new ApiResponse();
186 + $intThatNeedNoFileHandling = ['ACF', 'MetaBox', 'Pods']; //these takes raw file and upload it
187 + $baseFieldValues = $fieldValues;
188 + $entryDetails = [
189 + 'formId' => $formID,
190 + 'entryId' => $entryID,
191 + 'fieldValues' => $fieldValues
192 + ];
193 + if (is_array($integrations)) {
194 + foreach ($integrations as $integrationIDStr) {
195 + if (!is_string($integrationIDStr)) {
196 + return;
125 197 }
126 - }
198 + $currentFieldValues = $baseFieldValues;
199 + $integrationID = intval(Utilities::jsonObj($integrationIDStr)->id ?? 0, 10);
200 + if (!empty($integrationID) && is_int($integrationID)) {
201 + $integrationResult
202 + = $integrationHandler->getAIntegration($integrationID);
203 + $integrationDetails = is_wp_error($integrationResult) ? null : $integrationResult[0];
204 + // Honor enable/disable: a disabled integration is never executed.
205 + if (!is_null($integrationDetails) && isset($integrationDetails->status) && empty($integrationDetails->status)) {
206 + continue;
207 + }
208 + $integrationName = is_null($integrationDetails) ? null : ucfirst(str_replace(' ', '', $integrationDetails->integration_type));
209 + if ('Brevo(SendinBlue)' === $integrationName) {
210 + $integrationName = 'SendinBlue';
211 + }
212 + if (!is_null($integrationName) && static::isExists($integrationName)) {
213 + if (!in_array($integrationName, $intThatNeedNoFileHandling)) {
214 + $currentFieldValues = IntegrationHandler::handleFileUrl($currentFieldValues, $formID, $entryID);
215 + }
216 + $integration = static::isExists($integrationName);
217 + $handler = new $integration($integrationID, $formID);
218 + $integDetails = is_string($integrationDetails->integration_details) ? json_decode($integrationDetails->integration_details) : $integrationDetails->integration_details;
219 + if (isset($integDetails->field_map)) {
220 + $sptagData = self::specialTagFields($integDetails->field_map);
221 + $currentFieldValues = $currentFieldValues + $sptagData;
222 + }
223 + // fresh time budget per handler: a chain of slow integrations (30s HTTP
224 + // timeout each) must not be killed by max_execution_time mid-loop
225 + if (\function_exists('set_time_limit') && false === strpos((string) ini_get('disable_functions'), 'set_time_limit')) {
226 + set_time_limit(60);
227 + }
228 + try {
229 + $handler->execute($integrationHandler, $integrationDetails, $currentFieldValues, $entryID, $logID);
230 + } catch (\Throwable $executionError) {
231 + // one failing integration must not abort the remaining ones
232 + Log::debug_log('[+] Integration execution threw: ' . $executionError->getMessage());
233 + $logResponse->apiResponse(
234 + $logID,
235 + $integrationID,
236 + ['type' => 'record', 'type_name' => $integrationName ?: 'Integration'],
237 + 'errors',
238 + $executionError->getMessage(),
239 + $entryDetails
240 + );
241 + }
242 + } else {
243 + do_action('bitform_integration_run_failure', $integrationID, $formID);
127 244
128 - /**
129 - * This function helps to execute Integration
130 - *
131 - * @param Array $integrations List of integrstion to execute.
132 - * Element will be json string like {"id":1}
133 - * @param Array $fieldValues Values of submitted fields
134 - * @param Integer $formID ID of current form
135 - *
136 - * @return void Nothing to return
137 - */
138 - public static function executeIntegrations($integrations, $fieldValues, $formID, $logID=null, $entryID = 0)
139 - {
140 - $integrationHandler = new IntegrationHandler($formID);
141 - if (is_array($integrations)) {
142 - foreach ($integrations as $integrationIDStr) {
143 - $integrationID = intval(json_decode($integrationIDStr)->id, 10);
144 - if (!empty($integrationID) && is_int($integrationID)) {
145 - $integrationResult
146 - = $integrationHandler->getAIntegration($integrationID);
147 - $integrationDetails = is_wp_error($integrationResult) ? null : $integrationResult[0];
148 - $integrationName = is_null($integrationDetails) ? null : ucfirst(str_replace(' ', null, $integrationDetails->integration_type));
149 - if (!is_null($integrationName) && static::isExists($integrationName)) {
150 - $integration = static::isExists($integrationName);
151 - $handler = new $integration($integrationID, $formID);
152 - $handler->execute($integrationHandler, $integrationDetails, $fieldValues, $entryID, $logID);
153 - }
154 - }
155 - }
245 + $errorMsg = apply_filters('bitform_filter_integration_run_failure_message', __('Integration execution failed', 'bit-form'), $integrationID, $formID);
246 +
247 + Log::debug_log('[+] Integration execution failed: ' . $errorMsg);
248 +
249 + $logResponse->apiResponse(
250 + $logID,
251 + $integrationID,
252 + ['type' => 'record', 'type_name' => $integrationName || 'Integration'],
253 + 'errors',
254 + $errorMsg,
255 + $entryDetails
256 + );
257 + }
156 258 }
259 + }
157 260 }
261 + }
158 262
159 - public static function integrationExecutionHelper($integrations, $fieldValue, $formID, $entryID, $logID)
160 - {
161 - if (empty($integrations) || empty($formID)) {
162 - return;
163 - }
164 - foreach ($integrations as $key => $value) {
165 - self::executeIntegrations($value, $fieldValue, $formID, $logID, $entryID);
166 - }
167 - self::entryDeleted($formID,$entryID);
263 + public static function integrationExecutionHelper($integrations, $fieldValue, $formID, $entryID, $logID)
264 + {
265 + if (empty($integrations) || empty($formID)) {
266 + return;
168 267 }
268 + $trnasientData = get_transient("bitform_trigger_transient_{$entryID}");
269 + $trnasientData = is_string($trnasientData) ? json_decode($trnasientData) : $trnasientData;
270 + if (!empty($trnasientData['fields'])) {
271 + $fieldValue = array_merge($fieldValue, $trnasientData['fields']);
272 + }
273 + foreach ($integrations as $key => $value) {
274 + self::executeIntegrations($value, $fieldValue, $formID, $logID, $entryID);
275 + }
276 + self::entryDeleted($formID, $entryID);
277 + }
278 +
279 + /**
280 + * This function helps to save connected integration app
281 + *
282 + * @return wp_error | mixed
283 + */
284 + public function saveConnectedIntegrationApp($appConfig)
285 + {
286 + // error_log('[+] saveConnectedIntegrationApp: ' . print_r($appConfig, true));
287 + $connectionName = $appConfig->name;
288 + $connectionType = $appConfig->type;
289 + // $connectionDetails = wp_json_encode($appConfig);
290 +
291 + if (empty($appConfig->details)) {
292 + unset($appConfig->name, $appConfig->id);
293 +
294 + $connectionDetails = !is_string($appConfig) ?
295 + wp_json_encode($appConfig) : $appConfig;
296 + } else {
297 + $connectionDetails = !is_string($appConfig->details) ?
298 + wp_json_encode($appConfig->details) : $appConfig->details;
299 + }
300 + $connectionCategory = 'connected_integration_apps';
301 +
302 + // saveIntegration reads user_details['id'|'ip'|'time']; without them the insert
303 + // raises null-offset warnings and stores null user_id/created_at
304 + $integrationHandler = new IntegrationHandler(0, IpTool::getUserDetail());
305 +
306 + return $integrationHandler->saveIntegration($connectionName, $connectionType, $connectionDetails, $connectionCategory);
307 + }
308 +
309 + // get connectd integration app
310 + public function getConnectedIntegrationApp($integration_type = null)
311 + {
312 + $connectionCategory = 'connected_integration_apps';
313 +
314 + $integrationHandler = new IntegrationHandler(0);
315 + $allConnectedIntegApps = $integrationHandler->getAllIntegration($connectionCategory, $integration_type);
316 +
317 + if (!is_wp_error($allConnectedIntegApps)) {
318 + foreach ($allConnectedIntegApps as $integrationkey => $integrationValue) {
319 + $integrationData = [
320 + 'id' => $integrationValue->id,
321 + 'name' => $integrationValue->integration_name,
322 + 'type' => $integrationValue->integration_type,
323 + ];
324 + $allConnectedIntegApps[$integrationkey]->integration_details = wp_json_encode(array_merge(
325 + $integrationData,
326 + is_string($integrationValue->integration_details) ?
327 + (array) json_decode($integrationValue->integration_details) :
328 + $integrationValue->integration_details
329 + ));
330 + }
331 + }
332 + return $allConnectedIntegApps;
333 + }
334 +
335 + public function deleteConnectedApp($appId)
336 + {
337 + $integrationHandler = new IntegrationHandler(0);
338 +
339 + return $integrationHandler->deleteIntegration($appId);
340 + }
341 +
342 + public function renameConnectedApp($appId, $name)
343 + {
344 + // User details carry the time renameConnectedApp() stamps into updated_at.
345 + $integrationHandler = new IntegrationHandler(0, IpTool::getUserDetail());
346 +
347 + return $integrationHandler->renameConnectedApp($appId, $name);
348 + }
169 349 }