
    Vh%
                         d dl Z d dlZd dlmZmZ d dlmZ d dlmZ d dl d dl	 d Z
d	dZd Z e       j                         Z e ee             y)
    N)datetimetimezone)PumpAPI)JupAPI)*c                    g }t        dt        |               t        |       D ]  \  }}|dkD  rt        j                  d       t               j                  |      }|s<|j                  d      }|sP|j                  d      }t        d|        |j                  d      }t        d|        t        j                  |t        j                  	      j                  d 
      }t        d|        |j                  |||d        |S )NzLen of r   g      ?migration_started
token_hashzToken hash: creator_hashzcreator_hash: )tz)tzinfozmigration_started: )r
   r	   r   )printlen	enumeratetimesleepr   get_token_pool_infogetr   fromtimestampr   utcreplaceappend)	
token_listmigrateditokeninfotsr
   r   r	   s	            :/home/ubuntu/SOL_API/sol_API/src/v3/utils/pump_migrated.pyget_migrated_tokensr       s   H	GC
O$
%&j) 5q5JJsOx++E2XX)*XXl+
ZL)*xx/|n-.$222(,,GOOW[O\#$5#678$!2(
 	)4 O    c                    t        j                  di |}d}	 |j                         5 }| D ]G  }|d   }|j                  d      }|j                  d      }		 |j	                  d|||	dd|f       |dz  }I |j                          d d d        |j                          |S # t         j
                  j                  $ r Y w xY w# 1 sw Y   >xY w# |j                          w xY w)Nr   r
   r	   r   z
                        INSERT INTO token_migrations (token_hash, migration_started, creator_hash, processed, good, pool)
                        VALUES (%s, %s, %s, %s, %s, %s)
                            )	pymysqlconnectcursorr   executeerrIntegrityErrorcommitclose)
migrated_tokens	db_configpoolconninsertedr'   entryr
   r	   r   s
             r   insert_migrated_pumpsr3   ,   s    ??'Y'DH[[] 	f( "<0
$)II.A$B!$yy8
NN $%6aDQ MH KKM!	$ 	

O {{11 	 	$ 	

sF   C -CB 4CC  C =C?C  CCC C!c                  R   K   t               j                         } t        |        y w)N)r   get_recent_tokens_from_pumpr   )pump_tokenss    r   pump_migratedr7   F   s     )779K	+s   %')PUMP)r%   r   r   r   API.pumpAPIr   
API.jupAPIr   utils.loggerutils.configr    r3   r7   r5   r6   r   r   r$   r!   r   <module>r=      sI      '    B4 i335 c+ r!   