
    SpKg                         d dl Z d dlZd dlZd dlmZ d dlZd dlmZ  ej                         Z	de
de
de
fdZdej                  fd	Zy)
    N)NewMarketBot)loggerall_sessionswebshare_ipsreturnc                     g }t        d      D ]_  }t        j                  t        t        || f      }d|_        dt        |      z   |_        |j                          |j                  |       a |S )N   )targetargsThandleListingsQueue)
range	threadingThreadr   listings_queuedaemonstrnamestartappend)r   r   handle_listings_queue_threadsits        $/var/www/highfloat_scraper/Queues.pystartHandleListingsQueuer   
   st    $&!2Y 0&
 &Q/		%,,Q/0 )(    r   c                 `   	 | j                         dk  r*t        j                  t        j                  dd             np| j                         d   }t        |d   j                               d   d   }t        t        |      d||t        j                               }|j                  |       )Nr   g?g?high_lowzBest Thread)qsizetimesleeprandomuniformgetlistvaluesr   r   queueQueuegetBestOrWorstSkinsBulk)r   r   r   	bulk_listr   nms         r   r   r      s    
!Q&JJv~~c3/0 '**,Q/I IaL//1215jAHHB &&y1! r   )r   r&   r!   newMarketBotr   r   LoggingFormatterr   r'   r   r$   r   r    r   r   <module>r.      sN       %  #)4 )t ) )$2 2r   