
    dfG                         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 d dlZ ej                         Z
 ej                         ZdededefdZdej                  defd	Zdededefd
Zdej                  fdZy)    N)logger)NewMarketBot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handleCsgofloatQueue)
range	threadingThreadr   csgofloat_queuedaemonstrnamestartappend)r   r   csgofloat_queue_threadsits        $/var/www/highfloat_scraper/Queues.pystartCsgofloatQueuer      st     1X *'
 '#a&0		&&q)* #"    r   c           
         	 | j                         dk  r+t        j                  t        j                  dd             ned}t        j                  t        j                  dd             | j                         }t        j                  t        j                  dd             |d   }|d   }|d   }|d   }|d   }		 t        j                  d	d	d
dd      }
|
j                         }|j                  d|f       |j                         d   }t        j                  d       	 
|
j                          |du rit'        dd||dt)        j*                         t)        j*                               }|j-                  ||||	|      }||dk(  r|j/                  ||d       n# t        $ r* t        j                  d       d}j                          Y t         t        j"                  f$ r(}t        j                  t%        |             Y d }~d }~ww xY w# t         $ r)}t        j                  t%        |             Y d }~d }~ww xY w)NTr         ?   gffffff?         postgreszBerufsorientierung1!z23.88.122.575432)databaseuserpasswordhostportz/SELECT rank FROM floats WHERE inspect_link = %szSKIN IN DB, SKIPzSKIN NOT IN DB, CONTINUEFhighlowzQueue Threadnegeri9  )qsizetimesleeprandomuniformgetpsycopg2connectcursorexecutefetchoner   info	TypeErrorerrorclose	ExceptionDatabaseErrorr   r   queueQueuesingleCheckCsgofloatRanksingleCheckForPotentialBuy)r   r   r   
skin_in_dbsingle_elempricemarket_linksingle_full_item_namesingle_inspect_linkmpostgresql_connpostgresql_currank_dbr9   enmfinal_listings                    r   r   r      s)   
  "a'JJv~~c1-. JJJv~~c3/0)--/KJJv~~c3/0NE%a.K$/N!"-a.AA)"*"2"2'#3'# "1!7!7!9&&E(*
 )113A6./%".#))+ U"!"  KKMKKM !# ; ;!68KQPU! !("g-11%':D C >  '78"
$$&x556 )SZ(()
  %SV$$%s7   >A%F' $H '0HH1HH	I%I		Ic                     g }t        d      D ]d  }t        j                  t        t        |t
        | f      }d|_        dt        |      z   |_        |j                          |j                  |       f |S )Nr	   r
   ThandleListingsQueue)r   r   r   rO   listings_queuer   r   r   r   r   r   )r   r   handle_listings_queue_threadsr   r   s        r   startHandleListingsQueuerR   c   sw    $&!1X 0&	
 &Q/		%,,Q/0 )(r   rP   c           	      d   	 | j                         dk  r*t        j                  t        j                  dd             nr| j                         d   }t        |d   j                               d   d   }t        t        |      d||dt        j                         |      }|j                  |       )Nr   r   r   high_lowzBest ThreadF)r,   r-   r.   r/   r0   r1   listvaluesr   r   r=   r>   getBestOrWorstSkinsBulk)rP   r   r   r   	bulk_listrT   rL   s          r   rO   rO   v   s    
!Q&JJv~~c1-. '**,Q/IIaL//1215jAHHB &&y1! r   )r-   r2   r=   LoggingFormatterr   r/   newMarketBotr   r   r>   r   rP   rU   r   r   rR   rO    r   r   <module>r\      s       #  % %++-#d #$ #4 #$B%++ BT BJ)4 )t ) )&2 2r   