Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Curl	[ DIR ]	drwxr-xr-x	2018-11-05 09:00
FingersCrossed	[ DIR ]	drwxr-xr-x	2018-11-05 09:00
Slack	[ DIR ]	drwxr-xr-x	2018-11-05 09:00
SyslogUdp	[ DIR ]	drwxr-xr-x	2018-11-05 09:00
AbstractHandler.php	4.28 KB	-rw-r--r--	2018-11-05 09:00
AbstractProcessingHandler.php	1.5 KB	-rw-r--r--	2018-11-05 09:00
AbstractSyslogHandler.php	3.29 KB	-rw-r--r--	2018-11-05 09:00
AmqpHandler.php	3.78 KB	-rw-r--r--	2018-11-05 09:00
BrowserConsoleHandler.php	7.21 KB	-rw-r--r--	2018-11-05 09:00
BufferHandler.php	3.58 KB	-rw-r--r--	2018-11-05 09:00
ChromePHPHandler.php	5.48 KB	-rw-r--r--	2018-11-05 09:00
CouchDBHandler.php	1.91 KB	-rw-r--r--	2018-11-05 09:00
CubeHandler.php	4.52 KB	-rw-r--r--	2018-11-05 09:00
DeduplicationHandler.php	5.35 KB	-rw-r--r--	2018-11-05 09:00
DoctrineCouchDBHandler.php	1000 B	-rw-r--r--	2018-11-05 09:00
DynamoDbHandler.php	2.38 KB	-rw-r--r--	2018-11-05 09:00
ElasticSearchHandler.php	3.33 KB	-rw-r--r--	2018-11-05 09:00
ErrorLogHandler.php	2.31 KB	-rw-r--r--	2018-11-05 09:00
FilterHandler.php	4.32 KB	-rw-r--r--	2018-11-05 09:00
FingersCrossedHandler.php	5.77 KB	-rw-r--r--	2018-11-05 09:00
FirePHPHandler.php	5.33 KB	-rw-r--r--	2018-11-05 09:00
FleepHookHandler.php	3.28 KB	-rw-r--r--	2018-11-05 09:00
FlowdockHandler.php	3.28 KB	-rw-r--r--	2018-11-05 09:00
GelfHandler.php	1.91 KB	-rw-r--r--	2018-11-05 09:00
GroupHandler.php	2.69 KB	-rw-r--r--	2018-11-05 09:00
HandlerInterface.php	2.53 KB	-rw-r--r--	2018-11-05 09:00
HandlerWrapper.php	2.31 KB	-rw-r--r--	2018-11-05 09:00
HipChatHandler.php	10.51 KB	-rw-r--r--	2018-11-05 09:00
IFTTTHandler.php	2.06 KB	-rw-r--r--	2018-11-05 09:00
InsightOpsHandler.php	1.83 KB	-rw-r--r--	2018-11-05 09:00
LogEntriesHandler.php	1.58 KB	-rw-r--r--	2018-11-05 09:00
LogglyHandler.php	2.56 KB	-rw-r--r--	2018-11-05 09:00
MailHandler.php	1.58 KB	-rw-r--r--	2018-11-05 09:00
MandrillHandler.php	2.11 KB	-rw-r--r--	2018-11-05 09:00
MissingExtensionException.php	450 B	-rw-r--r--	2018-11-05 09:00
MongoDBHandler.php	1.57 KB	-rw-r--r--	2018-11-05 09:00
NativeMailerHandler.php	5.08 KB	-rw-r--r--	2018-11-05 09:00
NewRelicHandler.php	6.06 KB	-rw-r--r--	2018-11-05 09:00
NullHandler.php	953 B	-rw-r--r--	2018-11-05 09:00
PHPConsoleHandler.php	9.76 KB	-rw-r--r--	2018-11-05 09:00
PsrHandler.php	1.4 KB	-rw-r--r--	2018-11-05 09:00
PushoverHandler.php	6.47 KB	-rw-r--r--	2018-11-05 09:00
RavenHandler.php	6.96 KB	-rw-r--r--	2018-11-05 09:00
RedisHandler.php	2.82 KB	-rw-r--r--	2018-11-05 09:00
RollbarHandler.php	3.85 KB	-rw-r--r--	2018-11-05 09:00
RotatingFileHandler.php	5.75 KB	-rw-r--r--	2018-11-05 09:00
SamplingHandler.php	2.61 KB	-rw-r--r--	2018-11-05 09:00
SlackHandler.php	6.3 KB	-rw-r--r--	2018-11-05 09:00
SlackWebhookHandler.php	3.73 KB	-rw-r--r--	2018-11-05 09:00
SlackbotHandler.php	1.98 KB	-rw-r--r--	2018-11-05 09:00
SocketHandler.php	9.58 KB	-rw-r--r--	2018-11-05 09:00
StreamHandler.php	5.1 KB	-rw-r--r--	2018-11-05 09:00
SwiftMailerHandler.php	3.36 KB	-rw-r--r--	2018-11-05 09:00
SyslogHandler.php	1.8 KB	-rw-r--r--	2018-11-05 09:00
SyslogUdpHandler.php	2.51 KB	-rw-r--r--	2018-11-05 09:00
TestHandler.php	5.01 KB	-rw-r--r--	2018-11-05 09:00
WhatFailureGroupHandler.php	1.76 KB	-rw-r--r--	2018-11-05 09:00
ZendMonitorHandler.php	2.19 KB	-rw-r--r--	2018-11-05 09:00

