You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
139 lines
4.5 KiB
139 lines
4.5 KiB
#!/usr/bin/python3
|
|
# -*- coding: utf-8 -*-
|
|
|
|
import datetime
|
|
import os.path
|
|
import asyncio
|
|
import logging
|
|
import argparse
|
|
import websockets
|
|
import socketserver
|
|
import configparser
|
|
import os
|
|
from collections import deque
|
|
from urllib.parse import urlparse, parse_qs
|
|
from ansi2html import Ansi2HTMLConverter
|
|
|
|
current_dir = os.getcwd()
|
|
config = configparser.ConfigParser()
|
|
config.read(current_dir + '/logtailer.ini')
|
|
|
|
dmrids = {}
|
|
|
|
# init
|
|
logging.basicConfig(format='%(asctime)s %(levelname)s %(message)s', level=logging.INFO)
|
|
conv = Ansi2HTMLConverter(inline=True)
|
|
|
|
@asyncio.coroutine
|
|
def view_log(websocket, path):
|
|
global config
|
|
global dmrids
|
|
logging.info('Connected, remote={}, path={}'.format(websocket.remote_address, path))
|
|
|
|
try:
|
|
try:
|
|
parse_result = urlparse(path)
|
|
except Exception:
|
|
raise ValueError('Fail to parse URL', format(path))
|
|
|
|
NUM_LINES = int(config['MMDVMHost']['Num_Lines'])
|
|
path = os.path.abspath(parse_result.path)
|
|
now = datetime.datetime.now()
|
|
year = str(now.year)
|
|
month = str(now.month)
|
|
if len(month) == 1:
|
|
month = "0" + month
|
|
day = str(now.day)
|
|
if len(day) == 1:
|
|
day = "0" + day
|
|
|
|
file_path = ""
|
|
if path == "/MMDVM":
|
|
file_path = config['MMDVMHost']['Logdir']+config['MMDVMHost']['Prefix']+"-"+year+"-"+month+"-"+day+".log"
|
|
elif path == "/DAPNET":
|
|
file_path = config['DAPNETGateway']['Logdir']+config['DAPNETGateway']['Prefix']+"-"+year+"-"+month+"-"+day+".log"
|
|
NUM_LINES = 0
|
|
logging.info(file_path)
|
|
if not os.path.isfile(file_path):
|
|
raise ValueError('File not found', format(file_path))
|
|
|
|
with open(file_path, newline = '\n', encoding="utf8", errors='ignore') as f:
|
|
|
|
content = ''.join(deque(f, NUM_LINES))
|
|
content = conv.convert(content, full=False)
|
|
lines = content.split("\n")
|
|
for line in lines:
|
|
if line.find("from ") > 0 and line.find("to ") > 0:
|
|
source = line[line.index("from ") + 5:line.index("to ")].strip()
|
|
if source in dmrids:
|
|
line = line.replace(source, dmrids[source])
|
|
yield from websocket.send(line)
|
|
|
|
while True:
|
|
content = f.read()
|
|
if content:
|
|
content = conv.convert(content, full=False)
|
|
lines = content.split("\n")
|
|
for line in lines:
|
|
if line.find("from ") > 0 and line.find("to ") > 0:
|
|
source = line[line.index("from ") + 5:line.index("to ")].strip()
|
|
if source in dmrids:
|
|
line = line.replace(source, dmrids[source])
|
|
yield from websocket.send(line)
|
|
else:
|
|
yield from asyncio.sleep(0.2)
|
|
|
|
except ValueError as e:
|
|
try:
|
|
yield from websocket.send('Logtailer-Errormessage: ValueError: {}'.format(e))
|
|
yield from websocket.close()
|
|
except Exception:
|
|
pass
|
|
|
|
log_close(websocket, path, e)
|
|
|
|
except Exception as e:
|
|
try:
|
|
yield from websocket.send('Logtailer-Errormessage: Error: {}'.format(e))
|
|
yield from websocket.close()
|
|
except Exception:
|
|
pass
|
|
log_close(websocket, path, e)
|
|
|
|
else:
|
|
log_close(websocket, path)
|
|
|
|
|
|
def log_close(websocket, path, exception=None):
|
|
message = 'Closed, remote={}, path={}'.format(websocket.remote_address, path)
|
|
if exception is not None:
|
|
message += ', exception={}'.format(exception)
|
|
logging.info(message)
|
|
|
|
|
|
def websocketserver():
|
|
start_server = websockets.serve(view_log, config['DEFAULT']['Host'], config['DEFAULT']['Port'])
|
|
asyncio.get_event_loop().run_until_complete(start_server)
|
|
asyncio.get_event_loop().run_forever()
|
|
|
|
|
|
def main():
|
|
dmr_id_lookup = config['MMDVMHost']['DMR_ID_Lookup']
|
|
dmr_id_lookupfile = config['MMDVMHost']['DMR_ID_LookupFile']
|
|
|
|
if dmr_id_lookup == "1":
|
|
if not os.path.isfile(dmr_id_lookupfile):
|
|
raise ValueError('File not found', format(dmr_id_lookupfile))
|
|
|
|
f = open(dmr_id_lookupfile, 'r')
|
|
lines = f.readlines()
|
|
for line in lines:
|
|
tokens = line.split("\t")
|
|
dmrids[tokens[0]] = tokens[1]
|
|
logging.info("Starting Websocketserver")
|
|
websocketserver()
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|