31. Clientes web para os serviços jSON e XML da versão 12
Vamos escrever três aplicativos de console clientes para os serviços jSON e XML do servidor web que acabamos de criar. Retomamos a arquitetura cliente/servidor da versão 11:
Vamos criar três scripts de console:
- os scripts [main] e [main3] utilizarão a camada [métier] do servidor;
- o script [main2] utilizará a camada [métier] do cliente;
31.1. A estrutura de diretórios dos scripts dos clientes
A pasta [http-clients/07] é obtida inicialmente por meio da cópia da pasta [http-clients/06]. Em seguida, ela é modificada.
- em [1]: os dados utilizados ou criados pelo cliente;
- em [2], a configuração e os scripts de console do cliente;
- em [3], a camada [dao] do cliente;
- em [4], a pasta de testes da camada [dao] do cliente;
31.2. A camada [dao] dos clientes
31.2.1. Interface
A camada [dao] implementará a seguinte interface [InterfaceImpôtsDaoWithHttpSession]:
from abc import abstractmethod
from AbstractImpôtsDao import AbstractImpôtsDao
from AdminData import AdminData
from TaxPayer import TaxPayer
class InterfaceImpôtsDaoWithHttpSession(AbstractImpôtsDao):
# cálculo do imposto por unidade
@abstractmethod
def calculate_tax(self, taxpayer: TaxPayer):
pass
# cálculo do imposto por lotes
@abstractmethod
def calculate_tax_in_bulk_mode(self, taxpayers: list):
pass
# inicialização de uma sessão
@abstractmethod
def init_session(self, type_session: str):
pass
# fim da sessão
@abstractmethod
def end_session(self):
pass
# autenticação
@abstractmethod
def authenticate_user(self, user: str, password: str):
pass
# lista de simulações
@abstractmethod
def get_simulations(self) -> list:
pass
# excluir uma simulação
@abstractmethod
def delete_simulation(self, id: int) -> list:
pass
# obter os dados necessários para o cálculo do imposto
@abstractmethod
def get_admindata(self) -> AdminData:
pass
Cada método da interface corresponde a um serviço URL do servidor de cálculo de impostos.
- linha 7: a interface estende a classe [AbstractDao], que gerencia os acessos ao sistema de arquivos;
A correspondência entre os métodos e os URL de serviço é definida no arquivo de configuração [config]:
# o servidor de cálculo do imposto
"server": {
"urlServer": "http://127.0.0.1:5000",
"user": {
"login": "admin",
"password": "admin"
},
"url_services": {
"calculate-tax": "/calculer-impot",
"get-admindata": "/get-admindata",
"calculate-tax-in-bulk-mode": "/calculer-impots",
"init-session": "/init-session",
"end-session": "/fin-session",
"authenticate-user": "/authentifier-utilisateur",
"get-simulations": "/lister-simulations",
"delete-simulation": "/supprimer-simulation"
}
31.2.2. Implementação
A interface [InterfaceImpôtsDaoWithHttpSession] é implementada pela seguinte classe [ImpôtsDaoWithHttpSession]:
# importações
import json
import requests
import xmltodict
from flask_api import status
from AbstractImpôtsDao import AbstractImpôtsDao
from AdminData import AdminData
from ImpôtsError import ImpôtsError
from InterfaceImpôtsDaoWithHttpSession import InterfaceImpôtsDaoWithHttpSession
from TaxPayer import TaxPayer
class ImpôtsDaoWithHttpSession(InterfaceImpôtsDaoWithHttpSession):
# construtor
def __init__(self, config: dict):
# inicialização do pai
AbstractImpôtsDao.__init__(self, config)
# armazenamento dos elementos de configuração
# configuração geral
self.__config = config
# servidor
self.__config_server = config["server"]
# serviços
self.__config_services = config["server"]['url_services']
# modo de depuração
self.__debug = config["debug"]
# registrador
self.__logger = None
# cookies
self.__cookies = None
# tipo de sessão (json, xml)
self.__session_type = None
# etapa de solicitação/resposta
def get_response(self, method: str, url_service: str, data_value: dict = None, json_value=None):
# [method]: método HTTP, GET ou POST
# [url_service]: URL de serviço
# [data]: parâmetros do POST no formato x-www-form-urlencoded
# [json]: parâmetros do POST em JSON
# [cookies]: cookies a serem incluídos na solicitação
# é necessário ter uma sessão XML ou JSON; caso contrário, não será possível processar a resposta
if self.__session_type not in ['json', 'xml']:
raise ImpôtsError(73, "il n'y a pas de session valide en cours")
# conexão
if method == "GET":
# GET
response = requests.get(url_service, cookies=self.__cookies)
else:
# POST
response = requests.post(url_service, data=data_value, json=json_value, cookies=self.__cookies)
# modo de depuração?
if self.__debug:
# registrador
if not self.__logger:
self.__logger = self.__config['logger']
# estamos registrando
self.__logger.write(f"{response.text}\n")
# resultado
if self.__session_type == "json":
résultat = json.loads(response.text)
else: # xml
résultat = xmltodict.parse(response.text[39:])['root']
# recuperam-se os cookies da resposta, se houver
if response.cookies:
self.__cookies = response.cookies
# código de status
status_code = response.status_code
# se o código de status for diferente de 200 OK
if status_code != status.HTTP_200_OK:
raise ImpôtsError(35, résultat['réponse'])
# retorna-se o resultado
return résultat['réponse']
def init_session(self, session_type: str):
# registra-se o tipo da sessão
self.__session_type = session_type
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['init-session']}/{session_type}"
# execução da consulta
self.get_response("GET", url_service)
…
- linhas 16-34: o construtor da classe;
- linha 19: a classe pai é inicializada;
- linhas 21-28: alguns dados da configuração são armazenados;
- linhas 29-34: criam-se três propriedades utilizadas nos métodos da classe;
- linhas 36-82: o método [get_response] abstrai o que é comum a todos os métodos da camada [dao]: o envio de uma solicitação HTTP e a recuperação da resposta HTTP do servidor;
- linhas 38-42: definição dos 5 parâmetros do método [get_response];
- linha 42: observe que, como o servidor mantém uma sessão, o cliente precisa ler e reenviar cookies;
- linhas 44-46: verifica-se se há de fato uma sessão válida em andamento;
- linha 51: caso do GET. Os cookies recebidos são reenviados;
- linha 54: caso do POST. Este pode ter dois tipos de parâmetros:
- o tipo [x-www-form-urlencoded]. É o caso dos URL, [/calculer-impot] e [/authentifier-utilisateur]. Nesse caso, utiliza-se o parâmetro [data_value] recebido pelo método;
- o tipo [json]. É o caso dos URL e [/calculer-impots]. Nesse caso, utiliza-se o parâmetro [json_value] recebido pelo método;
Nesse caso também, o cookie de sessão é devolvido.
- linhas 56-62: se estivermos no modo [debug], a resposta do servidor é registrada no log. Esse registro é importante, pois permite saber exatamente o que o servidor retornou;
- linhas 64-68: dependendo se estamos no modo JSON ou XML, a resposta em texto do servidor é transformada em um dicionário. Tomemos o exemplo do URL [/init-session]:
A resposta jSON é a seguinte:
2020-08-03 11:45:21.218116, MainThread : {"action": "init-session", "état": 700, "réponse": ["session démarrée avec le type de réponse json"]}
A resposta XML é a seguinte:
2020-08-03 11:45:54.671871, MainThread : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
O código das linhas 64-68 garante que, nos dois casos, obtenha-se em [résultat] um dicionário com as chaves [action, état, réponse];
- linhas 70 a 72: se a resposta contiver cookies, eles são recuperados. Será necessário reenviá-los na próxima solicitação;
- linhas 74-79: se o status HTTP da resposta for diferente de 200, lança-se uma exceção com a mensagem de erro contida em resultado[’réponse’]. Pode ser um erro ou uma lista de erros;
- linhas 81-82: retorna-se a resposta do servidor ao código chamador;
[init_session]
- linha 84: o método [init_session] serve para definir o tipo de sessão (json ou xml) que o cliente deseja iniciar com o servidor;
- linha 86: registra-se o tipo de sessão desejado na classe. De fato, todos os métodos precisam dessa informação para decodificar corretamente a resposta do servidor;
- linhas 88-90: com base na configuração do aplicativo, determina-se o método de serviço URL a ser chamado;
- linha 93: o serviço URL é consultado. O resultado do método [get_response] não é recuperado:
- se ela lançar uma exceção, a operação falhou. A exceção não é tratada aqui e será repassada diretamente ao código chamador, que então encerrará o cliente com uma mensagem de erro;
- se não lançar uma exceção, significa que a inicialização da sessão foi bem-sucedida;
[authenticate_user]
def authenticate_user(self, user: str, password: str):
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['authenticate-user']}"
post_params = {
"user": user,
"password": password
}
# execução da solicitação
self.get_response("POST", url_service, post_params)
- o método [authenticate_user] serve para autenticar-se no servidor. Para isso, ele recebe as credenciais de conexão [user, password] na linha 1;
- linhas 2-4: determina-se o serviço URL a ser consultado;
- linhas 5 a 8: os parâmetros do POST, uma vez que o URL e o [/authentifier-utilisateur] aguardam um POST com parâmetros [user, password];
- linha 11: a consulta é executada. Mais uma vez, não se obtém a resposta do servidor. É a exceção lançada pelo [get_response] que indica se a operação foi bem-sucedida ou não;
[calculate_tax]
def calculate_tax(self, taxpayer: TaxPayer):
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['calculate-tax']}"
# parâmetros do POST
post_params = {
"marié": taxpayer.marié,
"enfants": taxpayer.enfants,
"salaire": taxpayer.salaire
}
# execução da solicitação
response = self.get_response("POST", url_service, post_params)
# atualização do TaxPayer com a resposta
taxpayer.fromdict(response)
- o método [calculate_tax] permite calcular o imposto de um contribuinte [taxpayer] passado como parâmetro. Esse parâmetro é modificado pelo método (linha 15) e, portanto, constitui o resultado do método;
- linhas 2-4: define-se o serviço URL a ser consultado;
- linhas 6-10: os parâmetros do POST a serem enviados. De fato, o serviço URL do serviço [/calculer-impot] aguarda um POST com os parâmetros [marié, enfants, salaire];
- linhas 12-13: a consulta é executada e a resposta do servidor é recuperada. O URL do serviço [/calculer-impot] retorna um dicionário com as chaves [impôt, décôte, surcôte, réduction, taux] do imposto;
- linha 15: o dicionário [response] obtido é utilizado para atualizar o contribuinte [taxpayer];
[calculate_tax_in_bulk_mode]
# cálculo do imposto em modo em lote
def calculate_tax_in_bulk_mode(self, taxpayers: list):
# permite que as exceções sejam reportadas
# converte os contribuintes em uma lista de dicionários
# mantém-se apenas as propriedades [marié, enfants, salaire]
list_dict_taxpayers = list(
map(lambda taxpayer:
taxpayer.asdict(included_keys=[
'_TaxPayer__marié',
'_TaxPayer__enfants',
'_TaxPayer__salaire']),
taxpayers))
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['calculate-tax-in-bulk-mode']}"
# execução da consulta
list_dict_taxpayers2 = self.get_response("POST", url_service, data_value=None, json_value=list_dict_taxpayers)
# quando há apenas um contribuinte e estamos em uma sessão XML, [list_dict_taxpayers2] não é uma lista
# nesse caso, transforma-se em uma lista
if not isinstance(list_dict_taxpayers2, list):
list_dict_taxpayers2 = [list_dict_taxpayers2]
# atualizamos a lista inicial de contribuintes com os resultados recebidos
for i in range(len(taxpayers)):
# atualização dos contribuintes [i]
taxpayers[i].fromdict(list_dict_taxpayers2[i])
# aqui, o parâmetro [taxpayers] foi atualizado com os resultados do servidor
- linha 2: o método recebe uma lista de contribuintes do tipo TaxPayer;
- linhas 7-13: essa lista de elementos do tipo [TaxPayer] é transformada em uma lista de dicionários [marié, enfants, salaire];
- linhas 15-17: define-se o URL de serviço;
- linhas 19-20: executa-se uma consulta POST cujo corpo jSON é formado pela lista de dicionários criada na linha 7. Recupera-se a resposta do servidor;
- linhas 23-24: os testes revelaram um problema quando a sessão é do tipo XML:
- se a lista inicial de contribuintes tiver N elementos (N>1), obtém-se como resultado uma lista de N dicionários do tipo [OrderedDict];
- se a lista inicial tiver apenas um elemento, obtém-se não uma lista, mas um elemento do tipo [OrderedDict];
- linhas 23-24: se estivermos nesse último caso (1 elemento), transformamos o resultado em uma lista de 1 elemento;
- linhas 25-28: essa lista de dicionários recebidos contém o imposto de cada contribuinte da lista inicial. Atualiza-se, então, cada um deles com os resultados recebidos;
[get_simulations]
def get_simulations(self) -> list:
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['get-simulations']}"
# execução da consulta
return self.get_response("GET", url_service)
- linha 1: o método solicita a lista das simulações realizadas na sessão atual;
- linha 2: o método retorna a resposta do servidor;
[delete_simulation]
def delete_simulation(self, id: int) -> list:
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['delete-simulation']}/{id}"
# execução da solicitação
return self.get_response("GET", url_service)
- linha 1: o método exclui a simulação cujo identificador é passado;
- linha 7: retorna a resposta do servidor, a lista das simulações restantes após a exclusão solicitada;
[get-admindata]
def get_admindata(self) -> AdminData:
# permitimos que as exceções sejam propagadas
# URL do serviço
config_server = self.__config_server
url_service = f"{config_server['urlServer']}{self.__config_services['get-admindata']}"
# execução da consulta
résultat = self.get_response("GET", url_service)
# o resultado é um dicionário de valores do tipo str se for uma sessão XML
if self.__session_type == 'xml':
# novo dicionário
résultat2 = {}
# converte tudo para formato numérico
for key, value in résultat.items():
# alguns elementos do dicionário são listas
if isinstance(value, list):
values = []
for value2 in value:
values.append(float(value2))
résultat2[key] = values
else:
# outros são elementos simples
résultat2[key] = float(value)
else:
résultat2 = résultat
# resultado do tipo AdminData
return AdminData().fromdict(résultat2)
- linha 1: o método solicita ao servidor as constantes fiscais necessárias para o cálculo do imposto;
- linha 29: retorna um tipo [AdminData];
- linha 9: a resposta do servidor é recuperada na forma de um dicionário. Os testes mostram que há um problema quando a sessão é do tipo XML: em vez de serem valores numéricos, os valores do dicionário são cadeias de caracteres. Já havíamos relatado esse problema durante a análise do módulo [xmltodict] e constatado que se tratava de um comportamento normal. O [xmltodict] não possui informações de tipos no fluxo XML que lhe é fornecido. Dito isso, neste caso específico, é necessário converter em valores numéricos todos os valores do dicionário recebido. Este contém três listas [limites, coeffr, coeffn] e uma sequência de propriedades numéricas;
- linhas 13-25: criação de um dicionário [résultat2] com valores numéricos a partir do dicionário [résultat] com valores do tipo cadeia de caracteres;
- linha 29: o dicionário [resultat2] é utilizado para inicializar um tipo [AdminData];
31.2.3. A fábrica da camada [dao]
Nossos clientes serão multithread. Como a camada [dao] é implementada por uma classe com estado de leitura/gravação (= propriedades de leitura/gravação), cada thread deve ter sua própria camada [dao] ou, caso contrário, será necessário sincronizar o acesso aos dados compartilhados entre os threads. Aqui, optamos pela primeira solução. Utilizamos uma classe [ImpôtsDaoWithHttpSessionFactory] capaz de criar instâncias da camada [dao]:
from ImpôtsDaoWithHttpSession import ImpôtsDaoWithHttpSession
class ImpôtsDaoWithHttpSessionFactory:
def __init__(self, config: dict):
# o parâmetro é armazenado
self.__config = config
def new_instance(self):
# retorna-se uma instância da camada [dao]
return ImpôtsDaoWithHttpSession(self.__config)
31.3. Configuração dos clientes
Os clientes são configurados pelos arquivos [config] e [config_layers]. O arquivo [config] é o seguinte:
def configure(config: dict) -> dict:
import os
# etapa 1 ------
# pasta deste arquivo
script_dir = os.path.dirname(os.path.abspath(__file__))
# caminho raiz
root_dir = "C:/Data/st-2020/dev/python/cours-2020/python3-flask-2020"
# dependências absolutas
absolute_dependencies = [
# pastas do projeto
# BaseEntity, MyException
f"{root_dir}/classes/02/entities",
# InterfaceImpôtsDao, InterfaceImpôtsMétier, InterfaceImpôtsUi
f"{root_dir}/impots/v04/interfaces",
# AbstractImpôtsdao, ImpôtsConsole, ImpôtsMétier
f"{root_dir}/impots/v04/services",
# ImpotsDaoWithAdminDataInDatabase
f"{root_dir}/impots/v05/services",
# AdminData, ImpôtsError, TaxPayer
f"{root_dir}/impots/v04/entities",
# Constantes, faixas
f"{root_dir}/impots/v05/entities",
# ImpôtsDaoWithHttpSession, ImpôtsDaoWithHttpSessionFactory, InterfaceImpôtsDaoWithHttpSession
f"{script_dir}/../services",
# scripts de configuração
script_dir,
# Logger
f"{root_dir}/impots/http-servers/02/utilities",
]
# definimos o syspath
from myutils import set_syspath
set_syspath(absolute_dependencies)
# etapa 2 ------
# configuração do aplicativo com constantes
config.update({
# arquivo de contribuintes
"taxpayersFilename": f"{script_dir}/../data/input/taxpayersdata.txt",
# arquivo de resultados
"resultsFilename": f"{script_dir}/../data/output/résultats.json",
# arquivo de erros
"errorsFilename": f"{script_dir}/../data/output/errors.txt",
# arquivo de logs
"logsFilename": f"{script_dir}/../data/logs/logs.txt",
# servidor de cálculo de impostos
"server": {
"urlServer": "http://127.0.0.1:5000",
"user": {
"login": "admin",
"password": "admin"
},
"url_services": {
"calculate-tax": "/calculer-impot",
"get-admindata": "/get-admindata",
"calculate-tax-in-bulk-mode": "/calculer-impots",
"init-session": "/init-session",
"end-session": "/fin-session",
"authenticate-user": "/authentifier-utilisateur",
"get-simulations": "/lister-simulations",
"delete-simulation": "/supprimer-simulation"
}
},
# modo de depuração
"debug": True
}
)
# etapa 3 ------
# instanciação das camadas
import config_layers
config['layers'] = config_layers.configure(config)
# fazemos a configuração
return config
O arquivo [config_layers] é o seguinte:
def configure(config: dict) -> dict:
# instanciação das camadas do aplicativo
# camada [métier]
from ImpôtsMétier import ImpôtsMétier
métier = ImpôtsMétier()
# fábrica da camada DAO
from ImpôtsDaoWithHttpSessionFactory import ImpôtsDaoWithHttpSessionFactory
dao_factory = ImpôtsDaoWithHttpSessionFactory(config)
# fazemos a configuração das camadas
return {
"dao_factory": dao_factory,
"métier": métier
}
- os clientes não terão acesso direto à camada [dao]. Para obtê-lo, eles deverão passar pela fábrica da camada [dao];
31.4. O cliente [main]
O cliente [main] permite testar os URL e [/init-session, /authentifier-utilisateur, /calculer-impots, /fin-session]:
# espera-se um parâmetro JSON ou XML
import sys
syntaxe = f"{sys.argv[0]} json / xml"
erreur = len(sys.argv) != 2
if not erreur:
session_type = sys.argv[1].lower()
erreur = session_type != "json" and session_type != "xml"
if erreur:
print(f"syntaxe : {syntaxe}")
sys.exit()
# configurando o aplicativo
import config
config = config.configure({"session_type": session_type})
# dependências
from ImpôtsError import ImpôtsError
import random
import sys
import threading
from Logger import Logger
# execução da camada [dao] em um thread
# taxpayers é uma lista de contribuintes
def thread_function(config: dict, taxpayers: list):
# recupera-se a fábrica da camada [dao]
dao_factory = config['layers']['dao_factory']
# cria-se uma instância da camada [dao]
dao = dao_factory.new_instance()
# tipo da sessão
session_type = config['session_type']
# número de contribuintes
nb_taxpayers = len(taxpayers)
# log
logger.write(f"début du calcul de l'impôt des {nb_taxpayers} contribuables\n")
# inicializa-se a sessão
dao.init_session(session_type)
# autenticação
dao.authenticate_user(config['server']['user']['login'], config['server']['user']['password'])
# cálculo do imposto dos contribuintes
dao.calculate_tax_in_bulk_mode(taxpayers)
# fim da sessão
dao.end_session()
# registro
logger.write(f"fin du calcul de l'impôt des {nb_taxpayers} contribuables\n")
# lista de threads do cliente
threads = []
logger = None
# código
try:
# registrador
logger = Logger(config["logsFilename"])
# armazenado na configuração
config["logger"] = logger
# registro de início
logger.write("début du calcul de l'impôt des contribuables\n")
# recuperamos a fábrica da camada [dao]
dao_factory = config["layers"]["dao_factory"]
# cria-se uma instância da camada [dao]
dao = dao_factory.new_instance()
# leitura dos dados dos contribuintes
taxpayers = dao.get_taxpayers_data()["taxpayers"]
# dos contribuintes?
if not taxpayers:
raise ImpôtsError(36, f"Pas de contribuables valides dans le fichier {config['taxpayersFilename']}")
# cálculo do imposto dos contribuintes com várias threads
i = 0
l_taxpayers = len(taxpayers)
while i < len(taxpayers):
# cada thread processará de 1 a 4 contribuintes
nb_taxpayers = min(l_taxpayers - i, random.randint(1, 4))
# a lista de contribuintes processados pela thread
thread_taxpayers = taxpayers[slice(i, i + nb_taxpayers)]
# incrementa-se i para a próxima thread
i += nb_taxpayers
# cria-se o thread
thread = threading.Thread(target=thread_function, args=(config, thread_taxpayers))
# ele é adicionado à lista de threads do script principal
threads.append(thread)
# inicia-se a thread — essa operação é assíncrona — não se aguarda o resultado da thread
thread.start()
# o thread principal aguarda a conclusão de todos os threads que iniciou
for thread in threads:
thread.join()
# aqui, todas as threads concluíram seu trabalho — cada uma modificou um ou mais objetos [taxpayer]
# os resultados são gravados no arquivo jSON
dao.write_taxpayers_results(taxpayers)
# fim
except BaseException as erreur:
# exibição do erro
print(f"L'erreur suivante s'est produite : {erreur}")
finally:
# fecha-se o registrador
if logger:
# registro de encerramento
logger.write("fin du calcul de l'impôt des contribuables\n")
# fechamento do registrador
logger.close()
# concluído
print("Travail terminé...")
# encerramento dos threads que ainda possam existir caso a execução tenha sido interrompida devido a um erro
sys.exit()
- linhas 4-11: o cliente aguarda um parâmetro que indique o tipo de sessão, json ou xml, a ser usado com o servidor;
- linhas 13-15: o cliente está configurado;
- linhas 48-104: esse código é conhecido. Já foi utilizado inúmeras vezes. Ele distribui os contribuintes para os quais se deseja calcular o imposto por várias threads;
- linha 26: o método [thread_function] é o método executado por cada thread para calcular o imposto dos contribuintes que lhe foram atribuídos;
- linhas 27-30: cada thread possui sua própria camada [dao];
- o cálculo do imposto é feito em quatro etapas:
- linhas 37-38: inicialização de uma sessão, em JSON ou XML, com o servidor;
- linhas 39-40: autenticação junto ao servidor;
- linhas 41-42: cálculo do imposto;
- linhas 43-44: encerramento da sessão com o servidor;
Ao executar esse código no modo [json], obtêm-se os seguintes logs:
2020-08-03 14:28:34.320751, MainThread : début du calcul de l'impôt des contribuables
2020-08-03 14:28:34.328749, Thread-1 : début du calcul de l'impôt des 4 contribuables
2020-08-03 14:28:34.328749, Thread-2 : début du calcul de l'impôt des 4 contribuables
2020-08-03 14:28:34.333592, Thread-3 : début du calcul de l'impôt des 3 contribuables
2020-08-03 14:28:34.368651, Thread-2 : {"action": "init-session", "état": 700, "réponse": ["session démarrée avec le type de réponse json"]}
2020-08-03 14:28:34.375699, Thread-1 : {"action": "init-session", "état": 700, "réponse": ["session démarrée avec le type de réponse json"]}
2020-08-03 14:28:34.377432, Thread-3 : {"action": "init-session", "état": 700, "réponse": ["session démarrée avec le type de réponse json"]}
2020-08-03 14:28:34.385653, Thread-2 : {"action": "authentifier-utilisateur", "état": 200, "réponse": "Authentification réussie"}
2020-08-03 14:28:34.392656, Thread-1 : {"action": "authentifier-utilisateur", "état": 200, "réponse": "Authentification réussie"}
2020-08-03 14:28:34.396377, Thread-3 : {"action": "authentifier-utilisateur", "état": 200, "réponse": "Authentification réussie"}
2020-08-03 14:28:34.406528, Thread-2 : {"action": "calculer-impots", "état": 1500, "réponse": [{"marié": "non", "enfants": 3, "salaire": 100000, "impôt": 16782, "surcôte": 7176, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 1}, {"marié": "oui", "enfants": 3, "salaire": 100000, "impôt": 9200, "surcôte": 2180, "taux": 0.3, "décôte": 0, "réduction": 0, "id": 2}, {"marié": "oui", "enfants": 5, "salaire": 100000, "impôt": 4230, "surcôte": 0, "taux": 0.14, "décôte": 0, "réduction": 0, "id": 3}, {"marié": "non", "enfants": 0, "salaire": 100000, "impôt": 22986, "surcôte": 0, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 4}]}
2020-08-03 14:28:34.413837, Thread-1 : {"action": "calculer-impots", "état": 1500, "réponse": [{"marié": "oui", "enfants": 2, "salaire": 55555, "impôt": 2814, "surcôte": 0, "taux": 0.14, "décôte": 0, "réduction": 0, "id": 1}, {"marié": "oui", "enfants": 2, "salaire": 50000, "impôt": 1384, "surcôte": 0, "taux": 0.14, "décôte": 384, "réduction": 347, "id": 2}, {"marié": "oui", "enfants": 3, "salaire": 50000, "impôt": 0, "surcôte": 0, "taux": 0.14, "décôte": 720, "réduction": 0, "id": 3}, {"marié": "non", "enfants": 2, "salaire": 100000, "impôt": 19884, "surcôte": 4480, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 4}]}
2020-08-03 14:28:34.416695, Thread-3 : {"action": "calculer-impots", "état": 1500, "réponse": [{"marié": "oui", "enfants": 2, "salaire": 30000, "impôt": 0, "surcôte": 0, "taux": 0.0, "décôte": 0, "réduction": 0, "id": 1}, {"marié": "non", "enfants": 0, "salaire": 200000, "impôt": 64210, "surcôte": 7498, "taux": 0.45, "décôte": 0, "réduction": 0, "id": 2}, {"marié": "oui", "enfants": 3, "salaire": 200000, "impôt": 42842, "surcôte": 17283, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 3}]}
2020-08-03 14:28:34.425747, Thread-2 : {"action": "fin-session", "état": 400, "réponse": "session réinitialisée"}
2020-08-03 14:28:34.425747, Thread-2 : fin du calcul de l'impôt des 4 contribuables
2020-08-03 14:28:34.428956, Thread-1 : {"action": "fin-session", "état": 400, "réponse": "session réinitialisée"}
2020-08-03 14:28:34.428956, Thread-1 : fin du calcul de l'impôt des 4 contribuables
2020-08-03 14:28:34.428956, Thread-3 : {"action": "fin-session", "état": 400, "réponse": "session réinitialisée"}
2020-08-03 14:28:34.428956, Thread-3 : fin du calcul de l'impôt des 3 contribuables
2020-08-03 14:28:34.428956, MainThread : fin du calcul de l'impôt des contribuables
Acima, vemos o percurso da thread [Thread-2].
Se executarmos [main] no modo XML, os logs serão os seguintes:
2020-08-03 14:32:48.495316, MainThread : début du calcul de l'impôt des contribuables
2020-08-03 14:32:48.496452, Thread-1 : début du calcul de l'impôt des 2 contribuables
2020-08-03 14:32:48.498992, Thread-2 : début du calcul de l'impôt des 2 contribuables
2020-08-03 14:32:48.498992, Thread-3 : début du calcul de l'impôt des 4 contribuables
2020-08-03 14:32:48.498992, Thread-4 : début du calcul de l'impôt des 3 contribuables
2020-08-03 14:32:48.538637, Thread-1 : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
2020-08-03 14:32:48.540783, Thread-4 : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
2020-08-03 14:32:48.547811, Thread-3 : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
2020-08-03 14:32:48.547811, Thread-2 : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
2020-08-03 14:32:48.555184, Thread-1 : <?xml version="1.0" encoding="utf-8"?>
<root><action>authentifier-utilisateur</action><état>200</état><réponse>Authentification réussie</réponse></root>
2020-08-03 14:32:48.564793, Thread-2 : <?xml version="1.0" encoding="utf-8"?>
<root><action>authentifier-utilisateur</action><état>200</état><réponse>Authentification réussie</réponse></root>
2020-08-03 14:32:48.564793, Thread-3 : <?xml version="1.0" encoding="utf-8"?>
<root><action>authentifier-utilisateur</action><état>200</état><réponse>Authentification réussie</réponse></root>
2020-08-03 14:32:48.568333, Thread-4 : <?xml version="1.0" encoding="utf-8"?>
<root><action>authentifier-utilisateur</action><état>200</état><réponse>Authentification réussie</réponse></root>
2020-08-03 14:32:48.568333, Thread-1 : <?xml version="1.0" encoding="utf-8"?>
<root><action>calculer-impots</action><état>1500</état><réponse><marié>oui</marié><enfants>2</enfants><salaire>55555</salaire><impôt>2814</impôt><surcôte>0</surcôte><taux>0.14</taux><décôte>0</décôte><réduction>0</réduction><id>1</id></réponse><réponse><marié>oui</marié><enfants>2</enfants><salaire>50000</salaire><impôt>1384</impôt><surcôte>0</surcôte><taux>0.14</taux><décôte>384</décôte><réduction>347</réduction><id>2</id></réponse></root>
2020-08-03 14:32:48.579205, Thread-2 : <?xml version="1.0" encoding="utf-8"?>
<root><action>calculer-impots</action><état>1500</état><réponse><marié>oui</marié><enfants>3</enfants><salaire>50000</salaire><impôt>0</impôt><surcôte>0</surcôte><taux>0.14</taux><décôte>720</décôte><réduction>0</réduction><id>1</id></réponse><réponse><marié>non</marié><enfants>2</enfants><salaire>100000</salaire><impôt>19884</impôt><surcôte>4480</surcôte><taux>0.41</taux><décôte>0</décôte><réduction>0</réduction><id>2</id></réponse></root>
2020-08-03 14:32:48.579205, Thread-3 : <?xml version="1.0" encoding="utf-8"?>
<root><action>calculer-impots</action><état>1500</état><réponse><marié>non</marié><enfants>3</enfants><salaire>100000</salaire><impôt>16782</impôt><surcôte>7176</surcôte><taux>0.41</taux><décôte>0</décôte><réduction>0</réduction><id>1</id></réponse><réponse><marié>oui</marié><enfants>3</enfants><salaire>100000</salaire><impôt>9200</impôt><surcôte>2180</surcôte><taux>0.3</taux><décôte>0</décôte><réduction>0</réduction><id>2</id></réponse><réponse><marié>oui</marié><enfants>5</enfants><salaire>100000</salaire><impôt>4230</impôt><surcôte>0</surcôte><taux>0.14</taux><décôte>0</décôte><réduction>0</réduction><id>3</id></réponse><réponse><marié>non</marié><enfants>0</enfants><salaire>100000</salaire><impôt>22986</impôt><surcôte>0</surcôte><taux>0.41</taux><décôte>0</décôte><réduction>0</réduction><id>4</id></réponse></root>
2020-08-03 14:32:48.588051, Thread-4 : <?xml version="1.0" encoding="utf-8"?>
<root><action>calculer-impots</action><état>1500</état><réponse><marié>oui</marié><enfants>2</enfants><salaire>30000</salaire><impôt>0</impôt><surcôte>0</surcôte><taux>0.0</taux><décôte>0</décôte><réduction>0</réduction><id>1</id></réponse><réponse><marié>non</marié><enfants>0</enfants><salaire>200000</salaire><impôt>64210</impôt><surcôte>7498</surcôte><taux>0.45</taux><décôte>0</décôte><réduction>0</réduction><id>2</id></réponse><réponse><marié>oui</marié><enfants>3</enfants><salaire>200000</salaire><impôt>42842</impôt><surcôte>17283</surcôte><taux>0.41</taux><décôte>0</décôte><réduction>0</réduction><id>3</id></réponse></root>
2020-08-03 14:32:48.594058, Thread-1 : <?xml version="1.0" encoding="utf-8"?>
<root><action>fin-session</action><état>400</état><réponse>session réinitialisée</réponse></root>
2020-08-03 14:32:48.595198, Thread-1 : fin du calcul de l'impôt des 2 contribuables
2020-08-03 14:32:48.595198, Thread-2 : <?xml version="1.0" encoding="utf-8"?>
<root><action>fin-session</action><état>400</état><réponse>session réinitialisée</réponse></root>
2020-08-03 14:32:48.595198, Thread-2 : fin du calcul de l'impôt des 2 contribuables
2020-08-03 14:32:48.595198, Thread-3 : <?xml version="1.0" encoding="utf-8"?>
<root><action>fin-session</action><état>400</état><réponse>session réinitialisée</réponse></root>
2020-08-03 14:32:48.595198, Thread-3 : fin du calcul de l'impôt des 4 contribuables
2020-08-03 14:32:48.603351, Thread-4 : <?xml version="1.0" encoding="utf-8"?>
<root><action>fin-session</action><état>400</état><réponse>session réinitialisée</réponse></root>
2020-08-03 14:32:48.603351, Thread-4 : fin du calcul de l'impôt des 3 contribuables
2020-08-03 14:32:48.603351, MainThread : fin du calcul de l'impôt des contribuables
Acima, o percurso do thread [Thread-2].
31.5. O cliente [main2]
O cliente [main2] permite testar os URL e [/init-session, /authentifier-utilisateur, /get-admindata, /fin-session]:
# aguardando um parâmetro JSON ou XML
import sys
syntaxe = f"{sys.argv[0]} json / xml"
erreur = len(sys.argv) != 2
if not erreur:
session_type = sys.argv[1].lower()
erreur = session_type != "json" and session_type != "xml"
if erreur:
print(f"syntaxe : {syntaxe}")
sys.exit()
# configurando o aplicativo
import config
config = config.configure({"session_type": session_type})
# dependências
from ImpôtsError import ImpôtsError
from Logger import Logger
logger = None
# código
try:
# registrador
logger = Logger(config["logsFilename"])
# armazenando na configuração
config["logger"] = logger
# log de início
logger.write("début du calcul de l'impôt des contribuables\n")
# recuperamos a fábrica da camada [dao]
dao_factory = config['layers']['dao_factory']
# cria-se uma instância da camada [dao]
dao = dao_factory.new_instance()
# recupera-se os contribuintes
taxpayers = dao.get_taxpayers_data()["taxpayers"]
# dos contribuintes?
if not taxpayers:
raise ImpôtsError(36, f"Pas de contribuables valides dans le fichier {config['taxpayersFilename']}")
# tipo da sessão
session_type = config['session_type']
# inicializa-se a sessão
dao.init_session(session_type)
# autenticação
dao.authenticate_user(config['server']['user']['login'], config['server']['user']['password'])
# recuperando os dados da administração fiscal
admindata = dao.get_admindata()
# fim da sessão
dao.end_session()
# cálculo do imposto dos contribuintes pela camada [métier]
métier = config['layers']['métier']
for taxpayer in taxpayers:
métier.calculate_tax(taxpayer, admindata)
# os resultados são gravados no arquivo jSON
dao.write_taxpayers_results(taxpayers)
except BaseException as erreur:
# exibição do erro
print(f"L'erreur suivante s'est produite : {erreur}")
finally:
# fecha-se o registrador
if logger:
# registro de encerramento
logger.write("fin du calcul de l'impôt des contribuables\n")
# encerramento do registrador
logger.close()
# concluído
print("Travail terminé...")
- linhas 1-11: recupera-se o parâmetro [json, xml], que define o tipo de sessão a ser estabelecida com o servidor;
- linhas 13-15: configura-se o cliente;
- linhas 30-33: cria-se uma camada [dao];
- linhas 34-35: com ela, recupera-se a lista de contribuintes para os quais é necessário calcular o imposto;
- em seguida, ocorrem as quatro etapas do diálogo com o servidor;
- linhas 41-42: inicia-se uma sessão com o servidor;
- linhas 43-44: realiza-se a autenticação junto ao servidor;
- linhas 45-46: solicitam-se ao servidor as constantes fiscais necessárias para o cálculo do imposto;
- linhas 47-48: encerra-se a sessão com o servidor;
- linhas 49-52: com essas constantes, é possível calcular o imposto dos contribuintes por meio da camada [métier] local no cliente;
- linhas 53-54: registram-se os resultados obtidos;
Para uma sessão XML, os resultados são os seguintes:
2020-08-03 14:44:43.194294, MainThread : début du calcul de l'impôt des contribuables
2020-08-03 14:44:43.231633, MainThread : <?xml version="1.0" encoding="utf-8"?>
<root><action>init-session</action><état>700</état><réponse>session démarrée avec le type de réponse xml</réponse></root>
2020-08-03 14:44:43.240872, MainThread : <?xml version="1.0" encoding="utf-8"?>
<root><action>authentifier-utilisateur</action><état>200</état><réponse>Authentification réussie</réponse></root>
2020-08-03 14:44:43.250061, MainThread : <?xml version="1.0" encoding="utf-8"?>
<root><action>get-admindata</action><état>1000</état><réponse><limites>9964.0</limites><limites>27519.0</limites><limites>73779.0</limites><limites>156244.0</limites><limites>93749.0</limites><coeffr>0.0</coeffr><coeffr>0.14</coeffr><coeffr>0.3</coeffr><coeffr>0.41</coeffr><coeffr>0.45</coeffr><coeffn>0.0</coeffn><coeffn>1394.96</coeffn><coeffn>5798.0</coeffn><coeffn>13913.7</coeffn><coeffn>20163.4</coeffn><abattement_dixpourcent_min>437.0</abattement_dixpourcent_min><plafond_impot_couple_pour_decote>2627.0</plafond_impot_couple_pour_decote><plafond_decote_couple>1970.0</plafond_decote_couple><valeur_reduc_demi_part>3797.0</valeur_reduc_demi_part><plafond_revenus_celibataire_pour_reduction>21037.0</plafond_revenus_celibataire_pour_reduction><id>1</id><abattement_dixpourcent_max>12502.0</abattement_dixpourcent_max><plafond_impot_celibataire_pour_decote>1595.0</plafond_impot_celibataire_pour_decote><plafond_decote_celibataire>1196.0</plafond_decote_celibataire><plafond_revenus_couple_pour_reduction>42074.0</plafond_revenus_couple_pour_reduction><plafond_qf_demi_part>1551.0</plafond_qf_demi_part></réponse></root>
2020-08-03 14:44:43.269850, MainThread : <?xml version="1.0" encoding="utf-8"?>
<root><action>fin-session</action><état>400</état><réponse>session réinitialisée</réponse></root>
2020-08-03 14:44:43.269850, MainThread : fin du calcul de l'impôt des contribuables
31.6. O cliente [main3]
O cliente [main3] permite testar os URL e [/init-session, /calculer-impots, /get-simulations, /delete-simulation, /fin-session]:
# aguardando um parâmetro JSON ou XML
import sys
syntaxe = f"{sys.argv[0]} json / xml"
erreur = len(sys.argv) != 2
if not erreur:
session_type = sys.argv[1].lower()
erreur = session_type != "json" and session_type != "xml"
if erreur:
print(f"syntaxe : {syntaxe}")
sys.exit()
# configurando o aplicativo
import config
config = config.configure({"session_type": session_type})
# dependências
from ImpôtsError import ImpôtsError
import sys
from Logger import Logger
logger = None
# código
try:
# registrador
logger = Logger(config["logsFilename"])
# armazenando na configuração
config["logger"] = logger
# log de início
logger.write("début du calcul de l'impôt des contribuables\n")
# recuperamos a fábrica da camada [dao]
dao_factory = config["layers"]["dao_factory"]
# cria-se uma instância da camada [dao]
dao = dao_factory.new_instance()
# leitura dos dados dos contribuintes
taxpayers = dao.get_taxpayers_data()["taxpayers"]
# dos contribuintes?
if not taxpayers:
raise ImpôtsError(36, f"Pas de contribuables valides dans le fichier {config['taxpayersFilename']}")
# cálculo do imposto dos contribuintes
# número de contribuintes
nb_taxpayers = len(taxpayers)
# registro
logger.write(f"début du calcul de l'impôt des {nb_taxpayers} contribuables\n")
# inicializa-se a sessão
dao.init_session(session_type)
# autenticação
dao.authenticate_user(config['server']['user']['login'], config['server']['user']['password'])
# cálculo do imposto dos contribuintes
dao.calculate_tax_in_bulk_mode(taxpayers)
# solicita-se a lista de simulações
simulations = dao.get_simulations()
# elimina-se uma em cada duas
for i in range(len(simulations)):
if i % 2 == 0:
# elimina-se a simulação
dao.delete_simulation(simulations[i]['id'])
# fim da sessão
dao.end_session()
# consulte os logs para ver os diferentes resultados (modo debug=True)
except BaseException as erreur:
# exibição do erro
print(f"L'erreur suivante s'est produite : {erreur}")
finally:
# encerrando o registrador de logs
if logger:
# log de encerramento
logger.write("fin du calcul de l'impôt des contribuables\n")
# encerramento do registrador
logger.close()
# concluído
print("Travail terminé...")
- linhas 1-11: obtém-se o tipo da sessão nos parâmetros do script;
- linhas 13-15: configura-se o aplicativo;
- linhas 25-50: encontramos código já explicado em algum momento;
- linhas 51-52: solicita-se a lista das simulações realizadas na sessão atual;
- linhas 53-57: exclui-se uma em cada duas simulações;
- linhas 58-59: encerra-se a sessão;
Durante uma sessão jSON, os logs são os seguintes:
2020-08-03 15:01:52.702297, MainThread : début du calcul de l'impôt des contribuables
2020-08-03 15:01:52.702297, MainThread : début du calcul de l'impôt des 11 contribuables
2020-08-03 15:01:52.734806, MainThread : {"action": "init-session", "état": 700, "réponse": ["session démarrée avec le type de réponse json"]}
2020-08-03 15:01:52.747961, MainThread : {"action": "authentifier-utilisateur", "état": 200, "réponse": "Authentification réussie"}
2020-08-03 15:01:52.765721, MainThread : {"action": "calculer-impots", "état": 1500, "réponse": [{"marié": "oui", "enfants": 2, "salaire": 55555, "impôt": 2814, "surcôte": 0, "taux": 0.14, "décôte": 0, "réduction": 0, "id": 1}, {"marié": "oui", "enfants": 2, "salaire": 50000, "impôt": 1384, "surcôte": 0, "taux": 0.14, "décôte": 384, "réduction": 347, "id": 2}, {"marié": "oui", "enfants": 3, "salaire": 50000, "impôt": 0, "surcôte": 0, "taux": 0.14, "décôte": 720, "réduction": 0, "id": 3}, {"marié": "non", "enfants": 2, "salaire": 100000, "impôt": 19884, "surcôte": 4480, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 4}, {"marié": "non", "enfants": 3, "salaire": 100000, "impôt": 16782, "surcôte": 7176, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 5}, {"marié": "oui", "enfants": 3, "salaire": 100000, "impôt": 9200, "surcôte": 2180, "taux": 0.3, "décôte": 0, "réduction": 0, "id": 6}, {"marié": "oui", "enfants": 5, "salaire": 100000, "impôt": 4230, "surcôte": 0, "taux": 0.14, "décôte": 0, "réduction": 0, "id": 7}, {"marié": "non", "enfants": 0, "salaire": 100000, "impôt": 22986, "surcôte": 0, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 8}, {"marié": "oui", "enfants": 2, "salaire": 30000, "impôt": 0, "surcôte": 0, "taux": 0.0, "décôte": 0, "réduction": 0, "id": 9}, {"marié": "non", "enfants": 0, "salaire": 200000, "impôt": 64210, "surcôte": 7498, "taux": 0.45, "décôte": 0, "réduction": 0, "id": 10}, {"marié": "oui", "enfants": 3, "salaire": 200000, "impôt": 42842, "surcôte": 17283, "taux": 0.41, "décôte": 0, "réduction": 0, "id": 11}]}
2020-08-03 15:01:52.785505, MainThread : {"action": "lister-simulations", "état": 500, "réponse": [{"décôte": 0, "enfants": 2, "id": 1, "impôt": 2814, "marié": "oui", "réduction": 0, "salaire": 55555, "surcôte": 0, "taux": 0.14}, {"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 720, "enfants": 3, "id": 3, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 5, "impôt": 16782, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 7176, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 5, "id": 7, "impôt": 4230, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 2, "id": 9, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 30000, "surcôte": 0, "taux": 0.0}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.801475, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 720, "enfants": 3, "id": 3, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 5, "impôt": 16782, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 7176, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 5, "id": 7, "impôt": 4230, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 2, "id": 9, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 30000, "surcôte": 0, "taux": 0.0}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.810129, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 5, "impôt": 16782, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 7176, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 5, "id": 7, "impôt": 4230, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 2, "id": 9, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 30000, "surcôte": 0, "taux": 0.0}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.818803, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 5, "id": 7, "impôt": 4230, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 2, "id": 9, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 30000, "surcôte": 0, "taux": 0.0}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.834604, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 2, "id": 9, "impôt": 0, "marié": "oui", "réduction": 0, "salaire": 30000, "surcôte": 0, "taux": 0.0}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.843803, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}, {"décôte": 0, "enfants": 3, "id": 11, "impôt": 42842, "marié": "oui", "réduction": 0, "salaire": 200000, "surcôte": 17283, "taux": 0.41}]}
2020-08-03 15:01:52.851855, MainThread : {"action": "supprimer-simulation", "état": 600, "réponse": [{"décôte": 384, "enfants": 2, "id": 2, "impôt": 1384, "marié": "oui", "réduction": 347, "salaire": 50000, "surcôte": 0, "taux": 0.14}, {"décôte": 0, "enfants": 2, "id": 4, "impôt": 19884, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 4480, "taux": 0.41}, {"décôte": 0, "enfants": 3, "id": 6, "impôt": 9200, "marié": "oui", "réduction": 0, "salaire": 100000, "surcôte": 2180, "taux": 0.3}, {"décôte": 0, "enfants": 0, "id": 8, "impôt": 22986, "marié": "non", "réduction": 0, "salaire": 100000, "surcôte": 0, "taux": 0.41}, {"décôte": 0, "enfants": 0, "id": 10, "impôt": 64210, "marié": "non", "réduction": 0, "salaire": 200000, "surcôte": 7498, "taux": 0.45}]}
2020-08-03 15:01:52.863165, MainThread : {"action": "fin-session", "état": 400, "réponse": "session réinitialisée"}
2020-08-03 15:01:52.863165, MainThread : fin du calcul de l'impôt des contribuables
- linha 6: temos 11 simulações;
- linha 12: após as diversas exclusões, restam apenas 5;
31.7. A classe de teste [Test2HttpClientDaoWithSession]
A classe [Test2HttpClientDaoWithSession] testa a camada [dao] dos clientes da seguinte maneira:
import unittest
from ImpôtsError import ImpôtsError
from Logger import Logger
from TaxPayer import TaxPayer
class Test2HttpClientDaoWithSession(unittest.TestCase):
def test_init_session_json(self) -> None:
print('test_init_session_json')
erreur = False
try:
dao.init_session('json')
except ImpôtsError as ex:
print(ex)
erreur = True
# não deve haver erros
self.assertFalse(erreur)
def test_init_session_xml(self) -> None:
print('test_init_session_xml')
erreur = False
try:
dao.init_session('xml')
except ImpôtsError as ex:
print(ex)
erreur = True
# não deve haver erros
self.assertFalse(erreur)
def test_init_session_xxx(self) -> None:
print('test_init_session_xxx')
erreur = False
try:
dao.init_session('xxx')
except ImpôtsError as ex:
print(ex)
erreur = True
# deve haver um erro
self.assertTrue(erreur)
def test_authenticate_user_success(self) -> None:
print('test_authenticate_user_success')
# inicializar sessão
dao.init_session('json')
# teste
erreur = False
try:
dao.authenticate_user(config['server']['user']['login'], config['server']['user']['password'])
except ImpôtsError as ex:
print(ex)
erreur = True
# não deve haver erro
self.assertFalse(erreur)
def test_authenticate_user_failed(self) -> None:
print('test_authenticate_user_failed')
# inicialização da sessão
dao.init_session('json')
# teste
erreur = False
try:
dao.authenticate_user('x', 'y')
except ImpôtsError as ex:
print(ex)
erreur = True
# deve haver um erro
self.assertTrue(erreur)
def test_get_simulations(self) -> None:
print('test_get_simulations')
# inicialização da sessão
dao.init_session('json')
# autenticação
dao.authenticate_user('admin', 'admin')
# cálculo de imposto
# {'casado': 'sim', 'filhos': 2, 'salário': 55555,
# 'imposto': 2814, 'sobretaxa': 0, 'abatimento': 0, 'redução': 0, 'alíquota': 0,14}
taxpayer = TaxPayer().fromdict({"marié": "oui", "enfants": 2, "salaire": 55555})
dao.calculate_tax(taxpayer)
# get_simulations
simulations = dao.get_simulations()
# verificações
# deve haver 1 simulação
self.assertEqual(1, len(simulations))
simulation = simulations[0]
# verificação do imposto calculado
self.assertAlmostEqual(simulation['impôt'], 2815, delta=1)
self.assertEqual(simulation['décôte'], 0)
self.assertEqual(simulation['réduction'], 0)
self.assertAlmostEqual(simulation['taux'], 0.14, delta=0.01)
self.assertEqual(simulation['surcôte'], 0)
def test_delete_simulation(self) -> None:
print('test_delete_simulation')
# inicialização da sessão
dao.init_session('json')
# autenticação
dao.authenticate_user('admin', 'admin')
# cálculo do imposto
taxpayer = TaxPayer().fromdict({"marié": "oui", "enfants": 2, "salaire": 55555})
dao.calculate_tax(taxpayer)
# get_simulations
simulations = dao.get_simulations()
# delete_simulation
dao.delete_simulation(simulations[0]['id'])
# get_simulations
simulations = dao.get_simulations()
# verificação — não deve haver mais simulações
self.assertEqual(0, len(simulations))
# estamos excluindo uma simulação que não existe
erreur = False
try:
dao.delete_simulation(100)
except ImpôtsError as ex:
print(ex)
erreur = True
# deve haver um erro
self.assertTrue(erreur)
if __name__ == '__main__':
# configurando o aplicativo
import config
config = config.configure({})
# registrar
logger = Logger(config["logsFilename"])
# armazenando na configuração
config["logger"] = logger
# camada [dao]
dao_factory = config['layers']['dao_factory']
dao = dao_factory.new_instance()
# executa-se os métodos de teste
print("tests en cours...")
unittest.main()
- a camada [dao] envia uma solicitação ao servidor, recebe sua resposta e a formata para devolvê-la ao código chamador. Quando o servidor envia uma resposta com um código de status diferente de 200, a camada [dao] lança uma exceção. Além disso, uma série de testes visa verificar se houve ou não uma exceção;
- linhas 9-18: inicializa-se uma sessão jSON. Não deve ocorrer nenhum erro;
- linhas 20-29: inicializa-se uma sessão XML. Não deve ocorrer nenhum erro;
- linhas 31-40: inicializa-se uma sessão com um tipo incorreto. Deve ocorrer um erro;
- linhas 42-54: realiza-se a autenticação com as credenciais corretas. Não deve ocorrer nenhum erro;
- linhas 56-68: autentica-se com credenciais incorretas. Deve ocorrer um erro;
- linhas 70-92: faz-se um cálculo de imposto e, em seguida, solicita-se a lista de simulações. Deve haver uma. Além disso, verifica-se se essa simulação contém de fato o imposto solicitado;
- linhas 94-119: faz-se uma simulação que é excluída em seguida. Depois, tenta-se excluir uma simulação quando já não há nenhuma. Deve ocorrer um erro;
- linhas 121-137: o teste é executado como um script de console clássico;
- linhas 122-124: configuramos o aplicativo;
- linhas 126-129: configuramos o logger. Isso nos permitirá acompanhar os logs;
- linhas 131-133: instanciamos a camada [dao] que será testada;
- linhas 135-137: executamos os testes;
Os resultados na console são os seguintes:
C:\Data\st-2020\dev\python\cours-2020\python3-flask-2020\venv\Scripts\python.exe C:/Data/st-2020/dev/python/cours-2020/python3-flask-2020/impots/http-clients/07/tests/Test2HttpClientDaoWithSession.py
tests en cours...
test_authenticate_user_failed
..MyException[35, ["Echec de l'authentification"]]
test_authenticate_user_success
test_delete_simulation
MyException[35, ["la simulation n° [100] n'existe pas"]]
test_get_simulations
test_init_session_json
test_init_session_xml
test_init_session_xxx
MyException[73, il n'y a pas de session valide en cours]
----------------------------------------------------------------------
Ran 7 tests in 0.171s
OK
Process finished with exit code 0