Commit f09daf20 authored by YannGarcia's avatar YannGarcia
Browse files

Add log viewer based on plantuml

parent f27fca84

ccsrc/Ports/LibSip/SipPort.cc

+0 −11
Original line number Diff line number Diff line
@@ -133,7 +133,6 @@ namespace LibSip__Interface { 
  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::INVITE__Request& send_par, const Address4SIP *destination_address)

  {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -145,7 +144,6 @@ namespace LibSip__Interface { 
  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::ACK__Request& send_par, const Address4SIP *destination_address)

  {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -156,7 +154,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::REGISTER__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -167,7 +164,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::SUBSCRIBE__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -178,7 +174,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::MESSAGE__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -189,7 +184,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::OPTIONS__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -200,7 +194,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::BYE__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -211,7 +204,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::CANCEL__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -222,7 +214,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::NOTIFY__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -233,7 +224,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::INFO__Request& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);
@@ -244,7 +234,6 @@ namespace LibSip__Interface { 
  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::Response& send_par, const Address4SIP *destination_address) {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

    loggers::get_instance().log(">>> SipPort::outgoing_send: %s", destination_address);



    float duration;

    loggers::get_instance().set_start_time(_time_key);

plantuml/AtsBCF.svg

0 → 100644
+176 −0

File added.

Preview size limit exceeded, changes collapsed.

plantuml/AtsBCF.txt

0 → 100644
+63 −0
Original line number Diff line number Diff line 
@startuml

title TC_BCF_SIP_MESSAGE_BV_03

/'Editor: https://plantuml-editor.kkeisuke.com/ '/

/'Syntax: http://plantuml.com/fr/sequence-diagram '/

!include etsi-style.iuml

!pragma teoz true

autonumber

participant system

box "TTCN-3 Environment" #LightBlue

participant "3:SIPP"

participant "4:SIPP"

note left: 10:21:11.715308

note left: 10:21:11.715798

endbox

"3:SIPP" --> system: map

"4:SIPP" --> system: map

"3:SIPP" -[#green]> system: @LibSip_SIPTypesAndValues.MESSAGE_Request

note right: [[file:///home/yann/dev/NG112/plantuml/msgs/10_21_11_716519.txt request := ...]]

note left: 10:21:11.716519

"3:SIPP" -> "3:SIPP": Start, duration: 15

note left: 10:21:11.718350

system -[#green]> "3:SIPP": @LibSip_SIPTypesAndValues.Response

note right: [[file:///home/yann/dev/NG112/plantuml/msgs/10_21_11_723002.txt response := ...]]

note left: 10:21:11.723002

"3:SIPP" -> "3:SIPP": Stop, duration: 15

note left: 10:21:11.723330

note left: 10:21:11.723463

note left: 10:21:11.723593

note left: 10:21:11.723710

note left: 10:21:11.723779

note left: 10:21:11.723843

note left: 10:21:11.724341

"4:SIPP" -> "4:SIPP": Start, duration: 30

note left: 10:21:11.724421

system -[#green]> "4:SIPP": @LibSip_SIPTypesAndValues.MESSAGE_Request

note right: [[file:///home/yann/dev/NG112/plantuml/msgs/10_21_11_837816.txt response := ...]]

note left: 10:21:11.837816

"4:SIPP" -> "4:SIPP": Stop, duration: 30

note left: 10:21:11.838711

"4:SIPP" -[#green]> system: @LibSip_SIPTypesAndValues.Response

note right: [[file:///home/yann/dev/NG112/plantuml/msgs/10_21_11_839359.txt request := ...]]

note left: 10:21:11.839359

note left: 10:21:11.923530

note left: 10:21:11.923809

note left: 10:21:11.924067

note left: 10:21:11.924302

note left: 10:21:11.924436

note left: 10:21:11.924489

note left: 10:21:11.924598

note left: 10:21:11.924900

note left: 10:21:11.925117

note left: 10:21:11.925385

note left: 10:21:11.925391

note left: 10:21:11.927194

"3:SIPP" --> system: unmap

"4:SIPP" --> system: unmap

hnote over "3:SIPP" #green: pass

note left: 10:21:11.929873

hnote over "4:SIPP" #green: pass

note left: 10:21:11.929912

hnote across #green: pass

note left: 10:21:11.929950

@enduml

plantuml/README.md

0 → 100644
+0 −0

Empty file added.

plantuml/__main__.py

0 → 100644
+180 −0
Original line number Diff line number Diff line 
# -*- Coding: utf-8 -*-



from __future__ import division # Import floating-point division (1/4=0.25) instead of Euclidian division (1/4=0)



import os

import glob

import sys

import logging



from regex_list import *



MSG_PATH = ""

IN_FILE_PATH = ""

OUT_FILE_PATH = ""

out_streams = object()

logger = object()

parser = object()

data_ctx = dict()



def process_command_line_args():

    global IN_FILE_PATH



    print(f"Arguments count: {len(sys.argv)}")

    for i, arg in enumerate(sys.argv):

        print(f"Argument {i:>6}: {arg}")

    IN_FILE_PATH = sys.argv[1]

    # End of function process_command_line_args



def process_line(line):

    global MSG_PATH, out_streams, logger, parser, data_ctx



    match = parser.parse_line(line)

    if match != None:

        logger.info(f"Matching: {match}")

        if 'testcase' in match:

            logger.info('Got testcase')

            out_streams.write('@startuml\n')

            out_streams.write(f"title {match['testcase']}\n")

            out_streams.write("/'Editor: https://plantuml-editor.kkeisuke.com/ '/\n")

            out_streams.write("/'Syntax: http://plantuml.com/fr/sequence-diagram '/\n")

            out_streams.write('!include etsi-style.iuml\n')

            out_streams.write('!pragma teoz true\n')

            out_streams.write('autonumber\n')

            out_streams.write('participant system\n')

            out_streams.write('box "TTCN-3 Environment" #LightBlue\n')

        elif 'operation' in match:

            logger.info('Got operation')

            if match['operation'] == 'mapped':

                out_streams.write(f"participant \"{match['comp']}:{match['protocol_port']}\"\n")

                data_ctx['protocol_port'].append(f"{match['comp']}:{match['protocol_port']}")

            else:

                if match['protocol_port'] != 'syncPort':

                    out_streams.write(f"\"{match['comp']}:{match['protocol_port']}\" --> system: unmap\n")

        elif 'request' in match:

            logger.info('Got request')

            if data_ctx['box_ended'] == False:

                out_streams.write('endbox\n')

                data_ctx['box_ended'] = True

                for p in data_ctx['protocol_port']:

                    out_streams.write(f"\"{p}\" --> system: map\n")

            out_streams.write(f"\"{match['comp']}:{match['port']}\" -[#green]> system: @{match['module']}.{match['message']}\n")

            s =  match['request'].replace(",", ",\\n").replace("\"", "").strip()

            if len(s) > 128:

                n = match['hours'] + "_" + match['minutes'] + "_" + match['seconds'] + "_" + match['milliseconds'] + ".txt"

                n = os.path.join(MSG_PATH, n)

                with open(n, "w") as msg:

                    msg.write(s)

                s = f'[[file://{n} request := ...]]' #{Click to read the message}

            out_streams.write(f"note right: {s}\n")

            out_streams.write(f"note left: {match['hours']}:{match['minutes']}:{match['seconds']}.{match['milliseconds']}\n")

        elif 'response' in match:

            logger.info('Got response')

            if data_ctx['box_ended'] == False:

                out_streams.write('endbox\n')

                data_ctx['box_ended'] = True

            out_streams.write(f"system -[#green]> \"{match['comp']}:{match['port']}\": @{match['module']}.{match['message']}\n")

            s = match['response'].replace(",", ",\\n").replace("\"", "").strip()

            if len(s) > 128:

                n = match['hours'] + "_" + match['minutes'] + "_" + match['seconds'] + "_" + match['milliseconds'] + ".txt"

                n = os.path.join(MSG_PATH, n)

                with open(n, "w") as msg:

                    msg.write(s)

                s = f'[[file://{n} response := ...]]' #{Click to read the message}

            out_streams.write(f"note right: {s}\n")

            out_streams.write(f"note left: {match['hours']}:{match['minutes']}:{match['seconds']}.{match['milliseconds']}\n")

        elif 'timer_name' in match:

            logger.info('Got timer')

            if match['timer_name'] == 'tc_sync':

                pass

            else:

                for p in data_ctx['protocol_port']:

                    if p.startswith(match['comp']):

                        out_streams.write(f"\"{p}\" -> \"{p}\": {match['start_stop']}, duration: {match['duration']}\n")

                        break

            out_streams.write(f"note left: {match['hours']}:{match['minutes']}:{match['seconds']}.{match['milliseconds']}\n")

        elif 'verdict' in match:

            logger.info('Got verdict')

            if 'ptcid' in match and match['ptcid'] != None:

                s = match['ptcid'].split('(')

                s = s[1].split(')')

                for p in data_ctx['protocol_port']:

                    if p.startswith(s[0]):

                        if match['verdict'] == 'fail':

                            out_streams.write(f"hnote over \"{p}\" #red: fail\n")

                        elif match['verdict'] == 'pass':

                            out_streams.write(f"hnote over \"{p}\" #green: pass\n")

                        elif match['verdict'] == 'inconc':

                            out_streams.write(f"hnote across #yellow: inconc\n")

                        else:

                            out_streams.write(f"hnote over \"{p}\" #gray: error\n")

                        out_streams.write(f"note left: {match['hours']}:{match['minutes']}:{match['seconds']}.{match['milliseconds']}\n")

                        break

        elif 'final_verdict' in match:

            logger.info('Got verdict')

            if match['final_verdict'] == 'fail':

                out_streams.write(f"hnote across #red: fail\n")

            elif match['final_verdict'] == 'pass':

                out_streams.write(f"hnote across #green: pass\n")

            elif match['final_verdict'] == 'inconc':

                out_streams.write(f"hnote across #yellow: inconc\n")

            else:

                out_streams.write(f"hnote across #gray: error\n")

            out_streams.write(f"note left: {match['hours']}:{match['minutes']}:{match['seconds']}.{match['milliseconds']}\n")

            out_streams.write('@enduml\n')

        else:

            logger.info('Got unsupported item')

        # End of 'if' statement

        out_streams.flush()

    # End of function process_line



def main():

    global MSG_PATH, OUT_FILE_PATH, out_streams, logger, parser, data_ctx



    process_command_line_args()



    # Initialize the logger

    logger = logging.getLogger(__name__)

    logger.setLevel(logging.DEBUG)

    l = logging.StreamHandler()

    l.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))

    logger.addHandler(l)



    # Prepare outputs

    OUT_FILE_PATH = sys.argv[2]

    CURRENT_PATH = os.getcwd()

    MSG_PATH = os.path.join(CURRENT_PATH, "msgs")

    logger.info(f'CURRENT_PATH:{CURRENT_PATH} - MSG_PATH{MSG_PATH}')

    if os.path.exists(MSG_PATH):

        files = glob.glob(os.path.join(MSG_PATH, '*'))

        for f in files:

            os.remove(f)

    else:

        os.mkdir(MSG_PATH)

    

    # Setup the regex

    parser = regex_list(logger)

    parser.reset_state()



    data_ctx = dict()

    data_ctx['protocol_port'] = []

    data_ctx['box_ended'] = False



    print(f"IN_FILE_PATH= {IN_FILE_PATH}")

    with open(IN_FILE_PATH, "r") as in_stream:

        with open(OUT_FILE_PATH, "w") as out_streams:

            line = in_stream.readline()

            while line != '':

                process_line(line)

                line = in_stream.readline()

            # End of 'for' statement

        # End of 'with' statement

    # End of 'with' statement



    os.system('java -DPLANTUML_LIMIT_SIZE=8192 -jar ./plantuml.jar -svg {}'.format(OUT_FILE_PATH))

# End of main function



if __name__ == "__main__":

    main()



# End of file