get-contacts-who-opened-email.php — OttoKit: All-in-One Automation Platform 1.1.36

suretriggers / src / Integrations / fluentcrm / actions / get-contacts-who-opened-email.php

suretriggers / src / Integrations / fluentcrm / actions Last commit date

get-contacts-who-opened-email.php

137 lines

1	<?php
2	/**
3	* GetContactsWhoOpenedEmail.
4	* php version 5.6
5	*
6	* @category GetContactsWhoOpenedEmail
7	* @package SureTriggers
8	* @author BSF <username@example.com>
9	* @license https://www.gnu.org/licenses/gpl-3.0.html GPLv3
10	* @link https://www.brainstormforce.com/
11	* @since 1.0.0
12	*/
13
14	namespace SureTriggers\Integrations\FluentCRM\Actions;
15
16	use Exception;
17	use SureTriggers\Integrations\AutomateAction;
18	use SureTriggers\Traits\SingletonLoader;
19
20	/**
21	* GetContactsWhoOpenedEmail
22	*
23	* @category GetContactsWhoOpenedEmail
24	* @package SureTriggers
25	* @author BSF <username@example.com>
26	* @license https://www.gnu.org/licenses/gpl-3.0.html GPLv3
27	* @link https://www.brainstormforce.com/
28	* @since 1.0.0
29	*/
30	class GetContactsWhoOpenedEmail extends AutomateAction {
31
32	/**
33	* Integration type.
34	*
35	* @var string
36	*/
37	public $integration = 'FluentCRM';
38
39	/**
40	* Action name.
41	*
42	* @var string
43	*/
44	public $action = 'fluentcrm_get_contacts_who_opened_email';
45
46	use SingletonLoader;
47
48	/**
49	* Register a action.
50	*
51	* @param array $actions actions.
52	* @return array
53	*/
54	public function register( $actions ) {
55	$actions[ $this->integration ][ $this->action ] = [
56	'label' => __( 'Get Contacts Who Opened Email', 'suretriggers' ),
57	'action' => $this->action,
58	'function' => [ $this, 'action_listener' ],
59	];
60	return $actions;
61	}
62
63	/**
64	* Action listener.
65	*
66	* @param int $user_id user_id.
67	* @param int $automation_id automation_id.
68	* @param array $fields fields.
69	* @param array $selected_options selectedOptions.
70	* @return array
71	* @throws Exception Exception.
72	*/
73	public function _action_listener( $user_id, $automation_id, $fields, $selected_options ) {
74
75	$campaign_id = isset( $selected_options['campaign_id'] ) ? absint( $selected_options['campaign_id'] ) : 0;
76	$username = isset( $selected_options['api_username'] ) ? sanitize_text_field( $selected_options['api_username'] ) : '';
77	$password = isset( $selected_options['api_password'] ) ? sanitize_text_field( $selected_options['api_password'] ) : '';
78	$wp_url = isset( $selected_options['wordpress_url'] ) ? esc_url_raw( $selected_options['wordpress_url'] ) : '';
79
80	if ( ! $campaign_id ) {
81	return [
82	'status' => 'error',
83	'message' => __( 'Campaign ID is required.', 'suretriggers' ),
84	];
85	}
86
87	if ( empty( $wp_url ) \|\| empty( $username ) \|\| empty( $password ) ) {
88	return [
89	'status' => 'error',
90	'message' => __( 'WordPress URL, Username, and Password are required.', 'suretriggers' ),
91	];
92	}
93
94	$args = [
95	'headers' => [
96	'Authorization' => 'Basic ' . base64_encode( $username . ':' . $password ),
97	'Content-Type' => 'application/json',
98	],
99	'sslverify' => false,
100	];
101	$request = wp_remote_get( $selected_options['wordpress_url'] . '/wp-json/fluent-crm/v2/campaigns/' . $campaign_id . '/emails?filter_type=view', $args );
102	$response_code = wp_remote_retrieve_response_code( $request );
103	$response_body = wp_remote_retrieve_body( $request );
104	$response_context = json_decode( $response_body, true );
105
106	if ( 200 !== $response_code ) {
107	return [
108	'status' => 'error',
109	'message' => __( 'Failed to fetch opened contacts.', 'suretriggers' ),
110	];
111	}
112
113	$opened_contacts = [];
114	if ( is_array( $response_context ) && isset( $response_context['emails']['data'] ) && is_array( $response_context['emails']['data'] ) ) {
115	foreach ( $response_context['emails']['data'] as $email ) {
116	if ( isset( $email['subscriber'] ) ) {
117	$opened_contacts[] = [
118	'id' => $email['subscriber']['id'],
119	'email' => $email['subscriber']['email'],
120	'first_name' => $email['subscriber']['first_name'],
121	'last_name' => $email['subscriber']['last_name'],
122	'opened_at' => $email['updated_at'],
123	];
124	}
125	}
126	}
127
128	return [
129	'status' => 'success',
130	'contacts' => $opened_contacts,
131	'count' => count( $opened_contacts ),
132	];
133	}
134	}
135
136	GetContactsWhoOpenedEmail::get_instance();
137