o QDi@sddlmZddlmZddlmZmZmZmZm Z m Z ddl m Z ddl mZddlmZdd lmZerNdd l mZdd lmZdd lmZdd lmZGdddZGdddZdS)) annotations)chain) TYPE_CHECKINGAnyClassVarListOptionalcast)errors)FrictionlessException)platform)system)types)Resource) TableResource)Loaderc@seZdZUdZdZded< gZded< d4d d Zd d Zd dZ e d5ddZ e d6ddZ e d7ddZ e d8ddZddZd9ddZe d:d!d"Zd;d$d%Zd8d&d'Zd8d(d)ZdParserzRParser representation Parameters: resource (Resource): resource FzClassVar[bool]requires_loaderzClassVar[List[str]]supported_typesresourcercCs||_d|_d|_d|_dSN)_Parser__resource_Parser__loader_Parser__sample_Parser__cell_stream)selfrrS/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/system/parser.py__init__%s zParser.__init__cCs|jr||Sr)closedopenrrrr __enter__+szParser.__enter__cCs |dSr)close)rtypevalue tracebackrrr__exit__0s zParser.__exit__returncCs|jS)z9 Returns: Resource: resource )rr#rrrr3zParser.resourcercC|jdur td|jS)z5 Returns: Loader: loader Nz*parser is not open or non requiring loader)rr r#rrrloader; z Parser.loader types.ISamplecCr,)z5 Returns: Loader: sample Nparser is not open)rr r#rrrsampleEr.z Parser.sampletypes.ICellStreamcCr,)z: Yields: any[][]: list stream Nr0)rr r#rrr cell_streamOr.zParser.cell_streamcCs<|z ||_||_|WSty|w)z!Open the parser as "io.open" does)r% read_loaderrread_cell_streamr Exceptionr#rrrr"[s   z Parser.openNonecCs|jr |jdSdS)z)Close the parser as "filelike.close" doesN)rr%r#rrrr%fsz Parser.closeboolcCs |jduS)zSWhether the parser is closed Returns: bool: if closed N)rr#rrrr!ks z Parser.closedOptional[Loader]cCs|jr t|j}|SdS)zLCreate and open loader Returns: Loader: loader N)rr create_loaderrr")rr-rrrr4vs zParser.read_loadercCsVg|_|}||}|D]}|j|t|j|jjjkr"nqt|j|}|S)zQRead list stream Returns: gen: list stream ) rread_cell_stream_createread_cell_stream_handle_errorsappendlenrdetector sample_sizer)rr3cellsrrrr5s   zParser.read_cell_streamcCt)zCreate list stream from loader Parameters: loader (Loader): loader Returns: gen: list stream NotImplementedErrorr#rrrr;s zParser.read_cell_stream_creater3CellStreamWithErrorHandlingcCst|S)zWrap list stream into error handler Parameters: gen: list stream Returns: gen: list stream )rErr3rrrr<s z%Parser.read_cell_stream_handle_errorssourcerrcCrB)zvWrite row stream from the source resource Parameters: source (Resource): source resource rC)rrGrrrwrite_row_streamr+zParser.write_row_streamN)rr)r*r)r*r)r*r/)r*r2)r*r7)r*r8)r*r9)r3r2r*rE)rGrr*r)__name__ __module__ __qualname____doc__r__annotations__rr r$r)propertyrr-r1r3r"r%r!r4r5r;r<rHrrrrrs4            rc@s&eZdZd ddZddZddZd S) rEr3r2cCs ||_dSr)r3rFrrrr s z$CellStreamWithErrorHandling.__init__cCs|Srrr#rrr__iter__sz$CellStreamWithErrorHandling.__iter__c Csz ttt|jWStytytjj tj j fy7}z t j t|d}t|d}~wtyO}z t jt|d}t||d}~wtyg}z t jt|d}t||d}~ww)N)note)r rrr3__next__ StopIterationr r zipfile BadZipFilegzip BadGzipFiler CompressionErrorstrUnicodeDecodeError EncodingErrorr6 SourceError)r exceptionerrorrrrrQs&    z$CellStreamWithErrorHandling.__next__N)r3r2)rIrJrKr rOrQrrrrrEs  rEN) __future__r itertoolsrtypingrrrrrr r r\r r rrrr resourcesrr-rrrErrrrs          +