function gelf_watchdog in GELF 7

Same name and namespace in other branches

1. 6 gelf.module \gelf_watchdog()

Implement hook_watchdog().

File

./gelf.module, line 26

gelf.module

Code

function gelf_watchdog($entry) {
  if (!gelf_require()) {
    if (function_exists('user_access') && user_access('administer gelf')) {
      drupal_set_message(t('GELF module requires the GELF PHP library to be installed.  View the README for installation instructions.'), 'error');
    }
    return;
  }
  $host = variable_get('gelf_host', 'localhost');
  $port = variable_get('gelf_port', 12201);
  $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("Request_method", $_SERVER['REQUEST_METHOD']);
  $gelf
    ->setAdditional("Server_host", $_SERVER['HTTP_HOST']);
  $gelf
    ->setAdditional("Client_host", $entry['ip']);
  try {
    $publisher = new GELFMessagePublisher($host, $port);
    $publisher
      ->publish($gelf);
  } catch (UnexpectedValueException $e) {
    if (function_exists('user_access') && user_access('administer gelf')) {
      drupal_set_message(t('Failed to publish gelf message: %message', array(
        '%message' => $e
          ->getMessage(),
      )), 'error');
    }
  }
}