Rename

<?php

/*
 * This file is part of the Monolog package.
 *
 * (c) Jordi Boggiano <j.boggiano@seld.be>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Monolog\Handler;

use Monolog\Logger;

/**
 * Logs to Cube.
 *
 * @link http://square.github.com/cube/
 * @author Wan Chen <kami@kamisama.me>
 */
class CubeHandler extends AbstractProcessingHandler
{
    private $udpConnection;
    private $httpConnection;
    private $scheme;
    private $host;
    private $port;
    private $acceptedSchemes = array('http', 'udp');

/**
     * Create a Cube handler
     *
     * @throws \UnexpectedValueException when given url is not a valid url.
     *                                   A valid url must consist of three parts : protocol://host:port
     *                                   Only valid protocols used by Cube are http and udp
     */
    public function __construct($url, $level = Logger::DEBUG, $bubble = true)
    {
        $urlInfo = parse_url($url);

if (!isset($urlInfo['scheme'], $urlInfo['host'], $urlInfo['port'])) {
            throw new \UnexpectedValueException('URL "'.$url.'" is not valid');
        }

if (!in_array($urlInfo['scheme'], $this->acceptedSchemes)) {
            throw new \UnexpectedValueException(
                'Invalid protocol (' . $urlInfo['scheme']  . ').'
                . ' Valid options are ' . implode(', ', $this->acceptedSchemes));
        }

$this->scheme = $urlInfo['scheme'];
        $this->host = $urlInfo['host'];
        $this->port = $urlInfo['port'];

parent::__construct($level, $bubble);
    }

/**
     * Establish a connection to an UDP socket
     *
     * @throws \LogicException           when unable to connect to the socket
     * @throws MissingExtensionException when there is no socket extension
     */
    protected function connectUdp()
    {
        if (!extension_loaded('sockets')) {
            throw new MissingExtensionException('The sockets extension is required to use udp URLs with the CubeHandler');
        }

$this->udpConnection = socket_create(AF_INET, SOCK_DGRAM, 0);
        if (!$this->udpConnection) {
            throw new \LogicException('Unable to create a socket');
        }

if (!socket_connect($this->udpConnection, $this->host, $this->port)) {
            throw new \LogicException('Unable to connect to the socket at ' . $this->host . ':' . $this->port);
        }
    }

/**
     * Establish a connection to a http server
     * @throws \LogicException when no curl extension
     */
    protected function connectHttp()
    {
        if (!extension_loaded('curl')) {
            throw new \LogicException('The curl extension is needed to use http URLs with the CubeHandler');
        }

$this->httpConnection = curl_init('http://'.$this->host.':'.$this->port.'/1.0/event/put');

if (!$this->httpConnection) {
            throw new \LogicException('Unable to connect to ' . $this->host . ':' . $this->port);
        }

curl_setopt($this->httpConnection, CURLOPT_CUSTOMREQUEST, "POST");
        curl_setopt($this->httpConnection, CURLOPT_RETURNTRANSFER, true);
    }

/**
     * {@inheritdoc}
     */
    protected function write(array $record)
    {
        $date = $record['datetime'];

$data = array('time' => $date->format('Y-m-d\TH:i:s.uO'));
        unset($record['datetime']);

if (isset($record['context']['type'])) {
            $data['type'] = $record['context']['type'];
            unset($record['context']['type']);
        } else {
            $data['type'] = $record['channel'];
        }

$data['data'] = $record['context'];
        $data['data']['level'] = $record['level'];

if ($this->scheme === 'http') {
            $this->writeHttp(json_encode($data));
        } else {
            $this->writeUdp(json_encode($data));
        }
    }

private function writeUdp($data)
    {
        if (!$this->udpConnection) {
            $this->connectUdp();
        }

socket_send($this->udpConnection, $data, strlen($data), 0);
    }

private function writeHttp($data)
    {
        if (!$this->httpConnection) {
            $this->connectHttp();
        }

curl_setopt($this->httpConnection, CURLOPT_POSTFIELDS, '['.$data.']');
        curl_setopt($this->httpConnection, CURLOPT_HTTPHEADER, array(
            'Content-Type: application/json',
            'Content-Length: ' . strlen('['.$data.']'),
        ));

Curl\Util::execute($this->httpConnection, 5, false);
    }
}