oiN dZddlZddlZddlZddlZddlZddlZddlm Z dZ dZ dZ de deefd Zd e de e fd Zd e dee ee ffd Zdedede deee ffdZd e de dee ee ffdZd e dee fdZdede dedee ee ffdZ d#de de e de e defdZedk(rddlZddlZeej<dkDrej<dndZeej<dkDrej<dndZ eej<dkDrej<dndZ!eee e! Z"e#ejHe"d!d"yy)$ur schema_contract.py - Worker 스키마 계약 검증 verifier workers/ 디렉토리를 자동 감지하여 SC-1 ~ SC-8 항목 검증 SC-1: Worker 디렉토리에 models.py 존재 확인 SC-2: Worker 디렉토리에 tests/test_contract.py 존재 확인 SC-3: shared/schemas/{name}.schema.json 존재 확인 SC-4: sample.normal.json → JSON Schema 검증 SC-5: sample.edge.json → JSON Schema 검증 (없으면 WARN) SC-6: Pydantic 모델 필드 ↔ JSON Schema properties 일치 확인 SC-7: sample.json mtime vs .schema.ts mtime 비교 (sample이 더 새우면 WARN) SC-8: Pydantic v1 문법(schema()) 사용 탐지 (WARN) N)Optionalz/home/jay/workspace/teamsz(/home/jay/workspace/teams/shared/schemasc. ddl}|S#t$rYywxYw)uFjsonschema 라이브러리를 임포트 시도. 없으면 None 반환.rN) jsonschema ImportError)rs B/home/jay/workspace/teams/dev4/qc/verifiers.bak/schema_contract.py_try_import_jsonschemars" s  workers_base_dirreturncltjj|dd}g}tj|D]T}tjj |tjj }|j |dVtjj|ddd}tj|D]i}tjj |tjj }tfd|DrV|j |dk|S)u workers_base_dir 하위에서 models.py 가 있는 디렉토리를 Worker로 감지. 반환: [{"dir": "/abs/path/info_keyword", "name": "info_keyword"}, ...] * models.py)dirnamec3.K|] }|dk(yw)rN).0w worker_dirs r z$_find_worker_dirs..:s;a1U8z);s)ospathjoinglobdirnamebasenameappendany)r patternworkers models_path worker_namepattern2rs @r_find_worker_dirsr#(s ggll+S+>GGyy)A WW__[1 gg&&z2 z;?@A ww||,c3 DHyy*E WW__[1 gg&&z2 ;7;; NN:{C D E Nrc<tjj|d} t|dd5}|j }dddt j dt j}|r|jdS y#1swYCxYw#t$rYywxYw)u models.py 에서 __schema_name__ 변수를 파싱. 없으면 None. 정규식으로 파싱하여 importlib 없이도 동작. r rutf-8encodingNz*^__schema_name__\s*=\s*["\']([^"\']+)["\']) rrropenreadresearch MULTILINEgroupOSError)rr fcontentms r_read_schema_name_overrider5@s '',,z;7K +sW 5 ffhG  IICWbll [ 771:         s(BB?BB B BBrc& t|dd5}tj|dfcdddS#1swYyxYw#t$r dd|fcYStj$r}dd|d|fcYd}~Sd}~wt $r}dd |d|fcYd}~Sd}~wwxYw) uCJSON 파일 로드. (data, error_msg) 반환. 실패 시 data=None.r&r'r(NzFile not found: zJSON parse error in : zOS error reading )r+jsonloadFileNotFoundErrorJSONDecodeErrorr1)rr2es r_load_json_filer>Qs5 $g . $!99Q<# $ $ $ /'v...   8+D6A3777 5(b4445sG=1 =:==BB! A0*B0 B< B B Bdataschema sample_pathc |j}||}t|j|d}|r_|ddDcgc]7}djd|jDxsdd|j 9}}d d |dd j|zfSd d |fScc}w#t $r*}d d|dt|jd|fcYd}~Sd}~wwxYw)uGjsonschema로 data를 schema에 대해 검증. (ok, detail_msg) 반환.c,t|jSN)listr)r=s rz/_validate_json_against_schema..es4<r$)keyN.c32K|]}t|ywrD)str)rps rrz0_validate_json_against_schema..gs71A7szr8FzSchema validation FAILED for ; TzSchema validation PASSED: zjsonschema error validating ) Draft7Validatorsorted iter_errorsrrmessage Exceptiontype__name__) r?r@jsonschema_modrA validator_cls validatorerrorsr=msgss r_validate_json_against_schemarZ^s \&66 !&)  --d39OP \bcede\fgWXsxx777C8DBqyykRgDg9+bIDIIVZO[[ [1+???h \4[MDGDTDTCUUWXYWZ[[[\s4:B >@AE % J   h ' (5j\k]SS S/ |= VVVYjCHH4 +5z  RQ R  " %%"%**,K %"$K% % Y1+baAQAQ@RRTUVTWXXXYs(I.AI.'G#4I.7H=I.AH, I.'I.<H< A I. I.#7HI. H)&I.(H))I., H95I.8H99I.< I+II+ I%"I+$I%%I+(I.*I++I.. J!7JJ!J!c g}tjtjj|ddd}t j d}|D]} t |ddd 5}t|d D]^\}}|j|stjj||}|j|d |d |j` d d d |S#1swY xYw#t$rYwxYw)u Worker 디렉토리의 .py 파일에서 Pydantic v1 문법 (`.schema()`) 사용을 탐지. 발견된 위치 목록 반환. z**z*.pyT) recursivez\bschema\(\s*\)r&r'ignore)r)rXr*:r8N) rrrrr-compiler+ enumerater.relpathrrstripr1) rhitspy_filesrpy_filer2linenolinerels r_detect_pydantic_v1_usagers Dyyj$?4PHjj+,G gsWXF H!$-aOHLFD~~d+ ggoogzB se1VHBt{{}o$FGH H K H H    s1C*#$CA CC*C' #C** C65C6worker schemas_dirjsonschema_missingc  |d}|d}g}d}d}t|} | r| } |jd|d| dn|} |jd|d| dtjj || d } tjj |d } tjj | r|jd | n|jd | d }tjj |dd} tjj | r|jd| n|jd| d }tjj | r|jd| n|jd| d }d}tjj | r)t | \}}|r|jd|d }d}nd}tjj || d}|r|jdn||jdntjj |s|jd|d }nWt |\}}|r|jd|d }n0t||||\}}|jd|rdndd||sd }tjj || d}|r|jd n||jd!ntjj |s|jd"|d }nWt |\}}|r|jd#|d }n0t||||\}}|jd$|rdndd||sd }||jd%nt|jd&ij}|s|jd'| d }nt||\}}||jd(|d }n|jd)|||z }||z }|s|rfg}|r|jd*t||r|jd+t||jd,d-j |d }n|jd.t|d/tjj || d0}||fDcgc]$}tjj |s#|&}}tjj |s|jd1|d2n|s|jd3n tjj|}g} |D]}!tjj|!}"|"|kDs(|"|z }#| jtjj|!d4|#d5d6tjj|| r&|jd7d-j | zd }n|jd8t#|}%|%rB|jd:|d;t|%d<|%dd=D]}&|jd>|&d }n|jd?|d|rd}'|'|fS|rd@}'|'|fSd}'|'|fScc}w#t $r }$|jd9|$d }Yd}$~$d}$~$wwxYw)Au` 단일 Worker에 대해 SC-1 ~ SC-8 수행. (overall_status, details_list) 반환. rrFzWorker 'u': schema name override → ''z': schema name = 'z' (from dir name)z .schema.jsonr zSC-1 PASS: models.py found: zSC-1 FAIL: models.py MISSING: Ttestsztest_contract.pyz)SC-2 PASS: tests/test_contract.py found: z+SC-2 FAIL: tests/test_contract.py MISSING: zSC-3 PASS: schema file found: z SC-3 FAIL: schema file MISSING: Nz SC-3 FAIL: z.sample.normal.jsonzQSC-4 SKIP: jsonschema library not installed. Install with: pip install jsonschemaz;SC-4 SKIP: schema not loaded (SC-3 failed), cannot validatez'SC-4 FAIL: sample.normal.json MISSING: z SC-4 FAIL: zSC-4 PASSFAILr8z.sample.edge.jsonzQSC-5 SKIP: jsonschema library not installed. Install with: pip install jsonschemaz;SC-5 SKIP: schema not loaded (SC-3 failed), cannot validatez'SC-5 WARN: sample.edge.json NOT FOUND: z SC-5 FAIL: zSC-5 z:SC-6 SKIP: schema not loaded (SC-3 failed), cannot comparer_z6SC-6 WARN: JSON Schema has no 'properties' defined in u-SC-6 FAIL: Cannot inspect Pydantic model — z SC-6 info: zin schema only: zin model only: uSC-6 FAIL: Field mismatch — rMz9SC-6 PASS: Pydantic fields match JSON Schema properties (z fields)z .schema.tsz!SC-7 SKIP: .schema.ts not found (z), skipping mtime checkz5SC-7 SKIP: no sample.json files found for mtime checkz is z.0fz s newer than u4SC-7 WARN: sample file(s) newer than .schema.ts — zrZrorrrsrrOlengetmtimerr1r)(rrrUrrr!detailshas_failhas_warnschema_name_override schema_baseschema_json_path models_pytest_contract_py schema_data schema_errnormal_json_path sample_data sample_errokmsgedge_json_path schema_propspydantic_fields import_msgonly_in_schema only_in_modelmismatch_partsts_schema_pathrLsample_paths_for_mtimets_mtime stale_samplessps_mtimediffr=v1_hitshitstatuss( r_verify_workerrsJ.KGHH6jA* +.KK=XYZ[! +.@ M^_`ww||KK= 1MN Z5I ww~~i 5i[AB7 {CDww||J9KL ww~~&'BCSBTUVDEUDVWX ww~~&'78H7IJK9:J9KLM  ww~~&'"12B"C Z  NN[ 5 6HK ww||KK=@S1TU 3   TU WW^^, -@AQ@RST"12B"C Z  NN[ 5 6H3[.:JGB NNUR6V"O/PQN 3   TU WW^^N +@@PQR"1."A Z  NN[ 5 6H3[..GB NNUR6V"z;*W 'OZ&!Nzl[\ZL9:!-!? /, > !]%'N%&--.vn/E.FG%&---f].C-DENN8>9R8ST $HNN -.h8 WW\\++j/IJN$n59J 77>>. )//??V W $NO ww''7HM, ''**2.X%"X-D!((77++B/0T#JmBGGL\L\]kLlKmn  Jii ./ R( 3GB;-PG ~- / 3B< 'C NNRu: & 'PQ\P]]^_` 7?  7? 7?o<  NN;A3? @H s,$Z-Z-A Z2BZ22 [;[[task_idc |t}|t}g}|jd||jd||jd|tjj |s|jd|t }|du}|r|jdt|}|s|jd|d|d S|jd t|d |Dcgc]}|d  c}d }d } |D]n} |jd| d d| ddt| |||\} } |j| |jd| d d| d| dk(rd}g| dk(smd} p|rd} n| rd} nd} | |d Scc}w)u Worker 스키마 계약을 검증합니다. Args: task_id: 검증할 task ID (로깅용) workers_base_dir: Worker 디렉토리 탐색 기준 경로. 기본값: /home/jay/workspace/teams 하위 자동 탐색 schemas_dir: JSON Schema 파일이 있는 디렉토리. 기본값: /home/jay/workspace/teams/shared/schemas/ Returns: {"status": "PASS"|"FAIL"|"WARN"|"SKIP", "details": [...]} Nz Schema contract check for task: zWorkers base dir: z Schemas dir: zWARN: schemas_dir not found: zkWARN: jsonschema library not installed. SC-4 and SC-5 will be SKIPPED. Install with: pip install jsonschemaz,SKIP: No workers found (no models.py) under SKIP)rrzFound z worker(s): rFz --- Worker: z (rz) ---)rrrUrz --- Worker 'z ' result: z ---rTrr) DEFAULT_TEAMS_BASEDEFAULT_SCHEMAS_DIRrrrisdirrr#rrextend)rr rrrUrrroverall_has_failoverall_has_warnrw_status w_details final_statuss rverifyrs$-) G NN5gY?@ NN'(8'9:; NN];-01 77== %6{mDE,-N'4/ R  01G :;K:L M !W55 NNVCL>'6RQqy6R5STU$v'7r&-NO,#)1  ) y!fVn%5ZzNO v #   # $    "w 77;7Ss% F__main__r*test)r rF) ensure_asciiindent)NN)%__doc__rimportlib.utilr`r9rr-rdtypingrrrrrKrEdictr#r5tupler>boolrZrorrrrrT_jsonrargvtaskwdirsdirresultprintdumpsrr$rrs   1@ T 038C=" 5# 5%(;"< 5 \  \ \;> \ 49 \ EYSEYsEYuXc]TWEW?XEYP#$s)0O OO O  3S > On'+!%N8 N8smN8#N8 N8b zchh-!+388A;Dchh-!+388A;Dchh-!+388A;D D4T BF +%++f5 ;<r$