<?php

error_reporting(E_ALL);
ini_set('display_errors',true);

require_once __DIR__.'/Config.php';
require_once __DIR__.'/InfluxdbLog.php';
require_once __DIR__.'/Rabbitmq.php';

/**
 * 发送者类
 */
class Sender{
    
    /**
     * 添加记录
     * @param array $data
     * @param array $tags
     * @return type
     */
    static function add($type,array $data,array $tags = []){
        $tags = $tags + array(
            'ip'=>'',
            'hostname'=>'',
        );
        return InfluxdbLog::handle($type,$data,$tags);
    }
    
    /**
     * 添加到队列中
     * @param array $data
     * @param array $tags
     * @return type
     */
    static function pushmq($type,array $data,array $tags = []){
        $tags = $tags + array(
            'ip'=>'',
            'hostname'=>'',
        );
        return Rabbitmq::handle($type, $data, $tags);
    }
    
    /**
     * 写日志
     * @param type $message
     * @return type
     */
    static function log($message){
        echo $message."\n";
        if (!Config::log_file){
            return;
        }
        
        $fp = @fopen(Config::log_file,'a');
        if (!$fp){
            return;
        }
        $r = fwrite($fp, $message."\n");
        fclose($fp);
        
        return $r;
    }
}