
    Ѯh                         d gZ ddlmZ ddlmZmZmZ ddlmZ ddl	m
Z
 ddlmZ ddlmZmZ ddlmZ dd	lmZmZ dd
lmZ  edeeef         Z	 	 dddddee   deeeef      dee   dee   dee   defdZy)paginate    )Mapping)AnyOptionalTypeVar)SimpleStatement)
connection)Model)apply_items_transformercreate_page)AbstractParams)AdditionalDataSyncItemsTransformer)verify_paramsT)boundN)transformeradditional_datamodelquery_filterparamsr   r   returnc          
         t        |d      \  }}|j                  rJ d       |xs i }t        t         | j                  di |      |j
                        }t        j                         }|j                  j                  |t        |j                               D 	ci c]  \  }}	t        |      |	 c}	}|j                        }
|
j                  }t        ||      }t        |f||
j                   d|xs i S c c}	}w )Ncursorz&Cassandra does not support total count)
fetch_size)
parameterspaging_state)r   next_ )r   include_totalr   strfiltersizer	   get_connectionsessionexecute	enumeratevaluesr   current_rowsr   r   r   )r   r   r   r   r   
raw_paramsstmtconnivr   itemst_itemss                r/home/www/academy-backend.kofcorporation.com/venv/lib/python3.12/site-packages/fastapi_pagination/ext/cassandra.pyr   r      s    'vx8FJ''Q)QQ'%2LLELL(<()??D $$&D\\!!*3L4G4G4I*JK$!QCFAIK&& " F
 E%e[9G!!  b	  Ls   C>)NN)__all__collections.abcr   typingr   r   r   cassandra.clusterr   cassandra.cqlenginer	   cassandra.cqlengine.modelsr
   fastapi_pagination.apir   r   fastapi_pagination.basesr   fastapi_pagination.typesr   r   fastapi_pagination.utilsr   r!   r   typedictr   r       r1   <module>r?      s   , # ) ) - * , G 3 I 2CwsCx()
 .2'+
 3704;4S>* ^$
 ./ n- 	r>   