add torrentz2 search functionality
Shrimadhav U K
parent
8eab2c90bb
commit
4a31f10e14
|
|
@ -4,4 +4,6 @@ requests
|
|||
Pillow
|
||||
hachoir
|
||||
cryptg
|
||||
cfscrape
|
||||
beautifulsoup4
|
||||
|
||||
|
|
|
|||
|
|
@ -0,0 +1,146 @@
|
|||
# This Source Code Form is subject to the terms of the Mozilla Public
|
||||
# License, v. 2.0. If a copy of the MPL was not distributed with this
|
||||
# file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
||||
|
||||
from telethon import events
|
||||
import os
|
||||
import requests
|
||||
from datetime import datetime
|
||||
import cfscrape # https://github.com/Anorov/cloudflare-scrape
|
||||
from bs4 import BeautifulSoup
|
||||
import urllib.parse
|
||||
|
||||
|
||||
@borg.on(events.NewMessage(pattern=r".torrentz search (.*)", outgoing=True))
|
||||
async def _(event):
|
||||
if event.fwd_from:
|
||||
return
|
||||
start = datetime.now()
|
||||
await event.edit("Processing ...")
|
||||
input_str = event.pattern_match.group(1)
|
||||
search_results = Scrapper.SearchTorrentz(input_str)
|
||||
output_str = ""
|
||||
i = 0
|
||||
for result in search_results:
|
||||
if i > 5:
|
||||
break
|
||||
url = "https://torrentz2.eu/" + result["hash"] + ""
|
||||
message_text = "[" + result["title"] + "](" + url + ") \r\n"
|
||||
message_text += " FILE SIZE: " + result["size"] + "\r\n"
|
||||
# message_text += " Uploaded " + result["date"] + "\r\n"
|
||||
message_text += " SEEDS: " + result["seeds"] + " PEERS: " + result["peers"] + " \r\n"
|
||||
message_text += "===\r\n"
|
||||
output_str += message_text
|
||||
i = i + 1
|
||||
end = datetime.now()
|
||||
ms = (end - start).seconds
|
||||
await event.edit("Scrapped Torrentz2.EU for {} in {} seconds. Obtained Results: \n {}".format(input_str, ms, output_str))
|
||||
|
||||
|
||||
@borg.on(events.NewMessage(pattern=r".upload (.*)", outgoing=True))
|
||||
async def _(event):
|
||||
if event.fwd_from:
|
||||
return
|
||||
await event.edit("Processing ...")
|
||||
input_str = event.pattern_match.group(1)
|
||||
if os.path.exists(input_str):
|
||||
start = datetime.now()
|
||||
await borg.send_file(
|
||||
event.chat_id,
|
||||
input_str,
|
||||
force_document=True,
|
||||
allow_cache=False,
|
||||
reply_to=event.message.reply_to_msg_id
|
||||
)
|
||||
end = datetime.now()
|
||||
ms = (end - start).seconds
|
||||
await event.edit("Uploaded in {} seconds.".format(ms))
|
||||
else:
|
||||
await event.edit("404: File Not Found")
|
||||
|
||||
|
||||
|
||||
class Scrapper:
|
||||
def SearchTorrentz(search_query):
|
||||
r = []
|
||||
url = "https://torrentz2.eu/searchA?safe=1&f=" + search_query + ""
|
||||
scraper = cfscrape.create_scraper() # returns a CloudflareScraper instance
|
||||
raw_html = scraper.get(url).content
|
||||
# print(raw_html)
|
||||
soup = BeautifulSoup(raw_html, "html.parser")
|
||||
results = soup.find_all("div", {"class": "results"})[0]
|
||||
for item in results.find_all("dl"):
|
||||
# print(item)
|
||||
"""
|
||||
The content scrapped on 23.06.2018 15:40:35
|
||||
<dt>
|
||||
<a href="/06f8a85906520e018db4a3cbec25219e00d7a704">
|
||||
www.TamilMV.cam - Shikkari Shambhu (2018) Malayalam DVDRip - 720p - x264 - AC3 5.1 - 1.2GB - ESub.mkv
|
||||
</a>
|
||||
» video movie hd
|
||||
</dt>
|
||||
<dd>
|
||||
<span> </span>
|
||||
<span title="1529692527">16 hours</span>
|
||||
<span>1266 MB</span>
|
||||
<span>6</span>
|
||||
<span>4</span>
|
||||
</dd>
|
||||
"""
|
||||
dt = item.find_all("dt")[0]
|
||||
dd = item.find_all("dd")[0]
|
||||
#
|
||||
try:
|
||||
link_and_text = dt.find_all("a")[0]
|
||||
link = link_and_text.get("href")[1:]
|
||||
title = link_and_text.get_text()
|
||||
span_elements = dd.find_all("span")
|
||||
date = span_elements[1].get_text()
|
||||
size = span_elements[2].get_text()
|
||||
seeds = span_elements[3].get_text()
|
||||
peers = span_elements[4].get_text()
|
||||
#
|
||||
r.append({
|
||||
"title": title,
|
||||
"hash": link,
|
||||
"date": date,
|
||||
"size": size,
|
||||
"seeds": seeds,
|
||||
"peers": peers
|
||||
})
|
||||
except:
|
||||
pass
|
||||
return r
|
||||
|
||||
def GetMagneticLink(info_hash):
|
||||
name = "SpEcTorrentBot"
|
||||
trackers = [
|
||||
"udp://tracker.openbittorrent.com:80",
|
||||
"udp://opentor.org:2710",
|
||||
"udp://tracker.ccc.de:80",
|
||||
"udp://tracker.blackunicorn.xyz:6969",
|
||||
"udp://tracker.coppersurfer.tk:6969",
|
||||
"udp://tracker.leechers-paradise.org:6969",
|
||||
"udp://tracker.openbittorrent.com:80",
|
||||
"udp://tracker.publicbt.com:80",
|
||||
"udp://tracker.istole.it:80",
|
||||
"udp://tracker.btzoo.eu:80/announce",
|
||||
"http://opensharing.org:2710/announce",
|
||||
"udp://open.demonii.com:1337/announce",
|
||||
"http://announce.torrentsmd.com:8080/announce.php",
|
||||
"http://announce.torrentsmd.com:6969/announce",
|
||||
"http://bt.careland.com.cn:6969/announce",
|
||||
"http://i.bandito.org/announce",
|
||||
"http://bttrack.9you.com/announce",
|
||||
];
|
||||
data = ""
|
||||
data += "magnet:"
|
||||
data += "?xt=urn:btih:"
|
||||
data += info_hash
|
||||
data += "&dn="
|
||||
data += urllib.parse.quote_plus(name)
|
||||
data += ""
|
||||
for tracker in trackers:
|
||||
data += "&tr="
|
||||
data += urllib.parse.quote_plus(tracker)
|
||||
return data
|
||||
Reference in New Issue