function gelf_watchdog in GELF 6

Same name and namespace in other branches

1. 7 gelf.module \gelf_watchdog()

Implement hook_watchdog().

File

./gelf.module, line 38

gelf.module

Code

function gelf_watchdog($entry) {
  static $gelf_publisher;
  if (module_exists('libraries') && ($gelflib_path = libraries_get_path('gelf-php'))) {
    if (file_exists($gelflib_path . '/GELFMessage.php') && file_exists($gelflib_path . '/GELFMessagePublisher.php')) {
      require_once $gelflib_path . '/GELFMessage.php';
      require_once $gelflib_path . '/GELFMessagePublisher.php';

      // Set up the gelf message publisher
      if (!isset($gelf_publisher)) {
        $host = variable_get('gelf_host', 'localhost');
        $port = variable_get('gelf_port', 12201);
        try {
          $gelf_publisher = new GELFMessagePublisher($host, $port);
        } catch (InvalidArgumentException $e) {
          if (user_access('administer gelf')) {
            drupal_set_message(t('Unable to instantiate GELF message publisher: @msg', array(
              '@msg' => $e
                ->getMessage(),
            )), 'error');
          }
          return;
        }
      }
      $gelf = new GELFMessage();
      $message = filter_xss(is_null($entry['variables']) ? $entry['message'] : strtr($entry['message'], $entry['variables']));
      $short_msg_length = 100;
      if (strlen($message) > $short_msg_length) {
        $short_message = preg_replace('/\\s+?(\\S+)?$/u', '', substr($message, 0, $short_msg_length));
      }
      else {
        $short_message = $message;
      }
      $username = isset($entry['user']->name) ? $entry['user']->name : variable_get('anonymous', t('Anonymous'));
      $gelf
        ->setShortMessage($short_message);
      $gelf
        ->setFullMessage($message);
      $gelf
        ->setHost(php_uname('n'));
      $gelf
        ->setFacility($entry['type']);
      $gelf
        ->setLevel($entry['severity']);
      $gelf
        ->setTimestamp($entry['timestamp']);
      $gelf
        ->setAdditional("Referer", $entry['referer']);
      $gelf
        ->setAdditional("Link", $entry['link']);
      $gelf
        ->setAdditional("Username", $username);
      $gelf
        ->setAdditional("Uid", $entry['user']->uid);
      $gelf
        ->setAdditional("Request_uri", $entry['request_uri']);
      $gelf
        ->setAdditional("Server_host", $_SERVER['HTTP_HOST']);
      $gelf
        ->setAdditional("Client_host", $entry['ip']);
      try {
        $gelf_publisher
          ->publish($gelf);
      } catch (UnexpectedValueException $e) {
        if (user_access('administer gelf')) {
          drupal_set_message(t('Failed to publish gelf message: %message', array(
            '%message' => $e
              ->getMessage(),
          )), 'error');
        }
      }
    }
  }
  else {
    if (user_access('administer gelf')) {
      drupal_set_message(t('GELF module requires libraries to be installed!'), 'error');
    }
  }
}