import xmlrpclib
import libtorrent as lt
import random
import time


server = xmlrpclib.ServerProxy('http://127.0.0.1:1989')



def fetch_torrent(ses, info_hash):
 print '+' * 60
 info_hash = info_hash.upper()
 url = 'magnet:?xt=urn:btih:%s' % (info_hash,)
 print "url:", url
 params = {
 'save_path': 'downloads',
 'storage_mode': lt.storage_mode_t(2),
 'paused': False,
 'auto_managed': False,
 'duplicate_is_error': True
 }
 handle = lt.add_magnet_uri(ses, url, params)
 status = ses.status()
 handle.set_sequential_download(1)
 down_time = time.time()
 if handle.has_metadata():
 info = handle.get_torrent_info()
 print '\n', time.ctime(), (time.time()-down_time), 's, got', url, info.name()
 print 'status', 'p', status.num_peers, 'g', status.dht_global_nodes, 'ts', status.dht_torrents, 'u', status.total_upload, 'd', status.total_download
 meta = info.metadata()
 print meta
 return meta
 else:
 print "no metadata"
 ses.remove_torrent(handle)
 print '+' * 60, '\n'




if __name__ == '__main__':
 r = random.randrange(10000, 50000)
 ses = lt.session()
 ses.listen_on(r, r+10)
 ses.add_dht_router('router.bittorrent.com',6881)
 ses.add_dht_router('router.utorrent.com',6881)
 ses.add_dht_router('dht.transmission.com',6881)
 ses.add_dht_router('70.39.87.34',6881)
 ses.start_dht()

 while True:
 info_hash = server.get_hash().upper()
 fetch_torrent(ses, info_hash)