o
    QDi                     @  sx   d dl mZ d dlZd dlmZ ddlmZ ddlm	Z	 ddl
mZ er0dd	lmZ dd
lmZ dZG dd de	ZdS )    )annotationsN)TYPE_CHECKING   )TableResource)Adapter   )	QsvMapper)Resource)Schemai  c                   @  s*   e Zd ZU ded< dddZdd	d
ZdS )
QsvAdapterstrqsv_pathc                 C  s
   || _ d S )N)r   )selfr    r   Y/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/formats/qsv/adapter.py__init__   s   
zQsvAdapter.__init__resourcer	   returnr
   c           	      C  s   | j ddddg}tj|tjtjd}|# 	 |jtd}|sn|j| q|j  |j	
 }W d    n1 s:w   Y  t|dd	}| }t |}|S )
Nstatsz--infer-datesz--dates-whitelistall)stdoutstdinT)sizecsv)dataformat)r   spPopenPIPE
read_bytes
BLOCK_SIZEr   writecloser   readr   	read_rowsr   read_schema)	r   r   commandprocesschunkbufferresultr   schemar   r   r   r%      s    
zQsvAdapter.read_schemaN)r   r   )r   r	   r   r
   )__name__
__module____qualname____annotations__r   r%   r   r   r   r   r      s   
 
r   )
__future__r   
subprocessr   typingr   	resourcesr   systemr   mapperr   r   r	   r+   r
   r    r   r   r   r   r   <module>   s    