notificationx / includes / Core / Rest / Posts.php

Posts.php in NotificationX – FOMO, Live Sales Notification, WooCommerce Sales Popup, GDPR, Social Proof, Announcement Banner & Floating Notification Bar 3.2.10, at includes/Core/Rest/Posts.php

341 lines 11.9 KB

Raw Download Zip

1	<?php
2
3	namespace NotificationX\Core\Rest;
4
5	use FluentForm\Framework\Database\Query\Expression;
6	use NotificationX\Core\Database;
7	use NotificationX\Core\PostType;
8	use NotificationX\Core\REST;
9	use NotificationX\Extensions\ExtensionFactory;
10	use NotificationX\Extensions\GlobalFields;
11	use NotificationX\GetInstance;
12	use NotificationX\NotificationX;
13	use WP_REST_Controller;
14	use WP_REST_Response;
15	use WP_REST_Server;
16	use WP_Error;
17
18	/**
19	* @method static Posts get_instance($args = null)
20	*/
21	class Posts extends WP_REST_Controller {
22	/**
23	* Instance of NotificationX
24	*
25	* @var NotificationX
26	*/
27	use GetInstance;
28
29	/**
30	* Post type.
31	*
32	* @since 4.7.0
33	* @var string
34	*/
35	protected $post_type;
36
37	/**
38	* Constructor.
39	*
40	* @since 4.7.0
41	*
42	* @param string $post_type Post type.
43	*/
44	public function __construct() {
45	$this->namespace = 'notificationx/v1';
46	$this->rest_base = 'nx';
47	add_action('rest_api_init', [$this, 'register_routes']);
48	}
49
50	/**
51	* Registers the routes for the objects of the controller.
52	*
53	* @since 4.7.0
54	*
55	* @see register_rest_route()
56	*/
57	public function register_routes() {
58	register_rest_route(
59	$this->namespace,
60	'/' . $this->rest_base,
61	array(
62	array(
63	'methods' => WP_REST_Server::READABLE,
64	'callback' => array($this, 'get_items'),
65	'permission_callback' => array($this, 'get_items_permissions_check'),
66	// 'args' => $this->get_collection_params(),
67	),
68	array(
69	'methods' => WP_REST_Server::CREATABLE,
70	'callback' => array($this, 'create_item'),
71	'permission_callback' => array($this, 'create_item_permissions_check'),
72	// 'args' => $this->get_endpoint_args_for_item_schema(WP_REST_Server::CREATABLE),
73	),
74	// 'schema' => array($this, 'get_public_item_schema'),
75	)
76	);
77
78	// $schema = $this->get_item_schema();
79	$get_item_args = array(
80	'context' => $this->get_context_param(array('default' => 'view')),
81	);
82
83	register_rest_route(
84	$this->namespace,
85	'/' . $this->rest_base . '/(?P<id>[\d]+)',
86	array(
87	'args' => array(
88	'id' => array(
89	'description' => __('Unique identifier for the object.', 'notificationx'),
90	'type' => 'integer',
91	),
92	),
93	array(
94	'methods' => WP_REST_Server::READABLE,
95	'callback' => array($this, 'get_item'),
96	'permission_callback' => array($this, 'get_item_permissions_check'),
97	// 'args' => $get_item_args,
98	),
99	array(
100	'methods' => WP_REST_Server::EDITABLE,
101	'callback' => array($this, 'update_item'),
102	'permission_callback' => array($this, 'update_item_permissions_check'),
103	// 'args' => $this->get_endpoint_args_for_item_schema(WP_REST_Server::EDITABLE),
104	),
105	array(
106	'methods' => WP_REST_Server::DELETABLE,
107	'callback' => array($this, 'delete_item'),
108	'permission_callback' => array($this, 'delete_item_permissions_check'),
109	'args' => array(
110	'force' => array(
111	'type' => 'boolean',
112	'default' => false,
113	'description' => __('Whether to bypass Trash and force deletion.', 'notificationx'),
114	),
115	),
116	),
117	// 'schema' => array($this, 'get_public_item_schema'),
118	)
119	);
120	}
121
122	/**
123	* Checks if a given request has access to read posts.
124	*
125	* @since 4.7.0
126	*
127	* @param WP_REST_Request $request Full details about the request.
128	* @return true\|WP_Error True if the request has read access, WP_Error object otherwise.
129	*/
130	public function get_items_permissions_check($request) {
131	return current_user_can('read_notificationx');
132	}
133
134	/**
135	* Checks if a given request has access to read post.
136	*
137	* @since 4.7.0
138	*
139	* @param WP_REST_Request $request Full details about the request.
140	* @return true\|WP_Error True if the request has read access, WP_Error object otherwise.
141	*/
142	public function get_item_permissions_check($request) {
143	$params = $request->get_params();
144	if( !empty( $params['source'] ) ) {
145	return current_user_can('read_notificationx');
146	}
147	return current_user_can('read_notificationx');
148	}
149
150
151	public function get_items($request) {
152	$params = $request->get_params();
153	$status = !empty($params['status']) ? $params['status'] : "all";
154	$page = !empty($params['page']) ? intval( $params['page'] ) : 1;
155	$per_page = !empty($params['per_page']) ? intval( $params['per_page'] ) : 20;
156	$search_keyword = !empty($params['s']) ? $params['s'] : '';
157	$start_from = ($page - 1) * $per_page;
158	$query = Database::get_instance()->query()
159	->from('nx_posts a')
160	->join('nx_stats b', 'b.nx_id', '=', 'a.nx_id')
161	->group_by('a.nx_id')
162	->order_by('a.updated_at', 'DESC')
163	->select('a.*, SUM(b.clicks) clicks, SUM(b.views) views');
164	if ($status !== 'all') {
165	$query->where('enabled', $status == 'enabled' ? true : false);
166	}
167	if( $search_keyword ) {
168	$query->where(function($query) use ($search_keyword) {
169	$query->where('title', 'LIKE', '%' . $search_keyword . '%')
170	->orWhere( 'a.nx_id', 'LIKE', '%'. $search_keyword . '%' );
171	});
172	}
173
174	$query->offset($start_from)
175	->limit($per_page);
176	$posts = $query->get();
177	$posts = PostType::get_instance()->__get_posts( $posts, '*' );
178
179	// Add entries count for popup notifications
180	global $wpdb;
181	$entries_table = $wpdb->prefix . 'nx_entries';
182	$entries_counts = $wpdb->get_results(
183	"SELECT nx_id, COUNT(*) as entries_count
184	FROM {$entries_table}
185	WHERE source IN ('popup_notification', 'exit_intent_custom')
186	GROUP BY nx_id",
187	ARRAY_A
188	);
189
190	// Create a lookup array for entries counts
191	$entries_lookup = [];
192	foreach ($entries_counts as $entry) {
193	$entries_lookup[$entry['nx_id']] = $entry['entries_count'];
194	}
195
196	// Add entries count to posts
197	foreach ($posts as $key => $post) {
198	if ($post['source'] === 'popup_notification') {
199	$posts[$key]['entries'] = isset($entries_lookup[$post['nx_id']]) ? $entries_lookup[$post['nx_id']] : 0;
200	}
201	}
202
203	$total_posts = Database::get_instance()->get_post(Database::$table_posts, [], 'count(*) AS total');
204	$enabled = Database::get_instance()->get_post(Database::$table_posts, ['enabled' => true], 'count(*) AS total');
205	$disabled = Database::get_instance()->get_post(Database::$table_posts, ['enabled' => false], 'count(*) AS total');
206
207	return [
208	'total' => $total_posts['total'],
209	'enabled' => $enabled['total'],
210	'disabled' => $disabled['total'],
211	'search_keyword' => $search_keyword,
212	'posts' => $posts,
213	];
214
215	}
216
217	/**
218	* Retrieves a single post.
219	*
220	* @since 4.7.0
221	*
222	* @param WP_REST_Request $request Full details about the request.
223	* @return WP_REST_Response\|WP_Error Response object on success, or WP_Error object on failure.
224	*/
225	public function get_item($request) {
226	PostType::get_instance()->set_context( 'edit' );
227	return PostType::get_instance()->get_post( absint( $request['id'] ) );
228	}
229
230	/**
231	* Checks if a given request has access to create a post.
232	*
233	* @since 4.7.0
234	*
235	* @param WP_REST_Request $request Full details about the request.
236	* @return true\|WP_Error True if the request has access to create items, WP_Error object otherwise.
237	*/
238	public function create_item_permissions_check($request) {
239	if (!empty($request['id'])) {
240	return new WP_Error(
241	'rest_post_exists',
242	__('Cannot create existing post.', 'notificationx'),
243	array('status' => 400)
244	);
245	}
246
247	return current_user_can('edit_notificationx');
248	}
249
250	/**
251	* Creates a single post.
252	*
253	* @since 4.7.0
254	*
255	* @param WP_REST_Request $request Full details about the request.
256	* @return WP_REST_Response\|WP_Error Response object on success, or WP_Error object on failure.
257	*/
258	public function create_item($request) {
259	if (!empty($request['nx_id'])) {
260	return new WP_Error(
261	'rest_post_exists',
262	__('Cannot create existing post.', 'notificationx'),
263	array('status' => 400)
264	);
265	}
266
267	// $prepared_post = $this->prepare_item_for_database($request);
268
269	// if (is_wp_error($prepared_post)) {
270	// return $prepared_post;
271	// }
272
273	$params = $request->get_params();
274	return PostType::get_instance()->save_post($params);
275	}
276
277	/**
278	* Checks if a given request has access to update a post.
279	*
280	* @since 4.7.0
281	*
282	* @param WP_REST_Request $request Full details about the request.
283	* @return true\|WP_Error True if the request has access to update the item, WP_Error object otherwise.
284	*/
285	public function update_item_permissions_check($request) {
286	$params = $request->get_params();
287	if( !empty( $params['source'] ) ) {
288	return current_user_can('edit_notificationx');
289	}
290	return current_user_can('edit_notificationx');
291	}
292
293	/**
294	* Updates a single post.
295	*
296	* @since 4.7.0
297	*
298	* @param WP_REST_Request $request Full details about the request.
299	* @return WP_REST_Response\|WP_Error Response object on success, or WP_Error object on failure.
300	*/
301	public function update_item($request) {
302	$params = $request->get_params();
303	return PostType::get_instance()->save_post($params);
304	}
305
306	/**
307	* Checks if a given request has access to delete a post.
308	*
309	* @since 4.7.0
310	*
311	* @param WP_REST_Request $request Full details about the request.
312	* @return true\|WP_Error True if the request has access to delete the item, WP_Error object otherwise.
313	*/
314	public function delete_item_permissions_check($request) {
315	// if ($post && !$this->check_delete_permission($post)) {
316	// return new WP_Error(
317	// 'rest_cannot_delete',
318	// __('Sorry, you are not allowed to delete this post.'),
319	// array('status' => rest_authorization_required_code())
320	// );
321	// }
322	return current_user_can('edit_notificationx');
323	}
324
325	/**
326	* Deletes a single post.
327	*
328	* @since 4.7.0
329	*
330	* @param WP_REST_Request $request Full details about the request.
331	* @return WP_REST_Response\|WP_Error Response object on success, or WP_Error object on failure.
332	*/
333	public function delete_item($request) {
334	if(PostType::get_instance()->delete_post($request['id'])){
335	wp_send_json_success();
336	}
337	wp_send_json_error();
338	}
339
340	}
341