app.py

from daf_virtual_rasp.com.enquadramento import Enquadramento
from daf_virtual_rasp.com.arq import Arq
from daf_virtual_rasp.com.poller import Poller
from daf_virtual_rasp.com.enq_enum import TIPO_t
from daf_virtual_rasp.daf.daf import DAF

import sys, time, os
import serial
import argparse
import logging

# Porta serial padrão
default_port = '/dev/ttyGS0'

# Definindo argumentos de linha de comando
parser = argparse.ArgumentParser(description='DAF-pi')
parser.add_argument('-p', '--port', type=str, default=default_port, help='Porta serial de comunicação (default: /dev/ttyGS0)')
parser.add_argument('-t', '--timeout_arq', type=float, default=2, help='Tempo de timeout da camada de arq (default: 2 segundos)')
args = parser.parse_args()

# Recebendo argumentos de linha de comando
port = args.port
timeout_arq = args.timeout_arq

# Configuração do log
log_level = os.getenv('DAF_PI_LOG', 'INFO').upper()
log_level = getattr(logging, log_level, logging.INFO)
formatter = '%(asctime)s %(levelname)s %(name)s %(threadName)s : %(message)s'
logging.basicConfig(stream=sys.stdout, level=log_level, format=formatter)

logging.debug('Log de DEBUG habilitado')

# define parametros das camadas ARQ e Enquadramento
max_tentativas_arq = 3
timeout_enq = 0.5

# obtém porta serial 
ser = serial.Serial(
            port=port,
            baudrate = 115200,
            parity=serial.PARITY_NONE,
            stopbits=serial.STOPBITS_ONE,
            bytesize=serial.EIGHTBITS,
            timeout= None
        )

ser.flush()


# cria os objetos das camadas ARQ, Enquadramento e DAF
e = Enquadramento(ser, timeout_enq)
a = Arq(max_tentativas_arq, timeout_arq)
daf = DAF()

# define organização das subcamadas
daf.set_inferior(a)
a.set_superior(daf)
a.set_inferior(e)
e.set_superior(a)

# despacha as camadas
pol = Poller()
pol.adiciona(daf)
pol.adiciona(e)
pol.adiciona(a)
pol.despache()