~jJrdZddlmZddlZddlmcmZddl Z ddl m Z ddl Z dd Z d Zd Zd Zd ZdZdS)zAutomated Architecture Boundary Enforcement & DDD Conformance Suite. Enforces Hexagonal Architecture (Ports & Adapters) and Domain-Driven Design boundaries. ) annotationsN)Path directoryrreturn list[Path]c@d|dDS)Nc$g|] }d|jv |S) __pycache__parts.0ps BC:\Projects\DSCons\tests\test_architecture_boundary_enforcement.py z(get_all_python_files.. s$ O O O!-qw2N2NA2N2N2N*.py)rglob)rs rget_all_python_filesr s" O Oyv.. O O OOrc(td}t|}ddg}g}|D]S}d|vr|d}|D]!}||vr||d|d"T| }|st jd d |zd zd d tj vst j |rt j |nd iz}tt j |d}dS)zRVerify no module calls external LLM REST endpoints directly, bypassing AI Gateway. app/modulesz-https://openrouter.ai/api/v1/chat/completionsz)https://generativelanguage.googleapis.comz"app/modules/agents/application/llmutf-8encodingz: Found direct LLM URL ''z#Architectural violations detected:   >assert not %(py0)spy0 violationsN)rras_posix read_textappend @pytest_ar_format_assertmsgjoin @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanation) modules_dirpy_filesforbidden_patternsr file_pathcontentpattern @py_assert1 @py_format2s r)test_zero_direct_llm_api_calls_in_modulesr4s^}%%K#K00H 83 JTT /93E3E3G3G G G %%w%77) T TG'!!!!Y"R"R"R"R"RSSS T>Z>ZZZBTYYzEZEZZZZZZZZZZZZZZZZzZZZZZzZZZZZZZZZZZZZZZZZZZZrc:dtddD}gd}g}|D]N}|d}|D]!}||vr||d|d"O| }|st jd d |zd zd d tj vst j |rt j |nd iz}tt j |d}dS)zRVerify presentation layer contains zero raw DDL (CREATE/ALTER/DROP TABLE) queries.c6g|]}d|jv d|jv|S presentationr r r s rrz;test_zero_raw_ddl_in_presentation_layer..); QW $ $ag)E)E )E)E)Errr)z CREATE TABLEz ALTER TABLEz DROP TABLErrz: Found raw DDL keyword '' in presentation layerz%Raw DDL found in presentation layer: rrrrN)rrr!upperr"r#r$r%r&r'r(r)r*r+)presentation_files ddl_keywordsrr/r0kwr2r3s r'test_zero_raw_ddl_in_presentation_layerr?'sf &&,,V44 A@@LJ'ff %%w%77==?? f fBW}}!!Y"d"d"d"d"deee f>\>\\\DtyyQ[G\G\\\\\\\\\\\\\\\\z\\\\\z\\\\\\\\\\\\\\\\\\\\rcdtddD}g}ddg}|D]<}|d}|D]!}||vr||d|d "=| }|st jd d |zd zd dtjvst j |rt j |ndiz}tt j |d}dS)zZVerify presentation layer contains zero raw SQL executions (cursor.execute / cur.execute).c6g|]}d|jv d|jv|Sr7r r s rrz;test_zero_raw_sql_in_presentation_layer..<r9rrrzcursor.execute(z cur.execute(rrz: Found raw SQL execution 'r:zCRaw SQL executions found in presentation layer (Rule 6 violation): rrrrN) rrr!r"r#r$r%r&r'r(r)r*r+)r<rsql_exec_patternsr/r0r1r2r3s r'test_zero_raw_sql_in_presentation_layerrC:s^ &&,,V44 J*N;'mm %%w%77( m mG'!!!!Y"k"k7"k"k"klll m>z>zzzbeienenoyezezzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzrc V tdtdtdtdtdtdtdg}hd}g}|D]"}|st|D]}tj|d t | }tj|D] t tj r4 j D]+}|j |vr | |d |j d ,Pt tj rB jr;t fd|Dr | |d jd $| }|st!jdd|zdzddt'jvst!j|rt!j|ndiz}t/t!j|d}dS)z`Verify application & domain layers in operations and zalo_crm do not import direct HTTP clients.z"app/modules/operations/applicationzapp/modules/operations/domainz app/modules/zalo_crm/applicationzapp/modules/zalo_crm/domainz app/modules/invoices/applicationzapp/modules/invoices/domainzapp/modules/core/domain>urllib.requesthttpxrequestsrr)filenamez: Illegal direct import 'rc3hK|],}j|kpj|dV-dS).N)module startswith)rmodnodes r z@test_application_and_domain_network_isolation..hsb+A+Agj4;#+=+bAWAW[^XaXaXaAbAb+A+A+A+A+A+Arz: Illegal from-import 'z;Network isolation violations in domain/application layers: rrrrN)rexistsrastparser!strwalk isinstanceImportnamesnamer" ImportFromrKanyr#r$r%r&r'r(r)r*r+) target_dirsforbidden_modulesrbase_dirr/treealiasr2r3rNs @r-test_application_and_domain_network_isolationr`Ns 122 ,-- /00 *++ /00 *++ &''K@??J _ _    -h77 _ _I9Y00'0BBSQZ^^\\\D _ _dCJ//_!%dd :):::&--.b.bUZU_.b.b.bcccd cn55_{_s+A+A+A+An+A+A+A(A(A_"))Y*]*]t{*]*]*]^^^ _ _>r>rrrZ]a]f]fgq]r]rrrrrrrrrrrrrrrrzrrrrrzrrrrrrrrrrrrrrrrrrrrrcjddlm}ddlm}g}t ||}|}|sd}t ||}|}|sddt jvstj trtj tnddt jvstj |rtj |nddt jvstj |rtj |ndtj |d z}| ||sd d t jvstj t rtj t nd dt jvstj |rtj |ndtj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}ddlm} ddlm} g}t | | }|}|sd}t | |}|}|sddt jvstj trtj tnddt jvstj | rtj | nddt jvstj | rtj | ndtj |d z}| ||sd d t jvstj t rtj t nd dt jvstj | rtj | ndtj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}ddlm} ddlm}g}t || }|}|sd}t ||}|}|sddt jvstj trtj tnddt jvstj |rtj |nddt jvstj | rtj | ndtj |d z}| ||sd d t jvstj t rtj t nd dt jvstj |rtj |ndtj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}ddlm}ddlm}g}t ||}|}|sd}t ||}|}|sddt jvstj trtj tnddt jvstj |rtj |nddt jvstj |rtj |ndtj |d z}| ||sd d t jvstj t rtj t nd dt jvstj |rtj |ndtj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}ddlm}dd lm}g}t ||}|}|sd!}t ||}|}|sddt jvstj trtj tndd"t jvstj |rtj |nd"d#t jvstj |rtj |nd#tj |d z}| ||sd d t jvstj t rtj t nd d"t jvstj |rtj |nd"tj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}dd$lm }dd%l!m"}g}t ||}|}|sd&}t ||}|}|sddt jvstj trtj tndd't jvstj |rtj |nd'd(t jvstj |rtj |nd(tj |d z}| ||sd d t jvstj t rtj t nd d't jvstj |rtj |nd'tj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}dd)l#m$}dd*l%m&}g}t ||}|}|sd+}t ||}|}|sddt jvstj trtj tndd,t jvstj |rtj |nd,d-t jvstj |rtj |nd-tj |d z}| ||sd d t jvstj t rtj t nd d,t jvstj |rtj |nd,tj |tj |d z}| |tj |d iz} dd| iz} ttj| dx}x}x}x}}dS).zcVerify all domain ports and infrastructure adapters are defined and adhere to protocol conventions.r)EmailNotificationPort)BrevoEmailAdapter send_emailz.%(py6)s {%(py6)s = %(py2)s(%(py3)s, %(py4)s) } issubclassrcrb)py2py3py4py6z1%(py13)s {%(py13)s = %(py8)s(%(py9)s, %(py11)s) }hasattr)py8py9py11py13zassert %(py16)spy16N) TelegramPort)TelegramHttpAdapter send_messagerrrq)EquipmentRepositoryPort)PostgresEquipmentRepositoryrecord_fuel_logrurt)ZaloGatewayPort)ZaloHttpAdapterrxrw)ZaloCrmRepositoryPort)PostgresZaloCrmRepositoryupsert_contactrzry)ISxdCrawlerPort)SxdStealthCrawlerAdaptercrawl_latest_announcementsr}r|)GdtGatewayPort)GdtPortalAdapterauthenticate_portalrr)'/app.modules.core.domain.ports.notification_portrb6app.modules.core.infrastructure.adapters.brevo_adapterrcrerjr&r'r#r(r)r"_format_boolopr*r+3app.modules.integrations.domain.ports.telegram_portrqAapp.modules.integrations.infrastructure.adapters.telegram_adapterrr=app.modules.operations.domain.ports.equipment_repository_portrtGapp.modules.operations.infrastructure.repositories.equipment_repositoryru3app.modules.zalo_crm.domain.ports.zalo_gateway_portrw>app.modules.zalo_crm.infrastructure.adapters.zalo_http_adapterrx:app.modules.zalo_crm.domain.ports.zalo_crm_repository_portryDapp.modules.zalo_crm.infrastructure.repositories.zalo_crm_repositoryrz3app.modules.inventory.domain.ports.sxd_crawler_portr|Iapp.modules.inventory.infrastructure.adapters.sxd_stealth_crawler_adapterr}2app.modules.invoices.domain.ports.gdt_gateway_portr ? ?k ?k ?k^jk7K\^jCkCkkCkkkkkkkkkkkkkk:kkkkk:kkkkkkkkkkkkk'kkkkk'kkkkkkkkkkkkk)>kkkkk)>kkkkkk ?kkkkkkkkkkkkk ?kkkkkkkkkkk7kkkkk7kkkkkkkkkkkkkK\kkkkkK\kkkkkk^jkkkkCkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkkQPPPPPeeeeeehh:)< 8 8h 8h 8hYghGDWYgrs#"""""  PPPP[[[.]]]&{{{(sss@"l"l"l"l"lr