-bhr ddlZddlZddlZddlZddlmZmZej jej jej jej je dddl m Z ddlmZddlddlddlmZd Zdd Zdd Zed k(rej.ed yy)N)datetimetimezonez..)BonkAPI)JupAPI)*)ClickHouseManagerc g}tdt|t|D]\}}|dkDrtjdt |t r|jd}n|}d|i}|sLtj|}|stjd||jd}|stjd||jdxs|}|jd xs|jd }tj|tj j!d } |jdxs|jd} |jdxs|jd} |jd} |j#|| | | || dtj%d|dzdt|d| xs||S)u Получает время миграций и создателей токенов. Комбинирует данные из get_recent_tokens_from_raydium_2() и JupAPI().get_token_pool_info() zLen of rg?mintzNo JupAPI info for token migration_startedzNo migration_started for token token_hash creator_hashcreator)tzN)tzinfosymboliconimgUrlname)r rrr rrzProcessed token r/z: )printlen enumeratetimesleep isinstancedictgetrget_token_pool_info bonk_loggerwarningr fromtimestamprutcreplaceappendinfo) token_listmigratedi token_data token_mintjup_infotsr rr rrrs >(+C||F#?z~~h'?~~f%$!2(    +AaC5#j/1B"VEYzDZ[\].]` Oc |stjdy t}|Dcgc]}|jdd}}t }|rqdj |Dcgc]}d|d c}}d|d} |j |} | r4| D chc]} | d  }} tjd t|d g} ttj} d }|D]}|jdd}||vrtjd||dz }7|jdd}|jd}t|trt|j}n| }| }d }d}|jdd}|jdd}| j|||||||||f | stjd|dygd}|j!d|| }|r&tjdt| d|dytj#dycc}wcc}wcc} w#t$r#} tjd | Yd } ~ d } ~ wwxYw#t$r"} tj#d| Yd } ~ yd } ~ wwxYw)zB Insert migrated tokens to the ClickHouse tokens database z!No tokens to insert into databaseFr ,'zESELECT token_address FROM tokens_info.tokens WHERE token_address IN ()rzFound z existing tokens in databasez%Could not check for existing tokens: NzSkipping existing token: rrr unsortedrrz!No new tokens to insert. Skipped z existing tokensT) token_addressrpoolr(processed_date processedquality shortNameimageztokens_info.tokensu✅ Successfully inserted z, new migrated tokens into database (skipped z existing)u)❌ Failed to insert tokens into databaseu(❌ Error inserting tokens to database: ) pump_loggerr!r rsetjoin execute_queryr&r Exceptionintrrr timestampr%execute_inserterror)migrated_tokensr8 db_managertokentoken_addressesexisting_tokensaddr placeholders check_queryresultrowedata_to_insert current_time skipped_countr7rmigration_timer(r9r:r;r<r=columnssuccesss r.insert_tokens_to_databaserXNs ?@[&( ETT5599\26TT% 88_$MTqa[$MNLabnaoopqK Q#11+>9?&@#s1v&@O&@$$vc/.B-CC_%`a 499;'  $" E!IIlB7M/  #<]O!LM" ii3G#YY':;N.(3~779:')NI G (B/IIIfb)E  ! ! # 1" H   @O_` a  ++,@'>Z    9#n:M9NNz|I{JJTU V   I JeU %N 'A Q##&KA3$OPP QN DQCHIs}IH I H%+ I9H/ H*$H/D I >I I I*H// I8IIII J 'JJ cKtj|}tjdt |dt |}tjdt |dtjdt |dt |}|rtjdy tjdy w) u Получает бонк токены, проверяет время миграции и создателя, заносит в базу как: token_hash, migration_started, creator_hash, processed=0, good=0, pool=BONK z BonkTokens z tokenszSuccessfully processed z tokens with migration dataz Inserting z tokens into database...u6✅ All migrated tokens successfully added to databaseu0❌ Failed to add some or all tokens to databaseN)r get_recent_tokens_from_raydium_2r r&rr/rXrF)days bonk_tokensrGrWs r. bonk_migratedr]s )<rps ' RWW__X-F MNO09vcJN, zGKK a !r0