blob: dfa94c978e6571aaacb6e0ad33ac69f176ed4d88 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
#!/usr/bin/env python3
import sys
import re
import os
import xml.etree.ElementTree
import socket
import binascii
import time
if len(sys.argv) < 2:
sys.exit("log file is not provided")
path = sys.argv[1]
p = re.compile(r"\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2} INFO: \[([TU][0-9a-fA-F]{8}): (\S+) < [\d.]+] ([0-9a-fA-F]+)")
def load_ports():
ports = {}
dir = os.path.dirname(os.path.abspath(__file__))
root = xml.etree.ElementTree.parse(dir + '/../setup/default.xml').getroot()
for entry in root.findall('entry'):
key = entry.attrib['key']
if key.endswith('.port'):
ports[key[:-5]] = int(entry.text)
return ports
ports = load_ports()
protocols = {}
messages = {}
for line in open(path):
print(line)
m = p.match(line)
if m:
session = m.group(1)
protocol = m.group(2)
message = m.group(3)
protocols[session] = protocol
if session not in messages:
messages[session] = []
messages[session].append(message)
print('Total: %d' % len(messages))
for session in protocols:
port = ports[protocols[session]]
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(("localhost", int(port)))
for message in messages[session]:
s.send(binascii.unhexlify(message))
time.sleep(0.5)
s.close()
|
