* public function pluginMessageIndexListener(&$args) { * // Create shortcut for stored data * $data = $args['message']['data']; * // Check if message was sent by current plugin * if ($args['message']['plugin'] == 'example') { * $args['result'] = array( * // Plugin should set one of the core message kinds to indexed message * 'kind' => Thread::KIND_INFO, * // Plugin should set arbitrary text for indexed message * 'message' => $data['title'] . ': ' . $data['body'] * ); * } * } * */ function cron_index_messages() { $db = Database::getInstance(); $db->throwExeptions(true); try { // Start transaction $db->query('START TRANSACTION'); // Select messages from closed threads $messages = $db->query( "SELECT {chatmessage}.* FROM {chatmessage}, {chatthread} " . "WHERE {chatmessage}.threadid = {chatthread}.threadid AND " . "({chatthread}.istate = :closed OR {chatthread}.istate = :left)", array( ':closed' => Thread::STATE_CLOSED, ':left' => Thread::STATE_LEFT ), array('return_rows' => Database::RETURN_ALL_ROWS) ); // Prevent race condition. Remove only moved to {indexedchatmessage} // messages. Get last loaded message ID for that. $last_id = 0; $dispatcher = EventDispatcher::getInstance(); foreach($messages as $key => $message) { // Find last message ID if ($message['messageid'] > $last_id) { $last_id = $message['messageid']; } // Leave core messages kind as is if ($message['ikind'] != Thread::KIND_PLUGIN) { continue; } // Provide an ability for plugins to index own messages $event_args = array( 'message' => unserialize($message['tmessage']), 'result' => false ); $dispatcher->triggerEvent('pluginMessageIndex', $event_args); // Check if message was processed by a plugin correctly $update_message = true; if (empty($event_args['result']['message'])) { $update_message = false; } // Check if kind set and correct if (empty($event_args['result']['kind']) || $event_args['result']['kind'] == Thread::KIND_PLUGIN) { $update_message = false; } // Check if message should be updated if (! $update_message) { unset($messages[$key]); continue; } // Update message $messages[$key]['ikind'] = $event_args['result']['kind']; $messages[$key]['tmessage'] = $event_args['result']['message']; if (array_key_exists('sender_name', $event_args['result'])) { $messages[$key]['tname'] = $event_args['result']['sender_name']; } if (array_key_exists('operator_id', $event_args['result'])) { $messages[$key]['agentId'] = $event_args['result']['operator_id']; } } // Check is there some messages that should be saved if (count($messages) != 0) { // Reindex messages array $messages = array_values($messages); // Prepare SQL query template $message_fields = array_keys($messages[0]); $placeholders = '(' . implode(', ', array_fill(0, count($message_fields), '?')) . ')'; $sql_template = 'INSERT INTO {indexedchatmessage} (' . implode(', ', $message_fields) . ') VALUES '; // Insert indexed messages into database by $block_size messages per // sql query $block_size = 20; $iteration_count = ceil(count($messages) / $block_size); for($i = 0; $i < $iteration_count; $i++) { // Get messages block $messages_block = array_slice( $messages, $i * $block_size, $block_size ); // Count of $messages_block can be less than $block_size for // the last block of messages. $real_block_size = count($messages_block); // Build array of inserted values $fields_to_insert = array(); foreach($messages_block as $message) { foreach($message_fields as $field_name) { $fields_to_insert[] = $message[$field_name]; } } // Build query $sql = $sql_template . implode( ', ', array_fill(0, $real_block_size, $placeholders) ); // Run query $db->query($sql, $fields_to_insert); } } // Check is there some processed messages that should be deleted if ($last_id != 0) { // Delete indexed messages $db->query( 'DELETE FROM {chatmessage} where messageid <= :last_id', array(':last_id' => $last_id) ); } } catch (Exception $e) { // Something went wrong: warn and rollback transaction. trigger_error( 'Messages indexing faild: ' . $e->getMessage(), E_USER_WARNING ); $db->query('ROLLBACK'); return; } // Commit transaction $db->query('COMMIT'); } /** * Generates cron URI * * @global string $webimroot Path of the mibew instalation from server root. * It defined in libs/config.php * @param string $cron_key Cron security key * @return string Cron URI */ function cron_get_uri($cron_key) { global $webimroot; $path = (empty($_SERVER['HTTPS']) || $_SERVER['HTTPS'] == 'off') ? 'http://' : 'https://'; $path .= $_SERVER['SERVER_NAME'] . $webimroot . '/cron.php'; $path .= empty($cron_key) ? '' : '?cron_key='.$cron_key; return $path; } ?>