]>
git.ipfire.org Git - ipfire.org.git/blob - webapp/handlers_tracker.py
6 from backend
.tracker
import bencode
, bdecode
, decode_hex
7 from handlers_base
import *
10 class TrackerIndexHandler(BaseHandler
):
12 releases
= self
.releases
.get_all()
15 releases
= releases
[:limit
]
17 self
.render("tracker-torrents.html", releases
=releases
)
20 class TrackerDetailHandler(BaseHandler
):
21 def get(self
, torrent_hash
):
22 file = self
.releases
.get_file_for_torrent_hash(torrent_hash
)
25 raise tornado
.web
.HTTPError(404, "Could not find torrent file for hash: %s" % torrent_hash
)
27 peers
= self
.tracker
.get_peers(torrent_hash
)
28 seeds
= self
.tracker
.get_seeds(torrent_hash
)
30 self
.render("tracker-torrent-detail.html", release
=file.release
,
31 file=file, peers
=peers
, seeds
=seeds
)
34 class TrackerDownloadHandler(BaseHandler
):
35 def get(self
, torrent_hash
):
36 file = self
.releases
.get_file_for_torrent_hash(torrent_hash
)
39 raise tornado
.web
.HTTPError(404, "Could not find torrent file for hash: %s" % torrent_hash
)
41 # Redirect the user to the download redirector.
42 self
.redirect("http://downloads.ipfire.org/%s.torrent" % file.filename
)
45 class TrackerBaseHandler(BaseHandler
):
46 def get_hexencoded_argument(self
, name
, all
=False):
48 arguments
= self
.request
.arguments
[name
]
53 for argument
in arguments
:
54 arguments_new
.append(decode_hex(argument
))
56 arguments
= arguments_new
63 def send_tracker_error(self
, error_message
):
64 msg
= bencode({"failure reason" : error_message
})
68 class TrackerAnnounceHandler(TrackerBaseHandler
):
70 self
.set_header("Content-Type", "text/plain")
72 def get_ipv6_address(self
, default_port
):
73 # Get the external IP address of the client.
74 addr
= self
.get_remote_ip()
77 return addr
, default_port
80 ipv6
= self
.get_argument("ipv6", None)
84 m
= re
.match("^\[(.*)\]\:(\d)$", ipv6
)
86 ipv6
, port
= (m
.group(1), m
.group(2))
92 def get_ipv4_address(self
, default_port
):
93 # Get the external IP address of the client.
94 addr
= self
.get_remote_ip()
97 return addr
, default_port
100 ipv4
= self
.get_argument("ipv4", None)
102 return ipv4
, default_port
104 ip
= self
.get_argument("ip", None)
106 return ip
, default_port
111 # Get the port and check it for sanity
112 port
= self
.get_argument("port", None)
117 if port
< 0 or port
> 65535:
119 except (TypeError, ValueError):
126 info_hash
= self
.get_hexencoded_argument("info_hash")
128 self
.send_tracker_error("Your client forgot to send your torrent's info_hash")
132 peer_id
= self
.get_hexencoded_argument("peer_id")
134 # Get the port and check it for sanity
135 port
= self
.get_port()
137 self
.send_tracker_error("Invalid port number or port number missing")
140 addr_ipv6
, port_ipv6
= self
.get_ipv6_address(port
)
141 addr_ipv4
, port_ipv4
= self
.get_ipv4_address(port
)
144 event
= self
.get_argument("event", None)
146 if not event
in ("started", "stopped", "completed"):
147 self
.send_tracker_error("Got unknown event")
150 self
.tracker
.handle_event(event
, peer_id
, info_hash
,
151 address6
=addr_ipv6
, port6
=port_ipv6
, address4
=addr_ipv4
, port4
=port_ipv4
)
154 "address6" : addr_ipv6
,
156 "address4" : addr_ipv4
,
158 "downloaded" : self
.get_argument("downloaded", 0),
159 "uploaded" : self
.get_argument("uploaded", 0),
160 "left_data" : self
.get_argument("left", 0),
163 self
.tracker
.update_peer(peer_id
, info_hash
, **peer_info
)
165 no_peer_id
= self
.get_argument("no_peer_id", False)
166 numwant
= self
.get_argument("numwant", self
.tracker
.numwant
)
168 peers
= self
.tracker
.get_peers(info_hash
, limit
=numwant
, no_peer_id
=no_peer_id
)
171 "tracker id" : self
.tracker
.tracker_id
,
172 "interval" : self
.tracker
.interval
,
173 "min interval" : self
.tracker
.min_interval
,
175 "complete" : self
.tracker
.complete(info_hash
),
176 "incomplete" : self
.tracker
.incomplete(info_hash
),
178 self
.finish(response
)
182 Cleanup after every request.
184 self
.tracker
.cleanup_peers()
187 class TrackerScrapeHandler(TrackerBaseHandler
):
189 info_hashes
= self
.get_hexencoded_argument("info_hash", all
=True)
191 response
= self
.tracker
.scrape(info_hashes
)
193 self
.finish(bencode(response
))