← All changes | admin/helpers/src/chat/storage/database.php +45 -2 1.8.7 → 1.8.16 View file →

		@@ -2,9 +2,9 @@
2	2	/**
3	3	* @package VikBooking
4	4	* @subpackage core
5	5	* @author E4J s.r.l.
6		- * @copyright Copyright (C) 2021 E4J s.r.l. All Rights Reserved.
	6	+ * @copyright Copyright (C) 2026 E4J s.r.l. All Rights Reserved.
7	7	* @license http://www.gnu.org/licenses/gpl-2.0.html GNU/GPL
8	8	* @link https://vikwp.com
9	9	*/
10	10
		@@ -80,11 +80,27 @@
80	80
81	81	if ($search->hasContext()) {
82	82	// filter by context
83	83	$query->where($this->db->qn('m.context') . ' = ' . $this->db->q($search->getContext()->getAlias()));
84		- $query->where($this->db->qn('m.id_context') . ' = ' . (int) $search->getContext()->getID());
	84	+
	85	+ // filter by context ID only if provided
	86	+ if ($search->getContext()->getID() > 0) {
	87	+ $query->where($this->db->qn('m.id_context') . ' = ' . (int) $search->getContext()->getID());
	88	+ }
85	89	}
86	90
	91	+ if ($search->hasCategories()) {
	92	+ // filter by supported contexts
	93	+ $query->where($this->db->qn('m.context') . ' IN (' . implode(',', array_map([$this->db, 'q'], $search->getCategories())) . ')');
	94	+ }
	95	+
	96	+ if ($search->hasRefId()) {
	97	+ $refId = $search->getRefId();
	98	+
	99	+ // filter by reference ID
	100	+ $query->where($this->db->qn('m.ref_id') . ' = ' . $this->db->q($refId));
	101	+ }
	102	+
87	103	if ($search->hasAggregate()) {
88	104	$inner = $this->db->getQuery(true);
89	105
90	106	// create inner query to fetch the latest message for each "thread"
		@@ -178,8 +194,13 @@
178	194	// do not notify myself
179	195	continue;
180	196	}
181	197
	198	+ if ($recipient->getID() == -2) {
	199	+ // skip also in case the recipient is the AI
	200	+ continue;
	201	+ }
	202	+
182	203	// register unread notification
183	204	$unreadMessage = new stdClass;
184	205	$unreadMessage->id_message = $message->getID();
185	206	$unreadMessage->id_sender = (int) $recipient->getID();
		@@ -185,8 +206,30 @@
185	206	$unreadMessage->id_sender = (int) $recipient->getID();
186	207	$this->db->insertObject('#__vikbooking_chat_messages_unread', $unreadMessage, 'id');
187	208	}
188	209	}
	210	+ }
	211	+
	212	+ /**
	213	+ * @inheritDoc
	214	+ */
	215	+ public function deleteMessage(VBOChatMessage $message)
	216	+ {
	217	+ // delete message record from the database
	218	+ $query = $this->db->getQuery(true)
	219	+ ->delete($this->db->qn('#__vikbooking_chat_messages'))
	220	+ ->where($this->db->qn('id') . ' = ' . (int) $message->getID());
	221	+
	222	+ $this->db->setQuery($query);
	223	+ $this->db->execute();
	224	+
	225	+ // delete notification record from the database
	226	+ $query = $this->db->getQuery(true)
	227	+ ->delete($this->db->qn('#__vikbooking_chat_messages_unread'))
	228	+ ->where($this->db->qn('id_message') . ' = ' . (int) $message->getID());
	229	+
	230	+ $this->db->setQuery($query);
	231	+ $this->db->execute();
189	232	}
190	233
191	234	/**
192	235	* @inheritDoc