aboutsummaryrefslogtreecommitdiff
path: root/examples/py-flow-info
diff options
context:
space:
mode:
authorToni Uhlig <matzeton@googlemail.com>2021-01-26 19:07:16 +0100
committerToni Uhlig <matzeton@googlemail.com>2021-01-26 19:07:16 +0100
commit102b61175ccb8a8e16444b25b319b8e3806eba1c (patch)
tree87c2c00674161d6cdd35ee6337216412a6e06eea /examples/py-flow-info
parent25c23e3d23a3c242a91a17ee0efeda1b1d64c852 (diff)
All colors are beautiful for py-flow-info.
* instance alias is now mandatory (will be required for future use-cases) Signed-off-by: Toni Uhlig <matzeton@googlemail.com>
Diffstat (limited to 'examples/py-flow-info')
-rwxr-xr-xexamples/py-flow-info/flow-info.py20
1 files changed, 15 insertions, 5 deletions
diff --git a/examples/py-flow-info/flow-info.py b/examples/py-flow-info/flow-info.py
index 81087cc8f..c13e9cead 100755
--- a/examples/py-flow-info/flow-info.py
+++ b/examples/py-flow-info/flow-info.py
@@ -41,9 +41,19 @@ def parse_json_str(json_str):
else TermColor.FAIL + TermColor.BOLD + TermColor.BLINK + 'RISK' + TermColor.END,
ndpi_frisk[:-2])
+ instance_and_source = ''
+ instance_and_source += '[{}]'.format(TermColor.setColorByString(j['alias']))
+ instance_and_source += '[{}]'.format(TermColor.setColorByString(j['source']))
+
+ flow_event_name = ''
+ if nDPIdEvent.FlowEventName == 'guessed' or nDPIdEvent.FlowEventName == 'undetected':
+ flow_event_name += '{}{:>16}{}'.format(TermColor.HINT, nDPIdEvent.FlowEventPrettyName, TermColor.END)
+ else:
+ flow_event_name += '{:>16}'.format(nDPIdEvent.FlowEventPrettyName)
+
if j['l3_proto'] == 'ip4':
- print('{:>16}: [{:.>6}] [{}][{:.>5}] [{:.>15}]{} -> [{:.>15}]{} {}' \
- ''.format(nDPIdEvent.FlowEventPrettyName,
+ print('{} {}: [{:.>6}] [{}][{:.>5}] [{:.>15}]{} -> [{:.>15}]{} {}' \
+ ''.format(instance_and_source, flow_event_name,
j['flow_id'], j['l3_proto'], j['l4_proto'],
j['src_ip'].lower(),
'[{:.>5}]'.format(j['src_port']) if 'src_port' in j else '',
@@ -51,8 +61,8 @@ def parse_json_str(json_str):
'[{:.>5}]'.format(j['dst_port']) if 'dst_port' in j else '',
ndpi_proto_categ))
elif j['l3_proto'] == 'ip6':
- print('{:>16}: [{:.>6}] [{}][{:.>5}] [{:.>39}]{} -> [{:.>39}]{} {}' \
- ''.format(nDPIdEvent.FlowEventPrettyName,
+ print('{} {}: [{:.>6}] [{}][{:.>5}] [{:.>39}]{} -> [{:.>39}]{} {}' \
+ ''.format(instance_and_source, flow_event_name,
j['flow_id'], j['l3_proto'], j['l4_proto'],
j['src_ip'].lower(),
'[{:.>5}]'.format(j['src_port']) if 'src_port' in j else '',
@@ -63,7 +73,7 @@ def parse_json_str(json_str):
raise RuntimeError('unsupported l3 protocol: {}'.format(j['l3_proto']))
if len(ndpi_frisk) > 0:
- print('{:>18}{}'.format('', ndpi_frisk))
+ print('{} {:>18}{}'.format(instance_and_source, '', ndpi_frisk))
if __name__ == '__main__':