]>
git.ipfire.org Git - people/shoehn/ipfire.org.git/blob - webapp/handlers_tracker.py
6 from backend
.tracker
import bencode
, bdecode
, encode_hex
, 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
)
29 self
.render("tracker-torrent-detail.html", release
=file.release
,
30 file=file, peers
=peers
)
33 class TrackerDownloadHandler(BaseHandler
):
34 def get(self
, torrent_hash
):
35 file = self
.releases
.get_file_for_torrent_hash(torrent_hash
)
38 raise tornado
.web
.HTTPError(404, "Could not find torrent file for hash: %s" % torrent_hash
)
40 # Redirect the user to the download redirector.
41 self
.redirect("http://downloads.ipfire.org/%s.torrent" % file.filename
)
44 class TrackerBaseHandler(BaseHandler
):
45 def get_hexencoded_argument(self
, name
, all
=False):
47 arguments
= self
.request
.arguments
[name
]
52 for argument
in arguments
:
53 arguments_new
.append(encode_hex(argument
))
55 arguments
= arguments_new
62 def send_tracker_error(self
, error_message
):
63 msg
= bencode({"failure reason" : error_message
})
67 class TrackerAnnounceHandler(TrackerBaseHandler
):
69 self
.set_header("Content-Type", "text/plain")
71 def get_ipv6_address(self
, default_port
):
72 # Get the external IP address of the client.
73 addr
= self
.get_remote_ip()
76 return addr
, default_port
79 ipv6
= self
.get_argument("ipv6", None)
83 m
= re
.match("^\[(.*)\]\:(\d)$", ipv6
)
85 ipv6
, port
= (m
.group(1), m
.group(2))
91 def get_ipv4_address(self
, default_port
):
92 # Get the external IP address of the client.
93 addr
= self
.get_remote_ip()
95 if addr
.startswith("172.28.1."):
96 addr
= "178.63.73.246"
99 return addr
, default_port
102 ipv4
= self
.get_argument("ipv4", None)
104 return ipv4
, default_port
106 ip
= self
.get_argument("ip", None)
108 return ip
, default_port
113 # Get the port and check it for sanity
114 port
= self
.get_argument("port", None)
119 if port
< 0 or port
> 65535:
121 except (TypeError, ValueError):
128 info_hash
= self
.get_hexencoded_argument("info_hash")
130 self
.send_tracker_error("Your client forgot to send your torrent's info_hash")
134 peer_id
= self
.get_hexencoded_argument("peer_id")
136 # Get the port and check it for sanity
137 port
= self
.get_port()
139 self
.send_tracker_error("Invalid port number or port number missing")
142 addr_ipv6
, port_ipv6
= self
.get_ipv6_address(port
)
143 addr_ipv4
, port_ipv4
= self
.get_ipv4_address(port
)
146 event
= self
.get_argument("event", None)
148 if not event
in ("started", "stopped", "completed"):
149 self
.send_tracker_error("Got unknown event")
152 self
.tracker
.handle_event(event
, peer_id
, info_hash
)
154 if event
== "stopped":
158 "address6" : addr_ipv6
,
160 "address4" : addr_ipv4
,
162 "downloaded" : self
.get_argument("downloaded", 0),
163 "uploaded" : self
.get_argument("uploaded", 0),
164 "left_data" : self
.get_argument("left", 0),
167 self
.tracker
.update_peer(peer_id
, info_hash
, **peer_info
)
169 no_peer_id
= self
.get_argument("no_peer_id", False)
170 numwant
= self
.get_argument("numwant", self
.tracker
.numwant
)
172 peers
= self
.tracker
.get_peers(info_hash
, limit
=numwant
, no_peer_id
=no_peer_id
)
175 "tracker id" : self
.tracker
.tracker_id
,
176 "interval" : self
.tracker
.interval
,
177 "min interval" : self
.tracker
.min_interval
,
179 "complete" : self
.tracker
.complete(info_hash
),
180 "incomplete" : self
.tracker
.incomplete(info_hash
),
182 self
.finish(response
)
186 Cleanup after every request.
188 self
.tracker
.cleanup_peers()
191 class TrackerScrapeHandler(TrackerBaseHandler
):
193 info_hashes
= self
.get_hexencoded_argument("info_hash", all
=True)
195 response
= self
.tracker
.scrape(info_hashes
)
197 self
.finish(bencode(response
))