function elasticsearch_connector_statistics_delete_node_logs in Elasticsearch Connector 7.5

Same name and namespace in other branches

1. 7 modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module \elasticsearch_connector_statistics_delete_node_logs()
2. 7.2 modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module \elasticsearch_connector_statistics_delete_node_logs()

Delete the node logs based on NID.

Parameters

int $nid:

1 call to elasticsearch_connector_statistics_delete_node_logs()

elasticsearch_connector_statistics_node_delete in modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module

Implements hook_node_delete().

File

modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module, line 194

Logs and displays access statistics for a site.

Code

function elasticsearch_connector_statistics_delete_node_logs($nid) {

  // TODO: Instead of deleting, update the logs and mark them deleted.
  $client_id = elasticsearch_connector_statistics_get_cluster_vars();
  if (!empty($client_id)) {
    $client = elasticsearch_connector_get_client_by_id($client_id);
    if ($client) {
      $index_name = elasticsearch_connector_statistics_get_cluster_vars('index');
      $params['index'] = $index_name;
      $params['type'] = variable_get('elasticsearch_connector_statistics_type', ELASTICSEARCH_CONNECTOR_STATS_DEFAULT_TYPE);
      $params['body']['query'] = array(
        'bool' => array(
          'must' => array(
            'match_all' => array(),
          ),
          'filter' => array(
            array(
              'term' => array(
                'entity.entity_nid' => $nid,
              ),
            ),
            array(
              'term' => array(
                'entity.entity_type' => 'node',
              ),
            ),
          ),
        ),
      );
      try {
        $response = $client
          ->deleteByQuery($params);
      } catch (Exception $e) {
        watchdog('elasticsearch_connector_statistics', $e
          ->getMessage(), array(), WATCHDOG_ERROR);
      }
    }
  }
}