
    gw	                         d dl Z d dlmZ d dlZd dlmZ d dlmZ d dlZ	ej                  xs dZ
 G d dej                        Zd
dZed	k(  r e        yy)    N)Decimal)stdout)UUIDzUTF-8c                       e Zd Zd Zy)CleanJSONEncoderc                 :   t        |t        j                  t        j                  f      r|j                         S t        |t        t
        f      rt        |      S t        |t              r|j                  d      S t        j                  j                  | |      S )Nz
iso-8859-1)
isinstancedatetimedate	isoformatr   r   strbytesdecodejsonJSONEncoderdefault)selfobjs     F/var/www/openai/venv/lib/python3.12/site-packages/fastavro/__main__.pyr   zCleanJSONEncoder.default   sp    cHMM8+<+<=>==?"gt_-s8OU#::l++##++D#66    N)__name__
__module____qualname__r    r   r   r   r      s    7r   r   c                 0   dd l }ddlm} | xs |j                  }  |d      }|j	                  ddd       |j	                  d	d
dd       |j	                  dddd       |j	                  dddd       |j	                  dddt
        j                          |j	                  ddddd       |j                  | dd        }|j                  rFt        dj                  t        t
        j                  j                                     t        d       |j                  xs dg}|D ]h  }|dk(  r|j                   j"                  }nt%        |d      }t        j&                  |      }|j(                  rHt+        j,                  |j(                  |j.                  d       |j.                  j1                  d       |j2                  rU|j2                  d= t+        j,                  |j2                  |j.                  d       |j.                  j1                  d       |j4                  rdnd }	|D ]^  }
t+        j,                  |
|j.                  |	t6                |j.                  j1                  d       |j.                  j9                          ` k y )!Nr   )ArgumentParserz)iter over avro file, emit records as JSON)descriptionfilez#file(s) to parse, use `-' for stdin*)helpnargsz--schemazdump schema instead of records
store_trueF)r    actionr   z
--metadataz dump metadata instead of recordsz--codecszprint supported codecsz	--versionversionz	fastavro )r#   r$   z-pz--prettyzpretty print json   
-rb   )indentzavro.schema)r*   cls)sysargparser   argvadd_argumentavro__version__
parse_argscodecsprintjoinsortedreadBLOCK_READERSexitr   stdinbufferopenreaderschemar   dumpr   writemetadataprettyr   flush)r.   r,   r   parserargsfilesfilenamefor=   r*   records              r   mainrJ      s7   '388D(STF
%JRUV
-	   /	   1,PU   I4;K;K:L/M   j2<QV   T!"X&D{{diityy66789QII#Es?!!Bh%BR;;IIfmmSZZ:JJT"]].IIfooszz!<JJT"kktFIIfcjj=MNJJT"JJ ) r   __main__)N)r
   decimalr   r   r,   r   uuidr   fastavror0   encodingr   r   rJ   r   r   r   r   <module>rP      sQ         ??%g	7t'' 	7;| zF r   