/**
 * 텔레그램 단방향 메세지 송출..
 * 만든놈 : 방문넷(lee@dongwon.me)
 * 라이센스 : 그딴거 없음. 주석 지우고 사용가능 하실께요~
 * 상업용이든 비상업용이든 알아서잘 수정하여 쓰세용~
 * A/S나 문의는 받지않습니다~~
 */

//======================================================================================
// 모듈 로드
//======================================================================================
var http = require('http');					//http 서버
var url  = require('url');					//URL
var exec = require('child_process').exec;	//서버 커멘트 처리(보안상 문제가 있을수 있음으로 주의)

//======================================================================================
// 변수 설정
//======================================================================================
var telegramCli = '/usr/bin/telegram-cli';		//텔레그램 실행파일 경로
var telegramKey = '/etc/telegram/server.pub';	//텔레그램 serverkey 경로
var telegramId = '텔레그램 연락처에 적힌 이름.';						//메세지 받을 아이디
var serverPort = 7890;							//리스닝할 서버 포트(외부 iptable은 웬만하면 열지마세요!);
var messageFlag = true;							//메세지 전송 여부.

//======================================================================================
// http 서버 오픈.	
// 외부에서 접근 불가능하게 해야 조금이나마 안심.
// 외부에서 접근을 시도할경우 거부하는 쪽이 좋음.
//======================================================================================
var webServer = http.createServer(function(req,res)
{
	_LOG_('호출 아이피 => ' + req.connection.remoteAddress);
	
	//로컬용도로 만든 거기에 로컬 아이피가 아닐경우는 튕겨내기.
	if(req.connection.remoteAddress != '127.0.0.1') 
	{
		_LOG_('로컬 호출이 아닙니다.');
		res.end();
		return;
	}

	//Url 쪼개기
	var urlParts = url.parse(req.url, true);
    
    //쿼리 스트링
    var query = urlParts.query;

    //쿼리스트링 로그 찍기.
    _LOG_(JSON.stringify(query));

    if(query.do == 'msg')
    {
    	SendMsg(query.message);
    }
    else if (query.do == 'flag')
    {
    	if(query.flag == 'true')
    	{
    		messageFlag = true;
    		_LOG_('메세지를 받습니다.');
    	}
    	else
    	{
    		messageFlag = false;
    		_LOG_('메세지를 안 받습니다.');
    	}
    }
    
    //끝!
    res.end();
}).listen(serverPort);;

//======================================================================================
// 로직 시작.
//======================================================================================
//메세지 송출.
function SendMsg(string)
{
	_LOG_('메세지 송출 시작');
	_LOG_('메세지 송출 메세지 => ' + string);
	
	if(messageFlag === false)
	{
		_LOG_('메세지를 받지 않고 있습니다.');
		_LOG_('메세지를 받으실려면 메세지 받기를 활성화 하십시오.');
		_LOG_('메세지 송출를 취소 하였습니다.');
		return;
	}

	exec(
		"echo 'msg "+telegramId+" "+string+"' | "+telegramCli+" -k "+telegramKey+" -W " ,
		function(err, stdout, stderr) { 
			if(err) { 
				_LOG_(err.message); 
				return;
			}

			_LOG_('메세지 송출 완료');
		}
	);
}

SendMsg('텔레그램 서버가 실행 되었습니다.');

//======================================================================================
// 로그용도.
//======================================================================================
function _LOG_(msg, type)
{
	if(typeof(type) == 'undefined') {
		type = 'info';
	}

	if(type == 'debug') {
		console.log('['+getTimeStampLog()+'] [디버그] ' + msg);
	}
	else if (type == 'info') {
		console.log('['+getTimeStampLog()+'] [정보] ' + msg);
	}
	else if (type == 'error') {
		console.log('['+getTimeStampLog()+'] [에러] ' + msg);
	}
}

function getTimeStampLog () {
	var d = new Date();
	var s =
		leadingZeros(d.getFullYear(), 4) + '-' +
		leadingZeros(d.getMonth() + 1, 2) + '-' +
		leadingZeros(d.getDate(), 2) + ' ' +
		leadingZeros(d.getHours(), 2) + ':' +
		leadingZeros(d.getMinutes(), 2) + ':' +
		leadingZeros(d.getSeconds(), 2);

	return s;
}

function leadingZeros(n, digits) {
	var zero = '';
	n = n.toString();

	if (n.length < digits) {
		for (i = 0; i < digits - n.length; i++) {
			zero += '0';
		}
	}

	return zero + n;
}